diff --git a/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/controller/SurvStationInfoController.java b/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/controller/SurvStationInfoController.java index 782b74e..a963a0b 100644 --- a/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/controller/SurvStationInfoController.java +++ b/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/controller/SurvStationInfoController.java @@ -49,8 +49,6 @@ public class SurvStationInfoController { @Autowired private ISurvStationInfoService survStationInfoService; @Autowired - private ISurvDeviceInfoService survDeviceInfoService; - @Autowired private ISurvDeviceDeployService survDeviceDeployService; @Autowired private IScEquZhibiaoService zhibiaoService; @@ -156,36 +154,39 @@ public class SurvStationInfoController { Integer finalDataCounts = 0; //水实时 - if(!orientList.isEmpty()) { - //计算历史数据量 - Integer dataCounts = hisdataOrientwaterService.getHisDataCount(orientList); - finalDataCounts=finalDataCounts+dataCounts; - } -// //畜禽 - if(!liveList.isEmpty()) { - //计算历史数据量 - Integer dataCounts = hisdataLivestockwaterService.getHisDataCount(liveList); - finalDataCounts=finalDataCounts+dataCounts; - } - //气实时 - if(!airList.isEmpty()) { +// if(!orientList.isEmpty()) { +// //计算历史数据量 +// Integer dataCounts = hisdataOrientwaterService.getHisDataCount(orientList); +// finalDataCounts=finalDataCounts+dataCounts; +// } +//// //畜禽 +// if(!liveList.isEmpty()) { +// //计算历史数据量 +// Integer dataCounts = hisdataLivestockwaterService.getHisDataCount(liveList); +// finalDataCounts=finalDataCounts+dataCounts; +// } +// //气实时 +// if(!airList.isEmpty()) { +// +// //计算历史数据量 +// Integer dataCounts = hisdataAirService.getHisDataCount(airList); +// finalDataCounts=finalDataCounts+dataCounts; +// } +// //土壤实时 +// if(!soilList.isEmpty()){ +// //计算历史数据量 +// Integer dataCounts = hisdataSoilService.getHisDataCount(soilList); +// finalDataCounts=finalDataCounts+dataCounts; +// } +// //水质实时 +// if(!waterList.isEmpty()){ +// //计算历史数据量 +// Integer dataCounts = hisdataSoilService.getHisDataCount(waterList); +// finalDataCounts=finalDataCounts+dataCounts; +// } + + finalDataCounts = survStationInfoService.countStationData(record.getStationCode()); - //计算历史数据量 - Integer dataCounts = hisdataAirService.getHisDataCount(airList); - finalDataCounts=finalDataCounts+dataCounts; - } - //土壤实时 - if(!soilList.isEmpty()){ - //计算历史数据量 - Integer dataCounts = hisdataSoilService.getHisDataCount(soilList); - finalDataCounts=finalDataCounts+dataCounts; - } - //水质实时 - if(!waterList.isEmpty()){ - //计算历史数据量 - Integer dataCounts = hisdataSoilService.getHisDataCount(waterList); - finalDataCounts=finalDataCounts+dataCounts; - } //获取数据量 record.setSurvDataCount(finalDataCounts); //补充设备在线状态 @@ -313,8 +314,8 @@ public class SurvStationInfoController { constructOrient.setTransdataOrientwaterVo(survTransdataOrientwaterVo); orientData.addAll(zhAdminFeignClient.constructOrient(constructOrient)); //计算历史数据量 - Integer dataCounts = hisdataOrientwaterService.getHisDataCount(orientList); - finalDataCounts=finalDataCounts+dataCounts; +// Integer dataCounts = hisdataOrientwaterService.getHisDataCount(orientList); +// finalDataCounts=finalDataCounts+dataCounts; } // //畜禽 if(!liveList.isEmpty()) { @@ -324,8 +325,8 @@ public class SurvStationInfoController { constructLive.setTransdataLivestockwaterVo(survTransdataLivestockwaterVo); LiveData.addAll(zhAdminFeignClient.constructLive(constructLive)); //计算历史数据量 - Integer dataCounts = hisdataLivestockwaterService.getHisDataCount(liveList); - finalDataCounts=finalDataCounts+dataCounts; +// Integer dataCounts = hisdataLivestockwaterService.getHisDataCount(liveList); +// finalDataCounts=finalDataCounts+dataCounts; } // //气实时 if(!airList.isEmpty()) { @@ -337,8 +338,8 @@ public class SurvStationInfoController { constructAir.setDeploy(deployMap.get(survTransdataAirVo.getDeployCode())); airData.addAll(zhAdminFeignClient.constructAir(constructAir)); //计算历史数据量 - Integer dataCounts = hisdataAirService.getHisDataCount(airList); - finalDataCounts=finalDataCounts+dataCounts; +// Integer dataCounts = hisdataAirService.getHisDataCount(airList); +// finalDataCounts=finalDataCounts+dataCounts; } //土壤实时 if(!soilList.isEmpty()){ @@ -350,8 +351,8 @@ public class SurvStationInfoController { constructSoil.setDeploy(deployMap.get(survTransdataSoilVo.getDeployCode())); soilData.addAll(zhAdminFeignClient.constructSoil(constructSoil)); //计算历史数据量 - Integer dataCounts = hisdataSoilService.getHisDataCount(soilList); - finalDataCounts=finalDataCounts+dataCounts; +// Integer dataCounts = hisdataSoilService.getHisDataCount(soilList); +// finalDataCounts=finalDataCounts+dataCounts; } //水质实时 if(!waterList.isEmpty()){ @@ -363,8 +364,8 @@ public class SurvStationInfoController { constructSoil.setDeploy(deployMap.get(survTransdataSoilVo.getDeployCode())); waterData.addAll(zhAdminFeignClient.constructSoil(constructSoil)); //计算历史数据量 - Integer dataCounts = hisdataSoilService.getHisDataCount(waterList); - finalDataCounts=finalDataCounts+dataCounts; +// Integer dataCounts = hisdataSoilService.getHisDataCount(waterList); +// finalDataCounts=finalDataCounts+dataCounts; } // //恶臭实时 if(!stinkList.isEmpty()){ @@ -373,10 +374,11 @@ public class SurvStationInfoController { constructStink.setTransdataStinkVo(survTransdataStinkVo); stinkData.addAll(zhAdminFeignClient.constructStink(constructStink)); //计算历史数据量 - Integer dataCounts = survHisdataVocsService.getHisDataCount(stinkList); - finalDataCounts=finalDataCounts+dataCounts; +// Integer dataCounts = survHisdataVocsService.getHisDataCount(stinkList); +// finalDataCounts=finalDataCounts+dataCounts; } //获取数据量 + finalDataCounts = survStationInfoService.countStationData(curStation.getStationCode()); curStation.setSurvDataCount(finalDataCounts); //重新计算设备数 // int counts = curStation.getDeviceList().size(); diff --git a/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/mapper/SurvStationInfoMapper.java b/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/mapper/SurvStationInfoMapper.java index 39d1775..c277d07 100644 --- a/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/mapper/SurvStationInfoMapper.java +++ b/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/mapper/SurvStationInfoMapper.java @@ -25,4 +25,6 @@ public interface SurvStationInfoMapper extends BaseMapper { List getAllStationAndDevice(@Param("stationCode") String stationCode,@Param("camera") String camera, @Param("token")String token,@Param("tenantId")String tenantId); Integer getCountOfAllData(); + + Integer countStationData(String stationCode); } diff --git a/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/mapper/xml/SurvStationInfoMapper.xml b/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/mapper/xml/SurvStationInfoMapper.xml index 2d52dd8..3688c93 100644 --- a/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/mapper/xml/SurvStationInfoMapper.xml +++ b/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/mapper/xml/SurvStationInfoMapper.xml @@ -118,4 +118,19 @@ + + \ No newline at end of file diff --git a/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/service/ISurvStationInfoService.java b/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/service/ISurvStationInfoService.java index d83045d..8cf2641 100644 --- a/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/service/ISurvStationInfoService.java +++ b/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/service/ISurvStationInfoService.java @@ -25,4 +25,6 @@ public interface ISurvStationInfoService extends IService { Integer getCountOfAllData(); Integer getStationDataCounts(SurvStationInfo survStationInfo,String tenantId); + + Integer countStationData(String stationCode); } diff --git a/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/service/impl/SurvStationInfoServiceImpl.java b/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/service/impl/SurvStationInfoServiceImpl.java index 622b973..43f2089 100644 --- a/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/service/impl/SurvStationInfoServiceImpl.java +++ b/zh-module-applet/zh-applet-api/src/main/java/org/jeecg/system/applet/service/impl/SurvStationInfoServiceImpl.java @@ -108,5 +108,10 @@ public class SurvStationInfoServiceImpl extends ServiceImpl