From bc715618eb64d62a6a4bd8f9eaf6cc1152e295cb Mon Sep 17 00:00:00 2001 From: liquanyu Date: Wed, 16 Nov 2016 16:46:37 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BB=BA=E6=A1=A3=E9=A2=84=E4=BA=A7=E6=9C=9F?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../job/index/service/SyncDataService.java | 4 +- .../operate/web/controller/TestController.java | 91 +++++++++++++++------- 2 files changed, 67 insertions(+), 28 deletions(-) diff --git a/platform-job-index/src/main/java/com/lyms/platform/job/index/service/SyncDataService.java b/platform-job-index/src/main/java/com/lyms/platform/job/index/service/SyncDataService.java index 316b8c9..846626c 100644 --- a/platform-job-index/src/main/java/com/lyms/platform/job/index/service/SyncDataService.java +++ b/platform-job-index/src/main/java/com/lyms/platform/job/index/service/SyncDataService.java @@ -320,7 +320,9 @@ public class SyncDataService { type = 3; } - patients.setDueDate(DateUtil.addDay(DataUtil.getDate(map.get("P_LASTMENSTRUALPERIOD")), 42 * 7)); + Date dueDate = DateUtil.addDay(DateUtil.addMonth(DataUtil.getDate(map.get("P_LASTMENSTRUALPERIOD")), 9), 7); + + patients.setDueDate(dueDate); person.setCreated(new Date()); person.setId(String.valueOf(map.get("PID"))); 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 9e7a1fc..b0ca5b0 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 @@ -4,9 +4,14 @@ import com.lyms.hospitalapi.qhdfy.QhdfyHisService; import com.lyms.platform.biz.JdbcUtil; import com.lyms.platform.biz.service.AssayConfigService; import com.lyms.platform.biz.service.PatientsService; +import com.lyms.platform.common.enums.YnEnums; +import com.lyms.platform.common.utils.DateUtil; import com.lyms.platform.common.utils.JsonUtil; import com.lyms.platform.operate.web.service.SyncDataTaskService; import com.lyms.platform.pojo.AssayConfig; +import com.lyms.platform.pojo.Patients; +import com.lyms.platform.query.PatientsQuery; +import org.apache.commons.collections.CollectionUtils; import org.apache.commons.io.FileUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.mongodb.core.MongoTemplate; @@ -18,10 +23,8 @@ import org.springframework.web.bind.annotation.ResponseBody; import java.io.File; import java.io.IOException; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.text.CollationElementIterator; +import java.util.*; /** * Created by Zhang.Rui on 2016/4/8. @@ -114,29 +117,29 @@ public class TestController { } - @RequestMapping(value = "/syncData", method = RequestMethod.GET) - @ResponseBody - public String syncData(@RequestParam(required = true) final String oracleHid,@RequestParam(required = true) final Integer mysqlHid) { - final MongoTemplate template = mongoTemplate; - - JdbcUtil.initData(mysqlHid); - System.out.println("initData------"); - - new Thread(new Runnable() { - @Override - public void run() { - System.out.print("同步开始儿童>>>>>>>>>>>>>>>>>>>>>>>>>"); - JdbcUtil.syncDataBaby(oracleHid, template); - System.out.print("同步结束儿童>>>>>>>>>>>>>>>>>>>>>>>>>"); - } - }).start(); - - -// System.out.println("同步开始孕妇1>>>>>>>>>>>>>>>>>>>>>>>>>"); -// JdbcUtil.syncDataPat(oracleHid, template); -// System.out.println("同步结束孕妇1>>>>>>>>>>>>>>>>>>>>>>>>>"); - return "starting..........."; - } +// @RequestMapping(value = "/syncData", method = RequestMethod.GET) +// @ResponseBody +// public String syncData(@RequestParam(required = true) final String oracleHid,@RequestParam(required = true) final Integer mysqlHid) { +// final MongoTemplate template = mongoTemplate; +// +// JdbcUtil.initData(mysqlHid); +// System.out.println("initData------"); +// +// new Thread(new Runnable() { +// @Override +// public void run() { +// System.out.print("同步开始儿童>>>>>>>>>>>>>>>>>>>>>>>>>"); +// JdbcUtil.syncDataBaby(oracleHid, template); +// System.out.print("同步结束儿童>>>>>>>>>>>>>>>>>>>>>>>>>"); +// } +// }).start(); +// +// +//// System.out.println("同步开始孕妇1>>>>>>>>>>>>>>>>>>>>>>>>>"); +//// JdbcUtil.syncDataPat(oracleHid, template); +//// System.out.println("同步结束孕妇1>>>>>>>>>>>>>>>>>>>>>>>>>"); +// return "starting..........."; +// } @RequestMapping(value = "/addSieveJob", method = RequestMethod.GET) @@ -231,4 +234,38 @@ public class TestController { return "syncQhdSieve finish"; } + /** + * 更新医院的孕妇的建档的预产期 + * @param hospitalId + * @return + */ + @RequestMapping(value = "/updateDueDate", method = RequestMethod.GET) + @ResponseBody + public String updateDueDate(@RequestParam(required = true) String hospitalId) { + PatientsQuery patientsQuery1 = new PatientsQuery(); + patientsQuery1.setYn(YnEnums.YES.getId()); + patientsQuery1.setHospitalId(hospitalId); + List pats = patientsService.queryPatient(patientsQuery1); + if (CollectionUtils.isNotEmpty(pats)) + { + for (Patients pat : pats) + { + if (pat != null && pat.getLastMenses() != null) + { + Date dueDate = DateUtil.addDay(DateUtil.addMonth(pat.getLastMenses(), 9), 7); + if (!DateUtil.getyyyy_MM_dd(dueDate).equals(DateUtil.getyyyy_MM_dd(pat.getDueDate()))) + { + System.out.println(pat.getPhone()); + pat.setDueDate(dueDate); + patientsService.updatePatient(pat); + } + + } + + } + } + + return "update finish"; + } + } -- 1.8.3.1