fix: IotSharp RPC response topic error. (#38)

iioter · Feb 15, 2023 · 6cdac03 · 6cdac03
1 parent bfd22ac
commit 6cdac03
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/Plugins/Plugin/DeviceThread.cs b/Plugins/Plugin/DeviceThread.cs
@@ -209,7 +209,7 @@ public void MyMqttClient_OnExcRpc(object? sender, RpcRequest e)
 
                 _logger.LogInformation($"{Device.DeviceName}收到RPC,{e}");
                 RpcResponse rpcResponse = new()
-                { DeviceName = e.DeviceName, RequestId = e.RequestId, IsSuccess = false };
+                { DeviceName = e.DeviceName, RequestId = e.RequestId, IsSuccess = false, Method = e.Method};
                 //执行写入变量RPC
                 if (e.Method.ToLower() == "write")
                 {

diff --git a/Plugins/Plugin/MyMqttClient.cs b/Plugins/Plugin/MyMqttClient.cs
@@ -390,7 +390,7 @@ public async Task ResponseRpcAsync(RpcResponse rpcResponse)
                         await ResponseIsRpcAsync(new ISRpcResponse
                         {
                             DeviceId = rpcResponse.DeviceName,
-                            Method = "Method",
+                            Method = rpcResponse.Method,
                             ResponseId = rpcResponse.RequestId,
                             Data = JsonConvert.SerializeObject(new Dictionary<string, object>
                             {

diff --git a/Plugins/PluginInterface/RpcResponse.cs b/Plugins/PluginInterface/RpcResponse.cs
@@ -9,6 +9,7 @@ namespace PluginInterface
     public class RpcResponse
     {
         public string RequestId { get; set; }
+        public string Method { get; set; }
         public string DeviceName { get; set; }
         public bool IsSuccess { get; set; }
         public string Description { get; set; }