ciro_xu/iotgateway
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
谷草` 2023-02-15 08:42:29 +08:00 committed by GitHub
parent bfd22acad1
commit 6cdac03ef4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Plugins/Plugin/DeviceThread.cs
View File

@ -209,7 +209,7 @@ namespace Plugin
_logger.LogInformation($"{Device.DeviceName}收到RPC,{e}"); _logger.LogInformation($"{Device.DeviceName}收到RPC,{e}");
RpcResponse rpcResponse = new() RpcResponse rpcResponse = new()
{ DeviceName = e.DeviceName, RequestId = e.RequestId, IsSuccess = false }; { DeviceName = e.DeviceName, RequestId = e.RequestId, IsSuccess = false, Method = e.Method};
//执行写入变量RPC //执行写入变量RPC
if (e.Method.ToLower() == "write") if (e.Method.ToLower() == "write")
{ {

2
Plugins/Plugin/MyMqttClient.cs
View File

@ -390,7 +390,7 @@ namespace Plugin
await ResponseIsRpcAsync(new ISRpcResponse await ResponseIsRpcAsync(new ISRpcResponse
{ {
DeviceId = rpcResponse.DeviceName, DeviceId = rpcResponse.DeviceName,
Method = "Method", Method = rpcResponse.Method,
ResponseId = rpcResponse.RequestId, ResponseId = rpcResponse.RequestId,
Data = JsonConvert.SerializeObject(new Dictionary<string, object> Data = JsonConvert.SerializeObject(new Dictionary<string, object>
{ {

1
Plugins/PluginInterface/RpcResponse.cs
View File

@ -9,6 +9,7 @@ namespace PluginInterface
public class RpcResponse public class RpcResponse
{ {
public string RequestId { get; set; } public string RequestId { get; set; }
public string Method { get; set; }
public string DeviceName { get; set; } public string DeviceName { get; set; }
public bool IsSuccess { get; set; } public bool IsSuccess { get; set; }
public string Description { get; set; } public string Description { get; set; }