package com.ycl.calculate; import com.ycl.platform.domain.entity.CheckIndexCar; import com.ycl.platform.domain.result.HK.VehicleDeviceSamplingResult; import com.ycl.platform.mapper.CheckIndexCarMapper; import com.ycl.platform.service.ICheckIndexCarService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import utils.DateUtils; import java.math.BigDecimal; import java.math.RoundingMode; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; /** * 计算车辆抓拍数据准确性、url可用性、大图可用性 * 车辆数据抽检接口 * 获取分省厅、区域的map k为deptId或者Province_deptId * 更新或新增 */ @Component @Slf4j public class CarDeviceSampleCalculation extends IndexCalculationServe implements CalculationStrategy { @Autowired private CheckIndexCarMapper checkIndexCarMapper; @Autowired private ICheckIndexCarService checkIndexCarService; //区域车辆抽检指标 protected static class AreaStats { int totalSites = 0; int importantTotalSites = 0; //属性识别准确的点位数 int accuracySites = 0; //属性识别准确的重点点位数 int importantAccuracySites = 0; //图片可用的点位数 int picUsabilitySites = 0; //图片总点位数 int picSites = 0; } @Override public void calculate(List list) { //获取分区域的指标数量 Map areaStatsMap = getAreaStatsMap(list,Boolean.FALSE); if (areaStatsMap == null) return; // 查询是否index表已经存在今日数据 List checkIndexCarList = checkIndexCarMapper.selectToday(DateUtils.getDate()); List checkIndexCars = new ArrayList<>(); areaStatsMap.forEach((deptId, stats) -> { if (stats.totalSites > 0) { CheckIndexCar checkIndexCar = createOrUpdateCheckIndexCar(deptId, stats, checkIndexCarList); if (checkIndexCar != null) { checkIndexCars.add(checkIndexCar); } } }); checkIndexCarService.saveOrUpdateBatch(checkIndexCars); } /** * 累计抓拍数据准确设备数和设备总数,区分重点点位 */ @Override public void updateAreaStats(Map areaStatsMap, String key, VehicleDeviceSamplingResult result) { //返回对象的引用,如果不存在会放入新的key,value AreaStats stats = areaStatsMap.computeIfAbsent(key, k -> new AreaStats()); VehicleDeviceSamplingResult.VehicleDifference vehDiff = result.getVehDiff(); VehicleDeviceSamplingResult.BigUsefulness bigUseful = result.getBigUseful(); stats.totalSites++; //90%及以上数据合格则此车辆卡口设备被视为抓拍数据准确 if (vehDiff.getMajorConPercent() >= 0.9) { stats.accuracySites++; } //重点点位为六项属性 if (result.getImportantTag() != null && result.getImportantTag()) { stats.importantTotalSites++; if (vehDiff.getImportantConPercent() >= 0.9) { stats.importantAccuracySites++; } } //只计算抽检的 if(bigUseful.getSampleCount() !=0){ stats.picSites++; //大图可用率大于90%视为合格, if (bigUseful.getBigUsefulPercent() >= 0.9) { stats.picUsabilitySites++; } } } /** * 车辆抓拍数据准确性、大图可用性 */ private CheckIndexCar createOrUpdateCheckIndexCar(String key, AreaStats stats, List checkIndexCarList) { CheckIndexCar checkIndexCar = getCheckIndex(key, checkIndexCarList, CheckIndexCar.class); if (checkIndexCar == null) { return null; } //调用车辆抓拍数据准确性计算方法 Map accuracyParam = new HashMap<>(); accuracyParam.put("totalSites", stats.totalSites); accuracyParam.put("importantTotalSites", stats.importantTotalSites); accuracyParam.put("accuracySites", stats.accuracySites); accuracyParam.put("importantAccuracySites", stats.importantAccuracySites); BigDecimal dataAccuracy = dataAccuracy(accuracyParam); checkIndexCar.setVehicleCaptureAccuracy(dataAccuracy); //调用大图可用性计算方法 Map usabilityParam = new HashMap<>(); usabilityParam.put("totalSites", stats.picSites); usabilityParam.put("picUsabilitySites", stats.picUsabilitySites); BigDecimal picUsability = picUsability(usabilityParam); checkIndexCar.setVehiclePictureAvailability(picUsability); return checkIndexCar; } }