PunkHPX8/PunkHPX8_RT/Schedulers/VPW/SchedulerVPW.cs

using Aitex.Common.Util;
using Aitex.Core.Common;
using Aitex.Core.RT.Log;
using Aitex.Core.Util;
using PunkHPX8_Core;
using PunkHPX8_RT.Modules;
using PunkHPX8_RT.Modules.SRD;
using MECF.Framework.Common.Equipment;
using MECF.Framework.Common.RecipeCenter;
using MECF.Framework.Common.SubstrateTrackings;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using PunkHPX8_RT.Modules.VpwMain;
using PunkHPX8_RT.Modules.VpwCell;

namespace PunkHPX8_RT.Schedulers.Srd
{
    public class SchedulerVPW : SchedulerModule
    {
        #region 内部变量
        private VpwCellEntity _vpwEntity;
        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="moduleName"></param>
        public SchedulerVPW(ModuleName moduleName) : base(moduleName.ToString())
        {
            _vpwEntity = Singleton<RouteManager>.Instance.GetModule<VpwCellEntity>(moduleName.ToString());
        }
        /// <summary>
        /// 执行
        /// </summary>
        /// <param name="parameter"></param>
        /// <returns></returns>
        public override bool RunProcess(object recipe, object parameter, List<SchedulerSyncModuleMessage> syncModuleMessages)
        {
            if (!(recipe is VpwRecipe))
            {
                _state = RState.Failed;
                LOG.WriteLog(eEvent.ERR_SRD, Module.ToString(), "recipe is invalid");
                return false;
            }
            _isStartRunRecipe = false;
            VpwRecipe vpwRecipe = (VpwRecipe)recipe;
            bool result = _vpwEntity.CheckToPostMessage<VPWCellState, VPWCellMsg>(eEvent.INFO_VPW, Module.ToString(), (int)VPWCellMsg.RunRecipe, vpwRecipe, 1);
            if (result)
            {
                _state = RState.Running;
            }
            return result;
        }
        /// <summary>
        /// 监控执行
        /// </summary>
        /// <returns></returns>
        public override bool MonitorProcess(SchedulerSequence schedulerSequence,bool hasMatchWafer)
        {
            if (!_isStartRunRecipe)
            {
                _isStartRunRecipe = _vpwEntity.State == (int)VPWCellState.RunReciping;
            }
            if (_isStartRunRecipe)
            {
                VpwMainEntity vpwMainEntity = Singleton<RouteManager>.Instance.GetModule<VpwMainEntity>(ModuleName.VPWMain1.ToString());
                if (!_vpwEntity.IsIdle)
                {
                    return true;
                }
                if (vpwMainEntity.IsChamberClosed)
                {
                    vpwMainEntity.CheckToPostMessage<VPWCellState, VPWCellMsg>(eEvent.INFO_VPW, Module.ToString(), (int)VPWMainMsg.ChamberDown);
                }
                else
                {
                    if (vpwMainEntity.IsIdle)
                    {
                        _state = RState.End;
                        _isStartRunRecipe = false;
                    }
                }
            }
            return true;
        }
        /// <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 (_vpwEntity.IsBusy)
            {
                reason = $"{_vpwEntity.Module} is busy";
                return false;
            }

            if(WaferManager.Instance.CheckNoWafer(Module,0))
            {
                reason = $"{_vpwEntity.Module} has no wafer";
                return false;
            }

            if (!SchedulerSequenceManager.Instance.CheckSystemHasTheSameSizeVpw())
            {
                return true;
            }

            VpwCellEntity vpwCellEntity1 = Singleton<RouteManager>.Instance.GetModule<VpwCellEntity>(ModuleName.VPW1.ToString());
            VpwCellEntity vpwCellEntity2 = Singleton<RouteManager>.Instance.GetModule<VpwCellEntity>(ModuleName.VPW2.ToString());

            if (vpwCellEntity1.State != (int)VPWCellState.WaitForRunRecipe && vpwCellEntity1.State != (int)VPWCellState.RunReciping)
            {
                return false;
            }
            if (WaferManager.Instance.CheckNoWafer(ModuleName.VPW1, 0))
            {
                reason = $"{ModuleName.VPW1} has no wafer";
                return false;
            }
            if (vpwCellEntity2.State != (int)VPWCellState.WaitForRunRecipe&&vpwCellEntity2.State!=(int)VPWCellState.RunReciping)
            {
                return false;
            }
            if (WaferManager.Instance.CheckNoWafer(ModuleName.VPW2, 0))
            {
                reason = $"{ModuleName.VPW2} has no wafer";
                return false;
            }
            return true;
        }
    }
}