From 7a5f0c5f778b2f7c5992e0c3dc0a31d6ad8eb1b8 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E4=BC=9F?= <421281095@qq.com>
Date: Thu, 11 Sep 2025 14:49:56 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=9C=BA=E5=9C=BA=E6=8E=A8?=
 =?UTF-8?q?=E6=B5=81=E5=88=B0175?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs b/OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs
index d28a9f4..a5ec9b2 100644
--- a/OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs
+++ b/OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs
@@ -35,7 +35,7 @@ public class ConfigSubscribe : IJob
     private object _dockUploadFileLocker = new();
     private readonly ILogger<ConfigSubscribe> _logger;
     private readonly ConcurrentDictionary<string, DateTime> _processedMessages = new();
-    private readonly ConcurrentDictionary<string, string> liveInfo = new();
+    private readonly ConcurrentDictionary<string, string> _liveInfo = new();
     private readonly TimeSpan _deduplicationWindow = TimeSpan.FromMinutes(1);
 
     public ConfigSubscribe(MqttClientManager mqttClientManager, ISqlSugarClient sqlSugarClient,
@@ -106,8 +106,8 @@ public class ConfigSubscribe : IJob
         //_logger.LogInformation($"主题：{topic}\n消息：{message}");
         long code = 0;
         // rtmp://175.27.168.120:6019/live/
-        var rtmp = "rtmp://box.wisestcity.com:1935/live/7";
-        //var rtmp = "rtmp://175.27.168.120:6019/live/7";
+        //var rtmp = "rtmp://box.wisestcity.com:1935/live/7";
+        var rtmp = "rtmp://175.27.168.120:6019/live/7";
         switch (tempStr)
         {
             case "thing/product/*/requests":
@@ -664,7 +664,7 @@ public class ConfigSubscribe : IJob
                                     var topicRequest = $"thing/product/{sn}/services";
                                     // 开启直播
                                     await _mqttClientManager.PublishAsync(topicRequest, param);
-                                    liveInfo[$"{tid}{bid}"] = taskAssign1.TaskId;
+                                    _liveInfo[$"{tid}{bid}"] = taskAssign1.TaskId;
                                 }
                             }
 
@@ -719,8 +719,8 @@ public class ConfigSubscribe : IJob
                         _logger.LogDebug($"开启直播成功 {message}");
                         // 关于直播是否开启成功
                         // 取得taskid 然后从liveInfo中移除
-                        var tempTaskId = liveInfo[$"{result.tid}{result.bid}"];
-                        liveInfo.TryRemove($"{result.tid}{result.bid}", out _);
+                        var tempTaskId = _liveInfo[$"{result.tid}{result.bid}"];
+                        _liveInfo.TryRemove($"{result.tid}{result.bid}", out _);
                         var req = new CallAiModel { TaskId = tempTaskId, RtmpUrl = rtmp };
                         await _manageApp.CallAiModel(req);
                         break;