diff --git a/platform-operate-api/src/main/java/com/lyms/hospitalapi/lcfy/LisService.java b/platform-operate-api/src/main/java/com/lyms/hospitalapi/lcfy/LisService.java index 2178a33..16253b1 100644 --- a/platform-operate-api/src/main/java/com/lyms/hospitalapi/lcfy/LisService.java +++ b/platform-operate-api/src/main/java/com/lyms/hospitalapi/lcfy/LisService.java @@ -1,7 +1,9 @@ package com.lyms.hospitalapi.lcfy; import com.lyms.platform.common.utils.DateUtil; +import com.lyms.platform.common.utils.SystemConfig; import com.lyms.platform.pojo.PreEugenicsBaseModel; +import com.lyms.platform.pojo.ResidentsArchiveModel; import org.apache.commons.dbutils.DbUtils; import org.springframework.stereotype.Service; @@ -9,35 +11,51 @@ import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; -import java.util.Date; -import java.util.HashMap; -import java.util.Map; +import java.util.*; /** + * 陵城妇幼保存检查项到lis系统中 * Created by Administrator on 2016/9/9 0009. */ @Service("lcfyLisService") public class LisService { + /** + * 孕前优生检查时候保存检查项到lis系统中 + * @param model + * @return + */ public Map save(PreEugenicsBaseModel model){ Map itemsWamen = new HashMap<>(); - itemsWamen.put("lyms001","白带检查"); - itemsWamen.put("lyms002","血细胞分析"); - itemsWamen.put("lyms003","血型"); - itemsWamen.put("lyms004","血糖"); - itemsWamen.put("lyms005","乙肝血清学检查"); - itemsWamen.put("lyms006","肝肾功能检测"); - itemsWamen.put("lyms007","甲状腺功能检测"); - itemsWamen.put("lyms008","病毒筛查"); - itemsWamen.put("lyms009","尿常规检查"); + itemsWamen.put("lyms001","白带常规检查"); + itemsWamen.put("lyms002","淋球菌检测"); + itemsWamen.put("lyms003","沙眼衣原体检测"); + itemsWamen.put("lyms004","血液常规检验"); + itemsWamen.put("lyms005","尿液常规检验"); + itemsWamen.put("lyms006","ABO红细胞定型"); + itemsWamen.put("lyms007","RH血型鉴定"); + itemsWamen.put("lyms008","血清葡萄糖检测"); + itemsWamen.put("lyms009","乙型肝炎血清五项检测"); + itemsWamen.put("lyms010","肝功能检测（谷丙转氨酶）"); + itemsWamen.put("lyms011","肾功能检测（肌酐）"); + itemsWamen.put("lyms012","甲状腺功能（促甲状腺激素）"); + itemsWamen.put("lyms013","梅毒螺旋体筛查"); + itemsWamen.put("lyms014","风疹病毒IgG抗体测定"); + itemsWamen.put("lyms015","巨细胞病毒IgM测定"); + itemsWamen.put("lyms016","巨细胞病毒IgG测定"); + itemsWamen.put("lyms017","弓形体IgM测定"); + itemsWamen.put("lyms018","弓形体IgG测定"); + itemsWamen.put("lyms019","妇科超声常规检查"); Map itemsMan = new HashMap<>(); - itemsMan.put("lyms003","血型"); - itemsMan.put("lyms009","尿常规检查"); - itemsMan.put("lyms010","梅毒螺旋体筛查"); - itemsMan.put("lyms011","乙肝血清学检查"); - itemsMan.put("lyms012","肝肾功能检测"); + itemsMan.put("lyms005","尿液常规检验"); + itemsMan.put("lyms006","ABO红细胞定型"); + itemsMan.put("lyms007","RH血型鉴定"); + itemsMan.put("lyms009","乙型肝炎血清五项检测"); + itemsMan.put("lyms010","肝功能检测（谷丙转氨酶）"); + itemsMan.put("lyms011","肾功能检测（肌酐）"); + itemsMan.put("lyms013","梅毒螺旋体筛查"); Connection conn = null; String sql = "insert into TI_申请信息孕(v患者类别,v患者编号,v患者ID号,v患者姓名,v性别,v年龄,v年龄类型,v申请项目编码,v申请项目名称,v唯一标识号,iTag,v手机号,v身份证号,d申请时间,v申请日期,i项目数量) values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; PreparedStatement ps = null; @@ -103,11 +121,142 @@ public class LisService { e1.printStackTrace(); } DbUtils.closeQuietly(conn); - e.printStackTrace(); System.out.println(e.getMessage()); } return null; } + + /** + * 婚检中保存检查项 到lis系统中 + * @param residentsArchiveModel + * @return + */ + public Map save(ResidentsArchiveModel residentsArchiveModel ){ + Map itemsWamen = new HashMap<>(); + itemsWamen.put("lymsh001","白带常规检查"); + itemsWamen.put("lymsh002","淋球菌检测"); + itemsWamen.put("lymsh003","沙眼衣原体检测"); + itemsWamen.put("lymsh004","血液常规检验"); + itemsWamen.put("lymsh005","尿液常规检验"); + itemsWamen.put("lymsh006","ABO红细胞定型"); + itemsWamen.put("lymsh007","RH血型鉴定"); + itemsWamen.put("lymsh008","血清葡萄糖检测"); + itemsWamen.put("lymsh009","乙型肝炎血清五项检测"); + itemsWamen.put("lymsh010","肝功能检测（谷丙转氨酶）"); + itemsWamen.put("lymsh011","肾功能检测（肌酐）"); + itemsWamen.put("lymsh012","甲状腺功能（促甲状腺激素）"); + itemsWamen.put("lymsh013","梅毒螺旋体筛查"); + itemsWamen.put("lymsh014","风疹病毒IgG抗体测定"); + itemsWamen.put("lymsh015","巨细胞病毒IgM测定"); + itemsWamen.put("lymsh016","巨细胞病毒IgG测定"); + itemsWamen.put("lymsh017","弓形体IgM测定"); + itemsWamen.put("lymsh018","弓形体IgG测定"); + itemsWamen.put("lymsh019","妇科超声常规检查"); + + + Map itemsWamenj = new HashMap<>(); + itemsWamenj.put("lymsh004","血液常规检验"); + itemsWamenj.put("lymsh005","尿液常规检验"); + itemsWamenj.put("lymsh009","乙型肝炎血清五项检测"); + itemsWamenj.put("lymsh010","肝功能检测（谷丙转氨酶）"); + itemsWamenj.put("lymsh013","梅毒螺旋体筛查"); + itemsWamenj.put("lymsh019","妇科超声常规检查"); + itemsWamenj.put("lymsh020","人免疫缺陷病毒抗体测定"); + + Map itemsMan = new HashMap<>(); + itemsMan.put("lymsh004","血液常规检验"); + itemsMan.put("lymsh005","尿液常规检验"); + itemsMan.put("lymsh006","ABO红细胞定型"); + itemsMan.put("lymsh007","RH血型鉴定"); + itemsMan.put("lymsh009","乙型肝炎血清五项检测"); + itemsMan.put("lymsh010","肝功能检测（谷丙转氨酶）"); + itemsMan.put("lymsh011","肾功能检测（肌酐）"); + itemsMan.put("lymsh013","梅毒螺旋体筛查"); + Connection conn = null; + String sql = "insert into TI_申请信息孕(v患者类别,v患者编号,v患者ID号,v患者姓名,v性别,v年龄,v年龄类型,v申请项目编码,v申请项目名称,v唯一标识号,iTag,v手机号,v身份证号,d申请时间,v申请日期,i项目数量) values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; + PreparedStatement ps = null; + ResultSet rs = null; + try { + conn = ConnTools.makeLisConnection(); + if (SystemConfig.WOMAN_ID.equals(residentsArchiveModel.getSex())) + { + String wId = com.lyms.platform.common.utils.StringUtils.uuid(); + Set sets = new HashSet<>(); + if (residentsArchiveModel.getMilitary() != null && residentsArchiveModel.getMilitary() == 1) + { + sets.addAll(itemsWamenj.keySet()); + } + else + { + sets.addAll(itemsWamen.keySet()); + } + for (String key : sets) + { + ps = conn.prepareStatement(sql); + ps.setString(1,"TJ"); + ps.setString(2,wId); + ps.setString(3,wId); + ps.setString(4, residentsArchiveModel.getUsername()); + ps.setString(5, "女"); + ps.setString(6, residentsArchiveModel.getBirthday() != null ? DateUtil.getAge(residentsArchiveModel.getBirthday())+"" : ""); + ps.setString(7, "岁"); + ps.setString(8, key); + ps.setString(9, itemsWamen.get(key)); + ps.setString(10, com.lyms.platform.common.utils.StringUtils.uuid()); + ps.setString(11,"0"); + ps.setString(12,residentsArchiveModel.getPhone()); + ps.setString(13,residentsArchiveModel.getCertificateNum()); + ps.setDate(14, new java.sql.Date(new Date().getTime())); + ps.setString(15,DateUtil.getyyyy_MM_dd(new Date())); + ps.setInt(16, 1); + int inCount = ps.executeUpdate(); + System.out.println("女性保存"+inCount); + } + } + else + { + String mid = com.lyms.platform.common.utils.StringUtils.uuid(); + for (String key : itemsMan.keySet()) + { + ps = conn.prepareStatement(sql); + ps.setString(1,"TJ"); + ps.setString(2,mid); + ps.setString(3,mid); + ps.setString(4, residentsArchiveModel.getUsername()); + ps.setString(5, "男"); + ps.setString(6, residentsArchiveModel.getBirthday() != null ? DateUtil.getAge(residentsArchiveModel.getBirthday())+"" : ""); + ps.setString(7, "岁"); + ps.setString(8, key); + ps.setString(9, itemsMan.get(key)); + ps.setString(10, com.lyms.platform.common.utils.StringUtils.uuid()); + ps.setString(11,"0"); + ps.setString(12,residentsArchiveModel.getPhone()); + ps.setString(13,residentsArchiveModel.getCertificateNum()); + ps.setDate(14, new java.sql.Date(new Date().getTime())); + ps.setString(15, DateUtil.getyyyy_MM_dd(new Date())); + ps.setInt(16, 1); + int inCount = ps.executeUpdate(); + System.out.println("男性性保存"+inCount); + } + } + } + catch (Exception e) + { + try { + if (rs != null) + { + rs.close(); + } + } catch (SQLException e1) { + e1.printStackTrace(); + } + DbUtils.closeQuietly(conn); + + e.printStackTrace(); + System.out.println(e.getMessage()); + } + return null; + } } diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/ResidentsArchiveController.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/ResidentsArchiveController.java index 7046f89..0add8fe 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/ResidentsArchiveController.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/ResidentsArchiveController.java @@ -110,7 +110,7 @@ public class ResidentsArchiveController extends BaseController { @TokenRequired public BaseObjectResponse querySpouseInfoByName(@RequestParam("name")String name,@RequestParam("sexId")String sexId,HttpServletRequest request){ LoginContext loginState = (LoginContext) request.getAttribute("loginContext"); - BaseObjectResponse objectResponse = residentsArchiveFacade.querySpouseInfoByName(name,sexId, loginState.getId()); + BaseObjectResponse objectResponse = residentsArchiveFacade.querySpouseInfoByName(name, sexId, loginState.getId()); return objectResponse; } @@ -128,6 +128,19 @@ public class ResidentsArchiveController extends BaseController { return objectResponse; } + + /** + * 保存lis检查项到lis系统中 + * @param id + * @return + */ + @RequestMapping(value = "/setResidentsCheckItem/{id}", method = RequestMethod.GET) + @ResponseBody + @TokenRequired + public BaseResponse setResidentsCheckItem(@PathVariable("id")String id){ + return residentsArchiveFacade.setResidentsCheckItem(id); + } + /** * 妇女健康管理 * @param residentsArchiveQueryRequest diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/ResidentsArchiveFacade.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/ResidentsArchiveFacade.java index 066cb75..8cc9306 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/ResidentsArchiveFacade.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/ResidentsArchiveFacade.java @@ -1,5 +1,6 @@ package com.lyms.platform.operate.web.facade; +import com.lyms.hospitalapi.lcfy.LisService; import com.lyms.platform.beans.MsgRequest; import com.lyms.platform.biz.service.*; import com.lyms.platform.common.constants.ErrorCodeConstants; @@ -63,13 +64,14 @@ public class ResidentsArchiveFacade { @Autowired private SmsConfigFacade smsConfigFacade; @Autowired - private SyncDataService syncDataService; - @Autowired private ITrackDownService trackDownService; @Autowired private PostVisitHospitalService postVisitHospitalService; @Autowired + private LisService lcfyLisService; + + @Autowired private TrackDownRecordService trackDownRecordService; public BaseObjectResponse findResidentsArchive(ResidentsArchiveQueryRequest queryRequest, Integer userId) { @@ -1061,4 +1063,16 @@ public class ResidentsArchiveFacade { } return new BaseObjectResponse().setErrorcode(ErrorCodeConstants.SUCCESS).setErrormsg("成功").setData(list); } + + + public BaseResponse setResidentsCheckItem(String id) { + ResidentsArchiveQuery query = new ResidentsArchiveQuery(); + query.setYn(YnEnums.YES.getId()); + query.setId(id); + List modelList = residentsArchiveService.queryResident(query); + if (CollectionUtils.isNotEmpty(modelList)) { + lcfyLisService.save(modelList.get(0)); + } + return new BaseResponse().setErrorcode(ErrorCodeConstants.SUCCESS).setErrormsg("成功"); + } } diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/impl/PreEugebicsServiceImpl.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/impl/PreEugebicsServiceImpl.java index cfdcb56..7c87f7a 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/impl/PreEugebicsServiceImpl.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/impl/PreEugebicsServiceImpl.java @@ -166,8 +166,12 @@ public class PreEugebicsServiceImpl extends BaseServiceImpl implements IPreEugen model.setHospitalId(hospitalId); model.setCreated(new Date()); mongoTemplate.insert(model); - System.out.println(model.getId()); - saveLis(model); + //陵城区妇幼保健院 + if ("2100002042".equals(hospitalId)) + { + saveLis(model); + } + return new BaseResponse(); }