From 268869c6a1ad052e358ee119ff892057a52725c0 Mon Sep 17 00:00:00 2001
From: wendy512 <wendy512@yeah.net>
Date: 星期四, 29 二月 2024 21:10:56 +0800
Subject: [PATCH] bugfix：修复紫光华智录像查询返回StartTime、EndTime为2024-02-21T11:10:36+08:00，兼容多种不同日期格式
---
src/main/java/com/genersoft/iot/vmp/gb28181/session/VideoStreamSessionManager.java | 27 +++++++++++++++++++++++++++
1 files changed, 27 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/session/VideoStreamSessionManager.java b/src/main/java/com/genersoft/iot/vmp/gb28181/session/VideoStreamSessionManager.java
index 1c00dc3..24d4ef3 100755
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/session/VideoStreamSessionManager.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/session/VideoStreamSessionManager.java
@@ -75,6 +75,33 @@
return (SsrcTransaction)redisTemplate.opsForValue().get(scanResult.get(0));
}
+ public SsrcTransaction getSsrcTransactionByCallId(String callId){
+
+ if (ObjectUtils.isEmpty(callId)) {
+ return null;
+ }
+ String key = VideoManagerConstants.MEDIA_TRANSACTION_USED_PREFIX + userSetting.getServerId() + "_*_*_" + callId+ "_*";
+ List<Object> scanResult = RedisUtil.scan(redisTemplate, key);
+ if (!scanResult.isEmpty()) {
+ return (SsrcTransaction)redisTemplate.opsForValue().get(scanResult.get(0));
+ }else {
+ key = VideoManagerConstants.MEDIA_TRANSACTION_USED_PREFIX + userSetting.getServerId() + "_*_*_play_*";
+ scanResult = RedisUtil.scan(redisTemplate, key);
+ if (scanResult.isEmpty()) {
+ return null;
+ }
+ for (Object keyObj : scanResult) {
+ SsrcTransaction ssrcTransaction = (SsrcTransaction)redisTemplate.opsForValue().get(keyObj);
+ if (ssrcTransaction.getSipTransactionInfo() != null &&
+ ssrcTransaction.getSipTransactionInfo().getCallId().equals(callId)) {
+ return ssrcTransaction;
+ }
+ }
+ return null;
+ }
+
+ }
+
public List<SsrcTransaction> getSsrcTransactionForAll(String deviceId, String channelId, String callId, String stream){
if (ObjectUtils.isEmpty(deviceId)) {
deviceId ="*";
--
Gitblit v1.8.0