diff --git a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/controller/BigScreenController.java b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/controller/BigScreenController.java index 7378c3a..50435ec 100644 --- a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/controller/BigScreenController.java +++ b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/controller/BigScreenController.java @@ -384,6 +384,7 @@ public class BigScreenController { List orientList = new ArrayList<>(); List liveList = new ArrayList<>(); List waterList = new ArrayList<>(); + Map map = new HashMap<>(); for (SurvDeviceDeploy survDeviceDeploy : survStationInfo.getDeviceList()) { if(PollutionConstants.SOIL_SURV.equals(survDeviceDeploy.getDeployType())){//土壤设备 soilList.add(survDeviceDeploy.getDeployCode()); @@ -399,6 +400,7 @@ public class BigScreenController { //只保留摄像头的数据 // remainList.add(survDeviceDeploy); } + map.put(survDeviceDeploy.getDeployCode(),survDeviceDeploy); } // if(PollutionConstants.SOIL_SURV.equals(survDeviceDeploy.getDeployType())){//土壤设备 @@ -462,9 +464,14 @@ public class BigScreenController { noent.setStationCode(survStationInfo.getStationCode()); noent.setSurvItem(PollutionEnum.dataWaterNo.getCode()); + String deployId = map.get(transdataOrientwaterVo.getDeviceCode()).getId(); + tpent.setValue(transdataOrientwaterVo.getDataWaterTp()); + tpent.setDeployId(deployId); tnent.setValue(transdataOrientwaterVo.getDataWaterTn()); + tnent.setDeployId(deployId); noent.setValue(transdataOrientwaterVo.getDataWaterNo()); + noent.setDeployId(deployId); tpList.add(tpent); tnList.add(tnent); noList.add(noent); @@ -525,10 +532,16 @@ public class BigScreenController { codent.setStationCode(survStationInfo.getStationCode()); codent.setSurvItem(PollutionEnum.dataWaterCod.getCode()); + String deployId = map.get(transdataLivestockwaterVo.getDeviceCode()).getId(); + tpent.setValue(transdataLivestockwaterVo.getDataWaterTp()); + tpent.setDeployId(deployId); tnent.setValue(transdataLivestockwaterVo.getDataWaterTn()); + tnent.setDeployId(deployId); nhent.setValue(transdataLivestockwaterVo.getDataWaterNh()); + nhent.setDeployId(deployId); codent.setValue(transdataLivestockwaterVo.getDataWaterCod()); + codent.setDeployId(deployId); tpList.add(tpent); tnList.add(tnent); @@ -549,6 +562,9 @@ public class BigScreenController { if(IotConstants.Data_Types_All.equals(dataTypes) || IotConstants.Data_Types_Water.equals(dataTypes)) { if (!waterList.isEmpty()) { //五常 List commonDataTrans = CommonUtils.transData(waterList.get(0), false, null, null, null, null).getTransData(); + if(!commonDataTrans.isEmpty()){ + commonDataTrans.forEach(item->item.setStationName(survStationInfo.getStationName())); + } listFinal.addAll(commonDataTrans); } else { jsonObject.put("HisSurvData", new ArrayList<>()); @@ -564,6 +580,47 @@ public class BigScreenController { listFinal.sort(timeCompare); jsonObject.put("HisSurvData", listFinal); } + //补充土壤最新数据 + List deployTypes = new ArrayList<>(); + deployTypes.add(PollutionConstants.SOIL_SURV); + deployTypes.add(PollutionConstants.AIR_SURV); + List deploys = deployService.getDeviceListByStation(null,deployTypes); + List soilIds = new ArrayList<>(); + List airIds = new ArrayList<>(); + if(!deploys.isEmpty()){ + for (SurvDeviceDeploy deploy : deploys) { + if(PollutionConstants.SOIL_SURV.equals(deploy.getDeployType())){//土壤设备 + soilIds.add(deploy.getId()); + }else if(PollutionConstants.AIR_SURV.equals(deploy.getDeployType())){//气象设备 + airIds.add(deploy.getId()); + } + } + } + List soilDataTrans = new ArrayList<>(); + if(!soilIds.isEmpty()){ + List soildsData = transdataSoilService.lambdaQuery() + .in(SurvTransdataSoil::getDeployId,soilIds) + .list(); + + for (SurvTransdataSoil datas : soildsData) { + List trans = CommonUtils.constructSoil(datas); + soilDataTrans.addAll(trans); + } + } + jsonObject.put("soilHisSurvData", soilDataTrans); + List airDataTrans = new ArrayList<>(); + if(!airIds.isEmpty()){ + List airsData = transdataAirService.lambdaQuery() + .in(SurvTransdataAir::getDeployId,airIds) + .list(); + + for (SurvTransdataAir datas : airsData) { + List trans = CommonUtils.constructAir(datas); + airDataTrans.addAll(trans); + } + } + jsonObject.put("airHisSurvData", airDataTrans); + return Result.ok(jsonObject); } diff --git a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/mapper/xml/SurvTransdataOrientwaterMapper.xml b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/mapper/xml/SurvTransdataOrientwaterMapper.xml index bdba9dd..446c199 100644 --- a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/mapper/xml/SurvTransdataOrientwaterMapper.xml +++ b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/mapper/xml/SurvTransdataOrientwaterMapper.xml @@ -40,6 +40,7 @@ +