| | |
| | | private DeviceMapper deviceMapper; |
| | | |
| | | @Autowired |
| | | private InterfaceLogMapper interfaceLogMapper; |
| | | |
| | | @Autowired |
| | | private MemberMapper memberMapper; |
| | | |
| | | @Autowired |
| | |
| | | warningEvent.setStatus(Constants.TWO); |
| | | warningEventMapper.updateById(warningEvent); |
| | | } |
| | | |
| | | } |
| | | |
| | | } |
| | | } |
| | | } |
| | |
| | | if(CollectionUtils.isNotEmpty(deviceList)){ |
| | | for (Device device:deviceList) { |
| | | device.setSendInfo(warningRule.getDeviceNoticeContent()); |
| | | DeviceServiceImpl.sendBroadcaseBobaoHttpBiz(device); |
| | | DeviceServiceImpl.sendBroadcaseBobaoHttpBiz(device,interfaceLogMapper); |
| | | } |
| | | } |
| | | } |
| | |
| | | return false; |
| | | } |
| | | for (WarningRuleDetail warningRuleDetail:warningRuleDetails) { |
| | | if(Objects.nonNull(warningRuleDetail.getRegionId())){ |
| | | if(Objects.nonNull(warningRuleDetail.getDeviceId())){ |
| | | if(warningEventList.stream().filter(i->Constants.equalsInteger(i.getWarningId(),warningRuleDetail.getWarningId()) |
| | | && StringUtils.isNotBlank(i.getRegionId()) && i.getRegionId().equals(warningRuleDetail.getRegionId()) |
| | | && StringUtils.isNotBlank(i.getDeviceId()) && i.getDeviceId().equals(warningRuleDetail.getDeviceId()) |
| | | ).collect(Collectors.toList()).size()<=Constants.ZERO){ |
| | | return false; |
| | | } |