hn_zw_back_charger/Service/Charger/Client/ChargerClient.cs

using System.Collections.Concurrent;
using Autofac;
using Entity.DbModel.Station;
using HybirdFrameworkCore.Autofac;
using HybirdFrameworkCore.Autofac.Attribute;
using HybirdFrameworkCore.Entity;
using HybirdFrameworkCore.Redis;
using HybirdFrameworkCore.Utils;
using HybirdFrameworkDriver.Session;
using HybirdFrameworkDriver.TcpClient;
using log4net;
using Newtonsoft.Json;
using Repository.Station;
using Service.Charger.Codec;
using Service.Charger.Common;
using Service.Charger.Handler;
using Service.Charger.Msg;
using Service.Charger.Msg.Charger.OutCharger.Req;
using Service.Charger.Msg.Charger.Req;
using Service.Charger.Msg.Charger.Resp;
using Service.Charger.Msg.Host.Req;
using Service.Charger.Msg.Host.Req.Bms;
using Service.Charger.Msg.Host.Req.OutCharger.Req;

namespace Service.Charger.Client;

/// <summary>
///     示例程序
/// </summary>
[Scope("InstancePerDependency")]
public class ChargerClient : TcpClient<IBaseHandler, Decoder, Encoder>
{
    #region 属性

    /// <summary>
    /// 充电机编号
    /// </summary>
    public string Sn { get; set; }

    public ushort AuthTimes { get; set; } = 0;
    public bool IsAuthed { get; set; } = false;

    /// <summary>
    /// 参考 Service.Charger.Common.ChargingStatus
    /// </summary>
    public UInt16 ChargingStatus { get; set; }

    /// <summary>
    /// 是否已经开始充电
    /// </summary>
    public bool IsCharged { get; set; } = false;


    /// <summary>
    /// 站外两枪时是否在充电
    /// </summary>
    public ConcurrentDictionary<byte, bool> GunCharged = new ConcurrentDictionary<byte, bool>
    {
        [1] = false,
        [2] = false
    };

    /// <summary>
    /// 充电桩连接状态
    /// </summary>
    public ConcurrentDictionary<byte, bool> ChargedPile = new ConcurrentDictionary<byte, bool>
    {
        [1] = false,
        [2] = false
    };

    public bool IsStopped { get; set; } = false;
    public bool IsCanSendStopCmd { get; set; } = true;

    public DateTime? ChargingStartTime { get; set; }

    public DateTime? ChargingStopTime { get; set; }

    /// <summary>
    /// 电池包实时数据
    /// </summary>
    public BatteryPackData? BatteryPackData { get; set; }

    /// <summary>
    /// 电池包实时单体温度&单体电压数据
    /// </summary>
    public BatteryPackDataVoltage? BatteryPackDataVoltage { get; set; }

    /// <summary>
    /// 电池包上报累计充放电电量
    /// </summary>
    public BatteryPackTotalElectricity? BatteryPackTotalElectricity { get; set; }

    /// <summary>
    /// 电池包上报充放电口温度
    /// </summary>
    public BatteryPackPortTemperature? BatteryPackPortTemperature { get; set; }

    /// <summary>
    /// 电池包内部接触器状态和故障上报
    /// </summary>
    public BatteryPackStateAndFault? BatteryPackStateAndFault { get; set; }

    /// <summary>
    /// 充放电设备应答站功率调节指令
    /// </summary>
    public PowerRegulationRes PowerRegulationRes { get; set; }

    /// <summary>
    /// 电池包实时遥信上报（站内充电模式有电池包时周期性上传）
    /// </summary>
    public RemoteSignaling RemoteSignaling { get; set; }

    /// <summary>
    /// 充电机上报车辆 VIN
    /// </summary>
    public VehicleVIN VehicleVIN { get; set; }

    /// <summary>
    /// 充放电机应答辅助控制
    /// </summary>
    public AuxiliaryPowerRes AuxiliaryPowerRes { get; set; }

    /// <summary>
    /// 充放电上报交流电表数据（交流电表接到充电机上的情况）
    /// </summary>
    public AcMeter AcMeter { get; set; }

    /// <summary>
    ///充电机遥信数据
    /// </summary>
    public UploadRemoteSignalData UploadRemoteSignalData = new UploadRemoteSignalData();

    /// <summary>
    /// 充电机工作状态-从遥信数据包中得到。00H：待机 01H：工作 02H：工作完成 03H：充/放电暂停
    /// </summary>
    public byte Workstate { get; set; }

    /// <summary>
    /// 充电机故障-遥信数据包总故障 00H正常、01H故障
    /// </summary>
    public bool TotalError { get; set; }

    /// <summary>
    /// 充电机告警-遥信数据包总告警 00H正常、01H告警
    /// </summary>
    public bool TotalWarning { get; set; }

    /// <summary>
    /// 充电机遥测数据
    /// </summary>
    public UploadTelemetryData UploadTelemetryData = new UploadTelemetryData();

    /// <summary>
    /// 充放电机上传单体动力蓄电池电压极值统计
    /// </summary>
    public VoltageExtremumStatistics? VoltageExtremumStatistics = new VoltageExtremumStatistics();

    /// <summary>
    /// 充电桩的遥测
    /// </summary>
    public ConcurrentDictionary<byte, PileUploadTelemetry> PileUploadTelemetry = new();

    /// <summary>
    /// 充电桩的遥信
    /// </summary>
    public ConcurrentDictionary<byte, PileUploadRemoteSignal> PileUploadRemoteSignal = new();

    /// <summary>
    /// 充电桩状态信息
    /// </summary>
    public ConcurrentDictionary<byte, ChargerPile> ChargerPile = new();
    
    /// <summary>
    /// 充电桩功率
    /// </summary>
    public ConcurrentDictionary<byte, float> ChargePilePower = new();

    /// <summary>
    ///充电机实时充电功率
    /// </summary>
    public float RealTimeChargePower { get; set; } = 0;

    /// <summary>
    /// 心跳-桩状态
    /// </summary>
    public byte PileState { get; set; }

    /// <summary>
    /// 电池编码
    /// </summary>
    public string? BatteryNo { get; set; }

    /// <summary>
    /// 电池厂家
    /// </summary>
    public byte? BatteryFactory { get; set; }

    /// <summary>
    /// 电池仓编号
    /// </summary>
    public string? BinNo { get; set; }

    /// <summary>
    /// 远程升级-监控网关上送升级完成确认帧
    /// </summary>
    public UplinkUpgrade UplinkUpgrade { get; set; }

    /// <summary>
    /// 充电订单号
    /// </summary>
    public string? ChargeOrderNo { get; set; }

    /// <summary>
    /// 当前指令
    /// </summary>
    public string? CurrentCmd { get; set; }

    /// <summary>
    /// 当前接收报文
    /// </summary>
    public string? CurrentMsg { get; set; }

    #endregion

    #region db

    private ChargeOrderRepository _chargeOrderRepository;
    private BinInfoRepository _binInfoRepository;

    #endregion

    public ChargerClient(ChargeOrderRepository chargeOrderRepository, BinInfoRepository binInfoRepository)
    {
        _chargeOrderRepository = chargeOrderRepository;
        _binInfoRepository = binInfoRepository;
    }

    private ILog Log()
    {
        var name = "Charger" + this.Sn;
        ILog logger = LogManager.GetLogger(name);

        Console.WriteLine(name + "-" + logger.GetHashCode());
        return logger;
    }

    /// <summary>
    ///
    /// </summary>
    /// <param name="asdu"></param>
    public void ReceiveMsgHandle(ASDU asdu)
    {
        this.CurrentMsg = CurrentCmd = JsonConvert.SerializeObject(asdu, Formatting.Indented) + "\r\n" +
                                       BitUtls.BytesToHexStr(asdu.ToBytes());
    }

    #region 发送指令

    private ushort IncreAuthTimes()
    {
        if (AuthTimes < 65535)
        {
            AuthTimes += 1;
        }
        else
        {
            AuthTimes = 1;
        }

        return AuthTimes;
    }


    /// <summary>
    /// 发送鉴权
    /// </summary>
    public Result<bool> SendAuth()
    {
        if (!Connected)
        {
            return Result<bool>.Fail($"charger-{BinNo} disconnect");
        }

        byte authCodeKey = ChargerUtils.GetByteRandomNum(); //鉴码KEY[随机数]
        byte[] authCodes = ChargerUtils.GetAuthCodesResult(ChargerConst.AuthCode, authCodeKey); //鉴权码
        Auth auth = new Auth(IncreAuthTimes(), authCodes, authCodeKey);
        CurrentCmd = JsonConvert.SerializeObject(auth, Formatting.Indented) + "\r\n" +
                     BitUtls.BytesToHexStr(auth.ToBytes());
        this.Channel.WriteAndFlushAsync(auth);
        return Result<bool>.Success();
    }

    /// <summary>
    /// 监控平台发送远程开始充电指令
    /// </summary>
    /// <param name="socLimit">SOC限制.百分比</param>
    /// <param name="changePowerCmdType">功率调节指令类型.默认1 绝对功率值</param>
    /// <param name="changePower">1kw/位,默认3600</param>
    /// <param name="chargeOrderNo">充电流水号</param>
    public Result<string> SendRemoteStartCharging(byte socLimit, float changePower = 360, byte changePowerCmdType = 1,
        string? chargeOrderNo = null)
    {
        if (!Connected)
        {
            return Result<string>.Fail($"充电机{BinNo}未连接");
        }

        if (string.IsNullOrWhiteSpace(chargeOrderNo))
        {
            chargeOrderNo = ChargerUtils.GenChargeOrderSn();
        }

        Log().Info(
            $"SendRemoteStartCharging soc={socLimit}, changePower={changePower}, changePowerCmdType={changePowerCmdType}, chargeOrderNo={chargeOrderNo}");
        var remoteStartCharging = new RemoteStartCharging(socLimit, changePowerCmdType, changePower, chargeOrderNo);
        CurrentCmd = JsonConvert.SerializeObject(remoteStartCharging, Formatting.Indented) + "\r\n" +
                     BitUtls.BytesToHexStr(remoteStartCharging.ToBytes());
        this.Channel.WriteAndFlushAsync(remoteStartCharging);

        return Result<string>.Success(chargeOrderNo);
    }

    /// <summary>
    /// 监控平台发送远程停止充电指令
    /// </summary>
    /// <param name="reason">0 正常停机 1 服务器发现桩异常,强制停机</param>
    public Result<bool> SendRemoteStopCharging(byte reason = 0)
    {
        if (!Connected)
        {
            return Result<bool>.Fail($"charger-{BinNo} disconnect");
        }

        RemoteStopCharging remoteStopCharging = new RemoteStopCharging(reason);
        CurrentCmd = JsonConvert.SerializeObject(remoteStopCharging, Formatting.Indented) + "\r\n" +
                     BitUtls.BytesToHexStr(remoteStopCharging.ToBytes());
        this.Channel.WriteAndFlushAsync(remoteStopCharging);
        return Result<bool>.Success();
    }

    /// <summary>
    /// 监控平台发送功率调节指令
    /// </summary>
    /// <param name="expectedOperatingPower">期望运行功率</param>
    public Result<bool> SendPowerRegulation(float expectedOperatingPower)
    {
        if (!Connected)
        {
            return Result<bool>.Fail($"charger-{BinNo} disconnect");
        }

        PowerRegulation powerRegulation = new PowerRegulation(expectedOperatingPower);
        this.Channel.WriteAndFlushAsync(powerRegulation);
        return Result<bool>.Success();
    }

    /// <summary>
    /// 倍率 例如，0.单5C位该0值.1C为 5 ,1C 时该值为 10
    /// </summary>
    /// <param name="rate"></param>
    public Result<bool> SendAdjustChargeRate(float rate)
    {
        if (!Connected)
        {
            return Result<bool>.Fail($"charger-{BinNo} disconnect");
        }

        AdjustChargeRate adjustChargeRate = new AdjustChargeRate(rate);
        this.Channel.WriteAndFlushAsync(adjustChargeRate);
        return Result<bool>.Success();
    }

    /// <summary>
    /// 监控平台下发辅源控制指令
    /// </summary>
    /// <param name="openFlag">打开辅助电源标志 1：电池包辅助电源导通 0：电池包辅助电源断开</param>
    public Result<bool> SendAuxiliaryPower(byte openFlag)
    {
        if (!Connected)
        {
            return Result<bool>.Fail($"charger-{BinNo} disconnect");
        }

        AuxiliaryPower auxiliaryPower = new AuxiliaryPower(openFlag);
        CurrentCmd = JsonConvert.SerializeObject(auxiliaryPower, Formatting.Indented) + "\r\n" +
                     BitUtls.BytesToHexStr(auxiliaryPower.ToBytes());
        this.Channel.WriteAndFlushAsync(auxiliaryPower);
        return Result<bool>.Success();
    }

    /// <summary>
    /// 监控平台下发电池仓的状态
    /// </summary>
    /// <param name="battery">是否有电池 0:无电池 1：有电池</param>
    /// <param name="connectionState">电接头连接状态 0:未连接 1: 已连接</param>
    /// <param name="waterCondition">水接头状态 0:未连接 1: 已连接</param>
    public Result<bool> SendBatteryHolderStatus(byte battery, byte connectionState, byte waterCondition)
    {
        if (!Connected)
        {
            return Result<bool>.Fail($"charger-{BinNo} disconnect");
        }

        BatteryHolderStatus batteryHolderStatus = new BatteryHolderStatus(battery, connectionState, waterCondition);
        CurrentCmd = JsonConvert.SerializeObject(batteryHolderStatus, Formatting.Indented) + "\r\n" +
                     BitUtls.BytesToHexStr(batteryHolderStatus.ToBytes());
        this.Channel.WriteAndFlushAsync(batteryHolderStatus);
        return Result<bool>.Success();
    }


    /// <summary>
    /// 站控下发 VIN 鉴权的结果
    /// </summary>
    /// <param name="vinresult">VIN 鉴权结果 1:通过 2 不通过</param>
    public Result<bool> SendAuthenticationVIN(byte vinresult)
    {
        if (!Connected)
        {
            return Result<bool>.Fail($"charger-{BinNo} disconnect");
        }

        AuthenticationVIN authenticationVIN = new AuthenticationVIN(vinresult);
        this.Channel.WriteAndFlushAsync(authenticationVIN);
        return Result<bool>.Success();
    }

    /// <summary>
    /// 远程升级-站级监控升级请求下发
    /// </summary>
    /// <param name="executionControl">执行控制 0x01：立即执行 0x02：空闲执行</param>
    /// <param name="downloadTimeout">下载超时时间</param>
    /// <param name="versionNumber">版本号</param>
    /// <param name="fileName">文件名称</param>
    /// <param name="fileSize">文件大小</param>
    /// <param name="mD5Verification">MD5校验值</param>
    /// <param name="url">URL（文件路径）</param>
    public Result<bool> SendUpgradeRequest(byte executionControl, byte downloadTimeout, string versionNumber,
        string fileName, uint fileSize, string mD5Verification, string url)
    {
        if (!Connected)
        {
            return Result<bool>.Fail($"charger-{BinNo} disconnect");
        }

        UpgradeRequest upgradeRequest = new UpgradeRequest(executionControl, downloadTimeout, versionNumber, fileName,
            fileSize, mD5Verification, url);
        this.Channel.WriteAndFlushAsync(upgradeRequest);
        return Result<bool>.Success();
    }

    /// <summary>
    /// 设置尖峰平谷时间段
    /// </summary>
    /// <param name="setPeakValleyTime"></param>
    public Result<bool> SendSetPeakValleyTime(SetPeakValleyTime setPeakValleyTime)
    {
        if (!Connected)
        {
            return Result<bool>.Fail($"charger-{BinNo} disconnect");
        }


        CurrentCmd = JsonConvert.SerializeObject(setPeakValleyTime, Formatting.Indented) + "\r\n" +
                     BitUtls.BytesToHexStr(setPeakValleyTime.ToBytes());
        this.Channel.WriteAndFlushAsync(setPeakValleyTime);

        Log().Info($"SendSetPeakValleyTime{CurrentCmd} to chargeOrderNo={BinNo}");

        return Result<bool>.Success();
    }

    /// <summary>
    /// 3.4.7 监控平台下发掉线停止充电
    /// </summary>
    /// <param name="enabled"> 0：不使能 1：使能</param>
    public Result<bool> SendOfflineStopCharging(byte enabled)
    {
        if (!Connected)
        {
            return Result<bool>.Fail($"charger-{BinNo} disconnect");
        }

        OfflineStopCharging offlineStopCharging = new OfflineStopCharging(enabled);
        CurrentCmd = JsonConvert.SerializeObject(offlineStopCharging, Formatting.Indented) + "\r\n" +
                     BitUtls.BytesToHexStr(offlineStopCharging.ToBytes());
        this.Channel.WriteAndFlushAsync(offlineStopCharging);
        return Result<bool>.Success();
    }

    /// <summary>
    /// 3.4.12 站控设备切换站内/站外充电切换
    /// </summary>
    /// <param name="chargeMode">00:无效 01:站内 02:站外</param>
    public Result<bool> SendChangeChargeMode(byte chargeMode)
    {
        if (!Connected)
        {
            return Result<bool>.Fail($"charger-{BinNo} disconnect");
        }

        ChangeChargeMode req = new ChangeChargeMode(chargeMode);
        this.Channel.WriteAndFlushAsync(req);
        return Result<bool>.Success();
    }

    /// <summary>
    /// 3.7.1 监控平台远程启动充电桩充电
    /// </summary>
    /// <param name="pn">充电枪ID号</param>
    /// <param name="socValue">SOC 限制</param>
    /// <param name="changePower">功率调节指令类型</param>
    /// <param name="changePowerCmdType">功率调节参数</param>
    /// <param name="chargeOrderNo"></param>
    /// <returns>充电流水号</returns>
    public Result<string> SendStartOutCharger(byte pn, byte socValue, short changePower = 360,
        byte changePowerCmdType = 1,
        string? chargeOrderNo = null)
    {
        if (!Connected)
        {
            return Result<string>.Fail($"充电机{BinNo}未连接");
        }

        if (string.IsNullOrWhiteSpace(chargeOrderNo))
        {
            chargeOrderNo = ChargerUtils.GenChargeOrderSn();
        }

        Log().Info(
            $"SendStartOutCharger pn={pn}, socValue={socValue}, changePower={changePower}, changePowerCmdType={changePowerCmdType}, chargeOrderNo={chargeOrderNo}");

        PileStartCharge pileStartCharge =
            new PileStartCharge(pn, socValue, changePowerCmdType, changePower, chargeOrderNo);

        this.Channel.WriteAndFlushAsync(pileStartCharge);

        return Result<string>.Success(chargeOrderNo);
    }

    /// <summary>
    /// 3.7.3 监控平台远程停止充电桩充电
    /// </summary>
    /// <param name="pn"></param>
    /// <param name="stopReason"></param>
    /// <returns></returns>
    public Result<string> SendStopOutCharger(byte pn, byte stopReason)
    {
        if (!Connected)
        {
            return Result<string>.Fail($"充电机{BinNo}未连接");
        }

        Log().Info(
            $"SendStartOutCharger pn={pn}, stopReason={stopReason}");
        PileStopCharge pileStopCharge = new PileStopCharge(pn, stopReason);
        this.Channel.WriteAndFlushAsync(pileStopCharge);

        return Result<string>.Success();
    }

    /// <summary>
    /// 3.7.9 监控平台发送充电桩功率调节指令
    /// </summary>
    /// <param name="pn"></param>
    /// <param name="expectedOperatingPower"></param>
    /// <returns></returns>
    public Result<bool> SendPileAdjustPower(byte pn, float expectedOperatingPower)
    {
        if (!Connected)
        {
            return Result<bool>.Fail($"charger-{BinNo} disconnect");
        }

        PileAdjustPower powerRegulation = new PileAdjustPower(pn, expectedOperatingPower);
        this.Channel.WriteAndFlushAsync(powerRegulation);
        return Result<bool>.Success();
    }

    /// <summary>
    ///
    /// </summary>
    public Result<bool> SendQueryBattery()
    {
        if (!Connected)
        {
            return Result<bool>.Fail($"charger-{BinNo} disconnect");
        }

        QueryBattery queryBattery = new QueryBattery(ChargerConst.BatteryNo);
        CurrentCmd = JsonConvert.SerializeObject(queryBattery, Formatting.Indented) + "\r\n" +
                     BitUtls.BytesToHexStr(queryBattery.ToBytes());
        this.Channel.WriteAndFlushAsync(queryBattery);
        return Result<bool>.Success();
    }

    #endregion


    #region 启动充电

    /// <summary>
    ///
    /// </summary>
    public Result<bool> StartCharge(byte chargeSoc, float chargePower)
    {
        if (string.IsNullOrWhiteSpace(BinNo))
        {
            return Result<bool>.Fail("charger init error with no BinNo");
        }

        if (!Connected)
        {
            return Result<bool>.Fail($"charger-{BinNo} disconnect");
        }

        BinInfo binInfo = _binInfoRepository.QueryByClause(it => it.Code == BinNo);
        if (binInfo == null)
        {
            return Result<bool>.Fail($"charger-{BinNo} not exist");
        }

        BatteryNo = binInfo.BatteryNo;
        if (string.IsNullOrWhiteSpace(BatteryNo))
        {
            return Result<bool>.Fail($"charger-{BinNo} battery not exist");
        }

        if (binInfo.AmtLock == 1)
        {
            return Result<bool>.Fail($"仓-{BinNo} 被锁定");
        }

        if (binInfo.CanChargeFlag == 0)
        {
            return Result<bool>.Fail($"仓-{BinNo} 被禁用");
        }

        RedisHelper redisHelper = AppInfo.Container.Resolve<RedisHelper>();

        string? lockKey = redisHelper.GetStrValue($"chargeNo{BinNo}Start");
        if (!string.IsNullOrWhiteSpace(lockKey))
        {
            return Result<bool>.Success(true, $"charger-{BinNo} is starting");
        }

        redisHelper.SetKeyValueStr($"chargeNo{BinNo}Start", DateTime.Now.ToString("f"), TimeSpan.FromMinutes(1));

        Result<string> chargeOrderNo = SendRemoteStartCharging(chargeSoc, chargePower);
        if (!chargeOrderNo.IsSuccess)
        {
            return Result<bool>.Fail(chargeOrderNo.Msg);
        }

        ChargeOrderNo = chargeOrderNo.Data;
        _chargeOrderRepository.Insert(new ChargeOrder()
        {
            Sn = ChargeOrderNo,
            BatteryNo = BatteryNo,
            CmdStatus = 0,
            ChargerNo = BinNo,
            ChargeMode = 1,
            StartMode = 1
        });

        return Result<bool>.Success(true, "发送成功");
    }

    #endregion

    /// <summary>
    ///
    /// </summary>
    /// <returns></returns>
    public bool Connect()
    {
        base.BaseConnect();
        Log().Info($"charger {Sn} connect succeed");
        return Connected;
    }

    /// <summary>
    ///
    /// </summary>
    /// <param name="sn"></param>
    /// <param name="destAddr"></param>
    public void SessionAttr(string sn, string destAddr)
    {
        ChannelUtils.AddAttr(Channel, ChargerConst.ChargerSn, sn);
        ChannelUtils.AddAttr(Channel, ChargerConst.EqmTypeNo, sn);
        ChannelUtils.AddAttr(Channel, ChargerConst.EqmCode, sn);
        ChannelUtils.AddAttr(Channel, ChargerConst.DestAddr, destAddr);
    }
}