commit

DataFusion/res/config.properties

@@ -3,5 +3,10 @@ jdbcUrl_connected  = jdbc:sqlserver://192.160.253.176:1433;DatabaseName=QiHIS
 #jdbcUrl_connected  = jdbc:oracle:thin:@192.168.100.4:1521:pacs
 user_connected 	   = his
 password_connected = his
+
+jdbcUrl_local  = jdbc:mysql://127.0.0.1:3306/pacsonline
+#jdbcUrl_connected  = jdbc:oracle:thin:@192.168.100.4:1521:pacs
+user_local 	   = zskk
+password_local = Zskk_2022
 #DATA-Parms
 institution_id     = 27400005

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

@@ -18,6 +18,7 @@ import com.jfinal.template.Engine;
 import com.zskk.control.ViewController;
 import com.zskk.service.ServiceFactory;
 import com.zskk.task.DataTask;
+import com.zskk.task.USInfoTask;
 import com.zskk.task.UpdateTask;
 
 public class ZskkConfig extends JFinalConfig {
@@ -61,21 +62,37 @@ public class ZskkConfig extends JFinalConfig {
 
 		return new DruidPlugin(PropKit.get("jdbcUrl_connected"), PropKit.get("user_connected"),PropKit.get("password_connected").trim());
 	}
+	
+	public static DruidPlugin createLocalDruidPlugin() {
+
+		return new DruidPlugin(PropKit.get("jdbcUrl_local"), PropKit.get("user_local"),PropKit.get("password_local").trim());
+	}
 
 	@Override
 	public void configPlugin(Plugins me) {
 		// 配置数据库连接池插件
 		DruidPlugin druidPluginConnected = createConnectedDruidPlugin();
 		me.add(druidPluginConnected);
+		
+		DruidPlugin druidPluginLocal = createLocalDruidPlugin();
+		me.add(druidPluginConnected);
 
 		// 配置ActiveRecord插件
 		ActiveRecordPlugin arpConnected = new ActiveRecordPlugin("connected", druidPluginConnected);
 		arpConnected.setDialect(new SqlServerDialect());
 		me.add(arpConnected);
+		
+		ActiveRecordPlugin arpLocal = new ActiveRecordPlugin("local", druidPluginLocal);
+		arpLocal.setDialect(new MysqlDialect());
+		me.add(arpLocal);
 
 		Cron4jPlugin cpData = new Cron4jPlugin();
 		cpData.addTask("*/2 * * * *", new UpdateTask());
 		me.add(cpData);
+		
+		Cron4jPlugin usData = new Cron4jPlugin();
+		usData.addTask("*/2 * * * *", new USInfoTask());
+		me.add(usData);
 	}
 
 	@Override

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

@@ -0,0 +1,93 @@
+package com.zskk.task;
+
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.jfinal.plugin.activerecord.Db;
+import com.jfinal.plugin.activerecord.Record;
+import com.jfinal.plugin.cron4j.ITask;
+import com.zskk.service.DataService;
+import com.zskk.service.ServiceFactory;
+import com.zskk.service.ThreadPoolService;
+
+public class USInfoTask implements ITask {
+
+	@Override
+	public void run() {
+		// TODO Auto-generated method stub
+		
+		List<Record> records = Db.use("connected").find("select * from View_PACS where CHECK_TYPE='US1'");
+		for (Record rd : records) {
+			Record	recordfind =Db.use("local").findFirst("select * from View_PACS where HISID=? and PARTOFCHECK=? and LODGEDATE=?",rd.getStr("HISID"),rd.getStr("PARTOFCHECK"),rd.getStr("LODGEDATE"));
+			if(recordfind !=null)
+			{
+				continue;
+			}
+			Record	record =new Record();
+			record.set("HISID", rd.getStr("HISID")==null?"":rd.getStr("HISID"));
+			record.set("INPATIENTNO", rd.getStr("INPATIENTNO")==null?"":rd.getStr("INPATIENTNO"));
+			record.set("LODGENO", rd.getStr("LODGENO")==null?"":rd.getStr("LODGENO"));
+			record.set("NAME", rd.getStr("NAME")==null?"":rd.getStr("NAME"));
+			record.set("SEX", rd.getStr("SEX")==null?"":rd.getStr("SEX"));
+			record.set("BIRTHDATE", rd.getStr("BIRTHDATE")==null?"":rd.getStr("BIRTHDATE"));
+			record.set("LODGESECTION", rd.getStr("LODGESECTION")==null?"":rd.getStr("LODGESECTION"));
+			record.set("LODGEDOCTOR", rd.getStr("LODGEDOCTOR")==null?"":rd.getStr("LODGEDOCTOR"));
+			record.set("AGE", rd.getStr("AGE")==null?"":rd.getStr("AGE"));
+			record.set("CHECK_TYPE", rd.getStr("CHECK_TYPE")==null?"":rd.getStr("CHECK_TYPE"));
+			record.set("PARTOFCHECK", rd.getStr("PARTOFCHECK")==null?"":rd.getStr("PARTOFCHECK"));
+			record.set("DIRECTION", rd.getStr("DIRECTION")==null?"":rd.getStr("DIRECTION"));
+			record.set("ADDRESS", rd.getStr("ADDRESS")==null?"":rd.getStr("ADDRESS"));
+			record.set("RACE", rd.getStr("RACE")==null?"":rd.getStr("RACE"));
+			record.set("PROFESSION", rd.getStr("PROFESSION")==null?"":rd.getStr("PROFESSION"));
+			record.set("MARITALSTATUS", rd.getStr("MARITALSTATUS")==null?"":rd.getStr("MARITALSTATUS"));
+			record.set("TELEPHONE", "");
+			record.set("DEGREE", rd.getStr("DEGREE")==null?"":rd.getStr("DEGREE"));
+			record.set("LODGEDATE", rd.getStr("LODGEDATE")==null?"":rd.getStr("LODGEDATE"));
+			record.set("BEDNO", rd.getStr("BEDNO")==null?"":rd.getStr("BEDNO"));
+			record.set("TIMES", rd.getStr("TIMES")==null?"":rd.getStr("TIMES"));
+			record.set("zyh", rd.getStr("zyh")==null?"":rd.getStr("zyh"));
+			record.set("cwh", rd.getStr("cwh")==null?"":rd.getStr("cwh"));
+			Db.use("local").save("View_PACS", record);
+
+		}
+		
+		
+	}
+
+	@Override
+	public void stop() {
+		// TODO Auto-generated method stub
+
+	}
+	
+	/**
+	 * 日期字符串格式转换
+	 * @param dateStr
+	 * @return
+	 */
+	private String parseStringToDate(String dateStr) {
+		if (dateStr == null) {
+			return "";
+		}
+		SimpleDateFormat sdf= new SimpleDateFormat("yyyy.MM.dd HH:mm:ss");
+	    Date date = null;
+	    String timeString = null;
+		try {
+			date = sdf.parse(dateStr);
+			SimpleDateFormat sdf2= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+			timeString = sdf2.format(date);
+		} catch (ParseException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+        return timeString;
+	}
+
+}