nhet_cn_back_main/Service/Execute/Step/DoSwappingState.cs

using Autofac;
using Entity.Attr;
using Entity.Constant;
using HybirdFrameworkCore.Autofac;
using log4net;
using Repository.Station;
using Service.Execute.Api;
using Service.Execute.Model;
using Service.Execute.Model.Tbox;
using Service.Execute.StaticTools;
using Service.Execute.SwapException;
using Service.Execute.Utils;
using Service.Init;
using Service.Station;

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 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);


        //再次读锁止状态，防止plc需要挪车
        InvokeStatus carInPosition2 = CarInPosition2(machine);
        if (carInPosition2 != InvokeStatus.Done)
        {
            return SwappingStateMachine.ReturnWithInvokeErr(carInPosition2, ExceptionReason.None);
        }


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

        InvokeStatus holdOn = HoldOn(machine);
        if (holdOn != InvokeStatus.Done)
        {
            return SwappingStateMachine.ReturnWithInvokeErr(holdOn, ExceptionReason.None);
        }


        //查看通道状态
        StateResult checkChannelStatus = CheckChannelStatus(machine);
        if (checkChannelStatus != null)
        {
            return checkChannelStatus;
        }

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

        //旧电池搬运
        InvokeStatus oldBatteryCarryIn = OldBatteryCarryIn(machine);
        if (oldBatteryCarryIn != InvokeStatus.Done)
        {
            return SwappingStateMachine.ReturnWithInvokeErr(oldBatteryCarryIn, ExceptionReason.None);
        }

        //新电池搬运
        InvokeStatus newBatteryCarryOut = NewBatteryCarryOut(machine);
        if (newBatteryCarryOut != InvokeStatus.Done)
        {
            return SwappingStateMachine.ReturnWithInvokeErr(newBatteryCarryOut, 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);
        }


        //航车回归安全位置
        InvokeStatus toInvokeStatus = ToSafePosition(machine);
        if (toInvokeStatus != InvokeStatus.Done)
        {
            return SwappingStateMachine.ReturnWithInvokeErr(toInvokeStatus, ExceptionReason.None);
        }


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

    /// <summary>
    /// 下发plc启动换电
    /// </summary>
    /// <returns></returns>
    public InvokeStatus StartSwapping(SwappingStateMachine machine)
    {
        return Invoker.Invoke("UnLockCar", 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);

                    //查詢當前任務狀態是否被更改
                    var readPlcTaskStatus = PlcApi.ReadTaskStatus(1);
                    if (startSwapping && readPlcTaskStatus)
                    {
                        machine.SwapOrder.SwapBeginTime = DateTime.Now;
                        _CommonMgr.UpdateSwapOrder(machine);
                        machine.SwapStatus = 0;
                        machine.StartSwappingFlag = true;
                        _CommonMgr.InsertStep(InfoEnum.BusinessSwappingStep.StartSwappingFlag,
                            machine);
                    }
                }
            }, () =>
            {
             SoundApi.PlayOneSound((int)InfoEnum.SwapInfo.ErrStartSwap);   
            },false, () => { },10,InvokeStatus.None);
    }


    /// <summary>
    /// plc读任务状态 上使能
    /// </summary>
    /// <param name="machine"></param>
    /// <returns></returns>
    public InvokeStatus HoldOn(SwappingStateMachine machine)
    {
        return Invoker.Invoke("plc HoldOn", 1000, 5, machine.IsCanceled,
            () => machine.PlcHoldFlag, () =>
            {
                //查询车辆锁止状态
                var taskPrepare = PlcApi.ReadTaskStatus(1);
                if (taskPrepare)
                {
                    bool holdOn = PlcApi.HoldOn();
                    if (holdOn)
                    {
                        SoundApi.PlayOneSound((int)InfoEnum.SwapInfo.StartSwapInfo);
                        machine.PlcHoldFlag = true;
                    }
                }
            }, () => { });
    }


    /// <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());


                int status = PlcApi.ReadPlcTaskStatus();
                //处理程序太快，plc还没有初始值的状态
                if (status == 1002 || status != 1003)
                {
                }
                else
                {
                    machine.UnOldBatteryFlag = true;
                }

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

    public InvokeStatus OldBatteryCarryIn(SwappingStateMachine machine)
    {
        return Invoker.Invoke("plc OldBatteryCarryIn", 500, 5, machine.IsCanceled,
            () => machine.StorageOldBatteryFlag, () =>
            {
                //  machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.InfoOldBatteryCarryIn.GetLed());
                var readPlcTaskStatus = PlcApi.ReadPlcTaskStatus();

                if (readPlcTaskStatus == 1003 || readPlcTaskStatus != 1004)
                {
                }
                else
                {
                    machine.StorageOldBatteryFlag = true;
                }

                machine.StorageOldBatteryFlag = readPlcTaskStatus == 1004;

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

    public InvokeStatus NewBatteryCarryOut(SwappingStateMachine machine)
    {
        return Invoker.Invoke("plc NewBatteryCarryOut", 500, 5, machine.IsCanceled,
            () => machine.OutNewBatteryFlag, () =>
            {
                // machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.InfoNewBatteryCarryOut.GetLed());

                if (PlcApi.ReadPlcTaskStatus() == 1004)
                {
                    
                }
                else
                {
                    machine.OutNewBatteryFlag = true;
                }

                if (machine.OutNewBatteryFlag)
                {
                    _CommonMgr.InsertStep(InfoEnum.BusinessSwappingStep.OutNewBatteryFlag,
                        machine);
                }
            }, () => { SoundApi.PlayOneSound((int)InfoEnum.SwapInfo.InfoNewBatteryCarryOut);}, 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());
                if (PlcApi.ReadPlcTaskStatus() == 1005)
                {
                   
                }
                else
                {
                    machine.InstallNewBatteryFlag = true;
                }

                if (machine.InstallNewBatteryFlag)
                {
                    _CommonMgr.InsertStep(InfoEnum.BusinessSwappingStep.InstallNewBatteryFlag,
                        machine);
                }
            }, () =>
            {
                SoundApi.PlayOneSound((int)InfoEnum.SwapInfo.InfoPack);
            },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());
                var readPlcTaskStatus = PlcApi.ReadPlcTaskStatus();
                if (readPlcTaskStatus == 1006 || readPlcTaskStatus == 1007)
                {
                    machine.FinishNewBatteryFlag = true;
                    machine.BusinessSwappingForCloudState =
                        InfoEnum.BusinessSwappingForCloudState.SwapFinish;
                    //  CloudApi.SendStateLog(machine.SwapOrder, machine.BusinessSwappingForCloudState);
                    machine.BusinessSwappingStateUpdateTime = DateTime.Now;
                    SoundApi.PlayOneSound((int)InfoEnum.SwapInfo.InfoPackFinish);

                    _CommonMgr.InsertStep(InfoEnum.BusinessSwappingStep.FinishNewBatteryFlag,
                        machine);
                }
            }, () => { },false, () => { },
            10,InvokeStatus.None);
    }

    /// <summary>
    /// 行车回归安全位置
    /// </summary>
    /// <param name="machine"></param>
    /// <returns></returns>
    public InvokeStatus ToSafePosition(SwappingStateMachine machine)
    {
        return Invoker.Invoke("plc ToSavePosition", 500, 5, machine.IsCanceled,
            () => machine.ToSafePositionFlag, () =>
            {
                //  machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.InfoPackFinish.GetLed());
              
                if (PlcApi.ReadPlcTaskStatus() == 1007)
                {
                    SoundApi.PlayOneSound((int)InfoEnum.SwapInfo.InfoToSafePosition);
                    machine.ToSafePositionFlag = true;
                    machine.BusinessSwappingStateUpdateTime = DateTime.Now;

                    machine.SwapStatus = 1;
                }
            }, () => { });
    }


    /// <summary>
    /// 查看通道状态
    /// :0：无效值
    /// 1000;拍照OK
    ///1010;拍照NG
    ///1020;拍照超限，请移车
    /// </summary>
    /// <returns></returns>
    public StateResult CheckChannelStatus(SwappingStateMachine machine)
    {
        int count = 0;
        while (!machine.ChannelStatusOkFlag)
        {
            
            if (machine.CancelFlag)
            {
                _log.Info($" CheckChannelStatus canceled");
                return  StateResult.Cancel;
            }
            
            _log.Info("begin plc CheckChannelStatus");
            Thread.Sleep(2000);
            var channelStatus = PlcApi.ChannelStatus();
            if (count % 10 == 0)
            {
                SoundApi.PlayOneSound((int)InfoEnum.SwapInfo.CarTakePhotoInfo);
            }

            count++;

            if (channelStatus == 1000)
            {
                machine.ChannelStatusOkFlag = true;
                return null;
            }
            else if (channelStatus == 1020)
            {
                //需要移车 先解锁  提示移动车辆,等待3分钟
                var lockCar = TBoxApi.LockCarManyTimes(machine.RfidReadModel.VelVin);
                if (lockCar.Result)
                {
                    // machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.ErrChannelStatus.GetLed());
                    SoundApi.PlayOneSound((int)InfoEnum.SwapInfo.ErrChannelStatus);
                    //等待2分钟
                    Thread.Sleep(3*60 *1000);
                    machine.VehiclesInPlace2Flag = false;
                    machine.StartSwappingFlag = false;
                    machine.PlcHoldFlag = false;
                    machine.ChannelStatusOkFlag = false;
                    //回归到本阶段的读锁止状态
                    return new StateResult()
                    {
                        SwappingState = SwappingState.DoSwapping
                    };
                }
            }
            else if (channelStatus == 1010)
            {
                //故障 不能继续换电，提示驶离,上报云平台，修改换电订单
                machine.SwapStatus = (int)InfoEnum.SwapOrderResult.Fail;
                machine.SwapFailReason = "拍照故障 plc故障码1010";
                //跳转到SwappDone
                return new StateResult()
                {
                    SwappingState = SwappingState.SwapDone
                };
            }
        }

        return null;
    }


    /// <summary>
    /// 车辆到位
    /// </summary>
    /// <returns></returns>
    public InvokeStatus CarInPosition2(SwappingStateMachine machine)
    {
        return Invoker.Invoke("check CarInPosition2", 500, 50, machine.IsCanceled,
            () => machine.VehiclesInPlace2Flag, () =>
            {
                var result = TBoxApi.GetCarInfo(machine.RfidReadModel.VelVin);
                TboxCarInfoModel tboxCarInfoModel = result.Result;

                int succCount = 0;
                List<bool> succL = new List<bool>()
                {
                    StaticStationInfo.TboxStateFlameout, StaticStationInfo.TboxStateBreak, StaticStationInfo.TboxStateN
                };
                var successCount = succL.Where(i => i).Count();

                var status = tboxCarInfoModel?.CarStatus;

                if (StaticStationInfo.TboxStateFlameout)
                {
                    if (status?.Keys == 0)
                    {
                        succCount++;
                    }
                }

                if (StaticStationInfo.TboxStateBreak)
                {
                    if (status?.Break == 1)
                    {
                        succCount++;
                    }
                }

                if (StaticStationInfo.TboxStateN)
                {
                    if (status?.Gear == 0)
                    {
                        succCount++;
                    }
                }
                
                if (succCount==successCount)
                {
                    machine.VehiclesInPlace2Flag = true;
                }
            }, () =>
            {
                machine.ExceptionReason = ExceptionReason.CarInPositionError;
                //   machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.ErrorCarInPositionTimeout.GetLed());
                SoundApi.PlayOneSound((int)InfoEnum.SwapInfo.ErrorCarInPositionTimeout);
            }, false, () => { }
            , 20, InvokeStatus.None);
    }
}