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

using SHJX.Service.Control.Extends;

namespace SHJX.Service.Control.Pipeline.Nodes
{
    public class Dissolve : INode
    {
        #region Fields
        private static TaskExtend _taskExtend;
        private static IDataManager _dataManager;
        #endregion

        public Dissolve(IDataManager dataManager, TaskExtend taskExtend)
        {
            Name = nameof(Dissolve);
            _taskExtend = taskExtend;
            _dataManager = dataManager;
        }

        public override INode Invoke()
        {
            DissolveDate date = _dataManager.Query<DissolveDate>().Where(it => it.PositionName.Equals(CurrentTask.To)).First();
            date.LastTryTime = DateTime.Now;
            date.SampleSource = CurrentTask.Source;
            date.Start = true;
            _dataManager.Update(date);
            DissolveInterval interval = _dataManager.Query<DissolveInterval>().First();
            interval.LastTryTime = DateTime.Now;
            _dataManager.Update(interval);
            CurrentTask.Status = TaskState.Dissolve;
            _dataManager.Update(CurrentTask);
            return this;
        }
    }
}