package com.ycl.calculate; import com.ycl.platform.domain.entity.CheckIndexCar; import com.ycl.platform.domain.result.HK.PicAccessResult; 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.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; /** * 计算车辆抓拍数据准确性、url可用性、大图可用性 * 车辆数据抽检接口 * 获取分省厅、区域的map k为deptId或者Province_deptId * 更新或新增 */ @Component @Slf4j public class CarUrlCalculation extends IndexCalculationServe implements CalculationStrategy { @Autowired private CheckIndexCarMapper checkIndexCarMapper; @Autowired private ICheckIndexCarService checkIndexCarService; //区域车辆抽检指标 protected static class AreaStats { int totalSites = 0; //url可访问的点位数 int urlUsabilitySites = 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, PicAccessResult result) { //返回对象的引用,如果不存在会放入新的key,value AreaStats stats = areaStatsMap.computeIfAbsent(key, k -> new AreaStats()); stats.totalSites++; //图片访问率>=90% 视为合格 if (PicAccessResult.calUrl(result).compareTo(new BigDecimal("0.9")) >= 0) { stats.urlUsabilitySites++; } } /** * 车辆url可用性 */ private CheckIndexCar createOrUpdateCheckIndexCar(String key, AreaStats stats, List checkIndexCarList) { CheckIndexCar checkIndexCar = getCheckIndex(key, checkIndexCarList, CheckIndexCar.class); if (checkIndexCar == null) { return null; } //调用url可用性计算方法 Map urlParam = new HashMap<>(); urlParam.put("totalSites", stats.totalSites); urlParam.put("urlQualifySites", stats.urlUsabilitySites); BigDecimal urlUsability = urlUsability(urlParam); checkIndexCar.setVehicleUrlAvailability(urlUsability); return checkIndexCar; } }