eaxing_back_africa_charger/Service/Charger/Client/ClientMgr.cs

using Autofac;
using DotNetty.Transport.Channels;
using Entity.DbModel.Station;
using HybirdFrameworkCore.Autofac;
using HybirdFrameworkCore.Autofac.Attribute;
using HybirdFrameworkDriver.Session;
using log4net;
using Repository.Station;
using Service.Charger.Common;
using Service.Equipment;

namespace Service.Charger.Client;

/// <summary>
///     示例程序
/// </summary>
[Scope("SingleInstance")]
public static class ClientMgr
{

    private static readonly ILog Log = LogManager.GetLogger(typeof(ClientMgr));
    
    private static readonly Dictionary<string, ChargerClient> Dictionary = new();

    public static ChargerClient? GetBySn(string sn)
    {
        Dictionary.TryGetValue(sn, out var o);
        return o;
    }

    public static bool TryGetClient(IChannel channel, out string sn, out ChargerClient? client)
    {
        string? snt = ChannelUtils.GetAttr(channel, ChargerConst.ChargerSn);

        if (!string.IsNullOrWhiteSpace(snt))
        {
            var chargerClient = GetBySn(snt);
            if (chargerClient != null)
            {
                sn = snt;
                client = chargerClient;
                return true;
            }
        }

        sn = string.Empty;
        client = null;
        return false;
    }

    public static void AddBySn(string sn, ChargerClient client)
    {
        Dictionary[sn] = client;
    }

    //TODO 连接、鉴权，开始充电，结束充电，设置尖峰平谷，读取尖峰平谷，发送功率调节指令，发送辅助源控制指令，下发掉线停止充电，
    public static void InitClient()
    {
        EquipInfoRepository equipInfoRepository = AppInfo.Container.Resolve<EquipInfoRepository>();
        EquipNetInfoRepository netInfoRepository = AppInfo.Container.Resolve<EquipNetInfoRepository>();
        List<EquipInfo> equipInfos = equipInfoRepository.QueryListByClause(it => it.TypeCode == (int)EquipmentType.Charger);
        if (equipInfos.Count > 0)
        {
            Dictionary<string,EquipInfo> set = equipInfos.ToDictionary(it => it.Code, it => it);
            List<EquipNetInfo> equipNetInfos = netInfoRepository.QueryListByClause(it => set.ContainsKey(it.Code));
            foreach (EquipNetInfo netInfo in equipNetInfos)
            {
                Task.Run(() =>
                {
                    ConnClient(netInfo);
                });
            }
        }
    }

    private static void ConnClient(EquipNetInfo netInfo)
    {
        Log.Info($"begin to connect {netInfo.Code} {netInfo.NetAddr}:{netInfo.NetPort}");
        ChargerClient client = AppInfo.Container.Resolve<ChargerClient>();
        client.InitBootstrap(netInfo.NetAddr, int.Parse(netInfo.NetPort));
        client.Connect();
        client.SessionAttr(netInfo.Code, netInfo.NetAddr);
        AddBySn(netInfo.Code, client);
        Log.Info($"connected {netInfo.Code} {netInfo.NetAddr}:{netInfo.NetPort}");
    }
}