修改mqtt数据

elkers

2 天以前 9b2654eaf1feb56543cf805b5f44a36b2907cff1

 src/main/java/com/nanjing/water/service/DataUploadRecordService.java

@@ -296,6 +296,8 @@
            ERROR_LOGGER.error(action, "消息不能为空");
            return;
        }
        String[] split1 = topic.split("/");
        if(split1[1].equals("data")){
        //处理心跳
        Random random=new Random();
        int i=random.nextInt(100);
@@ -420,6 +422,8 @@
        }
    }

    }

     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());