diff --git a/OpenAuth.App/BaseApp/Subscribe/ConfigSubscribe.cs b/OpenAuth.App/BaseApp/Subscribe/ConfigSubscribe.cs index 5949656..99b2168 100644 --- a/OpenAuth.App/BaseApp/Subscribe/ConfigSubscribe.cs +++ b/OpenAuth.App/BaseApp/Subscribe/ConfigSubscribe.cs @@ -41,6 +41,7 @@ public class ConfigSubscribe : IJob await Subscribe(); } + // todo 暂时不使用 public static readonly string[] TopicList = { "thing/product/**/osd", @@ -68,7 +69,7 @@ public class ConfigSubscribe : IJob sys/product/{gateway_sn}/status 设备上下线、更新拓扑 thing/product/{gateway_sn}/property/set_reply 设备属性设置的响应 thing/product/{gateway_sn}/drc/up DRC 协议上行*/ - var tempStr = sn.Replace("sn", "*"); + var tempStr = topic.Replace(sn, "*"); Console.WriteLine($"成功调用主题 [{topic}] 的消息: {message}"); // 主题方法 var result = JsonConvert.DeserializeObject>(message); @@ -80,8 +81,8 @@ public class ConfigSubscribe : IJob // todo // 任务资源处理 // 航线进度处理 - // 任务取消 - case "thing/product/**/services_reply": + // 任务取消 thing/product/*/services_reply + case "thing/product/*/services_reply": switch (method) {