From 7211da2b3ae401413bb6d3c2d4ca431cf17d4c7e Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期四, 29 八月 2024 16:27:05 +0800
Subject: [PATCH] 工单生成逻辑判断bug
---
ycl-server/src/main/java/com/ycl/task/UYTask.java | 55 ++++++++++++++++++++++---------------------------------
1 files changed, 22 insertions(+), 33 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 587d9bc..b910d85 100644
--- a/ycl-server/src/main/java/com/ycl/task/UYTask.java
+++ b/ycl-server/src/main/java/com/ycl/task/UYTask.java
@@ -4,12 +4,14 @@
import com.mongodb.client.result.DeleteResult;
import com.ycl.feign.UYClient;
import com.ycl.platform.domain.param.UY.*;
+import com.ycl.platform.domain.result.HK.FaceDeviceInspectionResult;
import com.ycl.platform.domain.result.UY.OneMachineFileResult;
import com.ycl.platform.domain.result.UY.OsdMonitorResult;
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.platform.service.UYErrorTypeCheckService;
import com.ycl.utils.DateUtils;
import constant.ApiConstants;
import lombok.extern.slf4j.Slf4j;
@@ -43,6 +45,9 @@
private IYwThresholdService ywThresholdService;
@Autowired
private ITMonitorService monitorService;
+ @Autowired
+ private UYErrorTypeCheckService uyErrorTypeCheckService;
+
@Value("${youYun.tenantId}")
private String tenantId;
@Value("${youYun.apikey}")
@@ -73,9 +78,11 @@
//濡傛灉浠婂ぉ瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
Query query = new Query(Criteria
.where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
- DeleteResult result = mongoTemplate.remove(query, QueryVqdResult.class);
+ DeleteResult result = mongoTemplate.remove(query, ImageDetectionResult.class);
//瀛樻斁鍦╩ongo涓�
mongoTemplate.insertAll(records);
+ // 宸ュ崟鐢熸垚
+ uyErrorTypeCheckService.imageDetectionCheck(records);
} else {
log.error("鍥惧儚鐩戞祴鏁版嵁涓虹┖{}", data);
}
@@ -88,40 +95,10 @@
} else {
log.error("鍥惧儚鐩戞祴鏁版嵁涓虹┖");
}
+// Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
+// uyErrorTypeCheckService.imageDetectionCheck(mongoTemplate.find(query, ImageDetectionResult.class));
log.info("缁撴潫鎵ц鍥惧儚鐩戞祴鏁版嵁鍚屾");
}
-
-// //涓�鏈轰竴妗�
-// public void monitorTask() {
-// // 涓�鏈轰竴妗ｆ敞鍐岀巼
-// // 妗ｆ鑰冩牳姣�
-// log.info("寮�濮嬫墽琛屼竴鏈轰竴妗ｆ暟鎹悓姝�");
-// OneMachineFileParam param = new OneMachineFileParam();
-// param.setOffset(ApiConstants.PageNo);
-// param.setLimit(ApiConstants.PageSize);
-// JSONObject jsonObject = uyClient.oneMachineFile(param);
-// if (jsonObject != null) {
-// JSONObject cameraList = jsonObject.getJSONObject("CameraList");
-// if (cameraList != null) {
-// List<OneMachineFileResult> data = cameraList.getList("data", OneMachineFileResult.class);
-// if (!CollectionUtils.isEmpty(data)) {
-// //濡傛灉浠婂ぉ瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
-// Query query = new Query(Criteria
-// .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
-// DeleteResult result = mongoTemplate.remove(query, OneMachineFileResult.class);
-// //瀛樻斁鍦╩ongo涓�
-// mongoTemplate.insertAll(data);
-// } else {
-// log.error("涓�鏈轰竴妗ｆ暟鎹负绌簕}", cameraList);
-// }
-// } else {
-// log.error("涓�鏈轰竴妗ｆ暟鎹负绌簕}", jsonObject);
-// }
-// } else {
-// log.error("涓�鏈轰竴妗ｆ暟鎹负绌�");
-// }
-// log.info("缁撴潫鎵ц涓�鏈轰竴妗ｆ暟鎹悓姝�");
-// }
//涓�鏈轰竴妗�
public void monitorQualifyTask() {
@@ -146,6 +123,8 @@
DeleteResult result = mongoTemplate.remove(query, MonitorQualifyResult.class);
//瀛樻斁鍦╩ongo涓�
mongoTemplate.insertAll(records);
+ // 宸ュ崟鐢熸垚
+ uyErrorTypeCheckService.monitorQualifyCheck(records);
} else {
log.error("涓�鏈轰竴妗ｅ悎鏍肩巼鏁版嵁涓虹┖{}", data);
}
@@ -156,6 +135,8 @@
} else {
log.error("涓�鏈轰竴妗ｅ悎鏍肩巼鏁版嵁涓虹┖");
}
+// Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
+// uyErrorTypeCheckService.monitorQualifyCheck(mongoTemplate.find(query, MonitorQualifyResult.class));
log.info("缁撴潫涓�鏈轰竴妗ｅ悎鏍肩巼鏁版嵁鍚屾");
}
@@ -183,6 +164,8 @@
DeleteResult result = mongoTemplate.remove(query, VideoOnlineResult.class);
//瀛樻斁鍦╩ongo涓�
mongoTemplate.insertAll(records);
+ // 宸ュ崟鐢熸垚
+ uyErrorTypeCheckService.videoOnlineCheck(records);
} else {
log.error("鐐逛綅鍦ㄧ嚎缁撴灉鏁版嵁涓虹┖{}", data);
}
@@ -195,6 +178,8 @@
} else {
log.error("鐐逛綅鍦ㄧ嚎缁撴灉鏁版嵁涓虹┖");
}
+// Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
+// uyErrorTypeCheckService.videoOnlineCheck(mongoTemplate.find(query, VideoOnlineResult.class));
log.info("缁撴潫鎵ц鐐逛綅鍦ㄧ嚎鏁版嵁鍚屾");
}
@@ -221,11 +206,15 @@
DeleteResult result = mongoTemplate.remove(query, RecordMetaDSumResult.class);
//瀛樻斁鍦╩ongo涓�
mongoTemplate.insertAll(records);
+ // 宸ュ崟鐢熸垚
+ uyErrorTypeCheckService.recordMetaDSumCheck(records);
}
} else {
log.error("褰曞儚鍙敤鏁版嵁涓虹┖{}", jsonObject);
}
}
+// Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
+// uyErrorTypeCheckService.recordMetaDSumCheck(mongoTemplate.find(query, RecordMetaDSumResult.class));
log.info("缁撴潫鎵ц褰曞儚鍙敤鏁版嵁鍚屾");
}
--
Gitblit v1.8.0