From abe394b44da8d5e3eb187e97697fe2193dc80521 Mon Sep 17 00:00:00 2001 From: liquanyu Date: Thu, 20 Jul 2017 09:40:42 +0800 Subject: [PATCH] update code --- .../java/com/lyms/platform/sync/data/service/SyncDataService.java | 4 ++-- .../src/main/java/com/lyms/platform/sync/data/util/DataUtil.java | 4 ++-- .../src/main/java/com/lyms/platform/sync/data/util/JDBCUtil.java | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/platform-sync-data/src/main/java/com/lyms/platform/sync/data/service/SyncDataService.java b/platform-sync-data/src/main/java/com/lyms/platform/sync/data/service/SyncDataService.java index 984183d..6ee4b32 100644 --- a/platform-sync-data/src/main/java/com/lyms/platform/sync/data/service/SyncDataService.java +++ b/platform-sync-data/src/main/java/com/lyms/platform/sync/data/service/SyncDataService.java @@ -174,7 +174,7 @@ public class SyncDataService { public void syncBabyData(String oracleHid, Integer mysqlHid) { - DataUtil.initData(mysqlHid); + DataUtil.initData(mysqlHid,oracleHid); initBabyGuides(); new workerBaby(oracleHid).start(); } @@ -215,7 +215,7 @@ public class SyncDataService { public void syncPatientData(String oracleHid,Integer mysqlHid) { //初始化数据 - DataUtil.initData(mysqlHid); + DataUtil.initData(mysqlHid,oracleHid); String sql = "select replace(mp.P_NO,'-','') as PID,mp.*,p_birthday,p_name,floor((trunc(sysdate) - trunc(mp.P_LASTMENSTRUALPERIOD)+1) /7) as weeks,vc.VC_CARDNO from MOMMY_PATIENT mp left join Plat_Patient pp " + " on mp.p_platpatientid=pp.p_id left join (select max(VC_OPERTIME) as OPERTIME,VC_CARDNO,VC_PATIENTNO from MOMMY_VISITCARD group by VC_CARDNO,VC_PATIENTNO) vc on vc.VC_PATIENTNO = mp.P_NO " + diff --git a/platform-sync-data/src/main/java/com/lyms/platform/sync/data/util/DataUtil.java b/platform-sync-data/src/main/java/com/lyms/platform/sync/data/util/DataUtil.java index 17c26d2..3713c7b 100644 --- a/platform-sync-data/src/main/java/com/lyms/platform/sync/data/util/DataUtil.java +++ b/platform-sync-data/src/main/java/com/lyms/platform/sync/data/util/DataUtil.java @@ -18,9 +18,9 @@ public class DataUtil { private static Integer orgId = 0; - public static void initData(Integer mysqlHid) { + public static void initData(Integer mysqlHid,String oracleHid) { orgId = mysqlHid; - List> listEmp = JDBCUtil.getOracleListDataBySql("select e.e_name,e.e_id from mommy_employee e"); + List> listEmp = JDBCUtil.getOracleListDataBySql("select e.e_name,e.e_id from mommy_employee e where e.e_hospitalid = '" + oracleHid+"'"); for (Map map : listEmp) { employees.put(getString(map.get("E_ID")), getString(map.get("E_NAME"))); } diff --git a/platform-sync-data/src/main/java/com/lyms/platform/sync/data/util/JDBCUtil.java b/platform-sync-data/src/main/java/com/lyms/platform/sync/data/util/JDBCUtil.java index 26bbcb8..1f72e4a 100644 --- a/platform-sync-data/src/main/java/com/lyms/platform/sync/data/util/JDBCUtil.java +++ b/platform-sync-data/src/main/java/com/lyms/platform/sync/data/util/JDBCUtil.java @@ -43,7 +43,7 @@ public class JDBCUtil { Connection con = null; try { Class.forName("com.mysql.jdbc.Driver"); - String url = "jdbc:mysql://192.168.1.26:3306/sync_platform?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8"; + String url = "jdbc:mysql://192.168.1.39:3306/platform?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8"; String userName = "platform"; String pwd = "platform123"; con = DriverManager.getConnection(url, userName, pwd); -- 1.8.3.1