using System;
using System.Collections.Generic;
using System.Text;
using HDL_ON.Entity;

namespace HDL_ON.DriverLayer
{
    /// <summary>
    /// 通讯方式
    /// </summary>
    public enum CommunicationMode
    {
        none,
        /// <summary>
        /// 本地udp
        /// </summary>
        local_BusUdp,
        /// <summary>
        /// 本地tcp客户端
        /// </summary>
        tcp_local_client,
    }

    public class Control
    {
        static Control _control;
        public static Control Ins
        {
            get
            {
                if (_control == null)
                {
                    _control = new Control();
                }
                return _control;
            }
        }
        int _msg_id = 1;
        /// <summary>
        /// 通讯ID
        /// </summary>
        public int msg_id
        {
            get
            {
                return _msg_id++;
            }
        }
        /// <summary>
        /// 获取13位时间戳
        /// </summary>
        /// <returns></returns>
        public string Get_TimeStamp()
        {
            long t = DateTime.Now.Ticks / 10000;
            return t.ToString();
        }

        bool _gatewayOnline = false;
        /// <summary>
        /// 网关是否在线
        /// </summary>
        public bool GatewayOnline {
            get
            {
                return _gatewayOnline;
            }
            set
            {
                _gatewayOnline = value;
                //修改主页连接状态
                UI.HomePage.LoadEvent_CheckLinkStatus();
                FunctionList.List.ReadAllFunctionStatus();
            }
        }
        /// <summary>
        /// 网关通讯ID
        /// </summary>
        public string GatewayId;

        bool _isRemote = false;
        /// <summary>
        /// 是否为远程连接
        /// </summary>
        public bool IsRemote {
            get
            {
                return _isRemote;
            }
            set
            {
                _isRemote = value;
                if(value)
                {
                    DAL.Mqtt.MqttClient.InitState();
                }else
                {
                    DAL.Mqtt.MqttClient.DisConnectRemote();
                }
            }
        }
        /// <summary>
        /// 通讯地址IP
        /// </summary>
        public string reportIp = "255.255.255.255";
        /// <summary>
        /// tcp服务端
        /// </summary>
        public Control_TcpServer myTcpServer = null;
        /// <summary>
        /// tcp客服端
        /// </summary>
        public Control_TcpClient myTcpClient = null;
        /// <summary>
        /// 本地udp
        /// </summary>
        public Control_Udp myUdp = null;

        /// <summary>
        /// 通讯方式
        /// </summary>
        public CommunicationMode communicationMode;

        /// <summary>
        /// 打开tcp服务端
        /// </summary>
        public void OpenTcpServer()
        {
            myTcpServer = new Control_TcpServer();
            myTcpServer.OpenServer();
        }

        /// <summary>
        /// 打开Udp
        /// </summary>
        public void OpenUdp(int port)
        {
            if (myUdp == null)
            {
                myUdp = new Control_Udp();
            }

            UdpSocket._BusSocket.Start(port);
        }
        /// <summary>
        /// 关闭udp
        /// </summary>
        public void CloseUdp()
        {
            if (myUdp != null)
            {
                myUdp = null;
            }
            UdpSocket._BusSocket.Stop();
        }

        /// <summary>
        /// 打开tcp客服端
        /// </summary>
        public void OpenTcpClent()
        {
            if (myTcpClient == null)
            {
                myTcpClient = new Control_TcpClient(reportIp);
                myTcpClient.Connect();
            }
        }

        ///// <summary>
        ///// 改变通讯方式
        ///// </summary>
        //public void ChangeCommunicationMode(CommunicationMode communicationMode)
        //{
        //    this.communicationMode = communicationMode;
        //}

        /// <summary>
        /// 搜索本地网关列表
        /// </summary>
        public void SearchLoaclGateway()
        {
            OpenUdp(DB_ResidenceData.residenceData.GatewayType == 0 ? 6000 : 8585);
            new System.Threading.Thread(() =>
            {
                for (int i = 0; i < 5; i++)
                {
                    if (GatewayOnline)
                        break;
                    if (DB_ResidenceData.residenceData.GatewayType == 0)
                    {
                        myUdp.ControlBytesSend(Command.ReadGateway, 255, 255, new byte[] { (byte)new Random().Next(255), (byte)new Random().Next(255) });
                    }
                    else if (DB_ResidenceData.residenceData.GatewayType == 1)
                    {
                        myUdp.SearchLocalGateway();
                    }
                    System.Threading.Thread.Sleep(500);
                }
            })
            { IsBackground = true }.Start();
        }

        /// <summary>
        /// 场景控制入口
        /// </summary>
        public void ControlScene(Scene scene)
        {
            if(myUdp!=null)
            {
                myUdp.ControlBusScenes(scene);
            }
            if(myTcpClient!= null)
            {
                ControlAProtocolScene(scene);
            }
        }

        /// <summary>
        /// 发送命令
        /// 自动判断是否为A协议设备，
        /// 不是A协议，自动转化bus命令数据
        /// </summary>
        /// <param name="commandString"></param>
        /// <param name="function"></param>
        /// <returns></returns>
        public void SendWriteCommand(Function function, Dictionary<string, string> commandDictionary)
        {
            function.usageCount++;
            function.refreshTime = DateTime.Now;
            DAL.Server.HttpServerRequest httpServer = new DAL.Server.HttpServerRequest();
            //远程通讯
            if (Ins.IsRemote || true) 
            {
                //ALink控制、Bus控制使用同一个接口控制，由云端负责解析
                var apiControlData = function.GetApiControlData(commandDictionary);
                var actionObjs = new List<ApiAlinkControlActionObj>();
                actionObjs.Add(apiControlData);
                var pack = httpServer.ControlDevice(actionObjs);
                MainPage.Log($"{pack.Code}:{pack.Data}");
            }
            //本地通讯
            else
            {
                //Bus控制
                if (DB_ResidenceData.residenceData.GatewayType == 0)
                {
                    try
                    {
                        if (myUdp != null)
                        {
                            myUdp.WriteBusData(function, commandDictionary);
                        }
                    }
                    catch (Exception ex)
                    {
                        MainPage.Log($"发送数据异常: {ex.Message}");
                    }
                }
                //ALink控制
                else
                {
                    if (myUdp != null)
                    {
                        var functionControlDataObj = function.GetGatewayAlinkControlData(commandDictionary);
                        var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(functionControlDataObj);
                        var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ControlFunctionTopic, functionControlDataJson);
                        myUdp.SendLocalHdlLinkData(sendBytes);
                    }
                }
            }
        }

        /// <summary>
        /// 发送读取命令
        /// 自动判断是否为A协议设备
        /// </summary>
        public void SendReadCommand(Function function)
        {
            function.refreshTime = DateTime.Now;
            if (Ins.IsRemote)
            {

            }
            else
            {
                if (function.bus_Data != null)
                {
                    try
                    {
                        Ins.myUdp.ReadBusData(function);
                    }
                    catch (Exception ex)
                    {
                        MainPage.Log($"发送数据异常: {ex.Message}");
                    }
                }
                else
                {
                    var readKey = new Dictionary<string, string>();
                    readKey.Add("sid", function.sid);

                    var readDataObj = new GatewayAlinkReadObj()
                    {
                        id = Ins.msg_id.ToString(),
                        objects = new List<Dictionary<string, string>>()
                        {
                            readKey
                        },
                         //time_stamp = 
                    };
                    var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(readDataObj);
                    var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ReadStatus, functionControlDataJson);
                    Ins.myUdp.SendLocalHdlLinkData(sendBytes);
                }
            }
        }
        /// <summary>
        /// 发送A协议读取命令
        /// </summary>
        public void SendReadCommand(List<Dictionary<string, string>> keyValuePairs)
        {
            var readDataObj = new GatewayAlinkReadObj()
            {
                id = Ins.msg_id.ToString(),
                objects = keyValuePairs,
                //time_stamp = 
            };
            var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(readDataObj);
            var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ReadStatus, functionControlDataJson);
            Ins.myUdp.SendLocalHdlLinkData(sendBytes);
        }

        /// <summary>
        /// 控制a协议场景
        /// </summary>
        /// <param name="scene"></param>
        static void ControlAProtocolScene(Scene scene)
        {
            var sendSidObj = new AProtocolSendingObject();
            sendSidObj.time_stamp = "";
            sendSidObj.type = "device_sid";
            sendSidObj.command = "get_list_response";
        }
        /// <summary>
        /// 转换通讯数据
        /// </summary>
        public byte[] ConvertSendBodyData(string topic, string bodyDataString)
        {
            string topicString = "Topic:" + topic + "\r\n";
            byte[] bodyBytes = Encoding.ASCII.GetBytes(bodyDataString);
            string lengthString = "Length:" + bodyBytes.Length.ToString() + "\r\n" + "\r\n";

            string sendDataString = topicString + lengthString + bodyDataString;
            byte[] sendDataBytes = Encoding.ASCII.GetBytes(sendDataString);
            MainPage.Log($"转换HDL-Link数据\r\n{sendDataString}\r\n");

            return sendDataBytes;
        }
        /// <summary>
        /// 转换接收到的数据
        /// </summary>
        /// <returns></returns>
        public void ConvertReceiveData(byte[] receiveBytes)
        {
            var reString = Encoding.UTF8.GetString(receiveBytes);
            AnalysisReceiveData(reString);
        }
        /// <summary>
        /// 转换接收到的数据
        /// </summary>
        /// <returns></returns>
        public LocalCommunicationData AnalysisReceiveData(string receiveString)
        {
            LocalCommunicationData receiveObj = new LocalCommunicationData();

            var res = receiveString.Split("\r\n\r\n");

            if (res.Length == 2)
            {
                var topics = res[0].Split("\r\n");
                MainPage.Log(res[1]);
                foreach (var ts in topics)
                {
                    var key = ts.Split(":");
                    switch (key[0])
                    {
                        case "Topic":
                            receiveObj.Topic = key[1];
                            break;
                        case "Length":
                            receiveObj.Length = Convert.ToInt32(key[1]);
                            break;
                    }
                }
                //验证有效数据长度
                //if (res[1].Length != receiveObj.Length)
                //{
                //    MainPage.Log($"收到数据包长度不够");
                //    return receiveObj;
                //}
                receiveObj.BodyDataString = res[1];

                var bodyJObj = Newtonsoft.Json.JsonConvert.DeserializeObject<ResponsePack>(res[1]);
                if (bodyJObj == null)
                {
                    return receiveObj;
                }
                switch (receiveObj.Topic)
                {
                    case CommunicationTopic.SearchLoaclGatewayReply:
                        var device = Newtonsoft.Json.JsonConvert.DeserializeObject<DeviceModule>(bodyJObj.objects.ToString());
                        if (device.device_mac == DB_ResidenceData.residenceData.residenceGatewayMAC)
                        {
                            Ins.GatewayOnline = true;
                            Ins.GatewayId = device.gatewayId;
                            reportIp = "239.0.168.188";// device.ip_address;
                            Ins.IsRemote = false;
                        }
                        break;
                }
            }
            return receiveObj;
        }
    }
}