|
|
@ -361,10 +361,14 @@ public class StatsResiWarnServiceImpl implements StatsResiWarnService { |
|
|
|
} |
|
|
|
//2、符合条件的楼栋
|
|
|
|
Map<String, String> configMap = warnResult.getData().stream().collect(Collectors.toMap(IcResiCategoryWarnConfigDTO::getId, IcResiCategoryWarnConfigDTO::getLabel)); |
|
|
|
List<String> configIds = warnResult.getData().stream().map(m -> m.getId()).collect(Collectors.toList()); |
|
|
|
List<String> configIds = warnResult.getData().stream().map(IcResiCategoryWarnConfigDTO::getId).collect(Collectors.toList()); |
|
|
|
List<IcUserWarnNoticeResultDTO> list = icStatsResiWarnDao.queryUserWarnNotice(formDTO.getCustomerId(), formDTO.getAgencyId(), configIds); |
|
|
|
List<IcUserWarnNoticeResultDTO> resList = new ArrayList<>(); |
|
|
|
Map<String, Integer> level1ThresholdMap = warnResult.getData().stream().collect(Collectors.toMap(IcResiCategoryWarnConfigDTO::getId, IcResiCategoryWarnConfigDTO::getLevel1)); |
|
|
|
for (IcUserWarnNoticeResultDTO dto : list) { |
|
|
|
if (dto.getCount()<level1ThresholdMap.get(dto.getConfigId())){ |
|
|
|
continue; |
|
|
|
} |
|
|
|
//南宁路社区第二网格亿联小区2号楼失业人员超出预警!
|
|
|
|
BuildingInfoCache infoCache = CustomerIcHouseRedis.getBuildingInfo(dto.getBuildingId()); |
|
|
|
if (null == infoCache) { |
|
|
|