视频标注接口完善

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;
@@ -45,6 +45,10 @@
    private ITMonitorService monitorService;
    @Value("${youYun.tenantId}")
    private String tenantId;
    @Value("${youYun.apikey}")
    private String apikey;
    @Value("${youYun.accesskey}")
    private String accesskey;
    @Value("${youYun.email}")
    private String email;
    @Value("${youYun.passwd}")
@@ -82,6 +86,41 @@
        log.info("结束执行一机一档数据同步");
    }

    //一机一档合格率
    public void monitorQualifyTask() {
        //一机一档合格率
        log.info("开始执行一机一档合格率数据同步");
        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<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, MonitorQualifyResult.class);
                        //存放在mongo中
                        mongoTemplate.insertAll(records);
                    } else {
                        log.error("一机一档合格率数据为空{}", data);
                    }
                }
            } else {
                log.error("一机一档合格率数据为空{}", jsonObject);
            }
        } else {
            log.error("一机一档合格率数据为空");
        }
        log.info("结束一机一档合格率数据同步");
    }

    //图像监测诊断结果
    public void queryVqdResultTask() {
        //点位在线率
@@ -89,6 +128,8 @@
        log.info("开始执行图像监测诊断结果数据同步");
        QueryVqdParam param = new QueryVqdParam();
        param.setTenantId(tenantId);
        param.setApikey(apikey);
        param.setAccesskey(accesskey);
        JSONObject jsonObject = uyClient.queryVqdResult(param);
        if (jsonObject != null) {
            log.info("数据格式" + jsonObject);
@@ -156,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);