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


@@ -2,9 +2,8 @@




import com.alibaba.fastjson2.JSONObject;


import com.mongodb.client.result.DeleteResult;


import com.ycl.calculate.CalculationStrategy;


import com.ycl.factory.IndexCalculationFactory;


import com.ycl.platform.domain.param.HK.*;


import com.ycl.platform.domain.result.BaseResult;


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


import com.ycl.platform.service.ICheckIndexCarService;


import com.ycl.platform.service.ICheckIndexFaceService;


@@ -20,13 +19,11 @@


import org.springframework.data.mongodb.core.query.Query;


import org.springframework.stereotype.Component;


import org.springframework.util.CollectionUtils;


import org.springframework.util.unit.DataUnit;




import java.text.SimpleDateFormat;


import java.util.Date;


import java.util.List;






//海康对接数据任务


@Slf4j


@Component("HKTask")


public class HKTask {


@@ -53,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);


@@ -72,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);


@@ -95,7 +92,7 @@


        if (!CollectionUtils.isEmpty(carList)) {


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


            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()))


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


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


            //存放在mongo中


@@ -111,7 +108,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()))


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


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


            //存放在mongo中


@@ -133,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);


@@ -153,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);


@@ -173,7 +170,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, DataIntegrityMonitoringResult.class);


            //存放在mongo中


            mongoTemplate.insert(faceList);


@@ -193,7 +190,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, AttrRecognitionMonitorResult.class);


            //存放在mongo中


            mongoTemplate.insert(faceList);


@@ -215,9 +212,9 @@


        if (!CollectionUtils.isEmpty(carList)) {


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


            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()))


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


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


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


            //存放在mongo中


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


            mongoTemplate.insert(carList);


@@ -231,9 +228,9 @@


        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()))


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


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


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


            //存放在mongo中


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


            mongoTemplate.insert(faceList);


@@ -253,7 +250,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, PicAccessResult.class);


            //存放在mongo中


            mongoTemplate.insert(faceList);


@@ -273,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);


        }


@@ -293,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);


        }


@@ -304,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);


@@ -314,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 {