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

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

@@ -198,4 +198,11 @@ 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(`/cloudRecord/detail/${row.app}/${row.stream}`)
+      this.$router.push(`/cloudRecordDetail/${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(`/cloudRecord/detail/${row.app}/${row.stream}`)
+      this.$router.push(`/cloudRecordDetail/${row.app}/${row.stream}`)
     },
     importChannel: function() {
       this.$refs.importChannel.openDialog(() => {})