using Dapper;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Threading.Tasks;
using VueWebCoreApi.Tools;

namespace VueWebCoreApi.Quartz
{
    public class QuartzSearchData
    {
        /// <summary>
        /// 查询任务列表
        /// </summary>
        /// <returns></returns>
        public static DataTable QuartzSearch()
        {
            //查找任务列表
            var sql = @"select TaskName,GroupName,Interval,ApiUrl,AuthKey,AuthValue,Describe,RequestType,LastRunTime,Status   
                        from ScheduleInfo";
            var data = DapperHelper.selecttable(sql);
            return data;
        }

        /// <summary>
        /// 新增任务
        /// </summary>
        /// <param name="taskOptions"></param>
        /// <returns></returns>
        public static bool QuartzCreate(TaskOptions taskOptions)
        {
            List<object> list = new List<object>();
            string sql = @"insert into  ScheduleInfo(TaskName,GroupName,Interval,ApiUrl,AuthKey,AuthValue,Describe,RequestType,LastRunTime,Status,CreateAuthr,CreateTime)
                                   values(@TaskName,@GroupName,@Interval,@ApiUrl,@AuthKey,@AuthValue,@Describe,@RequestType,@LastRunTime,@Status,@CreateAuthr,@CreateTime)";
            list.Add(new { str = sql, parm = new { 
                TaskName = taskOptions.TaskName,
                GroupName = taskOptions.GroupName,
                Interval = taskOptions.Interval,
                ApiUrl = taskOptions.ApiUrl,
                AuthKey = taskOptions.AuthKey,
                AuthValue = taskOptions.AuthValue,
                Describe = taskOptions.Describe,
                RequestType = taskOptions.RequestType,
                LastRunTime = taskOptions.LastRunTime,
                Status=taskOptions.Status,
                CreateAuthr="9999",
                CreateTime= DateTime.Now.ToString()
            } 
            });
            bool aa = DapperHelper.DoTransaction(list);
            return aa;
        }

        /// <summary>
        /// 修改任务
        /// </summary>
        /// <param name="taskOptions"></param>
        /// <returns></returns>
        public static bool QuartzUpdate(TaskOptions taskOptions)
        {
            List<object> list = new List<object>();
            string sql = @"update  ScheduleInfo set TaskName=@TaskName,GroupName=@GroupName,Interval=@Interval,ApiUrl=@ApiUrl,AuthKey=@AuthKey,AuthValue=@AuthValue,Describe=@Describe,RequestType=@RequestType,LastRunTime=@LastRunTime,Status=@Status
                           where TaskName=@TaskName and GroupName=@GroupName";
            list.Add(new
            {
                str = sql,
                parm = new
                {
                    TaskName = taskOptions.TaskName,
                    GroupName = taskOptions.GroupName,
                    Interval = taskOptions.Interval,
                    ApiUrl = taskOptions.ApiUrl,
                    AuthKey = taskOptions.AuthKey,
                    AuthValue = taskOptions.AuthValue,
                    Describe = taskOptions.Describe,
                    RequestType = taskOptions.RequestType,
                    LastRunTime = taskOptions.LastRunTime,
                    Status = taskOptions.Status
                }
            });
            bool aa = DapperHelper.DoTransaction(list);
            return aa;
        }

        /// <summary>
        /// 删除任务
        /// </summary>
        /// <param name="taskOptions"></param>
        /// <returns></returns>
        public static bool QuartzDelete(TaskOptions taskOptions)
        {
            List<object> list = new List<object>();
            string sql = @"delete  ScheduleInfo where TaskName=@TaskName and GroupName=@GroupName";
            list.Add(new
            {
                str = sql,
                parm = new
                {
                    TaskName = taskOptions.TaskName,
                    GroupName = taskOptions.GroupName,
                    Interval = taskOptions.Interval,
                    ApiUrl = taskOptions.ApiUrl,
                    AuthKey = taskOptions.AuthKey,
                    AuthValue = taskOptions.AuthValue,
                    Describe = taskOptions.Describe,
                    RequestType = taskOptions.RequestType,
                    LastRunTime = taskOptions.LastRunTime,
                    Status = taskOptions.Status
                }
            });
            bool aa = DapperHelper.DoTransaction(list);
            return aa;
        }
    }
}