diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/JdbcUtil.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/JdbcUtil.java index 7d6c286..6d8111c 100644 --- a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/JdbcUtil.java +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/JdbcUtil.java @@ -176,7 +176,7 @@ public class JdbcUtil { } - public static void syncPatientData(String hospitalId) + public static void syncPatientData(String hospitalId,MongoTemplate mongoTemplate) { int num = 1; @@ -186,7 +186,7 @@ public class JdbcUtil { "(select replace(mp.P_NO,'-','') as PID,mp.*,p_birthday,p_name,floor((trunc(sysdate) - trunc(mp.P_LASTMENSTRUALPERIOD)+1) /7) as weeks from MOMMY_PATIENT mp left join Plat_Patient pp" + " on mp.p_platpatientid=pp.p_id where mp.p_hospitalid = '" + hospitalId + "') A WHERE ROWNUM < "+(num+20)+" and weeks < 42) WHERE RN >= "+num+" "); num=num+20; - MongoTemplate mongoTemplate = getMongoTemplate(); +// MongoTemplate mongoTemplate = getMongoTemplate(); for (Map map : list) { Patients patients = new Patients(); @@ -896,7 +896,7 @@ public class JdbcUtil { return dat1a; } - public static void syncBabyData(String hospitalId) { + public static void syncBabyData(String hospitalId,MongoTemplate mongoTemplate) { int num = 1; @@ -910,7 +910,7 @@ public class JdbcUtil { " A WHERE ROWNUM < "+(num+20)+" ) WHERE RN >= "+num+" "); num = num+20; - MongoTemplate mongoTemplate = getMongoTemplate(); +// MongoTemplate mongoTemplate = getMongoTemplate(); for (Map map : list) { @@ -1398,10 +1398,10 @@ public class JdbcUtil { } } - public static void syncData(String hid) + public void syncData(String hid,MongoTemplate mongoTemplate) { - syncBabyData(hid); - syncPatientData(hid); + syncBabyData(hid,mongoTemplate); + syncPatientData(hid,mongoTemplate); } public static void main(String[] args) @@ -1415,7 +1415,7 @@ public class JdbcUtil { // System.out.print(list); // DBCollection conn = template.getCollection("lyms_patient_test"); // conn.up - syncBabyData("62"); - syncPatientData("62"); +// syncBabyData("62"); +// syncPatientData("62"); } } diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java index a522c42..7f7827c 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java @@ -1,6 +1,8 @@ package com.lyms.platform.operate.web.controller; import com.lyms.platform.operate.web.utils.JdbcUtil; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; @@ -19,6 +21,9 @@ import java.util.Map; @Controller public class TestController { + + @Autowired + private MongoTemplate mongoTemplate; /** * 获取科室 */ @@ -91,9 +96,19 @@ public class TestController { @RequestMapping(value = "/syncData", method = RequestMethod.GET) - public void syncData( @RequestParam(required = true) String hid) { - System.out.print("同步开始>>>>>>>>>>>>>>>>>>>>>>>>>"); - com.lyms.platform.biz.JdbcUtil.syncData(hid); - System.out.print("同步结束>>>>>>>>>>>>>>>>>>>>>>>>>"); + public void syncData( @RequestParam(required = true) final String hid) { + + final MongoTemplate template = mongoTemplate; + + new Thread(new Runnable() { + @Override + public void run() { + System.out.print("同步开始>>>>>>>>>>>>>>>>>>>>>>>>>"); + new com.lyms.platform.biz.JdbcUtil().syncData(hid, template); + System.out.print("同步结束>>>>>>>>>>>>>>>>>>>>>>>>>"); + } + }).start(); + + } }