/** # __----~~~~~~~~~~~------___ # . . ~~//====...... __--~ ~~ # -. \_|// |||\\ ~~~~~~::::... /~ # ___-==_ _-~o~ \/ ||| \\ _/~~- # __---~~~.==~||\=_ -_--~/_-~|- |\\ \\ _/~ # _-~~ .=~ | \\-_ '-~7 /- / || \ / # .~ .~ | \\ -_ / /- / || \ / # / ____ / | \\ ~-_/ /|- _/ .|| \ / # |~~ ~~|--~~~~--_ \ ~==-/ | \~--===~~ .\ # ' ~-| /| |-~\~~ __--~~ # |-~~-_/ | | ~\_ _-~ /\ # / \ \__ \/~ \__ # _--~ _/ | .-~~____--~-/ ~~==. # ((->/~ '.|||' -_| ~~-/ , . _|| # -_ ~\ ~~---l__i__i__i--~~_/ # _-~-__ ~) \--______________--~~ # //.-~~~-~_--~- |-------~~~~~~~~ # //.-~~~--\ # 神兽保佑 # 永无BUG! */ package com.nanjing.water.service; import com.baomidou.mybatisplus.core.toolkit.Sequence; import com.google.gson.Gson; import com.google.gson.JsonArray; import com.google.gson.JsonObject; import com.google.gson.reflect.TypeToken; import com.nanjing.water.common.*; import com.nanjing.water.common.enums.*; import com.nanjing.water.common.model.Tuple; import com.nanjing.water.common.util.*; import com.nanjing.water.host.mqtt.CountVO; import com.nanjing.water.repository.impl.*; import com.nanjing.water.repository.po.*; import org.apache.commons.lang3.BooleanUtils; import org.slf4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.lang.reflect.Type; import java.util.*; import java.util.regex.Matcher; import java.util.regex.Pattern; import java.util.stream.Collectors; import com.nanjing.water.entity.request.datauploadrecord.ReqCreateDataUploadRecord; import com.nanjing.water.entity.request.datauploadrecord.ReqModifyDataUploadRecord; import com.nanjing.water.entity.search.SearchDataUploadRecord; import com.nanjing.water.repository.vo.DataUploadRecordVO; import com.nanjing.water.service.convert.DataUploadRecordConvert; /** * 数据上报记录 * @author lin.liu */ @Service public class DataUploadRecordService extends BaseService { private static final Logger ERROR_LOGGER = LoggerUtil.get(ELogger.SYS_ERROR); @Autowired private DataUploadRecordMapperImpl mapper; @Autowired private WaterFacilityMapperImpl waterFacilityMapper; @Autowired private WaterFacilityParameterMapperImpl waterFacilityParameterMapper; @Autowired private WaterMonitoryPointMapperImpl waterMonitoryPointMapper; @Autowired private AlarmHistoryMapperImpl alarmHistoryMapper; public ExecutedResult create(ReqCreateDataUploadRecord request) { // 转换po DataUploadRecordPO item = DataUploadRecordConvert.INSTANCE.toCreate(request); // 设置状态 //item.setStatus(EState.NORMAL.getValue()); // 设置记录创建时间 item.setCreateTime(LocalDateTimeUtil.nowTimeStamp()); // 是否删除(逻辑删除)初始值 item.setIsDelete(EYesOrNo.NO.getValue()); int rowCount = mapper.insert(item); if (rowCount != 1) { return ExecutedResult.failed("创建[数据上报记录]失败。"); } return ExecutedResult.success(item.getId()); } public ExecutedResult modify(ReqModifyDataUploadRecord request) { // 验证记录是否存在 ExecutedResult checkExists = this.check4Id(request.getId()); if (checkExists.isFailed()) { return ExecutedResult.failed(checkExists.getMsg()); } // 转换po DataUploadRecordPO item = DataUploadRecordConvert.INSTANCE.toModify(request); int rowCount = mapper.updateById(item); if (rowCount != 1) { return ExecutedResult.failed("编辑[数据上报记录]失败。"); } return ExecutedResult.success(); } public ExecutedResult get(Long id) { DataUploadRecordVO result = new DataUploadRecordVO(); DataUploadRecordPO find = mapper.get(id); if (null != find) { // 转换vo result = DataUploadRecordConvert.INSTANCE.toVo(find); } return ExecutedResult.success(result); } // public ExecutedResult stop(Long id) { // // 验证记录是否存在 // ExecutedResult checkExists = this.check4Id(id); // if (checkExists.isFailed()) { // return ExecutedResult.failed(checkExists.getMsg()); // } // DataUploadRecordPO item = new DataUploadRecordPO(); // item.setId(id); // item.setStatus(EState.DISABLED.getValue()); // // int rowCount = mapper.updateById(item); // if (rowCount != 1) { // return ExecutedResult.failed("停用[数据上报记录]失败。"); // } // return ExecutedResult.success(); // } // // public ExecutedResult enable(Long id) { // // 验证记录是否存在 // ExecutedResult checkExists = this.check4Id(id); // if (checkExists.isFailed()) { // return ExecutedResult.failed(checkExists.getMsg()); // } // DataUploadRecordPO item = new DataUploadRecordPO(); // item.setId(id); // item.setStatus(EState.NORMAL.getValue()); // // int rowCount = mapper.updateById(item); // if (rowCount != 1) { // return ExecutedResult.failed("启用[数据上报记录]失败。"); // } // return ExecutedResult.success(); // } // // public ExecutedResult setSort(ReqSetSort request) { // // 验证记录是否存在 // ExecutedResult checkExists = this.check4Id(request.getId()); // if (checkExists.isFailed()) { // return ExecutedResult.failed(checkExists.getMsg()); // } // DataUploadRecordPO item = new DataUploadRecordPO(); // item.setId(request.getId()); // item.setSort(request.getSort()); // // int rowCount = mapper.updateById(item); // if (rowCount != 1) { // return ExecutedResult.failed("设置[数据上报记录]排序值失败。"); // } // return ExecutedResult.success(); // } // // public ExecutedResult listSetSort(ReqListSetSort request) { // // id列表 // List listId = request.getList().stream().map(ReqSetSort::getId).collect(Collectors.toList()); // // 验证记录是否存在 // ExecutedResult> checkExists = this.check4Id(listId); // if (checkExists.isFailed()) { // return ExecutedResult.failed(checkExists.getMsg()); // } // // List listUpdate = request.getList().stream() // .map(c -> { // DataUploadRecordPO item = new DataUploadRecordPO(); // item.setId(c.getId()); // item.setSort(c.getSort()); // return item; // }) // .collect(Collectors.toList()); // Boolean result = mapper.modifyList(listUpdate); // if (result) { // return ExecutedResult.success(); // } // return ExecutedResult.failed("[数据上报记录]设置排序值失败"); // } // // public ExecutedResult remove(Long id) { // Boolean result = mapper.deleteLogic(id); // if (BooleanUtils.isFalse(result)) { // return ExecutedResult.failed("删除[数据上报记录]失败。"); // } // return ExecutedResult.success(); // } // // public ExecutedResult removeList(List ids) { // Boolean result = mapper.deleteLogic(ids); // if (BooleanUtils.isFalse(result)) { // return ExecutedResult.failed("删除[数据上报记录]失败。"); // } // return ExecutedResult.success(); // } public ExecutedResult> getList(List listId) { List result = new ArrayList<>(); List list = mapper.getList(listId); if (ListUtil.isNotNullOrEmpty(list)) { // 转换vo result = DataUploadRecordConvert.INSTANCE.toVo(list); } return ExecutedResult.success(result); } public ExecutedResult> search(SearchDataUploadRecord search) { // 处理创建时间范围-查询参数 Tuple createTimeRange = ParameterUtil.getTimeRange(search.getCreateTimeRange()); if (StringUtil.isNotNullOrEmpty(createTimeRange.getItem1())) { search.setCreateTimeStart(LocalDateTimeUtil.getTimeStamp(createTimeRange.getItem1()).getTime()); } if (StringUtil.isNotNullOrEmpty(createTimeRange.getItem2())) { search.setCreateTimeEnd(LocalDateTimeUtil.getTimeStamp(createTimeRange.getItem2()).getTime()); } PagerResult pageList = mapper.search(search); List listVo = new ArrayList<>(); List list = pageList.getList(); if (ListUtil.isNotNullOrEmpty(list)) { pageList.setLastId(list.get(list.size() - 1).getId()); // 转换vo listVo = DataUploadRecordConvert.INSTANCE.toVo(list); } PagerResult result = new PagerResult<>(pageList.getLimit(), pageList.getPage(), pageList.getTotal(), listVo); result.setLastId(pageList.getLastId()); return ExecutedResult.success(result); } protected ExecutedResult check4Id(Long id) { DataUploadRecordPO exists = mapper.get(id); if (Objects.isNull(exists)) { return ExecutedResult.failed("[数据上报记录]不存在:" + id); } return ExecutedResult.success(exists); } protected ExecutedResult> check4Id(List listId) { // 从数据库查找数据上报记录 List list = mapper.getList(listId); if (ListUtil.isNullOrEmpty(list)) { return ExecutedResult.failed("[数据上报记录]不存在." + listId); } // 数据库找到的id列表 List listIdFind = list.stream().map(DataUploadRecordPO::getId).collect(Collectors.toList()); // 数量不一致 if (listId.size() != listIdFind.size()) { // 筛选数据库不存在的数据上报记录 List listIdNotFound = listId.stream().filter(c -> !listIdFind.contains(c)).collect(Collectors.toList()); if (ListUtil.isNullOrEmpty(list)) { return ExecutedResult.failed("[数据上报记录]不存在." + listIdNotFound); } } return ExecutedResult.success(list); } /** * mqtt收到消息 * @param topic 主题 * @param msg 消息内容 */ public void mqttReceived(String topic, String msg) { String action = "mqtt收到消息"; if (StringUtil.isNullOrEmpty(topic)) { ERROR_LOGGER.error(action, "主题不能为空"); return; } if (StringUtil.isNullOrEmpty(msg)) { ERROR_LOGGER.error(action, "消息不能为空"); return; } Gson gson = new Gson(); JsonObject object = gson.fromJson(msg, JsonObject.class); String asJsonObject = object.get("time").getAsString(); Type listType = new TypeToken>() { }.getType(); //获取data数据 JsonArray data = object.getAsJsonArray("Data"); List listVo = gson.fromJson(data, listType); for(CountVO vo:listVo){ String[] split = vo.getName().split("-"); vo.setName(split[0]); vo.setCode(split[1]); } List facilityPOList = waterFacilityMapper.getList(); List parameterPOList = waterFacilityParameterMapper.getList(); // List historyPOList = alarmHistoryMapper.getList(); //根据设备编号分组 Map> collect = listVo.stream().collect(Collectors.groupingBy(CountVO::getName)); for (Map.Entry> entry : collect.entrySet()) { //获取设备信息 WaterFacilityPO facilityPO = facilityPOList.stream().filter(x -> x.getFacilityCode().equals(entry.getKey())).findFirst().orElse(null); //获取设备所属监控点 ListparameterList=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); 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() ); break; case "QF2": //2号空开吸合关闭报警 QFCreateAlarm(facilityPO,parameterPO1, vo.getValue()); break; case "QF3": //3号空开吸合关闭报警 QFCreateAlarm(facilityPO,parameterPO1, vo.getValue()); break; case "QF4": //4号空开吸合关闭报警 QFCreateAlarm(facilityPO,parameterPO1, vo.getValue()); break; case "B001Fault": //1号泵综合故障 faultCreateAlarm(facilityPO,parameterPO1, vo.getValue()); break; case "B002Fault": //2号泵综合故障 faultCreateAlarm(facilityPO,parameterPO1, vo.getValue()); break; case "SQ": //水侵报警 SQFaultCreateAlarm(facilityPO,parameterPO1, vo.getValue()); break; case "H1001Fault": //高水位报警 faultCreateAlarm(facilityPO,parameterPO1, vo.getValue()); break; case "L1001Fault": //低水位报警 faultCreateAlarm(facilityPO,parameterPO1, vo.getValue()); break; } } waterFacilityParameterMapper.updateById(parameterList); } } public void QFCreateAlarm(WaterFacilityPO facilityPO,WaterFacilityParameterPO parameterPO,String value){ if(value.equals("false")){ alarmHistoryMapper.deleteList(parameterPO.getFacilityId(),parameterPO.getColumnsCode()); AlarmHistoryPO alarmHistoryPO=new AlarmHistoryPO(); alarmHistoryPO.setFacilityId(facilityPO.getId()); alarmHistoryPO.setFacilityName(facilityPO.getFacilityName()); alarmHistoryPO.setCode(parameterPO.getColumnsCode()); alarmHistoryPO.setDescription(parameterPO.getColumnsShow()+"关闭"); alarmHistoryPO.setCreateTime(LocalDateTimeUtil.nowTimeStamp()); alarmHistoryPO.setLastTime(LocalDateTimeUtil.nowTimeStamp()); alarmHistoryMapper.insert(alarmHistoryPO); } } public void faultCreateAlarm(WaterFacilityPO facilityPO,WaterFacilityParameterPO parameterPO,String value){ if(value.equals("true")){ alarmHistoryMapper.deleteList(parameterPO.getFacilityId(),parameterPO.getColumnsCode()); AlarmHistoryPO alarmHistoryPO=new AlarmHistoryPO(); alarmHistoryPO.setFacilityId(facilityPO.getId()); alarmHistoryPO.setFacilityName(facilityPO.getFacilityName()); alarmHistoryPO.setCode(parameterPO.getColumnsCode()); alarmHistoryPO.setDescription(parameterPO.getColumnsShow()+"关闭"); alarmHistoryPO.setCreateTime(LocalDateTimeUtil.nowTimeStamp()); alarmHistoryPO.setLastTime(LocalDateTimeUtil.nowTimeStamp()); alarmHistoryMapper.insert(alarmHistoryPO); } } public void SQFaultCreateAlarm(WaterFacilityPO facilityPO,WaterFacilityParameterPO parameterPO,String value){ if(value.equals("1")){ alarmHistoryMapper.deleteList(parameterPO.getFacilityId(),parameterPO.getColumnsCode()); AlarmHistoryPO alarmHistoryPO=new AlarmHistoryPO(); alarmHistoryPO.setFacilityId(facilityPO.getId()); alarmHistoryPO.setFacilityName(facilityPO.getFacilityName()); alarmHistoryPO.setCode(parameterPO.getColumnsCode()); alarmHistoryPO.setDescription(parameterPO.getColumnsShow()+"关闭"); alarmHistoryPO.setCreateTime(LocalDateTimeUtil.nowTimeStamp()); alarmHistoryPO.setLastTime(LocalDateTimeUtil.nowTimeStamp()); alarmHistoryMapper.insert(alarmHistoryPO); } } }