From f66278375a9c5f7b98c84a619f323cbd63e5cc57 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=99=88=E4=BC=9F?= <421281095@qq.com> Date: Fri, 20 Jun 2025 15:58:52 +0800 Subject: [PATCH] =?UTF-8?q?bugfix:=20=E5=AD=97=E7=AC=A6=E4=B8=B2=E6=9B=BF?= =?UTF-8?q?=E6=8D=A2=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- OpenAuth.App/BaseApp/Subscribe/ConfigSubscribe.cs | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) 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) {