From 70210b0eb0c58e1779fd89cbcf0909154d7d4936 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期六, 01 七月 2023 11:45:18 +0800
Subject: [PATCH] 基本完成优先级排队报警逻辑
---
ard-work/src/main/java/com/ruoyi/alarm/globalAlarm/service/impl/QueueTaskExecutor.java | 12 +++++++++---
1 files changed, 9 insertions(+), 3 deletions(-)
diff --git a/ard-work/src/main/java/com/ruoyi/alarm/globalAlarm/service/impl/QueueTaskExecutor.java b/ard-work/src/main/java/com/ruoyi/alarm/globalAlarm/service/impl/QueueTaskExecutor.java
index d4c5e1f..659afcc 100644
--- a/ard-work/src/main/java/com/ruoyi/alarm/globalAlarm/service/impl/QueueTaskExecutor.java
+++ b/ard-work/src/main/java/com/ruoyi/alarm/globalAlarm/service/impl/QueueTaskExecutor.java
@@ -23,7 +23,7 @@
*/
@Component
-@Slf4j
+@Slf4j(topic = "guideQueue")
public class QueueTaskExecutor {
@Resource
IHikClientService hikClientService;
@@ -42,12 +42,18 @@
cmd.setExpired(30);
cmd.setRecordBucketName("record");
cmd.setRecordObjectName("alarm");
+ log.debug("寮�濮嬪紩瀵�");
boolean guideRes = hikClientService.guideTargetPosition(cmd);
if (guideRes) {
+ log.debug("寮曞鎴愬姛");
hikClientService.controlLock(cmd);//涓婇攣
cmd.setEnable(true);//寮�濮嬪綍鍍�
hikClientService.recordToMinio(cmd);//寮�濮嬪綍鍍�
- Thread.sleep(30000);
+ try {
+ Thread.sleep(30000);
+ } catch (InterruptedException e) {
+ log.info("褰撳墠浠诲姟ID"+guideTask.getAlarmId()+"绾跨▼琚粓姝�");
+ }
cmd.setEnable(false);//鍋滄褰曞儚
cmd.setUploadMinio(true);//涓婁紶minio
String url = hikClientService.recordToMinio(cmd);//鍋滄褰曞儚杩斿洖url
@@ -83,7 +89,7 @@
}
}
} catch (Exception ex) {
- log.info("鑷姩寮曞寮傚父:" + ex.getMessage());
+ log.info("绾跨▼浠诲姟寮傚父:" + ex.getMessage());
}
}
}
--
Gitblit v1.9.3