using iWareCc.Cache.Entity; using iWareCc.Conveyor.Entity; using iWareCc.DecomposeTask.Entity; using iWareCc.Properties; using iWareCommon.Common.Entity; using iWareCommon.Common.EnumType; using iWareCommon.Utils; using iWareDataCore.ORM; using iWareDataCore.TASK.Entity; using iWareDataCore.TASK.EnumType; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; namespace iWareCc.FinishConveyorTask.Chain { public class 获取当前的任务 : IHandler { /// /// 该节点的下一个节点 /// private IHandler nextHandler = null; public IHandler NextHandler { set { nextHandler = value; } } private ConveyorEntity Conveyor; /// /// 任务容器 /// private PartTaskContainer DecompositionTaskContainer; public 获取当前的任务(ConveyorEntity conveyor, PartTaskContainer decompositionTaskContainer) { this.Conveyor = conveyor; this.DecompositionTaskContainer = decompositionTaskContainer; } public void Handle() { using (var dbModel = new DbModelCore()) { try { var task = dbModel.TASKPartTasks.OrderBy(x => x.finishtimes).FirstOrDefault(x => x.iscurrent == (int)EYesOrNo.是 && x.isreleased == (int)EYesOrNo.是 && x.isfinished == (int)EYesOrNo.否 && x.type == (int)EPartTaskType.输送机任务 && x.equipid == Conveyor.Equipment.Id && x.status == (int)EPartTaskStatus.执行中); if (task == null) { LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送机任务/" + Conveyor.Equipment.EquipName, "获取当前的任务:{0}", "没有找到待完成的任务"); return; } task.finishtimes += 1; if (task.sourceplace == "100201") { var sc = CacheEntity.Conveyors.First(x => x.Equipment.EquipName == "conveyor1").Gates.FirstOrDefault(x => x.Place.PlaceTypeName == "sc"); var materila = dbModel.BASEMaterials.FirstOrDefault(x => x.code == task.materialcode); if (!string.IsNullOrEmpty(materila.wide)) { if (!sc.SendMaterialWindTask(materila.wide, materila.thick)) { sc.SendMaterialWindTask(materila.wide, materila.thick); } } } dbModel.SaveChanges(); DecompositionTaskContainer.PartTask = new PartTaskEntity(task); LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送机任务/" + Conveyor.Equipment.EquipName, "获取当前的任务:{0}", DecompositionTaskContainer.PartTask.Id); if (nextHandler != null) { nextHandler.Handle(); } } catch (Exception ex) { LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "Handle", ex.Message); } } } } }