SHJX_GM/SHJX.Service.Control/Pipeline/Contents/VirtualPipeline.cs

namespace SHJX.Service.Control.Pipeline.Contents
{
    /// <summary>
    /// 虚拟管道
    /// </summary>
    public class VirtualPipeline : IPipeline
    {
        /// <summary>
        /// 首节点
        /// </summary>
        private INode _firstNode;

        /// <summary>
        /// 添加节点
        /// </summary>
        /// <param name="node"></param>
        /// <returns></returns>
        public IPipeline AddNode(INode node)
        {
            if (_firstNode == null)
            {
                _firstNode = node;
            }
            else
            {
                INode current = _firstNode;
                while (current.NextNode != null)
                {
                    current = current.NextNode;
                }
                current.NextNode = node;
            }
            return this;
        }

        /// <summary>
        /// 调用
        /// </summary>
        /// <param name="value"></param>
        public void Invoke(EquipmentTask value)
        {
            _firstNode?.SetTask(value)?.Invoke()?.Record()?.Next();
        }
    }
}