diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/PregnantBuildController.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/PregnantBuildController.java index 520720f..973b4f2 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/PregnantBuildController.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/PregnantBuildController.java @@ -1,493 +1,515 @@ -package com.lyms.platform.operate.web.controller; - - -import com.lyms.platform.biz.service.YunBookbuildingService; -import com.lyms.platform.common.annotation.TokenRequired; -import com.lyms.platform.common.base.BaseController; -import com.lyms.platform.common.base.LoginContext; -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.MessageUtil; -import com.lyms.platform.common.utils.PropertiesUtils; -import com.lyms.platform.common.utils.StringUtils; -import com.lyms.platform.operate.web.facade.AntenatalExaminationFacade; -import com.lyms.platform.operate.web.facade.BookbuildingFacade; -import com.lyms.platform.operate.web.request.AntenatalExaminationQueryRequest; -import com.lyms.platform.operate.web.request.BookbuildingQueryRequest; -import com.lyms.platform.operate.web.request.YunBookbuildingAddRequest; -import org.apache.commons.httpclient.HttpClient; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Controller; -import org.springframework.web.bind.annotation.*; - -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; -import java.io.IOException; -import java.io.UnsupportedEncodingException; -import java.net.URLEncoder; - - -/* - *孕妇建档 - * lqy - * 2016-06-15 - */ -@Controller -public class PregnantBuildController extends BaseController{ - - @Autowired - private YunBookbuildingService yunBookbuildingService; - - @Autowired - private BookbuildingFacade bookbuildingFacade; - - @Autowired - private AntenatalExaminationFacade antenatalExaminationFacade; - - - /** - * 查询孕妇建档记录 - * @return - */ - @RequestMapping(value = "/getCheckTicketList", method = RequestMethod.GET) - @ResponseBody - @TokenRequired - public BaseListResponse getCheckTicketList(@RequestParam(required = true) String patientId) { - return bookbuildingFacade.getTicketList(patientId); - } - - /** - * 添加孕妇建档或者更新孕妇建档 - * @param yunBookbuildingAddRequest - * @return - */ - @RequestMapping(method = RequestMethod.POST, value = "/addOrUpdateYunBuild") - @ResponseBody - @TokenRequired - public BaseResponse addOrUpdateYunBuild(@RequestBody YunBookbuildingAddRequest yunBookbuildingAddRequest,HttpServletRequest request) { - LoginContext loginState = (LoginContext) request.getAttribute("loginContext"); - if (yunBookbuildingAddRequest != null && !StringUtils.isEmpty(yunBookbuildingAddRequest.getId()) ) - { - return bookbuildingFacade.updatePregnantById(yunBookbuildingAddRequest.getId(), yunBookbuildingAddRequest,loginState.getId()); - - } - BaseObjectResponse p = bookbuildingFacade.addPregnantBookbuilding(yunBookbuildingAddRequest,loginState.getId()); - return p; - } - - - - - /** - * 删除孕妇建档 - * @param id - * @return - */ - @RequestMapping(value = "/deletePregnant/{id}", method = RequestMethod.DELETE) - @ResponseBody - @TokenRequired - public BaseResponse deletePregnantById(@PathVariable("id")String id,HttpServletRequest httpServletRequest){ - LoginContext loginState = (LoginContext) httpServletRequest.getAttribute("loginContext"); - return bookbuildingFacade.deletePregnantById(id,loginState.getId()); - } - - - - /** - * 查询孕妇建档记录 - * @return - */ - @RequestMapping(value = "/queryPregnantBuildRecord", method = RequestMethod.GET) - @ResponseBody - @TokenRequired - public BaseListResponse queryPregnantBuildRecord(@RequestParam(required = false) String id, - @RequestParam(required = false) String pid, - @RequestParam(required = false) String vcCardNo, - @RequestParam(required = false) String cardNo,HttpServletRequest httpServletRequest){ - BookbuildingQueryRequest bookbuildingQueryRequest = new BookbuildingQueryRequest(); - bookbuildingQueryRequest.setVcCardNo(vcCardNo); - bookbuildingQueryRequest.setCardNo(cardNo); - bookbuildingQueryRequest.setPid(pid); - // id，HuJiaqi添加，为了建档管理里面的查看单条使用 - bookbuildingQueryRequest.setId(id); - LoginContext loginState = (LoginContext) httpServletRequest.getAttribute("loginContext"); - BaseListResponse listResponse = bookbuildingFacade.queryPregnantBuildRecord(bookbuildingQueryRequest, loginState.getId()); - return listResponse; - } - - /** - * 查询孕妇详细建档信息通过Id - * @param id - * @return - */ - @RequestMapping(value = "/queryPregnantBuildById/{id}", method = RequestMethod.GET) - @ResponseBody - public BaseObjectResponse queryPregnantBuildRecord(@PathVariable("id")String id){ - BaseObjectResponse objectResponse = bookbuildingFacade.queryPregnantBuildById(id); - return objectResponse; - } - - - /** - * 查询儿童对应孕妇的建档记录 - * @param id 孕妇ID - * @return - */ - @RequestMapping(value = "/queryThisBabyPatient/{id}", method = RequestMethod.GET) - @ResponseBody - @TokenRequired - public BaseResponse queryThisBabyPatient(@PathVariable("id")String id,HttpServletRequest request){ - AntenatalExaminationQueryRequest antenatalExaminationQueryRequest = new AntenatalExaminationQueryRequest(); - antenatalExaminationQueryRequest.setPatientId(id); - LoginContext loginState = (LoginContext) request.getAttribute("loginContext"); - return antenatalExaminationFacade.queryAntenatalExamination(antenatalExaminationQueryRequest,loginState.getId()); - } - - /** - * 获取本院最近 - * @return - */ - @RequestMapping(value = "/queryPregnant", method = RequestMethod.GET) - @ResponseBody - @TokenRequired - public BaseResponse queryLatePregnant(HttpServletRequest request,@RequestParam("parentId")String parentId){ - LoginContext loginState = (LoginContext) request.getAttribute("loginContext"); - return bookbuildingFacade.findPatientById(parentId,loginState.getId()); - } - - - - /** - * 建档页面基础数据 - * @return - */ - @RequestMapping(value = "/getYunBuildBaseConfig", method = RequestMethod.GET) - @ResponseBody - public BaseObjectResponse getBabyBuildBaseConfig(){ - return bookbuildingFacade.getYunBuildBaseConfig(); - } - - /** - *查询孕妇建档基本信息 - * @return - */ - @RequestMapping(value = "/queryYunBuildInfo", method = RequestMethod.GET) - @ResponseBody - @TokenRequired - public BaseObjectResponse queryYunBuildInfo(HttpServletRequest request,@RequestParam(required = false) String cardNo,@RequestParam(required = false) String vcCardNo){ - LoginContext loginState = (LoginContext) request.getAttribute("loginContext"); - BaseObjectResponse objectResponse = bookbuildingFacade.queryYunBuildInfo(cardNo,vcCardNo,loginState.getId()); - return objectResponse; - } - - - - @RequestMapping(value = "/queryHospitals", method = RequestMethod.GET) - @ResponseBody - public BaseObjectResponse queryHospitals(HttpServletRequest request, - @RequestParam(required = false) String keyWord, - @RequestParam(required = false) Integer page, - @RequestParam(required = false) Integer limit){ - BaseObjectResponse objectResponse = bookbuildingFacade.queryHospitals(keyWord, page, limit); - return objectResponse; - } - - - public static final String center_statistics_url= PropertiesUtils.getPropertyValue("center_statistics_url"); - - public String paramEncode(String param) { - try { - return URLEncoder.encode(param,"utf-8"); - } catch (UnsupportedEncodingException e) { - e.printStackTrace(); - return param; - } - } - - /** - * 产检报告 - * @param request - * @return - */ - @RequestMapping(value = "/queryChanJianReport", method = RequestMethod.GET) - @TokenRequired - public void queryChanJianReport(HttpServletRequest request,HttpServletResponse response, - @RequestParam(required = false) String exDateStart, - @RequestParam(required = false) String exDateEnd, - @RequestParam(required = false) String name, - @RequestParam(required = false) Integer weekStarts, - @RequestParam(required = false) Integer weekEnds, - @RequestParam(required = false) String hbsab, - @RequestParam(required = false) String hbeag, - @RequestParam(required = false) String hbeab, - @RequestParam(required = false) String hbcab, - @RequestParam(required = false) String syphilis, - @RequestParam(required = false) String hiv, - @RequestParam(required = false) String hcv, - @RequestParam(required = false) String doctorNo, - @RequestParam(required = false) Integer page, - @RequestParam(required = false) Integer limit - ){ - LoginContext loginState = (LoginContext) request.getAttribute("loginContext"); - StringBuffer params = new StringBuffer(); - params.append("userId="); - params.append(loginState.getId()); - if (org.apache.commons.lang.StringUtils.isNotBlank(exDateStart)) { - params.append("&exDateStart="); - params.append(paramEncode(exDateStart)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(exDateEnd)) { - params.append("&exDateEnd="); - params.append(paramEncode(exDateEnd)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(name)) { - params.append("&name="); - params.append(paramEncode(name)); - } - if (weekStarts != null) { - params.append("&weekStarts="); - params.append(weekStarts); - } - if (weekEnds != null) { - params.append("&weekEnds="); - params.append(weekEnds); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(hbsab)) { - params.append("&hbsab="); - params.append(paramEncode(hbsab)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(hbeag)) { - params.append("&hbeag="); - params.append(paramEncode(hbeag)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(hbeab)) { - params.append("&hbeab="); - params.append(paramEncode(hbeab)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(hbcab)) { - params.append("&hbcab="); - params.append(paramEncode(hbcab)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(syphilis)) { - params.append("&syphilis="); - params.append(paramEncode(syphilis)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(hiv)) { - params.append("&hiv="); - params.append(paramEncode(hiv)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(hcv)) { - params.append("&hcv="); - params.append(paramEncode(hcv)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(doctorNo)) { - params.append("&doctorNo="); - params.append(paramEncode(doctorNo)); - } - if (page != null) { - params.append("&page="); - params.append(page); - } - if (limit != null) { - params.append("&limit="); - params.append(limit); - } - MessageUtil.UTF8GetMethod utf8GetMethod = new MessageUtil.UTF8GetMethod(center_statistics_url+"center/queryChanJianReport?" + params.toString()); - HttpClient client = new HttpClient(); - try { - client.executeMethod(utf8GetMethod); - int statusCode = utf8GetMethod.getStatusCode(); - if (200 == statusCode) { - String json = new String(utf8GetMethod.getResponseBodyAsString()); - writeJson(response, json); - } - } catch (IOException e) { - e.printStackTrace(); - } - } - - - @RequestMapping(value = "/exportChanReport", method = RequestMethod.GET) - @TokenRequired - public void exportChanReport(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse, - @RequestParam(required = false) String exDateStart, - @RequestParam(required = false) String exDateEnd, - @RequestParam(required = false) String name, - @RequestParam(required = false) Integer weekStarts, - @RequestParam(required = false) Integer weekEnds, - @RequestParam(required = false) String hbsab, - @RequestParam(required = false) String hbeag, - @RequestParam(required = false) String hbeab, - @RequestParam(required = false) String hbcab, - @RequestParam(required = false) String syphilis, - @RequestParam(required = false) String hiv, - @RequestParam(required = false) String hcv, - @RequestParam(required = false) String doctorNo, - @RequestParam(required = false) Integer page, - @RequestParam(required = false) Integer limit){ - LoginContext loginState = (LoginContext) httpServletRequest.getAttribute("loginContext"); - StringBuffer params = new StringBuffer(); - params.append("userId="); - params.append(loginState.getId()); - if (org.apache.commons.lang.StringUtils.isNotBlank(exDateStart)) { - params.append("&exDateStart="); - params.append(paramEncode(exDateStart)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(exDateEnd)) { - params.append("&exDateEnd="); - params.append(paramEncode(exDateEnd)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(name)) { - params.append("&name="); - params.append(paramEncode(name)); - } - if (weekStarts != null) { - params.append("&weekStarts="); - params.append(weekStarts); - } - if (weekEnds != null) { - params.append("&weekEnds="); - params.append(weekEnds); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(hbsab)) { - params.append("&hbsab="); - params.append(paramEncode(hbsab)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(hbeag)) { - params.append("&hbeag="); - params.append(paramEncode(hbeag)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(hbeab)) { - params.append("&hbeab="); - params.append(paramEncode(hbeab)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(hbcab)) { - params.append("&hbcab="); - params.append(paramEncode(hbcab)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(syphilis)) { - params.append("&syphilis="); - params.append(paramEncode(syphilis)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(hiv)) { - params.append("&hiv="); - params.append(paramEncode(hiv)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(hcv)) { - params.append("&hcv="); - params.append(paramEncode(hcv)); - } - if (org.apache.commons.lang.StringUtils.isNotBlank(doctorNo)) { - params.append("&doctorNo="); - params.append(paramEncode(doctorNo)); - } - if (page != null) { - params.append("&page="); - params.append(page); - } - if (limit != null) { - params.append("&limit="); - params.append(limit); - } - MessageUtil.UTF8GetMethod utf8GetMethod = new MessageUtil.UTF8GetMethod(center_statistics_url+"center/exportChanReport?" + params.toString()); - HttpClient client = new HttpClient(); - try { - client.executeMethod(utf8GetMethod); - int statusCode = utf8GetMethod.getStatusCode(); - if (200 == statusCode) { - httpServletResponse.setContentType("application/octet-stream"); - httpServletResponse.setCharacterEncoding("UTF-8"); - httpServletResponse.setHeader("Content-Disposition", "attachment;fileName=datas.xls"); - httpServletResponse.getOutputStream().write(utf8GetMethod.getResponseBody()); - } - } catch (IOException e) { - e.printStackTrace(); - } - } - - /** - * 产检报告 - * @param request - * @return - */ - - @RequestMapping(value = "/center/queryChanJianReport", method = RequestMethod.GET) - @ResponseBody - public BaseListResponse queryCenterChanJianReport(HttpServletRequest request, - @RequestParam(required = false) Integer userId, - @RequestParam(required = false) String exDateStart, - @RequestParam(required = false) String exDateEnd, - @RequestParam(required = false) String name, - @RequestParam(required = false) Integer weekStarts, - @RequestParam(required = false) Integer weekEnds, - @RequestParam(required = false) String hbsab, - @RequestParam(required = false) String hbeag, - @RequestParam(required = false) String hbeab, - @RequestParam(required = false) String hbcab, - @RequestParam(required = false) String syphilis, - @RequestParam(required = false) String hiv, - @RequestParam(required = false) String hcv, - @RequestParam(required = false) String doctorNo, - @RequestParam(required = false) Integer page, - @RequestParam(required = false) Integer limit){ - BaseListResponse objectResponse = bookbuildingFacade.queryChanJianReport(userId, - exDateStart, - exDateEnd, - name, - weekStarts, - weekEnds, - hbsab, - hbeag, - hbeab, - hbcab, - syphilis, - hiv, - hcv, - doctorNo, - page, - limit - - ); - return objectResponse; - } - - - @RequestMapping(value = "/center/exportChanReport", method = RequestMethod.GET) - public void exportCenterChanReport(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse, - @RequestParam(required = false) Integer userId, - @RequestParam(required = false) String exDateStart, - @RequestParam(required = false) String exDateEnd, - @RequestParam(required = false) String name, - @RequestParam(required = false) Integer weekStarts, - @RequestParam(required = false) Integer weekEnds, - @RequestParam(required = false) String hbsab, - @RequestParam(required = false) String hbeag, - @RequestParam(required = false) String hbeab, - @RequestParam(required = false) String hbcab, - @RequestParam(required = false) String syphilis, - @RequestParam(required = false) String hiv, - @RequestParam(required = false) String hcv, - @RequestParam(required = false) String doctorNo, - @RequestParam(required = false) Integer page, - @RequestParam(required = false) Integer limit){ - bookbuildingFacade.exportChanReport(userId, httpServletResponse, - exDateStart, - exDateEnd, - name, - weekStarts, - weekEnds, - hbsab, - hbeag, - hbeab, - hbcab, - syphilis, - hiv, - hcv, - doctorNo); - } - - - - +package com.lyms.platform.operate.web.controller; + + +import com.lyms.platform.biz.service.GenSequenceIdService; +import com.lyms.platform.biz.service.YunBookbuildingService; +import com.lyms.platform.common.annotation.TokenRequired; +import com.lyms.platform.common.base.BaseController; +import com.lyms.platform.common.base.LoginContext; +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.MessageUtil; +import com.lyms.platform.common.utils.PropertiesUtils; +import com.lyms.platform.common.utils.StringUtils; +import com.lyms.platform.operate.web.facade.AntenatalExaminationFacade; +import com.lyms.platform.operate.web.facade.BookbuildingFacade; +import com.lyms.platform.operate.web.request.AntenatalExaminationQueryRequest; +import com.lyms.platform.operate.web.request.BookbuildingQueryRequest; +import com.lyms.platform.operate.web.request.YunBookbuildingAddRequest; +import org.apache.commons.httpclient.HttpClient; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Controller; +import org.springframework.web.bind.annotation.*; + +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +import java.io.IOException; +import java.io.UnsupportedEncodingException; +import java.net.URLEncoder; + + +/* + *孕妇建档 + * lqy + * 2016-06-15 + */ +@Controller +public class PregnantBuildController extends BaseController{ + + @Autowired + private YunBookbuildingService yunBookbuildingService; + + @Autowired + private BookbuildingFacade bookbuildingFacade; + + @Autowired + private AntenatalExaminationFacade antenatalExaminationFacade; + + @Autowired + private GenSequenceIdService genSequenceIdService; + + + /** + * 查询孕妇建档记录 + * @return + */ + @RequestMapping(value = "/getCheckTicketList", method = RequestMethod.GET) + @ResponseBody + @TokenRequired + public BaseListResponse getCheckTicketList(@RequestParam(required = true) String patientId) { + return bookbuildingFacade.getTicketList(patientId); + } + + /** + * 添加孕妇建档或者更新孕妇建档 + * @param yunBookbuildingAddRequest + * @return + */ + @RequestMapping(method = RequestMethod.POST, value = "/addOrUpdateYunBuild") + @ResponseBody + @TokenRequired + public BaseResponse addOrUpdateYunBuild(@RequestBody YunBookbuildingAddRequest yunBookbuildingAddRequest,HttpServletRequest request) { + LoginContext loginState = (LoginContext) request.getAttribute("loginContext"); + if (yunBookbuildingAddRequest != null && !StringUtils.isEmpty(yunBookbuildingAddRequest.getId()) ) + { + return bookbuildingFacade.updatePregnantById(yunBookbuildingAddRequest.getId(), yunBookbuildingAddRequest,loginState.getId()); + + } + BaseObjectResponse p = bookbuildingFacade.addPregnantBookbuilding(yunBookbuildingAddRequest,loginState.getId()); + return p; + } + + /** + * 添加孕妇建档 + * @param request + * @return + */ + @RequestMapping(method = RequestMethod.POST, value = "/createOrUpdateYunBuild") + @ResponseBody + @TokenRequired + public BaseResponse getSequenceId(@RequestBody YunBookbuildingAddRequest yunBookbuildingAddRequest,HttpServletRequest request) { + LoginContext loginState = (LoginContext) request.getAttribute("loginContext"); + if (yunBookbuildingAddRequest != null && !StringUtils.isEmpty(yunBookbuildingAddRequest.getId()) ) + { + return bookbuildingFacade.updatePregnantById(yunBookbuildingAddRequest.getId(), yunBookbuildingAddRequest,loginState.getId()); + + } + BaseObjectResponse p = bookbuildingFacade.createOrUpdateYunBuild(yunBookbuildingAddRequest,loginState.getId()); + return p; + } + + + + /** + * 删除孕妇建档 + * @param id + * @return + */ + @RequestMapping(value = "/deletePregnant/{id}", method = RequestMethod.DELETE) + @ResponseBody + @TokenRequired + public BaseResponse deletePregnantById(@PathVariable("id")String id,HttpServletRequest httpServletRequest){ + LoginContext loginState = (LoginContext) httpServletRequest.getAttribute("loginContext"); + return bookbuildingFacade.deletePregnantById(id,loginState.getId()); + } + + + + /** + * 查询孕妇建档记录 + * @return + */ + @RequestMapping(value = "/queryPregnantBuildRecord", method = RequestMethod.GET) + @ResponseBody + @TokenRequired + public BaseListResponse queryPregnantBuildRecord(@RequestParam(required = false) String id, + @RequestParam(required = false) String pid, + @RequestParam(required = false) String vcCardNo, + @RequestParam(required = false) String cardNo,HttpServletRequest httpServletRequest){ + BookbuildingQueryRequest bookbuildingQueryRequest = new BookbuildingQueryRequest(); + bookbuildingQueryRequest.setVcCardNo(vcCardNo); + bookbuildingQueryRequest.setCardNo(cardNo); + bookbuildingQueryRequest.setPid(pid); + // id，HuJiaqi添加，为了建档管理里面的查看单条使用 + bookbuildingQueryRequest.setId(id); + LoginContext loginState = (LoginContext) httpServletRequest.getAttribute("loginContext"); + BaseListResponse listResponse = bookbuildingFacade.queryPregnantBuildRecord(bookbuildingQueryRequest, loginState.getId()); + return listResponse; + } + + /** + * 查询孕妇详细建档信息通过Id + * @param id + * @return + */ + @RequestMapping(value = "/queryPregnantBuildById/{id}", method = RequestMethod.GET) + @ResponseBody + public BaseObjectResponse queryPregnantBuildRecord(@PathVariable("id")String id){ + BaseObjectResponse objectResponse = bookbuildingFacade.queryPregnantBuildById(id); + return objectResponse; + } + + + /** + * 查询儿童对应孕妇的建档记录 + * @param id 孕妇ID + * @return + */ + @RequestMapping(value = "/queryThisBabyPatient/{id}", method = RequestMethod.GET) + @ResponseBody + @TokenRequired + public BaseResponse queryThisBabyPatient(@PathVariable("id")String id,HttpServletRequest request){ + AntenatalExaminationQueryRequest antenatalExaminationQueryRequest = new AntenatalExaminationQueryRequest(); + antenatalExaminationQueryRequest.setPatientId(id); + LoginContext loginState = (LoginContext) request.getAttribute("loginContext"); + return antenatalExaminationFacade.queryAntenatalExamination(antenatalExaminationQueryRequest,loginState.getId()); + } + + /** + * 获取本院最近 + * @return + */ + @RequestMapping(value = "/queryPregnant", method = RequestMethod.GET) + @ResponseBody + @TokenRequired + public BaseResponse queryLatePregnant(HttpServletRequest request,@RequestParam("parentId")String parentId){ + LoginContext loginState = (LoginContext) request.getAttribute("loginContext"); + return bookbuildingFacade.findPatientById(parentId,loginState.getId()); + } + + + + /** + * 建档页面基础数据 + * @return + */ + @RequestMapping(value = "/getYunBuildBaseConfig", method = RequestMethod.GET) + @ResponseBody + public BaseObjectResponse getBabyBuildBaseConfig(){ + return bookbuildingFacade.getYunBuildBaseConfig(); + } + + /** + *查询孕妇建档基本信息 + * @return + */ + @RequestMapping(value = "/queryYunBuildInfo", method = RequestMethod.GET) + @ResponseBody + @TokenRequired + public BaseObjectResponse queryYunBuildInfo(HttpServletRequest request,@RequestParam(required = false) String cardNo,@RequestParam(required = false) String vcCardNo){ + LoginContext loginState = (LoginContext) request.getAttribute("loginContext"); + BaseObjectResponse objectResponse = bookbuildingFacade.queryYunBuildInfo(cardNo,vcCardNo,loginState.getId()); + return objectResponse; + } + + + + @RequestMapping(value = "/queryHospitals", method = RequestMethod.GET) + @ResponseBody + public BaseObjectResponse queryHospitals(HttpServletRequest request, + @RequestParam(required = false) String keyWord, + @RequestParam(required = false) Integer page, + @RequestParam(required = false) Integer limit){ + BaseObjectResponse objectResponse = bookbuildingFacade.queryHospitals(keyWord, page, limit); + return objectResponse; + } + + + public static final String center_statistics_url= PropertiesUtils.getPropertyValue("center_statistics_url"); + + public String paramEncode(String param) { + try { + return URLEncoder.encode(param,"utf-8"); + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + return param; + } + } + + /** + * 产检报告 + * @param request + * @return + */ + @RequestMapping(value = "/queryChanJianReport", method = RequestMethod.GET) + @TokenRequired + public void queryChanJianReport(HttpServletRequest request,HttpServletResponse response, + @RequestParam(required = false) String exDateStart, + @RequestParam(required = false) String exDateEnd, + @RequestParam(required = false) String name, + @RequestParam(required = false) Integer weekStarts, + @RequestParam(required = false) Integer weekEnds, + @RequestParam(required = false) String hbsab, + @RequestParam(required = false) String hbeag, + @RequestParam(required = false) String hbeab, + @RequestParam(required = false) String hbcab, + @RequestParam(required = false) String syphilis, + @RequestParam(required = false) String hiv, + @RequestParam(required = false) String hcv, + @RequestParam(required = false) String doctorNo, + @RequestParam(required = false) Integer page, + @RequestParam(required = false) Integer limit + ){ + LoginContext loginState = (LoginContext) request.getAttribute("loginContext"); + StringBuffer params = new StringBuffer(); + params.append("userId="); + params.append(loginState.getId()); + if (org.apache.commons.lang.StringUtils.isNotBlank(exDateStart)) { + params.append("&exDateStart="); + params.append(paramEncode(exDateStart)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(exDateEnd)) { + params.append("&exDateEnd="); + params.append(paramEncode(exDateEnd)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(name)) { + params.append("&name="); + params.append(paramEncode(name)); + } + if (weekStarts != null) { + params.append("&weekStarts="); + params.append(weekStarts); + } + if (weekEnds != null) { + params.append("&weekEnds="); + params.append(weekEnds); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(hbsab)) { + params.append("&hbsab="); + params.append(paramEncode(hbsab)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(hbeag)) { + params.append("&hbeag="); + params.append(paramEncode(hbeag)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(hbeab)) { + params.append("&hbeab="); + params.append(paramEncode(hbeab)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(hbcab)) { + params.append("&hbcab="); + params.append(paramEncode(hbcab)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(syphilis)) { + params.append("&syphilis="); + params.append(paramEncode(syphilis)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(hiv)) { + params.append("&hiv="); + params.append(paramEncode(hiv)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(hcv)) { + params.append("&hcv="); + params.append(paramEncode(hcv)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(doctorNo)) { + params.append("&doctorNo="); + params.append(paramEncode(doctorNo)); + } + if (page != null) { + params.append("&page="); + params.append(page); + } + if (limit != null) { + params.append("&limit="); + params.append(limit); + } + MessageUtil.UTF8GetMethod utf8GetMethod = new MessageUtil.UTF8GetMethod(center_statistics_url+"center/queryChanJianReport?" + params.toString()); + HttpClient client = new HttpClient(); + try { + client.executeMethod(utf8GetMethod); + int statusCode = utf8GetMethod.getStatusCode(); + if (200 == statusCode) { + String json = new String(utf8GetMethod.getResponseBodyAsString()); + writeJson(response, json); + } + } catch (IOException e) { + e.printStackTrace(); + } + } + + + @RequestMapping(value = "/exportChanReport", method = RequestMethod.GET) + @TokenRequired + public void exportChanReport(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse, + @RequestParam(required = false) String exDateStart, + @RequestParam(required = false) String exDateEnd, + @RequestParam(required = false) String name, + @RequestParam(required = false) Integer weekStarts, + @RequestParam(required = false) Integer weekEnds, + @RequestParam(required = false) String hbsab, + @RequestParam(required = false) String hbeag, + @RequestParam(required = false) String hbeab, + @RequestParam(required = false) String hbcab, + @RequestParam(required = false) String syphilis, + @RequestParam(required = false) String hiv, + @RequestParam(required = false) String hcv, + @RequestParam(required = false) String doctorNo, + @RequestParam(required = false) Integer page, + @RequestParam(required = false) Integer limit){ + LoginContext loginState = (LoginContext) httpServletRequest.getAttribute("loginContext"); + StringBuffer params = new StringBuffer(); + params.append("userId="); + params.append(loginState.getId()); + if (org.apache.commons.lang.StringUtils.isNotBlank(exDateStart)) { + params.append("&exDateStart="); + params.append(paramEncode(exDateStart)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(exDateEnd)) { + params.append("&exDateEnd="); + params.append(paramEncode(exDateEnd)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(name)) { + params.append("&name="); + params.append(paramEncode(name)); + } + if (weekStarts != null) { + params.append("&weekStarts="); + params.append(weekStarts); + } + if (weekEnds != null) { + params.append("&weekEnds="); + params.append(weekEnds); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(hbsab)) { + params.append("&hbsab="); + params.append(paramEncode(hbsab)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(hbeag)) { + params.append("&hbeag="); + params.append(paramEncode(hbeag)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(hbeab)) { + params.append("&hbeab="); + params.append(paramEncode(hbeab)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(hbcab)) { + params.append("&hbcab="); + params.append(paramEncode(hbcab)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(syphilis)) { + params.append("&syphilis="); + params.append(paramEncode(syphilis)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(hiv)) { + params.append("&hiv="); + params.append(paramEncode(hiv)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(hcv)) { + params.append("&hcv="); + params.append(paramEncode(hcv)); + } + if (org.apache.commons.lang.StringUtils.isNotBlank(doctorNo)) { + params.append("&doctorNo="); + params.append(paramEncode(doctorNo)); + } + if (page != null) { + params.append("&page="); + params.append(page); + } + if (limit != null) { + params.append("&limit="); + params.append(limit); + } + MessageUtil.UTF8GetMethod utf8GetMethod = new MessageUtil.UTF8GetMethod(center_statistics_url+"center/exportChanReport?" + params.toString()); + HttpClient client = new HttpClient(); + try { + client.executeMethod(utf8GetMethod); + int statusCode = utf8GetMethod.getStatusCode(); + if (200 == statusCode) { + httpServletResponse.setContentType("application/octet-stream"); + httpServletResponse.setCharacterEncoding("UTF-8"); + httpServletResponse.setHeader("Content-Disposition", "attachment;fileName=datas.xls"); + httpServletResponse.getOutputStream().write(utf8GetMethod.getResponseBody()); + } + } catch (IOException e) { + e.printStackTrace(); + } + } + + /** + * 产检报告 + * @param request + * @return + */ + + @RequestMapping(value = "/center/queryChanJianReport", method = RequestMethod.GET) + @ResponseBody + public BaseListResponse queryCenterChanJianReport(HttpServletRequest request, + @RequestParam(required = false) Integer userId, + @RequestParam(required = false) String exDateStart, + @RequestParam(required = false) String exDateEnd, + @RequestParam(required = false) String name, + @RequestParam(required = false) Integer weekStarts, + @RequestParam(required = false) Integer weekEnds, + @RequestParam(required = false) String hbsab, + @RequestParam(required = false) String hbeag, + @RequestParam(required = false) String hbeab, + @RequestParam(required = false) String hbcab, + @RequestParam(required = false) String syphilis, + @RequestParam(required = false) String hiv, + @RequestParam(required = false) String hcv, + @RequestParam(required = false) String doctorNo, + @RequestParam(required = false) Integer page, + @RequestParam(required = false) Integer limit){ + BaseListResponse objectResponse = bookbuildingFacade.queryChanJianReport(userId, + exDateStart, + exDateEnd, + name, + weekStarts, + weekEnds, + hbsab, + hbeag, + hbeab, + hbcab, + syphilis, + hiv, + hcv, + doctorNo, + page, + limit + + ); + return objectResponse; + } + + + @RequestMapping(value = "/center/exportChanReport", method = RequestMethod.GET) + public void exportCenterChanReport(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse, + @RequestParam(required = false) Integer userId, + @RequestParam(required = false) String exDateStart, + @RequestParam(required = false) String exDateEnd, + @RequestParam(required = false) String name, + @RequestParam(required = false) Integer weekStarts, + @RequestParam(required = false) Integer weekEnds, + @RequestParam(required = false) String hbsab, + @RequestParam(required = false) String hbeag, + @RequestParam(required = false) String hbeab, + @RequestParam(required = false) String hbcab, + @RequestParam(required = false) String syphilis, + @RequestParam(required = false) String hiv, + @RequestParam(required = false) String hcv, + @RequestParam(required = false) String doctorNo, + @RequestParam(required = false) Integer page, + @RequestParam(required = false) Integer limit){ + bookbuildingFacade.exportChanReport(userId, httpServletResponse, + exDateStart, + exDateEnd, + name, + weekStarts, + weekEnds, + hbsab, + hbeag, + hbeab, + hbcab, + syphilis, + hiv, + hcv, + doctorNo); + } + + + + } \ No newline at end of file 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 095b177..64b6932 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,1032 +1,1039 @@ -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.*; -import com.lyms.platform.common.enums.YnEnums; -import com.lyms.platform.common.utils.CompressEncodeingUtil; -import com.lyms.platform.common.utils.DateUtil; -import com.lyms.platform.common.utils.ExceptionUtils; -import com.lyms.platform.common.utils.JsonUtil; -import com.lyms.platform.operate.web.facade.AntenatalExaminationFacade; -import com.lyms.platform.operate.web.facade.BabyCheckFacade; -import com.lyms.platform.operate.web.result.HighScoreResult; -import com.lyms.platform.operate.web.service.SyncDataTaskService; -import com.lyms.platform.permission.service.OrganizationService; -import com.lyms.platform.pojo.*; -import com.lyms.platform.query.*; -import com.lyms.platform.query.AntExChuQuery; -import com.lyms.platform.query.AntExQuery; -import com.lyms.platform.query.MatDeliverQuery; -import com.lyms.platform.query.PatientsQuery; -import org.apache.commons.collections.CollectionUtils; -import org.apache.commons.io.FileUtils; -import org.apache.commons.lang.StringUtils; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.data.domain.Sort; -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; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.ResponseBody; - -import java.io.File; -import java.io.IOException; -import java.util.*; - -/** - * Created by Zhang.Rui on 2016/4/8. - * 测试数据, 假数据 - */ -@Controller -public class TestController { - - - @Autowired - private MongoTemplate mongoTemplate; - - @Autowired - private PatientsService patientsService; - - @Autowired - private QhdfyHisService qhdfyHisService; - - @Autowired - private SyncDataTaskService syncDataTaskService; - @Autowired - private SieveService sieveService; - - @Autowired - private OrganizationService organizationService; - - @Autowired - private AntenatalExaminationService antenatalExaminationService; - - - @Autowired - private AntenatalExaminationFacade antenatalExaminationFacade; - - @Autowired - private MatDeliverService matDeliverService; - - @Autowired - private BabyBookbuildingService babyBookbuildingService; - - @Autowired - private BabyCheckService babyCheckService; - - - @Autowired - private BabyCheckFacade babyCheckFacade; - - @Autowired - private QhdfyFmService qhdfyFmService; -; - - /** - * 获取科室 - */ - @RequestMapping(value = "/hospitalDepartmentTest", method = RequestMethod.GET) - @ResponseBody - public List getDepartment() { - List list = new ArrayList<>(); - Map m = new HashMap<>(); - - m = new HashMap<>(); - m.put("id", String.valueOf(1)); - m.put("name", "妇产科"); - list.add(m); - - m = new HashMap<>(); - m.put("id", String.valueOf(2)); - m.put("name", "眼科"); - list.add(m); - - m = new HashMap<>(); - m.put("id", String.valueOf(3)); - m.put("name", "五官科"); - list.add(m); - - m = new HashMap<>(); - m.put("id", String.valueOf(4)); - m.put("name", "胸腔科"); - list.add(m); - - return list; - } - - - /** - * 获取医院 - */ - @RequestMapping(value = "/hospitalsTest", method = RequestMethod.GET) - @ResponseBody - public List getSampleTypeEnum() { - List list = new ArrayList<>(); - Map m = new HashMap<>(); - - m = new HashMap<>(); - m.put("id", String.valueOf(1)); - m.put("name", "秦皇岛安琪儿医院"); - list.add(m); - - m = new HashMap<>(); - m.put("id", String.valueOf(2)); - m.put("name", "成都市妇幼保健医院"); - list.add(m); - - m = new HashMap<>(); - m.put("id", String.valueOf(3)); - m.put("name", "成都市九龙医院"); - list.add(m); - - m = new HashMap<>(); - m.put("id", String.valueOf(4)); - m.put("name", "成都人民医院"); - list.add(m); - - m = new HashMap<>(); - m.put("id", String.valueOf(10)); - m.put("name", "成都脑瘤医院"); - list.add(m); - - return list; - } - - -// @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 = "/uncompress", method = RequestMethod.GET) - @ResponseBody - public String uncompress(String watermark) { - Long l = CompressEncodeingUtil.unCompressNumber(watermark); - String s = l.toString(); - int len = s.length(); - return s.substring(0,len-6) + "," + s.substring(len-6); - } - - @RequestMapping(value = "/addSieveJob", method = RequestMethod.GET) - @ResponseBody - public String addSieveJob() { - patientsService.addSieveJob();; - return "finish"; - } - - @RequestMapping(value = "/autoMatDeliver", method = RequestMethod.GET) - @ResponseBody - public String autoMatDeliver() { - patientsService.autoMatDeliver();; - return "finish"; - } - - @RequestMapping(value = "/delSieve", method = RequestMethod.GET) - @ResponseBody - public String delSieve() { - patientsService.delSieve();; - return "finish"; - } - - @RequestMapping(value = "/syncLisReportTask", method = RequestMethod.GET) - @ResponseBody - public String syncLisReportTask(@RequestParam(required = true)String time) { - qhdfyHisService.syncLisReportTask(time); - return "finish"; - } - - @Autowired - private AssayConfigService assayConfigService; - - @RequestMapping(value = "/assayconfiginit", method = RequestMethod.POST) - @ResponseBody - public String assayconfiginit(String json) { - try { - List list = JsonUtil.toList(json, AssayConfig.class); - for (AssayConfig config:list) { - assayConfigService.save(config); - } - } catch (Exception e) { - e.printStackTrace(); - } - return "assayconfiginit"; - } - - @RequestMapping(value = "/updateXY", method = RequestMethod.GET) - @ResponseBody - public String updateXY() { - syncDataTaskService.updateXY(); - return "finish"; - } - - @RequestMapping(value = "/syncQhdfyCsv", method = RequestMethod.GET) - @ResponseBody - public String syncQhdfyCsv() { - syncDataTaskService.syncQhdfyCsv(); - return "finish"; - } - - @RequestMapping(value = "/orderSieve", method = RequestMethod.GET) - @ResponseBody - public String orderSieve() { - syncDataTaskService.orderSieve(); - return "orderSieve finish"; - } - - @RequestMapping(value = "/sieveResult", method = RequestMethod.GET) - @ResponseBody - public String sieveResult() { - syncDataTaskService.sieveResult(); - return "sieveResult finish"; - } - - @RequestMapping(value = "/execsieve", method = RequestMethod.GET) - @ResponseBody - public String sieveResult1() { - syncDataTaskService.syncQhdSieve(); - return "syncQhdSieve finish"; - } - @RequestMapping(value = "/execsieveorder", method = RequestMethod.GET) - @ResponseBody - public String sieveOrder() { - sieveService.correctSieveOrder(); - return "sieveOrder 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"; - } - - @RequestMapping(value = "/rebuildDefaultRoles", method = RequestMethod.GET) - @ResponseBody - public String rebuildDefaultRoles() { - organizationService.rebuildDefaultRoles(); - return "sieveOrder finish"; - } - - - /** - * 修改最后一次产检时间冗余到patient中 - * @param hid - * @return - */ - @RequestMapping(value = "/syncPatNextTime", method = RequestMethod.GET) - @ResponseBody - public String syncPatNextTime(@RequestParam(required = true) String hid) { - PatientsQuery patientQuery = new PatientsQuery(); - patientQuery.setYn(YnEnums.YES.getId()); - patientQuery.setHospitalId(hid); - patientQuery.setType(1); - List patientses = patientsService.queryPatient(patientQuery); - int batchSize = 1000; - int end = 0; - for (int i = 0; i < patientses.size(); i += batchSize) { - end = (end + batchSize); - if (end > patientses.size()) { - end = patientses.size(); - } - System.out.println("start:" + i + ",end:" + end); - final List tempList = patientses.subList(i, end); - new Thread(new Runnable() { - @Override - public void run() { - if (CollectionUtils.isNotEmpty(tempList)) - { - for (Patients pat : tempList) { - AntExChuQuery antExChuQuery = new AntExChuQuery(); - antExChuQuery.setYn(YnEnums.YES.getId()); - antExChuQuery.setHospitalId(pat.getHospitalId()); - antExChuQuery.setParentId(pat.getId()); - List chus = antenatalExaminationService.queryAntExChu(antExChuQuery); - if (CollectionUtils.isNotEmpty(chus)) { - Date nextTime = null; - AntExChuModel chu = chus.get(0); - if (chu != null) - { - nextTime = chu.getNextCheckTime(); - AntExQuery antExQuery = new AntExQuery(); - antExQuery.setParentId(pat.getId()); - antExQuery.setYn(YnEnums.YES.getId()); - antExQuery.setHospitalId(pat.getHospitalId()); - List list = antenatalExaminationService.queryAntenatalExamination(antExQuery.convertToQuery().addOrder(Sort.Direction.DESC, "created")); - if (CollectionUtils.isNotEmpty(list)) - { - AntenatalExaminationModel ae = list.get(0); - if (ae != null) - { - nextTime = ae.getNextCheckTime(); - } - } - patientsService.updatePatientOneCol(pat.getId(), nextTime); - - } - - } - } - } - } - }).start(); - } - - return "syncPatNextTime finish"; - } - - /** - * @auther HuJiaqi - * @createTime 2016年12月21日 15时56分 - * @discription 冗余最后一次产检 - */ - @ResponseBody - @RequestMapping(value = "/syncPatientsLastCheckEmployeeId", method = RequestMethod.GET) - public String syncPatientsLastCheckEmployeeId(@RequestParam String hospitalId, - @RequestParam(required = false) String size) { - PatientsQuery patientsQuery = new PatientsQuery(); - patientsQuery.setYn(YnEnums.YES.getId()); - // 医院id - patientsQuery.setHospitalId(hospitalId); - List typeList = new ArrayList<>(); - // 孕妇 - typeList.add(1); - // 产妇 - typeList.add(3); - patientsQuery.setTypeList(typeList); - // 查询 - List patientsList = patientsService.queryPatient(patientsQuery); - System.out.println("本次读取了【" + patientsList.size() + "】条数据"); - int batchSize = StringUtils.isEmpty(size) ? 1000 : Integer.valueOf(size); - int end = 0; - for (int i = 0; i < patientsList.size(); i += batchSize) { - end = (end + batchSize); - if (end > patientsList.size()) { - end = patientsList.size(); - } - final List tempList = patientsList.subList(i, end); - new Thread(new Runnable() { - @Override - public void run() { - if (CollectionUtils.isNotEmpty(tempList)) { - for (Patients patients : tempList) { - String id = patients.getId(); - String hospitalId = patients.getHospitalId(); - String lastCheckEmployeeId = null; - String flag; - // 查询复诊，如果没有再查询初诊 - AntExQuery antExQuery = new AntExQuery(); - antExQuery.setYn(YnEnums.YES.getId()); - antExQuery.setParentId(id); - antExQuery.setHospitalId(hospitalId); - List antenatalExaminationModelList = antenatalExaminationService.queryAntenatalExamination(antExQuery.convertToQuery().addOrder(Sort.Direction.DESC, "created")); - if (CollectionUtils.isNotEmpty(antenatalExaminationModelList)) { - lastCheckEmployeeId = antenatalExaminationModelList.get(0).getCheckDoctor(); - flag = "复诊"; - } else { - // 查询初诊 - AntExChuQuery antExChuQuery = new AntExChuQuery(); - antExChuQuery.setYn(YnEnums.YES.getId()); - antExChuQuery.setParentId(id); - antExChuQuery.setHospitalId(hospitalId); - List antExChuModelList = antenatalExaminationService.queryAntExChu(antExChuQuery); - if (antExChuModelList.size() == 1) { - lastCheckEmployeeId = antExChuModelList.get(0).getProdDoctor(); - } - flag = "初诊"; - } - if (!StringUtils.isEmpty(lastCheckEmployeeId)) { - patientsService.updatePatientLastCheckEmployeeIdOne(id, lastCheckEmployeeId); - System.out.println("更新lyms_patient：id=" + id + "，lastCheckEmployeeId=" + lastCheckEmployeeId + "，来自" + flag); - } - } - } - } - }).start(); - } - return "syncPatientsLastCheckEmployeeId start......"; - } - - /** - * @auther HuJiaqi - * @createTime 2016年12月21日 15时56分 - * @discription 冗余分娩分娩医院，分娩年龄，分娩孕周，分娩方式 - */ - @ResponseBody - @RequestMapping(value = "/syncPatientsFmInfo", method = RequestMethod.GET) - public String syncPatientsFmInfo(@RequestParam(required = false) String size,@RequestParam(required = false) String hospitalId) { - MatDeliverQuery matDeliverQuery = new MatDeliverQuery(); - matDeliverQuery.setYn(YnEnums.YES.getId()); - if (StringUtils.isNotEmpty(hospitalId)) { - matDeliverQuery.setFmHospital(hospitalId); - } - // 查询 - List maternalDeliverModelList = matDeliverService.query(matDeliverQuery); - System.out.println("本次读取了【" + maternalDeliverModelList.size() + "】条数据"); - int batchSize = StringUtils.isEmpty(size) ? 1000 : Integer.valueOf(size); - int end = 0; - for (int i = 0; i < maternalDeliverModelList.size(); i += batchSize) { - end = (end + batchSize); - if (end > maternalDeliverModelList.size()) { - end = maternalDeliverModelList.size(); - } - final List tempList = maternalDeliverModelList.subList(i, end); - new Thread(new Runnable() { - @Override - public void run() { - if (CollectionUtils.isNotEmpty(tempList)) { - for (MaternalDeliverModel maternalDeliverModel : tempList) { - Patients patients = patientsService.findOnePatientById(maternalDeliverModel.getParentId()); - if (patients != null) { - // 顺便跑成产妇 - patients.setType(3); - patients.setFmHospital(maternalDeliverModel.getHospitalId()); - patients.setFmType(maternalDeliverModel.getDeliveryMode()); - try { - patients.setFmAge(DateUtil.getAge(patients.getBirth(), patients.getFmDate())); - } catch (Exception e) { - System.out.println(patients.getId() + "：这条数据的生日和分娩时间异常"); - // 跳过 - } - try { - patients.setFmWeek(DateUtil.getDays(patients.getLastMenses(), patients.getFmDate())); - } catch (Exception e) { - System.out.println(patients.getId() + "：这条数据的末日月经和分娩时间异常"); - // 跳过 - } - - System.out.println(patients.getFmHospital()); - System.out.println(patients.getFmType()); - System.out.println(patients.getFmAge()); - System.out.println(patients.getFmWeek()); - System.out.println(patients.toString()); - - patientsService.updatePatient(patients); - } - } - } - } - }).start(); - } - return "syncPatientsLastCheckEmployeeId start......"; - } - - /** - * @auther HuJiaqi - * @createTime 2016年12月21日 15时56分 - * @discription 冗余分娩分娩医院，分娩年龄，分娩孕周，分娩方式 - */ - @ResponseBody - @RequestMapping(value = "/syncPatientsFmInfo1", method = RequestMethod.GET) - public String syncPatientsFmInfo1(@RequestParam(required = false) String size) { - PatientsQuery patientsQuery = new PatientsQuery(); - patientsQuery.setYn(YnEnums.YES.getId()); - patientsQuery.setType(3); - // 查询 - List patientsList = patientsService.queryPatient(patientsQuery); - System.out.println("本次读取了【" + patientsList.size() + "】条数据"); - int batchSize = StringUtils.isEmpty(size) ? 1000 : Integer.valueOf(size); - int end = 0; - for (int i = 0; i < patientsList.size(); i += batchSize) { - end = (end + batchSize); - if (end > patientsList.size()) { - end = patientsList.size(); - } - final List tempList = patientsList.subList(i, end); - new Thread(new Runnable() { - @Override - public void run() { - if (CollectionUtils.isNotEmpty(tempList)) { - for (Patients patients : tempList) { - - try { - patients.setFmAge(DateUtil.getAge(patients.getBirth(), patients.getFmDate())); - } catch (Exception e) { - System.out.println(patients.getId() + "：这条数据的生日和分娩时间异常"); - // 跳过 - } - try { - patients.setFmWeek(DateUtil.getDays(patients.getLastMenses(), patients.getFmDate())); - } catch (Exception e) { - System.out.println(patients.getId() + "：这条数据的末日月经和分娩时间异常"); - // 跳过 - } - if(StringUtils.isNotEmpty(patients.getFmHospital())){ - patients.setIsAutoFm(YnEnums.NO.getId()); - }else{ - patients.setIsAutoFm(YnEnums.YES.getId()); - } - - System.out.println(patients.getFmAge()); - System.out.println(patients.getFmWeek()); - - patientsService.updatePatient(patients); - } - } - } - }).start(); - } - return "syncPatientsLastCheckEmployeeId start......"; - } - - @RequestMapping(value = "/initCardNo", method = RequestMethod.GET) - @ResponseBody - public String initCardNo() { - PatientsQuery query = new PatientsQuery(); - query.setYn(1); - query.setHospitalId("216"); - List list = patientsService.queryPatient(query); - int a = 0; - for (Patients patients:list) { - if (org.apache.commons.lang.StringUtils.isBlank(patients.getCardNo())) { - Patients db = new Patients(); - db.setId(patients.getId()); - db.setCardNo(patients.getPhone()); - db.setHcertificateTypeId("hcertificateTypeId"); - patientsService.updatePatient(db); - a++; - } - } - return "initCardNo finish - " + a; - } - - - /** - * 修改高危因素中包含健康的 把健康去掉 - * @param hid - * @return - */ - @RequestMapping(value = "/modifyRiskFactor", method = RequestMethod.GET) - @ResponseBody - public String modifyRiskFactor(@RequestParam(required = true) String hid) { - PatientsQuery patientQuery = new PatientsQuery(); - patientQuery.setYn(YnEnums.YES.getId()); - patientQuery.setHospitalId(hid); - patientQuery.setrLevel("e637b361-99cf-41eb-84f2-f0dab596e928"); - - List patientses = patientsService.queryPatient(patientQuery); - int batchSize = 500; - int end = 0; - for (int i = 0; i < patientses.size(); i += batchSize) { - end = (end + batchSize); - if (end > patientses.size()) { - end = patientses.size(); - } - System.out.println("start:" + i + ",end:" + end); - final List tempList = patientses.subList(i, end); - new Thread(new Runnable() { - @Override - public void run() { - if (CollectionUtils.isNotEmpty(tempList)) - { - for (Patients pat : tempList) { - if (pat != null) - { - String levelStr = pat.getRiskLevelId(); - if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(levelStr)) - { - List levels = JsonUtil.toList(levelStr, String.class); - if (CollectionUtils.isNotEmpty(levels) && levels.contains("e637b361-99cf-41eb-84f2-f0dab596e928") && levels.size() > 1) - { - List rFactors = pat.getRiskFactorId(); - if (CollectionUtils.isNotEmpty(rFactors) && rFactors.contains("d42eec03-aa86-45b8-a4e0-78a0ff365fb6")) - { - rFactors.remove("d42eec03-aa86-45b8-a4e0-78a0ff365fb6"); - levels.remove("e637b361-99cf-41eb-84f2-f0dab596e928"); - pat.setRiskFactorId(rFactors); - String resultLevel = JsonUtil.array2JsonString(levels); - pat.setRiskLevelId(resultLevel); - patientsService.updatePatient(pat); - - AntExChuQuery antExChuQuery = new AntExChuQuery(); - antExChuQuery.setYn(YnEnums.YES.getId()); - antExChuQuery.setParentId(pat.getId()); - antExChuQuery.setHospitalId(pat.getHospitalId()); - List antExChuModelList = antenatalExaminationService.queryAntExChu(antExChuQuery); - if (CollectionUtils.isNotEmpty(antExChuModelList)) - { - for(AntExChuModel cmodel : antExChuModelList) - { - String highriskStr = cmodel.getHighrisk(); - String otherRisk = cmodel.getOtherHighRisk(); - if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(highriskStr)) - { - List highrisks = JsonUtil.toList(highriskStr, String.class); - if (CollectionUtils.isNotEmpty(highrisks) && highrisks.contains("d42eec03-aa86-45b8-a4e0-78a0ff365fb6") && highrisks.size() > 1) - { - highrisks.remove("d42eec03-aa86-45b8-a4e0-78a0ff365fb6"); - cmodel.setHighrisk(JsonUtil.array2JsonString(highrisks)); - antenatalExaminationService.updateAntExChu(cmodel,cmodel.getId()); - } - else if (CollectionUtils.isNotEmpty(highrisks) && highrisks.contains("d42eec03-aa86-45b8-a4e0-78a0ff365fb6") && !"{}".equals(otherRisk)) - { - highrisks.remove("d42eec03-aa86-45b8-a4e0-78a0ff365fb6"); - cmodel.setHighrisk(JsonUtil.array2JsonString(highrisks)); - antenatalExaminationService.updateAntExChu(cmodel,cmodel.getId()); - } - } - } - - // 查询复诊 - AntExQuery antExQuery = new AntExQuery(); - antExQuery.setYn(YnEnums.YES.getId()); - antExQuery.setParentId(pat.getId()); - antExQuery.setHospitalId(pat.getHospitalId()); - List antenatalExaminationModelList = antenatalExaminationService.queryAntenatalExamination(antExQuery.convertToQuery()); - if (CollectionUtils.isNotEmpty(antenatalExaminationModelList)) { - for (AntenatalExaminationModel fmodel : antenatalExaminationModelList) { - String highriskStr = fmodel.getRiskFactor(); - String otherRisk = fmodel.getOtherRisk(); - if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(highriskStr)) - { - List highrisks = JsonUtil.toList(highriskStr, String.class); - if (CollectionUtils.isNotEmpty(highrisks) && highrisks.contains("d42eec03-aa86-45b8-a4e0-78a0ff365fb6") && highrisks.size() > 1) - { - highrisks.remove("d42eec03-aa86-45b8-a4e0-78a0ff365fb6"); - fmodel.setRiskFactor(JsonUtil.array2JsonString(highrisks)); - antenatalExaminationService.updateOneAnt(fmodel,fmodel.getId()); - } - else if (CollectionUtils.isNotEmpty(highrisks) && highrisks.contains("d42eec03-aa86-45b8-a4e0-78a0ff365fb6") && !"{}".equals(otherRisk)) - { - highrisks.remove("d42eec03-aa86-45b8-a4e0-78a0ff365fb6"); - fmodel.setRiskFactor(JsonUtil.array2JsonString(highrisks)); - antenatalExaminationService.updateOneAnt(fmodel, fmodel.getId()); - } - } - } - } - - } - } - } - - } - - } - } - } - } - }).start(); - } - - return "modifyRiskFactor finish"; - } - - - /** - * 更新产妇当前产程最后一次高危因素冗余到 patient中 - * @param hid - * @return - */ - @RequestMapping(value = "/updateChanLaskRisk", method = RequestMethod.GET) - @ResponseBody - public String updateChanLaskRisk(@RequestParam(required = true) String hid) { - PatientsQuery patientQuery = new PatientsQuery(); - patientQuery.setYn(YnEnums.YES.getId()); - patientQuery.setHospitalId(hid); - patientQuery.setType(3); - - List patientses = patientsService.queryPatient(patientQuery); - int batchSize = 500; - int end = 0; - for (int i = 0; i < patientses.size(); i += batchSize) { - end = (end + batchSize); - if (end > patientses.size()) { - end = patientses.size(); - } - System.out.println("start:" + i + ",end:" + end); - final List tempList = patientses.subList(i, end); - new Thread(new Runnable() { - @Override - public void run() { - if (CollectionUtils.isNotEmpty(tempList)) - { - for (Patients pat : tempList) { - if (pat != null) - { - Date min = pat.getLastMenses(); - Date max = pat.getFmDate(); - if (min != null && max != null) - { - HighScoreResult highScoreResult = antenatalExaminationFacade.getPatLastRiskByDate(pat.getPid(), true, min, max); - PatientsQuery patientsQuery1 = new PatientsQuery(); - patientsQuery1.setId(pat.getId()); - patientsQuery1.setYn(YnEnums.YES.getId()); - - Patients patients1 = new Patients(); - patients1.setModified(new Date()); - patients1.setRiskScore(highScoreResult.getScore()); - patients1.setRiskFactorId(highScoreResult.getHighId()); - patients1.setRiskLevelId(JsonUtil.array2JsonString(highScoreResult.getLevelId())); - //设置其他的高危因素 - patients1.setoRiskFactor(highScoreResult.getOtherRisk()); - patientsService.findAndModify(patientsQuery1, patients1); - } - } - } - } - } - }).start(); - } - - return "updateChanLaskRisk finish"; - } - - /** - * 更新儿童检查表中的生长发育评价 - * @param hid - * @return - */ - @RequestMapping(value = "/updateBabyGrowth", method = RequestMethod.GET) - @ResponseBody - public String updateBabyGrowth(@RequestParam(required = true) String hid) { - - BabyModelQuery babyModelQuery = new BabyModelQuery(); - babyModelQuery.setYn(YnEnums.YES.getId()); - babyModelQuery.setHospitalId(hid); - - List models = babyBookbuildingService.queryBabyBuildByCond(babyModelQuery); - if (CollectionUtils.isNotEmpty(models)) - { - int batchSize = 200; - int end = 0; - for (int i = 0; i < models.size(); i += batchSize) { - end = (end + batchSize); - if (end > models.size()) { - end = models.size(); - } - System.out.println("start:" + i + ",end:" + end); - final List tempList = models.subList(i, end); - new Thread(new Runnable() { - @Override - public void run() { - if (CollectionUtils.isNotEmpty(tempList)) - { - for (BabyModel babyModel : tempList) { - if (babyModel != null) - { - BabyCheckModelQuery query = new BabyCheckModelQuery(); - query.setYn(YnEnums.YES.getId()); - query.setBuildId(babyModel.getId()); - - List checkModels = babyCheckService.queryBabyCheckRecord(query); - if (CollectionUtils.isNotEmpty(checkModels)) - { - for (BabyCheckModel checkModel : checkModels) - { - String height = checkModel.getHeight(); - String birth = DateUtil.getyyyy_MM_dd(babyModel.getBirth()); - if (!com.lyms.platform.common.utils.StringUtils.isNotEmpty(birth)) - { - continue; - } - // type 0 体重标准差数值表 1 身长/身高标准差数值表 2 头围标准差数值表 3身高别体重 - if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(height)) - { - String value = babyCheckFacade.getGrowthValue(birth,Double.parseDouble(height),babyModel.getSex(),1); - checkModel.setHeightEvaluate(value); - - } - String head = checkModel.getHead(); - if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(head)) { - String value = babyCheckFacade.getGrowthValue(birth,Double.parseDouble(head),babyModel.getSex(),2); - checkModel.setHeadEvaluate(value); - } - - String weight = checkModel.getWeight(); - if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(weight)) { - String value = babyCheckFacade.getGrowthValue(birth,Double.parseDouble(weight),babyModel.getSex(),0); - checkModel.setWeightEvaluate(value); - } - - if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(height) && - com.lyms.platform.common.utils.StringUtils.isNotEmpty(weight)) - { - //发育评价 - List growthEvaluate = babyCheckFacade.getBabyGrowthEvaluate(Double.parseDouble(height), babyModel.getSex(), birth, Double.parseDouble(weight)); - if (CollectionUtils.isNotEmpty(growthEvaluate)) - { - checkModel.setGrowthEvaluate(JsonUtil.array2JsonString(growthEvaluate)); - } - - String hw = babyCheckFacade.getBabyHW(Double.parseDouble(height),Double.parseDouble(weight),babyModel.getSex(),birth); - checkModel.setHeightWeight(hw); - - } - checkModel.setHospitalId(checkModel.getHospitalId()); - checkModel.setBirth(babyModel.getBirth()); - - checkModel.setCheckMonth(DateUtil.getBabyAgeMonth(babyModel.getBirth(), checkModel.getCheckDate())); - babyCheckService.updateBabyCheck(checkModel,checkModel.getId()); - } - } - } - } - } - } - }).start(); - } - - } - - - return "updateBabyGrowth finish"; - } - - - /** - * 修正儿童助产机构 - * @param hid - * @return - */ - @RequestMapping(value = "/updateBabyFmHospital", method = RequestMethod.GET) - @ResponseBody - public String updateBabyFmHospital(@RequestParam(required = true) String hid) { - - BabyModelQuery babyModelQuery = new BabyModelQuery(); - babyModelQuery.setYn(YnEnums.YES.getId()); - babyModelQuery.setHospitalId(hid); - - List models = babyBookbuildingService.queryBabyBuildByCond(babyModelQuery); - if (CollectionUtils.isNotEmpty(models)) - { - int batchSize = 200; - int end = 0; - for (int i = 0; i < models.size(); i += batchSize) { - end = (end + batchSize); - if (end > models.size()) { - end = models.size(); - } - System.out.println("start:" + i + ",end:" + end); - final List tempList = models.subList(i, end); - new Thread(new Runnable() { - @Override - public void run() { - if (CollectionUtils.isNotEmpty(tempList)) - { - for (BabyModel babyModel : tempList) { - if (babyModel != null && com.lyms.platform.common.utils.StringUtils.isNotEmpty(babyModel.getMcertNo())) - { - PatientsQuery patientsQuery = new PatientsQuery(); - patientsQuery.setYn(YnEnums.YES.getId()); - patientsQuery.setType(3); - patientsQuery.setCardNo(babyModel.getMcertNo()); - List patients = patientsService.queryPatient(patientsQuery); - if (CollectionUtils.isNotEmpty(patients)) - { - for(Patients pat : patients) - { - MatDeliverQuery matDeliverQuery = new MatDeliverQuery(); - matDeliverQuery.setYn(YnEnums.YES.getId()); - matDeliverQuery.setParentId(pat.getId()); - List lists = matDeliverService.query(matDeliverQuery); - if (CollectionUtils.isNotEmpty(lists)) - { - if (lists.get(0) != null && com.lyms.platform.common.utils.StringUtils.isNotEmpty(lists.get(0).getFmHospital())) - { - babyModel.setDeliverOrg(lists.get(0).getFmHospital()); - babyBookbuildingService.updateBabyBuild(babyModel,babyModel.getId()); - break; - } - } - } - } - } - } - } - } - }).start(); - } - - } - - - return "updateBabyFmHospital finish"; - } - - @RequestMapping(value = "/updateBabyFmHid", method = RequestMethod.GET) - @ResponseBody - public String updateBabyFmHid() { - List list = null; - try { - list = FileUtils.readLines(new File("D:\\QHD.csv"), "gbk"); - for (String line:list) { - String ss[] = line.split(","); - if (ss.length > 1 && ss[0].trim().length() > 0) { - if (ss[0] != null) - { - - String id = ss[0].replace("-",""); - String name = ss[1]; - String oid = String.valueOf(JdbcUtil.getQhdMysqlSingleObjBySql("select id from organization where name = '" + name + "'", JdbcUtil.getQhdMysqlConnection())); - BabyModelQuery babyModelQuery = new BabyModelQuery(); - babyModelQuery.setYn(YnEnums.YES.getId()); - babyModelQuery.setId(id); - - List models = babyBookbuildingService.queryBabyBuildByCond(babyModelQuery); - if (CollectionUtils.isNotEmpty(models) && com.lyms.platform.common.utils.StringUtils.isNotEmpty(oid)) { - System.out.println(ss[0]+"==="+ss[1]); - BabyModel model = models.get(0); - model.setDeliverOrg(oid); - babyBookbuildingService.updateBabyBuild(model, model.getId()); - } - } - } - } - } catch (IOException e) { - ExceptionUtils.catchException(e,"跟新异常"); - e.printStackTrace(); - } - 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"; - } - - @RequestMapping(value = "/syncFmBySyxh", method = RequestMethod.GET) - @ResponseBody - public String syncFmBySyxh(@RequestParam(required = true) String start,@RequestParam(required = true) String end,@RequestParam(required = false) String syxh) { - qhdfyFmService.syncByPhone(start,end,syxh); - return "syncFmBySyxh finish"; - } - - public static void main(String[] a) { - try { - List list = FileUtils.readLines(new File("D:\\QHD.csv"), "gbk"); - List linenums = new ArrayList<>(); - for (String line:list) { - String ss[] = line.split(","); - if (ss.length > 0 && ss[0].trim().length() > 0) { - System.out.println(ss[0]+" "+ ss[1]); - } - } -// List list1 = FileUtils.readLines(new File("D:\\temp\\qhd-jd.csv"), "utf-8"); -// StringBuffer sb = new StringBuffer(); -// for (String line:list1) { -// String ss[] = line.split(","); -// if (ss.length > 0 && ss[0].trim().length() > 0 && linenums.contains(ss[0].trim())) { -// sb.append(line); -// sb.append("\r\n"); -// } -// } -// FileUtils.writeStringToFile(new File("d:\\temp\\qhdfy_lost_data.csv"), sb.toString()); - } catch (Exception e) { - e.printStackTrace(); - } - } - -} +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.*; +import com.lyms.platform.common.enums.YnEnums; +import com.lyms.platform.common.utils.CompressEncodeingUtil; +import com.lyms.platform.common.utils.DateUtil; +import com.lyms.platform.common.utils.ExceptionUtils; +import com.lyms.platform.common.utils.JsonUtil; +import com.lyms.platform.operate.web.facade.AntenatalExaminationFacade; +import com.lyms.platform.operate.web.facade.BabyCheckFacade; +import com.lyms.platform.operate.web.result.HighScoreResult; +import com.lyms.platform.operate.web.service.SyncDataTaskService; +import com.lyms.platform.permission.service.OrganizationService; +import com.lyms.platform.pojo.*; +import com.lyms.platform.query.*; +import com.lyms.platform.query.AntExChuQuery; +import com.lyms.platform.query.AntExQuery; +import com.lyms.platform.query.MatDeliverQuery; +import com.lyms.platform.query.PatientsQuery; +import org.apache.commons.collections.CollectionUtils; +import org.apache.commons.io.FileUtils; +import org.apache.commons.lang.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.domain.Sort; +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; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.ResponseBody; + +import java.io.File; +import java.io.IOException; +import java.util.*; + +/** + * Created by Zhang.Rui on 2016/4/8. + * 测试数据, 假数据 + */ +@Controller +public class TestController { + + + @Autowired + private MongoTemplate mongoTemplate; + + @Autowired + private PatientsService patientsService; + + @Autowired + private QhdfyHisService qhdfyHisService; + + @Autowired + private SyncDataTaskService syncDataTaskService; + @Autowired + private SieveService sieveService; + + @Autowired + private OrganizationService organizationService; + + @Autowired + private AntenatalExaminationService antenatalExaminationService; + + + @Autowired + private AntenatalExaminationFacade antenatalExaminationFacade; + + @Autowired + private MatDeliverService matDeliverService; + + @Autowired + private BabyBookbuildingService babyBookbuildingService; + + @Autowired + private BabyCheckService babyCheckService; + + + @Autowired + private BabyCheckFacade babyCheckFacade; + + @Autowired + private QhdfyFmService qhdfyFmService; + + @Autowired + private GenSequenceIdService genIdService; + /** + * 获取科室 + */ + @RequestMapping(value = "/hospitalDepartmentTest", method = RequestMethod.GET) + @ResponseBody + public List getDepartment() { + List list = new ArrayList<>(); + Map m = new HashMap<>(); + + m = new HashMap<>(); + m.put("id", String.valueOf(1)); + m.put("name", "妇产科"); + list.add(m); + + m = new HashMap<>(); + m.put("id", String.valueOf(2)); + m.put("name", "眼科"); + list.add(m); + + m = new HashMap<>(); + m.put("id", String.valueOf(3)); + m.put("name", "五官科"); + list.add(m); + + m = new HashMap<>(); + m.put("id", String.valueOf(4)); + m.put("name", "胸腔科"); + list.add(m); + + return list; + } + + + /** + * 获取医院 + */ + @RequestMapping(value = "/hospitalsTest", method = RequestMethod.GET) + @ResponseBody + public List getSampleTypeEnum() { + List list = new ArrayList<>(); + Map m = new HashMap<>(); + + m = new HashMap<>(); + m.put("id", String.valueOf(1)); + m.put("name", "秦皇岛安琪儿医院"); + list.add(m); + + m = new HashMap<>(); + m.put("id", String.valueOf(2)); + m.put("name", "成都市妇幼保健医院"); + list.add(m); + + m = new HashMap<>(); + m.put("id", String.valueOf(3)); + m.put("name", "成都市九龙医院"); + list.add(m); + + m = new HashMap<>(); + m.put("id", String.valueOf(4)); + m.put("name", "成都人民医院"); + list.add(m); + + m = new HashMap<>(); + m.put("id", String.valueOf(10)); + m.put("name", "成都脑瘤医院"); + list.add(m); + + return list; + } + + +// @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 = "/uncompress", method = RequestMethod.GET) + @ResponseBody + public String uncompress(String watermark) { + Long l = CompressEncodeingUtil.unCompressNumber(watermark); + String s = l.toString(); + int len = s.length(); + return s.substring(0,len-6) + "," + s.substring(len-6); + } + + @RequestMapping(value = "/addSieveJob", method = RequestMethod.GET) + @ResponseBody + public String addSieveJob() { + patientsService.addSieveJob();; + return "finish"; + } + + @RequestMapping(value = "/autoMatDeliver", method = RequestMethod.GET) + @ResponseBody + public String autoMatDeliver() { + patientsService.autoMatDeliver();; + return "finish"; + } + + @RequestMapping(value = "/delSieve", method = RequestMethod.GET) + @ResponseBody + public String delSieve() { + patientsService.delSieve();; + return "finish"; + } + + @RequestMapping(value = "/syncLisReportTask", method = RequestMethod.GET) + @ResponseBody + public String syncLisReportTask(@RequestParam(required = true)String time) { + qhdfyHisService.syncLisReportTask(time); + return "finish"; + } + + @Autowired + private AssayConfigService assayConfigService; + + @RequestMapping(value = "/assayconfiginit", method = RequestMethod.POST) + @ResponseBody + public String assayconfiginit(String json) { + try { + List list = JsonUtil.toList(json, AssayConfig.class); + for (AssayConfig config:list) { + assayConfigService.save(config); + } + } catch (Exception e) { + e.printStackTrace(); + } + return "assayconfiginit"; + } + + @RequestMapping(value = "/updateXY", method = RequestMethod.GET) + @ResponseBody + public String updateXY() { + syncDataTaskService.updateXY(); + return "finish"; + } + + @RequestMapping(value = "/syncQhdfyCsv", method = RequestMethod.GET) + @ResponseBody + public String syncQhdfyCsv() { + syncDataTaskService.syncQhdfyCsv(); + return "finish"; + } + + @RequestMapping(value = "/orderSieve", method = RequestMethod.GET) + @ResponseBody + public String orderSieve() { + syncDataTaskService.orderSieve(); + return "orderSieve finish"; + } + + @RequestMapping(value = "/sieveResult", method = RequestMethod.GET) + @ResponseBody + public String sieveResult() { + syncDataTaskService.sieveResult(); + return "sieveResult finish"; + } + + @RequestMapping(value = "/execsieve", method = RequestMethod.GET) + @ResponseBody + public String sieveResult1() { + syncDataTaskService.syncQhdSieve(); + return "syncQhdSieve finish"; + } + @RequestMapping(value = "/execsieveorder", method = RequestMethod.GET) + @ResponseBody + public String sieveOrder() { + sieveService.correctSieveOrder(); + return "sieveOrder 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"; + } + + @RequestMapping(value = "/rebuildDefaultRoles", method = RequestMethod.GET) + @ResponseBody + public String rebuildDefaultRoles() { + organizationService.rebuildDefaultRoles(); + return "sieveOrder finish"; + } + + + /** + * 修改最后一次产检时间冗余到patient中 + * @param hid + * @return + */ + @RequestMapping(value = "/syncPatNextTime", method = RequestMethod.GET) + @ResponseBody + public String syncPatNextTime(@RequestParam(required = true) String hid) { + PatientsQuery patientQuery = new PatientsQuery(); + patientQuery.setYn(YnEnums.YES.getId()); + patientQuery.setHospitalId(hid); + patientQuery.setType(1); + List patientses = patientsService.queryPatient(patientQuery); + int batchSize = 1000; + int end = 0; + for (int i = 0; i < patientses.size(); i += batchSize) { + end = (end + batchSize); + if (end > patientses.size()) { + end = patientses.size(); + } + System.out.println("start:" + i + ",end:" + end); + final List tempList = patientses.subList(i, end); + new Thread(new Runnable() { + @Override + public void run() { + if (CollectionUtils.isNotEmpty(tempList)) + { + for (Patients pat : tempList) { + AntExChuQuery antExChuQuery = new AntExChuQuery(); + antExChuQuery.setYn(YnEnums.YES.getId()); + antExChuQuery.setHospitalId(pat.getHospitalId()); + antExChuQuery.setParentId(pat.getId()); + List chus = antenatalExaminationService.queryAntExChu(antExChuQuery); + if (CollectionUtils.isNotEmpty(chus)) { + Date nextTime = null; + AntExChuModel chu = chus.get(0); + if (chu != null) + { + nextTime = chu.getNextCheckTime(); + AntExQuery antExQuery = new AntExQuery(); + antExQuery.setParentId(pat.getId()); + antExQuery.setYn(YnEnums.YES.getId()); + antExQuery.setHospitalId(pat.getHospitalId()); + List list = antenatalExaminationService.queryAntenatalExamination(antExQuery.convertToQuery().addOrder(Sort.Direction.DESC, "created")); + if (CollectionUtils.isNotEmpty(list)) + { + AntenatalExaminationModel ae = list.get(0); + if (ae != null) + { + nextTime = ae.getNextCheckTime(); + } + } + patientsService.updatePatientOneCol(pat.getId(), nextTime); + + } + + } + } + } + } + }).start(); + } + + return "syncPatNextTime finish"; + } + + /** + * @auther HuJiaqi + * @createTime 2016年12月21日 15时56分 + * @discription 冗余最后一次产检 + */ + @ResponseBody + @RequestMapping(value = "/syncPatientsLastCheckEmployeeId", method = RequestMethod.GET) + public String syncPatientsLastCheckEmployeeId(@RequestParam String hospitalId, + @RequestParam(required = false) String size) { + PatientsQuery patientsQuery = new PatientsQuery(); + patientsQuery.setYn(YnEnums.YES.getId()); + // 医院id + patientsQuery.setHospitalId(hospitalId); + List typeList = new ArrayList<>(); + // 孕妇 + typeList.add(1); + // 产妇 + typeList.add(3); + patientsQuery.setTypeList(typeList); + // 查询 + List patientsList = patientsService.queryPatient(patientsQuery); + System.out.println("本次读取了【" + patientsList.size() + "】条数据"); + int batchSize = StringUtils.isEmpty(size) ? 1000 : Integer.valueOf(size); + int end = 0; + for (int i = 0; i < patientsList.size(); i += batchSize) { + end = (end + batchSize); + if (end > patientsList.size()) { + end = patientsList.size(); + } + final List tempList = patientsList.subList(i, end); + new Thread(new Runnable() { + @Override + public void run() { + if (CollectionUtils.isNotEmpty(tempList)) { + for (Patients patients : tempList) { + String id = patients.getId(); + String hospitalId = patients.getHospitalId(); + String lastCheckEmployeeId = null; + String flag; + // 查询复诊，如果没有再查询初诊 + AntExQuery antExQuery = new AntExQuery(); + antExQuery.setYn(YnEnums.YES.getId()); + antExQuery.setParentId(id); + antExQuery.setHospitalId(hospitalId); + List antenatalExaminationModelList = antenatalExaminationService.queryAntenatalExamination(antExQuery.convertToQuery().addOrder(Sort.Direction.DESC, "created")); + if (CollectionUtils.isNotEmpty(antenatalExaminationModelList)) { + lastCheckEmployeeId = antenatalExaminationModelList.get(0).getCheckDoctor(); + flag = "复诊"; + } else { + // 查询初诊 + AntExChuQuery antExChuQuery = new AntExChuQuery(); + antExChuQuery.setYn(YnEnums.YES.getId()); + antExChuQuery.setParentId(id); + antExChuQuery.setHospitalId(hospitalId); + List antExChuModelList = antenatalExaminationService.queryAntExChu(antExChuQuery); + if (antExChuModelList.size() == 1) { + lastCheckEmployeeId = antExChuModelList.get(0).getProdDoctor(); + } + flag = "初诊"; + } + if (!StringUtils.isEmpty(lastCheckEmployeeId)) { + patientsService.updatePatientLastCheckEmployeeIdOne(id, lastCheckEmployeeId); + System.out.println("更新lyms_patient：id=" + id + "，lastCheckEmployeeId=" + lastCheckEmployeeId + "，来自" + flag); + } + } + } + } + }).start(); + } + return "syncPatientsLastCheckEmployeeId start......"; + } + + /** + * @auther HuJiaqi + * @createTime 2016年12月21日 15时56分 + * @discription 冗余分娩分娩医院，分娩年龄，分娩孕周，分娩方式 + */ + @ResponseBody + @RequestMapping(value = "/syncPatientsFmInfo", method = RequestMethod.GET) + public String syncPatientsFmInfo(@RequestParam(required = false) String size,@RequestParam(required = false) String hospitalId) { + MatDeliverQuery matDeliverQuery = new MatDeliverQuery(); + matDeliverQuery.setYn(YnEnums.YES.getId()); + if (StringUtils.isNotEmpty(hospitalId)) { + matDeliverQuery.setFmHospital(hospitalId); + } + // 查询 + List maternalDeliverModelList = matDeliverService.query(matDeliverQuery); + System.out.println("本次读取了【" + maternalDeliverModelList.size() + "】条数据"); + int batchSize = StringUtils.isEmpty(size) ? 1000 : Integer.valueOf(size); + int end = 0; + for (int i = 0; i < maternalDeliverModelList.size(); i += batchSize) { + end = (end + batchSize); + if (end > maternalDeliverModelList.size()) { + end = maternalDeliverModelList.size(); + } + final List tempList = maternalDeliverModelList.subList(i, end); + new Thread(new Runnable() { + @Override + public void run() { + if (CollectionUtils.isNotEmpty(tempList)) { + for (MaternalDeliverModel maternalDeliverModel : tempList) { + Patients patients = patientsService.findOnePatientById(maternalDeliverModel.getParentId()); + if (patients != null) { + // 顺便跑成产妇 + patients.setType(3); + patients.setFmHospital(maternalDeliverModel.getHospitalId()); + patients.setFmType(maternalDeliverModel.getDeliveryMode()); + try { + patients.setFmAge(DateUtil.getAge(patients.getBirth(), patients.getFmDate())); + } catch (Exception e) { + System.out.println(patients.getId() + "：这条数据的生日和分娩时间异常"); + // 跳过 + } + try { + patients.setFmWeek(DateUtil.getDays(patients.getLastMenses(), patients.getFmDate())); + } catch (Exception e) { + System.out.println(patients.getId() + "：这条数据的末日月经和分娩时间异常"); + // 跳过 + } + + System.out.println(patients.getFmHospital()); + System.out.println(patients.getFmType()); + System.out.println(patients.getFmAge()); + System.out.println(patients.getFmWeek()); + System.out.println(patients.toString()); + + patientsService.updatePatient(patients); + } + } + } + } + }).start(); + } + return "syncPatientsLastCheckEmployeeId start......"; + } + + /** + * @auther HuJiaqi + * @createTime 2016年12月21日 15时56分 + * @discription 冗余分娩分娩医院，分娩年龄，分娩孕周，分娩方式 + */ + @ResponseBody + @RequestMapping(value = "/syncPatientsFmInfo1", method = RequestMethod.GET) + public String syncPatientsFmInfo1(@RequestParam(required = false) String size) { + PatientsQuery patientsQuery = new PatientsQuery(); + patientsQuery.setYn(YnEnums.YES.getId()); + patientsQuery.setType(3); + // 查询 + List patientsList = patientsService.queryPatient(patientsQuery); + System.out.println("本次读取了【" + patientsList.size() + "】条数据"); + int batchSize = StringUtils.isEmpty(size) ? 1000 : Integer.valueOf(size); + int end = 0; + for (int i = 0; i < patientsList.size(); i += batchSize) { + end = (end + batchSize); + if (end > patientsList.size()) { + end = patientsList.size(); + } + final List tempList = patientsList.subList(i, end); + new Thread(new Runnable() { + @Override + public void run() { + if (CollectionUtils.isNotEmpty(tempList)) { + for (Patients patients : tempList) { + + try { + patients.setFmAge(DateUtil.getAge(patients.getBirth(), patients.getFmDate())); + } catch (Exception e) { + System.out.println(patients.getId() + "：这条数据的生日和分娩时间异常"); + // 跳过 + } + try { + patients.setFmWeek(DateUtil.getDays(patients.getLastMenses(), patients.getFmDate())); + } catch (Exception e) { + System.out.println(patients.getId() + "：这条数据的末日月经和分娩时间异常"); + // 跳过 + } + if(StringUtils.isNotEmpty(patients.getFmHospital())){ + patients.setIsAutoFm(YnEnums.NO.getId()); + }else{ + patients.setIsAutoFm(YnEnums.YES.getId()); + } + + System.out.println(patients.getFmAge()); + System.out.println(patients.getFmWeek()); + + patientsService.updatePatient(patients); + } + } + } + }).start(); + } + return "syncPatientsLastCheckEmployeeId start......"; + } + + @RequestMapping(value = "/initCardNo", method = RequestMethod.GET) + @ResponseBody + public String initCardNo() { + PatientsQuery query = new PatientsQuery(); + query.setYn(1); + query.setHospitalId("216"); + List list = patientsService.queryPatient(query); + int a = 0; + for (Patients patients:list) { + if (org.apache.commons.lang.StringUtils.isBlank(patients.getCardNo())) { + Patients db = new Patients(); + db.setId(patients.getId()); + db.setCardNo(patients.getPhone()); + db.setHcertificateTypeId("hcertificateTypeId"); + patientsService.updatePatient(db); + a++; + } + } + return "initCardNo finish - " + a; + } + + + /** + * 修改高危因素中包含健康的 把健康去掉 + * @param hid + * @return + */ + @RequestMapping(value = "/modifyRiskFactor", method = RequestMethod.GET) + @ResponseBody + public String modifyRiskFactor(@RequestParam(required = true) String hid) { + PatientsQuery patientQuery = new PatientsQuery(); + patientQuery.setYn(YnEnums.YES.getId()); + patientQuery.setHospitalId(hid); + patientQuery.setrLevel("e637b361-99cf-41eb-84f2-f0dab596e928"); + + List patientses = patientsService.queryPatient(patientQuery); + int batchSize = 500; + int end = 0; + for (int i = 0; i < patientses.size(); i += batchSize) { + end = (end + batchSize); + if (end > patientses.size()) { + end = patientses.size(); + } + System.out.println("start:" + i + ",end:" + end); + final List tempList = patientses.subList(i, end); + new Thread(new Runnable() { + @Override + public void run() { + if (CollectionUtils.isNotEmpty(tempList)) + { + for (Patients pat : tempList) { + if (pat != null) + { + String levelStr = pat.getRiskLevelId(); + if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(levelStr)) + { + List levels = JsonUtil.toList(levelStr, String.class); + if (CollectionUtils.isNotEmpty(levels) && levels.contains("e637b361-99cf-41eb-84f2-f0dab596e928") && levels.size() > 1) + { + List rFactors = pat.getRiskFactorId(); + if (CollectionUtils.isNotEmpty(rFactors) && rFactors.contains("d42eec03-aa86-45b8-a4e0-78a0ff365fb6")) + { + rFactors.remove("d42eec03-aa86-45b8-a4e0-78a0ff365fb6"); + levels.remove("e637b361-99cf-41eb-84f2-f0dab596e928"); + pat.setRiskFactorId(rFactors); + String resultLevel = JsonUtil.array2JsonString(levels); + pat.setRiskLevelId(resultLevel); + patientsService.updatePatient(pat); + + AntExChuQuery antExChuQuery = new AntExChuQuery(); + antExChuQuery.setYn(YnEnums.YES.getId()); + antExChuQuery.setParentId(pat.getId()); + antExChuQuery.setHospitalId(pat.getHospitalId()); + List antExChuModelList = antenatalExaminationService.queryAntExChu(antExChuQuery); + if (CollectionUtils.isNotEmpty(antExChuModelList)) + { + for(AntExChuModel cmodel : antExChuModelList) + { + String highriskStr = cmodel.getHighrisk(); + String otherRisk = cmodel.getOtherHighRisk(); + if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(highriskStr)) + { + List highrisks = JsonUtil.toList(highriskStr, String.class); + if (CollectionUtils.isNotEmpty(highrisks) && highrisks.contains("d42eec03-aa86-45b8-a4e0-78a0ff365fb6") && highrisks.size() > 1) + { + highrisks.remove("d42eec03-aa86-45b8-a4e0-78a0ff365fb6"); + cmodel.setHighrisk(JsonUtil.array2JsonString(highrisks)); + antenatalExaminationService.updateAntExChu(cmodel,cmodel.getId()); + } + else if (CollectionUtils.isNotEmpty(highrisks) && highrisks.contains("d42eec03-aa86-45b8-a4e0-78a0ff365fb6") && !"{}".equals(otherRisk)) + { + highrisks.remove("d42eec03-aa86-45b8-a4e0-78a0ff365fb6"); + cmodel.setHighrisk(JsonUtil.array2JsonString(highrisks)); + antenatalExaminationService.updateAntExChu(cmodel,cmodel.getId()); + } + } + } + + // 查询复诊 + AntExQuery antExQuery = new AntExQuery(); + antExQuery.setYn(YnEnums.YES.getId()); + antExQuery.setParentId(pat.getId()); + antExQuery.setHospitalId(pat.getHospitalId()); + List antenatalExaminationModelList = antenatalExaminationService.queryAntenatalExamination(antExQuery.convertToQuery()); + if (CollectionUtils.isNotEmpty(antenatalExaminationModelList)) { + for (AntenatalExaminationModel fmodel : antenatalExaminationModelList) { + String highriskStr = fmodel.getRiskFactor(); + String otherRisk = fmodel.getOtherRisk(); + if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(highriskStr)) + { + List highrisks = JsonUtil.toList(highriskStr, String.class); + if (CollectionUtils.isNotEmpty(highrisks) && highrisks.contains("d42eec03-aa86-45b8-a4e0-78a0ff365fb6") && highrisks.size() > 1) + { + highrisks.remove("d42eec03-aa86-45b8-a4e0-78a0ff365fb6"); + fmodel.setRiskFactor(JsonUtil.array2JsonString(highrisks)); + antenatalExaminationService.updateOneAnt(fmodel,fmodel.getId()); + } + else if (CollectionUtils.isNotEmpty(highrisks) && highrisks.contains("d42eec03-aa86-45b8-a4e0-78a0ff365fb6") && !"{}".equals(otherRisk)) + { + highrisks.remove("d42eec03-aa86-45b8-a4e0-78a0ff365fb6"); + fmodel.setRiskFactor(JsonUtil.array2JsonString(highrisks)); + antenatalExaminationService.updateOneAnt(fmodel, fmodel.getId()); + } + } + } + } + + } + } + } + + } + + } + } + } + } + }).start(); + } + + return "modifyRiskFactor finish"; + } + + + /** + * 更新产妇当前产程最后一次高危因素冗余到 patient中 + * @param hid + * @return + */ + @RequestMapping(value = "/updateChanLaskRisk", method = RequestMethod.GET) + @ResponseBody + public String updateChanLaskRisk(@RequestParam(required = true) String hid) { + PatientsQuery patientQuery = new PatientsQuery(); + patientQuery.setYn(YnEnums.YES.getId()); + patientQuery.setHospitalId(hid); + patientQuery.setType(3); + + List patientses = patientsService.queryPatient(patientQuery); + int batchSize = 500; + int end = 0; + for (int i = 0; i < patientses.size(); i += batchSize) { + end = (end + batchSize); + if (end > patientses.size()) { + end = patientses.size(); + } + System.out.println("start:" + i + ",end:" + end); + final List tempList = patientses.subList(i, end); + new Thread(new Runnable() { + @Override + public void run() { + if (CollectionUtils.isNotEmpty(tempList)) + { + for (Patients pat : tempList) { + if (pat != null) + { + Date min = pat.getLastMenses(); + Date max = pat.getFmDate(); + if (min != null && max != null) + { + HighScoreResult highScoreResult = antenatalExaminationFacade.getPatLastRiskByDate(pat.getPid(), true, min, max); + PatientsQuery patientsQuery1 = new PatientsQuery(); + patientsQuery1.setId(pat.getId()); + patientsQuery1.setYn(YnEnums.YES.getId()); + + Patients patients1 = new Patients(); + patients1.setModified(new Date()); + patients1.setRiskScore(highScoreResult.getScore()); + patients1.setRiskFactorId(highScoreResult.getHighId()); + patients1.setRiskLevelId(JsonUtil.array2JsonString(highScoreResult.getLevelId())); + //设置其他的高危因素 + patients1.setoRiskFactor(highScoreResult.getOtherRisk()); + patientsService.findAndModify(patientsQuery1, patients1); + } + } + } + } + } + }).start(); + } + + return "updateChanLaskRisk finish"; + } + + /** + * 更新儿童检查表中的生长发育评价 + * @param hid + * @return + */ + @RequestMapping(value = "/updateBabyGrowth", method = RequestMethod.GET) + @ResponseBody + public String updateBabyGrowth(@RequestParam(required = true) String hid) { + + BabyModelQuery babyModelQuery = new BabyModelQuery(); + babyModelQuery.setYn(YnEnums.YES.getId()); + babyModelQuery.setHospitalId(hid); + + List models = babyBookbuildingService.queryBabyBuildByCond(babyModelQuery); + if (CollectionUtils.isNotEmpty(models)) + { + int batchSize = 200; + int end = 0; + for (int i = 0; i < models.size(); i += batchSize) { + end = (end + batchSize); + if (end > models.size()) { + end = models.size(); + } + System.out.println("start:" + i + ",end:" + end); + final List tempList = models.subList(i, end); + new Thread(new Runnable() { + @Override + public void run() { + if (CollectionUtils.isNotEmpty(tempList)) + { + for (BabyModel babyModel : tempList) { + if (babyModel != null) + { + BabyCheckModelQuery query = new BabyCheckModelQuery(); + query.setYn(YnEnums.YES.getId()); + query.setBuildId(babyModel.getId()); + + List checkModels = babyCheckService.queryBabyCheckRecord(query); + if (CollectionUtils.isNotEmpty(checkModels)) + { + for (BabyCheckModel checkModel : checkModels) + { + String height = checkModel.getHeight(); + String birth = DateUtil.getyyyy_MM_dd(babyModel.getBirth()); + if (!com.lyms.platform.common.utils.StringUtils.isNotEmpty(birth)) + { + continue; + } + // type 0 体重标准差数值表 1 身长/身高标准差数值表 2 头围标准差数值表 3身高别体重 + if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(height)) + { + String value = babyCheckFacade.getGrowthValue(birth,Double.parseDouble(height),babyModel.getSex(),1); + checkModel.setHeightEvaluate(value); + + } + String head = checkModel.getHead(); + if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(head)) { + String value = babyCheckFacade.getGrowthValue(birth,Double.parseDouble(head),babyModel.getSex(),2); + checkModel.setHeadEvaluate(value); + } + + String weight = checkModel.getWeight(); + if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(weight)) { + String value = babyCheckFacade.getGrowthValue(birth,Double.parseDouble(weight),babyModel.getSex(),0); + checkModel.setWeightEvaluate(value); + } + + if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(height) && + com.lyms.platform.common.utils.StringUtils.isNotEmpty(weight)) + { + //发育评价 + List growthEvaluate = babyCheckFacade.getBabyGrowthEvaluate(Double.parseDouble(height), babyModel.getSex(), birth, Double.parseDouble(weight)); + if (CollectionUtils.isNotEmpty(growthEvaluate)) + { + checkModel.setGrowthEvaluate(JsonUtil.array2JsonString(growthEvaluate)); + } + + String hw = babyCheckFacade.getBabyHW(Double.parseDouble(height),Double.parseDouble(weight),babyModel.getSex(),birth); + checkModel.setHeightWeight(hw); + + } + checkModel.setHospitalId(checkModel.getHospitalId()); + checkModel.setBirth(babyModel.getBirth()); + + checkModel.setCheckMonth(DateUtil.getBabyAgeMonth(babyModel.getBirth(), checkModel.getCheckDate())); + babyCheckService.updateBabyCheck(checkModel,checkModel.getId()); + } + } + } + } + } + } + }).start(); + } + + } + + + return "updateBabyGrowth finish"; + } + + + /** + * 修正儿童助产机构 + * @param hid + * @return + */ + @RequestMapping(value = "/updateBabyFmHospital", method = RequestMethod.GET) + @ResponseBody + public String updateBabyFmHospital(@RequestParam(required = true) String hid) { + + BabyModelQuery babyModelQuery = new BabyModelQuery(); + babyModelQuery.setYn(YnEnums.YES.getId()); + babyModelQuery.setHospitalId(hid); + + List models = babyBookbuildingService.queryBabyBuildByCond(babyModelQuery); + if (CollectionUtils.isNotEmpty(models)) + { + int batchSize = 200; + int end = 0; + for (int i = 0; i < models.size(); i += batchSize) { + end = (end + batchSize); + if (end > models.size()) { + end = models.size(); + } + System.out.println("start:" + i + ",end:" + end); + final List tempList = models.subList(i, end); + new Thread(new Runnable() { + @Override + public void run() { + if (CollectionUtils.isNotEmpty(tempList)) + { + for (BabyModel babyModel : tempList) { + if (babyModel != null && com.lyms.platform.common.utils.StringUtils.isNotEmpty(babyModel.getMcertNo())) + { + PatientsQuery patientsQuery = new PatientsQuery(); + patientsQuery.setYn(YnEnums.YES.getId()); + patientsQuery.setType(3); + patientsQuery.setCardNo(babyModel.getMcertNo()); + List patients = patientsService.queryPatient(patientsQuery); + if (CollectionUtils.isNotEmpty(patients)) + { + for(Patients pat : patients) + { + MatDeliverQuery matDeliverQuery = new MatDeliverQuery(); + matDeliverQuery.setYn(YnEnums.YES.getId()); + matDeliverQuery.setParentId(pat.getId()); + List lists = matDeliverService.query(matDeliverQuery); + if (CollectionUtils.isNotEmpty(lists)) + { + if (lists.get(0) != null && com.lyms.platform.common.utils.StringUtils.isNotEmpty(lists.get(0).getFmHospital())) + { + babyModel.setDeliverOrg(lists.get(0).getFmHospital()); + babyBookbuildingService.updateBabyBuild(babyModel,babyModel.getId()); + break; + } + } + } + } + } + } + } + } + }).start(); + } + + } + + + return "updateBabyFmHospital finish"; + } + + @RequestMapping(value = "/updateBabyFmHid", method = RequestMethod.GET) + @ResponseBody + public String updateBabyFmHid() { + List list = null; + try { + list = FileUtils.readLines(new File("D:\\QHD.csv"), "gbk"); + for (String line:list) { + String ss[] = line.split(","); + if (ss.length > 1 && ss[0].trim().length() > 0) { + if (ss[0] != null) + { + + String id = ss[0].replace("-",""); + String name = ss[1]; + String oid = String.valueOf(JdbcUtil.getQhdMysqlSingleObjBySql("select id from organization where name = '" + name + "'", JdbcUtil.getQhdMysqlConnection())); + BabyModelQuery babyModelQuery = new BabyModelQuery(); + babyModelQuery.setYn(YnEnums.YES.getId()); + babyModelQuery.setId(id); + + List models = babyBookbuildingService.queryBabyBuildByCond(babyModelQuery); + if (CollectionUtils.isNotEmpty(models) && com.lyms.platform.common.utils.StringUtils.isNotEmpty(oid)) { + System.out.println(ss[0]+"==="+ss[1]); + BabyModel model = models.get(0); + model.setDeliverOrg(oid); + babyBookbuildingService.updateBabyBuild(model, model.getId()); + } + } + } + } + } catch (IOException e) { + ExceptionUtils.catchException(e,"跟新异常"); + e.printStackTrace(); + } + 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"; + } + + @RequestMapping(value = "/syncFmBySyxh", method = RequestMethod.GET) + @ResponseBody + public String syncFmBySyxh(@RequestParam(required = true) String start,@RequestParam(required = true) String end,@RequestParam(required = false) String syxh) { + qhdfyFmService.syncByPhone(start,end,syxh); + return "syncFmBySyxh finish"; + } + + public static void main(String[] a) { + try { + List list = FileUtils.readLines(new File("D:\\QHD.csv"), "gbk"); + List linenums = new ArrayList<>(); + for (String line:list) { + String ss[] = line.split(","); + if (ss.length > 0 && ss[0].trim().length() > 0) { + System.out.println(ss[0]+" "+ ss[1]); + } + } +// List list1 = FileUtils.readLines(new File("D:\\temp\\qhd-jd.csv"), "utf-8"); +// StringBuffer sb = new StringBuffer(); +// for (String line:list1) { +// String ss[] = line.split(","); +// if (ss.length > 0 && ss[0].trim().length() > 0 && linenums.contains(ss[0].trim())) { +// sb.append(line); +// sb.append("\r\n"); +// } +// } +// FileUtils.writeStringToFile(new File("d:\\temp\\qhdfy_lost_data.csv"), sb.toString()); + } catch (Exception e) { + e.printStackTrace(); + } + } + + @RequestMapping("/poll") + @ResponseBody + public String poll() { + return genIdService.poll("1234"); + } + +} 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 76c284e..c64c498 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 @@ -117,6 +117,9 @@ public class BookbuildingFacade { private PatientCheckTicketService patientCheckTicketService; @Autowired private AreaCodeService areaCodeService; + + @Autowired + private GenSequenceIdService genSequenceIdService; /** * 根据患者的建档ID，查询还未使用的免费产检查券 @@ -311,6 +314,190 @@ public class BookbuildingFacade { return br; } + + /** + * 添加孕妇建档 + * + * @param yunRequest + * @return + */ + public BaseObjectResponse createOrUpdateYunBuild( + YunBookbuildingAddRequest yunRequest, Integer userId) { + + BaseObjectResponse br = new BaseObjectResponse(); + PatientsQuery patientsQuery = new PatientsQuery(); + patientsQuery.setYn(YnEnums.YES.getId()); + patientsQuery.setType(1); + patientsQuery.setHospitalId(yunRequest.getHospitalId()); + patientsQuery.setBuildTypeEq(0); + patientsQuery.setDueStatus(0); + + if (yunRequest.getPregnantCertificateNum() != null) { + patientsQuery.setCardNo(yunRequest.getPregnantCertificateNum()); + //判断该身份证号码是否有孕妇建档 在该医院 + List patients = yunBookbuildingService.queryPregnantWithQuery(patientsQuery); + if (CollectionUtils.isNotEmpty(patients)) { + br.setErrorcode(ErrorCodeConstants.DATA_EXIST); + br.setErrormsg("该身份证在医院已经建档"); + return br; + } + } + if (yunRequest.getPregnantPhone() != null) { + patientsQuery.setCardNo(null); + patientsQuery.setPhone(yunRequest.getPregnantPhone()); + //判断该手机号码在 孕期内有没有建档 + List patients = yunBookbuildingService.queryPregnantWithQuery(patientsQuery); + if (CollectionUtils.isNotEmpty(patients)) { + br.setErrorcode(ErrorCodeConstants.DATA_EXIST); + br.setErrormsg("该手机号码已经建档"); + return br; + } + } + + //就诊卡号判断 + if (StringUtils.isNotEmpty(yunRequest.getVcCardNo())) { + patientsQuery.setCardNo(null); + patientsQuery.setPhone(null); + patientsQuery.setVcCardNo(yunRequest.getVcCardNo()); + patientsQuery.setHospitalId(yunRequest.getHospitalId()); + List patients = yunBookbuildingService.queryPregnantWithQuery(patientsQuery); + if (CollectionUtils.isNotEmpty(patients)) { + br.setErrorcode(ErrorCodeConstants.DATA_EXIST); + br.setErrormsg("该就诊卡号在该医院已经建档"); + return br; + } + } + + Integer type = 1; //1孕妇 2儿童 3产妇 + //建档类型 0 未分娩建档 1儿童建档时建档 2 自动分娩类型 3 转诊自动建档 + Integer buildType = 0; + Date date = null; + if (yunRequest.getLastMenstrualPeriod() != null) { + date = DateUtil.addWeek(DateUtil.parseYMD(yunRequest.getLastMenstrualPeriod()), 42); + Date currentDate = DateUtil.formatDate(new Date()); + if (date.getTime() <= currentDate.getTime()) { + type = 3; + buildType = 2; + } + } + + PersonModel resperson = null; + if (StringUtils.isNotEmpty(yunRequest.getPregnantCertificateNum())) { + + PersonModelQuery personModelQuery = new PersonModelQuery(); + personModelQuery.setCardNo(yunRequest.getPregnantCertificateNum()); + personModelQuery.setYn(YnEnums.YES.getId()); + personModelQuery.setTypes(new Integer[]{1, 3}); //孕妇或者产妇基本信息 + List personModels = personService.queryPersons(personModelQuery); + + PersonModel pmodel = new PersonModel(); + pmodel.setName(yunRequest.getPregnantName()); + pmodel.setBirth(DateUtil.parseYMD(yunRequest.getBirthday())); + pmodel.setPhone(yunRequest.getPregnantPhone()); + pmodel.setCardNo(yunRequest.getPregnantCertificateNum()); + pmodel.setType(type); + pmodel.setModified(new Date()); + if (CollectionUtils.isNotEmpty(personModels) && personModels.get(0) != null) { + + resperson = personModels.get(0); + personService.updatePerson(pmodel, personModels.get(0).getId()); + } else { + pmodel.setYn(YnEnums.YES.getId()); + pmodel.setCreated(new Date()); + resperson = personService.addPerson(pmodel); + } + } + + Patients patient = getPatientsData(yunRequest); + patient.setDueStatus(0); + //1孕妇 3 产妇 + patient.setType(type); + if (type == 3) { + patient.setIsAutoFm(YnEnums.YES.getId()); + } + patient.setBuildType(buildType); + if (type == ServiceObjEnums.CHANOBJ.getId() && date != null) { + patient.setFmDate(date); + } + if (resperson != null) { + patient.setPid(resperson.getId()); + HighScoreResult highScoreResult = antenatalExaminationFacade.findLastRisk(resperson.getId(), true); + if (CollectionUtils.isNotEmpty(highScoreResult.getHighId())) { + patient.setRiskFactorId(highScoreResult.getHighId()); + } + patient.setRiskScore(highScoreResult.getScore()); + if (CollectionUtils.isNotEmpty(highScoreResult.getLevelId())) { + patient.setRiskLevelId(JsonUtil.array2JsonString(highScoreResult.getLevelId())); + } + } + + patient.setCreated(new Date()); + patient.setModified(new Date()); + patient.setOperator(userId); + Patients p = yunBookbuildingService.addPregnantBookbuilding(patient); + + if (p == null || p.getId() == null) { + br.setErrorcode(ErrorCodeConstants.SYSTEM_ERROR); + br.setErrormsg("建档失败，保存异常"); + return br; + + } + + //加入产筛 + patientsService.validata(p); + + if (type == ServiceObjEnums.YUNOBJ.getId()) { + //生成建档短信 + createBuildSms(p); + } + + + if (p.getType() != null && p.getType() == 1) { + + Organization organization = organizationService.getOrganization(Integer.valueOf(yunRequest.getHospitalId())); + if (null != organization) { + AreaCodeQuery areaCodeQuery = new AreaCodeQuery(); + areaCodeQuery.setAreaId(organization.getCityId()); + areaCodeQuery.setYn(YnEnums.YES.getId()); + List code = areaCodeService.queryList(areaCodeQuery); + AreaCodeModel areaCode = null; + + + String groupId= groupsFacade.findItemIdByCurrentUserId(autoMatchFacade.getHospitalId(userId)); + if(org.apache.commons.lang.StringUtils.isNotEmpty(groupId)){ + OrganizationGroupsItems groupsItems = groupsFacade.findById(groupId); + if(null!=groupsItems){ + if (CollectionUtils.isNotEmpty(code)) { + areaCode = code.get(0); + } + if (null != areaCode&&StringUtils.isNotEmpty(areaCode.getAreaCode())) { + // 建档成功后，给孕妇造五个条形码 + String ticketPid = autoIncermentService.nextPatientTicketId(areaCode.getAreaCode()); + + int start = TicketTypeEnums.TICKTE_ALL.getType().equals(groupsItems.getTicketType()) ?1:PatientCheckTicketFacade.complyCurrentDay(p.getLastMenses()); + for (Integer i =start; i <= 5; i++) { + PatientCheckTicket ticket = new PatientCheckTicket(); + ticket.setStatus(1); + ticket.setHospitalId(p.getHospitalId()); + ticket.setPatientId(p.getId()); + ticket.setCreated(new Date()); +// ticket.setId(areaCode.getAreaCode() + ticketPid + i); + ticket.setId(genSequenceIdService.poll(areaCode.getAreaCode())); + ticket.setPid(p.getPid()); + patientCheckTicketService.addTicket(ticket); + } + } + } + } + } + } + + br.setErrorcode(ErrorCodeConstants.SUCCESS); + br.setErrormsg("成功"); + br.setData(p.getId()); + return br; + + } /** * 创建孕妇建档短信 diff --git a/platform-operate-api/src/main/resources/database.properties b/platform-operate-api/src/main/resources/database.properties index c2f8b67..1c37561 100644 --- a/platform-operate-api/src/main/resources/database.properties +++ b/platform-operate-api/src/main/resources/database.properties @@ -1,79 +1,85 @@ -#mongo.db.host=192.168.5.8 -#mongo.db.port=27017 -#mongo.db.dbname=platform - -mongo.db.host=${mongo.db.host} -mongo.db.port=${mongo.db.port} -mongo.db.dbname=${mongo.db.dbname} -mongo.db.username=${mongo.db.username} -mongo.db.password=${mongo.db.password} - -mongo.connectionsPerHost=${mongo.connectionsPerHost} -mongo.threadsAllowedToBlockForConnectionMultiplier=${mongo.threadsAllowedToBlockForConnectionMultiplier} -mongo.connectTimeout=${mongo.connectTimeout} -mongo.maxWaitTime=${mongo.maxWaitTime} -mongo.autoConnectRetry=${mongo.autoConnectRetry} -mongo.socketKeepAlive=${mongo.socketKeepAlive} -mongo.socketTimeout=${mongo.socketTimeout} -mongo.slaveOk=${mongo.slaveOk} - - - -#服务启动方式 1院内单机方式 2 服务器方式# -server.startup=2 - -mysql.slave.driver=com.mysql.jdbc.Driver -mysql.slave.jdbcurl=jdbc:mysql://192.168.5.250:3306/platform?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8 -mysql.slave.db.name=platform -mysql.slave.db.password=platform123 - -maindata.maxpoolsize=5 -maindata.initialpoolsize=2 -maindata.minpoolsize=2 -#主服务器数据库配置# -mysql.master.db.name=${mysql.db.name} -mysql.master.db.password=${mysql.db.password} -mysql.master.driver=com.mysql.jdbc.Driver -mysql.master.jdbcurl=${mysql.jdbcurl} - - - -redis.servers=${redis.servers} - -token.prefix=member - - - -login.typeId=2 -login.token=265a841b-9bb5-434a-8c2b-e78df86fc45d -login.defaultPwd=123456 -#1 本地缓存 2 sso登录(需要外网) -run.mode=2 -#1 区域 2 单机 -run.region=1 - - -mongo.config.replica.set.address=192.168.1.XXX:27017,192.168.1.113.XXX:27018,192.168.1.xxx:27019 -mongo.config.replica.set.name=repl -mongo.config.database=test -mongo.config.username= mongo.config.password= mongodb.connection= - - -report.driver=oracle.jdbc.driver.OracleDriver -report.jdbcurl=${report.db.jdbcurl} -report.username=${report.db.username} -report.password=${report.db.password} - -report.maxpoolsize=5 -report.initialpoolsize=2 -report.minpoolsize=2 - -#添加管理员默认所属机构 -defaultAdminOrgId=203 - - -#mongo数据是否上传 1：上传，0：不上传 -mongo_sync=1 -mongo_sync_url=http://mms.api.stage.platform.healthbaby.com.cn/syncmongo -mongo_sync_token=68884AD1832AB397E2F85F87FE371C74 -mongo_crypto_key=Lymsh@2016 \ No newline at end of file +#mongo.db.host=192.168.5.8 +#mongo.db.port=27017 +#mongo.db.dbname=platform + +mongo.db.host=${mongo.db.host} +mongo.db.port=${mongo.db.port} +mongo.db.dbname=${mongo.db.dbname} +mongo.db.username=${mongo.db.username} +mongo.db.password=${mongo.db.password} + +mongo.connectionsPerHost=${mongo.connectionsPerHost} +mongo.threadsAllowedToBlockForConnectionMultiplier=${mongo.threadsAllowedToBlockForConnectionMultiplier} +mongo.connectTimeout=${mongo.connectTimeout} +mongo.maxWaitTime=${mongo.maxWaitTime} +mongo.autoConnectRetry=${mongo.autoConnectRetry} +mongo.socketKeepAlive=${mongo.socketKeepAlive} +mongo.socketTimeout=${mongo.socketTimeout} +mongo.slaveOk=${mongo.slaveOk} + + + +#服务启动方式 1院内单机方式 2 服务器方式# +server.startup=2 + +mysql.slave.driver=com.mysql.jdbc.Driver +mysql.slave.jdbcurl=jdbc:mysql://192.168.5.250:3306/platform?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8 +mysql.slave.db.name=platform +mysql.slave.db.password=platform123 + +maindata.maxpoolsize=5 +maindata.initialpoolsize=2 +maindata.minpoolsize=2 +#主服务器数据库配置# +mysql.master.db.name=${mysql.db.name} +mysql.master.db.password=${mysql.db.password} +mysql.master.driver=com.mysql.jdbc.Driver +mysql.master.jdbcurl=${mysql.jdbcurl} + + + +redis.servers=${redis.servers} + +token.prefix=member + + + +login.typeId=2 +login.token=265a841b-9bb5-434a-8c2b-e78df86fc45d +login.defaultPwd=123456 +#1 本地缓存 2 sso登录(需要外网) +run.mode=2 +#1 区域 2 单机 +run.region=1 + + +mongo.config.replica.set.address=192.168.1.XXX:27017,192.168.1.113.XXX:27018,192.168.1.xxx:27019 +mongo.config.replica.set.name=repl +mongo.config.database=test +mongo.config.username= mongo.config.password= mongodb.connection= + + +report.driver=oracle.jdbc.driver.OracleDriver +report.jdbcurl=${report.db.jdbcurl} +report.username=${report.db.username} +report.password=${report.db.password} + +report.maxpoolsize=5 +report.initialpoolsize=2 +report.minpoolsize=2 + +#添加管理员默认所属机构 +defaultAdminOrgId=203 + + +#mongo数据是否上传 1：上传，0：不上传 +mongo_sync=1 +mongo_sync_url=http://mms.api.stage.platform.healthbaby.com.cn/syncmongo +mongo_sync_token=68884AD1832AB397E2F85F87FE371C74 +mongo_crypto_key=Lymsh@2016 + +# sequence id configs +sequence.create.size=3000 +sequence.index=20000000 +sequence.min.size=300 +sequence.schedule.expression=0 */1 * * * ? \ No newline at end of file diff --git a/platform-operate-api/src/main/resources/spring/applicationContext-quartz.xml b/platform-operate-api/src/main/resources/spring/applicationContext-quartz.xml index ac55ce1..96c19ee 100644 --- a/platform-operate-api/src/main/resources/spring/applicationContext-quartz.xml +++ b/platform-operate-api/src/main/resources/spring/applicationContext-quartz.xml @@ -1,139 +1,158 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/platform-operate-api/src/main/resources/spring/applicationContext.xml b/platform-operate-api/src/main/resources/spring/applicationContext.xml index eab7d01..e13051a 100644 --- a/platform-operate-api/src/main/resources/spring/applicationContext.xml +++ b/platform-operate-api/src/main/resources/spring/applicationContext.xml @@ -1,81 +1,81 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file