blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
fuliqi
2024-08-01 d1883c9da86e3e36e0c997554ad79b44a8f35494 
 ycl-server/src/main/java/com/ycl/task/HKTask.java


@@ -23,7 +23,7 @@


import java.util.Date;


import java.util.List;






//海康对接数据任务


@Slf4j


@Component("HKTask")


public class HKTask {


@@ -50,7 +50,7 @@


        List<VehicleDeviceInspectionResult> list = getDataList(jsonObject, VehicleDeviceInspectionResult.class, "车辆设备全检指标监测结果数据为空");


        if (!CollectionUtils.isEmpty(list)) {


            //如果存在之前的数据先删除


            Query query = new Query(Criteria.where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


            Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


            DeleteResult result = mongoTemplate.remove(query, VehicleDeviceInspectionResult.class);


            //存放在mongo中


            mongoTemplate.insert(list);


@@ -69,7 +69,7 @@


        List<FaceDeviceInspectionResult> list = getDataList(jsonObject, FaceDeviceInspectionResult.class, "人脸设备全检指标监测结果数据为空");


        if (!CollectionUtils.isEmpty(list)) {


            //如果存在之前的数据先删除


            Query query = new Query(Criteria.where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


            Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


            DeleteResult result = mongoTemplate.remove(query, FaceDeviceInspectionResult.class);


            //存放在mongo中


            mongoTemplate.insert(list);


@@ -86,33 +86,33 @@


        log.info("开始执行抓拍数据量检测结果数据同步");


        /** 车辆数据 */


        SnapshotDataMonitorParam carParam = new SnapshotDataMonitorParam();


        carParam.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DATATYPE_CAR);


        carParam.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_CAR);


        JSONObject carJsonObject = hkClient.SnapshotDataMonitor(carParam);


        List<SnapshotDataMonitorResult> carList = getDataList(carJsonObject, SnapshotDataMonitorResult.class, "车辆抓拍数据量检测结果数据");


        if (!CollectionUtils.isEmpty(carList)) {


            //如果今天存在之前的数据先删除


            Query query = new Query(Criteria


                    .where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))


                    .and("dataType").is(ApiConstants.HK_DATATYPE_CAR));


                    .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))


                    .and("dataType").is(ApiConstants.HK_DataType_CAR));


            DeleteResult result = mongoTemplate.remove(query, SnapshotDataMonitorResult.class);


            //存放在mongo中


            carList.forEach(item -> item.setDataType(ApiConstants.HK_DATATYPE_CAR));


            carList.forEach(item -> item.setDataType(ApiConstants.HK_DataType_CAR));


            mongoTemplate.insert(carList);


        }




        /** 人脸数据 */


        SnapshotDataMonitorParam faceParam = new SnapshotDataMonitorParam();


        faceParam.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DATATYPE_FACE);


        faceParam.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_FACE);


        JSONObject faceJsonObject = hkClient.SnapshotDataMonitor(carParam);


        List<SnapshotDataMonitorResult> faceList = getDataList(faceJsonObject, SnapshotDataMonitorResult.class, "人脸抓拍数据量检测结果数据为空");


        if (!CollectionUtils.isEmpty(faceList)) {


            //如果今天存在之前的数据先删除


            Query query = new Query(Criteria


                    .where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))


                    .and("dataType").is(ApiConstants.HK_DATATYPE_FACE));


                    .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))


                    .and("dataType").is(ApiConstants.HK_DataType_FACE));


            DeleteResult result = mongoTemplate.remove(query, SnapshotDataMonitorResult.class);


            //存放在mongo中


            carList.forEach(item -> item.setDataType(ApiConstants.HK_DATATYPE_FACE));


            carList.forEach(item -> item.setDataType(ApiConstants.HK_DataType_FACE));


            mongoTemplate.insert(faceList);


        }


        //TODO:工单


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


        if (!CollectionUtils.isEmpty(faceList)) {


            //如果今天存在之前的数据先删除


            Query query = new Query(Criteria


                    .where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


                    .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


            DeleteResult result = mongoTemplate.remove(query, MonitoringDetailResult.class);


            //存放在mongo中


            mongoTemplate.insert(faceList);


@@ -150,7 +150,7 @@


        if (!CollectionUtils.isEmpty(faceList)) {


            //如果今天存在之前的数据先删除


            Query query = new Query(Criteria


                    .where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


                    .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


            DeleteResult result = mongoTemplate.remove(query, CrossDetailResult.class);


            //存放在mongo中


            mongoTemplate.insert(faceList);


@@ -164,13 +164,13 @@


        log.info("开始执行数据完整性监测结果数据同步");


        //车辆卡口设备抓拍数据完整性


        DataIntegrityMonitoringParam param = new DataIntegrityMonitoringParam();


        param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DATATYPE_CAR);


        param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_CAR);


        JSONObject jsonObject = hkClient.DataIntegrityMonitoring(param);


        List<DataIntegrityMonitoringResult> faceList = getDataList(jsonObject, DataIntegrityMonitoringResult.class, "数据完整性监测结果数据为空");


        if (!CollectionUtils.isEmpty(faceList)) {


            //如果今天存在之前的数据先删除


            Query query = new Query(Criteria


                    .where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


                    .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


            DeleteResult result = mongoTemplate.remove(query, DataIntegrityMonitoringResult.class);


            //存放在mongo中


            mongoTemplate.insert(faceList);


@@ -184,13 +184,13 @@


        log.info("开始执行属性识别准确监测结果数据同步");


        //车辆卡口设备抓拍数据准确性


        AttrRecognitionParam param = new AttrRecognitionParam();


        param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DATATYPE_CAR);


        param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_CAR);


        JSONObject jsonObject = hkClient.AttrRecognitionMonitor(param);


        List<AttrRecognitionMonitorResult> faceList = getDataList(jsonObject, AttrRecognitionMonitorResult.class, "属性识别准确监测结果数据为空");


        if (!CollectionUtils.isEmpty(faceList)) {


            //如果今天存在之前的数据先删除


            Query query = new Query(Criteria


                    .where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


                    .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


            DeleteResult result = mongoTemplate.remove(query, AttrRecognitionMonitorResult.class);


            //存放在mongo中


            mongoTemplate.insert(faceList);


@@ -206,33 +206,33 @@


        //车辆卡口设备抓拍数据上传及时性


        /** 车辆数据 */


        SnapshotDelayMonitorParam carParam = new SnapshotDelayMonitorParam();


        carParam.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DATATYPE_CAR);


        carParam.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_CAR);


        JSONObject carJsonObject = hkClient.SnapshotDelayMonitor(carParam);


        List<SnapshotDelayMonitorResult> carList = getDataList(carJsonObject, SnapshotDelayMonitorResult.class, "车辆抓拍数据量检测结果数据");


        if (!CollectionUtils.isEmpty(carList)) {


            //如果今天存在之前的数据先删除


            Query query = new Query(Criteria


                    .where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))


                    .and("dataType").is(ApiConstants.HK_DATATYPE_CAR));


            DeleteResult result = mongoTemplate.remove(query, SnapshotDataMonitorResult.class);


                    .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))


                    .and("dataType").is(ApiConstants.HK_DataType_CAR));


            DeleteResult result = mongoTemplate.remove(query, SnapshotDelayMonitorParam.class);


            //存放在mongo中


            carList.forEach(item -> item.setDataType(ApiConstants.HK_DATATYPE_CAR));


            carList.forEach(item -> item.setDataType(ApiConstants.HK_DataType_CAR));


            mongoTemplate.insert(carList);


        }




        /** 人脸数据 */


        SnapshotDelayMonitorParam faceParam = new SnapshotDelayMonitorParam();


        faceParam.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DATATYPE_FACE);


        faceParam.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_FACE);


        JSONObject faceJsonObject = hkClient.SnapshotDelayMonitor(faceParam);


        List<SnapshotDelayMonitorParam> faceList = getDataList(faceJsonObject, SnapshotDelayMonitorParam.class, "人脸抓拍数据量检测结果数据为空");


        if (!CollectionUtils.isEmpty(faceList)) {


            //如果今天存在之前的数据先删除


            Query query = new Query(Criteria


                    .where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))


                    .and("dataType").is(ApiConstants.HK_DATATYPE_FACE));


            DeleteResult result = mongoTemplate.remove(query, SnapshotDataMonitorResult.class);


                    .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))


                    .and("dataType").is(ApiConstants.HK_DataType_FACE));


            DeleteResult result = mongoTemplate.remove(query, SnapshotDelayMonitorParam.class);


            //存放在mongo中


            carList.forEach(item -> item.setDataType(ApiConstants.HK_DATATYPE_FACE));


            carList.forEach(item -> item.setDataType(ApiConstants.HK_DataType_FACE));


            mongoTemplate.insert(faceList);


        }


        //TODO:工单


@@ -244,13 +244,13 @@


        log.info("开始执行图片访问监测结果数据同步");


        //车辆卡口信息采集准确率、车辆卡口设备url可用性


        PicAccessParam param = new PicAccessParam();


        param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DATATYPE_CAR);


        param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_CAR);


        JSONObject jsonObject = hkClient.PicAccessMonitor(param);


        List<PicAccessResult> faceList = getDataList(jsonObject, PicAccessResult.class, "图片访问监测结果数据为空");


        if (!CollectionUtils.isEmpty(faceList)) {


            //如果今天存在之前的数据先删除


            Query query = new Query(Criteria


                    .where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


                    .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


            DeleteResult result = mongoTemplate.remove(query, PicAccessResult.class);


            //存放在mongo中


            mongoTemplate.insert(faceList);


@@ -270,8 +270,8 @@


        if (!CollectionUtils.isEmpty(faceList)) {


            //如果今天存在之前的数据先删除


            Query query = new Query(Criteria


                    .where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


            DeleteResult result = mongoTemplate.remove(query, PicAccessResult.class);


                    .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


            DeleteResult result = mongoTemplate.remove(query, FaceDeviceSamplingResult.class);


            //存放在mongo中


            mongoTemplate.insert(faceList);


        }


@@ -290,8 +290,8 @@


        if (!CollectionUtils.isEmpty(faceList)) {


            //如果今天存在之前的数据先删除


            Query query = new Query(Criteria


                    .where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


            DeleteResult result = mongoTemplate.remove(query, PicAccessResult.class);


                    .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


            DeleteResult result = mongoTemplate.remove(query, FaceDeviceSamplingResult.class);


            //存放在mongo中


            mongoTemplate.insert(faceList);


        }


@@ -301,7 +301,7 @@




    //解析数据


    private <T> List<T> getDataList(JSONObject faceJsonObject, Class<T> resultClass, String message) {


        if (faceJsonObject != null && ApiConstants.successCode.equals(faceJsonObject.getString("code"))) {


        if (faceJsonObject != null && ApiConstants.HKSuccessCode.equals(faceJsonObject.getString("code"))) {


            JSONObject data = faceJsonObject.getJSONObject("data");


            if (data == null) {


                log.error(message, faceJsonObject);


@@ -311,11 +311,6 @@


            if (CollectionUtils.isEmpty(list)) {


                log.error(message, data);


                return null;


            }


            for (T t : list) {


                if (t instanceof BaseResult) {


                    ((BaseResult) t).setCreateTime(new Date());


                }


            }


            return list;


        } else {