|
|
@@ -166,14 +166,17 @@ public class RedisExpiredPhotographListener extends KeyExpirationEventMessageLis
|
|
|
StringBuffer userIds = new StringBuffer();
|
|
|
StringBuffer phones = new StringBuffer();
|
|
|
if (!redisService.hasKey(key)) {
|
|
|
+ log.info("进入最终循环!");
|
|
|
//如果没有这个key了 则统计异常率
|
|
|
//查询配置
|
|
|
WarningConfig warningConfig = warningConfigService.getOne(new LambdaQueryWrapper<WarningConfig>().eq(WarningConfig::getWarningType, 1));
|
|
|
List<WarningDetail> list = warningDetailService.list(new LambdaQueryWrapper<WarningDetail>().eq(WarningDetail::getLogId, warningNoticeLog.getId()));
|
|
|
if (list.size() > 0) {
|
|
|
List<WarningDetail> collect = list.stream().filter(i -> i.getResult() == true).collect(Collectors.toList());
|
|
|
- double div = NumberUtil.div(collect.size(), warningConfig.getAnomalyCount().intValue());
|
|
|
- if (div > warningConfig.getAnomalyRate()) {
|
|
|
+ double rate = NumberUtil.div(collect.size(), warningConfig.getAnomalyCount().intValue());
|
|
|
+ double rate2 = NumberUtil.div(warningConfig.getAnomalyRate(), new Double(100));
|
|
|
+ log.info("rate={},rate2={}",rate,rate2);
|
|
|
+ if (rate > rate2) {
|
|
|
|
|
|
WarningNoticeLogDto warningNoticeLogDto = new WarningNoticeLogDto();
|
|
|
warningNoticeLogDto.setId(warningNoticeLog.getId());
|