SHJX_GM/SHJX.Service.Control/Pipeline/Nodes/TargetDewater.cs

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<EquipmentArea>().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;
        }
    }
}