CyberX8/CyberX8_RT/Schedulers/Aligner/SchedulerAligner.cs

using System.Diagnostics;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Aitex.Core.RT.Fsm;
using Aitex.Core.Util;
using Aitex.Core.RT.SCCore;
using Aitex.Sorter.Common;
using MECF.Framework.Common.Equipment;
using MECF.Framework.Common.Schedulers;
using MECF.Framework.Common.SubstrateTrackings;
using CyberX8_RT.Modules;
using MECF.Framework.Common.CommonData;
using CyberX8_Core;
using Aitex.Core.RT.Log;
using Aitex.Core.Common;

namespace CyberX8_RT.Schedulers.Aligner
{
    public class SchedulerAligner : SchedulerModule
    {
        #region 内部变量
        private EfemEntity _efemEntity;
        #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 SchedulerAligner(ModuleName module) : base(module.ToString())
        {
            _efemEntity = Singleton<RouteManager>.Instance.EFEM;
        }
        /// <summary>
        /// 执行
        /// </summary>
        /// <param name="parameter"></param>
        /// <returns></returns>
        public override bool RunProcess(object recipe, object parameter, List<SchedulerSyncModuleMessage> syncModuleMessages)
        {
            if (_efemEntity.IsBusy)
            {
                return false;
            }
            int angle = int.Parse(parameter.ToString());
            return _efemEntity.CheckToPostMessage<EfemEntity.STATE, EfemEntity.MSG>(eEvent.ERR_EFEM_COMMON_FAILED,
                Module.ToString(), (int)EfemEntity.MSG.Align, ModuleName.Aligner1.ToString(), 0, angle);
        }
        /// <summary>
        /// 监控执行
        /// </summary>
        /// <returns></returns>
        public override bool MonitorProcess(SchedulerSequence schedulerSequence,bool hasMatchWafer)
        {
            if (_efemEntity.IsBusy)
            {
                _state = RState.Running;
            }
            if (_efemEntity.IsIdle)
            {
                _state = RState.End;
            }
            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 (WaferManager.Instance.CheckHasWafer(Module, 0))
            {
                WaferInfo waferInfo = WaferManager.Instance.GetWafer(Module, 0);
                bool result= waferInfo.WaferID==materialId;
                if (!result)
                {
                    reason = $"aligner wafer id {waferInfo.WaferID} is not matched with {materialId}";
                }
                return result;
            }
            else
            {
                reason = "aligner has no wafer";
                return false;
            }
        }
    }
}