From a7c7965a518359a1c81bde0a8c451f2fc1cc25fe Mon Sep 17 00:00:00 2001 From: zhangjian <zhangjianrock@163.com> Date: 星期五, 07 七月 2023 16:31:40 +0800 Subject: [PATCH] 无人机转发接口 --- ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/AlarmTask.java | 26 +++++++++++++++++++++----- 1 files changed, 21 insertions(+), 5 deletions(-) diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/AlarmTask.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/AlarmTask.java index 16d4594..1dc3ebe 100644 --- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/AlarmTask.java +++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/AlarmTask.java @@ -1,11 +1,15 @@ package com.ruoyi.quartz.task; +import com.ruoyi.alarm.globalAlarm.domain.GuidePriorityQueue; +import com.ruoyi.alarm.globalAlarm.domain.GuideTask; import com.ruoyi.alarm.globalAlarm.service.IGlobalAlarmService; import com.ruoyi.alarm.stealAlarm.domain.ArdAlarmStealelec; import com.ruoyi.alarm.stealAlarm.service.IStealElecAlarmService; import com.ruoyi.common.core.domain.entity.SysUser; import com.ruoyi.common.utils.LonlatConver; +import com.ruoyi.common.utils.spring.SpringUtils; import com.ruoyi.common.websocket.util.WebSocketUtils; +import com.ruoyi.device.camera.service.IArdCamerasService; import com.ruoyi.system.service.ISysUserService; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; @@ -13,6 +17,7 @@ import javax.annotation.Resource; import java.text.SimpleDateFormat; import java.util.*; +import java.util.concurrent.PriorityBlockingQueue; import static com.ruoyi.common.websocket.util.WebSocketUtils.ONLINE_USER_SESSIONS; @@ -24,11 +29,9 @@ * @Version: 1.0 **/ @Component("AlarmTask") -@Slf4j(topic = "AlarmTask") +@Slf4j public class AlarmTask { - @Resource - IGlobalAlarmService globalAlarmService; /** * @鎻忚堪 瀹氭椂鎺ㄩ�佹墍鏈夋姤璀︾殑鐐逛綅鏁伴噺 * @鍙傛暟 [] @@ -38,9 +41,22 @@ * @淇敼浜哄拰鍏跺畠淇℃伅 */ public void globalAlarmCountPush() { - Map<String, Integer> stringIntegerMap = globalAlarmService.selectAlarmLogsCount(); + IGlobalAlarmService globalAlarmService = SpringUtils.getBean(IGlobalAlarmService.class); + Map<String, Object> stringIntegerMap = globalAlarmService.selectAlarmLogsCount(); if (ONLINE_USER_SESSIONS.size() > 0) { WebSocketUtils.sendMessageAll(stringIntegerMap); } } -} + /** + * 瀹氭椂娓呯┖寮曞闃熷垪 + * 鍒樿嫃涔� + * 2023/7/1 10:41 + */ + public void clearGuideQueue() { + log.info("瀹氭椂娓呯悊寮曞闃熷垪"); + for(PriorityBlockingQueue<GuideTask> guideQueue:GuidePriorityQueue.cameraQueueMap.values()) + { + guideQueue.clear(); + } + } +} \ No newline at end of file -- Gitblit v1.9.3