sc/ForwardingServer
1
0 Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

添加信息

Browse Source
This commit is contained in:
sc committed 2026-06-20 14:30:03 +08:00
2 parents 5d6cebc982 1b9791f32a
commit ae1dd1a353
1 file changed
+24 -24
Download Patch File Download Diff File Expand all files Collapse all files
AsyncTcpServer.cs
+24 -24
View File
@@ -47,42 +47,42 @@ namespace ForwardingServer
{
if (DAT.Length > 5)
{
DataRow[] r_ = DATA.MachineTable.Select("ID='" + client.Id + "'");
if (r_.Length > 0)
{
int? s_ = r_.First().Field<int?>("Start");
DataRow[] r_ = DATA.MachineTable.Select("ID='" + client.Id + "'");
if (r_.Length > 0)
{
int? s_ = r_.First().Field<int?>("Start");
if (s_ == 30)
if (s_ == 30)
{
if (DAT.StartsWith("{") || DAT.StartsWith("["))
{
if (DAT.StartsWith("{") || DAT.StartsWith("["))
DATA.Person deserializedPerson = JsonSerializer.Deserialize<DATA.Person>(DAT)!;
//转发逻辑
var dr = DATA.UserTable.Select("Terminal='" + deserializedPerson.Terminal + "'");
if (dr.Length > 0)
{
DATA.Person deserializedPerson = JsonSerializer.Deserialize<DATA.Person>(DAT)!;
//转发逻辑
var dr = DATA.UserTable.Select("Terminal='" + deserializedPerson.Terminal + "'");
if (dr.Length > 0)
{
DataRow drEmployee = dr.First();
drEmployee.BeginEdit();
drEmployee["RDAT"] = DAT;
drEmployee.EndEdit();
drEmployee.AcceptChanges();
}
DataRow drEmployee = dr.First();
drEmployee.BeginEdit();
drEmployee["RDAT"] = DAT;
drEmployee.EndEdit();
drEmployee.AcceptChanges();
}
}
}
else
{
Personm deserializedPerson = JsonSerializer.Deserialize<Personm>(DAT)!;
DATA.MachineTable.Rows.Add(client.Id, client.IP, 30, "/" + deserializedPerson.SERVEREnterprise,
deserializedPerson.SERVERMachineName, deserializedPerson.MachineVer);
}
else
{
Personm deserializedPerson = JsonSerializer.Deserialize<Personm>(DAT)!;
DATA.MachineTable.Rows.Add(client.Id, client.IP, 30, "/" + deserializedPerson.SERVEREnterprise,
deserializedPerson.SERVERMachineName, deserializedPerson.MachineVer);
Console.WriteLine("["+DateTime.Now.ToString("yyyy-MM-DD HH:mm:ss:fff")+"] LINK ID " + client.Id + " IP " + client.IP + "\n DATA =" + DAT);
}
}
}
catch (Exception ex)
{//错误
Console.WriteLine("Tcp:" + ex.ToString());
Console.WriteLine("Tcp:" + ex.ToString());
}
return EasyTask.CompletedTask;