SunlightAggregationManager/UserClass/AsyncTcpServer.cs

using SunlightAggregationManager.ViewModel;
using System;
using System.Collections.Generic;
using System.Data;
using System.Net.Sockets;
using System.Security.Cryptography.Pkcs;
using System.Text;
using System.Text.Json;
using System.Windows;
using System.Windows.Markup;
using System.Xml.Linq;
using TouchSocket.Core;
using TouchSocket.Sockets;
using static SunlightAggregationManager.UserClass.AsyncTcpServer;

namespace SunlightAggregationManager.UserClass
{
    public class AsyncTcpServer
    {
        public class Person
        {
            public required string User { get; set; }
            public required string Password { get; set; }
            public required string IP { get; set; }
            public required string Terminal { get; set; }
            public required string Dat { get; set; }
        }

        public static async void Configuration(int P1, int P2)
        {
            await TcpMain(P1, P2);
        }

        public static TcpService service = new TcpService();

        public static async Task TcpMain(int port1 ,int port2)
        {
            NetFwManger.AllowPort(port1, "TCP");//开放7790端口
            NetFwManger.AllowPort(port2, "TCP");//开放7790端口
            //TcpService service = new TcpService();
            service.Connecting = (client, e) => { return EasyTask.CompletedTask; };//有客户端正在连接
            service.Connected = (client, e) => {return EasyTask.CompletedTask;};//有客户端成功连接
            service.Closing = (client, e) => {
                Console.WriteLine("[Disconnecting]IP[" + client.IP + "]ID[" + client.Id + "]"); 
                return EasyTask.CompletedTask; };//有客户端正在断开连接，只有当主动断开时才有效。
            service.Closed =  (client, e) => {
                //离线记录
                Dictionary<string, object> myDictOff = new Dictionary<string, object>();
                myDictOff.Add("State", 15);
                myDictOff.Add("LastActionTime", DateTime.Now);
                myDictOff.Add("LastOfflineTime", DateTime.Now);
                myDictOff.Add("Note", "Offline");
                MainWindowViewModel.Updata_Memory(MainWindowViewModel._userData, "LinkID='" + client.Id + "'", myDictOff);
                Console.WriteLine("[Offline]IP[" + client.IP + "]ID["+ client.Id + "]");
                return EasyTask.CompletedTask; 
            };//有客户端断开连接
            service.Received = (client, e) =>{                
                string DAT = e.Memory.Span.ToString(Encoding.UTF8);
                try
                {
                    Person? deserializedPerson = JsonSerializer.Deserialize<Person>(DAT);

                    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")
                        {
                            if (_dat == "20")
                            {//行为
                                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") + "]");
                                Command(deserializedPerson?.Dat ?? "NOT", client.Id, deserializedPerson!);
                            }
                            else
                            {//首次登录记录
                                Dictionary<string, object> myDict = new Dictionary<string, object>();
                                myDict.Add("State", 20);
                                myDict.Add("LinkID", client.Id);
                                myDict.Add("LastLoginIP", deserializedPerson?.IP ?? client.IP);
                                myDict.Add("LastLoginTime", DateTime.Now);
                                myDict.Add("LastLoginTerminal", deserializedPerson?.Terminal ?? "unknown device");
                                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 + "]IP[" + deserializedPerson?.IP ?? client.IP +
                                    "]ID[" + client.Id + "]Terminal[" + (deserializedPerson?.Terminal ?? "unknown device") + "]");

                                //返回登录信息
                                Dictionary<string, object> login = new Dictionary<string, object>();
                                DataRow? dat = MainWindowViewModel.Selet_Row(MainWindowViewModel._userData,"User='" +                        
                                    deserializedPerson?.User + "' and Password ='" + deserializedPerson?.Password + "'");
                                login.Add("Enterprise", dat?.Field<object>("Enterprise")??"");
                                login.Add("Department", dat?.Field<object>("Department") ?? "");
                                login.Add("Groups", dat?.Field<object>("Groups") ?? "");
                                login.Add("UserId", dat?.Field<object>("UserID") ?? "");
                                login.Add("UserName", dat?.Field<object>("Name") ?? "");

                                deserializedPerson!.Dat = JsonSerializer.Serialize(login);
                                var jsdat = JsonSerializer.Serialize(deserializedPerson);
                                client.SendAsync(jsdat);
                            }
                        }
                        else
                        {//停用账号关闭连接
                            client.SendAsync("Account Deactivated");
                            foreach (var item in AsyncTcpServer.service.Clients)
                            {
                                if (item.Id == client.Id)
                                {
                                    item.CloseAsync();

                                    //在断开连接后，释放对象。
                                    item.Dispose();
                                }
                            }
                        }
                    }
                    else
                    { //无效账号关闭连接
                        client.SendAsync("Invalid Account");
                        foreach (var item in AsyncTcpServer.service.Clients)
                        {
                            if (item.Id == client.Id)
                            {
                                item.CloseAsync();
                                item.Dispose();
                            }
                        }
                    }
                   
                }
                catch (Exception ex)
                {//错误
                    LogGing.ERRDATA(ex);
                    Console.WriteLine("Tcp:" + ex.ToString());
                    client.SendAsync("Target instruction parsing error manager will close connection");
                    foreach (var item in AsyncTcpServer.service.Clients)
                    {
                        if (item.Id == client.Id)
                        {
                            item.CloseAsync();
                            item.Dispose();
                        }
                    }
                }

                return EasyTask.CompletedTask;
            };


            await service.SetupAsync(new TouchSocketConfig()//载入配置
                //  .SetMaxBufferSize(1024 * 1024 * 100)
                //.SetMinBufferSize(1024 * 1024)
                .SetListenIPHosts(new IPHost[] { new IPHost(port1), new IPHost(port2) })//同时监听两个地址
                .ConfigureContainer(a =>//容器的配置顺序应该在最前面
                {
                })
                .ConfigurePlugins(a =>
                {
                })
                );
            
            await service.StartAsync();//启动

            Console.WriteLine("TCP Port:"+ port1.ToString());
            Console.WriteLine("TCP Port:"+ port2.ToString());
            Console.WriteLine("TCP SERVER:START");
        }

        public static async void Command(string dat, string id, 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 == "SysData")//回复请求的信息
                {
                    ret = JsonSerializer.Serialize(data_);
                }
                if (Command == "ChemicalStatistics")//回复请求的信息
                {
                    data_.Add("ChemicalStatistics", Newtonsoft.Json.JsonConvert.SerializeObject(MainWindowViewModel.ChemicalStatistics));
                    ret = JsonSerializer.Serialize(data_);
                }
                if (Command == "Info")//回复info请求的信息
                {
                    var t = ToList(MainWindowViewModel._machines).ToJsonString();
                    //格式化返回信息
                    data_.Add("Info", t);
                    data_.Add("DyeMeasurementNumber", MainWindowViewModel.DyeMeasurementNumber.ToString());
                    data_.Add("ChemicalNumber", MainWindowViewModel.ChemicalNumber.ToString());
                    data_.Add("PowderNumber", MainWindowViewModel.PowderNumber.ToString());
                    data_.Add("DyeDissolveNumber", MainWindowViewModel.DyeDissolveNumber.ToString());
                    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 Id>'" +
                         s_ + "'", 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 service.SendAsync(id, jsdat);
            }
            catch (Exception ex)
            {
                LogGing.ERRDATA(ex);
                Console.WriteLine(ex.ToString());
            }
        }

        public static List<Dictionary<string, object?>>? ToList(DataTable table)//datatable转list
        {
            if (table == null) return null;

            // 使用 AsEnumerable() 将 DataTable 转换为 IEnumerable<DataRow>
            // 然后投影为 Dictionary
            return table.AsEnumerable().Select(row =>
                table.Columns.Cast<DataColumn>().ToDictionary(
                    col => col.ColumnName,
                    col => {
                        var value = row[col];
                        // 核心修改：如果是数据库空值 DBNull.Value，则转为 C# 的 null，否则保持原值
                        return value == DBNull.Value ? null : value;
                    }
                )
            ).ToList();
        }
    }

      
}