Estsh-Yiri/Estsh.Core.Quartz/Service/FileQuartzService.cs

using Estsh.Core.Quartz.Enum;
using Estsh.Core.Quartz.Model;
using Estsh.Core.Quartz.Tools;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Threading.Tasks;

namespace Estsh.Core.Quartz.Service
{
    public class FileQuartzService : IQuartzService
    {
        private QuartzFileHelper _quartzFileHelper;
        public FileQuartzService(QuartzFileHelper quartzFileHelper)
        {
            _quartzFileHelper = quartzFileHelper;
        }
        public Task<ResultQuartzData> AddJob(tab_quarz_task model)
        {
            return Task.Run(() =>
             {
                var list=  _quartzFileHelper.GetJobs(a=>1==1);
                 if (list == null)
                 {
                     list=  new List<tab_quarz_task>();

                 }
                 if (list.Count == 0)
                 {
                     model.id =1;
                 }
                 else
                 {
                     model.id = list.Max(a => a.id) + 1;
                 }
                 list.Add(model);
                 _quartzFileHelper.WriteJobConfig(list);
                 return new ResultQuartzData { message = "数据保存成功!", status = true };

             });


        }

        public Task<List<tab_quarz_task>> GetJobs(Expression<Func<tab_quarz_task, bool>> where)
        {
            return Task.Run(() =>
            {

                var list = _quartzFileHelper.GetJobs(where);
                return list;

            });
        }

        public Task<ResultQuartzData> Pause(tab_quarz_task model)
        {
            //throw new NotImplementedException();
            return Task.Run(() =>
            {
                var list = _quartzFileHelper.GetJobs(a => 1 == 1);
                list.ForEach(f=> { 
                 if(f.TaskName == model.TaskName && f.GroupName == model.GroupName)
                    {
                        f.Status = Convert.ToInt32(JobState.暂停);
                    }
                }) ;
                _quartzFileHelper.WriteJobConfig(list);
                return new ResultQuartzData { message = "数据暂停成功!", status = true }; ;

            });
        }

        public Task<ResultQuartzData> Remove(tab_quarz_task model)
        {
            return Task.Run(() =>
            {
                var list = _quartzFileHelper.GetJobs(a => 1 == 1);
                list.Remove(list.Find(a=>a.TaskName==model.TaskName&&a.GroupName==model.GroupName));
                _quartzFileHelper.WriteJobConfig(list);
                return new ResultQuartzData { message = "数据暂停成功!", status = true }; ;

            });
        }

        //public Task<ResultQuartzData> Run(tab_quarz_task model)
        //{
        //    return Task.Run(() =>
        //    {
        //        var list = _quartzFileHelper.GetJobs(a => 1 == 1);
        //        list.ForEach(f => {
        //            if (f.TaskName == model.TaskName && f.GroupName == model.GroupName)
        //            {
        //                f.Status = Convert.ToInt32(JobState.开启);
        //            }
        //        });
        //        _quartzFileHelper.WriteJobConfig(list);
        //        return new ResultQuartzData { message = "数据暂停成功!", status = true }; ;

        //    });
        //}

        public Task<ResultQuartzData> Start(tab_quarz_task model)
        {
            return Task.Run(() =>
            {
                var list = _quartzFileHelper.GetJobs(a => 1 == 1);
                list.ForEach(f => {
                    if (f.TaskName == model.TaskName && f.GroupName == model.GroupName)
                    {
                        f.Status = Convert.ToInt32(JobState.开启);
                    }
                });
                _quartzFileHelper.WriteJobConfig(list);
                return new ResultQuartzData { message = "数据开启成功!", status = true }; ;

            });
        }

        public Task<ResultQuartzData> Update(tab_quarz_task model)
        {
            return Task.Run(() =>
            {
                var list = _quartzFileHelper.GetJobs(a => 1 == 1);
                list.Remove(list.Find(a =>a.id==model.id));
                list.Add(model);
                _quartzFileHelper.WriteJobConfig(list);
                return new ResultQuartzData { message = "数据修改成功!", status = true }; ;

            });
        }
    }
}