g82tt/ThingsGateway
1
0
Fork 0
mirror of https://gitee.com/ThingsGateway/ThingsGateway.git synced 2025-10-29 14:43:59 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: mqttcollect 重载变量寄存器

Browse Source
This commit is contained in:
Diego
2025-04-11 11:01:29 +08:00
parent 0a6651ac11
commit a7ee6d78b5
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/Plugin/ThingsGateway.Plugin.Mqtt/MqttCollect/MqttCollect.cs
View File

@@ -101,6 +101,7 @@ public partial class MqttCollect : CollectBase
protected override async Task<List<VariableSourceRead>> ProtectedLoadSourceReadAsync(List<VariableRuntime> deviceVariables)
{
await Task.CompletedTask.ConfigureAwait(false);
TopicItemDict.Clear();
if (deviceVariables.Count > 0)
{
var dataResult = new List<VariableSourceRead>();
@@ -123,7 +124,7 @@ public partial class MqttCollect : CollectBase
//获取主题，负载路径list的字典
foreach (var group in groups)
{
TopicItemDict.Add(group.Key, new());
TopicItemDict.TryAdd(group.Key, new());
TopicItemDict[group.Key] = new();
var sourVars = new VariableSourceRead()
{