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


@@ -5,13 +5,16 @@


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


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


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


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


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 lombok.extern.slf4j.Slf4j;


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


import org.springframework.stereotype.Component;


import org.springframework.util.CollectionUtils;


@@ -32,17 +35,19 @@


 * 更新或新增


 */


@Component


@Slf4j


public class CarSnapshotDelayCalculation extends IndexCalculationServe implements CalculationStrategy<SnapshotDelayMonitorResult> {


    @Autowired


    private CheckIndexCarMapper checkIndexCarMapper;


    @Autowired


    private ITMonitorService monitorService;


    private TMonitorMapper monitorMapper;


    @Autowired


    private ICheckIndexCarService checkIndexCarService;




    //区域车辆点位在线指标的内部类


    private static class AreaStats {


        int totalCount = 0;


        int delayCount = 0;


        //0-180s


        int delayCount1 = 0;


        //180-300s


@@ -54,19 +59,19 @@


    @Override


    public void calculate(List<SnapshotDelayMonitorResult> 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(SnapshotDelayMonitorResult::getExternalIndexCode).collect(Collectors.toList())))


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


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


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


        //获取省厅国标码集合


        List<String> provinceIds = getProvince();




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


        for (SnapshotDelayMonitorResult result : list) {


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


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


            if (monitor == null) continue;




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


@@ -74,7 +79,7 @@




            // 处理省厅数据


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


                String provinceKey = "Province_" + deptId;


                String provinceKey = ApiConstants.Province + deptId;


                updateAreaStats(areaStatsMap, provinceKey, result);


            }


        }


@@ -101,6 +106,7 @@


        //返回对象的引用，如果不存在会放入新的key,value


        AreaStats stats = areaStatsMap.computeIfAbsent(key, k -> new AreaStats());


        stats.totalCount += result.getDataCount();


        stats.delayCount += result.getDelayCount();


        stats.delayCount1 += result.getDataDelayCount1();


        stats.delayCount2 += result.getDataDelayCount2();


        stats.delayCount3 += result.getDataDelayCount3();


@@ -118,11 +124,12 @@


        //调用抓拍上传及时性计算方法


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


        param.put("totalCount", stats.totalCount);


        param.put("delayCount", stats.delayCount);


        param.put("delayCount1", stats.delayCount1);


        param.put("delayCount2", stats.delayCount2);


        param.put("delayCount3", stats.delayCount3);


        BigDecimal index = snapshopDelay(param);


        checkIndexCar.setSiteOnline(index);


        checkIndexCar.setVehicleUploadTimeliness(index);


        return checkIndexCar;


    }


}