| | |
|---|
| | | .filter(calculateRuleVO -> ContractRule.CONTRACT_RULE_Online.getName().equals(calculateRuleVO.getRuleName())) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | List<Integer> unitIds = ruleVos.stream().map(CalculateRuleVO::getUnitId).collect(Collectors.toList()); |
|---|
| | | List<YwPoint> ywPoints = ywPointMapper.selectList(new QueryWrapper<YwPoint>().in("unit_id", unitIds)); |
|---|
| | | List<YwPoint> ywPoints = ywPointMapper.selectList(new QueryWrapper<YwPoint>().in("unit_id", unitIds).eq("examine_status",1)); |
|---|
| | | //key是unitId value是设备编码集合 |
|---|
| | | Map<Long, List<YwPoint>> unitMap = ywPoints.stream().filter(point -> point.getUnitId() != null) |
|---|
| | | .collect(Collectors.groupingBy( |
|---|
| | |
|---|
| | | if (!CollectionUtils.isEmpty(reportNumbers) && reportNumbers.contains(point.getSerialNumber())) |
|---|
| | | continue; |
|---|
| | | totalSite++; |
|---|
| | | if (ApiConstants.UY_OnlineSite_Online.equals(point.getOnline())) { |
|---|
| | | if (ApiConstants.UY_OnlineSite_Online.equals(point.getOnline()) && ApiConstants.UY_OnlineSite_Online.equals(point.getPingOnline())) { |
|---|
| | | onlineSite++; |
|---|
| | | } |
|---|
| | | } |
|---|
