From dd9c64d7a8db1e11b77b08a3ab5f96cc9808c3b1 Mon Sep 17 00:00:00 2001
From: lin <648540858@qq.com>
Date: Mon, 26 May 2025 18:04:02 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E8=AE=BE=E5=A4=87=E7=8A=B6?=
 =?UTF-8?q?=E6=80=81=E4=BF=9D=E6=8C=81=E4=BB=BB=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 README.md                                     | 10 ++---
 .../iot/vmp/common/DeviceStatusCallback.java  |  7 +++
 .../task/deviceStatus/DeviceStatusTask.java   | 43 +++++++++++++++++++
 .../deviceStatus/DeviceStatusTaskInfo.java    | 17 ++++++++
 4 files changed, 72 insertions(+), 5 deletions(-)
 create mode 100644 src/main/java/com/genersoft/iot/vmp/common/DeviceStatusCallback.java
 create mode 100644 src/main/java/com/genersoft/iot/vmp/gb28181/task/deviceStatus/DeviceStatusTask.java
 create mode 100644 src/main/java/com/genersoft/iot/vmp/gb28181/task/deviceStatus/DeviceStatusTaskInfo.java

diff --git a/README.md b/README.md
index 1bd09a39b..6e2348b26 100644
--- a/README.md
+++ b/README.md
@@ -16,11 +16,11 @@ WEB VIDEO PLATFORM是一个基于GB28181-2016标准实现的开箱即用的网
 前端页面基于vue-admin-template构建 [https://github.com/PanJiaChen/vue-admin-template?tab=readme-ov-file](https://github.com/PanJiaChen/vue-admin-template?tab=readme-ov-file)  
 
 # 应用场景：
-支持浏览器无插件播放摄像头视频。
-支持国标设备(摄像机、平台、NVR等)设备接入
-支持rtsp, rtmp，直播设备设备接入，充分利旧。
-支持国标级联。多平台级联。跨网视频预览。
-支持跨网网闸平台互联。
+- 支持浏览器无插件播放摄像头视频。
+- 支持国标设备(摄像机、平台、NVR等)设备接入
+- 支持rtsp, rtmp，直播设备设备接入，充分利旧。
+- 支持国标级联。多平台级联。跨网视频预览。
+- 支持跨网网闸平台互联。
 
 
 # 文档
diff --git a/src/main/java/com/genersoft/iot/vmp/common/DeviceStatusCallback.java b/src/main/java/com/genersoft/iot/vmp/common/DeviceStatusCallback.java
new file mode 100644
index 000000000..9ee9b9edb
--- /dev/null
+++ b/src/main/java/com/genersoft/iot/vmp/common/DeviceStatusCallback.java
@@ -0,0 +1,7 @@
+package com.genersoft.iot.vmp.common;
+
+import com.genersoft.iot.vmp.gb28181.bean.SipTransactionInfo;
+
+public interface DeviceStatusCallback {
+    public void run(String deviceId, SipTransactionInfo transactionInfo);
+}
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/task/deviceStatus/DeviceStatusTask.java b/src/main/java/com/genersoft/iot/vmp/gb28181/task/deviceStatus/DeviceStatusTask.java
new file mode 100644
index 000000000..f08150899
--- /dev/null
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/task/deviceStatus/DeviceStatusTask.java
@@ -0,0 +1,43 @@
+package com.genersoft.iot.vmp.gb28181.task.deviceStatus;
+
+import com.genersoft.iot.vmp.common.DeviceStatusCallback;
+import com.genersoft.iot.vmp.gb28181.bean.SipTransactionInfo;
+import lombok.Data;
+import org.jetbrains.annotations.NotNull;
+
+import java.util.concurrent.Delayed;
+import java.util.concurrent.TimeUnit;
+
+@Data
+public abstract class DeviceStatusTask implements Delayed {
+
+    private String deviceId;
+
+    private DeviceStatusCallback callback;
+
+    private SipTransactionInfo transactionInfo;
+
+    /**
+     * 超时时间(单位： 毫秒)
+     */
+    private long delayTime;
+
+    public abstract void expired();
+
+    @Override
+    public long getDelay(@NotNull TimeUnit unit) {
+        return unit.convert(delayTime - System.currentTimeMillis(), TimeUnit.MILLISECONDS);
+    }
+
+    @Override
+    public int compareTo(@NotNull Delayed o) {
+        return (int) (this.getDelay(TimeUnit.MILLISECONDS) - o.getDelay(TimeUnit.MILLISECONDS));
+    }
+
+    public DeviceStatusTaskInfo getInfo(){
+        DeviceStatusTaskInfo taskInfo = new DeviceStatusTaskInfo();
+        taskInfo.setTransactionInfo(transactionInfo);
+        taskInfo.setDeviceId(deviceId);
+        return taskInfo;
+    }
+}
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/task/deviceStatus/DeviceStatusTaskInfo.java b/src/main/java/com/genersoft/iot/vmp/gb28181/task/deviceStatus/DeviceStatusTaskInfo.java
new file mode 100644
index 000000000..2e6380436
--- /dev/null
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/task/deviceStatus/DeviceStatusTaskInfo.java
@@ -0,0 +1,17 @@
+package com.genersoft.iot.vmp.gb28181.task.deviceStatus;
+
+import com.genersoft.iot.vmp.gb28181.bean.SipTransactionInfo;
+import lombok.Data;
+
+@Data
+public class DeviceStatusTaskInfo{
+
+    private String deviceId;
+
+    private SipTransactionInfo transactionInfo;
+
+    /**
+     * 过期时间
+     */
+    private long expireTime;
+}