From f34143df6d376c3444f8f2f01d991db995c25438 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: Fri, 12 Apr 2024 10:36:18 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9totalReaderCount=E7=B1=BB?=
 =?UTF-8?q?=E5=9E=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../iot/vmp/media/zlm/dto/StreamPushItem.java          | 10 +++++-----
 .../iot/vmp/service/impl/StreamPushServiceImpl.java    |  2 +-
 .../vmp/service/impl/StreamPushUploadFileHandler.java  |  2 +-
 .../redisMsg/RedisPushStreamStatusListMsgListener.java |  2 +-
 .../vmp/vmanager/streamPush/StreamPushController.java  |  2 +-
 5 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/media/zlm/dto/StreamPushItem.java b/src/main/java/com/genersoft/iot/vmp/media/zlm/dto/StreamPushItem.java
index 797286fe..f498479d 100755
--- a/src/main/java/com/genersoft/iot/vmp/media/zlm/dto/StreamPushItem.java
+++ b/src/main/java/com/genersoft/iot/vmp/media/zlm/dto/StreamPushItem.java
@@ -35,7 +35,7 @@ public class StreamPushItem extends GbStream implements Comparable<StreamPushIte
      * 观看总人数，包括hls/rtsp/rtmp/http-flv/ws-flv
      */
     @Schema(description = "观看总人数")
-    private String totalReaderCount;
+    private Integer totalReaderCount;
 
     /**
      * 协议 包括hls/rtsp/rtmp/http-flv/ws-flv
@@ -159,7 +159,7 @@ public class StreamPushItem extends GbStream implements Comparable<StreamPushIte
         streamPushItem.setStream(streamInfo.getStream());
         streamPushItem.setAliveSecond(streamInfo.getMediaInfo().getAliveSecond());
 //        streamPushItem.setOriginSock(streamInfo.getMediaInfo().getOriginSock());
-        streamPushItem.setTotalReaderCount(streamInfo.getMediaInfo().getReaderCount() + "");
+        streamPushItem.setTotalReaderCount(streamInfo.getMediaInfo().getReaderCount());
         streamPushItem.setOriginType(streamInfo.getOriginType());
 //        streamPushItem.setOriginTypeStr(streamInfo.getMediaInfo().getOriginTypeStr());
 //        streamPushItem.setOriginUrl(streamInfo.getMediaInfo().getOriginUrl());
@@ -180,7 +180,7 @@ public class StreamPushItem extends GbStream implements Comparable<StreamPushIte
         streamPushItem.setStream(event.getStream());
         streamPushItem.setAliveSecond(event.getMediaInfo().getAliveSecond());
 //        streamPushItem.setOriginSock(streamInfo.getMediaInfo().getOriginSock());
-        streamPushItem.setTotalReaderCount(event.getMediaInfo().getReaderCount() + "");
+        streamPushItem.setTotalReaderCount(event.getMediaInfo().getReaderCount());
         streamPushItem.setOriginType(event.getMediaInfo().getOriginType());
 //        streamPushItem.setOriginTypeStr(streamInfo.getMediaInfo().getOriginTypeStr());
 //        streamPushItem.setOriginUrl(streamInfo.getMediaInfo().getOriginUrl());
@@ -242,11 +242,11 @@ public class StreamPushItem extends GbStream implements Comparable<StreamPushIte
         this.stream = stream;
     }
 
-    public String getTotalReaderCount() {
+    public Integer getTotalReaderCount() {
         return totalReaderCount;
     }
 
-    public void setTotalReaderCount(String totalReaderCount) {
+    public void setTotalReaderCount(Integer totalReaderCount) {
         this.totalReaderCount = totalReaderCount;
     }
 
diff --git a/src/main/java/com/genersoft/iot/vmp/service/impl/StreamPushServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/service/impl/StreamPushServiceImpl.java
index c849358b..7a149402 100755
--- a/src/main/java/com/genersoft/iot/vmp/service/impl/StreamPushServiceImpl.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/impl/StreamPushServiceImpl.java
@@ -217,7 +217,7 @@ public class StreamPushServiceImpl implements IStreamPushService {
         streamPushItem.setStream(item.getStream());
         streamPushItem.setAliveSecond(item.getAliveSecond());
         streamPushItem.setOriginSock(item.getOriginSock());
-        streamPushItem.setTotalReaderCount(item.getTotalReaderCount() + "");
+        streamPushItem.setTotalReaderCount(item.getTotalReaderCount());
         streamPushItem.setOriginType(item.getOriginType());
         streamPushItem.setOriginTypeStr(item.getOriginTypeStr());
         streamPushItem.setOriginUrl(item.getOriginUrl());
diff --git a/src/main/java/com/genersoft/iot/vmp/service/impl/StreamPushUploadFileHandler.java b/src/main/java/com/genersoft/iot/vmp/service/impl/StreamPushUploadFileHandler.java
index a1271593..2c3a3fa4 100755
--- a/src/main/java/com/genersoft/iot/vmp/service/impl/StreamPushUploadFileHandler.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/impl/StreamPushUploadFileHandler.java
@@ -137,7 +137,7 @@ public class StreamPushUploadFileHandler extends AnalysisEventListener<StreamPus
         streamPushItem.setName(streamPushExcelDto.getName());
         streamPushItem.setOriginType(2);
         streamPushItem.setOriginTypeStr("rtsp_push");
-        streamPushItem.setTotalReaderCount("0");
+        streamPushItem.setTotalReaderCount(0);
         streamPushItem.setPlatformId(streamPushExcelDto.getPlatformId());
         streamPushItem.setCatalogId(streamPushExcelDto.getCatalogId());
 
diff --git a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamStatusListMsgListener.java b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamStatusListMsgListener.java
index 49ffd75f..e65ea8d0 100755
--- a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamStatusListMsgListener.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamStatusListMsgListener.java
@@ -84,7 +84,7 @@ public class RedisPushStreamStatusListMsgListener implements MessageListener {
                                 streamPushItem.setMediaServerId(mediaServerService.getDefaultMediaServer().getId());
                                 streamPushItem.setOriginType(2);
                                 streamPushItem.setOriginTypeStr("rtsp_push");
-                                streamPushItem.setTotalReaderCount("0");
+                                streamPushItem.setTotalReaderCount(0);
                                 streamPushItemForSave.add(streamPushItem);
                                 allGBId.put(streamPushItem.getGbId(), streamPushItem);
                             } else {
diff --git a/src/main/java/com/genersoft/iot/vmp/vmanager/streamPush/StreamPushController.java b/src/main/java/com/genersoft/iot/vmp/vmanager/streamPush/StreamPushController.java
index 309cd694..2ea4b873 100755
--- a/src/main/java/com/genersoft/iot/vmp/vmanager/streamPush/StreamPushController.java
+++ b/src/main/java/com/genersoft/iot/vmp/vmanager/streamPush/StreamPushController.java
@@ -274,7 +274,7 @@ public class StreamPushController {
         stream.setStatus(false);
         stream.setPushIng(false);
         stream.setAliveSecond(0L);
-        stream.setTotalReaderCount("0");
+        stream.setTotalReaderCount(0);
         if (!streamPushService.add(stream)) {
             throw new ControllerException(ErrorCode.ERROR100);
         }