using iWareCc.Cache.Entity; using iWareCc.DecomposeTask.Entity; using iWareCc.Properties; using iWareCc.Srm.Entity; using iWareCommon.Common.Entity; using iWareCommon.Common.EnumType; using iWareCommon.Utils; using iWareDataCore.DEV.EnumType; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks; namespace iWareCc.FinishStackerTask.Chain { public class 等待堆垛机完成任务 : IHandler { /// /// 该节点的下一个节点 /// private IHandler nextHandler = null; public IHandler NextHandler { set { nextHandler = value; } } private StackerEntity Stacker; /// /// 任务容器 /// private PartTaskContainer DecompositionTaskContainer; public 等待堆垛机完成任务(StackerEntity stacker, PartTaskContainer decompositionTaskContainer) { this.Stacker = stacker; this.DecompositionTaskContainer = decompositionTaskContainer; } public void Handle() { try { if (Stacker.WTaskNo != DecompositionTaskContainer.PartTask.Id) { LogTextHelper.WriteLine(Resources.LogDir + @"/完成堆垛机任务/" + Stacker.Equipment.EquipName, "等待堆垛机完成任务WCSId={0},STAKERID={1}:{2}", DecompositionTaskContainer.PartTask.Id, Stacker.WTaskNo, "任务号不匹配"); return; } if (Stacker.TaskFinish < 1) { LogTextHelper.WriteLine(Resources.LogDir + @"/完成堆垛机任务/" + Stacker.Equipment.EquipName, "等待堆垛机完成任务:{0}", "任务执行中..."); return; } var flag1 = CacheEntity.OpcWcfServiceClient.WriteValue(Stacker.OpcWriteItems.TaskNo, (int)EYesOrNo.否); while (Stacker.State != (int)ESrmState.堆垛机空闲) { Thread.Sleep(1000); } if (!flag1) { LogTextHelper.WriteLine(Resources.LogDir + @"/完成堆垛机任务/" + Stacker.Equipment.EquipName, "等待堆垛机完成任务:{0}", "发送OPC失败"); return; } LogTextHelper.WriteLine(Resources.LogDir + @"/完成堆垛机任务/" + Stacker.Equipment.EquipName, "等待堆垛机完成任务:{0}", "任务已完成"); if (nextHandler != null) { nextHandler.Handle(); } } catch (Exception ex) { LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "Handle", ex.Message); } } } }