修复过期时间设置异常

This commit is contained in:
lin 2025-08-07 17:31:51 +08:00
parent 5c25385d29
commit 45509372bd
7 changed files with 7 additions and 14 deletions

View File

@ -11,7 +11,7 @@ public class DeviceStatusTaskInfo{
private SipTransactionInfo transactionInfo; private SipTransactionInfo transactionInfo;
/** /**
* 过期时间 * 过期时间,单位毫秒
*/ */
private long expireTime; private long expireTime;
} }

View File

@ -118,7 +118,7 @@ public class DeviceStatusTaskRunner {
if (taskInfo == null) { if (taskInfo == null) {
continue; continue;
} }
Long expire = redisTemplate.getExpire(redisKey); Long expire = redisTemplate.getExpire(redisKey, TimeUnit.MILLISECONDS);
taskInfo.setExpireTime(expire); taskInfo.setExpireTime(expire);
result.add(taskInfo); result.add(taskInfo);
} }

View File

@ -15,7 +15,7 @@ public class SubscribeTaskInfo {
private String key; private String key;
/** /**
* 过期时间 * 过期时间单位
*/ */
private long expireTime; private long expireTime;

View File

@ -118,7 +118,7 @@ public class SubscribeTaskRunner{
if (taskInfo == null) { if (taskInfo == null) {
continue; continue;
} }
Long expire = redisTemplate.getExpire(redisKey); Long expire = redisTemplate.getExpire(redisKey, TimeUnit.SECONDS);
taskInfo.setExpireTime(expire); taskInfo.setExpireTime(expire);
result.add(taskInfo); result.add(taskInfo);
} }

View File

@ -1,15 +1,8 @@
package com.genersoft.iot.vmp.gb28181.task.platformStatus; package com.genersoft.iot.vmp.gb28181.task.platformStatus;
import com.genersoft.iot.vmp.common.CommonCallback;
import com.genersoft.iot.vmp.gb28181.bean.SipTransactionInfo; import com.genersoft.iot.vmp.gb28181.bean.SipTransactionInfo;
import lombok.Data; import lombok.Data;
import lombok.Getter;
import lombok.Setter;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.jetbrains.annotations.NotNull;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;
/** /**
* 平台注册任务可序列化的信息 * 平台注册任务可序列化的信息
@ -23,7 +16,7 @@ public class PlatformRegisterTaskInfo{
private SipTransactionInfo sipTransactionInfo; private SipTransactionInfo sipTransactionInfo;
/** /**
* 过期时间 * 过期时间单位 毫秒
*/ */
private long expireTime; private long expireTime;
} }

View File

@ -179,7 +179,7 @@ public class PlatformStatusTaskRunner {
if (taskInfo == null) { if (taskInfo == null) {
continue; continue;
} }
Long expire = redisTemplate.getExpire(redisKey); Long expire = redisTemplate.getExpire(redisKey, TimeUnit.MILLISECONDS);
taskInfo.setExpireTime(expire); taskInfo.setExpireTime(expire);
result.add(taskInfo); result.add(taskInfo);
} }

View File

@ -2,4 +2,4 @@ spring:
application: application:
name: wvp name: wvp
profiles: profiles:
active: 1078 active: 274-dev