添加项目文件。

yl

2024-10-09 622910b0f7cfdf90305844794e7451a611f8ae93

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
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;
        }
    }
}