blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
wxr
2020-12-19 792ca2a402feb952ef890d653f2e049c1230baf1 
 HDL_ON/DAL/DriverLayer/Control_Udp.cs

old mode 100644
new mode 100755

@@ -29,6 +29,7 @@


        /// 所有对一端口的控制都会放到这个集合里


        /// </summary>


        static List<Control_Udp> controlList = new List<Control_Udp>(50);


        




        public System.Net.IPEndPoint EndPoint


        {


@@ -65,7 +66,7 @@


        /// <summary>


        /// 重发验证


        /// </summary>


        public void ReceiveRepeatManager(string receiveFlag)


        public static void ReceiveRepeatManager(string receiveFlag,byte []usefulBytes)


        {


            for (int i = 0; i < controlList.Count; i++)


            {


@@ -175,7 +176,7 @@


                                        break;


                                }


                                ControlBytesSend(Command.SetCurtainModelStutas, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID,


                                    new byte[] { f.localFunction.bus.loopId, curtainState });


                                    new byte[] { f.localFunction.bus.LoopId, curtainState });


                                break;


                            }


                        }


@@ -218,10 +219,10 @@


                                    }


                                    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 });


                            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:


@@ -248,7 +249,7 @@


                            }


                        }


                        ControlBytesSend(Command.SetSingleLight, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID,


                            new byte[] { f.localFunction.bus.loopId, brightness });


                            new byte[] { f.localFunction.bus.LoopId, brightness });


                        break;


                    case FunctionType.RGB:


                        break;


@@ -271,7 +272,7 @@


                        }


                        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 });


                                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)


@@ -289,7 +290,7 @@


                                        break;


                                }


                                ControlBytesSend(Command.SetSingleLight, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID,


                                    new byte[] { f.localFunction.bus.loopId, onOffValue });


                                    new byte[] { f.localFunction.bus.LoopId, onOffValue });


                                break;


                            }


                        }


@@ -309,7 +310,7 @@


            {


                var subnetId = function.bus.SubnetID;


                var deviceId = function.bus.DeviceID;


                var loopId = function.bus.loopId;


                var loopId = function.bus.LoopId;




                switch (function.functionCategory)


                {


@@ -328,11 +329,11 @@


                                {


                                    b = (byte)light.brightness == 0 ? (byte)100 : (byte)light.brightness;


                                }


                                var bytes = new byte[] { function.bus.loopId,


                                var bytes = new byte[] { function.bus.LoopId,


                                            b,


                                            254, 0,Convert.ToByte(light.fadeTime) ,3,


                                            (byte)light.redColor,(byte)light.greenColor,


                                            (byte)light.blueColor,


                                            (byte)light.RedColor,(byte)light.GreenColor,


                                            (byte)light.BlueColor,


                                            0,0};


                                ControlBytesSend(Command.SetLogicLoopColor, subnetId, deviceId, bytes, 1);


                                break;


@@ -347,13 +348,13 @@


                                    b1 = (byte)light.brightness == 0 ? (byte)100 : (byte)light.brightness;


                                }


                                ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] {


                                            function.bus.loopId,


                                            function.bus.LoopId,


                                            b1,


                                            0, Convert.ToByte(light.fadeTime) });


                                //DimmerPage.UpdataStates(light);


                                break;


                            case FunctionType.Relay:


                                ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { function.bus.loopId, light.trait_on_off.curValue.ToString() == "on" ? (byte)100 : (byte)0, 0, 0 });


                                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;


                        }


@@ -376,7 +377,7 @@


                                {


                                    b1 = 2;


                                }


                                ControlBytesSend(Command.SetCurtainModelStutas, subnetId, deviceId, new byte[] { curtain.bus.loopId, b1 });


                                ControlBytesSend(Command.SetCurtainModelStutas, subnetId, deviceId, new byte[] { curtain.bus.LoopId, b1 });


                                break;


                            case FunctionType.MotorCurtain:


                            case FunctionType.RollingShutter:


@@ -384,7 +385,7 @@


                                //{


                                if (curtain.trait_on_off.curValue.ToString() == "stop")


                                {


                                    ControlBytesSend(Command.SetCurtainModelStutas, subnetId, deviceId, new byte[] { curtain.bus.loopId, 0 });


                                    ControlBytesSend(Command.SetCurtainModelStutas, subnetId, deviceId, new byte[] { curtain.bus.LoopId, 0 });


                                }


                                else


                                {


@@ -415,20 +416,20 @@


                        {


                            case FunctionType.AC:


                                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.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 });


                                foreach (var dic in commandDictionary)


                                {


                                    switch (dic.Key)


                                    {


                                        case "on_off":


                                            ControlBytesSend(Command.InstructionPanelKey, aC.bus.SubnetID, aC.bus.DeviceID, new byte[] { 3, aC.trait_on_off.curValue.ToString() == "on" ? (byte)1 : (byte)0, aC.bus.loopId });


                                            ControlBytesSend(Command.InstructionPanelKey, aC.bus.SubnetID, aC.bus.DeviceID, new byte[] { 3, aC.trait_on_off.curValue.ToString() == "on" ? (byte)1 : (byte)0, aC.bus.LoopId });


                                            break;


                                        case "mode":


                                            ControlBytesSend(Command.InstructionPanelKey, aC.bus.SubnetID, aC.bus.DeviceID, new byte[] { 6, aC.curModeIndex, aC.bus.loopId });


                                            ControlBytesSend(Command.InstructionPanelKey, aC.bus.SubnetID, aC.bus.DeviceID, new byte[] { 6, aC.curModeIndex, aC.bus.LoopId });


                                            break;


                                        case "fan":


                                            ControlBytesSend(Command.InstructionPanelKey, aC.bus.SubnetID, aC.bus.DeviceID, new byte[] { 5, aC.curFanIndex, aC.bus.loopId });


                                            ControlBytesSend(Command.InstructionPanelKey, aC.bus.SubnetID, aC.bus.DeviceID, new byte[] { 5, aC.curFanIndex, aC.bus.LoopId });


                                            break;


                                        case "temp":


                                            byte modeKey = 4;


@@ -450,7 +451,7 @@


                                                    modeKey = 2;


                                                    break;


                                            }


                                            ControlBytesSend(Command.InstructionPanelKey, aC.bus.SubnetID, aC.bus.DeviceID, new byte[] { modeKey, Convert.ToByte(aC.trait_temp.curValue), aC.bus.loopId });


                                            ControlBytesSend(Command.InstructionPanelKey, aC.bus.SubnetID, aC.bus.DeviceID, new byte[] { modeKey, Convert.ToByte(aC.trait_temp.curValue), aC.bus.LoopId });


                                            break;


                                        default:


                                            MainPage.Log($"功能未支持 : {dic.Key}");


@@ -489,7 +490,7 @@


                                                break;


                                        }


                                    }


                                    ControlBytesSend(Command.SetFloorHeat, subnetId, deviceId, new byte[] { fh.bus.loopId, b1, (byte)fh.curTempType, fh.curModeIndex, fh.modeTemp["normal"], fh.modeTemp["day"], fh.modeTemp["night"], fh.modeTemp["away"], 0, 0 });


                                    ControlBytesSend(Command.SetFloorHeat, subnetId, deviceId, new byte[] { fh.bus.LoopId, b1, (byte)fh.curTempType, fh.curModeIndex, fh.modeTemp["normal"], fh.modeTemp["day"], fh.modeTemp["night"], fh.modeTemp["away"], 0, 0 });


                                }


                                break;


                        }


@@ -501,10 +502,10 @@


                                var fan = function as Fan;


                                if (fan.trait_on_off.curValue.ToString() == "on")


                                {


                                    ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { fan.bus.loopId, (byte)fan.openLevel });


                                    ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { fan.bus.LoopId, (byte)fan.openLevel });


                                }


                                {


                                    ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { fan.bus.loopId, 0 });


                                    ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { fan.bus.LoopId, 0 });


                                }


                                break;


                        }


@@ -514,7 +515,7 @@


                        {


                            case FunctionType.Socket:


                                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 });


                                ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { s.bus.LoopId, s.trait_on_off.curValue.ToString() == "on" ? (byte)100 : (byte)0 });


                                break;


                        }


                        break;


@@ -541,7 +542,7 @@


            {


                var subnetId = function.bus.SubnetID;


                var deviceId = function.bus.DeviceID;


                var loopId = function.bus.loopId;


                var loopId = function.bus.LoopId;




                switch (function.functionCategory)


                {


@@ -553,7 +554,7 @@


                                ControlBytesSend(Command.ReadLightAllLoopBrightness, subnetId, deviceId, new byte[] { });


                                break;


                            case FunctionType.RGB:


                                ControlBytesSend(Command.ReadLogicLoopColor, subnetId, deviceId, new byte[] { function.bus.loopId });


                                ControlBytesSend(Command.ReadLogicLoopColor, subnetId, deviceId, new byte[] { function.bus.LoopId });


                                break;


                        }


                        break;


@@ -563,7 +564,7 @@


                            case FunctionType.Curtain:


                            case FunctionType.MotorCurtain:


                            case FunctionType.RollingShutter:


                                ControlBytesSend(Command.ReadCurtainStatus, subnetId, deviceId, new byte[] { function.bus.loopId });


                                ControlBytesSend(Command.ReadCurtainStatus, subnetId, deviceId, new byte[] { function.bus.LoopId });


                                break;


                        }


                        break;


@@ -571,10 +572,10 @@


                        switch (function.functionType)


                        {


                            case FunctionType.AC:


                                ControlBytesSend(Command.ReadACMode, subnetId, deviceId, new byte[] { function.bus.loopId });


                                ControlBytesSend(Command.ReadACMode, subnetId, deviceId, new byte[] { function.bus.LoopId });


                                break;


                            case FunctionType.FloorHeating:


                                ControlBytesSend(Command.ReadFloorHeat, subnetId, deviceId, new byte[] { function.bus.loopId });


                                ControlBytesSend(Command.ReadFloorHeat, subnetId, deviceId, new byte[] { function.bus.LoopId });


                                break;


                        }


                        break;


@@ -583,7 +584,7 @@


                        {


                            case FunctionType.Fan:


                                var fan = function as Fan;


                                ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { fan.bus.loopId });


                                ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { fan.bus.LoopId });


                                break;


                        }


                        break;


@@ -592,14 +593,14 @@


                        {


                            case FunctionType.Socket:


                                var s = function as SwitchSocket;


                                ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { s.bus.loopId });


                                ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { s.bus.LoopId });


                                break;


                        }


                        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)((int)sensor.functionType % 256), sensor.bus.LoopId });


                        break;


                }


            }


@@ -623,7 +624,7 @@


                {


                    for (int i = 0; i < controlList.Count;)


                    {


                        if (controlList[i] == null || 3 <= controlList[i].Packet.HaveSendCount)


                        if (controlList[i] == null || 3 <= controlList[i].packet.HaveSendCount)


                        {


                            controlList.RemoveAt(i);


                        }


@@ -692,7 +693,7 @@


        void run()


        {


            allDone.Set();


            Packet.HaveSendCount = 4;


            packet.HaveSendCount = 4;


        }




        //数据发送处理


@@ -706,7 +707,7 @@


                new System.Threading.Thread(() =>


                {


                    System.Threading.Thread.Sleep(1000);


                    UdpSocket._BusSocket.Start(6000);


                    UdpSocket._BusSocket.Start(UdpSocket._BusSocket.Port);


                    controlLostCount = 0;


                })


                { IsBackground = true }.Start();


@@ -715,16 +716,16 @@


            try


            {


                //MainPage.Log("发送数据:" + SendFlag);


                UdpSocket._BusSocket.AsyncBeginSend(Packet);


                Packet.HaveSendCount--;


                UdpSocket._BusSocket.AsyncBeginSend(packet);


                packet.HaveSendCount--;




                //这里是重发两次


                while (Packet.HaveSendCount < 3)


                while (packet.HaveSendCount < 3)


                {


                    if (Packet.FlagDateTime.AddMilliseconds(1000).Ticks <= DateTime.Now.Ticks)


                    if (packet.FlagDateTime.AddMilliseconds(1000).Ticks <= DateTime.Now.Ticks)


                    {


                        MainPage.Log("重发数据:" + SendFlag);


                        UdpSocket._BusSocket.AsyncBeginSend(Packet);


                        UdpSocket._BusSocket.AsyncBeginSend(packet);


                        controlLostCount++;


                    }


                    System.Threading.Thread.Sleep(100);


@@ -743,7 +744,7 @@


        /// <summary>


        /// 当前数据包


        /// </summary>


        Packet Packet;


        Packet packet;


        /// <summary>


        /// 记录发送数据包


        /// </summary>


@@ -787,6 +788,10 @@




        }




        //private void signAlinkPacket()


        //{


        //}




        /// <summary>


        /// 发送数据


        /// </summary>


@@ -796,14 +801,14 @@


        {


            try


            {


                Packet = new Packet(target.SendBytes, target.IPEndPoint);


                Packet.HaveSendCount = 3 - sendCount;


                packet = new Packet(target.SendBytes, target.IPEndPoint);


                packet.HaveSendCount = 3 - sendCount;




                signPacket(target);




                System.Threading.Thread thread = new System.Threading.Thread(new System.Threading.ParameterizedThreadStart(managerSendCount));


                thread.IsBackground = true;


                thread.Start(Packet);


                thread.Start(packet);




                if (isWait)


                {


@@ -828,11 +833,11 @@


                


                var sendBytes = Control.Ins.ConvertSendBodyData(CommunicationTopic.SearchLoaclGateway, bodyString);


                //组播发送


                Packet = new Packet(sendBytes, new System.Net.IPEndPoint(System.Net.IPAddress.Parse("239.0.168.188"), 8585));


                Packet.HaveSendCount = 4;//ps：没有重发，后期有时间可以增加重发判断


                packet = new Packet(sendBytes, new System.Net.IPEndPoint(System.Net.IPAddress.Parse("239.0.168.188"), 8585));


                packet.HaveSendCount = 4;//ps：没有重发，后期有时间可以增加重发判断


                System.Threading.Thread thread = new System.Threading.Thread(new System.Threading.ParameterizedThreadStart(managerSendCount));


                thread.IsBackground = true;


                thread.Start(Packet);


                thread.Start(packet);


                //wait();不需要等待


            }


            catch (Exception ex)


@@ -840,20 +845,24 @@


                MainPage.Log($"Send bus data error {ex.Message}");


            }


        }






        /// <summary>


        /// 发送udp A协议数据


        /// </summary>


        public void SendLocalHdlLinkData(byte[] sendBytes)


        public void SendLocalHdlLinkData(byte[] sendBytes,string id, bool isWait=false)


        {


            Packet = new Packet(sendBytes, new System.Net.IPEndPoint(System.Net.IPAddress.Parse(Control.Ins.reportIp), 8585));


            Packet.HaveSendCount = 4;//ps：没有重发，后期有时间可以增加重发判断


            packet = new Packet(sendBytes, new System.Net.IPEndPoint(System.Net.IPAddress.Parse(Control.Ins.reportIp), 8585));


            sendFlag = id;


            System.Threading.Thread thread = new System.Threading.Thread(new System.Threading.ParameterizedThreadStart(managerSendCount));


            thread.IsBackground = true;


            thread.Start(Packet);


            //wait();不需要等待


            thread.Start(packet);


            if (isWait)


            {


                wait(); 


            }


            //MainPage.Log($"发送Hdl-Link数据，IP:{Control.Ins.reportIp}:8585");


        }






    }




}