视频标注接口完善

xiangpei

2024-08-08 32015a4af728d411b45be368e6beee9edc3ff922

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

@@ -6,8 +6,8 @@
import com.ycl.platform.domain.param.UY.*;
import com.ycl.platform.domain.result.UY.OneMachineFileResult;
import com.ycl.platform.domain.result.UY.OsdMonitorResult;
import com.ycl.platform.domain.result.UY.QueryVqdResult;
import com.ycl.platform.domain.result.UY.RecordMetaDSumResult;
import com.ycl.platform.domain.result.UY.*;
import com.ycl.platform.service.ITMonitorService;
import com.ycl.platform.service.IYwThresholdService;
import com.ycl.utils.DateUtils;
@@ -90,20 +90,22 @@
    public void monitorQualifyTask() {
        //一机一档合格率
        log.info("开始执行一机一档合格率数据同步");
        OneMachineFileParam param = new OneMachineFileParam();
        JSONObject jsonObject = uyClient.oneMachineFile(param);
        MonitorQualifyParam param = new MonitorQualifyParam();
        param.setPageNum(ApiConstants.pageNo);
        param.setPageSize(ApiConstants.pageSize);
        JSONObject jsonObject = uyClient.monitorQualify(param);
        if (jsonObject != null) {
            log.info("数据格式" + jsonObject);
            String code = jsonObject.getString("code");
            if (ApiConstants.UYSuccessCodeStr.equals(code)) {
                JSONObject data = jsonObject.getJSONObject("data");
                if (data != null) {
                    List<OneMachineFileResult> records = data.getList("records", OneMachineFileResult.class);
                    List<MonitorQualifyResult> records = data.getList("records", MonitorQualifyResult.class);
                    if (!CollectionUtils.isEmpty(records)) {
                        //如果今天存在之前的数据先删除
                        Query query = new Query(Criteria
                                .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
                        DeleteResult result = mongoTemplate.remove(query, OneMachineFileResult.class);
                        DeleteResult result = mongoTemplate.remove(query, MonitorQualifyResult.class);
                        //存放在mongo中
                        mongoTemplate.insertAll(records);
                    } else {
@@ -195,6 +197,8 @@
        //视频标注
        log.info("开始执行视频标注数据同步");
        OsdMonitorParam param = new OsdMonitorParam();
        param.setPageNum(ApiConstants.pageNo);
        param.setPageSize(ApiConstants.pageSize);
        JSONObject jsonObject = uyClient.osdMonitorList(param, tenantId);
        if (jsonObject != null) {
            log.info("数据格式" + jsonObject);