using SunlightAggregationManager.ViewModel;
using System;
using System.Collections.Generic;
using System.Data;
using System.Text;
using System.Text.Json;
using TouchSocket.Core;
using TouchSocket.Sockets;
using static SunlightAggregationManager.UserClass.AsyncTcpServer;

namespace SunlightAggregationManager.UserClass
{
    public class AsyncTcpClient
    {
        public static TouchSocket.Sockets.TcpClient tcpClient = new TouchSocket.Sockets.TcpClient();
        public static async void Configuration(string ip, string Name, string user, string Password)
        {
            await TcpClient(tcpClient, "tcp://"+ip);
        }

        public static async void TcpTransmit(object Dat)
        {           
            //发送字符串数据
            try
            {
                await tcpClient.SendAsync(JsonSerializer.Serialize(Dat));
            }
            catch (Exception ex)
            {
                Console.WriteLine("Tcp:" + ex.ToString());
            }
        }

        public static async Task TcpClient(TouchSocket.Sockets.TcpClient tcpClient, string ip)
        {

            // 自定义心跳首次延迟60秒开始，之后每30秒执行一次
            Timer timer = new Timer(TimerCallback, null, TimeSpan.FromSeconds(60), TimeSpan.FromSeconds(30));

            tcpClient.Connecting = (client, e) => { return EasyTask.CompletedTask; };//即将连接到服务器，此时已经创建socket，但是还未建立tcp
            tcpClient.Connected = (client, e) =>
            {            
                //设定显示状态
                System.Data.DataRow targetRow =ViewModel.MainWindowViewModel._service.Select("Service = 'Sunlight_Server_Link'").FirstOrDefault()!;
                if (targetRow != null)
                {
                    targetRow.BeginEdit();
                    targetRow["Status"] = "Connected";
                    targetRow.EndEdit();
                }
                //发送本机信息到转发服务器
                Dictionary<string, object> myDict = new Dictionary<string, object>();
                myDict.Add("SERVEREnterprise", MainWindowViewModel.Enterprise);
                myDict.Add("SERVERMachineName", MainWindowViewModel.MachineName);
                myDict.Add("SERVERNAME", MainWindowViewModel.SERVERNAME);
                myDict.Add("SERVERUSER", MainWindowViewModel.SERVERUSER);
                myDict.Add("SERRVERPASWORD", MainWindowViewModel.SERRVERPASWORD);
                myDict.Add("MachineVer", MainWindowViewModel.MachineVer);
                TcpTransmit(myDict);

                Console.WriteLine("Sunlight_Server_Connected");
                return EasyTask.CompletedTask;
            };//成功连接到服务器
            tcpClient.Closing = (client, e) => {
                System.Data.DataRow targetRow = ViewModel.MainWindowViewModel._service.Select("Service = 'Sunlight_Server_Link'").FirstOrDefault()!;
                if (targetRow != null)
                {
                    targetRow.BeginEdit();
                    targetRow["Status"] = "Disconnect";
                    targetRow.EndEdit();
                }
                Console.WriteLine("Sunlight_Server_Disconnect");
                return EasyTask.CompletedTask; };//即将从服务器断开连接。此处仅主动断开才有效。
            tcpClient.Closed = (client, e) => {
                System.Data.DataRow targetRow = ViewModel.MainWindowViewModel._service.Select("Service = 'Sunlight_Server_Link'").FirstOrDefault()!;
                if (targetRow != null)
                {
                    targetRow.BeginEdit();
                    targetRow["Status"] = "Disconnect";
                    targetRow.EndEdit();
                }
                Console.WriteLine("Sunlight_Server_Disconnect");
                return EasyTask.CompletedTask; };//从服务器断开连接，当连接不成功时不会触发。
            #region Tcp客户端使用Received异步委托接收数据
            tcpClient.Received = (client, e) =>
            {
                //从服务器收到信息。但是一般byteBlock和requestInfo会根据适配器呈现不同的值。
                var mes = e.Memory.Span.ToString(Encoding.UTF8);
                //信息处理暂停心跳定时
                timer.Change(Timeout.Infinite, Timeout.Infinite);

                try
                {
                    Person? deserializedPerson = JsonSerializer.Deserialize<Person>(mes);

                    var _user = MainWindowViewModel.Selet_Memory(MainWindowViewModel._userData, "State", "User='" +
                        deserializedPerson?.User + "' and Password ='" + deserializedPerson?.Password + "'");
                    if (_user != null)
                    {
                        string _dat = _user?.ToString() ?? "0";
                        if (_dat != "99")
                        {
                            //行为
                            Dictionary<string, object> myDict = new Dictionary<string, object>();
                            //myDict.Add("LinkID", client.Id);
                            myDict.Add("LastLoginIP", deserializedPerson?.IP ?? client.IP);
                            myDict.Add("LastActionTime", DateTime.Now);
                            myDict.Add("Note", deserializedPerson?.Dat ?? "unknown");
                            MainWindowViewModel.Updata_Memory(MainWindowViewModel._userData, "User='" + deserializedPerson?.User + "'", myDict);

                            Console.WriteLine("[Log on]User[" + deserializedPerson?.User + "]Note[" + (deserializedPerson?.Dat ?? "unknown") + "]");
                            CommandC(deserializedPerson?.Dat ?? "NOT", deserializedPerson!);
                        }
                        else
                        {//停用账号关闭连接
                            client.SendAsync("Account Deactivated");
                        }
                    }
                    else
                    { //无效账号关闭连接
                        client.SendAsync("Invalid Account");
                    }
                }
                catch (Exception ex)
                {//错误
                    Console.WriteLine("Tcp:" + ex.ToString());
                    client.SendAsync("Target instruction parsing error manager will close connection");
                }
                finally
                {//继续心跳定时
                    timer.Change(TimeSpan.FromSeconds(30), TimeSpan.FromSeconds(30));
                }

                return EasyTask.CompletedTask;
            };
            #endregion

            try
            {
                await tcpClient.SetupAsync(new TouchSocketConfig()
                    .SetSingleStreamDataHandlingAdapter(() => new PeriodPackageAdapter())//以超时周期和包
                    .SetRemoteIPHost(ip)                    
                    .ConfigurePlugins(a =>
                    {
                        a.UseReconnection<TouchSocket.Sockets.TcpClient>(options =>
                        {
                            options.PollingInterval = TimeSpan.FromSeconds(5);
                        });
                        
                    })
                    .ConfigureContainer(a =>
                    {
                        
                    }));

                await tcpClient.ConnectAsync();//调用连接，当连接不成功时，会抛出异常。

            }
            catch (Exception ex)
            {
                LogGing.ERRDATA(ex);
                Console.WriteLine("Tcp:" + ex.ToString());
            }
        }
        private static void TimerCallback(object? state)
        {
            try
            {
                if (tcpClient.Online)
                {
                    tcpClient.SendAsync("SUNLIGHT");
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.ToString());
                LogGing.ERRDATA(ex);
            }
        }

        public static async void CommandC(string dat, Person person)//
        {
            try
            {
                string Command = "", ret = "";

                Dictionary<string, object> data_ = new Dictionary<string, object>();
                var deserialized = JsonSerializer.Deserialize<Dictionary<string, object>>(dat)!;
                if (deserialized.TryGetValue("Command", out var val) && val != null) Command = val.ToString()!;
                if (Command == "Log")//回复请求的信息
                {
                    DataRow? _user = MainWindowViewModel.Selet_Row(MainWindowViewModel._userData, "User='" +
                                 person?.User + "' and Password ='" + person?.Password + "'");

                    data_.Add("Enterprise", _user?.Field<object>("Enterprise") ?? "");
                    data_.Add("Department", _user?.Field<object>("Department") ?? "");
                    data_.Add("Groups", _user?.Field<object>("Groups") ?? "");
                    data_.Add("UserId", _user?.Field<object>("UserID") ?? "");
                    data_.Add("UserName", _user?.Field<object>("Name") ?? "");
                    ret = JsonSerializer.Serialize(data_);
                }
                if (Command == "Info")//回复info请求的信息
                {
                    var t = ToList(MainWindowViewModel._machines).ToJsonString();
                    //格式化返回信息
                    data_.Add("Info", t);
                    ret = JsonSerializer.Serialize(data_);
                }
                if (Command == "Query")//回复Query请求的信息
                {
                    string s_ = deserialized.GetValue("StartTime").ToString()!;
                    string e_ = deserialized.GetValue("EndTime").ToString()!;
                    string f_ = deserialized.GetValue("Field").ToString()!;

                    DataTable resultTable = await MainWindowViewModel.dataBase.ExecuteQueryAsync("SELECT " +
                        f_ + " FROM [dbo].[Dyelots] " + "WHERE CreationTime>'" + s_ + "'and CreationTime<'" + e_ + "'");
                    //格式化返回信息
                    data_.Add("Query", Newtonsoft.Json.JsonConvert.SerializeObject(resultTable));
                    ret = JsonSerializer.Serialize(data_);
                }
                if (Command == "QueryDyelot")//回复QueryDyelot请求的信息
                {
                    string d_ = deserialized.GetValue("DyelotName").ToString()!;
                    string f_ = deserialized.GetValue("Field").ToString()!;

                    DataTable resultTable = await MainWindowViewModel.dataBase.ExecuteQueryAsync("SELECT " +
                        f_ + " FROM [dbo].[Dyelots] " + "WHERE Dyelot LIKE '" + d_ + "%'");
                    //格式化返回信息
                    data_.Add("Query", Newtonsoft.Json.JsonConvert.SerializeObject(resultTable));
                    ret = JsonSerializer.Serialize(data_);
                }
                if (Command == "QueryDetail")//回复QueryDetail请求的信息
                {
                    string d_ = deserialized.GetValue("Dyelot").ToString()!;
                    string r_ = deserialized.GetValue("ReDye").ToString()!;
                    string f_ = deserialized.GetValue("Field").ToString()!;

                    DataTable resultTable = await MainWindowViewModel.dataBase.ExecuteQueryAsync("SELECT " +
                        f_ + " FROM [dbo].[DyelotsBulkedRecipe] " + "WHERE Dyelot='" + d_ + "'and ReDye='" + r_ + "'");
                    //格式化返回信息
                    data_.Add("QueryDetail", Newtonsoft.Json.JsonConvert.SerializeObject(resultTable));
                    ret = JsonSerializer.Serialize(data_);
                }
                if (Command == "Notification")//回复Notification请求的信息
                {
                    string s_ = deserialized.GetValue("StartTime").ToString()!;
                    string e_ = deserialized.GetValue("EndTime").ToString()!;

                    var groups = MainWindowViewModel.Selet_Memory(MainWindowViewModel._userData,
                        "Groups", "User='" + person?.User + "'");

                   DataTable resultTable = MainWindowViewModel.SQLiteHelpers.ExecuteDataSet("" +
                        "select * from Notification WHERE Groups='" + groups + "' and Time>'" +
                        s_ + "' and Time<'" + e_ + "'", null)?.Tables[0] ?? new DataTable();
                   if(resultTable.Rows.Count==0) resultTable.Rows.Add();

                    //格式化返回信息
                    data_.Add("Notification", Newtonsoft.Json.JsonConvert.SerializeObject(resultTable));
                    ret = JsonSerializer.Serialize(data_);
                }
                if (Command == "InfoMachine")//回复InfoMachine请求的信息
                {
                    string t_ = deserialized.GetValue("Type").ToString()!;
                    string? m_ =null, f_ = "*";

                    if (deserialized.TryGetValue("MachinName", out var MachinName) && MachinName != null) m_ = MachinName.ToString();
                    if (deserialized.TryGetValue("Field", out var Field) && Field != null) f_ = Field.ToString();

                    if (t_ == "10")
                    {
                        DataTable resultTable = await MainWindowViewModel.dataBase.ExecuteQueryAsync("SELECT " +
                        f_ + " FROM [dbo].[WaitDispenseDyestuff] WHERE DispenseMachine='" + m_ + "'");
                        data_.Add("Type", "10");
                        data_.Add("InfoMachine", Newtonsoft.Json.JsonConvert.SerializeObject(resultTable));
                    }
                    else if (t_ == "12")
                    {
                        DataTable resultTable = await MainWindowViewModel.dataBase.ExecuteQueryAsync("SELECT " +
                        f_ + " FROM [dbo].[ShelfInfo] ");
                        data_.Add("Type", "12");
                        data_.Add("InfoMachine", Newtonsoft.Json.JsonConvert.SerializeObject(resultTable));
                    }
                    else if (t_ == "20")
                    {
                        DataTable resultTable = await MainWindowViewModel.dataBase.ExecuteQueryAsync("SELECT " +
                        f_ + " FROM [dbo].[WaitChemical] WHERE DispenseMachine='" + m_ + "'");
                        data_.Add("Type", "20");
                        data_.Add("InfoMachine", Newtonsoft.Json.JsonConvert.SerializeObject(resultTable));
                    }
                    else
                    {
                        data_.Add("InfoMachine", "");
                    }

                    //格式化返回信息
                    ret = JsonSerializer.Serialize(data_);
                }
                if (Command == "InfoMachineHistory")//回复InfoMachineHistory请求的信息
                {
                    string t_ = deserialized.GetValue("Type").ToString()!;
                    string? m_ = null, f_ = "*";

                    if (deserialized.TryGetValue("MachinName", out var MachinName) && MachinName != null) m_ = MachinName.ToString();
                    if (deserialized.TryGetValue("Field", out var Field) && Field != null) f_ = Field.ToString();

                    if (t_ == "80")
                    {
                        DataTable resultTable = await MainWindowViewModel.dataBase.ExecuteQueryAsync("SELECT " +
                        f_ + " FROM [dbo].[DyeSolutionHistory] WHERE DispenseStartTime >'" + DateTime.Now.AddDays(-3)+
                        "' and DispenseMachine='" + m_ + "'");
                        data_.Add("Type", "80");
                        data_.Add("InfoMachineHistory", Newtonsoft.Json.JsonConvert.SerializeObject(resultTable));
                    }
                    else if (t_ == "82")
                    {
                        DataTable resultTable = await MainWindowViewModel.dataBase.ExecuteQueryAsync("SELECT " +
                        f_ + " FROM [dbo].[inOutRecords] WHERE Createtime >'" + DateTime.Now.AddDays(-3)+"'");
                        data_.Add("Type", "82");
                        data_.Add("InfoMachineHistory", Newtonsoft.Json.JsonConvert.SerializeObject(resultTable));
                    }
                    else if (t_ == "90")
                    {
                        DataTable resultTable = await MainWindowViewModel.dataBase.ExecuteQueryAsync("SELECT " +
                        f_ + " FROM [dbo].[DyeSolutionHistory] WHERE DispenseStartTime >'" + DateTime.Now.AddDays(-3) +
                        "' and DispenseMachine='" + m_ + "'");
                        data_.Add("Type", "90");
                        data_.Add("InfoMachineHistory", Newtonsoft.Json.JsonConvert.SerializeObject(resultTable));
                    }
                    else
                    {
                        data_.Add("InfoMachineHistory", "");
                    }

                    //格式化返回信息
                    ret = JsonSerializer.Serialize(data_);
                }
                if (Command == "InfoMachinePipes")//回复Notification请求的信息
                {
                    string? m_ = null, f_ = "*";

                    if (deserialized.TryGetValue("MachinName", out var MachinName) && MachinName != null) m_ = MachinName.ToString();
                    if (deserialized.TryGetValue("Field", out var Field) && Field != null) f_ = Field.ToString();

                    DataTable resultTable = await MainWindowViewModel.dataBase.ExecuteQueryAsync("SELECT " +
                    f_ + " FROM [dbo].[Pipes] WHERE Dispenser='" + m_ + "'");
                    data_.Add("InfoMachinePipes", Newtonsoft.Json.JsonConvert.SerializeObject(resultTable));

                    //格式化返回信息
                    ret = JsonSerializer.Serialize(data_);
                }
                if (Command == "SETUSER")//回复Notification请求的信息
                {
                    MainWindowViewModel.Updata_Memory(MainWindowViewModel._userData, 
                        "User='" + deserialized.GetValue("USER").ToString()! + "'" ,
                        deserialized.GetValue("VALUE").ToString(), deserialized.GetValue("KEY").ToString()!);
                    data_.Add("USER", deserialized.GetValue("USER").ToString()!); 
                    data_.Add("VALUE", deserialized.GetValue("VALUE").ToString()!);
                    data_.Add("KEY", deserialized.GetValue("KEY").ToString()!);
                    data_.Add("SETUSER", "OK");
                    //格式化返回信息
                    ret = JsonSerializer.Serialize(data_);
                }

                person!.Dat = ret.ToString();
                var jsdat = JsonSerializer.Serialize(person);
                await tcpClient.SendAsync(jsdat);
            }
            catch (Exception ex)
            {
                LogGing.ERRDATA(ex);
                Console.WriteLine(ex.ToString());
            }
        }
    }
}