FurnaceELK/Furnace/FurnaceRT/Equipments/Boats/BoatMove.cs

using Aitex.Core.RT.Device;
using Aitex.Core.RT.Device.Unit;
using Aitex.Core.RT.Event;
using Aitex.Core.RT.Routine;
using Aitex.Core.RT.SCCore;
using Aitex.Core.Util;
using Aitex.Sorter.Common;
using MECF.Framework.Common.Alarms;
using MECF.Framework.Common.Device.Bases;
using MECF.Framework.Common.Equipment;
using MECF.Framework.Common.SubstrateTrackings;
using MECF.Framework.RT.EquipmentLibrary.HardwareUnits.Robot;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using FurnaceRT.Equipments.Systems;
using static Aitex.Core.RT.Device.Unit.IoBoat;
using System.Diagnostics;
using FurnaceRT.Devices;
using FurnaceRT.Equipments.PMs;
using MECF.Framework.Common.Tolerance;
using MECF.Framework.Common.CommonData.SorterDefines;
using MECF.Framework.RT.EquipmentLibrary.HardwareUnits.PMs;
using Aitex.Core.RT.Log;

namespace FurnaceRT.Equipments.Boats
{
    public class BoatMove : ModuleRoutine, IRoutine
    {
        enum RoutineStep
        {
            SetBoatSpeed,
            SetBoatDirection,
            BoatRAxisHome,
            BoatRAxisMove,
            SetBoatZAxisMoveStop,
            SetBoatRAxisMoveStop,
            SetBoatInterval,
            CheckPrepareMove,
            Load,
            Unload,
            Delay1,
            Delay2,
            Delay3,
            ZMoveToStart,
            ZMoveToEnd,
            ZMove,
            AutoShutterOpen,
            AutoShutterClose,
        }

        private BoatModule _boatModule;
        private int _zAxisTimeout = 0;
        private int _rAxisTimeout = 0;
        private int _shutterTimeout = 0;
        private string _command;
        private string _position;
        private float _speed;
        private FilterChecker _filterChecker = new FilterChecker();
        public BoatMove(BoatModule boatModule)
        {
            _boatModule = boatModule;
            Module = boatModule.Module;

            Name = "Move";
        }
        public void Init(string command, string position, string speed)
        {
            _command = command;
            _position = position;
            float.TryParse(speed, out _speed);

            var para = new List<object> { _command, _position, _speed };
            _boatModule.BoatZAxisMoveFailedForInterlock.RetryMessage = (int)BoatModule.MSG.BoatMoveRetry;
            _boatModule.BoatZAxisMoveFailedForInterlock.RetryMessageParas = para.ToArray();

            _boatModule.BoatZAxisMoveFailedForHumanInterlock.RetryMessage = (int)BoatModule.MSG.BoatMoveRetry;
            _boatModule.BoatZAxisMoveFailedForHumanInterlock.RetryMessageParas = para.ToArray();

            _boatModule.BoatZAxisMoveFailedForWaferRobotArmExtend.RetryMessage = (int)BoatModule.MSG.BoatMoveRetry;
            _boatModule.BoatZAxisMoveFailedForWaferRobotArmExtend.RetryMessageParas = para.ToArray();

            _boatModule.BoatZAxisMoveTimeOut.RetryMessage = (int)BoatModule.MSG.BoatMoveRetry;
            _boatModule.BoatZAxisMoveTimeOut.RetryMessageParas = para.ToArray();

            _boatModule.AutoShutterMoveFailedForInterlock.RetryMessage = (int)BoatModule.MSG.BoatMoveRetry;
            _boatModule.AutoShutterMoveFailedForInterlock.RetryMessageParas = para.ToArray();

            _boatModule.AutoShutterOpenTimeOut.RetryMessage = (int)BoatModule.MSG.BoatMoveRetry;
            _boatModule.AutoShutterOpenTimeOut.RetryMessageParas = para.ToArray();

            _boatModule.AutoShutterCloseTimeOut.RetryMessage = (int)BoatModule.MSG.BoatMoveRetry;
            _boatModule.AutoShutterCloseTimeOut.RetryMessageParas = para.ToArray();

            _boatModule.BoatRAxisMoveTimeOut.RetryMessage = (int)BoatModule.MSG.BoatMoveRetry;
            _boatModule.BoatRAxisMoveTimeOut.RetryMessageParas = para.ToArray();
        }

        public Result Start(params object[] objs)
        {
            Reset();
            _zAxisTimeout = SC.GetValue<int>($"{Module}.BoatElevatorServo.MotionTimeout");
            _rAxisTimeout = SC.GetValue<int>($"{Module}.BoatRotationServo.MotionTimeout");
            _shutterTimeout = SC.GetValue<int>($"{Module}.AutoShutter.MotionTimeout");
            var isBeforeShutter = new List<string>() { "boatload", "boatcap2", "boatunload", "boatloaderhome", };
            if (!string.IsNullOrEmpty(_command) && isBeforeShutter.Contains(_command))
            {
                string reason = "";
                if (!_boatModule.CheckPrepareMove(out reason, false))
                {
                    _boatModule.BoatZAxisMoveFailedForInterlock.Set(reason);
                    //return Result.FAIL;
                }

            }
            _filterChecker.CheckInterval = 1;

            Notify($"Start");
            return Result.RUN;
        }

        public void Abort()
        {
            if (_boatModule.CheckPrepareMove(out _, false))
            {
                _boatModule.ZAxisDevice.ServoStop();
                _boatModule.RAxisDevice.ServoStop();
            }
        }

        public override Result Monitor()
        {
            try
            {
                PauseRountine(_boatModule.RAxisDevice.IsPause);
                if (_boatModule.RAxisDevice.IsPause)
                    return Result.RUN;

                if (_boatModule.RAxisDevice.IsError || _boatModule.ZAxisDevice.IsError)
                    return Result.FAIL;

                switch (_command)
                {
                    case "boatload":
                    case "boatcap2":
                        AutoShutterOpen((int)RoutineStep.AutoShutterOpen, true, _shutterTimeout);

                        CheckBoatLoadO2Desity((int)RoutineStep.Load, _zAxisTimeout);

                        var position = (BoatPosition)Enum.Parse(typeof(BoatPosition), _position);

                        SetBoatZAxisMove((int)RoutineStep.ZMove, position, _speed, (int)_zAxisTimeout);
                        break;
                    case "boatunload":
                    case "boatloaderhome":
                        AutoShutterOpen((int)RoutineStep.AutoShutterOpen, true, _shutterTimeout);

                        CheckBoatUnLoadO2Desity((int)RoutineStep.Unload, _zAxisTimeout);

                        //CheckPrepareMove((int)RoutineStep.CheckPrepareMove, 2);

                        position = (BoatPosition)Enum.Parse(typeof(BoatPosition), _position);

                        SetBoatZAxisMove((int)RoutineStep.ZMove, position, _speed, (int)_zAxisTimeout);

                        AutoShutterOpen((int)RoutineStep.AutoShutterClose, false, _shutterTimeout);
                        break;
                    case "boatrotate":
                        var direction = (BoatRotationDirection)Enum.Parse(typeof(BoatRotationDirection), _position);
                        SetBoatRAxisMove((int)RoutineStep.BoatRAxisMove, direction, _speed, _rAxisTimeout);
                        break;
                    case "boatrotatestop"://r home
                        SetBoatRAxisMoveStop((int)RoutineStep.SetBoatRAxisMoveStop);

                        Delay((int)RoutineStep.Delay1, 2);

                        SetBoatRAxisHome((int)RoutineStep.BoatRAxisHome, _rAxisTimeout);
                        break;
                    case "stop(includer-axis)":
                        SetBoatZAxisMoveStop((int)RoutineStep.SetBoatZAxisMoveStop);

                        SetBoatRAxisMoveStop((int)RoutineStep.SetBoatRAxisMoveStop);
                        break;
                }
            }
            catch (RoutineBreakException)
            {
                return Result.RUN;
            }
            catch (RoutineFaildException ex)
            {
                //_boatModule.RAxisDevice.ServoStop();
                return Result.FAIL;
            }

            Notify("Finished");
            return Result.DONE;
        }
        private void CheckBoatUnLoadO2Desity(int id, int timeout)
        {
            var reason = "";
            Tuple<bool, Result> ret = ExecuteAndWait(id, () =>
            {
                Notify($"Check Boat UnLoad O2Desity");
                return true;
            }, () =>
            {
                var pm = (Singleton<EquipmentManager>.Instance.Modules[ModuleName.PM1] as PMModule);

                if (!pm.IsProcessing)
                {
                    LOG.Info($"boat Unload Check O2Desity,IsProcessing={pm.IsProcessing}");
                    return true;
                }
                var isCheckO2Enbale = pm.GetBoatUnLoadCheckO2DensityConfig();
                if (!isCheckO2Enbale)
                    return true;

                var o2LimtData = pm.GetBoatUnLoadLAO2CheckSV();
                _filterChecker.Monitor(pm.GetN2PurgeUnder20PPMStatus(o2LimtData));
                if (_filterChecker.Trig)
                {
                    pm.IsWait = false;
                    LOG.Info($"boat Check O2Desity,boatUnLoad TransferRoomO2DensityCheckEnable={isCheckO2Enbale},LA LimtData={o2LimtData},Wait BoatUnLoad。A");
                    _filterChecker.Restart();
                    return true;
                }
                pm.IsWait = true;
                return false; ;


            }, timeout * 1000);

            if (ret.Item1)
            {
                if (ret.Item2 == Result.FAIL)
                {
                    throw (new RoutineFaildException());
                }
                else if (ret.Item2 == Result.TIMEOUT) //timeout
                {
                    _boatModule.BoatZAxisMoveFailedForInterlock.Set($"CheckO2Desity timeout={timeout}");
                    throw (new RoutineFaildException());
                }
                else
                    throw (new RoutineBreakException());
            }
        }

        private void CheckBoatLoadO2Desity(int id, int timeout)
        {
            var reason = "";
            Tuple<bool, Result> ret = ExecuteAndWait(id, () =>
            {
                Notify($"Check O2");
                return true;
            }, () =>
            {
                var pm = (Singleton<EquipmentManager>.Instance.Modules[ModuleName.PM1] as PMModule);

                if (!pm.IsProcessing)
                {
                    LOG.Info($"boat load Check O2Desity,IsProcessing={pm.IsProcessing}");
                    return true;
                }

                var isCheckO2Enbale = pm.GetBoatLoadCheckO2DensityConfig();
                if (!isCheckO2Enbale)
                    return true;

                var o2LimtData = pm.GetBoatLoadLAO2CheckSV();
                _filterChecker.Monitor(pm.GetN2PurgeUnder20PPMStatus(o2LimtData));
                if (_filterChecker.Trig)
                {
                    pm.IsWait = false;
                    _filterChecker.Restart();
                    LOG.Info($"boat load Check O2Desity,boatLoad TransferRoomO2DensityCheckEnable={isCheckO2Enbale},LA LimtData={o2LimtData},Wait BoatLoad。A");
                    return true;
                }
             
                pm.IsWait = true;
                return false; ;


            }, timeout * 1000);

            if (ret.Item1)
            {
                if (ret.Item2 == Result.FAIL)
                {
                    throw (new RoutineFaildException());
                }
                else if (ret.Item2 == Result.TIMEOUT) //timeout
                {
                    _boatModule.BoatZAxisMoveFailedForInterlock.Set($"CheckO2Desity timeout={timeout}");
                    throw (new RoutineFaildException());
                }
                else
                    throw (new RoutineBreakException());
            }
        }

        private void CheckPrepareMove(int id, int timeout)
        {
            var reason = "";
            Tuple<bool, Result> ret = ExecuteAndWait(id, () =>
            {
                Notify($"Check boat move enable");
                return true;
            }, () =>
            {
                return _boatModule.CheckPrepareMove(out reason);
            }, timeout * 2 * 1000);

            if (ret.Item1)
            {
                if (ret.Item2 == Result.FAIL)
                {
                    throw (new RoutineFaildException());
                }
                else if (ret.Item2 == Result.TIMEOUT) //timeout
                {
                    _boatModule.BoatZAxisMoveFailedForInterlock.Set($"{reason} is not OK, can not complete in {timeout} seconds");
                    throw (new RoutineFaildException());
                }
                else
                    throw (new RoutineBreakException());
            }
        }
        private void AutoShutterOpen(int id, bool isOpen, int timeout)
        {
            Tuple<bool, Result> ret = ExecuteAndWait(id, () =>
            {
                Notify($"shutter {(isOpen ? "open" : "close")}");
                string reason;
                if (!_boatModule.ShutterDevice.SetOpen(isOpen, out reason))
                {
                    _boatModule.ShutterDevice.AutoShutterMoveFailedForInterlock.Set();
                    return false;
                }
                return true;
            }, () =>
            {

                return isOpen ? _boatModule.ShutterDevice.OpenCloseStatus == DeviceStatus.Open : _boatModule.ShutterDevice.OpenCloseStatus == DeviceStatus.Close;

            }, timeout * 1000);

            if (ret.Item1)
            {
                if (ret.Item2 == Result.FAIL)
                {
                    throw (new RoutineFaildException());
                }
                else if (ret.Item2 == Result.TIMEOUT) //timeout
                {
                    if (isOpen)
                    {
                        _boatModule.ShutterDevice.AutoShutterOpenTimeOut.Set($"can not complete in {timeout} seconds");
                    }
                    else
                    {
                        _boatModule.ShutterDevice.AutoShutterCloseTimeOut.Set($"can not complete in {timeout} seconds");
                    }
                    throw (new RoutineFaildException());
                }
                else
                    throw (new RoutineBreakException());
            }
        }
        private void SetBoatZAxisMove(int id, BoatPosition position, float speed, int timeout)
        {
            Tuple<bool, Result> ret = ExecuteAndWait(id, () =>
            {
                Notify($"Boat ZAxis movet to {position}");
                string reason;
                if (!_boatModule.ZAxisDevice.SetServoMoveTo(position.ToString(), out reason, speed))
                {
                    //_boatModule.BoatDevice.BoatRAxisMoveFailedForInterlock.Description = reason;
                    _boatModule.BoatZAxisMoveFailedForInterlock.Set(reason);
                }
                return true;
            }, () =>
            {
                if (_boatModule.ZAxisDevice.IsError)
                    return null;
                return _boatModule.ZAxisDevice.CheckServoAtPosition(position.ToString());
            }, timeout * 2 * 1000);

            if (ret.Item1)
            {
                if (ret.Item2 == Result.FAIL)
                {
                    _boatModule.ZAxisDevice.ServoStop();
                    throw (new RoutineFaildException());
                }
                else if (ret.Item2 == Result.TIMEOUT) //timeout
                {
                    _boatModule.ZAxisDevice.ServoStop();
                    _boatModule.BoatZAxisMoveTimeOut.Set($"can not complete in {timeout} seconds");
                    throw (new RoutineFaildException());
                }
                else
                    throw (new RoutineBreakException());
            }
        }
        private void SetBoatZAxisMoveStop(int id)
        {
            Tuple<bool, Result> ret = Execute(id, () =>
            {
                Notify($"Set ZAxis boat stop");

                _boatModule.ZAxisDevice.ServoStop();

                return true;
            });

            if (ret.Item1)
            {
                if (ret.Item2 == Result.FAIL)
                {
                    throw (new RoutineFaildException());
                }
                else
                    throw (new RoutineBreakException());
            }
        }
        private void SetBoatRAxisMoveStop(int id)
        {
            Tuple<bool, Result> ret = Execute(id, () =>
            {
                Notify($"Set RAxis boat stop");

                _boatModule.RAxisDevice.ServoStop();

                return true;
            });

            if (ret.Item1)
            {
                if (ret.Item2 == Result.FAIL)
                {
                    throw (new RoutineFaildException());
                }
                else
                    throw (new RoutineBreakException());
            }
        }

        private void SetBoatRAxisHome(int id, int timeout)
        {
            Tuple<bool, Result> ret = ExecuteAndWait(id, () =>
            {
                Notify($"Boat RAxis home");

                if (!_boatModule.RAxisDevice.SetServoHome())
                {
                    _boatModule.BoatRAxisHomeFailed.Set();
                }

                return true;
            }, () =>
            {
                if (_boatModule.RAxisDevice.IsError)
                    return null;
                return _boatModule.RAxisDevice.IsHomeDone && _boatModule.RAxisDevice.IsReady;

            }, timeout * 1000);

            if (ret.Item1)
            {
                if (ret.Item2 == Result.FAIL)
                {
                    _boatModule.RAxisDevice.ServoStop();
                    throw (new RoutineFaildException());
                }
                else if (ret.Item2 == Result.TIMEOUT) //timeout
                {
                    _boatModule.RAxisDevice.ServoStop();
                    _boatModule.BoatRAxisHomeTimeout.Set($"can not complete in {timeout} seconds");
                    throw (new RoutineFaildException());
                }
                else
                    throw (new RoutineBreakException());
            }
        }

        private void SetBoatRAxisMove(int id, BoatRotationDirection direction, float speed, int timeout)
        {
            Tuple<bool, Result> ret = ExecuteAndWait(id, () =>
            {
                Notify($"Boat RAxis {direction}");
                string reason;
                if (!_boatModule.RAxisDevice.SetServoMoveTo(direction.ToString(), out reason, speed))
                {
                    //_boatModule.BoatDevice.BoatRAxisMoveFailedForInterlock.Description = reason;
                    _boatModule.BoatRAxisMoveFailedForInterlock.Set(reason);
                }
                return true;
            }, () =>
            {
                if (_boatModule.RAxisDevice.IsError)
                    return null;
                return _boatModule.RAxisDevice.IsMoving;
            }, timeout * 2 * 1000);

            if (ret.Item1)
            {
                if (ret.Item2 == Result.FAIL)
                {
                    _boatModule.RAxisDevice.ServoStop();
                    throw (new RoutineFaildException());
                }
                else if (ret.Item2 == Result.TIMEOUT) //timeout
                {
                    _boatModule.RAxisDevice.ServoStop();
                    _boatModule.BoatRAxisMoveTimeOut.Set($"can not complete in {timeout} seconds");
                    throw (new RoutineFaildException());
                }
                else
                    throw (new RoutineBreakException());
            }
        }
    }
}