From c7738ff5df85e5ba0dd7fd16ca2770b950cdd8f8 Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期一, 02 九月 2024 11:09:01 +0800
Subject: [PATCH] 报备导出优化
---
ycl-server/src/main/java/com/ycl/task/UYTask.java | 105 +++++++++++++++++++---------------------------------
1 files changed, 38 insertions(+), 67 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 1313214..fcae41b 100644
--- a/ycl-server/src/main/java/com/ycl/task/UYTask.java
+++ b/ycl-server/src/main/java/com/ycl/task/UYTask.java
@@ -95,6 +95,7 @@
// } else {
// log.error("鍥惧儚鐩戞祴鏁版嵁涓虹┖");
// }
+ // 鏈湴娴嬭瘯
Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
uyErrorTypeCheckService.imageDetectionCheck(mongoTemplate.find(query, ImageDetectionResult.class));
log.info("缁撴潫鎵ц鍥惧儚鐩戞祴鏁版嵁鍚屾");
@@ -106,37 +107,38 @@
// 涓�鏈轰竴妗ｆ敞鍐岀巼
// 妗ｆ鑰冩牳姣�
log.info("寮�濮嬫墽琛屼竴鏈轰竴妗ｅ悎鏍肩巼鏁版嵁鍚屾");
-// MonitorQualifyParam param = new MonitorQualifyParam();
-// param.setPageNum(ApiConstants.PageNo);
-// param.setPageSize(ApiConstants.PageSize);
-// JSONObject jsonObject = uyClient.monitorQualify(param);
-// if (jsonObject != null) {
-// 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);
-// //瀛樻斁鍦╩ongo涓�
-// mongoTemplate.insertAll(records);
-// // 宸ュ崟鐢熸垚
-// uyErrorTypeCheckService.monitorQualifyCheck(records);
-// } else {
-// log.error("涓�鏈轰竴妗ｅ悎鏍肩巼鏁版嵁涓虹┖{}", data);
-// }
-// }
-// } else {
-// log.error("涓�鏈轰竴妗ｅ悎鏍肩巼鏁版嵁涓虹┖{}", jsonObject);
-// }
-// } else {
-// log.error("涓�鏈轰竴妗ｅ悎鏍肩巼鏁版嵁涓虹┖");
-// }
- Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
- uyErrorTypeCheckService.monitorQualifyCheck(mongoTemplate.find(query, MonitorQualifyResult.class));
+ MonitorQualifyParam param = new MonitorQualifyParam();
+ param.setPageNum(ApiConstants.PageNo);
+ param.setPageSize(ApiConstants.PageSize);
+ JSONObject jsonObject = uyClient.monitorQualify(param);
+ if (jsonObject != null) {
+ 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);
+ //瀛樻斁鍦╩ongo涓�
+ mongoTemplate.insertAll(records);
+ // 宸ュ崟鐢熸垚
+ uyErrorTypeCheckService.monitorQualifyCheck(records);
+ } else {
+ log.error("涓�鏈轰竴妗ｅ悎鏍肩巼鏁版嵁涓虹┖{}", data);
+ }
+ }
+ } else {
+ log.error("涓�鏈轰竴妗ｅ悎鏍肩巼鏁版嵁涓虹┖{}", jsonObject);
+ }
+ } else {
+ log.error("涓�鏈轰竴妗ｅ悎鏍肩巼鏁版嵁涓虹┖");
+ }
+ // 鏈湴娴嬭瘯
+// Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
+// uyErrorTypeCheckService.monitorQualifyCheck(mongoTemplate.find(query, MonitorQualifyResult.class));
log.info("缁撴潫涓�鏈轰竴妗ｅ悎鏍肩巼鏁版嵁鍚屾");
}
@@ -178,8 +180,9 @@
} else {
log.error("鐐逛綅鍦ㄧ嚎缁撴灉鏁版嵁涓虹┖");
}
- Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
- uyErrorTypeCheckService.videoOnlineCheck(mongoTemplate.find(query, VideoOnlineResult.class));
+ // 鏈湴娴嬭瘯
+// Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
+// uyErrorTypeCheckService.videoOnlineCheck(mongoTemplate.find(query, VideoOnlineResult.class));
log.info("缁撴潫鎵ц鐐逛綅鍦ㄧ嚎鏁版嵁鍚屾");
}
@@ -213,44 +216,12 @@
// log.error("褰曞儚鍙敤鏁版嵁涓虹┖{}", jsonObject);
// }
// }
+ // 鏈湴娴嬭瘯
Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
uyErrorTypeCheckService.recordMetaDSumCheck(mongoTemplate.find(query, RecordMetaDSumResult.class));
log.info("缁撴潫鎵ц褰曞儚鍙敤鏁版嵁鍚屾");
}
- //瑙嗛鏍囨敞
- public void OsdMonitorTask() {
- //瑙嗛鏍囨敞
- log.info("寮�濮嬫墽琛岃棰戞爣娉ㄦ暟鎹悓姝�");
- OsdMonitorParam param = new OsdMonitorParam();
- param.setPageNum(ApiConstants.PageNo);
- param.setPageSize(ApiConstants.PageSize);
- JSONObject jsonObject = uyClient.osdMonitorList(param, tenantId);
- if (jsonObject != null) {
- if (ApiConstants.UYSuccessCodeStr.equals(jsonObject.getString("code"))) {
- JSONObject data = jsonObject.getJSONObject("data");
- if (data != null) {
- List<OsdMonitorResult> records = data.getList("records", OsdMonitorResult.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, OsdMonitorResult.class);
- //瀛樻斁鍦╩ongo涓�
- mongoTemplate.insertAll(records);
- } else {
- log.error("瑙嗛鏍囨敞鏁版嵁涓虹┖{}", data);
- }
- } else {
- log.error("瑙嗛鏍囨敞鏁版嵁涓虹┖{}", jsonObject);
- }
- } else {
- log.error("瑙嗛鏍囨敞鏁版嵁涓虹┖{}", jsonObject);
- }
- } else {
- log.error("瑙嗛鏍囨敞鏁版嵁涓虹┖");
- }
- log.info("缁撴潫鎵ц瑙嗛鏍囨敞鏁版嵁鍚屾");
- }
+
}
--
Gitblit v1.8.0