using DyeingComputer.UserClass;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Net.Sockets;
using System.Reflection.Emit;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Diagnostics;
using TouchSocket.Core;
using TouchSocket.Sockets;
using DyeingComputer.ViewModel;
using System.Runtime.InteropServices;
using ScottPlot.Colormaps;

namespace DyeingComputer.UserClass
{/// <summary>
 /// 异步TCP服务器
 /// </summary>
    public class AsyncTcpServer
    {
        public static async Task Main()
        {            
            TcpService service = new TcpService();
            service.Connecting = (client, e) => { return EasyTask.CompletedTask; };//有客户端正在连接
            service.Connected = (client, e) => { return EasyTask.CompletedTask; };//有客户端成功连接
            service.Closing = (client, e) => { return EasyTask.CompletedTask; };//有客户端正在断开连接，只有当主动断开时才有效。
            service.Closed = (client, e) => { return EasyTask.CompletedTask; };//有客户端断开连接
            service.Received = (client, e) =>
            {
                string SYSAPI = e.ByteBlock.Span.ToString(Encoding.ASCII).Substring(0,5);
                LogGing.LogSQLDATA("800", "TcpServer", "API:"+ SYSAPI);
                if (SYSAPI == "SC800") client.SendAsync(MainWindowViewModel.S01);
                if (SYSAPI == "SC801") client.SendAsync(MainWindowViewModel.S16.ToString());
                if (SYSAPI == "SC802") client.SendAsync(MainWindowViewModel.S03);
                if (SYSAPI == "SC803") client.SendAsync(MainWindowViewModel.S05);
                if (SYSAPI == "SC804") client.SendAsync(MainWindowViewModel.S06);
                if (SYSAPI == "SC810") 
                {

                }
                if (SYSAPI == "SC820")
                { 

                }
                if (SYSAPI == "SC830")//当前信息
                {
                    Dictionary<string, object> Chart_new = new Dictionary<string, object>();//缓存函数
                    Chart_new.Add("DYELOT", MainWindowViewModel.WorkNumder);
                    Chart_new.Add("Time", MainWindowViewModel.SYSTime);
                    Chart_new.Add("MST",  MainWindowViewModel.TEMP_co);
                    Chart_new.Add("MTT", MainWindowViewModel.Selet_dtm("1010"));
                    Chart_new.Add("MTL", MainWindowViewModel.Selet_dtm("1015"));
                    Chart_new.Add("MTH", MainWindowViewModel.Selet_dtm("1009"));
                    Chart_new.Add("MUT", MainWindowViewModel.Selet_dtm("1011"));
                    Chart_new.Add("STTA", MainWindowViewModel.Selet_dtm("1012"));
                    Chart_new.Add("STLA", MainWindowViewModel.Selet_dtm("1017"));
                    Chart_new.Add("STTB", MainWindowViewModel.Selet_dtm("1013"));
                    Chart_new.Add("STLB", MainWindowViewModel.Selet_dtm("1018"));
                    Chart_new.Add("STTC", MainWindowViewModel.Selet_dtm("1014"));
                    Chart_new.Add("STLC", MainWindowViewModel.Selet_dtm("1019"));
                    client.SendAsync(Chart_new.ToJsonString());
                }
                if (SYSAPI == "SC851") client.SendAsync(MainWindowViewModel.dt_d.ToJsonString());//数字开关信息
                if (SYSAPI == "SC852") client.SendAsync(MainWindowViewModel.dt_a.ToJsonString());//寄存器信息
                if (SYSAPI == "SC853") client.SendAsync(MainWindowViewModel.dt_m.ToJsonString());//缓存信息

                return EasyTask.CompletedTask;
            };

            await service.SetupAsync(new TouchSocketConfig()//载入配置
                .SetListenIPHosts(new IPHost[] { new IPHost("tcp://127.0.0.1:7789"), new IPHost(7790) })//同时监听两个地址
                .ConfigureContainer(a =>//容器的配置顺序应该在最前面
                {
                    //a.AddConsoleLogger();//添加一个控制台日志注入（注意：在maui中控制台日志不可用）
                })
                .ConfigurePlugins(a =>
                {
                    //a.Add<DifferentProtocolPlugin>();
                })
                );
            await service.StartAsync();//启动

            LogGing.LogGingDATA("800SREVER:START");
        }
    }

    class MyTcpService : TcpService<MyTcpSessionClient>
    {
        protected override MyTcpSessionClient NewClient()
        {
            return new MyTcpSessionClient();
        }
    }

    class MyTcpSessionClient : TcpSessionClient
    {
        internal void SetDataHandlingAdapter(SingleStreamDataHandlingAdapter adapter)
        {
            base.SetAdapter(adapter);
        }
    }

    /// <summary>
    /// 此插件实现，按照不同端口，使用不同适配器。
    /// <list type="bullet">
    /// <item>7789端口:使用"**"结尾的数据</item>
    /// <item>7790端口:使用"##"结尾的数据</item>
    /// </list>
    /// </summary>
    internal class DifferentProtocolPlugin : PluginBase, ITcpConnectingPlugin, ITcpReceivedPlugin
    {
        public async Task OnTcpConnecting(ITcpSession client, ConnectingEventArgs e)
        {
            if (client is MyTcpSessionClient sessionClient)
            {
                if (sessionClient.ServicePort == 7789)
                {
                    sessionClient.SetDataHandlingAdapter(new TerminatorPackageAdapter("**"));
                }
                else
                {
                    sessionClient.SetDataHandlingAdapter(new TerminatorPackageAdapter("##"));
                }
            }

            await e.InvokeNext();
        }

        public async Task OnTcpReceived(ITcpSession client, ReceivedDataEventArgs e)
        {
            //如果是自定义适配器，此处解析时，可以判断e.RequestInfo的类型

            if (client is ITcpSessionClient sessionClient)
            {
                sessionClient.Logger.Info($"{sessionClient.GetIPPort()}收到数据，服务器端口：{sessionClient.ServicePort},数据：{e.ByteBlock}");
            }

            await e.InvokeNext();
        }
    }
}