Commit c9aac15a96c2704ad7280be64f85483c738b0a9c
1 parent
f2b21899ba
Exists in
master
and in
1 other branch
code update
Showing 4 changed files with 231 additions and 193 deletions
- platform-biz-patient-service/src/main/java/com/lyms/platform/biz/JdbcUtil.java
- platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/BabyCheckDaoImpl.java
- platform-data-api/src/main/java/com/lyms/platform/data/util/AmsMessageService.java
- platform-job-index/src/main/java/com/lyms/platform/job/index/service/SyncDataService.java
platform-biz-patient-service/src/main/java/com/lyms/platform/biz/JdbcUtil.java
View file @
c9aac15
| ... | ... | @@ -18,6 +18,7 @@ |
| 18 | 18 | import org.springframework.context.ApplicationContext; |
| 19 | 19 | import org.springframework.context.support.ClassPathXmlApplicationContext; |
| 20 | 20 | import org.springframework.data.mongodb.core.MongoTemplate; |
| 21 | +import org.springframework.data.mongodb.core.query.Criteria; | |
| 21 | 22 | import org.springframework.data.mongodb.core.query.Query; |
| 22 | 23 | import org.springframework.data.mongodb.core.query.Update; |
| 23 | 24 | import org.springframework.util.*; |
| ... | ... | @@ -1556,8 +1557,12 @@ |
| 1556 | 1557 | |
| 1557 | 1558 | |
| 1558 | 1559 | public static void main(String[] args) { |
| 1559 | -// MongoTemplate template = getMongoTemplate(); | |
| 1560 | -// AggregationOperation match = Aggregation.match(Criteria.where("_id").is("88ff423d07bf4d40b4fa331e6fe0e32a")); | |
| 1560 | + MongoTemplate template = getMongoTemplate(); | |
| 1561 | + | |
| 1562 | + Date nextDate = new Date(); | |
| 1563 | + template.updateFirst(new Query(Criteria.where("id").is("8c8a99a172084c18b5e4f237c944410f")), Update.update("nextDate", nextDate), BabyModel.class); | |
| 1564 | + | |
| 1565 | +// AggregationOperation match = Aggregation.mach(Criteria.where("_id").is("88ff423d07bf4d40b4fa331e6fe0e32a")); | |
| 1561 | 1566 | // AggregationOperation group = Aggregation.group("_id"); |
| 1562 | 1567 | // Aggregation aggregation = Aggregation.newAggregation(match, group); |
| 1563 | 1568 | // AggregationResults<BabyCheckModel> result = template.aggregate(aggregation, "lyms_patient_test", BabyCheckModel.class); |
platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/BabyCheckDaoImpl.java
View file @
c9aac15
| ... | ... | @@ -7,10 +7,13 @@ |
| 7 | 7 | import com.lyms.platform.common.dao.operator.MongoQuery; |
| 8 | 8 | import com.lyms.platform.pojo.AntenatalExaminationModel; |
| 9 | 9 | import com.lyms.platform.pojo.BabyCheckModel; |
| 10 | +import com.lyms.platform.pojo.BabyModel; | |
| 10 | 11 | import org.springframework.data.mongodb.core.aggregation.Aggregation; |
| 11 | 12 | import org.springframework.data.mongodb.core.aggregation.AggregationOperation; |
| 12 | 13 | import org.springframework.data.mongodb.core.aggregation.AggregationResults; |
| 13 | 14 | import org.springframework.data.mongodb.core.query.Criteria; |
| 15 | +import org.springframework.data.mongodb.core.query.Query; | |
| 16 | +import org.springframework.data.mongodb.core.query.Update; | |
| 14 | 17 | import org.springframework.stereotype.Repository; |
| 15 | 18 | |
| 16 | 19 | import java.util.List; |
| ... | ... | @@ -26,6 +29,7 @@ |
| 26 | 29 | @Override |
| 27 | 30 | public void updateBabyCheck(BabyCheckModel obj, String id) { |
| 28 | 31 | update(new MongoQuery(new MongoCondition("id", id, MongoOper.IS)).convertToMongoQuery(), obj); |
| 32 | + this.mongoTemplate.updateFirst(new Query(Criteria.where("id").is(obj.getBuildId())), Update.update("nextDate", obj.getNextDate()), BabyModel.class); | |
| 29 | 33 | } |
| 30 | 34 | |
| 31 | 35 | @Override |
platform-data-api/src/main/java/com/lyms/platform/data/util/AmsMessageService.java
View file @
c9aac15
| ... | ... | @@ -185,6 +185,25 @@ |
| 185 | 185 | // getMessageTemplateMap("8be01f59-ad25-4ae6-968d-8450c9421e0b", |
| 186 | 186 | // AmsServiceTypeEnum.CHILD_GUIDE); |
| 187 | 187 | |
| 188 | +// String result = "头:9.5|胸:10.0|腹:10.0"; | |
| 189 | +// String b = ""; | |
| 190 | +// | |
| 191 | +// //头:9.5|胸:10.0|腹:10.0 | |
| 192 | +// String[] arrs = result.split("\\u007C"); | |
| 193 | +// for (String str : arrs) { | |
| 194 | +// String[] temps = str.split(":"); | |
| 195 | +// if (str.startsWith("头")) { | |
| 196 | +// b = temps.length == 2 ? temps[1] : ""; | |
| 197 | +// System.out.println(b); | |
| 198 | +// } else if (str.startsWith("胸")) { | |
| 199 | +// b =temps.length == 2 ? temps[1] : ""; | |
| 200 | +// System.out.println(b); | |
| 201 | +// } else if (str.startsWith("腹")) { | |
| 202 | +// b =temps.length == 2 ? temps[1] : ""; | |
| 203 | +// System.out.println(b); | |
| 204 | +// } | |
| 205 | +// } | |
| 206 | + | |
| 188 | 207 | } |
| 189 | 208 | |
| 190 | 209 |
platform-job-index/src/main/java/com/lyms/platform/job/index/service/SyncDataService.java
View file @
c9aac15
| ... | ... | @@ -14,6 +14,7 @@ |
| 14 | 14 | import org.apache.commons.collections.CollectionUtils; |
| 15 | 15 | import org.springframework.beans.factory.annotation.Autowired; |
| 16 | 16 | import org.springframework.data.mongodb.core.MongoTemplate; |
| 17 | +import org.springframework.data.mongodb.core.query.Criteria; | |
| 17 | 18 | import org.springframework.data.mongodb.core.query.Query; |
| 18 | 19 | import org.springframework.data.mongodb.core.query.Update; |
| 19 | 20 | import org.springframework.stereotype.Service; |
| ... | ... | @@ -157,9 +158,7 @@ |
| 157 | 158 | @Override |
| 158 | 159 | public void run() { |
| 159 | 160 | |
| 160 | - List<Map<String, Object>> list = JDBCUtil.getOracleListDataBySql(" SELECT * FROM ( SELECT A.*, ROWNUM RN FROM " + | |
| 161 | - " (select replace(m.PI_ID,'-','') as ID,m.* from MOMMY_PATIENTINFO m where m.pi_bookbuildinghospitalid='" + hid + "') " + | |
| 162 | - " A WHERE ROWNUM < 1000000 ) WHERE RN >= 1 "); | |
| 161 | + List<Map<String, Object>> list = JDBCUtil.getOracleListDataBySql(" select replace(m.PI_ID,'-','') as ID,m.* from MOMMY_PATIENTINFO m where m.pi_bookbuildinghospitalid='" + hid + "' " ); | |
| 163 | 162 | |
| 164 | 163 | for (Map<String, Object> map : list) |
| 165 | 164 | { |
| ... | ... | @@ -181,184 +180,6 @@ |
| 181 | 180 | new workerBaby(oracleHid).start(); |
| 182 | 181 | } |
| 183 | 182 | |
| 184 | - private void syncBaby(Map<String, Object> map) | |
| 185 | - { | |
| 186 | - PersonModel personModel = new PersonModel(); | |
| 187 | - personModel.setId(DataUtil.getString(map.get("ID"))); | |
| 188 | - personModel.setPhone(DataUtil.getString(map.get("PI_MOTHERPHONE"))); | |
| 189 | - personModel.setName(DataUtil.getString(map.get("PI_NAME"))); | |
| 190 | - personModel.setCardNo(DataUtil.getString(map.get("PI_MOTHERPHONE"))); | |
| 191 | - personModel.setBirth(DataUtil.getDate(map.get("PI_BIRTHDAY"))); | |
| 192 | - personModel.setType(2); | |
| 193 | - personModel.setYn(YnEnums.YES.getId()); | |
| 194 | - personModel.setCreated(DataUtil.getDate(map.get("PI_CREATETIME"))); | |
| 195 | - personModel.setModified(DataUtil.getDate(map.get("PI_OPERTIME"))); | |
| 196 | - | |
| 197 | - mongoTemplate.save(personModel); | |
| 198 | - | |
| 199 | - BabyModel model = new BabyModel(); | |
| 200 | - model.setId(DataUtil.getString(map.get("ID"))); | |
| 201 | - model.setPid(personModel.getId()); | |
| 202 | - model.setCreated(DataUtil.getDate(map.get("PI_CREATETIME"))); | |
| 203 | - model.setModified(DataUtil.getDate(map.get("PI_OPERTIME"))); | |
| 204 | - model.setBirth(DataUtil.getDate(map.get("PI_BIRTHDAY"))); | |
| 205 | - model.setAddress(DataUtil.getString(map.get("PI_ADDRESS"))); | |
| 206 | - | |
| 207 | - model.setFname(DataUtil.getString(map.get("PI_FATHERNAME"))); | |
| 208 | - model.setFphone(DataUtil.getString(map.get("PI_FATHERPHONE"))); | |
| 209 | - model.setFbirth(DataUtil.getDate(map.get(""))); | |
| 210 | - | |
| 211 | - | |
| 212 | - String fproTypeId = DataUtil.getString(map.get("PI_FATHERPROFESSION")); | |
| 213 | - if (fproTypeId != null && !"".equals(fproTypeId)) { | |
| 214 | - String fproTypeName = DataUtil.getOracleBasicConfig(fproTypeId); | |
| 215 | - String id = DataUtil.getMongoBasicConfig(fproTypeName, SystemConfig.PROFESSION_TYPE_ID); | |
| 216 | - model.setFproTypeId(id); | |
| 217 | - } | |
| 218 | - | |
| 219 | - model.setFcertNo(DataUtil.getString(map.get(""))); | |
| 220 | - model.setFcertTypeId(DataUtil.getString(map.get(""))); | |
| 221 | - | |
| 222 | - String fLevelId = DataUtil.getString(map.get("PI_BBCULTURE")); | |
| 223 | - if (fLevelId != null && !"".equals(fLevelId)) { | |
| 224 | - String fLevelName = DataUtil.getOracleBasicConfig(fLevelId); | |
| 225 | - String id = DataUtil.getMongoBasicConfig(fLevelName, SystemConfig.LEVEL_TYPE_ID); | |
| 226 | - model.setfLevelId(id); | |
| 227 | - } | |
| 228 | - | |
| 229 | - model.setMname(DataUtil.getString(map.get("PI_MOTHERNAME"))); | |
| 230 | - model.setMphone(DataUtil.getString(map.get("PI_MOTHERPHONE"))); | |
| 231 | - model.setMbirth(DataUtil.getDate(map.get(""))); | |
| 232 | - | |
| 233 | - String mproTypeId = DataUtil.getString(map.get("PI_MATHERPROFESSION")); | |
| 234 | - if (mproTypeId != null && !"".equals(mproTypeId)) { | |
| 235 | - String mproTypeName = DataUtil.getOracleBasicConfig(mproTypeId); | |
| 236 | - String id = DataUtil.getMongoBasicConfig(mproTypeName, SystemConfig.PROFESSION_TYPE_ID); | |
| 237 | - model.setMproTypeId(id); | |
| 238 | - } | |
| 239 | - | |
| 240 | - model.setMcertNo(DataUtil.getString(map.get("PI_MOTHERPHONE"))); | |
| 241 | - model.setMcertTypeId("57e0a21c0cf209b410a82cda"); | |
| 242 | - | |
| 243 | - String mLevelId = DataUtil.getString(map.get("PI_MMCULTURE")); | |
| 244 | - if (mLevelId != null && !"".equals(mLevelId)) { | |
| 245 | - String mLevelName = DataUtil.getOracleBasicConfig(fLevelId); | |
| 246 | - String id = DataUtil.getMongoBasicConfig(mLevelName, SystemConfig.LEVEL_TYPE_ID); | |
| 247 | - model.setmLevelId(id); | |
| 248 | - } | |
| 249 | - | |
| 250 | - String zhuchanOrg = DataUtil.getString(map.get("PI_BIRTHASPHYXIA")); | |
| 251 | - if (zhuchanOrg != null && !"".equals(zhuchanOrg)) { | |
| 252 | - String id = DataUtil.getString(JDBCUtil.getMysqlSingleObjBySql("select id from organization where name = '" + zhuchanOrg + "'")); | |
| 253 | - model.setDeliverOrg(id); | |
| 254 | - } | |
| 255 | - | |
| 256 | - model.setCardNo(DataUtil.getString(map.get("PI_IDENTITYCARDNUMBER"))); | |
| 257 | - | |
| 258 | - String buildHospitalId = DataUtil.getString(map.get("PI_BOOKBUILDINGHOSPITALID")); | |
| 259 | - | |
| 260 | - | |
| 261 | - if (buildHospitalId != null && !"".equals(buildHospitalId)) { | |
| 262 | - String hname = DataUtil.getPatHosptalById(buildHospitalId); | |
| 263 | - String id = DataUtil.getOrgIdByName(hname); | |
| 264 | - model.setHospitalId(id); | |
| 265 | - } | |
| 266 | - | |
| 267 | - model.setBuildType(1); | |
| 268 | - model.setSex(DataUtil.getInteger(map.get("PI_SEX"))); | |
| 269 | - model.setName(DataUtil.getString(map.get("PI_NAME"))); | |
| 270 | - Integer yn = DataUtil.getInteger(map.get("PI_ISDELETE")); | |
| 271 | - model.setYn(yn); | |
| 272 | - | |
| 273 | - String dueTypeId = DataUtil.getString(map.get("PI_FENMIAN")); | |
| 274 | - if (dueTypeId != null && !"".equals(dueTypeId)) { | |
| 275 | - String name = DataUtil.getDataContentByById(dueTypeId); | |
| 276 | - model.setDueType(FmTypeEnums.getIdByName(name)); | |
| 277 | - } | |
| 278 | - | |
| 279 | - model.setFetusCount(DataUtil.getString(map.get("PI_FOETUSCOUNT"))); | |
| 280 | - model.setDueCount(DataUtil.getString(map.get("PI_BIRTHCOUNT"))); | |
| 281 | - model.setBabyWeight(DataUtil.getString(map.get("PI_WEIGHT"))); | |
| 282 | - model.setBabyHeight(DataUtil.getString(map.get("PI_HEIGHT"))); | |
| 283 | - model.setBabyHead(DataUtil.getString(map.get("PI_HEADSIZE"))); | |
| 284 | - model.setMalformation(DataUtil.getInteger(map.get("PI_BIRTHDEFORMED"))); | |
| 285 | - | |
| 286 | - String doctorId = DataUtil.getString(map.get("PI_CREATEOPER")); | |
| 287 | - if (doctorId != null && !"".equals(doctorId)) { | |
| 288 | - String hname = DataUtil.getEmpNameById(doctorId); | |
| 289 | - String id = DataUtil.getUserIdByName(hname); | |
| 290 | - model.setBuildDoctor(id); | |
| 291 | - } | |
| 292 | - | |
| 293 | - model.setBuildDate(DataUtil.getDate(map.get("PI_CREATETIME"))); | |
| 294 | - | |
| 295 | - Integer isVip = DataUtil.getInteger(map.get("PI_ISVIP")); | |
| 296 | - Integer status = DataUtil.getInteger(map.get("PI_SERVICETYPE")); | |
| 297 | - if (isVip == 0) { | |
| 298 | - model.setServiceType(ServiceTypeEnums.STANDARD_SERVICE.getId()); | |
| 299 | - if (status != null) { | |
| 300 | - if (status == 0) { | |
| 301 | - model.setServiceStatus(ServiceStatusEnums.STANDARD_OPEN.getId()); | |
| 302 | - } else { | |
| 303 | - model.setServiceStatus(ServiceStatusEnums.NO_OPEN.getId()); | |
| 304 | - } | |
| 305 | - | |
| 306 | - } | |
| 307 | - | |
| 308 | - } else if (isVip == 1) { | |
| 309 | - model.setServiceType(ServiceTypeEnums.ADD_SERVICE.getId()); | |
| 310 | - | |
| 311 | - if (status == 0) { | |
| 312 | - model.setServiceStatus(ServiceStatusEnums.ADD_OPEN.getId()); | |
| 313 | - } else if (status == 1) { | |
| 314 | - model.setServiceStatus(ServiceStatusEnums.SUSPEND.getId()); | |
| 315 | - } else if (status == 2) { | |
| 316 | - model.setServiceStatus(ServiceStatusEnums.UNSUBSCRIBE.getId()); | |
| 317 | - } else if (status == 3) { | |
| 318 | - model.setServiceStatus(ServiceStatusEnums.UNSUBSCRIBE.getId()); | |
| 319 | - } else if (status == 4) { | |
| 320 | - model.setServiceStatus(ServiceStatusEnums.ADD_OVERDUE.getId()); | |
| 321 | - } | |
| 322 | - } | |
| 323 | - | |
| 324 | - model.setVcCardNo(DataUtil.getString(map.get("PI_CARDNO"))); | |
| 325 | - // String apgar = getString(map.get("PI_APGAR")); | |
| 326 | - // if (StringUtils.isNotEmpty(apgar)) | |
| 327 | - // { | |
| 328 | - // String[] apgars = apgar.split("-"); | |
| 329 | - // if (apgars) | |
| 330 | - // { | |
| 331 | - // | |
| 332 | - // } | |
| 333 | - // } | |
| 334 | - // model.setApgarScore(); | |
| 335 | - model.setAsphyxiaM(DataUtil.getString(map.get(""))); | |
| 336 | - model.setPregnancyOut(DataUtil.getString(map.get(""))); | |
| 337 | - model.setBabyHealthy(DataUtil.getString(map.get(""))); | |
| 338 | - model.setContactStartM(DataUtil.getString(map.get(""))); | |
| 339 | - model.setContactM(DataUtil.getString(map.get(""))); | |
| 340 | - model.setEarlySuck(DataUtil.getString(map.get(""))); | |
| 341 | - model.setDiagnose(DataUtil.getString(map.get(""))); | |
| 342 | - model.setNextDate(DataUtil.getDate(map.get(""))); | |
| 343 | - model.setLastHighRisk(DataUtil.getInteger(map.get("PI_KIDSTYPE"))); | |
| 344 | - String dueWeek = DataUtil.getString(map.get("PI_GESTATIONALWEEKS")); | |
| 345 | - if (dueWeek != null && !"".equals(dueWeek)) { | |
| 346 | - | |
| 347 | - if (dueWeek.contains(".") && dueWeek.split("\\u002E").length > 0) { | |
| 348 | - model.setDueWeek(Integer.parseInt(dueWeek.split("\\u002E")[0])); | |
| 349 | - } else { | |
| 350 | - String sp = "\\u002B"; | |
| 351 | - String str = dueWeek.split(sp)[0]; | |
| 352 | - model.setDueWeek(Integer.parseInt(str)); | |
| 353 | - } | |
| 354 | - | |
| 355 | - } | |
| 356 | - | |
| 357 | - mongoTemplate.save(model); | |
| 358 | - syncBabyCheck(model.getId(), mongoTemplate,DataUtil.getDate(map.get("PI_BIRTHDAY"))); | |
| 359 | - } | |
| 360 | - | |
| 361 | - | |
| 362 | 183 | private void initChuzhenDatas() |
| 363 | 184 | { |
| 364 | 185 | |
| 365 | 186 | |
| ... | ... | @@ -807,11 +628,8 @@ |
| 807 | 628 | |
| 808 | 629 | } |
| 809 | 630 | |
| 810 | -// private synchronized void save(Object obj) | |
| 811 | -// { | |
| 812 | -// mongoTemplate.save(obj); | |
| 813 | -// } | |
| 814 | 631 | |
| 632 | + | |
| 815 | 633 | private void syncChuZhen(String pid, String parentId, MongoTemplate mongoTemplate,Date lastMenses,int weeks) { |
| 816 | 634 | long startTimes = System.currentTimeMillis(); |
| 817 | 635 | Map<String,Object> map = chuzhenDatas.get(parentId); |
| 818 | 636 | |
| ... | ... | @@ -895,8 +713,8 @@ |
| 895 | 713 | } |
| 896 | 714 | |
| 897 | 715 | } |
| 898 | - | |
| 899 | 716 | chuModel.setDirOpinion(content); |
| 717 | + chuModel.setTreatOpinion(DataUtil.getString(map.get("FE_OTHERINFO"))); | |
| 900 | 718 | |
| 901 | 719 | chuModel.setCheckTime(DataUtil.getDate(map.get("FE_ROCTORTIME"))); |
| 902 | 720 | chuModel.setOtherHighRisk("{}"); |
| ... | ... | @@ -983,7 +801,6 @@ |
| 983 | 801 | antxModel.setType(DataUtil.getString(map.get(""))); |
| 984 | 802 | antxModel.setTypeYc(DataUtil.getString(map.get(""))); |
| 985 | 803 | antxModel.setTreatmentOpinion(DataUtil.getString(map.get("TREATMENTOPINION"))); |
| 986 | - antxModel.setGuide(DataUtil.getString(map.get(""))); | |
| 987 | 804 | |
| 988 | 805 | String checkDoctorName = DataUtil.getString(map.get("CHECKDOCTOR")); |
| 989 | 806 | if (checkDoctorName != null && !"".equals(checkDoctorName)) { |
| 990 | 807 | |
| ... | ... | @@ -1047,8 +864,199 @@ |
| 1047 | 864 | } |
| 1048 | 865 | } |
| 1049 | 866 | |
| 867 | + private void syncBaby(Map<String, Object> map) | |
| 868 | + { | |
| 869 | + PersonModel personModel = new PersonModel(); | |
| 870 | + personModel.setId(DataUtil.getString(map.get("ID"))); | |
| 871 | + personModel.setPhone(DataUtil.getString(map.get("PI_MOTHERPHONE"))); | |
| 872 | + personModel.setName(DataUtil.getString(map.get("PI_NAME"))); | |
| 873 | + personModel.setCardNo(DataUtil.getString(map.get("PI_MOTHERPHONE"))); | |
| 874 | + personModel.setBirth(DataUtil.getDate(map.get("PI_BIRTHDAY"))); | |
| 875 | + personModel.setType(2); | |
| 876 | + personModel.setYn(YnEnums.YES.getId()); | |
| 877 | + personModel.setCreated(DataUtil.getDate(map.get("PI_CREATETIME"))); | |
| 878 | + personModel.setModified(DataUtil.getDate(map.get("PI_OPERTIME"))); | |
| 879 | + | |
| 880 | + mongoTemplate.save(personModel); | |
| 881 | + | |
| 882 | + BabyModel model = new BabyModel(); | |
| 883 | + model.setId(DataUtil.getString(map.get("ID"))); | |
| 884 | + model.setPid(personModel.getId()); | |
| 885 | + model.setCreated(DataUtil.getDate(map.get("PI_CREATETIME"))); | |
| 886 | + model.setModified(DataUtil.getDate(map.get("PI_OPERTIME"))); | |
| 887 | + model.setBirth(DataUtil.getDate(map.get("PI_BIRTHDAY"))); | |
| 888 | + model.setAddress(DataUtil.getString(map.get("PI_ADDRESS"))); | |
| 889 | + | |
| 890 | + model.setFname(DataUtil.getString(map.get("PI_FATHERNAME"))); | |
| 891 | + model.setFphone(DataUtil.getString(map.get("PI_FATHERPHONE"))); | |
| 892 | + model.setFbirth(DataUtil.getDate(map.get(""))); | |
| 893 | + | |
| 894 | + | |
| 895 | + String fproTypeId = DataUtil.getString(map.get("PI_FATHERPROFESSION")); | |
| 896 | + if (fproTypeId != null && !"".equals(fproTypeId)) { | |
| 897 | + String fproTypeName = DataUtil.getOracleBasicConfig(fproTypeId); | |
| 898 | + String id = DataUtil.getMongoBasicConfig(fproTypeName, SystemConfig.PROFESSION_TYPE_ID); | |
| 899 | + model.setFproTypeId(id); | |
| 900 | + } | |
| 901 | + | |
| 902 | + model.setFcertNo(DataUtil.getString(map.get(""))); | |
| 903 | + model.setFcertTypeId(DataUtil.getString(map.get(""))); | |
| 904 | + | |
| 905 | + String fLevelId = DataUtil.getString(map.get("PI_BBCULTURE")); | |
| 906 | + if (fLevelId != null && !"".equals(fLevelId)) { | |
| 907 | + String fLevelName = DataUtil.getOracleBasicConfig(fLevelId); | |
| 908 | + String id = DataUtil.getMongoBasicConfig(fLevelName, SystemConfig.LEVEL_TYPE_ID); | |
| 909 | + model.setfLevelId(id); | |
| 910 | + } | |
| 911 | + | |
| 912 | + model.setMname(DataUtil.getString(map.get("PI_MOTHERNAME"))); | |
| 913 | + model.setMphone(DataUtil.getString(map.get("PI_MOTHERPHONE"))); | |
| 914 | + model.setMbirth(DataUtil.getDate(map.get(""))); | |
| 915 | + | |
| 916 | + String mproTypeId = DataUtil.getString(map.get("PI_MATHERPROFESSION")); | |
| 917 | + if (mproTypeId != null && !"".equals(mproTypeId)) { | |
| 918 | + String mproTypeName = DataUtil.getOracleBasicConfig(mproTypeId); | |
| 919 | + String id = DataUtil.getMongoBasicConfig(mproTypeName, SystemConfig.PROFESSION_TYPE_ID); | |
| 920 | + model.setMproTypeId(id); | |
| 921 | + } | |
| 922 | + | |
| 923 | + model.setMcertNo(DataUtil.getString(map.get("PI_MOTHERPHONE"))); | |
| 924 | + model.setMcertTypeId("57e0a21c0cf209b410a82cda"); | |
| 925 | + | |
| 926 | + String mLevelId = DataUtil.getString(map.get("PI_MMCULTURE")); | |
| 927 | + if (mLevelId != null && !"".equals(mLevelId)) { | |
| 928 | + String mLevelName = DataUtil.getOracleBasicConfig(fLevelId); | |
| 929 | + String id = DataUtil.getMongoBasicConfig(mLevelName, SystemConfig.LEVEL_TYPE_ID); | |
| 930 | + model.setmLevelId(id); | |
| 931 | + } | |
| 932 | + | |
| 933 | + String zhuchanOrg = DataUtil.getString(map.get("PI_BIRTHASPHYXIA")); | |
| 934 | + if (zhuchanOrg != null && !"".equals(zhuchanOrg)) { | |
| 935 | + String id = DataUtil.getString(JDBCUtil.getMysqlSingleObjBySql("select id from organization where name = '" + zhuchanOrg + "'")); | |
| 936 | + model.setDeliverOrg(id); | |
| 937 | + } | |
| 938 | + | |
| 939 | + model.setCardNo(DataUtil.getString(map.get("PI_IDENTITYCARDNUMBER"))); | |
| 940 | + | |
| 941 | + String buildHospitalId = DataUtil.getString(map.get("PI_BOOKBUILDINGHOSPITALID")); | |
| 942 | + | |
| 943 | + | |
| 944 | + if (buildHospitalId != null && !"".equals(buildHospitalId)) { | |
| 945 | + String hname = DataUtil.getPatHosptalById(buildHospitalId); | |
| 946 | + String id = DataUtil.getOrgIdByName(hname); | |
| 947 | + model.setHospitalId(id); | |
| 948 | + } | |
| 949 | + | |
| 950 | + model.setBuildType(1); | |
| 951 | + model.setSex(DataUtil.getInteger(map.get("PI_SEX"))); | |
| 952 | + model.setName(DataUtil.getString(map.get("PI_NAME"))); | |
| 953 | + Integer yn = DataUtil.getInteger(map.get("PI_ISDELETE")); | |
| 954 | + model.setYn(yn); | |
| 955 | + | |
| 956 | + String dueTypeId = DataUtil.getString(map.get("PI_FENMIAN")); | |
| 957 | + if (dueTypeId != null && !"".equals(dueTypeId)) { | |
| 958 | + String name = DataUtil.getDataContentByById(dueTypeId); | |
| 959 | + model.setDueType(FmTypeEnums.getIdByName(name)); | |
| 960 | + } | |
| 961 | + | |
| 962 | + model.setFetusCount(DataUtil.getString(map.get("PI_FOETUSCOUNT"))); | |
| 963 | + model.setDueCount(DataUtil.getString(map.get("PI_BIRTHCOUNT"))); | |
| 964 | + if (StringUtils.isNotEmpty(DataUtil.getString(map.get("PI_WEIGHT")))) | |
| 965 | + { | |
| 966 | + try { | |
| 967 | + String strWeight = DataUtil.getString(map.get("PI_WEIGHT")); | |
| 968 | + java.text.DecimalFormat df =new java.text.DecimalFormat("#.00"); | |
| 969 | + model.setBabyWeight(df.format(strWeight)); | |
| 970 | + }catch (Exception e) | |
| 971 | + { | |
| 972 | + System.out.print(e); | |
| 973 | + } | |
| 974 | + | |
| 975 | + } | |
| 976 | + | |
| 977 | + model.setBabyHeight(DataUtil.getString(map.get("PI_HEIGHT"))); | |
| 978 | + model.setBabyHead(DataUtil.getString(map.get("PI_HEADSIZE"))); | |
| 979 | + model.setMalformation(DataUtil.getInteger(map.get("PI_BIRTHDEFORMED"))); | |
| 980 | + | |
| 981 | + String doctorId = DataUtil.getString(map.get("PI_CREATEOPER")); | |
| 982 | + if (doctorId != null && !"".equals(doctorId)) { | |
| 983 | + String hname = DataUtil.getEmpNameById(doctorId); | |
| 984 | + String id = DataUtil.getUserIdByName(hname); | |
| 985 | + model.setBuildDoctor(id); | |
| 986 | + } | |
| 987 | + | |
| 988 | + model.setBuildDate(DataUtil.getDate(map.get("PI_CREATETIME"))); | |
| 989 | + | |
| 990 | + Integer isVip = DataUtil.getInteger(map.get("PI_ISVIP")); | |
| 991 | + Integer status = DataUtil.getInteger(map.get("PI_SERVICETYPE")); | |
| 992 | + if (isVip == 0) { | |
| 993 | + model.setServiceType(ServiceTypeEnums.STANDARD_SERVICE.getId()); | |
| 994 | + if (status != null) { | |
| 995 | + if (status == 0) { | |
| 996 | + model.setServiceStatus(ServiceStatusEnums.STANDARD_OPEN.getId()); | |
| 997 | + } else { | |
| 998 | + model.setServiceStatus(ServiceStatusEnums.NO_OPEN.getId()); | |
| 999 | + } | |
| 1000 | + | |
| 1001 | + } | |
| 1002 | + | |
| 1003 | + } else if (isVip == 1) { | |
| 1004 | + model.setServiceType(ServiceTypeEnums.ADD_SERVICE.getId()); | |
| 1005 | + | |
| 1006 | + if (status == 0) { | |
| 1007 | + model.setServiceStatus(ServiceStatusEnums.ADD_OPEN.getId()); | |
| 1008 | + } else if (status == 1) { | |
| 1009 | + model.setServiceStatus(ServiceStatusEnums.SUSPEND.getId()); | |
| 1010 | + } else if (status == 2) { | |
| 1011 | + model.setServiceStatus(ServiceStatusEnums.UNSUBSCRIBE.getId()); | |
| 1012 | + } else if (status == 3) { | |
| 1013 | + model.setServiceStatus(ServiceStatusEnums.UNSUBSCRIBE.getId()); | |
| 1014 | + } else if (status == 4) { | |
| 1015 | + model.setServiceStatus(ServiceStatusEnums.ADD_OVERDUE.getId()); | |
| 1016 | + } | |
| 1017 | + } | |
| 1018 | + | |
| 1019 | + model.setVcCardNo(DataUtil.getString(map.get("PI_CARDNO"))); | |
| 1020 | + // String apgar = getString(map.get("PI_APGAR")); | |
| 1021 | + // if (StringUtils.isNotEmpty(apgar)) | |
| 1022 | + // { | |
| 1023 | + // String[] apgars = apgar.split("-"); | |
| 1024 | + // if (apgars) | |
| 1025 | + // { | |
| 1026 | + // | |
| 1027 | + // } | |
| 1028 | + // } | |
| 1029 | + // model.setApgarScore(); | |
| 1030 | + model.setAsphyxiaM(DataUtil.getString(map.get(""))); | |
| 1031 | + model.setPregnancyOut(DataUtil.getString(map.get(""))); | |
| 1032 | + model.setBabyHealthy(DataUtil.getString(map.get(""))); | |
| 1033 | + model.setContactStartM(DataUtil.getString(map.get(""))); | |
| 1034 | + model.setContactM(DataUtil.getString(map.get(""))); | |
| 1035 | + model.setEarlySuck(DataUtil.getString(map.get(""))); | |
| 1036 | + model.setDiagnose(DataUtil.getString(map.get(""))); | |
| 1037 | + model.setNextDate(DataUtil.getDate(map.get(""))); | |
| 1038 | + model.setHighRisk(DataUtil.getInteger(map.get("PI_KIDSTYPE"))); | |
| 1039 | + model.setLastHighRisk(DataUtil.getInteger(map.get("PI_KIDSTYPE"))); | |
| 1040 | + String dueWeek = DataUtil.getString(map.get("PI_GESTATIONALWEEKS")); | |
| 1041 | + if (dueWeek != null && !"".equals(dueWeek)) { | |
| 1042 | + | |
| 1043 | + if (dueWeek.contains(".") && dueWeek.split("\\u002E").length > 0) { | |
| 1044 | + model.setDueWeek(Integer.parseInt(dueWeek.split("\\u002E")[0])); | |
| 1045 | + } else { | |
| 1046 | + String sp = "\\u002B"; | |
| 1047 | + String str = dueWeek.split(sp)[0]; | |
| 1048 | + model.setDueWeek(Integer.parseInt(str)); | |
| 1049 | + } | |
| 1050 | + | |
| 1051 | + } | |
| 1052 | + | |
| 1053 | + mongoTemplate.save(model); | |
| 1054 | + syncBabyCheck(model.getId(), mongoTemplate,DataUtil.getDate(map.get("PI_BIRTHDAY"))); | |
| 1055 | + } | |
| 1056 | + | |
| 1057 | + | |
| 1050 | 1058 | public void syncBabyCheck(String parentId, MongoTemplate mongoTemplate,Date birth) { |
| 1051 | - String sql = " select * from MOMMY_CHILDEXAMINRECORD MC left join MOMMY_PATIENTINFO MP ON MP.PI_ID = MC.CER_PATIENTID WHERE replace(MP.Pi_Id,'-','')= '" + parentId + "'"; | |
| 1059 | + String sql = " select * from MOMMY_CHILDEXAMINRECORD MC left join MOMMY_PATIENTINFO MP ON MP.PI_ID = MC.CER_PATIENTID WHERE replace(MP.Pi_Id,'-','')= '" + parentId + "' order by mc.CER_EXAMINDATE asc "; | |
| 1052 | 1060 | |
| 1053 | 1061 | List<Map<String, Object>> list = JDBCUtil.getOracleListDataBySql(sql); |
| 1054 | 1062 | for (Map<String, Object> map : list) { |
| ... | ... | @@ -1075,9 +1083,7 @@ |
| 1075 | 1083 | checkModel.setCheckDoctor(id); |
| 1076 | 1084 | } |
| 1077 | 1085 | |
| 1078 | - checkModel.setGuideSuggest(DataUtil.getString(map.get("CER_DIRECTIVEOPINION"))); | |
| 1079 | - checkModel.setHandlSuggest(DataUtil.getString(map.get("CER_REMARKS"))); | |
| 1080 | - | |
| 1086 | + checkModel.setHandlSuggest(DataUtil.getString(map.get("CER_DIRECTIVEOPINION"))); | |
| 1081 | 1087 | checkModel.setMainFoster(DataUtil.getString(map.get(""))); |
| 1082 | 1088 | |
| 1083 | 1089 | |
| ... | ... | @@ -1205,6 +1211,10 @@ |
| 1205 | 1211 | checkModel.setWhiteCell(result); |
| 1206 | 1212 | } |
| 1207 | 1213 | } |
| 1214 | + | |
| 1215 | + Date nextDate = DataUtil.getDate(map.get("CER_NEXTEXAMINDATE")); | |
| 1216 | + mongoTemplate.updateFirst(new Query(Criteria.where("id").is(parentId)), Update.update("nextDate", nextDate), BabyModel.class); | |
| 1217 | + | |
| 1208 | 1218 | mongoTemplate.save(checkModel); |
| 1209 | 1219 | } |
| 1210 | 1220 | } |