From e66b83965943e8471d5e2fb616899e0c8271e840 Mon Sep 17 00:00:00 2001
From: ydpd <ydpd@163.com>
Date: Wed, 2 Mar 2022 00:02:03 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=86=85=E5=AD=98=E6=B3=84?=
 =?UTF-8?q?=E9=9C=B2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../iot/vmp/gb28181/event/SipSubscribe.java   | 21 ++++++++++++++-----
 1 file changed, 16 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/event/SipSubscribe.java b/src/main/java/com/genersoft/iot/vmp/gb28181/event/SipSubscribe.java
index a00ac630..4644fb0a 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/event/SipSubscribe.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/event/SipSubscribe.java
@@ -23,7 +23,8 @@ public class SipSubscribe {
 
     private Map<String, SipSubscribe.Event> okSubscribes = new ConcurrentHashMap<>();
 
-    private Map<String, Date> timeSubscribes = new ConcurrentHashMap<>();
+    private Map<String, Date> okTimeSubscribes = new ConcurrentHashMap<>();
+    private Map<String, Date> errorTimeSubscribes = new ConcurrentHashMap<>();
 
 //    @Scheduled(cron="*/5 * * * * ?")   //每五秒执行一次
 //    @Scheduled(fixedRate= 100 * 60 * 60 )
@@ -33,14 +34,24 @@ public class SipSubscribe {
         Calendar calendar = Calendar.getInstance();
         calendar.setTime(new Date());
         calendar.set(Calendar.HOUR, calendar.get(Calendar.HOUR) - 1);
-        for (String key : timeSubscribes.keySet()) {
-            if (timeSubscribes.get(key).before(calendar.getTime())){
+        for (String key : okTimeSubscribes.keySet()) {
+            if (okTimeSubscribes.get(key).before(calendar.getTime())){
                 logger.info("[定时任务] 清理过期的订阅信息： {}", key);
-                errorSubscribes.remove(key);
                 okSubscribes.remove(key);
-                timeSubscribes.remove(key);
+                okTimeSubscribes.remove(key);
             }
         }
+        for (String key : errorTimeSubscribes.keySet()) {
+            if (errorTimeSubscribes.get(key).before(calendar.getTime())){
+                logger.info("[定时任务] 清理过期的订阅信息： {}", key);
+                errorSubscribes.remove(key);
+                errorTimeSubscribes.remove(key);
+            }
+        }
+        logger.info("okTimeSubscribes.size:{}",okTimeSubscribes.size());
+        logger.info("okSubscribes.size:{}",okSubscribes.size());
+        logger.info("errorTimeSubscribes.size:{}",errorTimeSubscribes.size());
+        logger.info("errorSubscribes.size:{}",errorSubscribes.size());
     }
 
     public interface Event {