eaxing_back_africa_charger/Service/MyTask/BatteryInfoUploadTask.cs

using Autofac;
using Entity.DbModel.Station;
using HybirdFrameworkCore.Autofac;
using HybirdFrameworkCore.Autofac.Attribute;
using HybirdFrameworkCore.AutoTask;
using HybirdFrameworkCore.Redis;
using log4net;
using Newtonsoft.Json;
using Repository.Station;
using Service.Charger.Client;
using Service.Init;
using Service.Swap.Dto;

namespace Service.MyTask;
[Scope]
public class BatteryInfoUploadTask : ITask
{
    private static readonly ILog Log = LogManager.GetLogger(typeof(BatteryInfoUploadTask));
    private RedisHelper RedisHelper { get; set; } = AppInfo.Container.Resolve<RedisHelper>();
    private BinInfoRepository BinInfoRepository = AppInfo.Container.Resolve<BinInfoRepository>();

    private static bool _stop;

    public string Name()
    {
        return nameof(BatteryInfoUploadTask);
    }

    public int Interval()
    {
        return 1000 * 1;
    }

    public void Handle()
    {
        Log.Info("begin start BatteryInfoUploadTask uoload");
        DateTime now = DateTime.Now;
        List<BinInfo> binInfos = BinInfoRepository.Query();
        List<SingleBatInfo> batInfos = binInfos.Where(it => it.Exists == 1).Select(it =>
        {
            Log.Info("start BatteryInfoUploadTask uoload bininfo select");
            ChargerClient? client = ClientMgr.GetBySn(it.ChargerNo);
            SingleBatInfo batInfo = new SingleBatInfo()
            {
                bn = it.BatteryNo,
                bt = now,
                sd = it.ChargerNo,
                cno = Convert.ToInt32(it.ChargerNo.Substring(1)),
                el = 0,
                hc = Convert.ToInt32(it.ChargeStatus),
                hst=Convert.ToSingle(client?.BatteryPackDataVoltage?.CellTemperatureMax),
                hsv = Convert.ToSingle(client?.BatteryPackDataVoltage?.CellVoltageMax),
                lst = Convert.ToSingle(client?.BatteryPackDataVoltage?.CellTemperatureMin),
                lsv = Convert.ToSingle(client?.BatteryPackDataVoltage?.CellVoltageMin),
                soc = Convert.ToSingle(it.Soc),
                soe = Convert.ToSingle(it.Soe),
                soh = Convert.ToSingle(it.Soh)
            };
            return batInfo;
        }).ToList();
        BatDataInfo batDataInfo = new BatDataInfo
        {
            batn = batInfos.Count,
            sn = StaticStationInfo.StationNo,
            datainfo = batInfos
        };

        try
        {
            Log.Info("start BatteryInfoUploadTask send redis");
            RedisHelper.PublishAsync("BatteryInfoUploadTask", JsonConvert.SerializeObject(batDataInfo));
        }
        catch (Exception e)
        {
            Log.Info($"BatteryInfoUploadTask send redis error{e}");
        }
    }

    public bool Stoped()
    {
        return _stop;
    }

    public void Stop()
    {
        _stop = true;
    }

    public void ResetStop()
    {
        _stop = false;
    }
}