Commit 3f88cd32eb3bfec98d34590097a96b2825be5f61
1 parent
30c4ef2a14
Exists in
master
and in
6 other branches
荣成接口
Showing 1 changed file with 21 additions and 18 deletions
platform-operate-api/src/main/java/com/lyms/hospitalapi/rcfy/RcGlxtService.java
View file @
3f88cd3
| ... | ... | @@ -25,6 +25,7 @@ |
| 25 | 25 | |
| 26 | 26 | import java.sql.*; |
| 27 | 27 | import java.util.*; |
| 28 | +import java.util.Date; | |
| 28 | 29 | |
| 29 | 30 | |
| 30 | 31 | /** |
| ... | ... | @@ -591,20 +592,6 @@ |
| 591 | 592 | ps.setString(6, typeName); |
| 592 | 593 | ps.setString(7, null); |
| 593 | 594 | |
| 594 | -// SieveQuery sieveQuery = new SieveQuery(); | |
| 595 | -// sieveQuery.setYn(YnEnums.YES.getId()); | |
| 596 | -// sieveQuery.setParentId(model.getParentId()); | |
| 597 | -// List<SieveModel> modelList = sieveService.queryList(sieveQuery); | |
| 598 | -// String sieveResult= ""; | |
| 599 | -// if (CollectionUtils.isNotEmpty(modelList)) | |
| 600 | -// { | |
| 601 | -// Integer result = modelList.get(0).getCqResult(); | |
| 602 | -// if (result != null) | |
| 603 | -// { | |
| 604 | -// sieveResult = result == 0 ? "1" :"2"; | |
| 605 | -// } | |
| 606 | -// } | |
| 607 | - | |
| 608 | 595 | String sieveResult= ""; |
| 609 | 596 | if (map.get(key) != null) |
| 610 | 597 | { |
| ... | ... | @@ -672,7 +659,7 @@ |
| 672 | 659 | } |
| 673 | 660 | catch (Exception e) |
| 674 | 661 | { |
| 675 | - ExceptionUtils.catchException(e,"saveRcSieveInfoCount error."); | |
| 662 | + ExceptionUtils.catchException(e,"saveRcSieveInfo error."); | |
| 676 | 663 | }finally { |
| 677 | 664 | try { |
| 678 | 665 | if (ps != null) |
| 679 | 666 | |
| ... | ... | @@ -1346,9 +1333,8 @@ |
| 1346 | 1333 | |
| 1347 | 1334 | public void taskWorker() |
| 1348 | 1335 | { |
| 1349 | - //十分钟执行一次 | |
| 1350 | 1336 | java.util.Date end = new java.util.Date(); |
| 1351 | - java.util.Date start = new java.util.Date(end.getTime()-2*60*1000); | |
| 1337 | + java.util.Date start = new java.util.Date(end.getTime()-5*60*1000); | |
| 1352 | 1338 | |
| 1353 | 1339 | List<String> hids = getHids(); |
| 1354 | 1340 | |
| 1355 | 1341 | |
| ... | ... | @@ -1462,10 +1448,11 @@ |
| 1462 | 1448 | { |
| 1463 | 1449 | for (SieveResultModel sieveResultModel : list) |
| 1464 | 1450 | { |
| 1465 | - saveRcSieveInfo(sieveResultModel,hids); | |
| 1451 | + saveRcSieveInfo(sieveResultModel, hids); | |
| 1466 | 1452 | } |
| 1467 | 1453 | } |
| 1468 | 1454 | |
| 1455 | + //孕产妇妊娠风险 | |
| 1469 | 1456 | AntExRecordQuery antExRecordQuery = new AntExRecordQuery(); |
| 1470 | 1457 | antExRecordQuery.setHospitalList(hids); |
| 1471 | 1458 | antExRecordQuery.setModifiedStart(start); |
| ... | ... | @@ -1480,6 +1467,22 @@ |
| 1480 | 1467 | } |
| 1481 | 1468 | } |
| 1482 | 1469 | |
| 1470 | + | |
| 1471 | + //母婴阻断 | |
| 1472 | + AntExChuQuery antExChuQuery = new AntExChuQuery(); | |
| 1473 | + antExChuQuery.setYn(YnEnums.YES.getId()); | |
| 1474 | + antExChuQuery.setHospitalList(getHids()); | |
| 1475 | + antExChuQuery.setCreatedTimeStart(start); | |
| 1476 | + antExChuQuery.setCreatedTimeEnd(end); | |
| 1477 | + List<AntExChuModel> antExChuModels = antenatalExaminationService.queryAntExChu(antExChuQuery); | |
| 1478 | + System.out.println("xxxxxx antExChuModels=" + antExChuModels.size()+"===="+antExChuQuery.convertToQuery().convertToMongoQuery().toString()); | |
| 1479 | + if (org.apache.commons.collections.CollectionUtils.isNotEmpty(antExChuModels)) | |
| 1480 | + { | |
| 1481 | + for (AntExChuModel chuModel : antExChuModels) | |
| 1482 | + { | |
| 1483 | + saveRcZdInfo(chuModel); | |
| 1484 | + } | |
| 1485 | + } | |
| 1483 | 1486 | } |
| 1484 | 1487 | |
| 1485 | 1488 | } |