HC_YFZX
/
LASAPlatform
11
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改机场推流到175

feature-flyModify
陈伟 2025-09-11 14:49:56 +08:00
parent dbf58ef741
commit 7a5f0c5f77
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs
View File

@ -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;