using SHJX.Service.Control.Extends; namespace SHJX.Service.Control.Pipeline.Nodes { public class TargetDewater : INode { #region Fields private static TaskExtend _taskExtend; private static IDataManager _dataManager; #endregion public TargetDewater(IDataManager dataManager, TaskExtend taskExtend) { Name = nameof(TargetDewater); _taskExtend = taskExtend; _dataManager = dataManager; } public override INode Invoke() { EquipmentArea area = _dataManager.Query().Where(it => it.AreaName.Equals(AreaName.DEWATER_POSITION)).First(); if (area is null) { throw new ArgumentException(nameof(EquipmentArea)); } CurrentTask.To = area.PointName; _dataManager.Update(CurrentTask); return this; } } }