From 32015a4af728d411b45be368e6beee9edc3ff922 Mon Sep 17 00:00:00 2001 From: xiangpei <xiangpei@timesnew.cn> Date: 星期四, 08 八月 2024 19:20:26 +0800 Subject: [PATCH] 视频标注接口完善 --- ycl-server/src/main/java/com/ycl/task/UYTask.java | 14 +++++++++----- 1 files changed, 9 insertions(+), 5 deletions(-) diff --git a/ycl-server/src/main/java/com/ycl/task/UYTask.java b/ycl-server/src/main/java/com/ycl/task/UYTask.java index 1460a02..939cb01 100644 --- a/ycl-server/src/main/java/com/ycl/task/UYTask.java +++ b/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() { //涓�鏈轰竴妗e悎鏍肩巼 log.info("寮�濮嬫墽琛屼竴鏈轰竴妗e悎鏍肩巼鏁版嵁鍚屾"); - 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); //瀛樻斁鍦╩ongo涓� 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); -- Gitblit v1.8.0