blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
fuliqi
2024-09-05 cd24a045bd9ee29505ddc9760d25f5d4037f4f0c 
 ycl-server/src/main/java/com/ycl/calculate/FaceInFoAccuracyCalculation.java


@@ -4,7 +4,9 @@


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.FaceDeviceSamplingResult;


import com.ycl.platform.domain.result.HK.MonitoringDetailResult;


import com.ycl.platform.domain.vo.TMonitorVO;


import com.ycl.platform.mapper.CheckIndexFaceMapper;


import com.ycl.platform.mapper.TMonitorMapper;


import com.ycl.platform.service.ICheckIndexFaceService;


@@ -12,6 +14,7 @@


import com.ycl.system.mapper.SysConfigMapper;


import constant.ApiConstants;


import constant.CheckConstants;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Component;


import org.springframework.util.CollectionUtils;


@@ -29,13 +32,14 @@


 * 更新或新增


 */


@Component


@Slf4j


public class FaceInFoAccuracyCalculation extends IndexCalculationServe implements CalculationStrategy<MonitoringDetailResult> {


    @Autowired


    private CheckIndexFaceMapper checkIndexFaceMapper;


    @Autowired


    private ICheckIndexFaceService checkIndexFaceService;


    @Autowired


    private ITMonitorService monitorService;


    private TMonitorMapper monitorMapper;




    //区域车辆信息采集准确率的内部类


    private static class AreaStats {


@@ -46,19 +50,18 @@


    @Override


    public void calculate(List<MonitoringDetailResult> list) {


        if (CollectionUtils.isEmpty(list)) {


            log.info("数据为空");


            return;


        }


        //返回以国标码为key的设备map


        //TODO：monitor去掉了deptId


        Map<String, TMonitor> monitorMap = monitorService.list(new QueryWrapper<TMonitor>()


                        .in("serial_number", list.stream().map(MonitoringDetailResult::getExternalIndexCode).collect(Collectors.toList())))


                .stream().collect(Collectors.toMap(TMonitor::getSerialNumber, Function.identity()));


        Map<String, TMonitorVO> monitorMap = monitorMapper.selectListByIds(list.stream().map(MonitoringDetailResult::getExternalIndexCode).collect(Collectors.toList()))


                .stream().collect(Collectors.toMap(TMonitorVO::getSerialNumber, Function.identity()));


        //获取省厅国标码集合


        List<String> provinceIds = getProvince();


        Map<String, AreaStats> areaStatsMap = new HashMap<>();




        for (MonitoringDetailResult result : list) {


            TMonitor monitor = monitorMap.get(result.getExternalIndexCode());


            TMonitorVO monitor = monitorMap.get(result.getExternalIndexCode());


            if (monitor == null) continue;




            String deptId = monitor.getDeptId().toString();


@@ -67,7 +70,7 @@




            // 处理省厅数据


            if (!CollectionUtils.isEmpty(provinceIds) && provinceIds.contains(monitor.getSerialNumber())) {


                String provinceKey = "Province_" + deptId;


                String provinceKey = ApiConstants.Province + deptId;


                updateAreaStats(areaStatsMap, provinceKey, result);


            }


        }