bugfix: 响应消息,错误码取错值

feature-flyModify
陈伟 2025-06-20 16:35:58 +08:00
parent f66278375a
commit 27cfc84e43
1 changed files with 5 additions and 3 deletions

View File

@ -70,12 +70,12 @@ public class ConfigSubscribe : IJob
thing/product/{gateway_sn}/property/set_reply thing/product/{gateway_sn}/property/set_reply
thing/product/{gateway_sn}/drc/up DRC */ thing/product/{gateway_sn}/drc/up DRC */
var tempStr = topic.Replace(sn, "*"); var tempStr = topic.Replace(sn, "*");
Console.WriteLine($"成功调用主题 [{topic}] 的消息: {message}"); //Console.WriteLine($"成功调用主题 [{topic}] 的消息: {message}");
// 主题方法 // 主题方法
var result = JsonConvert.DeserializeObject<TopicServicesRequest<dynamic>>(message); var result = JsonConvert.DeserializeObject<TopicServicesRequest<dynamic>>(message);
var method = result.method; var method = result.method;
var data = result.data; var data = result.data;
long code = data.code; long code = data.result;
switch (tempStr) switch (tempStr)
{ {
// todo // todo
@ -83,7 +83,6 @@ public class ConfigSubscribe : IJob
// 航线进度处理 // 航线进度处理
// 任务取消 thing/product/*/services_reply // 任务取消 thing/product/*/services_reply
case "thing/product/*/services_reply": case "thing/product/*/services_reply":
switch (method) switch (method)
{ {
case "flighttask_prepare": // 下发任务响应 case "flighttask_prepare": // 下发任务响应
@ -134,6 +133,9 @@ public class ConfigSubscribe : IJob
break; break;
} }
break;
default:
Console.WriteLine($"未进入主题处理");
break; break;
} }
} }