From 0fab1b66fee393262f0e2aedbcb100dc16b11dc3 Mon Sep 17 00:00:00 2001
From: jiangjiazhi <jiangjiazhi@lymsh.com>
Date: Mon, 13 Aug 2018 11:28:25 +0800
Subject: [PATCH] 1

---
 .../dao/master/PatientServiceMapper.java           |   9 +
 .../permission/service/PatientServiceService.java  |   3 +
 .../service/impl/PatientServiceServiceImpl.java    |   5 +
 .../resources/mainOrm/master/PatientService.xml    |  28 ++-
 .../operate/web/controller/TestController.java     | 210 ++++++++++++++-------
 5 files changed, 181 insertions(+), 74 deletions(-)

diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/dao/master/PatientServiceMapper.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/dao/master/PatientServiceMapper.java
index 36cf683..fb96184 100644
--- a/platform-biz-service/src/main/java/com/lyms/platform/permission/dao/master/PatientServiceMapper.java
+++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/dao/master/PatientServiceMapper.java
@@ -4,6 +4,7 @@ import com.lyms.platform.permission.model.PatientService;
 import com.lyms.platform.permission.model.PatientServiceQuery;
 
 import java.util.List;
+import java.util.Map;
 
 public interface PatientServiceMapper {
     public void addPatientService(PatientService obj);
@@ -18,4 +19,12 @@ public interface PatientServiceMapper {
 
     public List<PatientService> queryPatientService(PatientServiceQuery query);
 
+    /**
+     * 查询只开通了标准服务的
+     *
+     * @param query
+     * @return
+     */
+    List<Map> selectOnlyBzService(PatientServiceQuery query);
+
 }
\ No newline at end of file
diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/PatientServiceService.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/PatientServiceService.java
index 8d9abfe..bb710bc 100644
--- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/PatientServiceService.java
+++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/PatientServiceService.java
@@ -4,6 +4,7 @@ import com.lyms.platform.permission.model.PatientService;
 import com.lyms.platform.permission.model.PatientServiceQuery;
 
 import java.util.List;
+import java.util.Map;
 
 public interface PatientServiceService {
     public void addPatientService(PatientService obj);
@@ -18,4 +19,6 @@ public interface PatientServiceService {
 
     public List<PatientService> queryPatientService(PatientServiceQuery query);
 
+
+    List<Map> selectOnlyBzService(PatientServiceQuery query);
 }
\ No newline at end of file
diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/PatientServiceServiceImpl.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/PatientServiceServiceImpl.java
index 0144849..e2f2e0a 100644
--- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/PatientServiceServiceImpl.java
+++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/PatientServiceServiceImpl.java
@@ -8,6 +8,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
+import java.util.Map;
 
 @Service
 public class PatientServiceServiceImpl implements PatientServiceService {
@@ -48,4 +49,8 @@ public class PatientServiceServiceImpl implements PatientServiceService {
         return patientServiceMapper.queryPatientService(query);
     }
 
+    @Override
+    public List<Map> selectOnlyBzService(PatientServiceQuery query) {
+        return patientServiceMapper.selectOnlyBzService(query);
+    }
 }
\ No newline at end of file
diff --git a/platform-biz-service/src/main/resources/mainOrm/master/PatientService.xml b/platform-biz-service/src/main/resources/mainOrm/master/PatientService.xml
index 68349dd..cc3cc77 100644
--- a/platform-biz-service/src/main/resources/mainOrm/master/PatientService.xml
+++ b/platform-biz-service/src/main/resources/mainOrm/master/PatientService.xml
@@ -37,9 +37,17 @@
     <update id="updatePatientService" parameterType="com.lyms.platform.permission.model.PatientService">
         update patient_service
         <set>
-            ser_doct = #{serDoct,jdbcType=VARCHAR},
-            create_user = #{createUser,jdbcType=VARCHAR},
-            update_user = #{updateUser,jdbcType=VARCHAR},
+            <if test="serDoct != null and serDoct != ''">
+                ser_doct = #{serDoct,jdbcType=VARCHAR},
+            </if>
+
+            <if test="createUser != null and createUser != ''">
+                create_user = #{createUser,jdbcType=VARCHAR},
+            </if>
+            <if test="updateUser != null and updateUser != ''">
+                update_user = #{updateUser,jdbcType=VARCHAR},
+            </if>
+
             <if test="parentid != null and parentid != ''">
                 parentid = #{parentid,jdbcType=VARCHAR},
             </if>
@@ -229,6 +237,20 @@
         <include refid="orderAndLimit"/>
     </select>
 
+    <!--查询只开通了标准服务的数据 -->
+    <select id="selectOnlyBzService" resultType="java.util.HashMap" parameterType="com.lyms.platform.permission.model.PatientServiceQuery">
+        SELECT  parentid,id from patient_service where ser_status=1
+        <if test="perType != null and perType != ''">
+            and per_type = #{perType,jdbcType=INTEGER}
+        </if>
+
+        and ser_type in (1,6,10,11)
+
+        GROUP BY parentid HAVING count(parentid)=1
+        <include refid="orderAndLimit"/>
+        ORDER BY
+    </select>
+
     <select id="queryPatientServiceCount" resultType="int"
             parameterType="com.lyms.platform.permission.model.PatientServiceQuery">
         select count(1) from patient_service
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 c4cd9ab..03a8298 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
@@ -34,6 +34,8 @@ import com.lyms.platform.operate.web.worker.BabyBuildSerToPatientSerWorker;
 import com.lyms.platform.operate.web.worker.BuildSerToPatientSerWorker;
 import com.lyms.platform.permission.model.Organization;
 import com.lyms.platform.permission.model.OrganizationQuery;
+import com.lyms.platform.permission.model.PatientService;
+import com.lyms.platform.permission.model.PatientServiceQuery;
 import com.lyms.platform.permission.service.OrganizationService;
 import com.lyms.platform.permission.service.PatientServiceService;
 import com.lyms.platform.pojo.*;
@@ -130,8 +132,6 @@ public class TestController extends BaseController {
     @Qualifier("commonThreadPool")
     private ThreadPoolTaskExecutor commonThreadPool;
     @Autowired
-    private PatientServiceService patientServiceService;
-    @Autowired
     private HosptialHighRiskService hosptialHighRiskService;
 
     @Autowired
@@ -1668,7 +1668,6 @@ public class TestController extends BaseController {
     }
 
 
-
     @RequestMapping(value = "/updateRecordOpinionFu", method = RequestMethod.GET)
     @ResponseBody
     public String updateRecordOpinionFu(@RequestParam(required = false) String hospitalId
@@ -1681,8 +1680,7 @@ public class TestController extends BaseController {
 
             antExQuery.setHospitalId(hospitalId);
         }
-        if (StringUtils.isNotEmpty(id))
-        {
+        if (StringUtils.isNotEmpty(id)) {
             antExQuery.setId(id);
         }
 
@@ -1706,14 +1704,12 @@ public class TestController extends BaseController {
                                 AntExRecordQuery pageAntExRecordsQuery = new AntExRecordQuery();
                                 pageAntExRecordsQuery.setfId(fuModel.getId());
                                 List<AntExRecordModel> recordModels = recordService.queryAntExRecords(pageAntExRecordsQuery);
-                                if (CollectionUtils.isNotEmpty(recordModels))
-                                {
-                                    if (StringUtils.isNotEmpty(fuModel.getTreatmentOpinion()))
-                                    {
-                                        System.out.println("fId=" + fuModel.getId()+";"+fuModel.getTreatmentOpinion());
+                                if (CollectionUtils.isNotEmpty(recordModels)) {
+                                    if (StringUtils.isNotEmpty(fuModel.getTreatmentOpinion())) {
+                                        System.out.println("fId=" + fuModel.getId() + ";" + fuModel.getTreatmentOpinion());
                                         AntExRecordModel recordModel = recordModels.get(0);
                                         recordModel.setTreatOpinion(fuModel.getTreatmentOpinion());
-                                        recordService.updateOne(recordModel,recordModel.getId());
+                                        recordService.updateOne(recordModel, recordModel.getId());
                                     }
                                 }
                             }
@@ -1738,8 +1734,7 @@ public class TestController extends BaseController {
 
             antExChuQuery.setHospitalId(hospitalId);
         }
-        if (StringUtils.isNotEmpty(id))
-        {
+        if (StringUtils.isNotEmpty(id)) {
             antExChuQuery.setId(id);
         }
 
@@ -1764,14 +1759,12 @@ public class TestController extends BaseController {
                                 AntExRecordQuery pageAntExRecordsQuery = new AntExRecordQuery();
                                 pageAntExRecordsQuery.setfId(chuModel.getId());
                                 List<AntExRecordModel> recordModels = recordService.queryAntExRecords(pageAntExRecordsQuery);
-                                if (CollectionUtils.isNotEmpty(recordModels))
-                                {
-                                    if (StringUtils.isNotEmpty(chuModel.getTreatOpinion()))
-                                    {
-                                        System.out.println("chuId=" + chuModel.getId()+";"+chuModel.getTreatOpinion());
+                                if (CollectionUtils.isNotEmpty(recordModels)) {
+                                    if (StringUtils.isNotEmpty(chuModel.getTreatOpinion())) {
+                                        System.out.println("chuId=" + chuModel.getId() + ";" + chuModel.getTreatOpinion());
                                         AntExRecordModel recordModel = recordModels.get(0);
                                         recordModel.setTreatOpinion(chuModel.getTreatOpinion());
-                                        recordService.updateOne(recordModel,recordModel.getId());
+                                        recordService.updateOne(recordModel, recordModel.getId());
                                     }
                                 }
                             }
@@ -1784,8 +1777,6 @@ public class TestController extends BaseController {
     }
 
 
-
-
     @Autowired
     private CommonService commonService;
     @Autowired
@@ -1812,29 +1803,29 @@ public class TestController extends BaseController {
     @RequestMapping(method = RequestMethod.GET, value = "/antex/antexlist2")
     @ResponseBody
     @TokenRequired
-    public BaseResponse findAntExList(@Valid AntExListQueryRequest exListQueryRequest,HttpServletRequest request) {
+    public BaseResponse findAntExList(@Valid AntExListQueryRequest exListQueryRequest, HttpServletRequest request) {
         LoginContext loginState = (LoginContext) request.getAttribute("loginContext");
-        return patientMedicalRecordFacade.findAntExListTwo(exListQueryRequest,loginState.getId());
+        return patientMedicalRecordFacade.findAntExListTwo(exListQueryRequest, loginState.getId());
     }
 
 
     @RequestMapping("/qhdfm")
     @ResponseBody
-    public BaseObjectResponse qhdfm(String cardNo){
+    public BaseObjectResponse qhdfm(String cardNo) {
         return new BaseObjectResponse().setErrorcode(ErrorCodeConstants.SUCCESS).setErrormsg("成功").setData(qhdfyFmService.queryFmPatient(cardNo));
     }
 
 
     @RequestMapping("/test")
     @ResponseBody
-    public String test(String code){
+    public String test(String code) {
 
         return cdfyHisService.getIdByVcCardNo(code);
     }
 
     @RequestMapping("/testLc")
     @ResponseBody
-    public MaternalDeliverResult testLc(String bhnum){
+    public MaternalDeliverResult testLc(String bhnum) {
 
         return lcdcfFmService.queryFmPatient(bhnum);
     }
@@ -1842,7 +1833,7 @@ public class TestController extends BaseController {
     @RequestMapping(value = "/handleSieveTime", method = RequestMethod.GET)
     @ResponseBody
     public String doSieveTime(@RequestParam(required = false) String hospitalId,
-                                   @RequestParam(required = false) String patientId) {
+                              @RequestParam(required = false) String patientId) {
 
         SieveQuery sieveQuery = new SieveQuery();
         sieveQuery.setYn(YnEnums.YES.getId());
@@ -1866,8 +1857,7 @@ public class TestController extends BaseController {
                 }
                 System.out.println("start:" + i + ",end:" + end);
                 final List<SieveModel> sieveModels = list.subList(i, end);
-                for (SieveModel model : sieveModels)
-                {
+                for (SieveModel model : sieveModels) {
 
                     System.out.println(model.getParentId());
                     sieveApplyOrderQuery1.setParentId(model.getParentId());
@@ -1875,11 +1865,9 @@ public class TestController extends BaseController {
 
                     List<SieveApplyOrderModel> list1 = applyOrderService.querySieveApplyOrderWithQuery(sieveApplyOrderQuery1);
 
-                    if (CollectionUtils.isNotEmpty(list1))
-                    {
+                    if (CollectionUtils.isNotEmpty(list1)) {
                         SieveApplyOrderModel applyOrderModel = list1.get(0);
-                         if (applyOrderModel.getApplyTime() == null)
-                        {
+                        if (applyOrderModel.getApplyTime() == null) {
                             applyOrderModel.setApplyTime(applyOrderModel.getCreated());
                             applyOrderService.updateSieve(applyOrderModel);
                             model.setApplyTime(applyOrderModel.getCreated());
@@ -1890,11 +1878,9 @@ public class TestController extends BaseController {
                     sieveResultQuery.setParentId(model.getParentId());
 
                     List<SieveResultModel> sieveResultModels = sieveService.queryListSieveResult(sieveResultQuery);
-                    if (CollectionUtils.isNotEmpty(sieveResultModels))
-                    {
+                    if (CollectionUtils.isNotEmpty(sieveResultModels)) {
                         SieveResultModel sieveResultModel = sieveResultModels.get(0);
-                        if (sieveResultModel.getResultTime() == null)
-                        {
+                        if (sieveResultModel.getResultTime() == null) {
                             sieveResultModel.setResultTime(sieveResultModel.getCreated());
                             sieveService.updateSieveRsult(sieveResultModel);
                             model.setResultTime(sieveResultModel.getCreated());
@@ -1902,8 +1888,7 @@ public class TestController extends BaseController {
                         }
                     }
 
-                    if (model.getStatus() == 3 && model.getDiagnosisTime() == null)
-                    {
+                    if (model.getStatus() == 3 && model.getDiagnosisTime() == null) {
                         model.setDiagnosisTime(model.getModified());
                         sieveService.updateOneChanQianDiaSieve(model);
                     }
@@ -1933,9 +1918,9 @@ public class TestController extends BaseController {
 //    }
 
 
-    @RequestMapping(value="/his/getClFyIdByVcCardNo")
+    @RequestMapping(value = "/his/getClFyIdByVcCardNo")
     @ResponseBody
-    public Map<String,Object> getLcdcfyByZyhHis(@RequestParam("vcCardNo")String vcCardNo){
+    public Map<String, Object> getLcdcfyByZyhHis(@RequestParam("vcCardNo") String vcCardNo) {
         Map<String, Object> map = new HashMap<String, Object>();
         map.put("id", "1236544");
         return map;
@@ -1943,12 +1928,13 @@ public class TestController extends BaseController {
 
 
     /**
-     *诸城初诊测试
+     * 诸城初诊测试
+     *
      * @return
      */
-    @RequestMapping(value="/zc/cscz")
+    @RequestMapping(value = "/zc/cscz")
     @ResponseBody
-    public BaseObjectResponse getCsCz(@RequestParam("id")String id,@RequestParam("parentId")String parentId){
+    public BaseObjectResponse getCsCz(@RequestParam("id") String id, @RequestParam("parentId") String parentId) {
         AntExChuModel antExChuModel = new AntExChuModel();
         antExChuModel.setId(id);
         antExChuModel.setParentId(parentId);
@@ -1957,12 +1943,13 @@ public class TestController extends BaseController {
     }
 
     /**
-     *诸城复诊测试
+     * 诸城复诊测试
+     *
      * @return
      */
-    @RequestMapping(value="/zc/csfz")
+    @RequestMapping(value = "/zc/csfz")
     @ResponseBody
-    public BaseObjectResponse getCsFz(@RequestParam("id")String id,@RequestParam("parentId")String parentId){
+    public BaseObjectResponse getCsFz(@RequestParam("id") String id, @RequestParam("parentId") String parentId) {
         AntenatalExaminationModel antenatalExaminationModel = new AntenatalExaminationModel();
         antenatalExaminationModel.setId(id);
         antenatalExaminationModel.setParentId(parentId);
@@ -1970,16 +1957,16 @@ public class TestController extends BaseController {
         return br;
     }
 
-    @RequestMapping(value="/zc/cz")
+    @RequestMapping(value = "/zc/cz")
     @ResponseBody
-    public BaseObjectResponse saveChuZhen(@RequestParam("startDate")String startDate,@RequestParam("endDate")String endDate){
+    public BaseObjectResponse saveChuZhen(@RequestParam("startDate") String startDate, @RequestParam("endDate") String endDate) {
         BaseObjectResponse br = zcPrenatalService.saveChuZhen(startDate, endDate);
         return br;
     }
 
-    @RequestMapping(value="/zc/fz")
+    @RequestMapping(value = "/zc/fz")
     @ResponseBody
-    public BaseObjectResponse saveFuZhen(@RequestParam("startDate")String startDate,@RequestParam("endDate")String endDate){
+    public BaseObjectResponse saveFuZhen(@RequestParam("startDate") String startDate, @RequestParam("endDate") String endDate) {
         BaseObjectResponse br = zcPrenatalService.saveFuZhen(startDate, endDate);
         return br;
     }
@@ -1987,12 +1974,13 @@ public class TestController extends BaseController {
 
     /**
      * 承德智业基本信息测试
+     *
      * @param id
      * @return
      */
-    @RequestMapping(value="/cd/cs")
+    @RequestMapping(value = "/cd/cs")
     @ResponseBody
-    public BaseObjectResponse baseinfo(@RequestParam("id")String id){
+    public BaseObjectResponse baseinfo(@RequestParam("id") String id) {
         Patients patients = patientsService.findOnePatientById(id);
         return cdGwInterface.saveBaseInfo(patients);
     }
@@ -2000,12 +1988,13 @@ public class TestController extends BaseController {
 
     /**
      * 承德智业初诊测试(第一次产前随访记录)
+     *
      * @param id
      * @return
      */
-    @RequestMapping(value="/cd/cz")
+    @RequestMapping(value = "/cd/cz")
     @ResponseBody
-    public BaseObjectResponse cz(@RequestParam("id")String id,@RequestParam("parentId")String parentId){
+    public BaseObjectResponse cz(@RequestParam("id") String id, @RequestParam("parentId") String parentId) {
         AntExChuModel antExChuModel = new AntExChuModel();
         antExChuModel.setId(id);
         antExChuModel.setParentId(parentId);
@@ -2016,12 +2005,13 @@ public class TestController extends BaseController {
 
     /**
      * 承德智业初诊测试(非第一次产前随访记录)
+     *
      * @param id
      * @return
      */
-    @RequestMapping(value="/cd/fz")
+    @RequestMapping(value = "/cd/fz")
     @ResponseBody
-    public BaseObjectResponse fz(@RequestParam("id")String id){
+    public BaseObjectResponse fz(@RequestParam("id") String id) {
         AntenatalExaminationModel antenatalExaminationModel = antExService.findOneById(id);
         return cdGwInterface.saveWoman_Preothervisit(antenatalExaminationModel);
     }
@@ -2029,12 +2019,13 @@ public class TestController extends BaseController {
 
     /**
      * 承德智业分娩测试
+     *
      * @param id
      * @return
      */
-    @RequestMapping(value="/cd/fm")
+    @RequestMapping(value = "/cd/fm")
     @ResponseBody
-    public BaseObjectResponse fm(@RequestParam("id")String id){
+    public BaseObjectResponse fm(@RequestParam("id") String id) {
         MaternalDeliverModel data = matDeliverService.getOneMatDeliver(id);
         return cdGwInterface.saveWomen_Delivery(data);
     }
@@ -2042,12 +2033,13 @@ public class TestController extends BaseController {
 
     /**
      * 承德智业产后访视测试
+     *
      * @param id
      * @return
      */
-    @RequestMapping(value="/cd/chfs")
+    @RequestMapping(value = "/cd/chfs")
     @ResponseBody
-    public BaseResponse chfs(@RequestParam("id")String id){
+    public BaseResponse chfs(@RequestParam("id") String id) {
         MatdeliverFollowModel matdeliverFollowModel = matDeliverFollowService.getOneMatDeliverFollow(id);
         return cdGwInterface.saveWoman_Postvisit(matdeliverFollowModel);
 
@@ -2056,27 +2048,28 @@ public class TestController extends BaseController {
 
     /**
      * 承德智业产后42天复查测试
+     *
      * @param id
      * @return
      */
-    @RequestMapping(value="/cd/chfc")
+    @RequestMapping(value = "/cd/chfc")
     @ResponseBody
-    public BaseResponse chfc(@RequestParam("id")String id){
+    public BaseResponse chfc(@RequestParam("id") String id) {
         PostReviewModel data = postReviewService.findOneById(id);
         return cdGwInterface.saveWoman_Post42Exam(data);
 
     }
 
 
-
     /**
      * 承德智业儿童基本信息测试
+     *
      * @param id
      * @return
      */
-    @RequestMapping(value="/cd/child")
+    @RequestMapping(value = "/cd/child")
     @ResponseBody
-    public BaseObjectResponse child_info(@RequestParam("id")String id){
+    public BaseObjectResponse child_info(@RequestParam("id") String id) {
         BabyModelQuery babyQuery = new BabyModelQuery();
         babyQuery.setId(id);
         babyQuery.setYn(YnEnums.YES.getId());
@@ -2091,12 +2084,13 @@ public class TestController extends BaseController {
 
     /**
      * 承德智业新生儿访视测试
+     *
      * @param id
      * @return
      */
-    @RequestMapping(value="/cd/newfs")
+    @RequestMapping(value = "/cd/newfs")
     @ResponseBody
-    public BaseObjectResponse newChildFs(@RequestParam("id")String id){
+    public BaseObjectResponse newChildFs(@RequestParam("id") String id) {
         NewbornVisit newbornVisit = mongoTemplate.findById(id, NewbornVisit.class);
         return cdGwInterface.saveChild_HomeVisit_Memo(newbornVisit);
     }
@@ -2104,22 +2098,96 @@ public class TestController extends BaseController {
 
     /**
      * 承德智业儿保测试
+     *
      * @param id
      * @return
      */
-    @RequestMapping(value="/cd/childck")
+    @RequestMapping(value = "/cd/childck")
     @ResponseBody
-    public BaseObjectResponse childCheck(@RequestParam("id")String id){
+    public BaseObjectResponse childCheck(@RequestParam("id") String id) {
         BabyCheckModelQuery query = new BabyCheckModelQuery();
         query.setYn(YnEnums.YES.getId());
         query.setId(id);
         List<BabyCheckModel> checkModels = babyCheckService.queryBabyCheckRecord(query);
-        if(checkModels != null && checkModels.size() > 0){
+        if (checkModels != null && checkModels.size() > 0) {
             return cdGwInterface.saveChild_HealthExam(checkModels.get(0));
         }
         return null;
     }
 
+    @RequestMapping(value = "/update/servicestatus")
+    @ResponseBody
+    public BaseObjectResponse updatePatientServiceStatus(@RequestParam(value = "t", defaultValue = "1") String type) {
+
+        int page = 1;
+        List<Map> dataMap = null;
+        do {
+            PatientServiceQuery patientServiceQuery = new PatientServiceQuery();
+            patientServiceQuery.setSort(" create_date asc ");
+            patientServiceQuery.setNeed("1");
+            patientServiceQuery.setPage(page);
+            patientServiceQuery.setLimit(100);
+            patientServiceQuery.setPerType(Integer.valueOf(type));
+            dataMap = patientServiceService.selectOnlyBzService(patientServiceQuery);
+            if (null != dataMap) {
+                for (Map map : dataMap) {
+                    commonThreadPool.execute(new Worker(map.get("parentid").toString(), map.get("id").toString(), Integer.valueOf(type)));
+                }
+            }
+            page++;
+        } while (null != dataMap && dataMap.size() == 100);
+        return new BaseObjectResponse().setErrorcode(ErrorCodeConstants.SUCCESS).setErrormsg("xxx");
+    }
+
+    public class Worker extends Thread {
+        private String parentId;
+        private String id;
+        private Integer type;
+
+        public Worker(String parentId, String id, Integer type) {
+            this.id = id;
+            this.parentId = parentId;
+            this.type = type;
+        }
+
+        @Override
+        public void run() {
+            try {
+                System.out.println("do worker by id :" + id +"parentId:" + parentId);
+                if (type == 1) {
+                    Patients patients = patientsService.findOnePatientById(parentId);
+                    if (null != patients) {
+                        //改成不开通
+                        patients.setServiceStatus(1);
+                        patients.setModified(new Date());
+                        patientsService.updatePatient(patients);
+                    }
+                } else {
+                    BabyModelQuery babyModelQuery = new BabyModelQuery();
+                    babyModelQuery.setYn(YnEnums.YES.getId());
+                    babyModelQuery.setId(parentId);
+                    List<BabyModel> babyModel = babyBookbuildingService.queryBabyBuildByCond(babyModelQuery);
+                    if(CollectionUtils.isNotEmpty(babyModel)){
+                        BabyModel baby =  babyModel.get(0);
+                        baby.setServiceStatus(1);
+                        baby.setModified(new Date());
+                        babyBookbuildingService.updateBabyBuild(baby,baby.getId());
+                    }
+                }
+
+
+                PatientService patientServiceService1 = new PatientService();
+                patientServiceService1.setId(id);
+                patientServiceService1.setSerStatus(2);
+                patientServiceService1.setSynStatus(1);
+                patientServiceService.updatePatientService(patientServiceService1);
+            } catch (Exception e) {
+                ExceptionUtils.catchException(e, "Worker error.");
+            }
+        }
+    }
 
 
+    @Autowired
+    private PatientServiceService patientServiceService;
 }
-- 
1.8.3.1