mirror of
https://gitee.com/ThingsGateway/ThingsGateway.git
synced 2025-10-24 12:20:28 +08:00
46 lines
1.9 KiB
C#
46 lines
1.9 KiB
C#
|
||
//using System.Text;
|
||
|
||
//using ThingsGateway.Gateway.Application;
|
||
|
||
//public class TestExexcuteExpressions : IExexcuteExpressions
|
||
//{
|
||
|
||
// public TouchSocket.Core.ILog Logger { get; set; }
|
||
|
||
// public async System.Threading.Tasks.Task<NodeOutput> ExecuteAsync(NodeInput input, System.Threading.CancellationToken cancellationToken)
|
||
// {
|
||
// //想上传mqtt，可以自己写mqtt上传代码，或者通过mqtt插件的公开方法上传
|
||
|
||
// //直接获取mqttclient插件类型的第一个设备
|
||
// var mqttClient = GlobalData.ReadOnlyChannels.FirstOrDefault(a => a.Value.PluginName == "ThingsGateway.Plugin.Mqtt.MqttClient").Value?.ReadDeviceRuntimes?.FirstOrDefault().Value?.Driver as ThingsGateway.Plugin.Mqtt.MqttClient;
|
||
// if (mqttClient == null)
|
||
// throw new("mqttClient NOT FOUND");
|
||
|
||
// TopicArray topicArray = new()
|
||
// {
|
||
// Topic = "test",
|
||
// Payload = Encoding.UTF8.GetBytes("test")
|
||
// };
|
||
// var result = await mqttClient.MqttUpAsync(topicArray, default).ConfigureAwait(false);// 主题 和 负载
|
||
// if (!result.IsSuccess)
|
||
// throw new(result.ErrorMessage);
|
||
// return new NodeOutput() { Value = result };
|
||
|
||
// //通过设备名称找出mqttClient插件
|
||
// //var mqttClient = GlobalData.ReadOnlyDevices.FirstOrDefault(a => a.Value.Name == "mqttDevice1").Value?.Driver as ThingsGateway.Plugin.Mqtt.MqttClient;
|
||
|
||
// //if (mqttClient == null)
|
||
// // throw new("mqttClient NOT FOUND");
|
||
|
||
// //TopicArray topicArray = new()
|
||
// //{
|
||
// // Topic = "test",
|
||
// // Payload = Encoding.UTF8.GetBytes("test")
|
||
// //};
|
||
// //var result = await mqttClient.MqttUpAsync(topicArray, default).ConfigureAwait(false);// 主题 和 负载
|
||
// //if (!result.IsSuccess)
|
||
// // throw new(result.ErrorMessage);
|
||
// //return new NodeOutput() { Value = result };
|
||
// }
|
||
//} |