eaxing_back_africa_main/Service/MyTask/UpdateDownBatteryInfoTask.cs

using Entity.DbModel.Station;
using HybirdFrameworkCore.Autofac.Attribute;
using HybirdFrameworkCore.AutoTask;
using log4net;
using Newtonsoft.Json;
using Repository.Station;
using Service.Mgr;

namespace Service.MyTask;

/// <summary>
/// 更新换下的电池编码和soc
/// </summary>
[Scope]
public class UpdateDownBatteryInfoTask : ITask
{
    private static readonly ILog Log = LogManager.GetLogger(typeof(UpdateDownBatteryInfoTask));

    private volatile bool _stop;
    

    public SwapOrderBatteryRepository _swapOrderBatteryRepository { get; set; }

    public BinInfoRepository _BinInfoRepository { get; set; }

    public string Name()
    {
        return "UpdateDownBatteryInfoTask";
    }

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

    public void Handle()
    {
        Log.Info("Begin UpdateDownBatteryInfo");
        try
        {
            var listSwapOrderBattery =
                _swapOrderBatteryRepository.QueryListByClause(i => i.DownBatteryNo == "-1" && i.DownBatterySoc == -1);
            if (listSwapOrderBattery.Count > 0)
            {
                Log.Info("listSwapOrderBattery.Count > 0");
                var UpSwapOrderBattery = listSwapOrderBattery[listSwapOrderBattery.Count - 1];
                var lstBinInfo = _BinInfoRepository.QueryByClause(i => i.Exists == 1
                                                                       && i.No == UpSwapOrderBattery.DownBatteryBinNo
                                                                           .ToString()
                                                                       && i.Soc > 0
                                                                       && !string.IsNullOrEmpty(i.BatteryNo)
                                                                       && i.BatteryNo != "-1");
                if (lstBinInfo != null)
                {
                    _swapOrderBatteryRepository.Update(i => new SwapOrderBattery()
                        {
                            DownBatterySoc = lstBinInfo.Soc,
                            DownNominalEnergy = lstBinInfo.NominalEnergy,
                            DownBatteryNo = lstBinInfo.BatteryNo
                        },
                        i => i.SwapOrderSn.ToString() == UpSwapOrderBattery.SwapOrderSn
                             && i.DownBatteryBinNo == UpSwapOrderBattery.DownBatteryBinNo);
                    Log.Info($"update DownBatteryBinNo SwapOrderSn:{UpSwapOrderBattery.SwapOrderSn} soc:{lstBinInfo.Soc} DownBatteryNo:{lstBinInfo.BatteryNo}");
                }
            }
        }
        catch (Exception e)
        {
        }


        /*try
        {
            List<SwapOrderBattery> batterys =
                _swapOrderBatteryRepository.QueryListByClause(
                    i => (i.DownBatteryNo == null || i.DownBatterySoc<0) &&  i.DownBatteryBinNo != null);


            if (batterys.Count <= 0)
            {
                return;
            }


            List<string> downBatteryBinNos = batterys.Select(i => i.DownBatteryBinNo.ToString()).ToList();
            Dictionary<string, BinInfo> binInfosMap = _BinInfoRepository
                .QueryListByClause(i => downBatteryBinNos.Contains(i.No) && i.Exists==1).ToDictionary(i => i.No);

            List<SwapOrderBattery> updateDbBattery = new List<SwapOrderBattery>();

            foreach (var battery in batterys)
            {
                //更新换下电池包
                binInfosMap.TryGetValue(battery.DownBatteryBinNo.ToString(), out BinInfo info);

                if (info.BatteryNo == null || info.BatteryNo == "" || info.BatteryNo == "-1")
                {
                    continue;
                }
                if (info.Soc == null || info.Soc <=0)
                {
                    continue;
                }

                /*if (!info.BatteryNo.Equals(battery.DownBatteryNo))
                {
                    continue;
                }#1#
                battery.DownBatteryNo = info.BatteryNo;
                battery.DownBatterySoc = info.Soc;
                battery.DownBatterySoe = info.Soe;
                updateDbBattery.Add(battery);
            }

            if (updateDbBattery.Count > 0)
            {
                Log.Info(
                    $" UpdateDownBatteryInfoTask update DowmBatteryInfo db={JsonConvert.SerializeObject(updateDbBattery)}");
                _swapOrderBatteryRepository.Update(updateDbBattery);
            }
        }
        catch (Exception e)
        {
            Log.Error($" UpdateDownBatteryInfoTask err e={e}");
        }*/
    }

    public bool Stoped()
    {
        return _stop;
    }

    public void Stop()
    {
        _stop = true;
    }

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