From 0f2e0147e8990e913d16d99bc1b94fb6bc53abd7 Mon Sep 17 00:00:00 2001 From: 陈嘉乐 <cjl@hdlchina.com.cn> Date: 星期四, 03 十二月 2020 15:35:42 +0800 Subject: [PATCH] 2020-12-03-1 --- HDL_ON/DAL/DriverLayer/Packet.cs | 660 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 660 insertions(+), 0 deletions(-) diff --git a/HDL_ON/DAL/DriverLayer/Packet.cs b/HDL_ON/DAL/DriverLayer/Packet.cs new file mode 100644 index 0000000..ea909d3 --- /dev/null +++ b/HDL_ON/DAL/DriverLayer/Packet.cs @@ -0,0 +1,660 @@ +锘縰sing System; +using System.Collections.Generic; +using System.Text; +using HDL_ON.Entity; +using HDL_ON.UI; +using Shared; + +namespace HDL_ON.DriverLayer +{ + /// <summary> + /// bus鏁版嵁鍖� + /// </summary> + public class Packet + { + /// <summary> + /// 缂撳啿鍖哄ぇ灏� + /// </summary> + public const int Size = 1024 + 200; + + /// <summary> + /// 鎺ユ敹鍒扮殑鏁版嵁 + /// </summary> + public byte[] Bytes; + + /// <summary> + /// 鏁版嵁鍙戦�両P鍦板潃 + /// </summary> + public System.Net.EndPoint RemoteEndPoint; + + public Packet() + { + this.Bytes = new byte[Size]; + RemoteEndPoint = new System.Net.IPEndPoint(System.Net.IPAddress.Any, 0); + } + public Packet(byte[] data, System.Net.EndPoint remoteEndPoint) + { + this.Bytes = data; + this.RemoteEndPoint = remoteEndPoint; + } + + /// <summary> + /// 璁板綍宸茬粡鍙戦�佹暟鎹嚭鍘荤殑鏃堕棿 + /// </summary> + public DateTime FlagDateTime; + + /// <summary> + /// 宸茬粡鍙戦�佷簡澶氬皯鏁� + /// </summary> + public int HaveSendCount; + + /// <summary> + /// 澶勭悊鎺ユ敹鍒扮殑鏁版嵁 + /// </summary> + public virtual void Manager() + { + try + { + //瀵逛簬鎿嶄綔鏁版嵁搴撶殑鏃堕棿姣旇緝闀跨殑锛屽彲浠ュ垱寤哄彟涓�涓嚎绋嬪鐞� + if (!"HDLMIRACLE".Equals(Encoding.ASCII.GetString(Bytes, 4, 10))) + { + return; + } + + byte subnetID = this.Bytes[17]; //婧愬瓙缃戝彿 + byte deviceID = this.Bytes[18]; //婧愯澶囧彿 + + //婧愯澶囩被鍨� + int deviceType = this.Bytes[19] * 256 + this.Bytes[20]; + + Command command = (Command)(Bytes[21] * 256 + Bytes[22]); //鎿嶄綔鐮佹帶鍒跺懡浠� + + byte targetSubnetID = this.Bytes[23]; + byte targetDeviceID = this.Bytes[24]; + + //涓嶆槸瑕佹帴鏀剁殑鎸囦护灏辫繑鍥� + if (!((targetSubnetID == 0 && targetDeviceID == 252) || (targetSubnetID == 0xff && targetDeviceID == 0xff))) + { + return; + } + byte[] usefulBytes = null; + if (this.Bytes[16] == 0xFF) + { + usefulBytes = new byte[Bytes.Length - 16 - 11]; + Array.Copy(Bytes, 27, usefulBytes, 0, usefulBytes.Length); + } + else + { + //鏈夌敤鐨勯檮鍔犳暟鎹� + usefulBytes = new byte[this.Bytes[16] - 11]; + Array.Copy(Bytes, 25, usefulBytes, 0, usefulBytes.Length); + } + //澶勭悊鎺ユ敹鍒扮殑鏁版嵁 + UdpPacket_DataProcessing(subnetID, deviceID, command, usefulBytes); + //澶勭悊鏄惁瑕侀噸鍙戞暟鎹� + ManagerReceive(subnetID, deviceID, command, usefulBytes); + } + catch (Exception ex) + { + MainPage.Log($"packet {ex.Message} "); + } + } + + /// <summary> + /// 鏁版嵁鍖呭鐞� + /// ps:鐢眂ommonpage杞Щ杩囨潵锛岃繕闇�瑕佽浆绉诲悎閫傜殑浣嶇疆绠$悊 + /// </summary> + /// <param name="subnetID"></param> + /// <param name="deviceID"></param> + /// <param name="command"></param> + /// <param name="receiveBytes"></param> + void UdpPacket_DataProcessing(byte subnetID, byte deviceID, Command command, byte[] receiveBytes) + { + try + { + switch (command) + { + case Command.SetSingleLightACK: + var queryList = new List<Function>(); + queryList.AddRange(DB_ResidenceData.functionList.electricals); + queryList.AddRange(DB_ResidenceData.functionList.lights); + foreach (var updataObj in queryList) + { + if (updataObj.GetBusId() == subnetID + "_" + deviceID + "_" + receiveBytes[0]) + { + if (updataObj.functionType != FunctionType.RGB) + { + updataObj.trait_on_off.curValue = receiveBytes[2] > 0 ? "on" : "off"; + if (updataObj.trait_on_off.curValue.ToString() == "on") + { + switch (updataObj.functionType) + { + case FunctionType.Fan: + (updataObj as Fan).openLevel = receiveBytes[2]; + updataObj.lastState = Language.StringByID(StringId.Level) + " : " + receiveBytes[2]; + break; + case FunctionType.Dimmer: + (updataObj as Light).brightness = receiveBytes[2]; + updataObj.lastState = Language.StringByID(StringId.Brightness) + " : " + receiveBytes[2] + "%"; + break; + } + } + HomePage.UpdataFunctionStates(updataObj); + RoomPage.UpdataStates(updataObj); + FunctionPage.UpdataStates(updataObj); + ClassificationPage.UpdataInfo(updataObj); + switch (updataObj.functionType) + { + case FunctionType.Relay: + RelayPage.UpdataState(updataObj as Light); + break; + case FunctionType.Dimmer: + DimmerPage.UpdataStates(updataObj as Light); + break; + case FunctionType.Fan: + FanPage.UpdataState(updataObj as Fan); + break; + } + break; + } + } + } + break; + case Command.ReadLightAllLoopBrightnessACK: + for (int i = 0; i < receiveBytes[0]; i++) + { + var light = DB_ResidenceData.functionList.lights.Find((obj) => obj.bus_Data.SubnetID == subnetID && obj.bus_Data.DeviceID == deviceID && obj.bus_Data.loopId == (i + 1)); + if (light != null) + { + if (light.functionType != FunctionType.RGB) + { + light.trait_on_off.curValue = receiveBytes[light.bus_Data.loopId] == 0 ? "off" : "on"; + if (light.trait_on_off.curValue.ToString() == "on") + { + light.brightness = receiveBytes[2]; + light.lastState = Language.StringByID(StringId.Brightness) + " : " + receiveBytes[2] + "%"; + } + HomePage.UpdataFunctionStates(light); + RoomPage.UpdataStates(light); + FunctionPage.UpdataStates(light); + ClassificationPage.UpdataInfo(light); + switch (light.functionType) + { + case FunctionType.Relay: + RelayPage.UpdataState(light); + break; + case FunctionType.Dimmer: + DimmerPage.UpdataStates(light); + break; + } + } + } + else + { + var e = DB_ResidenceData.functionList.electricals.Find((obj) => obj.bus_Data.SubnetID == subnetID && obj.bus_Data.DeviceID == deviceID && obj.bus_Data.loopId == i); + if (e != null) + { + var fan = e as Fan; + fan.trait_on_off.curValue = receiveBytes[2] == 0 ? "off" : "on"; + if (fan.trait_on_off.curValue.ToString() == "on") + { + fan.openLevel = receiveBytes[2]; + fan.lastState = Language.StringByID(StringId.Level) + " : " + receiveBytes[2]; + } + HomePage.UpdataFunctionStates(fan); + RoomPage.UpdataStates(fan); + FunctionPage.UpdataStates(fan); + ClassificationPage.UpdataInfo(fan); + switch (fan.functionType) + { + case FunctionType.Fan: + FanPage.UpdataState(fan); + break; + case FunctionType.Socket: + + break; + } + } + } + } + break; + case Command.SetLogicLoopColorACK: + case Command.ReadLogicLoopColorACK: + foreach (var rgb in DB_ResidenceData.functionList.lights) + { + if (rgb.GetBusId() == subnetID + "_" + deviceID + "_" + receiveBytes[0]) + { + if (rgb.functionType == FunctionType.RGB) + { + rgb.trait_on_off.curValue = receiveBytes[1] > 0 ? "on" : "off"; + if (receiveBytes[1] > 0) + { + rgb.brightness = receiveBytes[1]; + rgb.lastState = Language.StringByID(StringId.Brightness) + " : " + receiveBytes[1] + "%"; + } + rgb.redColor = receiveBytes[6]; + rgb.greenColor = receiveBytes[7]; + rgb.blueColor = receiveBytes[8]; + + HomePage.UpdataFunctionStates(rgb); + RoomPage.UpdataStates(rgb); + FunctionPage.UpdataStates(rgb); + ClassificationPage.UpdataInfo(rgb); + RGBPage.UpdataStates(rgb); + } + } + } + break; + case Command.SetCurtainModelStutasACK: + case Command.ReadCurtainStutasACK: + foreach (var curtain in DB_ResidenceData.functionList.curtains) + { + if (curtain.bus_Data.SubnetID == subnetID && curtain.bus_Data.DeviceID == deviceID) + { + if (receiveBytes[0] == 17) + { + if (receiveBytes[1] > 1) + { + curtain.trait_on_off.curValue = "on"; + } + else + { + curtain.trait_on_off.curValue = "off"; + } + curtain.percent = receiveBytes[1]; + curtain.lastState = Language.StringByID(StringId.Open) + curtain.percent + "%"; + } + else + { + if (curtain.bus_Data.loopId != receiveBytes[0]) + continue; + switch (receiveBytes[1]) + { + case 0: + curtain.trait_on_off.curValue = "stop"; + break; + case 1: + curtain.trait_on_off.curValue = "on"; + curtain.lastState = Language.StringByID(StringId.Open); + break; + case 2: + curtain.trait_on_off.curValue = "off"; + curtain.lastState = Language.StringByID(StringId.Close); + break; + } + } + RoomPage.UpdataStates(curtain); + FunctionPage.UpdataStates(curtain); + HomePage.UpdataFunctionStates(curtain); + ClassificationPage.UpdataInfo(curtain); + switch (curtain.functionType) + { + case FunctionType.Curtain: + CurtainModulePage.UpdataState(curtain); + break; + case FunctionType.MotorCurtain: + MotorCurtainPage.UpdataState(curtain); + break; + case FunctionType.RollingShutter: + RollingShutterPage.UpdataState(curtain); + break; + } + } + } + break; + case Command.SetACModeACK: + case Command.ReadACModeACK: + foreach (var ac in DB_ResidenceData.functionList.aCs) + { + if (ac.GetBusId() == subnetID + "_" + deviceID + "_" + receiveBytes[0]) + { + ac.curTempType = receiveBytes[1]; + ac.indoorTemp = receiveBytes[2]; + ac.trait_on_off.curValue = receiveBytes[8] == 1 ? "on" : "off"; + ac.curModeIndex = receiveBytes[9]; + ac.curFanIndex = receiveBytes[10]; + ac.trait_temp.curValue = receiveBytes[11]; + ac.lastState = ""; + switch (ac.trait_mode.curValue.ToString()) + { + case "cool": + ac.lastState = Language.StringByID(StringId.Cool); + break; + case "heat": + ac.lastState = Language.StringByID(StringId.Heat); + break; + case "dry": + ac.lastState = Language.StringByID(StringId.Dry); + break; + case "auto": + ac.lastState = Language.StringByID(StringId.Auto); + break; + case "fan": + ac.lastState = Language.StringByID(StringId.AirSupply); + break; + } + switch (ac.trait_fan.curValue.ToString()) + { + case "high": + ac.lastState += " " + Language.StringByID(StringId.HighWindSpeed); + break; + case "medium": + ac.lastState += " " + Language.StringByID(StringId.MiddleWindSpeed); + break; + case "low": + ac.lastState += " " + Language.StringByID(StringId.LowWindSpeed); + break; + case "auto": + ac.lastState += " " + Language.StringByID(StringId.Auto); + break; + } + ac.lastState += " " + ac.trait_temp.curValue + ac.tempUnitString; + RoomPage.UpdataStates(ac); + FunctionPage.UpdataStates(ac); + HomePage.UpdataFunctionStates(ac); + ClassificationPage.UpdataInfo(ac); + ACPage.UpdataStates(ac); + } + } + break; + case Command.ReadFloorHeatACK: + case Command.SetFloorHeatACK: + foreach (var fh in DB_ResidenceData.functionList.floorHeatings) + { + if (fh.GetBusId() == subnetID + "_" + deviceID + "_" + receiveBytes[0]) + { + fh.curTempType = receiveBytes[2]; + fh.trait_on_off.curValue = receiveBytes[1] % 2 == 0 ? "off" : "on"; + fh.curModeIndex = receiveBytes[3]; + if (fh.modeTemp.ContainsKey("normal")) + { + fh.modeTemp["normal"] = receiveBytes[4]; + } + else + { + fh.modeTemp.Add("normal", receiveBytes[4]); + } + if (fh.modeTemp.ContainsKey("day")) + { + fh.modeTemp["day"] = receiveBytes[5]; + } + else + { + fh.modeTemp.Add("day", receiveBytes[5]); + } + if (fh.modeTemp.ContainsKey("night")) + { + fh.modeTemp["night"] = receiveBytes[6]; + } + else + { + fh.modeTemp.Add("night", receiveBytes[6]); + } + if (fh.modeTemp.ContainsKey("away")) + { + fh.modeTemp["away"] = receiveBytes[7]; + } + else + { + fh.modeTemp.Add("away", receiveBytes[7]); + } + + switch (fh.trait_mode.curValue) + { + case "normal": + fh.lastState = Language.StringByID(StringId.Normal); + fh.trait_temp.curValue = receiveBytes[4]; + break; + case "day": + fh.lastState = Language.StringByID(StringId.Day); + fh.trait_temp.curValue = receiveBytes[5]; + break; + case "night": + fh.lastState = Language.StringByID(StringId.Night); + fh.trait_temp.curValue = receiveBytes[6]; + break; + case "timer": + fh.lastState = Language.StringByID(StringId.Auto); + if (receiveBytes[8] == 0) + { + fh.timeFlag = 0; + fh.trait_temp.curValue = receiveBytes[5]; + } + else + { + fh.timeFlag = 1; + fh.trait_temp.curValue = receiveBytes[6]; + } + break; + case "away": + fh.trait_temp.curValue = receiveBytes[7]; + fh.lastState = Language.StringByID(StringId.Away); + break; + } + fh.lastState += " " + fh.trait_temp.curValue + fh.tempUnitString; + RoomPage.UpdataStates(fh); + FunctionPage.UpdataStates(fh); + HomePage.UpdataFunctionStates(fh); + ClassificationPage.UpdataInfo(fh); + FloorHeatingPage.UpdataStates(fh); + } + } + break; + case Command.ReadDeviceLoopInfoACK: + FunctionType dt = (FunctionType)(11 * 256 + receiveBytes[1]); + string tag = receiveBytes[1] + "_" + subnetID + "_" + deviceID + "_" + receiveBytes[2]; + foreach (var sensor in DB_ResidenceData.functionList.sensorsEnvironmentalScience) + { + if (sensor.bus_Data != null) + { + if ((int)sensor.functionType % 256 == receiveBytes[1] && sensor.bus_Data.SubnetID == subnetID && + sensor.bus_Data.DeviceID == deviceID && sensor.bus_Data.loopId == receiveBytes[2]) + { + switch (dt) + { + case FunctionType.Temp: + byte[] tempBytes = new byte[] { receiveBytes[24], receiveBytes[25], receiveBytes[26], receiveBytes[27] }; + sensor.values = Math.Round(BitConverter.ToSingle(tempBytes, 0), 1); + break; + case FunctionType.Humidity: + sensor.values = Convert.ToDouble(receiveBytes[24] * 256 + receiveBytes[25]) / 10; + break; + case FunctionType.TVOC: + sensor.values = Convert.ToDouble(receiveBytes[24] * 256 + receiveBytes[25]) / 100; + break; + case FunctionType.PM25: + sensor.values = Convert.ToInt32(receiveBytes[24] * 256 + receiveBytes[25]); + break; + case FunctionType.CO2: + sensor.values = Convert.ToInt32(receiveBytes[24] * 256 + receiveBytes[25]); + break; + } + EnvironmentalSciencePage.LoadEvent_UpdataStatus(sensor); + } + } + } + break; + case Command.New_Analog_Quantity_BROADCAST: + string tag1 = receiveBytes[1] + "_" + subnetID + "_" + deviceID + "_" + receiveBytes[2]; + foreach (var sensor in DB_ResidenceData.functionList.sensorsEnvironmentalScience) + { + if (sensor.bus_Data != null) + { + if ((int)sensor.functionType % 256 == receiveBytes[1] && sensor.bus_Data.SubnetID == subnetID && + sensor.bus_Data.DeviceID == deviceID && sensor.bus_Data.loopId == receiveBytes[2]) + { + //0淇濈暀 1鏃犵鍙�4Byte鏁村舰 2鏈夌鍙�4Byte鏁村舰 3Float褰紙浠B憋級 + switch (receiveBytes[3]) + { + case 1: + sensor.values = (receiveBytes[5] * 256 * 256 * 256) + (receiveBytes[6] * 256 * 256) + (receiveBytes[7] * 256) + receiveBytes[8]; + break; + case 2: + sensor.values = -1 * ((receiveBytes[5] * 256 * 256 * 256) + (receiveBytes[6] * 256 * 256) + (receiveBytes[7] * 256) + receiveBytes[8]); + break; + case 3: + byte[] tempBytes = new byte[] { receiveBytes[5], receiveBytes[6], receiveBytes[7], receiveBytes[8] }; + sensor.values = Math.Round(BitConverter.ToSingle(tempBytes, 0), 1); + break; + } + switch (receiveBytes[4]) + { + case 2: + if (receiveBytes[1] == 5)//TVOC闇�姹傞櫎浠�100000 + sensor.values /= 100000; + break; + } + EnvironmentalSciencePage.LoadEvent_UpdataStatus(sensor); + } + } + } + break; + case Command.InstructionPanelKeyACK: + case Command.ReadInstructionPanelKeyACK: + byte reACPanel = 0; + if (receiveBytes.Length == 2) + { + reACPanel = 1; + } + else if (receiveBytes.Length == 3) + { + reACPanel = receiveBytes[2]; + } + else + { + break; + } + foreach (var ac in DB_ResidenceData.functionList.aCs) + { + if (ac.GetBusId() == subnetID + "_" + deviceID + "_" + reACPanel) + { + switch (receiveBytes[0]) + { + case 3:// + ac.trait_on_off.curValue = receiveBytes[1] == 1 ? "on" : "off"; + break; + case 4: + case 7: + case 8: + case 19: + ac.trait_temp.curValue = receiveBytes[1]; + break; + case 5: + ac.curFanIndex = receiveBytes[1]; + break; + case 6: + ac.curModeIndex = receiveBytes[1]; + break; + + } + ac.lastState = ""; + ac.lastState += " " + ac.trait_temp.curValue + ac.tempUnitString; + RoomPage.UpdataStates(ac); + FunctionPage.UpdataStates(ac); + HomePage.UpdataFunctionStates(ac); + ClassificationPage.UpdataInfo(ac); + ACPage.UpdataStates(ac); + } + } + break; + case Command.ReadPanleTempACK://1944 + case Command.PanleBroadcastTemp: + foreach (var ac in DB_ResidenceData.functionList.aCs) + { + if (ac.GetBusId() == subnetID + "_" + deviceID + "_" + receiveBytes[0]) + { + ac.indoorTemp = receiveBytes[1]; + FunctionPage.UpdataStates(ac); + } + } + 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 Name = Encoding.GetEncoding("gb2312").GetString(receiveBytes, 13, 20).Trim('\0'); ; + MainPage.Log($"name : {Name} ; mac : {mac}"); + if (DB_ResidenceData.residenceData.residenceGatewayMAC == mac) + { + DriverLayer.Control.Ins.GatewayOnline = true; + } + break; + } + } + catch (Exception ex) + { + MainPage.Log($"Bus Rev Erorr : {ex.Message}"); + } + } + /// <summary> + /// byte杞�16杩涘埗瀛楃涓� + /// </summary> + /// <param name="b"></param> + /// <returns></returns> + string ByteToHex16(byte b) + { + string s = Convert.ToString(b, 16).ToUpper(); + if (s.Length <= 1) + { + return "0" + s; + } + return s; + } + + /// <summary> + /// 澶勭悊鎺ユ敹鍥炴潵鐨勬暟鎹� + /// </summary> + void ManagerReceive(byte subnetID, byte deviceID, Command command, byte[] usefulBytes) + { + try + { + string receiveFlag = string.Format("{0},{1},{2},", subnetID, deviceID, (int)command); + + switch (command) + { + case Command.SetSingleLightACK: + receiveFlag += string.Format("{0}", usefulBytes[0]); + break; + case Command.SetLogicLoopColorACK: + receiveFlag += string.Format("{0},{1},{2}", usefulBytes[0], usefulBytes[1], usefulBytes[2]); + break; + case Command.ReadLogicLoopColorACK: + case Command.ReadACModeACK: + case Command.SetACModeACK: + case Command.ReadFloorHeatACK: + case Command.SetFloorHeatACK: + receiveFlag += string.Format("{0}", usefulBytes[0]); + break; + case Command.ReadLightAllLoopBrightnessACK: + receiveFlag += ""; + break; + case Command.ReadGatewayACK: + receiveFlag = string.Format("{0},{1}", usefulBytes[0], usefulBytes[1]); + break; + case Command.ReadDeviceLoopInfoACK: + if (usefulBytes[0] == 1) + { + receiveFlag += string.Format("{0},{1}", usefulBytes[0], usefulBytes[2]); ; + } + else + receiveFlag += string.Format("{0},{1},{2}", usefulBytes[0], usefulBytes[1], usefulBytes[2]); + break; + case Command.InstructionPanelKeyACK: + case Command.ReadInstructionPanelKeyACK: + receiveFlag += string.Format("{0},{1}", usefulBytes[0], usefulBytes[1]); + break; + case Command.ReadRemark: + DriverLayer.Control.Ins.myUdp.ReceiveReadRemark(usefulBytes); + break; + default: + break; + } + DriverLayer.Control.Ins.myUdp.ReceiveRepeatManager(receiveFlag); + } + catch (Exception ex) + { + MainPage.Log("ManagerReceive鎶涘嚭寮傚父锛�" + ex.ToString()); + } + } + + + } +} \ No newline at end of file -- Gitblit v1.8.0