| | |
| | | package com.ycl.calculate; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.ycl.platform.domain.entity.CheckIndexCar; |
| | | import com.ycl.platform.domain.entity.CheckIndexFace; |
| | | import com.ycl.platform.domain.entity.TMonitor; |
| | | import com.ycl.platform.domain.result.HK.MonitoringDetailResult; |
| | |
| | | @Autowired |
| | | private ICheckIndexFaceService checkIndexFaceService; |
| | | @Autowired |
| | | private SysConfigMapper sysConfigMapper; |
| | | @Autowired |
| | | private ITMonitorService monitorService; |
| | | @Autowired |
| | | private TMonitorMapper monitorMapper; |
| | | |
| | | //区域车辆信息采集准确率的内部类 |
| | | private static class AreaStats { |
| | |
| | | areaStatsMap.forEach((deptId, stats) -> { |
| | | if (stats.totalSites > 0) { |
| | | CheckIndexFace checkIndexFace = createOrUpdateCheckIndexFace(deptId, stats, checkIndexFaceList); |
| | | checkIndexFaces.add(checkIndexFace); |
| | | if (checkIndexFace != null) { |
| | | checkIndexFaces.add(checkIndexFace); |
| | | } |
| | | } |
| | | }); |
| | | |
| | |
| | | * 车辆信息采集正确率 |
| | | */ |
| | | private CheckIndexFace createOrUpdateCheckIndexFace(String key, AreaStats stats, List<CheckIndexFace> checkIndexFaceList) { |
| | | CheckIndexFace checkIndexFace; |
| | | |
| | | // 检查是否已存在今日数据 |
| | | Optional<CheckIndexFace> existingFace = checkIndexFaceList.stream() |
| | | .filter(car -> key.equals(car.getDeptId().toString()) && |
| | | (key.startsWith("Province_") ? CheckConstants.Examine_Tag_City.equals(car.getExamineTag()) |
| | | : CheckConstants.Examine_Tag_County.equals(car.getExamineTag()))) |
| | | .findFirst(); |
| | | |
| | | if (existingFace.isPresent()) { |
| | | checkIndexFace = existingFace.get(); |
| | | } else { |
| | | checkIndexFace = new CheckIndexFace(); |
| | | checkIndexFace.setDeptId(key.startsWith("Province_") ? Long.parseLong(key.split("_")[1]) : Long.parseLong(key)); |
| | | checkIndexFace.setExamineTag(key.startsWith("Province_") ? CheckConstants.Examine_Tag_City : CheckConstants.Examine_Tag_County); |
| | | checkIndexFace.setCreateTime(new Date()); |
| | | CheckIndexFace checkIndexFace = getCheckIndex(key, checkIndexFaceList, CheckIndexFace.class); |
| | | if (checkIndexFace == null) { |
| | | return null; |
| | | } |
| | | //调用计算方法 |
| | | Map<String, Object> siteOnlineParam = new HashMap<>(); |
| | | siteOnlineParam.put("totalSites", stats.totalSites); |
| | | siteOnlineParam.put("qualifySite", stats.qualifySite); |
| | | BigDecimal infoAccuracy = infoAccuracy(siteOnlineParam); |
| | | Map<String, Object> param = new HashMap<>(); |
| | | param.put("totalSites", stats.totalSites); |
| | | param.put("qualifySite", stats.qualifySite); |
| | | BigDecimal infoAccuracy = infoAccuracy(param); |
| | | checkIndexFace.setFaceInformationCollectionAccuracy(infoAccuracy); |
| | | return checkIndexFace; |
| | | } |