| | |
| | | * @修改人和其它信息 |
| | | */ |
| | | public void globalAlarmCountPush() { |
| | | IGlobalAlarmService globalAlarmService = SpringUtils.getBean(IGlobalAlarmService.class); |
| | | Map<String, Object> stringIntegerMap = globalAlarmService.selectAlarmLogsCount(); |
| | | if (ONLINE_USER_SESSIONS.size() > 0) { |
| | | try { |
| | | IGlobalAlarmService globalAlarmService = SpringUtils.getBean(IGlobalAlarmService.class); |
| | | Map<String, Object> stringIntegerMap = globalAlarmService.selectAlarmLogsCount(); |
| | | if (ONLINE_USER_SESSIONS.size() > 0) { |
| | | WebSocketUtils.sendMessageAll(stringIntegerMap); |
| | | } |
| | | } catch (Exception ex) { |
| | | log.error("定时推送所有报警的点位数量异常:" + ex.getMessage()); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 定时清空引导队列 |
| | | * 刘苏义 |
| | | * 2023/7/1 10:41 |
| | | */ |
| | | public void clearGuideQueue() { |
| | | log.info("定时清理引导队列"); |
| | | for(PriorityBlockingQueue<GuideTask> guideQueue:GuidePriorityQueue.cameraQueueMap.values()) |
| | | { |
| | | guideQueue.clear(); |
| | | try { |
| | | log.info("定时清理引导队列"); |
| | | for (PriorityBlockingQueue<GuideTask> guideQueue : GuidePriorityQueue.cameraQueueMap.values()) { |
| | | guideQueue.clear(); |
| | | } |
| | | } catch (Exception ex) { |
| | | log.error("定时清空引导队列:" + ex.getMessage()); |
| | | } |
| | | } |
| | | } |