hn_zw_back_main/Service/Cloud/Client/MyTask/ChargeOrderUploadTask.cs

using Entity.DbModel.Station;
using HybirdFrameworkCore.Autofac.Attribute;
using HybirdFrameworkCore.AutoTask;
using log4net;
using Repository.Station;

namespace Service.Cloud.Client.MyTask;

[Scope]
public class ChargeOrderUploadTask : ITask
{
    private static readonly ILog Log = LogManager.GetLogger(typeof(ChargeOrderUploadTask));

    private volatile bool _stop;

    public ChargeOrderRepository _chargeOrderRepository { get; set; }
    public SwapOrderRepository _swapOrder { get; set; }

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

    public void Handle()
    {
        try
        {
            //这里最多上报3次，然后只能手动上报
            List<ChargeOrder>? chargeOrders =
                _chargeOrderRepository.QueryListByClause(it => Convert.ToInt32(it.CloudReportStatus) == 0 
                    && Convert.ToInt32(it.CanUpload) == 1&&it.CmdStatus==1&&it.ReportingTimes<3);

            Log.Info($"there are {chargeOrders?.Count ?? 0} to upload");
            if (chargeOrders is { Count: > 0 })
            {
                Dictionary<string,List<ChargeOrder>> dictionary = chargeOrders.GroupBy(it => it.CloudChargeOrder).ToDictionary(i => i.Key, i=> i.ToList());
                foreach (var (k, v) in dictionary)
                {
                    CloudClientMgr.CloudClient?.PublishChargeOrder(v, 1);
                    
                    v.ForEach(obj => obj.ReportingTimes++);
                    _chargeOrderRepository.Update(v);
                }
            }
        }
        catch (Exception e)
        {
            Log.Error(e);
        }
    }

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

    public bool Stoped()
    {
        return _stop;
    }

    public void Stop()
    {
        _stop = true;
    }

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