GoEmptyShelfLineJob.cs 8.3 KB
using Common;

namespace DeviceLibrary
{
    /// <summary>
    /// 去空料架任务点
    /// </summary>
    public class GoEmptyShelfLineJob : Job
    {
        /// <summary>
        /// 去空料架任务点
        /// </summary>
        /// <param name="agvPlae">小车当前位置,空表示在待机位</param>
        /// <param name="palce">空料架位置点</param>
        public GoEmptyShelfLineJob(string agvPlae, string palce, string rfid)
        {
            EmptyShelfPlace = palce;
            this.agvPlae = agvPlae;
            RFID = rfid;
        }
        public string RFID { get; set; }
        /// <summary>
        /// 空料架位置点
        /// </summary>
        public string EmptyShelfPlace { get; set; }

        /// <summary>
        /// 接收任务时,agv的位置
        /// </summary>
        private string agvPlae { get; set; }


        private string runInfo = "";
        /// <summary>
        /// 运行信息
        /// </summary>
        public override string RunInfo
        {
            get { return string.Format("取空料架[RFID={0}][{1}]:{2}", RFID, CurTaskID, runInfo); }
        }


        private JobStep<TAKE_EMPTY_STEP> jobStep = new JobStep<TAKE_EMPTY_STEP>(TAKE_EMPTY_STEP.NONE);

        /// <summary>
        /// 空架任务执行,去目的地
        /// </summary>
        /// <param name="agv"></param>
        public override Job Execute(Agv_Info agv)
        {
            string msg = string.Format("{0} 取空料架[RFID={1}]: ", agv.Name, RFID);
            //bool rtn = false;
            int nodeIdx = AGVManager.FindNode(EmptyShelfPlace);
            if (jobStep.IsStep(TAKE_EMPTY_STEP.NONE))
            {
                jobStep.ToNextStep(TAKE_EMPTY_STEP.ASSIGN_AGV_TASK);
                runInfo = "开始任务[" + agvPlae + "->" + EmptyShelfPlace + "]" + "[RFID=" + RFID + "]";
                msg += string.Format("[{0}] {1}", jobStep.CurStep(), runInfo);
                jobStep.Msg = msg;
            }

            else if (jobStep.IsStep(TAKE_EMPTY_STEP.ASSIGN_AGV_TASK))
            {

                if (nodeIdx > -1)
                {
                    jobStep.ToNextStep(TAKE_EMPTY_STEP.WAIT_AGV_START_TASK);
                    runInfo = "AGV 添加任务:移动到" + EmptyShelfPlace + "[RFID=" + RFID + "]";
                    msg += string.Format("[{0}] {1}", jobStep.CurStep(), runInfo);
                    jobStep.Msg = msg;
                    MissionSys.AssignMission(agv, EmptyShelfPlace);
                    UpdateJobTaskInfo(agv);
                }
                else
                {
                    jobStep.ToNextStep(TAKE_EMPTY_STEP.ASSIGN_AGV_TASK);
                    runInfo = EmptyShelfPlace + " 不存在或未开启调用";
                    msg += string.Format("[{0}] {1}", jobStep.CurStep(), runInfo);
                    jobStep.Msg = msg;
                }
            }
            else if (jobStep.IsStep(TAKE_EMPTY_STEP.WAIT_AGV_START_TASK))
            {
                if (agv.CurTaskState.Equals(SettingString.Executing))
                {
                    jobStep.ToNextStep(TAKE_EMPTY_STEP.WAIT_REACH_PLACE);
                    runInfo = "AGV开始向目的地[" + EmptyShelfPlace + "]移动" + "[RFID=" + RFID + "]";
                    msg += string.Format("[{0}] {1}", jobStep.CurStep(), runInfo);
                    jobStep.Msg = msg;
                }
            }
            else if (jobStep.IsStep(TAKE_EMPTY_STEP.WAIT_REACH_PLACE))
            {
                CurTaskState = MissionSys.GetTakJobState(agv);
                if (MissionSys.CheckTaskFinished(agv, EmptyShelfPlace, CurTaskState))
                {
                    {
                        jobStep.ToNextStep(TAKE_EMPTY_STEP.WAIT_LINE_RESPONSE);
                        runInfo = "AGV到达 " + EmptyShelfPlace + " 向产线发送出料架请求[ReadyLeave]" + "[RFID=" + RFID + "]";
                        msg += string.Format("[{0}] {1}", jobStep.CurStep(), runInfo);
                        jobStep.Msg = msg;
                        if (nodeIdx == -1)
                        {
                            runInfo = EmptyShelfPlace + " 未开启调用";
                            msg += string.Format("[{0}] {1}", jobStep.CurStep(), runInfo);
                            jobStep.Msg = msg;
                            return this;
                        }
                        ClientNode node = AGVManager.nodeInfo[nodeIdx];
                        agv.RFID = node.RFID;
                        AGVManager.server.ReadyLeave(EmptyShelfPlace);
                    }

                }
            }
            else if (jobStep.IsStep(TAKE_EMPTY_STEP.WAIT_LINE_RESPONSE))
            {
                if (nodeIdx == -1)
                {
                    runInfo = EmptyShelfPlace + " 未开启调用";
                    msg += string.Format("[{0}] {1}", jobStep.CurStep(), runInfo);
                    jobStep.Msg = msg;
                    return this;
                }
                ClientNode node = AGVManager.nodeInfo[nodeIdx];
                agv.RFID = node.RFID;
                if (node.StateEquals(eNodeStatus.MayLeave))
                {
                    if (!agv.CurTarName.Equals("Enter"))
                    {
                        jobStep.ToNextStep(TAKE_EMPTY_STEP.WAIT_TAKE_EMPTY_SHELF);
                        runInfo = "收到产线出料请求[ReadyLeave]的响应 " + EmptyShelfPlace + "出料架,小车链条运行" + "[RFID=" + RFID + "]";
                        msg += string.Format("[{0}] {1}", jobStep.CurStep(), runInfo);
                        jobStep.Msg = msg;
                        //agv.RFID = node.RFID;
                        MissionSys.AssignMission(agv, SettingString.Enter);
                        UpdateJobTaskInfo(agv);
                    }

                }
                else if (jobStep.IsTimeOut(15000, out double timeOutValue))
                {
                    jobStep.ToNextStep(TAKE_EMPTY_STEP.WAIT_REACH_PLACE);
                }
            }
            else if (jobStep.IsStep(TAKE_EMPTY_STEP.WAIT_TAKE_EMPTY_SHELF))
            {
                CurTaskState = MissionSys.GetTakJobState(agv);
                if (MissionSys.CheckTaskFinished(agv, SettingString.Enter, CurTaskState))
                {
                    ClientNode node = AGVManager.nodeInfo[nodeIdx];

                    runInfo = "空料架在[" + EmptyShelfPlace + "]进入小车完成" + "[RFID=" + RFID + "]";
                    msg += string.Format("[{0}] {1}", jobStep.CurStep(), runInfo);
                    jobStep.Msg = msg;
                    AGVManager.CheckBoxNeedShelfState(agv, out string nodeName);
                    return new EmptyShelfBackJob(EmptyShelfPlace,eShelfType.SmallShelf, nodeName);
                }
                else if (jobStep.IsTimeOut(60000, out double timeOutValue))
                {
                    //链条停止
                    runInfo = "空料架在[" + EmptyShelfPlace + "]进入小车超时[" + timeOutValue.ToString("f1") + "秒],请检查料架进入小车的情况" + "[RFID=" + RFID + "]";
                }

            }
            else if (jobStep.IsStep(TAKE_EMPTY_STEP.END))
            {

            }

            return this;
        }


        /// <summary>
        /// AGV回收空料架流程
        /// </summary>
        private enum TAKE_EMPTY_STEP
        {
            /// <summary>
            /// 准备,发送给AGV
            /// </summary>
            NONE,   
            /// <summary>
            /// 给AGV分配任务
            /// </summary>
            ASSIGN_AGV_TASK,
            /// <summary>
            /// 等待AGV开始执行去取架点任务
            /// </summary>
            WAIT_AGV_START_TASK,
            /// <summary>
            /// 等待AGV到达取架点
            /// </summary>
            WAIT_REACH_PLACE,
            /// <summary>
            /// 等待AGV到达临时停车位
            /// </summary>
            WAIT_REACH_TEMP_PLACE,
            /// <summary>
            /// 等待产线回应
            /// </summary>
            WAIT_LINE_RESPONSE,

            /// <summary>
            /// 等待料架进入小车
            /// </summary>
            WAIT_TAKE_EMPTY_SHELF,
            /// <summary>
            /// 料架进入小车完成
            /// </summary>
            END
        }
    }

}