CyberX8/CyberX8_RT/Schedulers/Rinse/SchedulerRinse.cs

using Aitex.Common.Util;
using Aitex.Core.RT.Fsm;
using Aitex.Core.RT.Log;
using Aitex.Core.Util;
using CyberX8_Core;
using CyberX8_RT.Dispatch;
using CyberX8_RT.Modules;
using CyberX8_RT.Modules.Dryer;
using CyberX8_RT.Modules.Loader;
using CyberX8_RT.Modules.Prewet;
using CyberX8_RT.Modules.Rinse;
using CyberX8_RT.Schedulers.Transporter;
using MECF.Framework.Common.CommonData;
using MECF.Framework.Common.Equipment;
using MECF.Framework.Common.RecipeCenter;
using MECF.Framework.Common.WaferHolder;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace CyberX8_RT.Schedulers.Rinse
{
    public class SchedulerRinse : SchedulerModule
    {
        #region 内部变量
        private RinseEntity _rinseEntity;
        private bool _isStartRunRecipe = false;
        #endregion

        #region 属性
        /// <summary>
        /// 是否空闲
        /// </summary>
        public override bool IsIdle
        {
            get { return _state == RState.End; }
        }
        /// <summary>
        /// 是否错误
        /// </summary>
        public override bool IsError
        {
            get { return _state == RState.Failed || _state == RState.Timeout; }
        }
        #endregion

        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="module"></param>
        public SchedulerRinse(ModuleName moduleName) : base(moduleName.ToString())
        {
            _rinseEntity = Singleton<RouteManager>.Instance.GetModule<RinseEntity>(moduleName.ToString());
        }
        /// <summary>
        /// 执行
        /// </summary>
        /// <param name="parameter"></param>
        /// <returns></returns>
        public override bool RunProcess(object recipe, object parameter, List<SchedulerSyncModuleMessage> syncModuleMessages)
        {
            if (!(recipe is QdrRecipe))
            {
                _state = RState.Failed;
                LOG.WriteLog(eEvent.ERR_RINSE, Module.ToString(), "recipe is invalid");
                return false;
            }
            _isStartRunRecipe = false;
            QdrRecipe qdrRecipe = (QdrRecipe)recipe;
            bool result = _rinseEntity.CheckToPostMessage<RinseState, RinseMsg>(eEvent.ERR_RINSE, Module.ToString(), (int)RinseMsg.RunRecipe, qdrRecipe,1);
            if (result)
            {
                _state = RState.Running;
            }
            return result;
        }
        /// <summary>
        /// 监控执行
        /// </summary>
        /// <returns></returns>
        public override bool MonitorProcess(SchedulerSequence schedulerSequence, bool hasMatchWafer)
        {
            if (!_isStartRunRecipe)
            {
                _isStartRunRecipe = _rinseEntity.State == (int)RinseState.RunReciping;
            }

            if (_rinseEntity.IsError)
            {
                _state = RState.Failed;
                _isStartRunRecipe = false;
            }

            if (_isStartRunRecipe && _rinseEntity.IsIdle)
            {
                _state = RState.End;
                _isStartRunRecipe = false;
            }
            if(_rinseEntity.State==(int)RinseState.RunRecipeComplete||_rinseEntity.State==(int)RinseState.KeepWeting)
            {
                if (schedulerSequence.NextModuleType != ModuleType.Metal)
                {
                    NotifyRinseComplete();
                }
                else
                {
                    if (SchedulerManager.Instance.IsQdrCheckConflict)
                    {
                        WaferHolderInfo waferHolderInfo = WaferHolderManager.Instance.GetWaferHolder(Module.ToString());
                        if (waferHolderInfo == null)
                        {
                            return true;
                        }
                        SchedulerSequence nextTransporterSequence = WaferHolderTaskManager.Instance.GetNextTransporterlSequence(schedulerSequence.SequenceIndex, waferHolderInfo.Id);
                        if (nextTransporterSequence == null)
                        {
                            return true;
                        }
                        if(!(nextTransporterSequence.Parameters is TransporterAction))
                        {
                            return true;
                        }
                        TransporterAction transporterAction=nextTransporterSequence.Parameters as TransporterAction;
                        WaferHolderMoveItem waferHolderMoveItem = transporterAction.Parameter as WaferHolderMoveItem;
                        if (waferHolderMoveItem.DestModule == ModuleName.Unknown)
                        {
                            WaferHolderTask waferHolderTask = WaferHolderTaskManager.Instance.GetWaferHolderTaskByWaferHolderId(waferHolderInfo.Id);
                            if (waferHolderTask == null)
                            {
                                return true;
                            }
                            bool result = SchedulerModuleTimeManager.Instance.ConfirmAllMetalQdrAndDryer(waferHolderTask.SchedulerSequences, waferHolderInfo.Id, waferHolderTask.GetCurrentSchedulerIndex(), true, DateTime.Now);
                            if (result)
                            {
                                NotifyRinseComplete();
                            }
                            return true;
                        }
                        if (WaferHolderManager.Instance.HasWaferHolder(waferHolderMoveItem.DestModule.ToString()))
                        {
                            NotifyRinseKeepWet();
                        }
                        else
                        {
                            NotifyRinseComplete();
                        }
                    }
                    else
                    {
                        bool exsitEnableCell = false;
                        DepRecipe depRecipe = schedulerSequence.NextRecipe as DepRecipe;
                        ModuleName moduleName = SchedulerSequenceManager.Instance.CalculateAvaibleMetalCellByChemistry(depRecipe.Chemistry,
                            Module.ToString(), schedulerSequence.SequenceType, schedulerSequence.WaferSize, ref exsitEnableCell);
                        if (moduleName != ModuleName.Unknown)
                        {
                            IModuleEntity moduleEntity = Singleton<RouteManager>.Instance.GetModule<IModuleEntity>(moduleName.ToString());
                            if (SchedulerSequenceManager.Instance.CheckMetalCellRecipeTimeAvaible(moduleEntity, depRecipe))
                            {
                                NotifyRinseComplete();
                            }
                            else
                            {
                                NotifyRinseKeepWet();
                            }
                        }
                        else
                        {
                            if (exsitEnableCell)
                            {
                                NotifyRinseKeepWet();
                            }
                            else
                            {
                                NotifyRinseComplete();
                            }
                        }
                    }
                }
            }
            return true;
        }
        /// <summary>
        /// 通知Rinse完成
        /// </summary>
        private void NotifyRinseComplete()
        {
            _rinseEntity.CheckToPostMessage<RinseState, RinseMsg>(eEvent.INFO_RINSE, Module.ToString(), (int)RinseMsg.RecipeComplete);
        }

        /// <summary>
        /// 通知Rinse准备Keep Wet
        /// </summary>
        private void NotifyRinseKeepWet()
        {
            if (_rinseEntity.State == (int)RinseState.KeepWeting)
            {
                return;
            }
            _rinseEntity.CheckToPostMessage<RinseState, RinseMsg>(eEvent.WARN_PREWET, Module.ToString(),
                (int)RinseMsg.Keepwet);
        }

        /// <summary>
        /// 检验前置条件
        /// </summary>
        /// <param name="sequenceIndex"></param>
        /// <param name="parameter"></param>
        /// <returns></returns>
        public override bool CheckPrecondition(List<SchedulerSequence> schedulerSequences, int sequenceIndex, object parameter, string materialId,ref string reason)
        {
            if (_state == RState.Running)
            {
                reason = "scheduler module is already running";
                return false;
            }
            if (_rinseEntity.IsBusy)
            {
                reason = $"{_rinseEntity.Module} is busy";
                return false;
            }
            if(_rinseEntity.WaferHolderInfo==null)
            {
                reason = $"{_rinseEntity.Module} has no wafer shuttle";
                return false;
            }

            if (_rinseEntity.WaferHolderInfo.Id != materialId)
            {
                reason = $"{_rinseEntity.Module} wafer shuttle {_rinseEntity.WaferHolderInfo.Id} is not matched with {materialId}";
                return false;
            }
            return true;
        }
    }
}