diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/BookbuildingFacade.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/BookbuildingFacade.java index 9fc76b8..a35a13f 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/BookbuildingFacade.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/BookbuildingFacade.java @@ -5,7 +5,6 @@ import com.lyms.hospitalapi.fnfy.FnfyHisService; import com.lyms.hospitalapi.qhdfy.QhdfyHisService; import com.lyms.hospitalapi.qinglongxian.QingLongXianHisService; import com.lyms.hospitalapi.v2.HisService; -import com.lyms.platform.beans.MsgListRequest; import com.lyms.platform.beans.MsgRequest; import com.lyms.platform.biz.service.*; import com.lyms.platform.common.base.PageInfo; @@ -15,12 +14,16 @@ import com.lyms.platform.common.result.BaseListResponse; import com.lyms.platform.common.result.BaseObjectResponse; import com.lyms.platform.common.result.BaseResponse; import com.lyms.platform.common.utils.*; -import com.lyms.platform.operate.web.request.*; +import com.lyms.platform.operate.web.request.BookBuildManagerQueryRequest; +import com.lyms.platform.operate.web.request.BookbuildingQueryRequest; +import com.lyms.platform.operate.web.request.YunBookbuildingAddRequest; import com.lyms.platform.operate.web.result.*; import com.lyms.platform.operate.web.utils.JdbcUtil; -import com.lyms.platform.operate.web.utils.MessageCenterService; import com.lyms.platform.permission.dao.master.CouponMapper; -import com.lyms.platform.permission.model.*; +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.Users; import com.lyms.platform.permission.service.CouponService; import com.lyms.platform.permission.service.OrganizationService; import com.lyms.platform.permission.service.UsersService; @@ -646,6 +649,15 @@ public class BookbuildingFacade { } /** + * 更新孕妇服务相关信息 + * + * @param id + */ + public void updatePatientSerById(String id, Patients patient) { + yunBookbuildingService.updatePregnant(patient, id); + } + + /** * 更新孕妇信息 * * @param id diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientServiceSysFacade.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientServiceSysFacade.java index f76f79e..527decc 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientServiceSysFacade.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientServiceSysFacade.java @@ -4,8 +4,11 @@ import com.lyms.platform.biz.service.BabyService; import com.lyms.platform.biz.service.PatientsService; import com.lyms.platform.common.constants.ErrorCodeConstants; import com.lyms.platform.common.enums.PatientSerEnums; +import com.lyms.platform.common.enums.ServiceStatusEnums; +import com.lyms.platform.common.enums.ServiceTypeEnums; import com.lyms.platform.common.result.BaseResponse; import com.lyms.platform.common.utils.StringUtils; +import com.lyms.platform.operate.web.request.BabyBookbuildingAddRequest; import com.lyms.platform.permission.model.PatientService; import com.lyms.platform.permission.model.PatientServiceQuery; import com.lyms.platform.permission.service.PatientServiceService; @@ -35,6 +38,11 @@ public class PatientServiceSysFacade implements SysBaseFacade { @Autowired private BabyService babyService; + @Autowired + private BookbuildingFacade bookbuildingFacade; + @Autowired + private BabyBookbuildingFacade babyBookbuildingFacade; + @Override public BaseResponse execute(String synForm) { JSONArray jsonArray = JSONArray.fromObject(synForm); @@ -95,15 +103,48 @@ public class PatientServiceSysFacade implements SysBaseFacade { int serType = patientService.getSerType(); patientService.setUpdateDate(new Date()); // 1高危精准指导、5-专家咨询默认已经领取 - if(serType == PatientSerEnums.SerTypeEnums.yqjzzd.getId()||serType == PatientSerEnums.SerTypeEnums.zjzx.getId()){ + if (serType == PatientSerEnums.SerTypeEnums.yqjzzd.getId() || serType == PatientSerEnums.SerTypeEnums.zjzx.getId()) { //默认已领取 patientService.setStatus(2); - }else{ + } else { //默认待领取 patientService.setStatus(1); } patientServiceService.addPatientService(patientService); } + + if (patientService.getPerType() != null && patientService.getPerType() == 2) {//儿童建档服务数据处理 + BabyBookbuildingAddRequest babyBookbuildingAddRequest = new BabyBookbuildingAddRequest(); + babyBookbuildingAddRequest.setId(patientService.getParentid()); + if (PatientSerEnums.SerTypeEnums.babyjzzz.getId() == patientService.getSerType()) { + babyBookbuildingAddRequest.setServiceType(ServiceTypeEnums.ADD_SERVICE.getId()); + if (patientService.getSerStatus() == PatientSerEnums.SerStatusEnums.kt.getId()) { + babyBookbuildingAddRequest.setServiceStatus(ServiceStatusEnums.ADD_OPEN.getId()); + } else if (patientService.getSerStatus() == PatientSerEnums.SerStatusEnums.td.getId()) { + babyBookbuildingAddRequest.setServiceStatus(ServiceStatusEnums.UNSUBSCRIBE.getId()); + } else if (patientService.getSerStatus() == PatientSerEnums.SerStatusEnums.gq.getId()) { + babyBookbuildingAddRequest.setServiceStatus(ServiceStatusEnums.ADD_OVERDUE.getId()); + } else if (patientService.getSerStatus() == PatientSerEnums.SerStatusEnums.zt.getId()) { + babyBookbuildingAddRequest.setServiceStatus(ServiceStatusEnums.SUSPEND.getId()); + } + } + babyBookbuildingFacade.updateBabySerInfo(babyBookbuildingAddRequest); + } else {//孕妇建档服务数据处理 + Patients patient = new Patients(); + if (PatientSerEnums.SerTypeEnums.yqjzzd.getId() == patientService.getSerType()) {//孕期精准指导同步到建档 + patient.setServiceType(ServiceTypeEnums.ADD_SERVICE.getId()); + if (patientService.getSerStatus() == PatientSerEnums.SerStatusEnums.kt.getId()) { + patient.setServiceStatus(ServiceStatusEnums.ADD_OPEN.getId()); + } else if (patientService.getSerStatus() == PatientSerEnums.SerStatusEnums.td.getId()) { + patient.setServiceStatus(ServiceStatusEnums.UNSUBSCRIBE.getId()); + } else if (patientService.getSerStatus() == PatientSerEnums.SerStatusEnums.gq.getId()) { + patient.setServiceStatus(ServiceStatusEnums.ADD_OVERDUE.getId()); + } else if (patientService.getSerStatus() == PatientSerEnums.SerStatusEnums.zt.getId()) { + patient.setServiceStatus(ServiceStatusEnums.SUSPEND.getId()); + } + } + bookbuildingFacade.updatePatientSerById(patientService.getParentid(), patient); + } } System.out.println("同步数据方法结束"); diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/worker/BabyBuildSerToPatientSerWorker.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/worker/BabyBuildSerToPatientSerWorker.java index f87a579..03ad6ca 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/worker/BabyBuildSerToPatientSerWorker.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/worker/BabyBuildSerToPatientSerWorker.java @@ -124,7 +124,6 @@ public class BabyBuildSerToPatientSerWorker implements Callable { } catch (Exception e) { e.printStackTrace(); } - } System.out.println("线程处理数据完成，开始条数：" + startIndex + ",结束条数：" + endIndex + ",map:" + patientsMap.size());