commit

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

@@ -9,7 +9,7 @@ import com.jfinal.config.Routes;
 import com.jfinal.kit.PropKit;
 import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
 import com.jfinal.plugin.activerecord.dialect.MysqlDialect;
-import com.jfinal.plugin.activerecord.dialect.OracleDialect;
+//import com.jfinal.plugin.activerecord.dialect.OracleDialect;
 import com.jfinal.plugin.activerecord.dialect.SqlServerDialect;
 import com.jfinal.plugin.cron4j.Cron4jPlugin;
 import com.jfinal.plugin.druid.DruidPlugin;
@@ -79,9 +79,9 @@ public class ZskkConfig extends JFinalConfig {
 		arpConnected.setDialect(new SqlServerDialect());
 		me.add(arpConnected);
 		
-//		Cron4jPlugin cpData = new Cron4jPlugin();
-//		cpData.addTask("*/25 * * * *", new DataTask());
-//		me.add(cpData);
+		Cron4jPlugin cpData = new Cron4jPlugin();
+		cpData.addTask("*/25 * * * *", new DataTask());
+		me.add(cpData);
 
 //		Cron4jPlugin cp2 = new Cron4jPlugin();
 //		cp2.addTask("*/3 * * * *", new SyncTask2());

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

@@ -22,33 +22,33 @@ public class DataTask implements ITask {
 	public void run() {
 		// TODO Auto-generated method stub
 		try {
-			List<Exams> exams = Exams.dao.use("zskk").find("SELECT * FROM pacsonline.exams where exam_status=3 and institution_id=01600001 order by createdAt desc limit 20");
+			List<Exams> exams = Exams.dao.use("zskk").find("SELECT * FROM pacsonline.exams where exam_status=3 and institution_id=02800001 order by createdAt desc limit 20");
 			for (Exams exams2 : exams) {
-				Studies studies = Studies.dao.use("zskk").findById(exams2.getStudyId());
-				Record record = Db.use("connected").findFirst("select * from viewname where STUDYUID=?",studies.getStudyuid());
+//				Studies studies = Studies.dao.use("zskk").findById(exams2.getStudyId());
+				Record record = Db.use("connected").findFirst("select * from viewname where accessionNumber=?",exams2.getAccessionNum());
 				if (record == null) {
 					continue;
 				}
 				Report report = new Report().use("zskk");
 				report.setId(creatId());
-				report.setReportDatetime(parseStringToDate(record.getStr("REPORTDATE")));
-				if (record.getStr("IMPRESSION") == null && record.getStr("DESCRIPTION") == null) {
+				report.setReportDatetime(parseStringToDate(record.getStr("reportdate")));
+				if (record.getStr("diagnosis") == null && record.getStr("description") == null) {
 					continue;
 				}
-				report.setImpression(record.getStr("DESCRIPTION"));
-				report.setDescription(record.getStr("IMPRESSION"));
+				report.setImpression(record.getStr("diagnosis"));
+				report.setDescription(record.getStr("description"));
 				report.setExamId(exams2.getId());
 				report.setCreatedAt(new Date());
-				report.setReportDoctorId(getDoctorIdByName(record.getStr("REPORTDOCTOR")));
-				report.setReviewDoctorId(getDoctorIdByName(record.getStr("REVIEWDOCTOR")));
-				report.setReviewDatetime(parseStringToDate(record.getStr("REPORTDATE")));
-				report.setConfirmDoctorId(getDoctorIdByName(record.getStr("REVIEWDOCTOR")));
-				report.setConfirmDatetime(parseStringToDate(record.getStr("REPORTDATE")));
+				report.setReportDoctorId(getDoctorIdByName(record.getStr("reportdoctor")));
+				report.setReviewDoctorId(getDoctorIdByName(record.getStr("reportdoctor")));
+				report.setReviewDatetime(parseStringToDate(record.getStr("reportdate")));
+				report.setConfirmDoctorId(getDoctorIdByName(record.getStr("reportdoctor")));
+				report.setConfirmDatetime(parseStringToDate(record.getStr("reportdate")));
 				report.save();
 				PatientInfos patientInfos = PatientInfos.dao.use("zskk").findById(exams2.getPatientId());
-				patientInfos.setName(record.getStr("PATIENTNAME"));
-				patientInfos.setPhone(record.getStr("PHONE"));
-				patientInfos.setCardNum(record.getStr("IDCARD"));
+				patientInfos.setName(record.getStr("patientname"));
+//				patientInfos.setPhone(record.getStr("PHONE"));
+//				patientInfos.setCardNum(record.getStr("IDCARD"));
 				patientInfos.update();
 				exams2.setExamStatus(9);
 				exams2.update();
@@ -70,7 +70,7 @@ public class DataTask implements ITask {
 	
 	private String creatId() {
 		UUID id=UUID.randomUUID();
-        String[] idd= id.toString().split("-");
+        String[] idd =id.toString().split("-");
         return idd[0]+idd[1]+idd[2];
 	}