对接pacs

DataFusion/src/com/zskk/config/ZskkConfig.java

@@ -8,13 +8,14 @@ import com.jfinal.config.Plugins;
 import com.jfinal.config.Routes;
 import com.jfinal.kit.PropKit;
 import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
-import com.jfinal.plugin.activerecord.dialect.AnsiSqlDialect;
 import com.jfinal.plugin.activerecord.dialect.MysqlDialect;
 import com.jfinal.plugin.activerecord.dialect.SqlServerDialect;
+import com.jfinal.plugin.cron4j.Cron4jPlugin;
 import com.jfinal.plugin.druid.DruidPlugin;
 import com.jfinal.template.Engine;
 import com.zskk.control.ViewController;
 import com.zskk.model._MappingKit;
+import com.zskk.task.DataTask;
 
 public class ZskkConfig extends JFinalConfig {
 
@@ -72,6 +73,14 @@ public class ZskkConfig extends JFinalConfig {
 		ActiveRecordPlugin arpConnected = new ActiveRecordPlugin("connected", druidPluginConnected);
 		arpConnected.setDialect(new SqlServerDialect());
 		me.add(arpConnected);
+		
+		Cron4jPlugin cpData = new Cron4jPlugin();
+		cpData.addTask("*/10 * * * *", new DataTask());
+		me.add(cpData);
+
+//		Cron4jPlugin cp2 = new Cron4jPlugin();
+//		cp2.addTask("*/3 * * * *", new SyncTask2());
+//	me.add(cp2);
 	}
 
 	@Override

DataFusion/src/com/zskk/task/DataTask.java

@@ -1,6 +1,13 @@
 package com.zskk.task;
 
+import java.util.Date;
+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.Reports;
+import com.zskk.model.Studies;
 
 public class DataTask implements ITask {
 
@@ -8,6 +15,46 @@ public class DataTask implements ITask {
 	public void run() {
 		// TODO Auto-generated method stub
 
+		List<Studies> studies = Studies.dao.use("zskk").find("select * from Studies where hospitalId = 74300001 order by createdAt desc limit 50");
+		for (Studies studies2 : studies) {
+
+			Reports reports = Reports.dao.use("zskk").findFirst("select * from Reports where hospitalNo=74300001 and studyuid=?",studies2.getStudyUid());
+			if (reports == null) {
+				Record record = Db.use("connected").findFirst("select * from caller where STUDYUID=?",studies2.getStudyUid());
+				if (record == null ) {
+					continue;
+				}
+				Reports newreport = new Reports().use("zskk");
+				newreport.setTitle("定西市中医院");
+				newreport.setSubtitle(record.getStr("modality")==null?"":record.getStr("modality") + "诊断报告单");
+				newreport.setReportDoctor(record.getStr("reportdoctor")==null?"定西市中医院":record.getStr("reportdoctor"));
+				newreport.setImpression(record.getStr("impression")==null?"暂未出具":record.getStr("impression"));
+				newreport.setDescription(record.getStr("description")==null?"暂未出具":record.getStr("description"));
+				newreport.setHospitalNo("74300001");
+				newreport.setPatientName(record.getStr("patientName")==null?"无":record.getStr("patientName"));
+				newreport.setExamClass(record.getStr("modality")==null?record.getStr("modality"):record.getStr("modality"));
+				//newreport.setExamItem(record.getStr("FITEM_CH_NAME")==null?"无":record.getStr("FITEM_CH_NAME"));
+				newreport.setStatus(1);
+				newreport.setStudyuid(studies2.getStudyUid());
+				newreport.setExamNo(record.getStr("patientID")==null?"无":record.getStr("patientID"));
+				newreport.setStudyid(studies2.getAccessionNumber());
+				newreport.setCreatedAt(new Date());
+				newreport.setUpdatedAt(new Date());
+				newreport.setStudyKey(studies2.getStudyKey());
+				newreport.setDid(1);
+				newreport.setPatientid(record.getStr("patientID")==null?"无":record.getStr("patientID"));
+				newreport.setPatientSex(record.getStr("genderID")==null?"未设置":record.getStr("genderID"));
+				newreport.setPatientAge(record.getStr("patientage"));
+				newreport.setExamDateTime(record.getStr("reportDate")==null?"未设置":record.getStr("reportDate"));
+				newreport.setReportDateTime(record.getStr("reportDate")==null?"未设置":record.getStr("reportDate"));
+				newreport.setPhone(record.getStr("phone")==null?"未设置":record.getStr("phone"));
+				newreport.save();
+				studies2.setModality(record.getStr("modality")==null?record.getStr("modality"):record.getStr("modality"));
+				studies2.update();
+			}else {
+				continue;
+			}
+		}
 	}
 
 	@Override