Server/VB_DSM_DATA/VbdsmMockData/Vbdsm.Hj212/Program.cs

using Vbdsm.Settings;
using Vbdsm.SocketClients;

Console.WriteLine("------------------------数据上传（模拟）程序启动------------------------");
CancellationTokenSource tokenSource = new CancellationTokenSource();
CancellationToken cancellationToken = tokenSource.Token;
var clients = new Dictionary<string?, TpcClient>();
var terminals = new List<TerminalSetting>();
if (AppSetting.Instance.Terminals.Count > 0)
{
    terminals.AddRange(AppSetting.Instance.Terminals);
}
foreach (var terminal in terminals)
{
    var client = new TpcClient(terminal.CompanyId, terminal.TerminalIds);
    if (!clients.ContainsKey(terminal.CompanyId))
    {
        clients.Add(terminal.CompanyId, client);
        Task.Run(() => client.Run(), cancellationToken);
    }
}
Console.WriteLine("------------------------数据上传（模拟）启动完成------------------------");
while (true)
{
    string? cmd = Console.ReadLine();
    if (cmd == "exit")
    {
        break;
    }

    if (cmd != null)
    {
        if (clients.TryGetValue(cmd, out var _client))
        {
            _client.ReSend();
        }
        else
        {
            Console.WriteLine($"未能找到客户端【{cmd}】");
        }
    }
}
tokenSource.Cancel();