From 4e0f11f0344797e8500844526dade937641bcd4b Mon Sep 17 00:00:00 2001 From: liquanyu Date: Tue, 17 Jan 2017 11:15:25 +0800 Subject: [PATCH] update code --- .../com/lyms/hospitalapi/qhdfy/QhdfyFmService.java | 23 +++++++++++++++------- .../operate/web/controller/TestController.java | 14 +++++++++++++ 2 files changed, 30 insertions(+), 7 deletions(-) diff --git a/platform-operate-api/src/main/java/com/lyms/hospitalapi/qhdfy/QhdfyFmService.java b/platform-operate-api/src/main/java/com/lyms/hospitalapi/qhdfy/QhdfyFmService.java index bbec843..b52c43e 100644 --- a/platform-operate-api/src/main/java/com/lyms/hospitalapi/qhdfy/QhdfyFmService.java +++ b/platform-operate-api/src/main/java/com/lyms/hospitalapi/qhdfy/QhdfyFmService.java @@ -55,6 +55,12 @@ public class QhdfyFmService { queryFmPatient(startStr, endStr); } + public void syncWorker(String startStr,String endStr) { + System.out.println("sync start="+startStr+"end="+endStr); + ExceptionUtils.catchException("start="+startStr+"end="+endStr); + queryFmPatient(startStr, endStr); + } + public void queryFmPatient(String start,String end) { @@ -104,10 +110,12 @@ public class QhdfyFmService { " and SYXH not in (select SYXH from JHMK_FMJL where JSZ is not null and SC is not null and TZ is not null and YFZ is not null and SH is not null" + " and (SFFZRSTDT = ' 是 ' or SFSTDT = ' 是 '))"; List list = queryRunner.query(conn, sql, new BeanListHandler(FmItem.class)); - ExceptionUtils.catchException("size=" + list.size()); + ExceptionUtils.catchException("size====" + list.size()); + ExceptionUtils.catchException("sql===" + sql); if (CollectionUtils.isNotEmpty(list)) { for (FmItem item : list) { try { + ExceptionUtils.catchException("item===" + item); String dueDateStr = item.getSsrq(); if (!StringUtils.isNotEmpty(dueDateStr)) { continue; @@ -196,7 +204,7 @@ public class QhdfyFmService { as.put("pf5", item.getWfz()); as.put("pf10", item.getSfz()); baby.setApgarScore(JsonUtil.obj2JsonString(as)); - baby.setBabyGender(" 男 ".equals(item.getYexb()) ? "1" : "0"); + baby.setBabyGender("男".equals(item.getYexb()) ? "1" : "0"); baby.setBabyHeight(item.getSc());//新生儿生长 baby.setBabyWeight(item.getTz());//新生儿重量 baby.setDeformity("无".equals(item.getJx()) ? 0 : 1); //畸形 0非畸形 1畸形 @@ -206,8 +214,8 @@ public class QhdfyFmService { baby.setDueTime(fmt1.format(dueDate));//分娩时间 babies.add(baby); deliverAddRequest.setFmHospital("216"); //设置为秦皇岛分娩医院 - - matDeliverFacade.addOrUpdateMatDeliver(deliverAddRequest, users.get(0).getId()); + ExceptionUtils.catchException("deliverAddRequest===" + deliverAddRequest); +// matDeliverFacade.addOrUpdateMatDeliver(deliverAddRequest, users.get(0).getId()); } } @@ -304,8 +312,8 @@ public class QhdfyFmService { deliverAddRequest.setDueWeek(week); } - deliverAddRequest.setTireNumber(items.size());//TODO 胎数 - deliverAddRequest.setPlacenta(items.size()+"");//TODO 胎盘 + deliverAddRequest.setTireNumber(items.size()); + deliverAddRequest.setPlacenta(items.size()+""); if ("完好".equals(item.getHyqk())) { @@ -381,7 +389,8 @@ public class QhdfyFmService { } deliverAddRequest.setFmHospital("216"); - matDeliverFacade.addOrUpdateMatDeliver(deliverAddRequest, users.get(0).getId()); + ExceptionUtils.catchException("double deliverAddRequest===" + deliverAddRequest); +// matDeliverFacade.addOrUpdateMatDeliver(deliverAddRequest, users.get(0).getId()); } } 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 cfdb885..53db011 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,5 +1,6 @@ package com.lyms.platform.operate.web.controller; +import com.lyms.hospitalapi.qhdfy.QhdfyFmService; import com.lyms.hospitalapi.qhdfy.QhdfyHisService; import com.lyms.platform.biz.JdbcUtil; import com.lyms.platform.biz.service.*; @@ -79,6 +80,9 @@ public class TestController { @Autowired private BabyCheckFacade babyCheckFacade; + + @Autowired + private QhdfyFmService qhdfyFmService; ; /** @@ -983,6 +987,16 @@ public class TestController { return "updateBabyFmHid finish"; } + + + + @RequestMapping(value = "/syncFmData", method = RequestMethod.GET) + @ResponseBody + public String syncFmData(@RequestParam(required = true) String start,@RequestParam(required = true) String end) { + qhdfyFmService.syncWorker(start,end); + return "syncFmData finish"; + } + public static void main(String[] a) { try { List list = FileUtils.readLines(new File("D:\\QHD.csv"), "gbk"); -- 1.8.3.1