| | |
| | | for(EventBaseInfoRequest request : events){ |
| | | Warning warning = warningMapper.selectOne(new QueryWrapper<Warning>().lambda() |
| | | .eq(Warning::getIsdeleted,Constants.ZERO) |
| | | .eq(Warning::getCode, request.getSrcType()).last("limit 1")); |
| | | .eq(Warning::getCode, request.getEventType()).last("limit 1")); |
| | | |
| | | Constants.WarningConfig warningConfig = Constants.WarningConfig.getConfig(request.getEventType()); |
| | | |
| | |
| | | warningEvent.setSrcIndex(request.getSrcIndex()); |
| | | warningEvent.setSrcType(request.getSrcType()); |
| | | warningEvent.setSrcName(request.getSrcName()); |
| | | warningEvent.setWarningId(warning.getId()); |
| | | warningEvent.setDeviceId(request.getSrcIndex()); |
| | | warningEventMapper.insert(warningEvent); |
| | | |
| | | if(Objects.nonNull(warningConfig)){ |
| | | List<Integer> ruleIdList = impl.processWarnFront(warningConfig); |
| | | |
| | | Boolean falg = false; |
| | | Boolean falg = true; |
| | | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ruleIdList)){ |
| | | for (Integer ruleId:ruleIdList) { |
| | | WarningRule warningRule = warningRuleMapper.selectById(ruleId); |
| | |
| | | // dingTalk.getAlarmNoticeMsg(warningPush.getRegion(),DateUtil.getCurrDateTime(),warningConfig.getInfo())); |
| | | // warningPush.setStatus(noticeFlag?Constants.ONE:Constants.TWO); |
| | | } |
| | | warningPushMapper.insert(warningPush); |
| | | impl.sendDeviceNotice(warningRule); |
| | | warningPushMapper.insert(warningPush); |
| | | |
| | | falg = true; |
| | | }catch (Exception e){ |
| | | falg = false; |
| | | warningEvent.setStatus(Constants.TWO); |
| | | warningEventMapper.updateById(warningEvent); |
| | | } |
| | | } |
| | | } |
| | | if(falg){ |
| | | if(!falg){ |
| | | warningEvent.setStatus(Constants.ONE); |
| | | warningEventMapper.updateById(warningEvent); |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | } |
| | | |
| | | } |