| | |
| | | return ForeignResult.success(); |
| | | } |
| | | |
| | | /** |
| | | * 设备预警 |
| | | * */ |
| | | @Override |
| | | public ForeignResult deviceMonitor(DeviceMonitorReqDTO reqDTO) { |
| | | if (reqDTO == null) |
| | |
| | | List<String> deviceExcReceiver = Arrays.asList(DEVICE_EXC_RECEIVER); |
| | | if (!CollectionUtils.isEmpty(deviceExcReceiver)) { |
| | | List<String> distinctPhone = deviceExcReceiver.stream().distinct().collect(Collectors.toList()); |
| | | logger.info("【气体浓度异常短信发送】-----发送内容:" + "数据异常,无法进行监测 气体浓度连续超标,系统判断为设备离线,请相关负责人及时检查处置。" |
| | | logger.info("【气体浓度异常短信发送】-----发送内容:" + "克拉玛依富城数据异常,无法进行监测 气体浓度连续超标,系统判断为设备离线,请相关负责人及时检查处置。" |
| | | + " 发送时间: " + LocalDateTime.now()+ " 接收人手机号:" + distinctPhone); |
| | | if (!org.springframework.util.StringUtils.isEmpty(smsSendEnabledStatus) && "true".equals(smsSendEnabledStatus)) { |
| | | sendMessageUtil.sendMessageCheck(deviceExcReceiver.toArray(new String[deviceExcReceiver.size()]), mesMap); |
| | |
| | | } |
| | | return ForeignResult.success(); |
| | | } |
| | | |
| | | |
| | | private void gasFluxDataCacheAndPush(){ |
| | | LocalDateTime time = LocalDateTime.now(); |
| | |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 气体数据--预警信息推送 |
| | | * */ |
| | | private void warnLogGenerateAndExecPush(Integer warnThresholdEnumCode,GasCategory gasCategory,Double value){ |
| | | if (gasCategory == null) |
| | | throw new DataReceiveException(this.getClass(), ForeignResultCode.SYSTEM_ERROR_DATABASE_FAIL.getCode(),"该气体不存在于对照表"); |