Przeglądaj źródła

增加就诊号

刘韬 5 lat temu
rodzic
commit
3d7a2ff0b9

+ 4 - 3
DataFusion/src/com/zskk/config/ZskkConfig.java

@@ -17,6 +17,7 @@ import com.zskk.service.ServiceFactory;
 import com.zskk.control.ViewController;
 import com.zskk.model._MappingKit;
 import com.zskk.task.DataTask;
+import com.zskk.task.UpdateTask;
 
 public class ZskkConfig extends JFinalConfig {
 	
@@ -82,9 +83,9 @@ public class ZskkConfig extends JFinalConfig {
 		cpData.addTask("*/5 * * * *", new DataTask());
 		me.add(cpData);
 
-//		Cron4jPlugin cp2 = new Cron4jPlugin();
-//		cp2.addTask("*/3 * * * *", new SyncTask2());
-//	me.add(cp2);
+		Cron4jPlugin cp2 = new Cron4jPlugin();
+		cp2.addTask("*/30 * * * *", new UpdateTask());
+	    me.add(cp2);
 	}
 
 	@Override

+ 2 - 0
DataFusion/src/com/zskk/task/DataTask.java

@@ -119,6 +119,8 @@ public class DataTask implements ITask {
 					data.put("confirm_doctor_id", record.getStr("reviewdoctor"));
 					// 确认医生姓名
 					data.put("confirm_doctor_name", record.getStr("reviewdoctor"));
+					data.put("patient_no", record.getStr("patientid"));
+
 
 					ThreadPoolService tService = new com.zskk.service.ThreadPoolService();
 					tService.execute(() -> {

+ 20 - 0
DataFusion/src/com/zskk/task/UpdateTask.java

@@ -1,12 +1,32 @@
 package com.zskk.task;
 
+import java.util.List;
+
+import com.jfinal.plugin.activerecord.Db;
+import com.jfinal.plugin.activerecord.Record;
 import com.jfinal.plugin.cron4j.ITask;
+import com.zskk.model.Exams;
 
 public class UpdateTask implements ITask {
 
 	@Override
 	public void run() {
 		// TODO Auto-generated method stub
+		List<Exams> exams = Exams.dao.use("zskk").find(
+				"SELECT * FROM pacsonline.exams where exam_status=9 and institution_id=15700002 order by createdAt desc limit 50");
+		for (Exams exams2 : exams) {
+			try {
+				Record record = Db.use("connected").findFirst("select * from zskk where accessionNumber=?",
+						exams2.getPatientNum());
+				if (record == null) {
+					continue;
+				}
+				exams2.setHopitalizedNo(record.getStr("patientid"));
+				exams2.update();
+			}catch (Exception e) {
+				// TODO: handle exception
+			}
+		}
 
 	}