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.StaticTools; using Service.Execute.SwapException; using Service.Station; namespace Service.Execute.Step; public class DoSwappingState : IState { private readonly ILog _log = LogManager.GetLogger(typeof(DoSwappingState)); private readonly SwapOrderRepository _swapOrderRepository = AppInfo.Container.Resolve(); private readonly SwapOrderStepService _swapOrderStepService = AppInfo.Container.Resolve(); 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); } //查看通道状态 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); } return new StateResult() { SwappingState = SwappingState.SwapDone }; } /// /// 下发plc启动换电 /// /// public InvokeStatus StartSwapping(SwappingStateMachine machine) { return Invoker.Invoke("UnLockCar", 1000, 5, machine.IsCanceled, () => machine.StartSwappingFlag, () => { Task result = TBoxApi.UnLockCar(); bool unLock = result.Result; if (unLock) { //查询车辆锁止状态 var startSwapping = PlcApi.StartSwapping(); if (startSwapping) { machine.SwapOrder.SwapBeginTime = DateTime.Now; _swapOrderRepository.Update(machine.SwapOrder); machine.SwapStatus = 0; machine.StartSwappingFlag = true; _swapOrderStepService.InsertSwapStepForSwapMain(InfoEnum.BusinessSwappingStep.StartSwappingFlag, machine.StepSort++, machine.SwapOrder.Sn); } } }, () => { }); } /// /// 读取plc任务状态电池拆卸中 /// 读取plc任务状态电池入库搬运中 /// 读取plc任务状态电池出库搬运中 /// 读取plc任务状态电池安装中 /// 读取plc任务状态电池安装完成 /// /// public InvokeStatus UnPack(SwappingStateMachine machine) { return Invoker.Invoke("plc UnPack", 500, 5, machine.IsCanceled, () => machine.UnOldBatteryFlag, () => { machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.InfoUnPack.GetLed()); SoundTool.PlayOneSound((int)InfoEnum.SwapInfo.InfoUnPack); machine.UnOldBatteryFlag = PlcApi.ReadPlcTaskStatus() == 1002; if (machine.UnOldBatteryFlag) { _swapOrderStepService.InsertSwapStepForSwapMain(InfoEnum.BusinessSwappingStep.UnOldBatteryFlag, machine.StepSort++, machine.SwapOrder.Sn); } }, () => { }); } public InvokeStatus OldBatteryCarryIn(SwappingStateMachine machine) { return Invoker.Invoke("plc OldBatteryCarryIn", 500, 5, machine.IsCanceled, () => machine.StorageOldBatteryFlag, () => { machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.InfoOldBatteryCarryIn.GetLed()); SoundTool.PlayOneSound((int)InfoEnum.SwapInfo.InfoOldBatteryCarryIn); machine.StorageOldBatteryFlag = PlcApi.ReadPlcTaskStatus() == 1003; if (machine.StorageOldBatteryFlag) { _swapOrderStepService.InsertSwapStepForSwapMain(InfoEnum.BusinessSwappingStep.StorageOldBatteryFlag, machine.StepSort++, machine.SwapOrder.Sn); } }, () => { }); } public InvokeStatus NewBatteryCarryOut(SwappingStateMachine machine) { return Invoker.Invoke("plc NewBatteryCarryOut", 500, 5, machine.IsCanceled, () => machine.OutNewBatteryFlag, () => { machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.InfoNewBatteryCarryOut.GetLed()); SoundTool.PlayOneSound((int)InfoEnum.SwapInfo.InfoNewBatteryCarryOut); machine.OutNewBatteryFlag = PlcApi.ReadPlcTaskStatus() == 1004; if (machine.OutNewBatteryFlag) { _swapOrderStepService.InsertSwapStepForSwapMain(InfoEnum.BusinessSwappingStep.OutNewBatteryFlag, machine.StepSort++, machine.SwapOrder.Sn); } }, () => { }); } public InvokeStatus Pack(SwappingStateMachine machine) { return Invoker.Invoke("plc Pack ing", 500, 5, machine.IsCanceled, () => machine.InstallNewBatteryFlag, () => { machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.InfoPack.GetLed()); SoundTool.PlayOneSound((int)InfoEnum.SwapInfo.InfoPack); machine.InstallNewBatteryFlag = PlcApi.ReadPlcTaskStatus() == 1005; if (machine.InstallNewBatteryFlag) { _swapOrderStepService.InsertSwapStepForSwapMain(InfoEnum.BusinessSwappingStep.InstallNewBatteryFlag, machine.StepSort++, machine.SwapOrder.Sn); } }, () => { }); } public InvokeStatus PackFinish(SwappingStateMachine machine) { return Invoker.Invoke("plc Pack Finish", 500, 5, machine.IsCanceled, () => machine.FinishNewBatteryFlag, () => { machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.InfoPackFinish.GetLed()); SoundTool.PlayOneSound((int)InfoEnum.SwapInfo.InfoPackFinish); if (PlcApi.ReadPlcTaskStatus() == 1006) { machine.FinishNewBatteryFlag = true; machine.BusinessSwappingForCloudState = InfoEnum.BusinessSwappingForCloudState.SwapFinish; CloudApi.SendStateLog(machine.SwapOrder, machine.BusinessSwappingForCloudState); machine.BusinessSwappingStateUpdateTime = DateTime.Now; //上报云平台换电完成 machine.SwapStatus = 1; _swapOrderStepService.InsertSwapStepForSwapMain(InfoEnum.BusinessSwappingStep.FinishNewBatteryFlag, machine.StepSort++, machine.SwapOrder.Sn); } }, () => { }); } /// /// 查看通道状态 /// :0:无效值 /// 1000;拍照OK ///1010;拍照NG ///1020;拍照超限,请移车 /// /// public StateResult CheckChannelStatus(SwappingStateMachine machine) { while (!machine.ChannelStatusOkFlag) { _log.Info("begin plc CheckChannelStatus"); Thread.Sleep(1000); var channelStatus = PlcApi.ChannelStatus(); if (channelStatus == 1000) { machine.ChannelStatusOkFlag = true; return null; } else if (channelStatus == 1020) { //需要移车 先解锁 提示移动车辆,等待3分钟 var lockCar = TBoxApi.LockCar(); if (lockCar.Result) { machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.ErrChannelStatus.GetLed()); SoundTool.PlayOneSound((int)InfoEnum.SwapInfo.ErrChannelStatus); //等待3分钟 Thread.Sleep(3000); machine.VehiclesInPlace2Flag = false; machine.StartSwappingFlag = 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; } /// /// 车辆到位 /// /// public InvokeStatus CarInPosition2(SwappingStateMachine machine) { return Invoker.Invoke("check CarInPosition2", 500, 50, machine.IsCanceled, () => machine.VehiclesInPlace2Flag, () => { var result = TBoxApi.GetCarInfo(); TboxCarInfoModel tboxCarInfoModel = result.Result; if (tboxCarInfoModel.HeartBeatMsg.KeyStatus == 0) { machine.VehiclesInPlace2Flag = true; } }, () => { machine.ExceptionReason = ExceptionReason.CarInPositionError; machine.LedTool?.WriteProgramContent(InfoEnum.SwapInfo.ErrorCarInPositionTimeout.GetLed()); SoundTool.PlayOneSound((int)InfoEnum.SwapInfo.ErrorCarInPositionTimeout); }, false, () => { } , 20, InvokeStatus.None); } }