LAPTOP-5NTQJPUS\LT 1 month ago
parent
commit
39c5e96dd7

+ 3 - 3
DataFusion/res/config.properties

@@ -1,8 +1,8 @@
 #DB-connected partners
 #jdbcUrl_connected  = jdbc:sqlserver://192.168.17.58:1433;DatabaseName=visionpacs
-jdbcUrl_connected  = jdbc:mysql://10.167.10.55:3306/gecris?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull
-user_connected 	   = cloud
-password_connected = cloud
+jdbcUrl_connected  = jdbc:oracle:thin:@192.168.204.17:9897:YIDANHIS
+user_connected 	   = lispacsyun
+password_connected = lispacsyun123
 
 #DB-connected partners
 jdbcUrl_print  = jdbc:sqlserver://200.200.200.163:1433;DatabaseName=DICOMSOFT

+ 5 - 5
DataFusion/src/com/zskk/config/ZskkConfig.java

@@ -82,7 +82,7 @@ public class ZskkConfig extends JFinalConfig {
 
 		// 配置ActiveRecord插件
 		ActiveRecordPlugin arpConnected = new ActiveRecordPlugin("connected", druidPluginConnected);
-		arpConnected.setDialect(new MysqlDialect());
+		arpConnected.setDialect(new OracleDialect());
 		me.add(arpConnected);
 		
 //		// 配置数据库连接池插件
@@ -109,10 +109,10 @@ public class ZskkConfig extends JFinalConfig {
 		pifData.addTask("*/7 * * * *", new JCBGTask());
 		me.add(pifData);
 		
-//		//上传检验信息
-//	    Cron4jPlugin bdData = new Cron4jPlugin();
-//	    bdData.addTask("*/9 * * * *", new JYTask());
-//		me.add(bdData);
+		//上传检验信息
+	    Cron4jPlugin bdData = new Cron4jPlugin();
+	    bdData.addTask("*/9 * * * *", new JYTask());
+		me.add(bdData);
 //		
 //		//将打印png上传云端
 //	    Cron4jPlugin prData = new Cron4jPlugin();

+ 1 - 1
DataFusion/src/com/zskk/control/ViewController.java

@@ -92,7 +92,7 @@ public class ViewController extends Controller {
             druidPluginConnected.start();
 			// 配置ActiveRecord插件
 			ActiveRecordPlugin arpConnected = new ActiveRecordPlugin("connected", druidPluginConnected);
-			arpConnected.setDialect(new MysqlDialect());
+			arpConnected.setDialect(new OracleDialect());
 			arpConnected.start();
 
 		} catch (Exception e) {

+ 48 - 48
DataFusion/src/com/zskk/service/DataService.java

@@ -203,62 +203,62 @@ public class DataService {
 		JSONObject jsonObject = new JSONObject();
 		
 		JSONObject jsonObjectA = new JSONObject();
-		jsonObjectA.put("AA", checkStr(record.getStr("姓名")));
-		jsonObjectA.put("AB", checkStr(record.getStr("证件类型编码")));
-		jsonObjectA.put("AC", checkStr(record.getStr("证件号码")));
-		jsonObjectA.put("AD", checkStr(record.getStr("性别编码")));
-		jsonObjectA.put("AE", checkStr(record.getStr("出生日期")));
-		jsonObjectA.put("AF", checkStr(record.getStr("联系电话")));
-		jsonObjectA.put("AG", checkStr(record.getStr("电子健康卡号")));
+		jsonObjectA.put("AA", checkStr(record.getStr("AA")));
+		jsonObjectA.put("AB", checkStr(record.getStr("AB")));
+		jsonObjectA.put("AC", checkStr(record.getStr("AC")));
+		jsonObjectA.put("AD", checkStr(record.getStr("AD")));
+		jsonObjectA.put("AE", checkStr(record.getStr("AE")));
+		jsonObjectA.put("AF", checkStr(record.getStr("AF")));
+		jsonObjectA.put("AG", checkStr(record.getStr("AG")));
 
 		JSONObject jsonObjectB = new JSONObject();
-		jsonObjectB.put("BA", checkStr(record.getStr("就诊类型编码")));
-		jsonObjectB.put("BB", checkStr(record.getStr("就诊卡号")));
-		jsonObjectB.put("BC", checkStr(record.getStr("患者编号")));
-		jsonObjectB.put("BD", checkStr(record.getStr("就诊时间")));
-		jsonObjectB.put("BE", checkStr(record.getStr("就诊科室名称")));
-		jsonObjectB.put("BF", checkStr(record.getStr("申请医师名称")));
-		jsonObjectB.put("BG", checkStr(record.getStr("申请医生编码")));
-		jsonObjectB.put("BH", checkStr(record.getStr("主诉")));
-		jsonObjectB.put("BI", checkStr(record.getStr("年龄")));
-		jsonObjectB.put("BJ", "121403004061412685");
-		jsonObjectB.put("BK", "阳泉市第一人民医院");
-		jsonObjectB.put("BL", checkStr(record.getStr("临床诊断名称")));
-		jsonObjectB.put("BM", checkStr(record.getStr("临床诊断代码")));
+		jsonObjectB.put("BA", checkStr(record.getStr("BA")));
+		jsonObjectB.put("BB", checkStr(record.getStr("BB")));
+		jsonObjectB.put("BC", checkStr(record.getStr("BC")));
+		jsonObjectB.put("BD", checkStr(record.getStr("BD")));
+		jsonObjectB.put("BE", checkStr(record.getStr("BE")));
+		jsonObjectB.put("BF", checkStr(record.getStr("BF")));
+		jsonObjectB.put("BG", checkStr(record.getStr("BG")));
+		jsonObjectB.put("BH", checkStr(record.getStr("BH")));
+		jsonObjectB.put("BI", checkStr(record.getStr("BI")));
+		jsonObjectB.put("BJ", "12140300MB0006242M");
+		jsonObjectB.put("BK", "阳泉市第五人民医院(阳泉市精神病医院)");
+		jsonObjectB.put("BL", checkStr(record.getStr("BL")));
+		jsonObjectB.put("BM", checkStr(record.getStr("BM")));
 
 		JSONObject jsonObjectC = new JSONObject();
-		jsonObjectC.put("CA", checkStr(record.getStr("报告单编号")));
-		jsonObjectC.put("CB", checkStr(record.getStr("标本类型")));
-		jsonObjectC.put("CC", checkStr(record.getStr("检验项目名称")));
-		jsonObjectC.put("CD", checkStr(record.getStr("检测项目类型")));
-		jsonObjectC.put("CE", checkStr(record.getStr("报告医生姓名")));
-		jsonObjectC.put("CF", checkStr(record.getStr("报告医生编码")));
-		jsonObjectC.put("CG", checkStr(record.getStr("审核医师姓名")));
-		jsonObjectC.put("CH", checkStr(record.getStr("审核医师编码")));
-		jsonObjectC.put("CI", checkStr(record.getStr("报告科室名称")));
-		jsonObjectC.put("CJ", checkStr(record.getStr("报告评语")));
-		jsonObjectC.put("CK", checkStr(record.getStr("报告时间")));
-		jsonObjectC.put("CL", checkStr(record.getStr("互认项目编码")));
-		jsonObjectC.put("CM", checkStr(record.getStr("互认项目名称")));
-		jsonObjectC.put("CN", checkStr(record.getStr("报告单")));
+		jsonObjectC.put("CA", checkStr(record.getStr("CA")));
+		jsonObjectC.put("CB", checkStr(record.getStr("CB")));
+		jsonObjectC.put("CC", checkStr(record.getStr("CC")));
+		jsonObjectC.put("CD", checkStr(record.getStr("CD")));
+		jsonObjectC.put("CE", checkStr(record.getStr("CE")));
+		jsonObjectC.put("CF", checkStr(record.getStr("CF")));
+		jsonObjectC.put("CG", checkStr(record.getStr("CG")));
+		jsonObjectC.put("CH", checkStr(record.getStr("CH")));
+		jsonObjectC.put("CI", checkStr(record.getStr("CI")));
+		jsonObjectC.put("CJ", checkStr(record.getStr("CJ")));
+		jsonObjectC.put("CK", checkStr(record.getStr("CK")));
+		jsonObjectC.put("CL", checkStr(record.getStr("CL")));
+		jsonObjectC.put("CM", checkStr(record.getStr("CM")));
+		jsonObjectC.put("CN", checkStr(record.getStr("CN")));
 				
 		JSONArray jsonArrayD = new JSONArray();
 		for (Record itemrecord : items) {
 			JSONObject jsonObjectE = new JSONObject();
-			jsonObjectE.put("EA", checkStr(itemrecord.getStr("检验细项名称中文")));
-			jsonObjectE.put("EB", checkStr(itemrecord.getStr("检验细项缩写")));
-			jsonObjectE.put("EC", checkStr(itemrecord.getStr("检验细项序号")));
-			jsonObjectE.put("ED", checkStr(itemrecord.getStr("检验细项测量值")));
-			jsonObjectE.put("EE", checkStr(itemrecord.getStr("检验细项结果计量单位")));
-			jsonObjectE.put("EF", checkStr(itemrecord.getStr("检验细项结果")));
-			jsonObjectE.put("EG", checkStr(itemrecord.getStr("药敏结果")));
-			jsonObjectE.put("EH", checkStr(itemrecord.getStr("参考范围")));
-			jsonObjectE.put("EI", checkStr(itemrecord.getStr("检测方法")));
-			jsonObjectE.put("EJ", checkStr(itemrecord.getStr("KB")));
-			jsonObjectE.put("EK", checkStr(itemrecord.getStr("MIC")));
-			jsonObjectE.put("EL", checkStr(itemrecord.getStr("敏感度")));
-			jsonObjectE.put("EM", checkStr(itemrecord.getStr("互认项目编码")));
-			jsonObjectE.put("EN", checkStr(itemrecord.getStr("互认项目名称")));
+			jsonObjectE.put("EA", checkStr(itemrecord.getStr("EA")));
+			jsonObjectE.put("EB", checkStr(itemrecord.getStr("EB")));
+			jsonObjectE.put("EC", checkStr(itemrecord.getStr("EC")));
+			jsonObjectE.put("ED", checkStr(itemrecord.getStr("ED")));
+			jsonObjectE.put("EE", checkStr(itemrecord.getStr("EE")));
+			jsonObjectE.put("EF", checkStr(itemrecord.getStr("EF")));
+			jsonObjectE.put("EG", checkStr(itemrecord.getStr("EG")));
+			jsonObjectE.put("EH", checkStr(itemrecord.getStr("EH")));
+			jsonObjectE.put("EI", checkStr(itemrecord.getStr("EI")));
+			jsonObjectE.put("EJ", checkStr(itemrecord.getStr("EJ")));
+			jsonObjectE.put("EK", checkStr(itemrecord.getStr("EK")));
+			jsonObjectE.put("EL", checkStr(itemrecord.getStr("EL")));
+			jsonObjectE.put("EM", checkStr(itemrecord.getStr("EM")));
+			jsonObjectE.put("EN", checkStr(itemrecord.getStr("EN")));
 			jsonArrayD.add(jsonObjectE);
 		}
 		jsonObject.put("A", jsonObjectA);

+ 2 - 2
DataFusion/src/com/zskk/task/JYTask.java

@@ -24,9 +24,9 @@ public class JYTask implements ITask {
 		// TODO Auto-generated method stub
 		DataService dService = ServiceFactory.getService(DataService.class);
 
-		List<Record> records = Db.use("connected").find("select * from V_LAB_REPORT where 最后更新时间 > ?",parseStringToDate1());
+		List<Record> records = Db.use("connected").find("select * from V_LAB_REPORT where CZ > ?",parseStringToDate1());
 		for (Record record : records) {
-			List<Record> itemrecords = Db.use("connected").find("select * from V_LAB_ITEM where 报告单编号 = ?",record.getStr("报告单编号"));
+			List<Record> itemrecords = Db.use("connected").find("select * from V_LAB_ITEM where CA = ?",record.getStr("CA"));
 			dService.postLabReport(record,itemrecords);
 		}