diff --git a/DataVAPI/UpAndDown/ProcessServer.cs b/DataVAPI/UpAndDown/ProcessServer.cs index 45a033d..ddda032 100644 --- a/DataVAPI/UpAndDown/ProcessServer.cs +++ b/DataVAPI/UpAndDown/ProcessServer.cs @@ -75,7 +75,8 @@ namespace DataVAPI.UpAndDown Subscribe(IOTDevServer.HeartbeatSubTopic); //订阅主播消息 - Subscribe(IOTDevServer.BroadcastTopic); + Subscribe("/broadcast/grgpECHSL7q/Transit_SetDevice"); + Subscribe("/broadcast/grgpECHSL7q/Transit_Test_SetDevice"); IOTDevServer.UNConnectMqtt += new Action((o) => { ConsoleHelper.WriteSuccessLine(o); }); @@ -316,9 +317,8 @@ namespace DataVAPI.UpAndDown } } } - else if (topic == IOTDevServer.BroadcastTopic)//广播主题 + else if (topic == "/broadcast/grgpECHSL7q/Transit_SetDevice" || topic == "/broadcast/grgpECHSL7q/Transit_Test_SetDevice")//广播主题 { - if (message.Contains("AlarmType")) { AlarmTable alarm= Tools.JsonToObjectTools(message);