using System;
using System.Collections.Generic;
using System.Text;
using HDL_ON.DriverLayer;
using HDL_ON.Entity;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using Shared.Net;

namespace HDL_ON.DriverLayer
{
    public class Control_Udp
    {
        //public Control_Udp()
        //{
        //    MainPage.Log($"control bus udp 被创建，时间：{DateTime.Now}");
        //}
        /// <summary>
        /// 通讯端口
        /// </summary>
        public int port = 0;

        /// <summary>
        /// 控制失败次数
        /// </summary>
        public int controlLostCount = 0;

        /// <summary>
        /// 所有对一端口的控制都会放到这个集合里
        /// </summary>
        static List<Control_Udp> controlList = new List<Control_Udp>(50);
        

        public System.Net.IPEndPoint EndPoint
        {
            get
            {
                try
                {
                    return new System.Net.IPEndPoint(System.Net.IPAddress.Parse(new NetWiFi().BroadcastIpAddress.ToString()),6000);
                }
                catch
                {
                    //防止异常导致程序退出
                    return new System.Net.IPEndPoint(System.Net.IPAddress.Parse("127.0.0.1"), 6000);
                }
            }
        }

        /// <summary>
        /// 发送数据，不需要等待回复
        /// </summary>
        public void ControlBytesSend(Command command, byte subnetID, byte deviceID, byte[] gatewayBytes, int sendCount = 3,bool reSend = false)
        {
#if DEBUG
            string ddd = "";
            foreach (var bb in gatewayBytes)
            {
                ddd += bb + ",";
            }
            MainPage.Log($"发送bus命令:" + ((int)command).ToString("X").PadLeft(4,'0') + " : 数据:" + ddd);
#endif

            var control = new Control_Udp();
            control.Send(new Target()
            {
                IPEndPoint =  EndPoint ,
                Command = command,
                SubnetID = subnetID,
                DeviceID = deviceID,
                AddData = gatewayBytes,
            //}, 3, true);
            }, sendCount, reSend);
        }

        /// <summary>
        /// 重发验证
        /// </summary>
        public static void ReceiveRepeatManager(string receiveFlag,byte []usefulBytes)
        {
            for (int i = 0; i < controlList.Count; i++)
            {
                try
                {
                    var control = controlList[i];
                    if (control.SendFlag == receiveFlag)
                    {
                        control.UsefulBytes = usefulBytes;//
                        control.run();
                    }
                }
                catch (Exception ex)
                {
                    Console.WriteLine($"control error : {ex.Message}");
                }
            }
        }

        /// <summary>
        /// 000E 搜索回复
        /// </summary>
        public void ReceiveReadRemark(byte[] usefullBytes)
        {
            try
            {
                //账号没登录不回复
                if ( UserInfo.Current == null || ! UserInfo.Current.IsLogin)
                {
                    return;
                }

                Control.Ins.OpenTcpServer();
                var sendStr =  UserInfo.Current.AccountString;
                if (usefullBytes.Length == 0)
                {
                    SendRemark(sendStr);
                }
                else
                {
                    bool isExit = false;
                    for (int i = 0, len = usefullBytes.Length; i < len; i++)
                    {
                        if (i % 2 == 0)
                        {
                            if ((usefullBytes[i] & 0xFF) == 252 && (usefullBytes[i + 1] & 0xFF) == 252)
                            {
                                isExit = true;
                                break;
                            }
                        }
                    }
                    if (!isExit)
                    {
                        //不存在，代表没收到本机的发送，继续回复
                        SendRemark(sendStr);
                    }
                }
            }
            catch (Exception ex) {
                Console.WriteLine($"回复bus搜索异常 : {ex.Message}");
            }
        }
        /// <summary>
        /// 000F回复备注
        /// </summary>
        void SendRemark(string sendStr)
        {
            byte[] sendBytes = new byte[20];
            byte[] b1 = Encoding.GetEncoding("gb2312").GetBytes(sendStr);
            Array.Copy(b1, 0, sendBytes, 0, 20 < b1.Length ? 20 : b1.Length);

            var control = new Control_Udp();
            control.Send(new Target()
            {
                IPEndPoint = EndPoint,
                Command = Command.ReadRemarkACK,
                SubnetID = 0xFF,
                DeviceID = 0xFF,
                AddData = sendBytes,
            }, 0, false); //设置当前发送指令方式为：任何情况下本地发送、不限制、不加密明文发送
        }

        /// <summary>
        /// 控制bus场景
        /// </summary>
        public void ControlBusScenes(Scene scene)
        {
            if(Control.Ins.GatewayOnline_Local)
            {
                foreach (var f in scene.functions)
                {
                    if (f.localFunction == null)
                    {
                        continue;
                    }
                    switch (f.localFunction.spk)
                    {
                        case SPK.CurtainSwitch:
                            foreach (var attr in f.status)
                            {
                                if (attr.key == FunctionAttributeKey.OnOff)
                                {
                                    byte curtainState = 0;
                                    switch (attr.value)
                                    {
                                        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 },0);
                                    break;
                                }
                            }
                            break;
                        case SPK.AcStandard:
                        case SPK.HvacAC:
                            AC acTemp = new AC();
                            byte onoff = 0;
                            byte mode = 0;
                            byte fan = 0;
                            foreach (var attr in f.status)
                            {
                                byte modeKey = 4;
                                switch (attr.key)
                                {
                                    case FunctionAttributeKey.OnOff:
                                        if(attr.value == "on")
                                        {
                                            onoff = 1;
                                        }
                                        else
                                        {
                                            onoff = 0;
                                        }
                                        break;
                                    case FunctionAttributeKey.Mode:
                                        switch (attr.value)
                                        {
                                            case "auto":
                                                mode = 3;
                                                modeKey = 8;
                                                break;
                                            case "cool":
                                                mode = 0;
                                                modeKey = 4;
                                                break;
                                            case "heat":
                                                mode = 1;
                                                modeKey = 7;
                                                break;
                                            case "dry":
                                                mode = 4;
                                                modeKey = 19;
                                                break;
                                            case "fan":
                                                mode = 2;
                                                modeKey = 2;
                                                break;
                                        }
                                        break;
                                    case FunctionAttributeKey.FanSpeed:
                                        switch (attr.value)
                                        {
                                            case "high":
                                                fan = 1;
                                                break;
                                            case "medium":
                                                fan = 2;
                                                break;
                                            case "low":
                                                fan = 3;
                                                break;
                                            case "auto":
                                                fan = 0;
                                                break;
                                            default:
                                                fan = 0;
                                                break;
                                        }
                                        break;
                                    case FunctionAttributeKey.SetTemp:
                                        ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] {
                                                modeKey, Convert.ToByte(attr.value), f.localFunction.bus.LoopId });
                                        break;
                                }
                                ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { 3, onoff, f.localFunction.bus.LoopId });
                                ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { 6, mode, f.localFunction.bus.LoopId });
                                ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { 5, fan, f.localFunction.bus.LoopId });
                                ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { modeKey, modeKey, f.localFunction.bus.LoopId });
                               
                    }
                            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.HvacFloorHeat:case SPK.FloorHeatStandard:
                            if (f.status.Find((obj)=>obj.key ==FunctionAttributeKey.Mode) == null)
                            {
                                foreach (var dic in f.status)
                                {
                                    switch (dic.key)
                                    {
                                        case FunctionAttributeKey.OnOff:
                                            ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { 20, dic.value.ToString() == "on" ? (byte)1 : (byte)0, f.localFunction.bus.LoopId });
                                            break;
                                        case "mode":
                                            ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] { 21, Convert.ToByte(dic.value), f.localFunction.bus.LoopId });
                                            break;
                                        case FunctionAttributeKey.SetTemp:
                                            ControlBytesSend(Command.InstructionPanelKey, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] {
                                                25, Convert.ToByte(dic.value), f.localFunction.bus.LoopId });
                                            break;
                                    }
                                }
                            }
                            else
                            {
                                byte onoff_1 = 0;
                                byte setTemp_1 = 0;
                                byte mode_1 = 0;
                                foreach (var attr in f.status)
                                {
                                    switch (attr.key)
                                    {
                                        case FunctionAttributeKey.OnOff:
                                            if (attr.value == "on")
                                            {
                                                onoff_1 = 1;
                                            }
                                            else
                                            {
                                                onoff_1 = 0;
                                            }
                                            break;
                                        case FunctionAttributeKey.SetTemp:
                                            setTemp_1 = Convert.ToByte(attr.value);
                                            break;
                                        case FunctionAttributeKey.Mode:
                                            switch (attr.value)
                                            {
                                                case "day":
                                                    mode_1 = 2;
                                                    break;
                                                case "night":
                                                    mode_1 = 3;
                                                    break;
                                                case "away":
                                                    mode_1 = 4;
                                                    break;
                                                case "normal":
                                                    mode_1 = 1;
                                                    break;
                                                case "timer":
                                                    mode_1 = 5;
                                                    break;
                                            }
                                            break;
                                    }
                                }
                                ControlBytesSend(Command.SetFloorHeat, f.localFunction.bus.SubnetID, f.localFunction.bus.DeviceID, new byte[] {
                                f. localFunction.bus.LoopId, onoff_1, 0, setTemp_1, mode_1,  setTemp_1, setTemp_1, setTemp_1, 0, 0 });
                            }
                            break;
                        case SPK.ElectricSocket:
                        case SPK.PanelSocket:
                            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;
                    }
                }
            }
            else
            {
                foreach (var f in scene.functions)
                {
                    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)
                        {
                            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);
                }
            }
        }

        /// <summary>
        /// 控制bus设备
        /// </summary>
        /// <param name="commandString"></param>
        /// <returns></returns>
        public void WriteBusData(Function function, Dictionary<string, string> commandDictionary, bool reSend = false)
        {
            try
            {
                var subnetId = function.bus.SubnetID;
                var deviceId = function.bus.DeviceID;
                var loopId = function.bus.LoopId;

                switch (function.spk)
                {
                    case SPK.LightCCT:
                        #region cct light
                        byte b0 = 100;
                        if (commandDictionary.ContainsKey(FunctionAttributeKey.OnOff))
                        {
                            if (function.trait_on_off.curValue.ToString() == "off")
                            {
                                b0 = 0;
                            }
                            else
                            {
                                b0 = function.lastBrightness == 0 ? (byte)100 : Convert.ToByte(function.lastBrightness);
                            }
                        }
                        else
                        {
                            b0 = Convert.ToByte(function.GetAttrState(FunctionAttributeKey.Brightness));
                        }
                        var bytes0 = new byte[] { function.bus.LoopId,
                                            b0,
                                            254, 0,Convert.ToByte(function.GetAttrState(FunctionAttributeKey.FadeTime)) ,2,
                                            (byte)(Convert.ToInt32(function.GetAttrState(FunctionAttributeKey.CCT))/256),
                                            (byte)(Convert.ToInt32(function.GetAttrState(FunctionAttributeKey.CCT))%256),
                                            0,
                                            0,0};
                        ControlBytesSend(Command.SetLogicLoopColor, subnetId, deviceId, bytes0, 1);
                        #endregion
                        break;
                    case SPK.LightRGB:
                        #region rgb light
                        byte b = 100;
                        if (commandDictionary.ContainsKey(FunctionAttributeKey.OnOff))
                        {
                            if (function.trait_on_off.curValue.ToString() == "off")
                            {
                                b = 0;
                            }
                            else
                            {
                                b = function.lastBrightness == 0 ? (byte)100 : Convert.ToByte(function.lastBrightness);
                            }
                        }
                        else
                        {
                            b = Convert.ToByte(function.GetAttrState(FunctionAttributeKey.Brightness));
                        }
                        var tempLight = new Light();
                        var bytes = new byte[] { function.bus.LoopId,
                                            b,
                                            254, 0,Convert.ToByte(function.GetAttrState(FunctionAttributeKey.FadeTime)) ,3,
                                            (byte)tempLight.GetColor(0,function),
                                            (byte)tempLight.GetColor(1,function),
                                            (byte)tempLight.GetColor(2,function),
                                            0,0};
                        ControlBytesSend(Command.SetLogicLoopColor, subnetId, deviceId, bytes, 1);
                        #endregion
                        break;
                    case SPK.LightDimming:
                        #region dimming light
                        byte b1 = 100;
                        if (commandDictionary.ContainsKey(FunctionAttributeKey.OnOff))
                        {
                            if (function.trait_on_off.curValue.ToString() == "off")
                            {
                                b1 = 0;
                            }
                            else
                            {
                                b1 = function.lastBrightness == 0 ? (byte)100 : Convert.ToByte(function.lastBrightness);
                            }
                        }
                        else
                        {
                            b1 = Convert.ToByte(function.GetAttrState(FunctionAttributeKey.Brightness));
                        }
                        ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] {
                                            function.bus.LoopId,
                                            b1,
                                            0, Convert.ToByte(function.GetAttrState(FunctionAttributeKey.FadeTime)) });
                        #endregion
                        break;
                    case SPK.LightSwitch:
                        #region LightSwitch
                        ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { function.bus.LoopId, function.trait_on_off.curValue.ToString() == "on" ? (byte)100 : (byte)0, 0, 0 });
                        #endregion
                        break;
                    case SPK.CurtainSwitch:
                        #region switch curtain
                        byte switchCurtain = 0;
                        if (function.trait_on_off.curValue.ToString() == "stop")
                        {
                            switchCurtain = 0;
                        }
                        else if (function.trait_on_off.curValue.ToString() == "on")
                        {
                            switchCurtain = 1;
                        }
                        else
                        {
                            switchCurtain = 2;
                        }
                        ControlBytesSend(Command.SetCurtainModelStutas, subnetId, deviceId, new byte[] { function.bus.LoopId, switchCurtain });
                        #endregion
                        break;
                    case SPK.CurtainTrietex:
                    case SPK.CurtainRoller:
                        if (function.trait_on_off.curValue.ToString() == "stop")
                        {
                            ControlBytesSend(Command.SetCurtainModelStutas, subnetId, deviceId, new byte[] { function.bus.LoopId, 0 });
                        }
                        else
                        {
                            if (commandDictionary.ContainsKey(FunctionAttributeKey.Percent))
                            {
                                ControlBytesSend(Command.SetCurtainModelStutas, subnetId, deviceId, new byte[] { (byte)(((int)function.bus.LoopId) + 16), Convert.ToByte(function.GetAttrState(FunctionAttributeKey.Percent)) });
                            }
                            else
                            {

                                byte tempCurtainState = 0;
                                if (function.trait_on_off.curValue.ToString() == "stop")
                                {
                                    tempCurtainState = 0;
                                }
                                else if (function.trait_on_off.curValue.ToString() == "on")
                                {
                                    tempCurtainState = 1;
                                }
                                else
                                {
                                    tempCurtainState = 2;
                                }
                                ControlBytesSend(Command.SetCurtainModelStutas, subnetId, deviceId, new byte[] { function.bus.LoopId, tempCurtainState });
                            }

                        }
                        break;
                    case SPK.AcStandard:
                    case SPK.HvacAC:
                        var ac = new AC();

                        byte onoff = 0;
                        onoff = function.trait_on_off.curValue.ToString() == "on" ? (byte)1 : (byte)0;
                        byte mode = 0;
                        mode = ac.GetModeIndex(function);
                        byte fan = 0;
                        fan = ac.GetFanIndex(function);
                        byte sanfan = 0;
                        byte temp = 16;
                        temp = Convert.ToByte(function.GetAttrState(FunctionAttributeKey.SetTemp));
                        foreach (var dic in commandDictionary)
                        {
                            switch (dic.Key)
                            {
                                case FunctionAttributeKey.OnOff:
                                    onoff = dic.Value == "on" ? (byte)1 : (byte)0;
                                    //ControlBytesSend(Command.InstructionPanelKey, function.bus.SubnetID, function.bus.DeviceID,
                                    //    new byte[] { 3, onoff, function.bus.LoopId });
                                    break;
                                case "mode":
                                    switch (dic.Value)
                                    {
                                        case "auto":
                                            mode = 3;
                                            break;
                                        case "cool":
                                            mode = 0;
                                            break;
                                        case "heat":
                                            mode = 1;
                                            break;
                                        case "dry":
                                            mode = 4;
                                            break;
                                        case "fan":
                                            mode = 2;
                                            break;
                                        default:
                                            mode = 0;
                                            break;
                                    }
                                    //ControlBytesSend(Command.InstructionPanelKey, function.bus.SubnetID, function.bus.DeviceID,
                                    //    new byte[] { 6, mode, function.bus.LoopId });
                                    break;
                                case "fan":
                                    switch (dic.Value)
                                    {
                                        case "high":
                                            fan = 1;
                                            break;
                                        case "medium":
                                            fan = 2;
                                            break;
                                        case "low":
                                            fan = 3;
                                            break;
                                        case "auto":
                                            fan = 0;
                                            break;
                                        default:
                                            fan = 0;
                                            break;
                                    }
                                    //ControlBytesSend(Command.InstructionPanelKey, function.bus.SubnetID, function.bus.DeviceID,
                                    //    new byte[] { 5, fan, function.bus.LoopId });
                                    break;
                                case FunctionAttributeKey.SetTemp:
                                    try
                                    {
                                        temp = Convert.ToByte(dic.Value);
                                    }
                                    catch
                                    {
                                        temp = 16;
                                    }
                                    //byte modeKey = 4;
                                    //switch (ac.GetModeIndex(function))
                                    //{
                                    //    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;
                                    //}
                                    
                                    //ControlBytesSend(Command.InstructionPanelKey, function.bus.SubnetID, function.bus.DeviceID, new byte[] {
                                    //            modeKey, temp, function.bus.LoopId });
                                    break;
                                case FunctionAttributeKey.Swing:
                                    //sanfan
                                    break;
                                default:
                                    MainPage.Log($"功能未支持 : {dic.Key}");
                                    break;
                            }
                        }
                        /// 设置空调模块命令
                        /// 1空调号(1-128) 
                        ///2温度模式(摄氏Celsius:0，华氏Fahrenheit:1)                                     
                        ///3环境温度 (摄氏0-40，华氏32-99)    
                        ///4制冷控制温度(摄氏0-30，华氏32-86)    
                        ///5制热控制温度(摄氏0-30，华氏32-86)
                        ///6自动控制温度(摄氏0-30，华氏32-86)                                                                                           
                        ///7除湿控制温度(摄氏0-30，华氏32-86)
                        ///8椒缢偈导使ぷ髯此?  高4bit模式(0 制冷，1制热，2通风)  低4bit风速(0 自动，1高风?风，3低风)
                        ///9空调开关                 (1开0关)           
                        ///10设置模式               0 制冷1制热，2通风，3自动，4除湿
                        ///11设置风速                0 自动，1高风2中风，3低风          
                        ///12工作模控制温肚掮摄氏0-30，华氏32-86)         
                        ///13扫风模式：高4bit(实际扫风状态：0不扫风，1扫风)，低4bit(设置扫风模式：0不扫风，1扫风)
                        ControlBytesSend(Command.SetACMode, function.bus.SubnetID, function.bus.DeviceID, new byte[] { function.bus.LoopId,
                        0,0,0,0,0,0,0,onoff,mode,fan,temp,sanfan});

                        break;
                    case SPK.HvacFloorHeat:case SPK.FloorHeatStandard:
                        var fhTemp = new FloorHeating();
                        if (function.Fh_Mode_Temp.Count == 4)
                        {
                            if (function.GetAttribute(FunctionAttributeKey.Mode) == null)
                            {
                                foreach (var dic in commandDictionary)
                                {
                                    switch (dic.Key)
                                    {
                                        case FunctionAttributeKey.OnOff:
                                            ControlBytesSend(Command.InstructionPanelKey, function.bus.SubnetID, function.bus.DeviceID, new byte[] { 20, function.trait_on_off.curValue.ToString() == "on" ? (byte)1 : (byte)0, function.bus.LoopId });
                                            break;
                                        case "mode":
                                            ControlBytesSend(Command.InstructionPanelKey, function.bus.SubnetID, function.bus.DeviceID, new byte[] { 21, fhTemp.GetModeIndex(function), function.bus.LoopId });
                                            break;
                                        case FunctionAttributeKey.SetTemp:
                                            byte modeKey = 25;
                                            switch (fhTemp.GetModeIndex(function))
                                            {
                                                case 1:
                                                    modeKey = 25;
                                                    break;
                                                case 2:
                                                    modeKey = 26;
                                                    break;
                                                case 3:
                                                    modeKey = 27;
                                                    break;
                                                case 4:
                                                    modeKey = 28;
                                                    break;
                                            }
                                            ControlBytesSend(Command.InstructionPanelKey, function.bus.SubnetID, function.bus.DeviceID, new byte[] {
                                                modeKey, Convert.ToByte(function.GetAttrState(FunctionAttributeKey.SetTemp)), function.bus.LoopId });
                                            break;
                                        default:
                                            MainPage.Log($"功能未支持 : {dic.Key}");
                                            break;
                                    }
                                }
                            }
                            else
                            {
                                var onoffString = function.trait_on_off.curValue.ToString();
                                byte b12 = 1;
                                if (onoffString == "off")
                                {
                                    b12 = 0;
                                }
                                var wm = fhTemp.GetWorkModeIndex(function);
                                if (wm > 0)
                                {
                                    b12 += (byte)(16 + wm);
                                }
                                if (commandDictionary.ContainsKey("set_temp"))
                                {
                                    var dicTempString = "";
                                    commandDictionary.TryGetValue("set_temp", out dicTempString);
                                    var dicTemp = Convert.ToByte(dicTempString);
                                    var mode22 = function.GetAttrState(FunctionAttributeKey.Mode);
                                    switch (mode22)
                                    {
                                        case "day":
                                            function.Fh_Mode_Temp["day"] = dicTemp;
                                            break;
                                        case "night":
                                            function.Fh_Mode_Temp["night"] = dicTemp;
                                            break;
                                        case "away":
                                            function.Fh_Mode_Temp["away"] = dicTemp;
                                            break;
                                        case "normal":
                                            function.Fh_Mode_Temp["normal"] = dicTemp;
                                            break;
                                    }
                                }
                                var tt = fhTemp.GetTempUintIndex(function);
                                ControlBytesSend(Command.SetFloorHeat, subnetId, deviceId, new byte[] { function.bus.LoopId, b12,
                                        (byte)tt,fhTemp.GetModeIndex(function), function.Fh_Mode_Temp["normal"], function.Fh_Mode_Temp["day"], function.Fh_Mode_Temp["night"], function.Fh_Mode_Temp["away"], 0, 0 });
                            }
                        }
                        break;
                    case SPK.HvacFan:
                    case SPK.ElectricFan:
                        #region ElectricFan
                        if (function.trait_on_off.curValue.ToString() == "on")
                        {
                            ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { function.bus.LoopId, Convert.ToByte(function.GetAttrState(FunctionAttributeKey.OpenLevel)) });
                        }
                        {
                            ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { function.bus.LoopId, 0 });
                        }
                        #endregion
                        break;
                    case SPK.ElectricSocket:
                    case SPK.PanelSocket:
                        ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { function.bus.LoopId, function.trait_on_off.curValue.ToString() == "on" ? (byte)100 : (byte)0 });
                        break;
                }
                #region 发送命令立即更新UI
                //HomePage.UpdataFunctionStates(function);
                //RoomPage.UpdataStates(function);
                //FunctionPage.UpdataStates(function);
                //ClassificationPage.UpdataInfo(function);
                #endregion
            }
            catch (Exception ex)
            {
                MainPage.Log($"DataConversion_Bus Erorr : {ex.Message}");
            }
        }

        /// <summary>
        /// 读取bus设备数据
        /// </summary>
        public void ReadBusData(Function function)
        {
            try
            {
                var subnetId = function.bus.SubnetID;
                var deviceId = function.bus.DeviceID;
                var loopId = function.bus.LoopId;

                switch (function.spk)
                {
                    case SPK.LightSwitch:
                    case SPK.LightDimming:
                        ControlBytesSend(Command.ReadLightAllLoopBrightness, subnetId, deviceId, new byte[] { });
                        break;
                    case SPK.LightRGB:
                        ControlBytesSend(Command.ReadLogicLoopColor, subnetId, deviceId, new byte[] { function.bus.LoopId });
                        break;
                    case SPK.LightCCT:
                        ControlBytesSend(Command.ReadLogicLoopColor, subnetId, deviceId, new byte[] { function.bus.LoopId });
                        break;
                    case SPK.CurtainSwitch:
                    case SPK.CurtainTrietex:
                    case SPK.CurtainRoller:
                        ControlBytesSend(Command.ReadCurtainStatus, subnetId, deviceId, new byte[] { function.bus.LoopId });
                        break;
                    case SPK.AcStandard:
                    case SPK.HvacAC:
                        ControlBytesSend(Command.ReadACMode, subnetId, deviceId, new byte[] { function.bus.LoopId });
                        break;
                    case SPK.HvacFloorHeat:case SPK.FloorHeatStandard:
                        ControlBytesSend(Command.ReadFloorHeat, subnetId, deviceId, new byte[] { function.bus.LoopId });
                        break;
                    case SPK.HvacFan:
                    case SPK.ElectricFan:
                        ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { function.bus.LoopId });
                        break;
                    case SPK.ElectricSocket:
                    case SPK.PanelSocket:
                        ControlBytesSend(Command.SetSingleLight, subnetId, deviceId, new byte[] { function.bus.LoopId });
                        break;
                    case SPK.SensorTemperature:
                        ControlBytesSend(Command.ReadDeviceLoopInfo, subnetId, deviceId, new byte[] { 5, 2, function.bus.LoopId });
                        break;
                    case SPK.SensorHumidity:
                        ControlBytesSend(Command.ReadDeviceLoopInfo, subnetId, deviceId, new byte[] { 5, 3, function.bus.LoopId });
                        break;
                    case SPK.SensorTVOC:
                        ControlBytesSend(Command.ReadDeviceLoopInfo, subnetId, deviceId, new byte[] { 5, 5, function.bus.LoopId });
                        break;
                    case SPK.SensorPm25:
                        ControlBytesSend(Command.ReadDeviceLoopInfo, subnetId, deviceId, new byte[] { 5, 6, function.bus.LoopId });
                        break;
                    case SPK.SensorCO2:
                        ControlBytesSend(Command.ReadDeviceLoopInfo, subnetId, deviceId, new byte[] { 5, 7, function.bus.LoopId });
                        break;
                }
            }
            catch (Exception ex)
            {
                MainPage.Log($"Read DataConversion_Bus Erorr : {ex.Message}");
            }
        }

        /// <summary>
        /// 添加到内存数组里面
        /// </summary>
        void add()
        {
            /// <summary>
            /// 达到50条数据后就清理一下
            /// </summary>
            if (50 < controlList.Count)
            {
                lock (controlList)
                {
                    for (int i = 0; i < controlList.Count;)
                    {
                        if (controlList[i] == null || 3 <= controlList[i].packet.HaveSendCount)
                        {
                            controlList.RemoveAt(i);
                        }
                        else
                        {
                            i++;
                        }
                    }

                }
            }
            controlList.Add(this);
        }

        //当前数据的关键数据
        string sendFlag = string.Empty;
        protected string SendFlag
        {
            get
            {
                return sendFlag;
            }
            set
            {
                sendFlag = value;
                usefulBytes = null;
            }
        }

        private byte[] usefulBytes;
        /// <summary>
        /// 获取回来的有用信息,如果获取回来的数据为null，就会抛出异常信息
        /// </summary>
        public byte[] UsefulBytes
        {
            get
            {
                if (null == usefulBytes)
                {
                    // throw new Exception("不好意思，网络不稳定或者远程设备不在线，请稍候再试！");
                }

                return this.usefulBytes;
            }
            set
            {
                usefulBytes = value;
            }
        }

        //发送数据了之后当前线程等待或者运行的信号
        System.Threading.ManualResetEvent allDone = new System.Threading.ManualResetEvent(false);

        /// <summary>
        /// 发送了数据后，线程就是等待状态，直到接收到反馈或者超时后退出
        /// </summary>
        void wait()
        {
            allDone.Reset();
            allDone.WaitOne();
        }

        /// <summary>
        /// 让当前线程继续执行
        /// </summary>
        void run()
        {
            allDone.Set();
            packet.HaveSendCount = 4;
        }

        //数据发送处理
        void managerSendCount(object o)
        {
            add();
            //Bus socket无法控制，重启机制
            if (controlLostCount > 10)
            {
                UdpSocket._BusSocket.Stop();
                new System.Threading.Thread(() =>
                {
                    System.Threading.Thread.Sleep(1000);
                    UdpSocket._BusSocket.Start(UdpSocket._BusSocket.Port);
                    controlLostCount = 0;
                })
                { IsBackground = true }.Start();
            }

            try
            {
                MainPage.Log("发送数据:" + SendFlag);
                UdpSocket._BusSocket.AsyncBeginSend(packet);
                packet.HaveSendCount--;

                //这里是重发两次
                while (packet.HaveSendCount < 3)
                {
                    if (packet.FlagDateTime.AddMilliseconds(1000).Ticks <= DateTime.Now.Ticks)
                    {
                        MainPage.Log("重发数据:" + SendFlag);
                        UdpSocket._BusSocket.AsyncBeginSend(packet);
                        controlLostCount++;
                    }
                    System.Threading.Thread.Sleep(1000);
                }
            }
            catch (Exception ex)
            {
                MainPage.Log("managerSendCount:" + ex.ToString());
            }
            finally
            {
                allDone.Set();
            }
        }

        /// <summary>
        /// 当前数据包
        /// </summary>
        Packet packet;
        /// <summary>
        /// 记录发送数据包
        /// </summary>
        /// <param name="target"></param>
        private void signPacket(Target target)
        {
            this.SendFlag = string.Format("{0},{1},{2},", target.SubnetID, target.DeviceID, (int)target.Command + 1);

            switch (target.Command)
            {
                case Command.SetSingleLight:
                case Command.ReadLogicLoopColor:
                case Command.ReadACMode:
                case Command.SetACMode:
                case Command.ReadFloorHeat:
                case Command.SetFloorHeat:
                case Command.FreshAirRead:
                case Command.FreshAirControl:
                case Command.FreshAirRead_JinMao:
                case Command.FreshAirControl_JinMao:
                    this.sendFlag += string.Format("{0}", target.AddData[0]);
                    break;
                case Command.SetLogicLoopColor:
                    this.sendFlag += string.Format("{0},{1},{2}", target.AddData[0], target.AddData[1], target.AddData[2]);
                    break;
                case Command.ReadLightAllLoopBrightness:
                    this.SendFlag += "";
                    break;
                case Command.ReadGateway:
                    this.SendFlag = string.Format("{0},{1}", target.AddData[0], target.AddData[1]);
                    break;
                case Command.ReadDeviceLoopInfo:
                    if (target.AddData[0] == 1)//特殊处理灯光类，DMX模块每一个回路不固定小类，根据具体设置来回复
                        this.sendFlag += string.Format("{0},{1}", target.AddData[0], target.AddData[2]);
                    else
                        this.sendFlag += string.Format("{0},{1},{2}", target.AddData[0], target.AddData[1], target.AddData[2]);
                    break;
                case Command.InstructionPanelKey:
                case Command.ReadInstructionPanelKey:
                    this.sendFlag += string.Format("{0},{1}", target.AddData[0], target.AddData[1]);
                    break;
                default:
                    break;
            }

        }

        //private void signAlinkPacket()
        //{
        //}

        /// <summary>
        /// 发送数据
        /// </summary>
        /// <param name="target">发送对象</param>
        /// <param name="sendCount">重发次数</param>
        private void Send(Target target, int sendCount, bool isWait)
        {
            try
            {
                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);

                if (isWait)
                {
                    this.wait();
                }
            }
            catch(Exception ex)
            {
                MainPage.Log($"Send bus data error {ex.Message}");
            }
        }

        /// <summary>
        /// 读取网关IP
        /// </summary>
        public void SearchLocalGateway(bool broadcast = false)
        {
            try
            {
                var sendJob = new JObject { { "id", Control.Ins.msg_id.ToString() }, { "time_stamp", Utlis.GetTimestamp ()} };
                var bodyString = JsonConvert.SerializeObject(sendJob);
                
                var sendBytes = Control.Ins.ConvertSendBodyData(CommunicationTopic.SearchLoaclGateway, bodyString, false);
                if (broadcast)
                {
                    //广播
                    packet = new Packet(sendBytes, new System.Net.IPEndPoint(System.Net.IPAddress.Parse("255.255.255.255"), 8585));
                }
                else
                {
                    //组播发送
                    packet = new Packet(sendBytes, new System.Net.IPEndPoint(System.Net.IPAddress.Parse("239.0.168.188"), 8585));
                }
                packet.HaveSendCount = 4;
                System.Threading.Thread thread = new System.Threading.Thread(new System.Threading.ParameterizedThreadStart(managerSendCount));
                thread.IsBackground = true;
                thread.Start(packet);
                //wait();不需要等待

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

        /// <summary>
        /// 读取网关IP
        /// </summary>
        public void SendLinkCommand(string topic,string bodyString)
        {
            try
            {
                var sendBytes = Control.Ins.ConvertSendBodyData(topic, bodyString, false);
                //组播发送
                packet = new Packet(sendBytes, new System.Net.IPEndPoint(System.Net.IPAddress.Parse("239.0.168.188"), 8585));
                packet.HaveSendCount = 4;
                System.Threading.Thread thread = new System.Threading.Thread(new System.Threading.ParameterizedThreadStart(managerSendCount));
                thread.IsBackground = true;
                thread.Start(packet);
            }
            catch (Exception ex)
            {
                MainPage.Log($"Send bus data error {ex.Message}");
            }
        }

        /// <summary>
        /// 发送udp A协议数据
        /// </summary>
        public void SendLocalHdlLinkData(byte[] sendBytes,string id, int resend = 3)
        {
            packet = new Packet(sendBytes, new System.Net.IPEndPoint(System.Net.IPAddress.Parse(Control.Ins.reportIp), 8585));
            packet.HaveSendCount = 3 - resend;//重发次数
            sendFlag = id;
            System.Threading.Thread thread = new System.Threading.Thread(new System.Threading.ParameterizedThreadStart(managerSendCount));
            thread.IsBackground = true;
            thread.Start(packet);
            //if (isWait)
            //{
            //    wait(); 
            //}
            MainPage.Log($"发送Hdl-Link数据，IP:{Control.Ins.reportIp}:8585");
        }
    }

}