From 79ec28d5882efc5cdab4b30158fc4b044acef478 Mon Sep 17 00:00:00 2001 From: liquanyu Date: Thu, 22 Apr 2021 17:26:56 +0800 Subject: [PATCH] update --- .../dao/master/MasterMysqlAntexcMapper.java | 7 - .../service/impl/MysqlAntexcServiceImpl.java | 2 - .../resources/mainOrm/master/MasterMysqlAntexc.xml | 170 +++++++++++++++------ .../operate/web/controller/TestController.java | 1 - .../operate/web/facade/PatientSyncMysqlFacade.java | 69 ++++++--- 5 files changed, 170 insertions(+), 79 deletions(-) diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/dao/master/MasterMysqlAntexcMapper.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/dao/master/MasterMysqlAntexcMapper.java index 2af7309..f91a803 100644 --- a/platform-biz-service/src/main/java/com/lyms/platform/permission/dao/master/MasterMysqlAntexcMapper.java +++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/dao/master/MasterMysqlAntexcMapper.java @@ -11,15 +11,8 @@ import java.util.Map; public interface MasterMysqlAntexcMapper { void saveMysqlAntexc(MysqlAntexc model); - - void deleteMysqlAntexc(MysqlAntexc model); - - void saveMysqlAntex(MysqlAntex model); - - - void deleteMysqlAntex(MysqlAntex model); void addRisk(MysqlRisk model); diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/MysqlAntexcServiceImpl.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/MysqlAntexcServiceImpl.java index 167a0f0..8c972dd 100644 --- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/MysqlAntexcServiceImpl.java +++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/MysqlAntexcServiceImpl.java @@ -149,13 +149,11 @@ public class MysqlAntexcServiceImpl implements MysqlAntexcService { { masterMysqlAntexcMapper.deleteRiskLevelToMysql(reportRiskLevel); } - @Override public void saveRiskLevelToMysql(ReportRiskLevel reportRiskLevel) { masterMysqlAntexcMapper.saveRiskLevelToMysql(reportRiskLevel); } - @Override public List> getBuildCount(Map param) { return masterMysqlAntexcMapper.getBuildCount(param); diff --git a/platform-biz-service/src/main/resources/mainOrm/master/MasterMysqlAntexc.xml b/platform-biz-service/src/main/resources/mainOrm/master/MasterMysqlAntexc.xml index d2afd0d..32f63a9 100644 --- a/platform-biz-service/src/main/resources/mainOrm/master/MasterMysqlAntexc.xml +++ b/platform-biz-service/src/main/resources/mainOrm/master/MasterMysqlAntexc.xml @@ -1292,8 +1292,9 @@ @@ -1423,10 +1476,10 @@ ) tp INNER JOIN - (SELECT c.sourceId as sourceId,c.hospitalId from report_risk_level r - INNER JOIN report_antexchu c on r.foreignId = c.cid where r.type = 2 and c.type=1 and riskLevel > 1 ) - l on tp.patientId=l.sourceId + report_antexchu l on tp.patientId=l.sourceId + INNER JOIN report_risk_level r on r.foreignId = l.cid INNER JOIN organization o on l.hospitalId=o.id + where r.type = 2 and c.type=1 and riskLevel > 1 GROUP BY o.name @@ -1445,10 +1498,11 @@ ) tp INNER JOIN - (SELECT DISTINCT(c.sourceId) as sourceId ,c.hospitalId from report_risk_level r - INNER JOIN report_antexchu c on r.foreignId = c.cid where r.type = 2 and c.type=1 and riskLevel = 2 ) - l on tp.patientId=l.sourceId - INNER JOIN organization o on l.hospitalId=o.id GROUP BY o.name + report_antexchu l on tp.patientId=l.sourceId + INNER JOIN report_risk_level r on r.foreignId = l.cid + INNER JOIN organization o on l.hospitalId=o.id + where r.type = 2 and c.type=1 and riskLevel = 2 + GROUP BY o.name @@ -1489,10 +1544,11 @@ ) tp INNER JOIN - (SELECT DISTINCT(c.sourceId) as sourceId ,c.hospitalId from report_risk_level r - INNER JOIN report_antexchu c on r.foreignId = c.cid where r.type = 2 and c.type=1 and riskLevel = 4 ) - l on tp.patientId=l.sourceId - INNER JOIN organization o on l.hospitalId=o.id GROUP BY o.name + report_antexchu l on tp.patientId=l.sourceId + INNER JOIN report_risk_level r on r.foreignId = l.cid + INNER JOIN organization o on l.hospitalId=o.id + where r.type = 2 and c.type=1 and riskLevel = 4 + GROUP BY o.name @@ -1515,10 +1571,11 @@ ) tp INNER JOIN - (SELECT DISTINCT(c.sourceId) as sourceId ,c.hospitalId from report_risk_level r - INNER JOIN report_antexchu c on r.foreignId = c.cid where r.type = 2 and c.type=1 and riskLevel = 5 ) - l on tp.patientId=l.sourceId - INNER JOIN organization o on l.hospitalId=o.id GROUP BY o.name + report_antexchu l on tp.patientId=l.sourceId + INNER JOIN report_risk_level r on r.foreignId = l.cid + INNER JOIN organization o on l.hospitalId=o.id + where r.type = 2 and c.type=1 and riskLevel = 5 + GROUP BY o.name @@ -1539,16 +1596,17 @@ ) tp INNER JOIN - (SELECT DISTINCT(c.sourceId) as sourceId ,c.hospitalId from report_risk_level r - INNER JOIN report_antexchu c on r.foreignId = c.cid where r.type = 2 and c.type=1 and riskLevel = 1 ) - l on tp.patientId=l.sourceId - INNER JOIN organization o on l.hospitalId=o.id GROUP BY o.name + report_antexchu l on tp.patientId=l.sourceId + INNER JOIN report_risk_level r on r.foreignId = l.cid + INNER JOIN organization o on l.hospitalId=o.id + where r.type = 2 and c.type=1 and riskLevel = 1 + GROUP BY o.name 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 0535ba9..95d9982 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 @@ -4265,7 +4265,6 @@ public class TestController extends BaseController { - @ResponseBody @RequestMapping(value = "/syncAntexToMysql", method = RequestMethod.GET) public String syncAntexToMysql(@RequestParam(required = false) Date startDate,@RequestParam(required = false) Date endDate) { diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientSyncMysqlFacade.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientSyncMysqlFacade.java index 7ae5a0b..f20241f 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientSyncMysqlFacade.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/PatientSyncMysqlFacade.java @@ -1287,6 +1287,7 @@ public class PatientSyncMysqlFacade { while (true) { patientsQuery.setPage(page); + System.out.println("syncPatientsToMysql" + page); List patientses = patientsService.queryPatient(patientsQuery); if (CollectionUtils.isEmpty(patientses)) { @@ -1327,6 +1328,7 @@ public class PatientSyncMysqlFacade { while (true) { antExChuQuery.setPage(page); + System.out.println("syncAntexchuToMysql"+page); List antExChus = antenatalExaminationService.queryAntExChu(antExChuQuery); if (CollectionUtils.isEmpty(antExChus)) { @@ -1551,6 +1553,12 @@ public class PatientSyncMysqlFacade { param.put("cityId",cityId); param.put("areaId", areaId); List> bulidsCount = mysqlAntexcService.getBuildCount(param); + List> bulidCheckPersonCounts = mysqlAntexcService.getBulidCheckPersonCount(param); + List> bulidCheckNumCounts = mysqlAntexcService.getBulidCheckNumCount(param); + List> checkPersonCounts = mysqlAntexcService.getCheckPersonCount(param); + List> matDeliverCounts = mysqlAntexcService.getMatDeliverCount(param); + List> liveCounts = mysqlAntexcService.getLiveCount(param); + if (CollectionUtils.isNotEmpty(bulidsCount)) { @@ -1560,6 +1568,7 @@ public class PatientSyncMysqlFacade { String provId = String.valueOf(map.get("provinceId")); String cId = String.valueOf(map.get("cityId")); String aId = String.valueOf(map.get("areaId")); + String hospitalName = String.valueOf(map.get("hospitalName")); String provinceName = getAddressName(provId); String cityName = getAddressName(cId); String areaName = getAddressName(aId); @@ -1568,47 +1577,69 @@ public class PatientSyncMysqlFacade { map.put("cityName",cityName); map.put("areaName",areaName); - Map param1 = new HashMap(); - param1.put("startDate",startDate); - param1.put("endDate",endDate); - param1.put("hospitalId",map.get("hospitalId")); - List> bulidCheckPersonCounts = mysqlAntexcService.getBulidCheckPersonCount(param1); - //建档产检人数 long bulidCheckPersonCount = 0; if (CollectionUtils.isNotEmpty(bulidCheckPersonCounts)) { - bulidCheckPersonCount = Integer.valueOf(String.valueOf(bulidCheckPersonCounts.get(0).get("bulidCheckPersonCount"))); + for (Map checkData : bulidCheckPersonCounts) { + if (hospitalName.equals(checkData.get("hospitalName"))) + { + bulidCheckPersonCount = Long.valueOf(String.valueOf(checkData.get("bulidCheckPersonCount"))); + break; + } + } } map.put("bulidCheckPersonCount",bulidCheckPersonCount); - List> bulidCheckNumCounts = mysqlAntexcService.getBulidCheckNumCount(param1); + //建档产检人次统计 - int bulidCheckNumCount = 0; + long bulidCheckNumCount = 0; if (CollectionUtils.isNotEmpty(bulidCheckNumCounts)) { - bulidCheckNumCount = Integer.valueOf(String.valueOf(bulidCheckNumCounts.get(0).get("bulidCheckNumCount"))); + for (Map checkData : bulidCheckNumCounts) { + if (hospitalName.equals(checkData.get("hospitalName"))) + { + bulidCheckNumCount = Long.valueOf(String.valueOf(checkData.get("bulidCheckNumCount"))); + break; + } + } } map.put("bulidCheckNumCount",bulidCheckNumCount); //产检时间的产检人数统计 - List> checkPersonCounts = mysqlAntexcService.getCheckPersonCount(param1); - int checkPersonCount = 0; + + long checkPersonCount = 0; if (CollectionUtils.isNotEmpty(checkPersonCounts)) { - checkPersonCount = Integer.valueOf(String.valueOf(checkPersonCounts.get(0).get("checkPersonCount"))); + for (Map checkData : checkPersonCounts) { + if (hospitalName.equals(checkData.get("hospitalName"))) + { + checkPersonCount = Long.valueOf(String.valueOf(checkData.get("checkPersonCount"))); + break; + } + } } map.put("checkPersonCount",checkPersonCount); - int matDeliverCount = 0; - List> matDeliverCounts = mysqlAntexcService.getMatDeliverCount(param1); + long matDeliverCount = 0; if (CollectionUtils.isNotEmpty(matDeliverCounts)) { - matDeliverCount = Integer.valueOf(String.valueOf(matDeliverCounts.get(0).get("matDeliverCount"))); + for (Map checkData : matDeliverCounts) { + if (hospitalName.equals(checkData.get("hospitalName"))) + { + matDeliverCount = Long.valueOf(String.valueOf(checkData.get("matDeliverCount"))); + break; + } + } } map.put("matDeliverCount",matDeliverCount); - List> liveCounts = mysqlAntexcService.getLiveCount(param1); - int liveCount = 0; + long liveCount = 0; if (CollectionUtils.isNotEmpty(liveCounts)) { - liveCount = Integer.valueOf(String.valueOf(liveCounts.get(0).get("liveCount"))); + for (Map checkData : liveCounts) { + if (hospitalName.equals(checkData.get("hospitalName"))) + { + liveCount = Long.valueOf(String.valueOf(checkData.get("liveCount"))); + break; + } + } } map.put("liveCount",liveCount); } -- 1.8.3.1