优化延时任务到期时间更新

src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/DeviceServiceImpl.java

@@ -506,7 +506,11 @@ public class DeviceServiceImpl implements IDeviceService, CommandLineRunner {
         if (device == null || device.getSubscribeCycleForCatalog() < 0) {
             return false;
         }
-        log.info("[添加目录订阅] 设备 {}", device.getDeviceId());
+        if (transactionInfo == null) {
+            log.info("[添加目录订阅] 设备 {}", device.getDeviceId());
+        }else {
+            log.info("[目录订阅续期] 设备 {}", device.getDeviceId());
+        }
         try {
             sipCommander.catalogSubscribe(device, transactionInfo, eventResult -> {
                 ResponseEvent event = (ResponseEvent) eventResult.event;
@@ -566,7 +570,11 @@ public class DeviceServiceImpl implements IDeviceService, CommandLineRunner {
 
     @Override
     public boolean addMobilePositionSubscribe(@NotNull Device device, SipTransactionInfo transactionInfo) {
-        log.info("[添加移动位置订阅] 设备 {}", device.getDeviceId());
+        if (transactionInfo == null) {
+            log.info("[添加移动位置订阅] 设备 {}", device.getDeviceId());
+        }else {
+            log.info("[移动位置订阅续期] 设备 {}", device.getDeviceId());
+        }
         try {
             sipCommander.mobilePositionSubscribe(device, transactionInfo, eventResult -> {
                 ResponseEvent event = (ResponseEvent) eventResult.event;

src/main/java/com/genersoft/iot/vmp/gb28181/task/deviceStatus/DeviceStatusTaskRunner.java

@@ -94,14 +94,7 @@ public class DeviceStatusTaskRunner {
             return false;
         }
         log.debug("[更新状态任务时间] 编号： {}", key);
-        if (delayQueue.contains(task)) {
-            boolean remove = delayQueue.remove(task);
-            if (!remove) {
-                log.info("[更新状态任务时间] 从延时队列内移除失败： {}", key);
-            }
-        }
         task.setDelayTime(expirationTime);
-        delayQueue.offer(task);
         String redisKey = String.format("%s_%s_%s", prefix, userSetting.getServerId(), task.getDeviceId());
         Duration duration = Duration.ofSeconds((expirationTime - System.currentTimeMillis())/1000);
         redisTemplate.expire(redisKey, duration);

src/main/java/com/genersoft/iot/vmp/gb28181/task/deviceSubscribe/SubscribeTaskRunner.java

@@ -94,14 +94,7 @@ public class SubscribeTaskRunner{
             return false;
         }
         log.info("[更新订阅任务时间] {}, 编号： {}", task.getName(), key);
-        if (delayQueue.contains(task)) {
-            boolean remove = delayQueue.remove(task);
-            if (!remove) {
-                log.info("[更新订阅任务时间] 从延时队列内移除失败： {}", key);
-            }
-        }
         task.setDelayTime(expirationTime);
-        delayQueue.offer(task);
         String redisKey = String.format("%s_%s_%s", prefix, userSetting.getServerId(), task.getKey());
         Duration duration = Duration.ofSeconds((expirationTime - System.currentTimeMillis())/1000);
         redisTemplate.expire(redisKey, duration);

src/main/java/com/genersoft/iot/vmp/gb28181/task/platformStatus/PlatformStatusTaskRunner.java

@@ -114,14 +114,7 @@ public class PlatformStatusTaskRunner {
             return false;
         }
         log.info("[更新平台注册任务时间] 平台上级编号： {}", platformServerId);
-        if (registerDelayQueue.contains(task)) {
-            boolean remove = registerDelayQueue.remove(task);
-            if (!remove) {
-                log.info("[更新平台注册任务时间] 从延时队列内移除失败： {}", platformServerId);
-            }
-        }
         task.setDelayTime(expirationTime);
-        registerDelayQueue.offer(task);
         String redisKey = String.format("%s_%s_%s", prefix, userSetting.getServerId(), platformServerId);
         Duration duration = Duration.ofSeconds((expirationTime - System.currentTimeMillis())/1000);
         redisTemplate.expire(redisKey, duration);
@@ -165,14 +158,7 @@ public class PlatformStatusTaskRunner {
             return false;
         }
         log.info("[更新平台心跳任务时间] 平台上级编号： {}", platformServerId);
-        if (keepaliveTaskDelayQueue.contains(task)) {
-            boolean remove = keepaliveTaskDelayQueue.remove(task);
-            if (!remove) {
-                log.info("[更新平台心跳任务时间] 从延时队列内移除失败： {}", platformServerId);
-            }
-        }
         task.setDelayTime(expirationTime);
-        keepaliveTaskDelayQueue.offer(task);
         return true;
     }
 

src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMRESTfulUtils.java

@@ -446,7 +446,6 @@ public class ZLMRESTfulUtils {
         BigDecimal bigDecimal = new BigDecimal(stamp);
         param.put("stamp", bigDecimal);
         param.put("schema", schema);
-        System.out.println(bigDecimal);
         return sendPost(mediaServer, "seekRecordStamp",param, null);
     }
 }

src/main/java/com/genersoft/iot/vmp/utils/DateUtil.java

@@ -15,7 +15,7 @@ import java.time.temporal.TemporalAccessor;
 
 import java.util.Locale;
 
-/**    
+/**
  * 全局时间工具类
  * @author lin
  */
@@ -70,7 +70,7 @@ public class DateUtil {
 	public static String yyyy_MM_dd_HH_mm_ssToISO8601(@NotNull String formatTime) {
         return formatterISO8601.format(formatter.parse(formatTime));
     }
-	
+
 	public static String ISO8601Toyyyy_MM_dd_HH_mm_ss(String formatTime) {
         // 三种日期格式都尝试，为了兼容不同厂家的日期格式
         if (verification(formatTime, formatterCompatibleISO8601)) {
@@ -198,11 +198,4 @@ public class DateUtil {
         return ChronoUnit.MILLIS.between(startInstant, endInstant);
     }
 
-
-
-    public static void main(String[] args) {
-        long difference = getDifference("2025-05-21 13:00:00", "2025-05-21 13:30:00")/1000;
-        System.out.println(difference);
-    }
-
 }

web/src/views/streamProxy/index.vue

@@ -259,7 +259,7 @@ export default {
         })
     },
     queryCloudRecords: function(row) {
-      this.$router.push(`/cloudRecordDetail/${row.app}/${row.stream}`)
+      this.$router.push(`/cloudRecord/detail/${row.app}/${row.stream}`)
     },
     deleteStreamProxy: function(row) {
       this.$confirm('确定删除此代理吗？', '提示', {

web/src/views/streamPush/index.vue

@@ -255,7 +255,7 @@ export default {
       this.getPushList()
     },
     queryCloudRecords: function(row) {
-      this.$router.push(`/cloudRecordDetail/${row.app}/${row.stream}`)
+      this.$router.push(`/cloudRecord/detail/${row.app}/${row.stream}`)
     },
     importChannel: function() {
       this.$refs.importChannel.openDialog(() => {})