using CommunityToolkit.Mvvm; using CommunityToolkit.Mvvm.ComponentModel; using CommunityToolkit.Mvvm.Input; using ForwardingServerUI.Class; using System; using System.Collections.Generic; using System.Data; using System.Reflection.PortableExecutable; using System.Text; using TouchSocket.Sockets; namespace ForwardingServerUI { public partial class MainWindowViewModel : ObservableObject { 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; } } [ObservableProperty] public static DataTable _machineTable = new(); [ObservableProperty] public static DataTable _userTable = new(); public static SqliteHelper SQLiteHelpers = null!; //定义数据库 private readonly string DBAddress = Environment.CurrentDirectory + "\\DB\\DB.db"; //数据库路径 public static DataTable ActionLog = new DataTable(); public static readonly object TableLock = new object(); public async void Data() { SQLiteHelpers = new SqliteHelper(DBAddress); //数据库连接路径 SQLiteHelpers.Open(); //打开数据库 _machineTable.Columns.Add("ID", typeof(string)); _machineTable.Columns.Add("IP", typeof(string)); _machineTable.Columns.Add("Start", typeof(int)); _machineTable.Columns.Add("Enterprise", typeof(string)); _machineTable.Columns.Add("MachineName", typeof(string)); _machineTable.Columns.Add("HeartbeatTime", typeof(string)); _machineTable.Columns.Add("MachineVer", typeof(string)); _userTable.Columns.Add("ID", typeof(string)); _userTable.Columns.Add("IP", typeof(string)); _userTable.Columns.Add("User", typeof(string)); _userTable.Columns.Add("Enterprise", typeof(string)); _userTable.Columns.Add("Terminal", typeof(string)); _userTable.Columns.Add("MachineName", typeof(string)); _userTable.Columns.Add("RDAT", typeof(string)); await AsyncTcpServer.TcpMain(); await AsyncHttpServer.HttpMain(); } public MainWindowViewModel() { Data(); } } }