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 _logger; private readonly ConcurrentDictionary _processedMessages = new(); - private readonly ConcurrentDictionary liveInfo = new(); + private readonly ConcurrentDictionary _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;