You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
270 lines
13 KiB
270 lines
13 KiB
using SunlightAggregationManager.ViewModel;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
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)//
|
|
{
|
|
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 == "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")//回复info请求的信息
|
|
{
|
|
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 + "'");
|
|
|
|
var resultTable = MainWindowViewModel.SQLiteHelpers.ExecuteDataSet("" +
|
|
"select * from Notification WHERE Groups='" + groups + "' and Time>'" +
|
|
s_ + "' and Time<'" + e_ + "'", null)?.Tables[0] ?? new DataTable();
|
|
|
|
//格式化返回信息
|
|
data_.Add("Notification", Newtonsoft.Json.JsonConvert.SerializeObject(resultTable));
|
|
ret = JsonSerializer.Serialize(data_);
|
|
}
|
|
|
|
person.Dat=ret.ToString();
|
|
var jsdat = JsonSerializer.Serialize(person);
|
|
await service.SendAsync(id, jsdat);
|
|
}
|
|
|
|
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();
|
|
}
|
|
}
|
|
|
|
|
|
}
|
|
|