SHJX_GM/SHJX.Service.Control/Schedules/WritePipeSchedule.cs

using SHJX.Service.Control.Pipeline.Contents;

namespace SHJX.Service.Control.Schedules
{
    [EnableScheduling]
    public class WritePipeSchedule : IScheduler
    {
        private static IDataManager _dataManager;

        public WritePipeSchedule(IDataManager dataManager)
        {
            _dataManager = dataManager;
        }

        [Scheduled("WriteTaskToPipeline", 1000)]
        public void WriteTaskToPipeline()
        {
            EquipmentTask task = _dataManager.Query<EquipmentTask>().Where(item => item.RouteID.In(1, 2, 3, 4) && item.Status.Equals(TaskState.Doing)).First();
            if (task is null)
            {
                return;
            }
            task.Status = TaskState.Hit;
            _dataManager.Update(task);
            //if (task.To == "D2" && task.RouteStep == "Titration")
            //{
                //task.RouteStep = "Titration2";
            //}
            PipeContent.Factory(task.RouteStep).Invoke(task);
        }
    }
}