| New file |
| | |
|---|
| | | 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.TMonitor; |
|---|
| | | import com.ycl.platform.domain.result.HK.CrossDetailResult; |
|---|
| | | import com.ycl.platform.domain.result.HK.SnapshotDataMonitorResult; |
|---|
| | | import com.ycl.platform.mapper.CheckIndexCarMapper; |
|---|
| | | import com.ycl.platform.mapper.TMonitorMapper; |
|---|
| | | import com.ycl.platform.service.ICheckIndexCarService; |
|---|
| | | import com.ycl.platform.service.ITMonitorService; |
|---|
| | | import com.ycl.system.mapper.SysConfigMapper; |
|---|
| | | import constant.ApiConstants; |
|---|
| | | import constant.CheckConstants; |
|---|
| | | import constant.CheckSnapCountConstants; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | import org.springframework.util.CollectionUtils; |
|---|
| | | import utils.DateUtils; |
|---|
| | | |
|---|
| | | import java.math.BigDecimal; |
|---|
| | | import java.math.RoundingMode; |
|---|
| | | import java.time.LocalDate; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.function.Function; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 计算车辆卡口信息采集准确率 设备编码、行政区划代码、安装位置、坐标经纬度信息完整准确 |
|---|
| | | * 获取分省厅、区域的map<k,v> k为deptId或者Province_deptId |
|---|
| | | * 更新或新增 |
|---|
| | | */ |
|---|
| | | @Component |
|---|
| | | public class CarInFoAccuracyCalculation extends IndexCalculationServe implements CalculationStrategy<CrossDetailResult> { |
|---|
| | | @Autowired |
|---|
| | | private CheckIndexCarMapper checkIndexCarMapper; |
|---|
| | | @Autowired |
|---|
| | | private SysConfigMapper sysConfigMapper; |
|---|
| | | @Autowired |
|---|
| | | private ITMonitorService monitorService; |
|---|
| | | @Autowired |
|---|
| | | private TMonitorMapper monitorMapper; |
|---|
| | | @Autowired |
|---|
| | | private ICheckIndexCarService checkIndexCarService; |
|---|
| | | |
|---|
| | | //区域车辆信息采集准确率的内部类 |
|---|
| | | private static class AreaStats { |
|---|
| | | int totalSites = 0; |
|---|
| | | int qualifySite = 0; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void calculate(List<CrossDetailResult> list) { |
|---|
| | | if (CollectionUtils.isEmpty(list)) { |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | //返回以国标码为key的设备map |
|---|
| | | //TODO：monitor去掉了deptId |
|---|
| | | Map<String, TMonitor> monitorMap = monitorService.list(new QueryWrapper<TMonitor>() |
|---|
| | | .in("serial_number", list.stream().map(CrossDetailResult::getExternalIndexCode).collect(Collectors.toList()))) |
|---|
| | | .stream().collect(Collectors.toMap(TMonitor::getSerialNumber, Function.identity())); |
|---|
| | | //获取省厅国标码集合 |
|---|
| | | List<String> provinceIds = getProvince(); |
|---|
| | | Map<String, AreaStats> areaStatsMap = new HashMap<>(); |
|---|
| | | |
|---|
| | | for (CrossDetailResult result : list) { |
|---|
| | | TMonitor monitor = monitorMap.get(result.getExternalIndexCode()); |
|---|
| | | if (monitor == null) continue; |
|---|
| | | |
|---|
| | | String deptId = monitor.getDeptId().toString(); |
|---|
| | | |
|---|
| | | updateAreaStats(areaStatsMap, deptId, result); |
|---|
| | | |
|---|
| | | // 处理省厅数据 |
|---|
| | | if (!CollectionUtils.isEmpty(provinceIds) && provinceIds.contains(monitor.getSerialNumber())) { |
|---|
| | | String provinceKey = "Province_" + deptId; |
|---|
| | | updateAreaStats(areaStatsMap, provinceKey, result); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 查询是否index表已经存在今日数据 |
|---|
| | | List<CheckIndexCar> checkIndexCarList = checkIndexCarMapper.selectToday(DateUtils.getDate()); |
|---|
| | | List<CheckIndexCar> checkIndexCars = new ArrayList<>(); |
|---|
| | | areaStatsMap.forEach((deptId, stats) -> { |
|---|
| | | if (stats.totalSites > 0) { |
|---|
| | | CheckIndexCar checkIndexCar = createOrUpdateCheckIndexCar(deptId, stats, checkIndexCarList); |
|---|
| | | checkIndexCars.add(checkIndexCar); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | |
|---|
| | | checkIndexCarService.saveOrUpdateBatch(checkIndexCars); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 累计总点位数、标注异常点位数 |
|---|
| | | */ |
|---|
| | | private void updateAreaStats(Map<String, AreaStats> areaStatsMap, String key, CrossDetailResult result) { |
|---|
| | | //返回对象的引用，如果不存在会放入新的key,value |
|---|
| | | AreaStats stats = areaStatsMap.computeIfAbsent(key, k -> new AreaStats()); |
|---|
| | | stats.totalSites++; |
|---|
| | | if (ApiConstants.HK_Info_LayType_Normal.equals(result.getLalType()) && ApiConstants.HK_Info_GbCodeType_Normal.equals(result.getGbCodeType())) { |
|---|
| | | stats.qualifySite++; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 车辆信息采集正确率 |
|---|
| | | */ |
|---|
| | | private CheckIndexCar createOrUpdateCheckIndexCar(String key, AreaStats stats, List<CheckIndexCar> checkIndexCarList) { |
|---|
| | | CheckIndexCar checkIndexCar; |
|---|
| | | |
|---|
| | | // 检查是否已存在今日数据 |
|---|
| | | Optional<CheckIndexCar> existingCar = checkIndexCarList.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 (existingCar.isPresent()) { |
|---|
| | | checkIndexCar = existingCar.get(); |
|---|
| | | } else { |
|---|
| | | checkIndexCar = new CheckIndexCar(); |
|---|
| | | checkIndexCar.setDeptId(key.startsWith("Province_") ? Long.parseLong(key.split("_")[1]) : Long.parseLong(key)); |
|---|
| | | checkIndexCar.setExamineTag(key.startsWith("Province_") ? CheckConstants.Examine_Tag_City : CheckConstants.Examine_Tag_County); |
|---|
| | | checkIndexCar.setCreateTime(new Date()); |
|---|
| | | } |
|---|
| | | //调用计算方法 |
|---|
| | | Map<String, Object> siteOnlineParam = new HashMap<>(); |
|---|
| | | siteOnlineParam.put("totalSites", stats.totalSites); |
|---|
| | | siteOnlineParam.put("qualifySite", stats.qualifySite); |
|---|
| | | BigDecimal infoAccuracy = infoAccuracy(siteOnlineParam); |
|---|
| | | checkIndexCar.setVehicleInformationCollectionAccuracy(infoAccuracy); |
|---|
| | | return checkIndexCar; |
|---|
| | | } |
|---|
| | | } |
|---|
