bug修复

zxl

4 天以前 c83101eb62f5d4906b9c01ceea6b21a37f9e84d8

 ycl-server/src/main/java/com/ycl/task/HKTask.java

@@ -77,7 +77,7 @@
    @Autowired
    private CheckIndexFaceMapper faceMapper;

    //车辆设备全检指标监测结果
    //车辆设备全检指标监测结果 车辆（车辆卡口设备时钟准确性、）
    public void vehicleDeviceInspectionTask() {
        log.info("开始执行车辆设备全检指标监测结果数据同步");
        VehicleDeviceInspectionParam param = new VehicleDeviceInspectionParam();
@@ -107,7 +107,7 @@
        log.info("结束车辆设备全检指标监测结果数据同步");
    }

    //人脸设备全检指标监测结果
    //人脸设备全检指标监测结果 人脸（设备抓拍图片时钟准确性）
    public void faceDeviceInspectionTask() {
        log.info("开始执行人脸设备全检指标监测结果数据同步");
        FaceDeviceInspectionParam param = new FaceDeviceInspectionParam();
@@ -136,7 +136,7 @@
    }


    // 抓拍数据量监测结果
    // 抓拍数据量监测结果 车辆人脸（视图库对接稳定性、点位在线率）
    public void snapshotDataMonitorTask() {
        log.info("开始执行抓拍数据量检测结果数据同步");
        /** 车辆数据 */
@@ -170,7 +170,9 @@
        faceParam.setDate(DateUtils.getDate());
        faceParam.setDataType(ApiConstants.HK_DataType_FACE);
        List<SnapshotDataMonitorResult> faceList = HkApiUtil.sendAPI(host, appKey, appSecret, "/api/dqd/service/rs/v1/data/snapCountDetail/query", faceParam, SnapshotDataMonitorResult.class);
        log.info("打印人脸（视图库对接稳定性、点位在线率）HK接口获得任务信息:{}",faceList);
        if (!CollectionUtils.isEmpty(faceList)) {

            //如果今天存在之前的数据先删除
            Query query = new Query(Criteria
                    .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))
@@ -184,6 +186,7 @@
            pointService.setDeviceTagByGB(faceList, CheckConstants.Rule_Category_Face);
            //存放在mongo中
            faceList.forEach(item -> item.setDataType(ApiConstants.HK_DataType_FACE));
            log.info("打印人脸（视图库对接稳定性、点位在线率）设置tag并插入mongodb数据:{}",faceList);
            mongoTemplate.insertAll(faceList);
        }
        //修改online状态
@@ -217,6 +220,7 @@
                        willUpdateList.add(vo);
                    }
                });
                log.info("修改设备将要更新入sql中数据：{}",willUpdateList);
                if(!CollectionUtils.isEmpty(willUpdateList)) monitorMapper.updateOnlineFromHk(willUpdateList);
//            List<UpdateOnlineVO> willUpdateList = totalResult.stream().map(item -> {
//                UpdateOnlineVO vo = new UpdateOnlineVO();
@@ -240,7 +244,7 @@
        log.info("结束抓拍数据量检测结果数据同步");
    }

    //采集设备属性监测结果(人脸)
    //采集设备属性监测结果(人脸) 人脸（人脸卡口信息采集准确率）
    public void monitorDetailTask() {
        log.info("开始执行采集设备属性监测结果数据同步");
        //人脸卡口信息采集准确率
@@ -266,7 +270,7 @@
        log.info("结束采集设备属性监测结果数据同步");
    }

    //卡口属性监测结果
    //卡口属性监测结果 车辆（车辆卡口信息采集准确率、）
    public void crossDetailTask() {
        log.info("开始执行卡口属性监测结果数据同步");
        //车辆卡口信息采集准确率
@@ -292,7 +296,7 @@
        log.info("结束卡口属性监测结果数据同步");
    }

    //数据完整性监测结果
    //数据完整性监测结果 车量（车辆卡口设备抓拍数据完整性、）
    public void dataIntegrityMonitoringTask() {
        log.info("开始执行数据完整性监测结果数据同步");
        //车辆卡口设备抓拍数据完整性
@@ -320,7 +324,7 @@
        log.info("结束数据完整性监测结果数据同步");
    }

    //属性识别准确监测结果
    //属性识别准确监测结果 车辆（车辆卡口设备抓拍数据准确性、）
    public void attrRecognitionMonitorTask() {
        log.info("开始执行属性识别准确监测结果数据同步");
        //车辆卡口设备抓拍数据准确性
@@ -349,7 +353,7 @@

    }

    //抓拍数据时延监测结果
    //抓拍数据时延监测结果包含 车辆人脸（抓拍数据上传及时性）
    public void snapshopDelayMonitorTask() {
        log.info("开始执行抓拍数据时延监测结果数据同步");
        //车辆卡口设备抓拍数据上传及时性
@@ -405,7 +409,7 @@
        log.info("结束抓拍数据时延监测结果数据同步");
    }

    //图片访问监测结果
    //图片访问监测结果 车辆（车辆卡口信息采集准确率、车辆卡口设备url可用性）
    public void picAccessTask() {
        log.info("开始执行图片访问监测结果数据同步");
        //车辆卡口信息采集准确率、车辆卡口设备url可用性
@@ -433,7 +437,7 @@
        log.info("结束图片访问监测结果数据同步");
    }

    //车辆设备抽检指标监测结果
    //车辆设备抽检指标监测结果 车辆（车辆卡口信息采集准确率、车辆卡口设备url可用性）
    public void vehicleDeviceSamplingTask() {
        log.info("开始执行车辆设备抽检指标监测结果数据同步");
        //车辆卡口信息采集准确率、车辆卡口设备url可用性
@@ -462,7 +466,7 @@
    }


    //人脸设备抽检指标监测结果
    //人脸设备抽检指标监测结果 人脸（抓拍数据大图可用性,信息采集正确率）
    public void faceDeviceSamplingTask() {
        log.info("开始执行人脸设备抽检指标监测结果数据同步");
        FaceDeviceSamplingParam param = new FaceDeviceSamplingParam();