| | |
| | | log.info("设备状态长期无变化报警任务 RunningEquipmentStatusJob start! 时间:" + DateUtils.getNow()); |
| | | long startTime = System.currentTimeMillis(); |
| | | try { |
| | | //List<MdcEquipment> equipmentList = mdcEquipmentService.list(new LambdaQueryWrapper<>()); |
| | | List<MdcEquipment> equipmentList = mdcEquipmentService.list(new LambdaQueryWrapper<MdcEquipment>().eq(MdcEquipment::getEquipmentId, "2140198")); |
| | | List<MdcEquipment> equipmentList = mdcEquipmentService.list(new LambdaQueryWrapper<>()); |
| | | //List<MdcEquipment> equipmentList = mdcEquipmentService.list(new LambdaQueryWrapper<MdcEquipment>().eq(MdcEquipment::getEquipmentId, "2140198")); |
| | | // 获取利用率判定天数 |
| | | List<DictModel> dictModelList1 = sysDictService.queryEnableDictItemsByCode(CommonConstant.DICT_EQUIPMENT_RATE_JUDGE); |
| | | Integer equipmentRateJudge = 5; |
| | |
| | | equipmentRateJudge = Integer.valueOf(dictModelList1.get(0).getValue()); |
| | | } |
| | | // 获取利用率正常值 |
| | | List<DictModel> dictModelList2 = sysDictService.queryEnableDictItemsByCode(CommonConstant.DICT_EQUIPMENT_SPEED_JUDGE); |
| | | List<DictModel> dictModelList2 = sysDictService.queryEnableDictItemsByCode(CommonConstant.DICT_EQUIPMENT_RATE_NORMAL); |
| | | Integer equipmentRateNormal = 20; |
| | | if (dictModelList2 != null && !dictModelList2.isEmpty()) { |
| | | equipmentRateNormal = Integer.valueOf(dictModelList2.get(0).getValue()); |
| | | } |
| | | // 获取设备状态天数 |
| | | List<DictModel> dictModelList3 = sysDictService.queryEnableDictItemsByCode(CommonConstant.DICT_EQUIPMENT_RATE_NORMAL); |
| | | List<DictModel> dictModelList3 = sysDictService.queryEnableDictItemsByCode(CommonConstant.DICT_EQUIPMENT_SPEED_JUDGE); |
| | | Integer equipmentStatusJudge = 5; |
| | | if (dictModelList3 != null && !dictModelList3.isEmpty()) { |
| | | equipmentStatusJudge = Integer.valueOf(dictModelList3.get(0).getValue()); |
| | |
| | | if (flag) { |
| | | // 上报 |
| | | MessageDTO messageDTO = new MessageDTO(); |
| | | messageDTO.setTitle("设备利用率报警!"); |
| | | messageDTO.setCategory("预警消息"); |
| | | messageDTO.setFromUser("admin"); |
| | | messageDTO.setToUser("admin"); |
| | |
| | | if (flag) { |
| | | // 上报 |
| | | MessageDTO messageDTO = new MessageDTO(); |
| | | messageDTO.setTitle("设备状态长期无变化报警!"); |
| | | messageDTO.setCategory("预警消息"); |
| | | messageDTO.setFromUser("admin"); |
| | | messageDTO.setToUser("admin"); |