From 595d14c8502b477fed322de127079ce4659394a4 Mon Sep 17 00:00:00 2001 From: jiangjiazhi Date: Sat, 6 May 2017 15:20:57 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0soureceid?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../job/index/restore/data/ConvertHelper.java | 148 ++++++++++++++------- .../job/index/restore/data/SyncDataWork.java | 65 ++++----- 2 files changed, 134 insertions(+), 79 deletions(-) diff --git a/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/ConvertHelper.java b/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/ConvertHelper.java index 2a3bbad..51ccd9b 100644 --- a/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/ConvertHelper.java +++ b/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/ConvertHelper.java @@ -157,6 +157,7 @@ public class ConvertHelper localPatient.setGender(patients.getGender()); localPatient.setVip(patients.getVip()); localPatient.setCrisis(0); + localPatient.setHospitalForeignId(patients.getHospitalId()); //孕妇 localPatient.setType(patients.getType()); localPatient.setPublishId(0); @@ -296,7 +297,14 @@ public class ConvertHelper { if ("血压".equals(key)) { - Map map = JsonUtil.str2Obj(antExChuModel.getBp(), Map.class); + Map map = null; + try + { + map = JsonUtil.str2Obj(antExChuModel.getBp(), Map.class); + } catch (Exception e) + { + } + if (null != map) { String ssy = null; @@ -396,7 +404,15 @@ public class ConvertHelper //高危 if ("高危因素".equals(key)) { - List map = JsonUtil.toList(antExChuModel.getHighrisk(), List.class); + List map = null; + try + { + map = JsonUtil.toList(antExChuModel.getHighrisk(), List.class); + } catch (Exception e) + { + } + + if (CollectionUtils.isNotEmpty(map)) { StringBuilder sb = new StringBuilder(); @@ -413,7 +429,14 @@ public class ConvertHelper } if (null != antExChuModel.getOtherHighRisk() && !"{}".equals(antExChuModel.getOtherHighRisk())) { - Map map1 = JsonUtil.str2Obj(antExChuModel.getOtherHighRisk(), Map.class); + Map map1 =null; + try + { + map1 =JsonUtil.str2Obj(antExChuModel.getOtherHighRisk(), Map.class); + } catch (Exception e) + { + } + Object rh = map1.get("fxysu"); if (null != rh && StringUtils.isNotEmpty(rh.toString())) { @@ -435,26 +458,28 @@ public class ConvertHelper for (int j = 0; j < antExChuModel.getPlacentas().size(); j++) { LinkedHashMap map = (LinkedHashMap) antExChuModel.getPlacentas().get(j); - //胎先露、胎方位、胎心率和衔接 - String heartRate = String.valueOf(map.get("heartRate")); - String fetalPosition = String.valueOf(map.get("fetalPosition")); - String fetalPresentation = String.valueOf(map.get("fetalPresentation")); - String join = String.valueOf(map.get("join")); - if (!"null".equals(heartRate) && StringUtils.isNotEmpty(heartRate)) - { - heartRateVal += heartRate + "次/分" + ","; - } - if (!"null".equals(fetalPosition) && StringUtils.isNotEmpty(fetalPosition)) - { - fetalPositionVal += FetalPositionEnums.getTitle(fetalPosition) + ","; - } - if (!"null".equals(fetalPresentation) && StringUtils.isNotEmpty(fetalPresentation)) - { - fetalPresentationVal += FetalEnums.getTitle(fetalPresentation) + ","; - } - if (!"null".equals(join) && StringUtils.isNotEmpty(join)) - { - joinVal += JoinEnums.getTitle(join) + ","; + if(null!=map){ + //胎先露、胎方位、胎心率和衔接 + String heartRate = String.valueOf(map.get("heartRate")); + String fetalPosition = String.valueOf(map.get("fetalPosition")); + String fetalPresentation = String.valueOf(map.get("fetalPresentation")); + String join = String.valueOf(map.get("join")); + if (!"null".equals(heartRate) && StringUtils.isNotEmpty(heartRate)) + { + heartRateVal += heartRate + "次/分" + ","; + } + if (!"null".equals(fetalPosition) && StringUtils.isNotEmpty(fetalPosition)) + { + fetalPositionVal += FetalPositionEnums.getTitle(fetalPosition) + ","; + } + if (!"null".equals(fetalPresentation) && StringUtils.isNotEmpty(fetalPresentation)) + { + fetalPresentationVal += FetalEnums.getTitle(fetalPresentation) + ","; + } + if (!"null".equals(join) && StringUtils.isNotEmpty(join)) + { + joinVal += JoinEnums.getTitle(join) + ","; + } } } if (heartRateVal.endsWith(",")) @@ -555,7 +580,13 @@ public class ConvertHelper { if ("血压".equals(key)) { - Map map = JsonUtil.str2Obj(antExChuModel.getBp(), Map.class); + Map map = null; + try + { + map = JsonUtil.str2Obj(antExChuModel.getBp(), Map.class); + } catch (Exception e) + { + } if (null != map) { @@ -631,7 +662,13 @@ public class ConvertHelper //高危 else if ("高危因素".equals(key)) { - List map = JsonUtil.toList(antExChuModel.getRiskFactor(), List.class); + List map = null; + try + { + map = JsonUtil.toList(antExChuModel.getRiskFactor(), List.class); + } catch (Exception e) + { + } if (CollectionUtils.isNotEmpty(map)) { StringBuilder sb = new StringBuilder(); @@ -648,12 +685,23 @@ public class ConvertHelper } if (null != antExChuModel.getOtherRisk() && !"{}".equals(antExChuModel.getOtherRisk())) { - Map map1 = JsonUtil.str2Obj(antExChuModel.getOtherRisk(), Map.class); - Object rh = map1.get("fxysu"); - if (null != rh && StringUtils.isNotEmpty(rh.toString())) + Map map1 = null; + try + { + map1 = JsonUtil.str2Obj(antExChuModel.getOtherRisk(), Map.class); + } catch (Exception e) { - sb.append(rh); + } + if (null != map1) + { + Object rh = map1.get("fxysu"); + if (null != rh && StringUtils.isNotEmpty(rh.toString())) + { + sb.append(rh); + } + } + } //低压 java.util.Map dataMap1 = new HashMap<>(); @@ -673,26 +721,28 @@ public class ConvertHelper for (int j = 0; j < antExChuModel.getTireData().size(); j++) { LinkedHashMap map = (LinkedHashMap) antExChuModel.getTireData().get(j); - //胎先露、胎方位、胎心率和衔接 - String heartRate = String.valueOf(map.get("heartRate")); - String fetalPosition = String.valueOf(map.get("fetalPosition")); - String fetalPresentation = String.valueOf(map.get("fetalPresentation")); - String join = String.valueOf(map.get("join")); - if (!"null".equals(heartRate) && StringUtils.isNotEmpty(heartRate)) - { - heartRateVal += heartRate + "次/分" + ","; - } - if (!"null".equals(fetalPosition) && StringUtils.isNotEmpty(fetalPosition)) - { - fetalPositionVal += FetalPositionEnums.getTitle(fetalPosition) + ","; - } - if (!"null".equals(fetalPresentation) && StringUtils.isNotEmpty(fetalPresentation)) - { - fetalPresentationVal += FetalEnums.getTitle(fetalPresentation) + ","; - } - if (!"null".equals(join) && StringUtils.isNotEmpty(join)) - { - joinVal += JoinEnums.getTitle(join) + ","; + if(null!=map){ + //胎先露、胎方位、胎心率和衔接 + String heartRate = String.valueOf(map.get("heartRate")); + String fetalPosition = String.valueOf(map.get("fetalPosition")); + String fetalPresentation = String.valueOf(map.get("fetalPresentation")); + String join = String.valueOf(map.get("join")); + if (!"null".equals(heartRate) && StringUtils.isNotEmpty(heartRate)) + { + heartRateVal += heartRate + "次/分" + ","; + } + if (!"null".equals(fetalPosition) && StringUtils.isNotEmpty(fetalPosition)) + { + fetalPositionVal += FetalPositionEnums.getTitle(fetalPosition) + ","; + } + if (!"null".equals(fetalPresentation) && StringUtils.isNotEmpty(fetalPresentation)) + { + fetalPresentationVal += FetalEnums.getTitle(fetalPresentation) + ","; + } + if (!"null".equals(join) && StringUtils.isNotEmpty(join)) + { + joinVal += JoinEnums.getTitle(join) + ","; + } } } if (heartRateVal.endsWith(",")) diff --git a/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/SyncDataWork.java b/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/SyncDataWork.java index bcc0614..4775140 100644 --- a/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/SyncDataWork.java +++ b/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/SyncDataWork.java @@ -808,40 +808,45 @@ public class SyncDataWork { for (com.lyms.platform.pojo.Patients patients : patientses) { - logger.info("SyncWork-" + hospitalId + "-patient-" + patients.getId()); - StopWatch stopWatch3 = new StopWatch("SyncWork-" + hospitalId + "-patient-" + patients.getId()); - com.lymsh.mommybaby.maindata.model.Patients mamiPatient = ConvertHelper - .convertPatient(patients); - if (StringUtils.isNotEmpty(mamiPatient.getPhone())) + try { - MembersQuery membersQuery = new MembersQuery(); - membersQuery.setPhone(mamiPatient.getPhone()); - List memberses = membersService.queryMembers(membersQuery); - if (CollectionUtils.isNotEmpty(memberses)) + logger.info("SyncWork-" + hospitalId + "-patient-" + patients.getId()); + StopWatch stopWatch3 = new StopWatch("SyncWork-" + hospitalId + "-patient-" + patients.getId()); + com.lymsh.mommybaby.maindata.model.Patients mamiPatient = ConvertHelper + .convertPatient(patients); + if (StringUtils.isNotEmpty(mamiPatient.getPhone())) { - mamiPatient.setMemberId(memberses.get(0).getId()); + MembersQuery membersQuery = new MembersQuery(); + membersQuery.setPhone(mamiPatient.getPhone()); + List memberses = membersService.queryMembers(membersQuery); + if (CollectionUtils.isNotEmpty(memberses)) + { + mamiPatient.setMemberId(memberses.get(0).getId()); + } } - } - mamiPatient.setCrisis(setCric(patients)); - logger.info("aouPatients" + patients.getId()); - stopWatch3.start("aouPatients"); - //增加建档记录 - patientsService.aouPatients(mamiPatient); - stopWatch3.stop(); - //绑定用户 - bandingMember(mamiPatient); - logger.info("bandingMember" + patients.getId()); - //处理建档关系 - handlBuild(patients, mamiPatient, stopWatch3); - //处理risk - handLastRisk(patients, mamiPatient.getId()); - //处理初诊 - handleAntExc(patients, mamiPatient, stopWatch3); - //处理复诊 - handleAntEx(patients, mamiPatient, stopWatch3); - - logger.info(stopWatch3.toString()); + mamiPatient.setCrisis(setCric(patients)); + logger.info("aouPatients" + patients.getId()); + stopWatch3.start("aouPatients"); + //增加建档记录 + patientsService.aouPatients(mamiPatient); + stopWatch3.stop(); + //绑定用户 + bandingMember(mamiPatient); + logger.info("bandingMember" + patients.getId()); + //处理建档关系 + handlBuild(patients, mamiPatient, stopWatch3); + //处理risk + handLastRisk(patients, mamiPatient.getId()); + //处理初诊 + handleAntExc(patients, mamiPatient, stopWatch3); + //处理复诊 + handleAntEx(patients, mamiPatient, stopWatch3); + + logger.info(stopWatch3.toString()); + }catch (Exception e){ + ERROR_LOGGER.error("handl patient :"+patients.getId()+", hospitalId:" + hospitalId, e); + } } } logger.info("hospital " + hospitalId + ",costTime:" + (System.currentTimeMillis() - l)); -- 1.8.3.1