eaxing_back_africa_main/Service/Execute/Step/DoSwappingState.cs

using Autofac;
using Entity.Attr;
using Entity.Constant;
using HybirdFrameworkCore.Autofac;
using HybirdFrameworkCore.Configuration;
using log4net;
using Service.Charger.Client;
using Service.Execute.Api;
using Service.Execute.Model.Tbox;
using Service.Execute.SwapException;
using Service.Execute.Utils;
using Service.Init;
using Service.Led;
using Service.Sound.SoundClient;

namespace Service.Execute.Step;

public class DoSwappingState : IState
{
    private readonly ILog _log = LogManager.GetLogger(typeof(DoSwappingState));
    private readonly CommonMgr _CommonMgr = AppInfo.Container.Resolve<CommonMgr>();



    public static SoundClient? SoundClient { get; set; }


    public StateResult Handle(SwappingStateMachine machine)
    {
        //上报云平台换电开始
        machine.BusinessSwappingForCloudState = InfoEnum.BusinessSwappingForCloudState.BeginSwap;
        machine.BusinessSwappingStateUpdateTime = DateTime.Now;
        _log.Info($"BusinessSwappingForCloudState={machine.BusinessSwappingForCloudState}");
        //   CloudApi.SendStateLog(machine.SwapOrder, InfoEnum.BusinessSwappingForCloudState.BeginSwap);




        //下发启动换电
        InvokeStatus startSwapping = StartSwapping(machine);
        if (startSwapping != InvokeStatus.Done)
        {
            
            return SwappingStateMachine.ReturnWithInvokeErr(startSwapping, ExceptionReason.None);
        }



        //旧电池拆卸
        InvokeStatus unPack = UnPack(machine);
        if (unPack != InvokeStatus.Done)
        {
            return SwappingStateMachine.ReturnWithInvokeErr(unPack, ExceptionReason.None);
        }



        //安装
        InvokeStatus pack = Pack(machine);
        if (pack != InvokeStatus.Done)
        {
            return SwappingStateMachine.ReturnWithInvokeErr(pack, ExceptionReason.None);
        }
        //安装完成
        InvokeStatus packFinish = PackFinish(machine);
        if (packFinish != InvokeStatus.Done)
        {
            return SwappingStateMachine.ReturnWithInvokeErr(packFinish, ExceptionReason.None);
        }




        return new StateResult()
        {
            SwappingState = SwappingState.SwapDone
        };
    }

    /// <summary>
    /// 下发plc启动换电
    /// </summary>
    /// <returns></returns>
    public InvokeStatus StartSwapping(SwappingStateMachine machine)
    {
        return Invoker.Invoke("StartSwapping", 1000, 5, machine.IsCanceled,
            () => machine.StartSwappingFlag, () =>
            {
                Task<bool> result = TBoxApi.UnLockCarManyTimes(machine.RfidReadModel.VelVin);
                bool unLock = result.Result;
                if (unLock)
                {
                    var startSwapping = PlcApi.StartSwapping(machine.SwapOrderBatteryInfo.InBinInfo.No,
                        machine.SwapOrderBatteryInfo.UpBinInfo.No);

                    //查詢當前任務狀態是否被更改
                    if (startSwapping)
                    {
                        machine.SwapOrder.SwapBeginTime = DateTime.Now;
                        _CommonMgr.UpdateSwapOrder(machine);
                        machine.SwapStatus = 0;
                        machine.StartSwappingFlag = true;
                        _CommonMgr.InsertStep(InfoEnum.BusinessSwappingStep.StartSwappingFlag,
                            machine);
                    }
                }
            }, () =>
            {
                SoundClient = AppInfo.Container.Resolve<SoundClient>();
                SoundClient.SoundPlay(AppSettingsHelper.GetContent("SoundAddr", "Address30"));
                //SoundApi.PlayOneSound((int)InfoEnum.SwapInfo.ErrStartSwap);
                SoundClient = AppInfo.Container.Resolve<SoundClient>();
                SoundClient.SoundPlay(AppSettingsHelper.GetContent("SoundAddr", "Address01"));
                LedClient.SendMsgByKey(InfoEnum.SwapInfo.ErrStartSwap.GetLed());
            },false, () => { },10,InvokeStatus.None);
    }

    /// <summary>
    /// 读取plc任务状态电池拆卸中
    /// 读取plc任务状态电池入库搬运中
    ///   读取plc任务状态电池出库搬运中
    /// 读取plc任务状态电池安装中
    ///  读取plc任务状态电池安装完成
    /// </summary>
    /// <returns></returns>
    public InvokeStatus UnPack(SwappingStateMachine machine)
    {
        return Invoker.Invoke("plc UnPack", 500, 5, machine.IsCanceled,
            () => machine.UnOldBatteryFlag, () =>
            {
                //   machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.InfoUnPack.GetLed());

                LedClient.SendMsgByKey(InfoEnum.SwapInfo.InfoUnPack.GetLed());
                SoundClient = AppInfo.Container.Resolve<SoundClient>();
                SoundClient.SoundPlay(AppSettingsHelper.GetContent("SoundAddr", "Address11"));
                machine.UnOldBatteryFlag = ClientMgr.PlcClient.DisassembleDone;

                if (machine.UnOldBatteryFlag)
                {
                    _CommonMgr.InsertStep(InfoEnum.BusinessSwappingStep.UnOldBatteryFlag,
                        machine);
                }
            }, () => { SoundApi.PlayOneSound((int)InfoEnum.SwapInfo.InfoUnPack); }, false, () => { }, 10,
            InvokeStatus.None);
    }

    public InvokeStatus Pack(SwappingStateMachine machine)
    {
        return Invoker.Invoke("plc Pack ing", 500, 5, machine.IsCanceled,
            () => machine.InstallNewBatteryFlag, () =>
            {
                // machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.InfoPack.GetLed());
                LedClient.SendMsgByKey(InfoEnum.SwapInfo.InfoPack.GetLed());

                machine.InstallNewBatteryFlag = ClientMgr.PlcClient.SwapDone;

                if (machine.InstallNewBatteryFlag)
                {
                    _CommonMgr.InsertStep(InfoEnum.BusinessSwappingStep.InstallNewBatteryFlag,
                        machine);
                }
            }, () =>
            {
                //SoundApi.PlayOneSound((int)InfoEnum.SwapInfo.InfoPack);
                SoundClient = AppInfo.Container.Resolve<SoundClient>();
                SoundClient.SoundPlay(AppSettingsHelper.GetContent("SoundAddr", "Address12"));
                LedClient.SendMsgByKey(InfoEnum.SwapInfo.InfoPack.GetLed());
            },false, () => { },
            10,InvokeStatus.None);
    }

    public InvokeStatus PackFinish(SwappingStateMachine machine)
    {
        return Invoker.Invoke("plc Pack Finish", 500, 5, machine.IsCanceled,
            () => machine.FinishNewBatteryFlag, () =>
            {
                //  machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.InfoPackFinish.GetLed());
                if (ClientMgr.PlcClient.SwapDone)
                {
                    machine.FinishNewBatteryFlag = true;
                    machine.BusinessSwappingForCloudState =
                        InfoEnum.BusinessSwappingForCloudState.SwapFinish;
                    //  CloudApi.SendStateLog(machine.SwapOrder, machine.BusinessSwappingForCloudState);
                    machine.BusinessSwappingStateUpdateTime = DateTime.Now;
                    //SoundApi.PlayOneSound((int)InfoEnum.SwapInfo.InfoPackFinish);
                    SoundClient = AppInfo.Container.Resolve<SoundClient>();
                    SoundClient.SoundPlay(AppSettingsHelper.GetContent("SoundAddr", "Address13"));
                    LedClient.SendMsgByKey(InfoEnum.SwapInfo.InfoPackFinish.GetLed());

                    _CommonMgr.InsertStep(InfoEnum.BusinessSwappingStep.FinishNewBatteryFlag,
                        machine);
                    //SoundApi.PlayOneSound((int)InfoEnum.SwapInfo.InfoToSafePosition);
                    machine.ToSafePositionFlag = true;
                    machine.BusinessSwappingStateUpdateTime = DateTime.Now;

                    machine.SwapStatus = 1;
                }
            }, () => { },false, () => { },
            10,InvokeStatus.None);
    }
}