补充车辆抽检接口

xiangpei

2024-08-05 c221aef40109fe7296450bd51b872ce51ee3e59c

补充车辆抽检接口

 ycl-server/src/main/java/com/ycl/feign/FeignErrorDecoder.java

@@ -40,6 +40,7 @@
                break;
        }
        log.error(msg);
        log.error(response.reason());
        return new FeignException(msg);
    }
}

 ycl-server/src/main/java/com/ycl/feign/HKClient.java

@@ -127,7 +127,7 @@
     * @return 抓拍数据量监测结果
     */
    @PostMapping("/dqd/service/rs/v1/data/snapCountDetail/query")
    JSONObject SnapshotDataMonitor(@RequestBody SnapshotDataMonitorParam param);
    JSONObject snapshotDataMonitor(@RequestBody SnapshotDataMonitorParam param);

    /**
     * 抓拍数据时延监测结果
@@ -143,7 +143,7 @@
     * @return 抓拍数据时延监测结果
     */
    @PostMapping("/dqd/service/rs/v1/data/snapAgingDetail/query")
    JSONObject SnapshotDelayMonitor(@RequestBody SnapshotDelayMonitorParam param);
    JSONObject snapshotDelayMonitor(@RequestBody SnapshotDelayMonitorParam param);

    /**
     * 图片访问监测结果
@@ -154,7 +154,7 @@
     * @return 图片访问监测结果
     */
    @PostMapping("/dqd/service/rs/v1/data/picAccessDetail/query")
    JSONObject PicAccessMonitor(@RequestBody PicAccessParam param);
    JSONObject picAccessMonitor(@RequestBody PicAccessParam param);

    /**
     * 属性识别准确监测结果
@@ -164,7 +164,7 @@
     * @return 属性识别准确监测结果
     */
    @PostMapping("/dqd/service/rs/v1/data/attributeRecognition/query")
    JSONObject AttrRecognitionMonitor(@RequestBody AttrRecognitionParam param);
    JSONObject attrRecognitionMonitor(@RequestBody AttrRecognitionParam param);

    /**
     * 数据完整性监测结果
@@ -178,7 +178,7 @@
     * @return 数据完整性监测结果
     */
    @PostMapping("/dqd/service/rs/v1/data/attributeIntegrity/query")
    JSONObject DataIntegrityMonitoring(@RequestBody DataIntegrityMonitoringParam param);
    JSONObject dataIntegrityMonitoring(@RequestBody DataIntegrityMonitoringParam param);

    /**
     * 人脸设备全检指标监测结果
@@ -189,7 +189,7 @@
     * @return 人脸设备全检指标监测结果
     */
    @PostMapping("/dqd/service/rs/v2/data/faceFullAmount/query")
    JSONObject FaceDeviceInspection(@RequestBody FaceDeviceInspectionParam param);
    JSONObject faceDeviceInspection(@RequestBody FaceDeviceInspectionParam param);

    /**
     * 人脸设备抽检指标监测结果
@@ -200,7 +200,7 @@
     * @return 人脸设备抽检指标监测结果
     */
    @PostMapping("/dqd/service/rs/v2/data/faceSampleAmount/query")
    JSONObject FaceDeviceSampling(@RequestBody FaceDeviceSamplingParam param);
    JSONObject faceDeviceSampling(@RequestBody FaceDeviceSamplingParam param);

    /**
     * 车辆设备全检指标监测结果
@@ -211,7 +211,7 @@
     * @return 车辆设备全检指标监测结果
     */
    @PostMapping("/dqd/service/rs/v2/data/vehFullAmount/query")
    JSONObject VehicleDeviceInspection(@RequestBody VehicleDeviceInspectionParam param);
    JSONObject vehicleDeviceInspection(@RequestBody VehicleDeviceInspectionParam param);

    /**
     * 车辆设备抽检指标监测结果
@@ -222,7 +222,7 @@
     * @return 车辆设备抽检指标监测结果
     */
    @PostMapping("/dqd/service/rs/v2/data/vehSampleAmount/query")
    JSONObject VehicleDeviceSampling(@RequestBody VehicleDeviceSamplingParam param);
    JSONObject vehicleDeviceSampling(@RequestBody VehicleDeviceSamplingParam param);

    /**
     * 关注监测资源查询
@@ -239,7 +239,7 @@
     * @return 指标配置信息查询
     */
    @GetMapping("/dqd/service/rs/v1/statistics/criteria/query")
    JSONObject Criteria();
    JSONObject criteria();

    /**
     * 组织树查询
@@ -247,5 +247,5 @@
     * @return 组织树查询
     */
    @PostMapping("/dqd/service/rs/v1/orgInfo/standard/query")
    JSONObject OrganizationTree(@RequestBody OrganizationTreeParam param);
    JSONObject organizationTree(@RequestBody OrganizationTreeParam param);
}

 ycl-server/src/main/java/com/ycl/feign/UYClient.java

@@ -78,6 +78,6 @@
     * @param param
     * @return
     */
    @PostMapping(value = "/tenant/api/vi/user/login",headers = "No-Need-To-Token = true")
    @PostMapping(value = "/tenant/api/vi/user/login",headers = "No-Need-To-Token=true")
    JSONObject getToken(@RequestBody UYTokenParam param);
}

 ycl-server/src/main/java/com/ycl/interceptor/YYFeignInterceptor.java

@@ -9,6 +9,7 @@
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;

import org.springframework.context.annotation.Lazy;
import org.springframework.data.redis.core.RedisTemplate;


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

@@ -46,7 +46,7 @@
        log.info("开始执行车辆设备全检指标监测结果数据同步");
        VehicleDeviceInspectionParam param = new VehicleDeviceInspectionParam();
        param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate());
        JSONObject jsonObject = hkClient.VehicleDeviceInspection(param);
        JSONObject jsonObject = hkClient.vehicleDeviceInspection(param);
        List<VehicleDeviceInspectionResult> list = getDataList(jsonObject, VehicleDeviceInspectionResult.class, "车辆设备全检指标监测结果数据为空");
        if (!CollectionUtils.isEmpty(list)) {
            //如果存在之前的数据先删除
@@ -65,7 +65,7 @@
        log.info("开始执行人脸设备全检指标监测结果数据同步");
        FaceDeviceInspectionParam param = new FaceDeviceInspectionParam();
        param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate());
        JSONObject jsonObject = hkClient.FaceDeviceInspection(param);
        JSONObject jsonObject = hkClient.faceDeviceInspection(param);
        List<FaceDeviceInspectionResult> list = getDataList(jsonObject, FaceDeviceInspectionResult.class, "人脸设备全检指标监测结果数据为空");
        if (!CollectionUtils.isEmpty(list)) {
            //如果存在之前的数据先删除
@@ -87,7 +87,7 @@
        /** 车辆数据 */
        SnapshotDataMonitorParam carParam = new SnapshotDataMonitorParam();
        carParam.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_CAR);
        JSONObject carJsonObject = hkClient.SnapshotDataMonitor(carParam);
        JSONObject carJsonObject = hkClient.snapshotDataMonitor(carParam);
        List<SnapshotDataMonitorResult> carList = getDataList(carJsonObject, SnapshotDataMonitorResult.class, "车辆抓拍数据量检测结果数据");
        if (!CollectionUtils.isEmpty(carList)) {
            //如果今天存在之前的数据先删除
@@ -103,7 +103,7 @@
        /** 人脸数据 */
        SnapshotDataMonitorParam faceParam = new SnapshotDataMonitorParam();
        faceParam.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_FACE);
        JSONObject faceJsonObject = hkClient.SnapshotDataMonitor(carParam);
        JSONObject faceJsonObject = hkClient.snapshotDataMonitor(carParam);
        List<SnapshotDataMonitorResult> faceList = getDataList(faceJsonObject, SnapshotDataMonitorResult.class, "人脸抓拍数据量检测结果数据为空");
        if (!CollectionUtils.isEmpty(faceList)) {
            //如果今天存在之前的数据先删除
@@ -165,7 +165,7 @@
        //车辆卡口设备抓拍数据完整性
        DataIntegrityMonitoringParam param = new DataIntegrityMonitoringParam();
        param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_CAR);
        JSONObject jsonObject = hkClient.DataIntegrityMonitoring(param);
        JSONObject jsonObject = hkClient.dataIntegrityMonitoring(param);
        List<DataIntegrityMonitoringResult> faceList = getDataList(jsonObject, DataIntegrityMonitoringResult.class, "数据完整性监测结果数据为空");
        if (!CollectionUtils.isEmpty(faceList)) {
            //如果今天存在之前的数据先删除
@@ -185,7 +185,7 @@
        //车辆卡口设备抓拍数据准确性
        AttrRecognitionParam param = new AttrRecognitionParam();
        param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_CAR);
        JSONObject jsonObject = hkClient.AttrRecognitionMonitor(param);
        JSONObject jsonObject = hkClient.attrRecognitionMonitor(param);
        List<AttrRecognitionMonitorResult> faceList = getDataList(jsonObject, AttrRecognitionMonitorResult.class, "属性识别准确监测结果数据为空");
        if (!CollectionUtils.isEmpty(faceList)) {
            //如果今天存在之前的数据先删除
@@ -207,7 +207,7 @@
        /** 车辆数据 */
        SnapshotDelayMonitorParam carParam = new SnapshotDelayMonitorParam();
        carParam.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_CAR);
        JSONObject carJsonObject = hkClient.SnapshotDelayMonitor(carParam);
        JSONObject carJsonObject = hkClient.snapshotDelayMonitor(carParam);
        List<SnapshotDelayMonitorResult> carList = getDataList(carJsonObject, SnapshotDelayMonitorResult.class, "车辆抓拍数据量检测结果数据");
        if (!CollectionUtils.isEmpty(carList)) {
            //如果今天存在之前的数据先删除
@@ -223,7 +223,7 @@
        /** 人脸数据 */
        SnapshotDelayMonitorParam faceParam = new SnapshotDelayMonitorParam();
        faceParam.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_FACE);
        JSONObject faceJsonObject = hkClient.SnapshotDelayMonitor(faceParam);
        JSONObject faceJsonObject = hkClient.snapshotDelayMonitor(faceParam);
        List<SnapshotDelayMonitorParam> faceList = getDataList(faceJsonObject, SnapshotDelayMonitorParam.class, "人脸抓拍数据量检测结果数据为空");
        if (!CollectionUtils.isEmpty(faceList)) {
            //如果今天存在之前的数据先删除
@@ -240,12 +240,12 @@
    }

    //图片访问监测结果
    public void PicAccessTask() {
    public void picAccessTask() {
        log.info("开始执行图片访问监测结果数据同步");
        //车辆卡口信息采集准确率、车辆卡口设备url可用性
        PicAccessParam param = new PicAccessParam();
        param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_CAR);
        JSONObject jsonObject = hkClient.PicAccessMonitor(param);
        JSONObject jsonObject = hkClient.picAccessMonitor(param);
        List<PicAccessResult> faceList = getDataList(jsonObject, PicAccessResult.class, "图片访问监测结果数据为空");
        if (!CollectionUtils.isEmpty(faceList)) {
            //如果今天存在之前的数据先删除
@@ -258,34 +258,33 @@
        //TODO:工单处理
        log.info("结束图片访问监测结果数据同步");
    }

    //人脸设备抽检指标监测结果
    public void Face() {
        log.info("开始执行人脸设备抽检指标监测结果数据同步");
    //车辆设备抽检指标监测结果
    public void vehicleDeviceSamplingTask() {
        log.info("开始执行车辆设备抽检指标监测结果数据同步");
        //车辆卡口信息采集准确率、车辆卡口设备url可用性
        FaceDeviceSamplingParam param = new FaceDeviceSamplingParam();
        VehicleDeviceSamplingParam param = new VehicleDeviceSamplingParam();
        param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate());
        JSONObject jsonObject = hkClient.FaceDeviceSampling(param);
        List<FaceDeviceSamplingResult> faceList = getDataList(jsonObject, FaceDeviceSamplingResult.class, "人脸设备抽检指标监测结果数据为空");
        JSONObject jsonObject = hkClient.vehicleDeviceSampling(param);
        List<VehicleDeviceSamplingResult> faceList = getDataList(jsonObject, VehicleDeviceSamplingResult.class, "人脸设备抽检指标监测结果数据为空");
        if (!CollectionUtils.isEmpty(faceList)) {
            //如果今天存在之前的数据先删除
            Query query = new Query(Criteria
                    .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
            DeleteResult result = mongoTemplate.remove(query, FaceDeviceSamplingResult.class);
            DeleteResult result = mongoTemplate.remove(query, VehicleDeviceSamplingResult.class);
            //存放在mongo中
            mongoTemplate.insert(faceList);
        }
        //TODO:工单处理
        log.info("结束人脸设备抽检指标监测结果数据同步");
        log.info("结束车辆设备抽检指标监测结果数据同步");
    }

    //车辆设备抽检指标监测结果
    public void FaceDeviceSamplingTask() {
        log.info("开始执行车辆设备抽检指标监测结果数据同步");
        //车辆卡口信息采集准确率、车辆卡口设备url可用性

    //人脸设备抽检指标监测结果
    public void faceDeviceSamplingTask() {
        log.info("开始执行人脸设备抽检指标监测结果数据同步");
        FaceDeviceSamplingParam param = new FaceDeviceSamplingParam();
        param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate());
        JSONObject jsonObject = hkClient.FaceDeviceSampling(param);
        JSONObject jsonObject = hkClient.faceDeviceSampling(param);
        List<FaceDeviceSamplingResult> faceList = getDataList(jsonObject, FaceDeviceSamplingResult.class, "人脸设备抽检指标监测结果数据为空");
        if (!CollectionUtils.isEmpty(faceList)) {
            //如果今天存在之前的数据先删除