blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
fuliqi
2024-08-19 9c00d2823f39154144b5cf59105028427ec32b4e 
 ycl-server/src/main/java/com/ycl/calculate/FaceSnapshotDataCalculation.java


@@ -3,14 +3,18 @@


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.ycl.platform.domain.entity.CheckIndexFace;


import com.ycl.platform.domain.entity.TMonitor;


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


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


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;


import com.ycl.platform.service.ITMonitorService;


import com.ycl.system.mapper.SysConfigMapper;


import constant.ApiConstants;


import constant.CheckConstants;


import constant.CheckSnapCountConstants;


import lombok.extern.slf4j.Slf4j;


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


import org.springframework.stereotype.Component;


import org.springframework.util.CollectionUtils;


@@ -31,6 +35,7 @@


 * 更新或新增


 */


@Component


@Slf4j


//TODD:系统配置里的区分人脸和车辆、累加次数的概念、区县不少于40路，不达标市州的当月该项成绩不能得分。


public class FaceSnapshotDataCalculation extends IndexCalculationServe implements CalculationStrategy<SnapshotDataMonitorResult> {


    @Autowired


@@ -40,7 +45,7 @@


    @Autowired


    private SysConfigMapper sysConfigMapper;


    @Autowired


    private ITMonitorService monitorService;


    private TMonitorMapper monitorMapper;




    //区域人脸点位在线指标的内部类


    private static class AreaStats {


@@ -52,19 +57,19 @@


    @Override


    public void calculate(List<SnapshotDataMonitorResult> list) {


        if (CollectionUtils.isEmpty(list)) {


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


            return;


        }


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


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


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


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


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


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


        //获取省厅国标码集合


        List<String> provinceIds = getProvince();




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




        for (SnapshotDataMonitorResult result : list) {


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


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


            if (monitor == null) continue;




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


@@ -72,14 +77,14 @@




            // 处理省厅数据


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


                String provinceKey = "Province_" + deptId;


                String provinceKey = ApiConstants.Province + deptId;


                updateAreaStats(areaStatsMap, provinceKey, result);


            }


        }




        //获取2022同期抓拍平均值 省厅、市局


        BigDecimal cityCountAvg = getAverageCount(CheckSnapCountConstants.City);


        BigDecimal countyCountAvg = getAverageCount(CheckSnapCountConstants.County);


        BigDecimal cityCountAvg = getAverageCount(CheckSnapCountConstants.Face_City);


        BigDecimal countyCountAvg = getAverageCount(CheckSnapCountConstants.Face_County);




        // 查询今日数据


        List<CheckIndexFace> checkIndexFaceList = checkIndexFaceMapper.selectToday(DateUtils.getDate());


@@ -130,7 +135,7 @@


        BigDecimal siteOnline = siteOnline(siteOnlineParam);


        checkIndexFace.setSiteOnline(siteOnline);


        //视图库对接稳定性


        BigDecimal avgCount = key.startsWith("Province_") ? cityCountAvg : countyCountAvg;


        BigDecimal avgCount = key.startsWith(ApiConstants.Province) ? cityCountAvg : countyCountAvg;


        Map<String, Object> viewConnectParam = new HashMap<>();


        viewConnectParam.put("totalDataSum", stats.totalDataSum);


        viewConnectParam.put("avgCount", avgCount);