diff --git a/AsyncTcpServer.cs b/AsyncTcpServer.cs index 5627501..777f6f6 100644 --- a/AsyncTcpServer.cs +++ b/AsyncTcpServer.cs @@ -47,42 +47,43 @@ namespace ForwardingServer { if (DAT.Length > 5) { - DataRow[] r_ = DATA.MachineTable.Select("ID='" + client.Id + "'"); - if (r_.Length > 0) - { - int? s_ = r_.First().Field("Start"); - - if (s_ == 30) + DataRow[] r_ = DATA.MachineTable.Select("ID='" + client.Id + "'"); + if (r_.Length > 0) { - if (DAT.StartsWith("{") || DAT.StartsWith("[")) + int? s_ = r_.First().Field("Start"); + + if (s_ == 30) { - DATA.Person deserializedPerson = JsonSerializer.Deserialize(DAT)!; - //转发逻辑 - var dr = DATA.UserTable.Select("Terminal='" + deserializedPerson.Terminal + "'"); - if (dr.Length > 0) + if (DAT.StartsWith("{") || DAT.StartsWith("[")) { - DataRow drEmployee = dr.First(); - drEmployee.BeginEdit(); - drEmployee["RDAT"] = DAT; - drEmployee.EndEdit(); - drEmployee.AcceptChanges(); + DATA.Person deserializedPerson = JsonSerializer.Deserialize(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(); + } } - } + } } - } - else - { - Personm deserializedPerson = JsonSerializer.Deserialize(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 + "]\nDATA =" + DAT); + else + { + Personm deserializedPerson = JsonSerializer.Deserialize(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 + "]\nDATA =" + DAT); + } } } catch (Exception ex) {//错误 - Console.WriteLine("Tcp:" + ex.ToString()); + Console.WriteLine("Tcp:" + ex.ToString()); } return EasyTask.CompletedTask;