blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
wxr
2023-11-08 d099a65ce3f5f8ed9ba345f8f3bdcf617fa4af75 
 HDL_ON/DAL/Mqtt/MqttClient.cs


@@ -111,7 +111,7 @@


            {


                MqttInfoConfig.Current.IfGetMqttInfoSuccess = false;


            }


            Control.Ins.GatewayOnline_Cloud = Control.Ins.GatewayOnline_Local = false;


            //Control.Ins.GatewayOnline_Cloud = Control.Ins.GatewayOnline_Local = false;


            await DisConnectRemoteMqttClient(s);


        }




@@ -145,6 +145,7 @@




                        await StartCloudMqtt();


                        await SubscribeTopics();




                    }


                    catch { }


                }


@@ -549,7 +550,7 @@


                                {


                                    var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, tuyaEncryptKey);


                                    var revString = Encoding.UTF8.GetString(bytes);


                                    MainPage.Log($"mqtt 状态更新:{revString}");


                                    //MainPage.Log($"mqtt 状态更新:{revString}");


                                    Control.Ins.UpdataFunctionStatus(revString, null, true);


                                    //Control.Ins.MsgInfoList.Add($"mqtt 状态更新:{revString}");


                                    //Control.Ins.MsgInfoList.Add(revString + "\r\n");


@@ -564,7 +565,7 @@


                                    //SetGatewayOnlineResetCheck();


                                    //var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, mqttEncryptKey);


                                    //bus数据解析


                                    var packet = new Packet();


                                    var packet = new Packet(e.ApplicationMessage.Payload.Length);




                                    if (!string.IsNullOrEmpty(DB_ResidenceData.Instance.HomeGateway.aesKey))


                                    {


@@ -980,7 +981,7 @@






                MqttInfoConfig.Current.mMqttInfo = mqttInfoRequestResult_Obj;


                await MQTTConnectAsync();


                //await MQTTConnectAsync();


                //1.判断是否绑定了网关，获取网关远程连接的加密KEY


                //if (DB_ResidenceData.Instance.CheckWhetherGatewayIsBound())


                {