From 01136df34a1d8edb6972bbec725b656a602b83af Mon Sep 17 00:00:00 2001
From: elkers <elkers@163.com>
Date: 星期四, 24 四月 2025 16:58:27 +0800
Subject: [PATCH] 修改启泵时间时长计算

---
 src/main/java/com/nanjing/water/service/DataUploadRecordService.java |  300 +++++++++++++++++++++++++++++++++++------------------------
 1 files changed, 179 insertions(+), 121 deletions(-)

diff --git a/src/main/java/com/nanjing/water/service/DataUploadRecordService.java b/src/main/java/com/nanjing/water/service/DataUploadRecordService.java
index 138dba4..7dddf01 100644
--- a/src/main/java/com/nanjing/water/service/DataUploadRecordService.java
+++ b/src/main/java/com/nanjing/water/service/DataUploadRecordService.java
@@ -86,6 +86,8 @@
     private StringRedisTemplate redisTemplate;
     @Autowired
     private ObjectMapper objectMapper;
+    @Autowired
+    private WaterPumpOperatingRecordMapperImpl waterPumpOperatingRecordMapper;
 
     public ExecutedResult<Long> create(ReqCreateDataUploadRecord request) {
         // 转换po
@@ -296,130 +298,182 @@
             ERROR_LOGGER.error(action, "消息不能为空");
             return;
         }
-        //处理心跳
-        Random random=new Random();
-        int i=random.nextInt(100);
-        BigDecimal delayTime=BigDecimal.valueOf(1.0);
-        List<HeartbeatDataPO> list = heartbeatDataMapper.getList();
-        if(Objects.nonNull(list)){
-            HeartbeatDataPO heartbeatUp = list.stream().filter(item -> item.getDataKey().equals("heartbeat_up")).findFirst().orElse(null);
-            if(Objects.nonNull(heartbeatUp)){
-                heartbeatUp.setDataValue(i);
-                heartbeatDataMapper.updateById(heartbeatUp);
+        String[] split1 = topic.split("/");
+        if(split1[1].equals("data")){
+            //处理心跳
+            Random random=new Random();
+            int i=random.nextInt(100);
+            BigDecimal delayTime=BigDecimal.valueOf(1.0);
+            List<HeartbeatDataPO> list = heartbeatDataMapper.getList();
+            if(Objects.nonNull(list)){
+                HeartbeatDataPO heartbeatUp = list.stream().filter(item -> item.getDataKey().equals("heartbeat_up")).findFirst().orElse(null);
+                if(Objects.nonNull(heartbeatUp)){
+                    heartbeatUp.setDataValue(i);
+                    heartbeatDataMapper.updateById(heartbeatUp);
+                }
+                HeartbeatDataPO alarmTime = list.stream().filter(item -> item.getDataKey().equals("alarm_time")).findFirst().orElse(null);
+                if(Objects.nonNull(alarmTime)){
+                    delayTime=new BigDecimal(alarmTime.getDataValue()).setScale(1, RoundingMode.DOWN);
+                }
             }
-            HeartbeatDataPO alarmTime = list.stream().filter(item -> item.getDataKey().equals("alarm_time")).findFirst().orElse(null);
-           if(Objects.nonNull(alarmTime)){
-               delayTime=new BigDecimal(alarmTime.getDataValue()).setScale(1, RoundingMode.DOWN);
-           }
-        }
-        //获取延时报警时间
-        Gson gson = new Gson();
-        JsonObject object = gson.fromJson(msg, JsonObject.class);
-        String asJsonObject = object.get("time").getAsString();
-        Type listType = new TypeToken<List<CountVO>>() {
-        }.getType();
-        //获取data数据
-        JsonArray data = object.getAsJsonArray("Data");
-        List<CountVO> listVo = gson.fromJson(data, listType);
-        for(CountVO vo:listVo){
-            String[] split = vo.getName().split("-");
-            vo.setName(split[0]);
-            vo.setCode(split[1]);
-        }
+            //获取延时报警时间
+            Gson gson = new Gson();
+            JsonObject object = gson.fromJson(msg, JsonObject.class);
+            String asJsonObject = object.get("time").getAsString();
+            Type listType = new TypeToken<List<CountVO>>() {
+            }.getType();
+            //获取data数据
+            JsonArray data = object.getAsJsonArray("Data");
+            List<CountVO> listVo = gson.fromJson(data, listType);
+            for(CountVO vo:listVo){
+                String[] split = vo.getName().split("-");
+                vo.setName(split[0]);
+                vo.setCode(split[1]);
+            }
 
-        List<WaterFacilityPO> facilityPOList = waterFacilityMapper.getList();
-        List<WaterFacilityParameterPO> parameterPOList = waterFacilityParameterMapper.getList();
-        //获取存入redis每天开始的启泵次数
-        List<FacilityParameterDataVO> dataVOList=new ArrayList<>();
-        String objects = redisTemplate.opsForValue().get("pump_start_number");
-        if(StringUtil.isNotNullOrEmpty(objects)){
-                dataVOList= SerializeUtil.toListObject(objects, FacilityParameterDataVO.class);
-        }
+            List<WaterFacilityPO> facilityPOList = waterFacilityMapper.getList();
+            List<WaterFacilityParameterPO> parameterPOList = waterFacilityParameterMapper.getList();
+            List<WaterPumpOperatingRecordPO> recordPOList = waterPumpOperatingRecordMapper.getList();
+            //获取存入redis每天开始的启泵次数
+            List<WaterPumpOperatingRecordPO>dataVOList=new ArrayList<>();
+            String objects = redisTemplate.opsForValue().get("pump_start_number");
+            if(StringUtil.isNotNullOrEmpty(objects)){
+                dataVOList= SerializeUtil.toListObject(objects, WaterPumpOperatingRecordPO.class);
+            }
 
-       // List<AlarmHistoryPO> historyPOList = alarmHistoryMapper.getList();
-        //根据设备编号分组
-        Map<String, List<CountVO>> collect = listVo.stream().collect(Collectors.groupingBy(CountVO::getName));
-        for (Map.Entry<String, List<CountVO>> entry : collect.entrySet()) {
-            //获取设备信息
-            WaterFacilityPO facilityPO = facilityPOList.stream().filter(x -> x.getFacilityCode().equals(entry.getKey())).findFirst().orElse(null);
-            //历史记录上报
-            DataUploadRecordPO recordPO=new DataUploadRecordPO();
-            recordPO.setFacilityId(facilityPO.getId());
-            recordPO.setFacilityName(facilityPO.getFacilityName());
-            String json = gson.toJson(entry.getValue());
-            recordPO.setColumnsValue(json);
-            recordPO.setCreateTime(LocalDateTimeUtil.nowTimeStamp());
-            recordPO.setUploadDate(LocalDateTimeUtil.toDateString(LocalDateTimeUtil.nowTimeStamp()));
-            recordPO.setUploadTime(LocalDateTimeUtil.nowTimeStamp());
-            dataUploadRecordMapper.insert(recordPO);
-            //获取设备所属监控点
-            List<WaterFacilityParameterPO>parameterList=new ArrayList<>();
-            //循环上报数据
-            for(CountVO vo:entry.getValue()){
-                //保存数据
-                WaterFacilityParameterPO parameterPO1 = parameterPOList.stream().filter(item -> item.getFacilityId().equals(facilityPO.getId()) && item.getColumnsCode().equals(vo.getCode())).findFirst().orElse(null);
-                if(Objects.nonNull(parameterPO1)){
-                    parameterPO1.setColumnValue(vo.getValue());
-                    parameterPO1.setLastTime(asJsonObject);
+            // List<AlarmHistoryPO> historyPOList = alarmHistoryMapper.getList();
+            //根据设备编号分组
+            Map<String, List<CountVO>> collect = listVo.stream().collect(Collectors.groupingBy(CountVO::getName));
+            for (Map.Entry<String, List<CountVO>> entry : collect.entrySet()) {
+                //获取设备信息
+                WaterFacilityPO facilityPO = facilityPOList.stream().filter(x -> x.getFacilityCode().equals(entry.getKey())).findFirst().orElse(null);
+                //历史记录上报
+                DataUploadRecordPO recordPO=new DataUploadRecordPO();
+                recordPO.setFacilityId(facilityPO.getId());
+                recordPO.setFacilityName(facilityPO.getFacilityName());
+                String json = gson.toJson(entry.getValue());
+                recordPO.setColumnsValue(json);
+                recordPO.setCreateTime(LocalDateTimeUtil.nowTimeStamp());
+                recordPO.setUploadDate(LocalDateTimeUtil.toDateString(LocalDateTimeUtil.nowTimeStamp()));
+                recordPO.setUploadTime(LocalDateTimeUtil.nowTimeStamp());
+                dataUploadRecordMapper.insert(recordPO);
+                //获取设备所属监控点
+                List<WaterFacilityParameterPO>parameterList=new ArrayList<>();
+                //循环上报数据
+                for(CountVO vo:entry.getValue()){
+                    //保存数据
+//                    if(vo.getCode().equals("B001Time")||vo.getCode().equals("B002Time")){
+//                        if(vo.)
+//                    }
+                    WaterFacilityParameterPO parameterPO1 = parameterPOList.stream().filter(item -> item.getFacilityId().equals(facilityPO.getId()) && item.getColumnsCode().equals(vo.getCode())).findFirst().orElse(null);
+                    if(Objects.nonNull(parameterPO1)){
+                        parameterPO1.setColumnValue(vo.getValue());
+                        parameterPO1.setLastTime(asJsonObject);
+
+                    }
+
+                    switch (vo.getCode()){
+                        case "QF1":
+                            //1号空开吸合关闭报警
+                            QFCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
+                            break;
+                        case "QF2":
+                            //2号空开吸合关闭报警
+                            QFCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
+                            break;
+                        case "QF3":
+                            //3号空开吸合关闭报警
+                            QFCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
+                            break;
+                        case "QF4":
+                            //4号空开吸合关闭报警
+                            QFCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
+                            break;
+                        case "B001Fault":
+                            //1号泵综合故障
+                            faultCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
+                            break;
+                        case "B002Fault":
+                            //2号泵综合故障
+                            faultCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
+                            break;
+                        case "SQ":
+                            //水侵报警
+                            SQFaultCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
+                            break;
+                        case "H1001Fault":
+                            //高水位报警
+                            faultCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
+                            break;
+                        case "L1001Fault":
+                            //低水位报警
+                            faultCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
+                            break;
+                        case "B001StartNumber":
+                            //1号泵启泵次数
+                            startNumber(facilityPO,parameterPO1, recordPOList,dataVOList);
+                            break;
+                        case "B002StartNumber":
+                            //2号泵启泵次数
+                            startNumber(facilityPO,parameterPO1, recordPOList,dataVOList);
+                            break;
+                        case "B001Start":
+                            waterPumpStartNumber(recordPOList,facilityPO,"B001Start", vo.getValue());
+                            break;
+                        case "B002Start":
+                            waterPumpStartNumber(recordPOList,facilityPO,"B002Start", vo.getValue());
+                            break;
+//                        case "B001Time":
+//
+//                            break;
+//                        case "B002Time":
+//                            break;
+//                        case "B001TimeSum":
+//                            break;
+//                        case "B002TimeSum":
+//                            break;
+                    }
                     parameterList.add(parameterPO1);
                 }
-                //判断报警
-              //  AlarmHistoryPO alarmHistoryPO=null;
-//                if(ListUtil.isNotNullOrEmpty(historyPOList)){
-//                 alarmHistoryPO = historyPOList.stream().filter(item -> item.getFacilityId().equals(parameterPO1.getFacilityId()) && item.getCode().equals(parameterPO1.getColumnsCode()) && item.getIsSolve() == 0).findFirst().orElse(null);
-//                }
-                switch (vo.getCode()){
-                    case "QF1":
-                        //1号空开吸合关闭报警
-                        QFCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
-                        break;
-                    case "QF2":
-                        //2号空开吸合关闭报警
-                        QFCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
-                        break;
-                    case "QF3":
-                        //3号空开吸合关闭报警
-                        QFCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
-                        break;
-                    case "QF4":
-                        //4号空开吸合关闭报警
-                        QFCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
-                        break;
-                    case "B001Fault":
-                        //1号泵综合故障
-                        faultCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
-                        break;
-                    case "B002Fault":
-                        //2号泵综合故障
-                        faultCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
-                        break;
-                    case "SQ":
-                        //水侵报警
-                        SQFaultCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
-                        break;
-                    case "H1001Fault":
-                        //高水位报警
-                        faultCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
-                        break;
-                    case "L1001Fault":
-                        //低水位报警
-                        faultCreateAlarm(facilityPO,parameterPO1, vo.getValue(),gson,delayTime);
-                        break;
-                    case "B001StartNumber":
-                        //1号泵启泵次数
-                        startNumber(facilityPO,parameterPO1, vo.getValue(),dataVOList);
-                        break;
-                    case "B002StartNumber":
-                        //2号泵启泵次数
-                        startNumber(facilityPO,parameterPO1, vo.getValue(),dataVOList);
-                        break;
-                }
+                waterFacilityParameterMapper.updateById(parameterList);
+
             }
-            waterFacilityParameterMapper.updateById(parameterList);
-
         }
-    }
 
+    }
+      public void waterPumpStartNumber(List<WaterPumpOperatingRecordPO> recordPOList,WaterFacilityPO facility,String key,String value){
+          WaterPumpOperatingRecordPO recordPO = recordPOList.stream().filter(item -> item.getFacilityId().equals(facility.getId()) && item.getCode().equals(key)).findFirst().orElse(null);
+          if("true".equals(value)){
+               if(Objects.nonNull(recordPO)){
+                   if(recordPO.getStart().equals("false")){
+                       recordPO.setStartNumber(recordPO.getStartNumber()+1);
+                   }
+                   recordPO.setLastTime(LocalDateTimeUtil.nowDateTimeStr());
+                   recordPO.setStart("true");
+                   recordPO.setStartTime(recordPO.getStartTime()+3);
+                   recordPO.setSumStartTime(recordPO.getSumStartTime()+3);
+                   waterPumpOperatingRecordMapper.updateById(recordPO);
+               }else {
+                   recordPO=new WaterPumpOperatingRecordPO();
+                   recordPO.setPointId(facility.getPointId());
+                   recordPO.setFacilityId(facility.getId());
+                   recordPO.setCode(key);
+                   recordPO.setStartNumber(1);
+                   recordPO.setStartTime(3);
+                   recordPO.setSumStartTime(3);
+                   recordPO.setStart("true");
+                   recordPO.setCreateTime(LocalDateTimeUtil.nowTimeStamp());
+                   recordPO.setLastTime(LocalDateTimeUtil.nowDateTimeStr());
+                   waterPumpOperatingRecordMapper.insert(recordPO);
+               }
+           }else {
+              if(Objects.nonNull(recordPO)){
+                  recordPO.setStartTime(0);
+                  recordPO.setStart("false");
+                  waterPumpOperatingRecordMapper.updateById(recordPO);
+              }
+          }
+      }
      public void QFCreateAlarm(WaterFacilityPO facilityPO,WaterFacilityParameterPO parameterPO,String value, Gson gson,BigDecimal delayTime) throws MqttException {
         if(value.equals("false")){
                 alarmHistoryMapper.deleteList(parameterPO.getFacilityId(),parameterPO.getColumnsCode());
@@ -479,13 +533,17 @@
         }
     }
 
-    public void startNumber(WaterFacilityPO facilityPO,WaterFacilityParameterPO parameterPO,String value,List<FacilityParameterDataVO> dataVOList){
+    public void startNumber(WaterFacilityPO facilityPO,WaterFacilityParameterPO parameterPO,List<WaterPumpOperatingRecordPO> value,List<WaterPumpOperatingRecordPO> dataVOList){
         if(ListUtil.isNotNullOrEmpty(dataVOList)){
-            FacilityParameterDataVO facilityParameterDataVO = dataVOList.stream().filter(item -> item.getFacilityCode().equals(facilityPO.getFacilityCode()) && item.getColumnsCode().equals(parameterPO.getColumnsCode())).findFirst().orElse(null);
-            if(Objects.nonNull(facilityParameterDataVO)){
-                Integer columnsValue = Integer.valueOf(facilityParameterDataVO.getColumnValue());
-                Integer value1 = Integer.valueOf(value);
+            //获取缓存启泵次数
+            WaterPumpOperatingRecordPO WaterPumpOperatingRecordPO = dataVOList.stream().filter(item -> item.getFacilityId().equals(facilityPO.getId()) && item.getCode().equals(parameterPO.getColumnsCode())).findFirst().orElse(null);
+            //获取实时启泵次数
+           WaterPumpOperatingRecordPO recordPO = value.stream().filter(item -> item.getFacilityId().equals(facilityPO.getId()) && item.getCode().equals(parameterPO.getColumnsCode())).findFirst().orElse(null);
+            if(Objects.nonNull(WaterPumpOperatingRecordPO)&&Objects.nonNull(recordPO)){
+                Integer columnsValue = Integer.valueOf(WaterPumpOperatingRecordPO.getStartNumber());
+                Integer value1 = Integer.valueOf(recordPO.getStartNumber());
                 Integer dataNumber=value1-columnsValue;
+                alarmHistoryMapper.deleteList(parameterPO.getFacilityId(),parameterPO.getColumnsCode());
                 if(dataNumber>5){
                     alarmHistoryMapper.deleteList(parameterPO.getFacilityId(),parameterPO.getColumnsCode());
                     AlarmHistoryPO alarmHistoryPO=new AlarmHistoryPO();

--
Gitblit v1.9.3