GithubStar/ThingsGateway
1
0
Fork 0
mirror of https://github.com/ThingsGateway/ThingsGateway.git synced 2026-10-23 17:12:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

update iotSharpClient

Browse Source
This commit is contained in:
2248356998 qq.com
2023-04-04 11:07:05 +08:00
parent 651eb295a4
commit 202c511cfa
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Plugins/ThingsGateway.Mqtt/IotSharp/IotSharpClient.cs
+9 -2
View File
@@ -335,7 +335,8 @@ namespace ThingsGateway.Mqtt
}
private static DateTime timeSpan = new DateTime(1970, 1, 1, 0, 0, 0);
public override async Task ExecuteAsync(CancellationToken cancellationToken)
{
try
@@ -350,11 +351,17 @@ namespace ThingsGateway.Mqtt
{
try
{
Dictionary<string, string> nameValueDict = new();
foreach (var pair in item)
{
//只用最新的变量值
nameValueDict.AddOrUpdate(pair.name,pair.value);
}
if (!cancellationToken.IsCancellationRequested)
{
var variableMessage = new MqttApplicationMessageBuilder()
.WithTopic($"devices/{item.Key}/telemetry")
.WithPayload(item.ToDictionary(o => o.name, o => o.value).ToJson()).Build();
.WithPayload(nameValueDict.ToJson()).Build();
if (_mqttClient.IsConnected)
await _mqttClient.PublishAsync(variableMessage, cancellationToken);
}