From 33470790ac0069c7734fb1a5b8b07350950c6dfe Mon Sep 17 00:00:00 2001 From: wxr <464027401@qq.com> Date: 星期二, 24 十一月 2020 15:51:31 +0800 Subject: [PATCH] 20201124,整理mqtt订阅 --- HDL_ON/DAL/DriverLayer/Packet.cs | 39 +++++++++++++++++++++------------------ 1 files changed, 21 insertions(+), 18 deletions(-) diff --git a/HDL_ON/DAL/DriverLayer/Packet.cs b/HDL_ON/DAL/DriverLayer/Packet.cs index 8e7e8ca..fb85c55 100644 --- a/HDL_ON/DAL/DriverLayer/Packet.cs +++ b/HDL_ON/DAL/DriverLayer/Packet.cs @@ -54,12 +54,7 @@ public virtual void Manager() { try - { - //濡傛灉褰撳墠閫氳鏂瑰紡涓嶆槸鏈湴bus udp鍒欓��鍑� - if(DriverLayer.Control.ins.communicationMode != DriverLayer.CommunicationMode.local_BusUdp) - { - return; - } + { //瀵逛簬鎿嶄綔鏁版嵁搴撶殑鏃堕棿姣旇緝闀跨殑锛屽彲浠ュ垱寤哄彟涓�涓嚎绋嬪鐞� if (!"HDLMIRACLE".Equals(Encoding.ASCII.GetString(Bytes, 4, 10))) { @@ -131,15 +126,18 @@ { if (updataObj.trait_on_off.value.ToString() == "on") { - if (updataObj.functionType == FunctionType.Fan) + switch (updataObj.functionType) { - (updataObj as Fan).openLevel = receiveBytes[2]; - updataObj.lastState = Language.StringByID(StringId.Level) + " : " + receiveBytes[2]; - } - else - { - (updataObj as Light).brightness = receiveBytes[2]; - updataObj.lastState = Language.StringByID(StringId.Brightness) + " : " + receiveBytes[2] + "%"; + case FunctionType.Fan: + (updataObj as Fan).openLevel = receiveBytes[2]; + updataObj.lastState = Language.StringByID(StringId.Level) + " : " + receiveBytes[2]; + break; + case FunctionType.Relay: + (updataObj as Light).brightness = receiveBytes[2]; + updataObj.lastState = Language.StringByID(StringId.Brightness) + " : " + receiveBytes[2] + "%"; + break; + //case FunctionType.Socket: + // (updataObj as SwitchSocket). } } HomePage.UpdataFunctionStates(updataObj); @@ -572,10 +570,15 @@ } break; case Command.ReadGatewayACK: - var mac = ByteToHex16(receiveBytes[5]) + "." + ByteToHex16(receiveBytes[6]) + "." + ByteToHex16(receiveBytes[7]) + "." + ByteToHex16(receiveBytes[8]) + "." + ByteToHex16(receiveBytes[9]) + "." + ByteToHex16(receiveBytes[10]) + "." + ByteToHex16(receiveBytes[11]) + "." + ByteToHex16(receiveBytes[12]); + var mac = ByteToHex16(receiveBytes[5]) + ByteToHex16(receiveBytes[6]) + ByteToHex16(receiveBytes[7]) + ByteToHex16(receiveBytes[8]) + ByteToHex16(receiveBytes[9]) + ByteToHex16(receiveBytes[10]) + ByteToHex16(receiveBytes[11]) + ByteToHex16(receiveBytes[12]); + var Name = Encoding.GetEncoding("gb2312").GetString(receiveBytes, 13, 20).Trim('\0'); ; + MainPage.Log($"name : {Name} ; mac : {mac}"); +#if DEBUG + DB_ResidenceData.residenceData.residenceGatewayMAC = "4E47323347591243"; +#endif if (DB_ResidenceData.residenceData.residenceGatewayMAC == mac) { - DriverLayer.Control.ins.gatewayOnline = true; + DriverLayer.Control.Ins.GatewayOnline = true; } break; } @@ -643,12 +646,12 @@ receiveFlag += string.Format("{0},{1}", usefulBytes[0], usefulBytes[1]); break; case Command.ReadRemark: - DriverLayer.Control.ins.myUdp.ReceiveReadRemark(usefulBytes); + DriverLayer.Control.Ins.myUdp.ReceiveReadRemark(usefulBytes); break; default: break; } - DriverLayer.Control.ins.myUdp.ReceiveRepeatManager(receiveFlag); + DriverLayer.Control.Ins.myUdp.ReceiveRepeatManager(receiveFlag); } catch (Exception ex) { -- Gitblit v1.8.0