From 1026814d931de92f0da5f15a58870565a94100e0 Mon Sep 17 00:00:00 2001 From: 陈嘉乐 <cjl@hdlchina.com.cn> Date: 星期一, 11 一月 2021 14:37:38 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/NewFilePath' into WJC --- HDL_ON/DAL/DriverLayer/Control_Udp.cs | 384 +++++++++++++++++++++++++++++++----------------------- 1 files changed, 218 insertions(+), 166 deletions(-) diff --git a/HDL_ON/DAL/DriverLayer/Control_Udp.cs b/HDL_ON/DAL/DriverLayer/Control_Udp.cs index 5967ef9..5d91266 100644 --- a/HDL_ON/DAL/DriverLayer/Control_Udp.cs +++ b/HDL_ON/DAL/DriverLayer/Control_Udp.cs @@ -156,145 +156,180 @@ /// </summary> public void ControlBusScenes(Scene scene) { - foreach (var f in scene.functions) + if (Control.Ins.IsRemote) { - switch (f.localFunction.functionType) + foreach (var f in scene.functions) { - case FunctionType.Curtain: - foreach (var attr in f.status) + var count = 0; + List<ApiAlinkControlActionObj> actionObjs = new List<ApiAlinkControlActionObj>(); + Dictionary<string, string> d = new Dictionary<string, string>(); + var pm = new DAL.Server.HttpServerRequest(); + foreach (var temp in f.status) + { + if (f.localFunction == null) { - if (attr.key == FunctionAttributeKey.OnOff) + continue; + } + d.Add(temp.key, temp.value); + var apiControlData = f.localFunction.GetApiControlData(d); + actionObjs.Add(apiControlData); + count++; + if (count > 9) + { + var result = pm.ControlDevice(actionObjs); + actionObjs = new List<ApiAlinkControlActionObj>(); + count = 0; + } + } + var pack = pm.ControlDevice(actionObjs); + } + } + else + { + foreach (var f in scene.functions) + { + if (f.localFunction == null) + { + continue; + } + switch (f.localFunction.spk) + { + case SPK.CurtainSwitch: + foreach (var attr in f.status) { - byte curtainState = 0; - switch (attr.value) + if (attr.key == FunctionAttributeKey.OnOff) { - case "on": - curtainState = 1; - break; - case "off": - curtainState = 2; - break; - } - ControlBytesSend(Command.SetCurtainModelStutas, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, - new byte[] { f.localFunction.bus.LoopId, curtainState }); - break; - } - } - break; - case FunctionType.AC: - AC tempAc = new AC(); - foreach (var attr in f.status) - { - byte modeKey = 4; - switch (attr.key) - { - case FunctionAttributeKey.OnOff: - tempAc.trait_on_off.curValue = attr.value; - break; - case FunctionAttributeKey.Mode: - tempAc.trait_mode.curValue = attr.value; - break; - case FunctionAttributeKey.FanSpeed: - tempAc.trait_fan.curValue = attr.value; - break; - case FunctionAttributeKey.SetTemp: - tempAc.trait_temp.curValue = attr.value; - switch (tempAc.curModeIndex) - { - case 3: - modeKey = 8; - break; - case 0: - modeKey = 4; - break; - case 1: - modeKey = 7; - break; - case 4: - modeKey = 19; - break; - case 2: - modeKey = 2; - break; - } - break; - } - ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { 3, tempAc.trait_on_off.curValue.ToString() == "on" ? (byte)1 : (byte)0, f.localFunction.bus.LoopId }); - ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { 6, tempAc.curModeIndex, f.localFunction.bus.LoopId }); - ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { 5, tempAc.curFanIndex, f.localFunction.bus.LoopId }); - ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { modeKey, Convert.ToByte(tempAc.trait_temp.curValue), f.localFunction.bus.LoopId }); - } - break; - case FunctionType.Relay: - case FunctionType.Dimmer: - byte brightness = 0; - foreach (var attr in f.status) - { - switch (attr.key) - { - case FunctionAttributeKey.OnOff: + byte curtainState = 0; switch (attr.value) { case "on": - brightness = 100; + curtainState = 1; break; case "off": - brightness = 0; + curtainState = 2; break; } + ControlBytesSend(Command.SetCurtainModelStutas, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, + new byte[] { f.localFunction.bus.LoopId, curtainState }); break; - case FunctionAttributeKey.Brightness: - brightness = Convert.ToByte(attr.value); - break; + } } - } - ControlBytesSend(Command.SetSingleLight, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, - new byte[] { f.localFunction.bus.LoopId, brightness }); - break; - case FunctionType.RGB: - break; - case FunctionType.FloorHeating: - var tempFh = new FloorHeating(); - foreach (var attr in f.status) - { - switch (attr.key) + break; + case SPK.AcStandard: + AC tempAc = new AC(); + foreach (var attr in f.status) { - case FunctionAttributeKey.OnOff: - tempFh.trait_on_off.curValue = attr.value; - break; - case FunctionAttributeKey.SetTemp: - tempFh.trait_temp.curValue = attr.value; - break; - case FunctionAttributeKey.Mode: - tempFh.trait_mode.curValue = attr.value; - break; - } - } - byte b1 = tempFh.trait_on_off.curValue.ToString() == "on" ? (byte)1 : (byte)0; - ControlBytesSend(Command.SetFloorHeat, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { - f. localFunction.bus.LoopId, b1, 0, tempFh.curModeIndex, Convert.ToByte( tempFh.trait_temp.curValue), Convert.ToByte( tempFh.trait_temp.curValue), Convert.ToByte( tempFh.trait_temp.curValue), Convert.ToByte( tempFh.trait_temp.curValue), 0, 0 }); - break; - case FunctionType.Socket: - foreach (var attr in f.status) - { - if (attr.key == FunctionAttributeKey.OnOff) - { - byte onOffValue = 0; - switch (attr.value) + byte modeKey = 4; + switch (attr.key) { - case "on": - onOffValue = 1; + case FunctionAttributeKey.OnOff: + tempAc.trait_on_off.curValue = attr.value; break; - case "off": - onOffValue = 2; + case FunctionAttributeKey.Mode: + tempAc.trait_mode.curValue = attr.value; + break; + case FunctionAttributeKey.FanSpeed: + tempAc.trait_fan.curValue = attr.value; + break; + case FunctionAttributeKey.SetTemp: + tempAc.trait_temp.curValue = attr.value; + switch (tempAc.curModeIndex) + { + case 3: + modeKey = 8; + break; + case 0: + modeKey = 4; + break; + case 1: + modeKey = 7; + break; + case 4: + modeKey = 19; + break; + case 2: + modeKey = 2; + break; + } break; } - ControlBytesSend(Command.SetSingleLight, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, - new byte[] { f.localFunction.bus.LoopId, onOffValue }); - break; + ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { 3, tempAc.trait_on_off.curValue.ToString() == "on" ? (byte)1 : (byte)0, f.localFunction.bus.LoopId }); + ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { 6, tempAc.curModeIndex, f.localFunction.bus.LoopId }); + ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { 5, tempAc.curFanIndex, f.localFunction.bus.LoopId }); + ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { modeKey, Convert.ToByte(tempAc.trait_temp.curValue), f.localFunction.bus.LoopId }); } - } - break; + break; + case SPK.LightSwitch: + case SPK.LightDimming: + byte brightness = 0; + foreach (var attr in f.status) + { + switch (attr.key) + { + case FunctionAttributeKey.OnOff: + switch (attr.value) + { + case "on": + brightness = 100; + break; + case "off": + brightness = 0; + break; + } + break; + case FunctionAttributeKey.Brightness: + brightness = Convert.ToByte(attr.value); + break; + } + } + ControlBytesSend(Command.SetSingleLight, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, + new byte[] { f.localFunction.bus.LoopId, brightness, (byte)(f.localFunction.delay / 255), (byte)(f.localFunction.delay % 255) }); + break; + case SPK.LightRGB: + break; + case SPK.FloorHeatStandard: + var tempFh = new FloorHeating(); + foreach (var attr in f.status) + { + switch (attr.key) + { + case FunctionAttributeKey.OnOff: + tempFh.trait_on_off.curValue = attr.value; + break; + case FunctionAttributeKey.SetTemp: + tempFh.trait_temp.curValue = attr.value; + break; + case FunctionAttributeKey.Mode: + tempFh.trait_mode.curValue = attr.value; + break; + } + } + byte b1 = tempFh.trait_on_off.curValue.ToString() == "on" ? (byte)1 : (byte)0; + ControlBytesSend(Command.SetFloorHeat, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { + f. localFunction.bus.LoopId, b1, 0, tempFh.curModeIndex, Convert.ToByte( tempFh.trait_temp.curValue), Convert.ToByte( tempFh.trait_temp.curValue), Convert.ToByte( tempFh.trait_temp.curValue), Convert.ToByte( tempFh.trait_temp.curValue), 0, 0 }); + break; + case SPK.ElectricSocket: + foreach (var attr in f.status) + { + if (attr.key == FunctionAttributeKey.OnOff) + { + byte onOffValue = 0; + switch (attr.value) + { + case "on": + onOffValue = 1; + break; + case "off": + onOffValue = 2; + break; + } + ControlBytesSend(Command.SetSingleLight, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, + new byte[] { f.localFunction.bus.LoopId, onOffValue }); + break; + } + } + break; + } } } } @@ -312,13 +347,13 @@ var deviceId = function.bus.DeviceID; var loopId = function.bus.LoopId; - switch (function.functionCategory) + switch (function.Spk_Prefix) { case FunctionCategory.Light: var light = function as Light; - switch (light.functionType) + switch (light.spk) { - case FunctionType.RGB: + case SPK.LightRGB: MainPage.Log($"rgb level : {light.brightness}"); byte b = 100;//寮�鍏虫搷浣滀緷鎹畂n_off瀛楁锛屽疄闄呭紑鍏冲�间緷鎹産rightness锛屽綋on_off涓烘墦寮�锛宐rightness涓嶈兘涓�0 if (light.trait_on_off.curValue.ToString() == "off") @@ -337,7 +372,7 @@ 0,0}; ControlBytesSend(Command.SetLogicLoopColor, subnetId, deviceId, bytes, 1); break; - case FunctionType.Dimmer: + case SPK.LightDimming: byte b1 = 100; if (light.trait_on_off.curValue.ToString() == "off") { @@ -353,7 +388,7 @@ 0, Convert.ToByte(light.fadeTime) }); //DimmerPage.UpdataStates(light); break; - case FunctionType.Relay: + case SPK.LightSwitch: ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { function.bus.LoopId, light.trait_on_off.curValue.ToString() == "on" ? (byte)100 : (byte)0, 0, 0 }); //RelayPage.UpdataState(light); break; @@ -361,9 +396,9 @@ break; case FunctionCategory.Curtain: var curtain = function as Curtain; - switch (curtain.functionType) + switch (curtain.spk) { - case FunctionType.Curtain: + case SPK.CurtainSwitch: byte b1 = 0; if (curtain.trait_on_off.curValue.ToString() == "stop") { @@ -379,8 +414,8 @@ } ControlBytesSend(Command.SetCurtainModelStutas, subnetId, deviceId, new byte[] { curtain.bus.LoopId, b1 }); break; - case FunctionType.MotorCurtain: - case FunctionType.RollingShutter: + case SPK.CurtainTrietex: + case SPK.CurtainRoller: //if (commandDictionary.Count > 0) //{ if (curtain.trait_on_off.curValue.ToString() == "stop") @@ -411,10 +446,10 @@ break; } break; - case FunctionCategory.Thermostat: - switch (function.functionType) + case FunctionCategory.AC: + switch (function.spk) { - case FunctionType.AC: + case SPK.AcStandard: var aC = function as AC; ControlBytesSend(Command.SetACMode, subnetId, deviceId, new byte[] { aC.bus.LoopId, (byte)aC.curTempType, 32, 32, 32, 32, 32, 0, aC.trait_on_off.curValue.ToString() == "on" ? (byte)1 : (byte)0, aC.curModeIndex, aC.curFanIndex, Convert.ToByte(aC.trait_temp.curValue), 0 }); //ControlBytesSend(Command.InstructionPanelKey, aC.bus_Data.SubnetID, aC.bus_Data.DeviceID, new byte[] { 3, aC.on_off == "on" ? (byte)1 : (byte)0, aC.bus_Data.loopId }); @@ -460,7 +495,11 @@ } break; - case FunctionType.FloorHeating: + } + break; + case FunctionCategory.FloorHeat: + switch (function.spk) { + case SPK.FloorHeatStandard: var fh = function as FloorHeating; if (fh.modeTemp.Count == 4) { @@ -495,10 +534,10 @@ break; } break; - case FunctionCategory.Electrical: - switch (function.functionType) + case FunctionCategory.Electric: + switch (function.spk) { - case FunctionType.Fan: + case SPK.ElectricFan: var fan = function as Fan; if (fan.trait_on_off.curValue.ToString() == "on") { @@ -508,12 +547,7 @@ ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { fan.bus.LoopId, 0 }); } break; - } - break; - case FunctionCategory.SwitchDevice: - switch (function.functionType) - { - case FunctionType.Socket: + case SPK.ElectricSocket: var s = function as SwitchSocket; ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { s.bus.LoopId, s.trait_on_off.curValue.ToString() == "on" ? (byte)100 : (byte)0 }); break; @@ -544,54 +578,54 @@ var deviceId = function.bus.DeviceID; var loopId = function.bus.LoopId; - switch (function.functionCategory) + switch (function.Spk_Prefix) { case FunctionCategory.Light: - switch (function.functionType) + switch (function.spk) { - case FunctionType.Relay: - case FunctionType.Dimmer: + case SPK.LightSwitch: + case SPK.LightDimming: ControlBytesSend(Command.ReadLightAllLoopBrightness, subnetId, deviceId, new byte[] { }); break; - case FunctionType.RGB: + case SPK.LightRGB: ControlBytesSend(Command.ReadLogicLoopColor, subnetId, deviceId, new byte[] { function.bus.LoopId }); break; } break; case FunctionCategory.Curtain: - switch (function.functionType) + switch (function.spk) { - case FunctionType.Curtain: - case FunctionType.MotorCurtain: - case FunctionType.RollingShutter: + case SPK.CurtainSwitch: + case SPK.CurtainTrietex: + case SPK.CurtainRoller: ControlBytesSend(Command.ReadCurtainStatus, subnetId, deviceId, new byte[] { function.bus.LoopId }); break; } break; - case FunctionCategory.Thermostat: - switch (function.functionType) + case FunctionCategory.AC: + switch (function.spk) { - case FunctionType.AC: + case SPK.AcStandard: ControlBytesSend(Command.ReadACMode, subnetId, deviceId, new byte[] { function.bus.LoopId }); break; - case FunctionType.FloorHeating: + } + break; + case FunctionCategory.FloorHeat: + switch (function.spk) + { + case SPK.FloorHeatStandard: ControlBytesSend(Command.ReadFloorHeat, subnetId, deviceId, new byte[] { function.bus.LoopId }); break; } break; - case FunctionCategory.Electrical: - switch (function.functionType) + case FunctionCategory.Electric: + switch (function.spk) { - case FunctionType.Fan: + case SPK.ElectricFan: var fan = function as Fan; ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { fan.bus.LoopId }); break; - } - break; - case FunctionCategory.SwitchDevice: - switch (function.functionType) - { - case FunctionType.Socket: + case SPK.ElectricSocket: var s = function as SwitchSocket; ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { s.bus.LoopId }); break; @@ -599,8 +633,26 @@ break; case FunctionCategory.Sensor: var sensor = function as Sensor; - ControlBytesSend(Command.ReadDeviceLoopInfo, subnetId, deviceId, new byte[] { (byte)5, - (byte)((int)sensor.functionType % 256), sensor.bus.LoopId }); + byte sensorType = 0; + switch (function.spk) + { + case SPK.SensorTemperature: + sensorType = 2; + break; + case SPK.SensorHumidity: + sensorType = 3; + break; + case SPK.SensorTVOC: + sensorType = 5; + break; + case SPK.SensorPm25: + sensorType = 6; + break; + case SPK.SensorCO2: + sensorType = 7; + break; + } + ControlBytesSend(Command.ReadDeviceLoopInfo, subnetId, deviceId, new byte[] { 5, sensorType, sensor.bus.LoopId }); break; } } @@ -861,7 +913,7 @@ { wait(); } - //MainPage.Log($"鍙戦�丠dl-Link鏁版嵁锛孖P:{Control.Ins.reportIp}:8585"); + MainPage.Log($"鍙戦�丠dl-Link鏁版嵁锛孖P:{Control.Ins.reportIp}:8585"); } } -- Gitblit v1.8.0