任务调度之持久化（基于Quartz.net）

上一篇我们了解了任务调度及他的远端管理方式，传送门：任务调度及远端管理（基于Quartz.net）

这篇我们要完成任务调度的持久化功能，即新增修改删除之类的功能，这必须得要有的，不然都不知道后台都有什么作业在跑

一、Job的CURD

1.1 、新建Job表

CREATE TABLE [dbo].[Job](
    [Id] [uniqueidentifier] NOT NULL,
    [GroupName] [nvarchar](50) COLLATE Chinese_PRC_CI_AS NULL,
    [JobName] [nvarchar](50) COLLATE Chinese_PRC_CI_AS NULL,
    [TriggerName] [nvarchar](50) COLLATE Chinese_PRC_CI_AS NULL,
    [Cron] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
    [TriggerState] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
    [StartTime] [datetime] NULL,
    [EndTime] [datetime] NULL,
    [PreTime] [datetime] NULL,
    [NextTime] [datetime] NULL,
    [Description] [nvarchar](200) COLLATE Chinese_PRC_CI_AS NULL,
    [CreateTime] [datetime] NULL,
 CONSTRAINT [PK_Job] PRIMARY KEY CLUSTERED 
(
    [Id] ASC
)WITH (PAD_INDEX  = OFF, IGNORE_DUP_KEY = OFF) ON [PRIMARY]
) ON [PRIMARY]

GO

1.2、控制器还是用上一篇的HelloJobController，改一下

    public class HelloJobController : Controller
    {
        private IJobApplication jobApplication;

        public HelloJobController(IJobApplication jobApplication)
        {
            this.jobApplication = jobApplication;
        }

        [Route("Jobs/{PageIndex=1}")]
        public ActionResult Index(string PageIndex)
        {
            Page page = new Page();
            page.PageIndex = PageIndex.ToInt(1);

            var model = new JobPageViewModel();
            var soure = this.jobApplication.GetPage(page, t => t.CreateTime);

            model.Items = Mapper.Map<List<JobViewModel>>(soure.Item2);
            model.Total = soure.Item1;
            model.Page = page;

            return View(model);
        }

        [HttpPost]
        [ValidateAntiForgeryToken]
        public ActionResult Add(JobCURequest entity)
        {
            this.jobApplication.Add(new JobCURequest()
            {
                Id = Guid.NewGuid(),
                GroupName = entity.GroupName,
                JobName = entity.JobName,
                TriggerName = entity.TriggerName,
                Cron = entity.Cron,
                TriggerState = Quartz.TriggerState.None.ToString()
            });

            return RedirectToAction("Index");
        }

        [HttpGet]
        public ActionResult Delete(string id)
        {
            this.jobApplication.Delete(Guid.Parse(id));
            return RedirectToAction("Index");
        }

        [HttpGet]
        public ActionResult Edit(Guid id)
        {
            var soure = this.jobApplication.Get(id);
            return Json(soure, JsonRequestBehavior.AllowGet);
        }

        [HttpPost]
        [ValidateAntiForgeryToken]
        public ActionResult Edit(JobCURequest entity)
        {
            this.jobApplication.Update(new JobCURequest()
            {
                Id = entity.Id,
                GroupName = entity.GroupName,
                JobName = entity.JobName,
                TriggerName = entity.TriggerName,
                Cron = entity.Cron,
                TriggerState = Quartz.TriggerState.None.ToString()
            });

            return RedirectToAction("Index");
        }73     }

可以看到我们新加了IJobApplication的注入，以及Index、Add、Delete、Edit（2个）5个方法

至于里边的实现就是我们上一个系列写好的功能，详细情况请点击传送门：架构设计

1.3、 视图View也要改一下

@model Presentation.MVC.Models.JobPageViewModel
@{
    ViewBag.Title = "Index";
    Layout = "~/Views/Shared/_Bootstrap.cshtml";
}

<br />
<div class="panel panel-default">
    <div class="panel-heading">
        <h4 class="panel-title">
            <a data-toggle="collapse" data-parent="#accordion"
               href="#collapseOne" id="actionType">
                新增作业
            </a>
        </h4>
    </div>
    <div id="collapseOne" class="panel-collapse collapse">
        <div class="panel-body">
            @using (Html.BeginForm("Add", "HelloJob", null, FormMethod.Post, new { @id = "formHelloJob", @class = "form-horizontal", role = "form" }))
            {
                @Html.AntiForgeryToken()

                <div class="form-group">
                    <label for="LoginName" class="col-sm-2 control-label">群组</label>
                    <div class="col-sm-10">
                        <input type="text" class="form-control" name="GroupName" id="GroupName"
                               placeholder="请输入群组" />
                    </div>
                </div>
                <div class="form-group">
                    <label for="Password" class="col-sm-2 control-label">作业名称</label>
                    <div class="col-sm-10">
                        <input type="text" class="form-control" name="JobName" id="JobName"
                               placeholder="请输入作业名称" />
                    </div>
                </div>
                <div class="form-group">
                    <label for="Password" class="col-sm-2 control-label">触发器名称</label>
                    <div class="col-sm-10">
                        <input type="text" class="form-control" name="TriggerName" id="TriggerName"
                               placeholder="请输入触发器名称" />
                    </div>
                </div>
                <div class="form-group">
                    <label for="Password" class="col-sm-2 control-label">执行计划</label>
                    <div class="col-sm-10">
                        <input type="text" class="form-control" name="Cron" id="Cron"
                               placeholder="请输入执行计划" />
                    </div>
                </div>
                <div class="form-group">
                    <label for="Password" class="col-sm-2 control-label">描述</label>
                    <div class="col-sm-10">
                        <input type="text" class="form-control" name="Description" id="Description"
                               placeholder="请输入描述" />
                    </div>
                </div>
                <div class="form-group">
                    <div class="col-sm-offset-2 col-sm-10">
                        <input type="hidden" name="Id" id="Id" />
                        <button type="submit" class="btn btn-default">提交</button>
                    </div>
                </div>
            }
        </div>
    </div>
</div>

<div style=" margin-bottom:5px;">
    <a id="btnRun" class="btn btn-default" href="#" role="button">执行</a>
    <a id="btnPause" class="btn btn-default" href="#" role="button">暂停</a>
    <a id="btnResume" class="btn btn-default" href="#" role="button">恢复</a>

    <a id="btnEdit" class="btn btn-default" href="#" role="button" style=" margin-left:10px">修改</a>
    <a id="btnDel" class="btn btn-default" href="#" role="button">删除</a>
</div>
<table id="list" class="table table-striped table-bordered table-hover table-condensed">
    <thead>
        <tr>
            <th><input type="checkbox" class="chkAll" /></th>
            <th>序号</th>
            <th>群组</th>
            <th>作业名称</th>
            <th>触发器名称</th>
            <th>执行计划</th>
            <th>描述</th>
            <th>开始时间</th>
            <th>结束时间</th>
            <th>上次执行</th>
            <th>下次执行</th>
            <th>状态</th>
        </tr>
    </thead>
    <tbody>
        @foreach (var item in Model.Items)
        {
            <tr>
                <td><input type="checkbox" name="subBox" value="@item.Id" /></td>
                <td>@item.RowNumber</td>
                <td>@item.GroupName</td>
                <td>@item.JobName</td>
                <td>@item.TriggerName</td>
                <td>@item.Cron</td>
                <td>@item.Description</td>
                <td>@item.StartTime</td>
                <td>@item.EndTime</td>
                <td>@item.PreTime</td>
                <td>@item.NextTime</td>
                <td>@item.TriggerState</td>
            </tr>
        }
    </tbody>
</table>

<ul class="pagination">
    <li><a href="/HelloJob/@Model.PrePage">&laquo;</a></li>
    @for (int index = 1; index <= Model.TotalPage; index++)
    {
        if (Model.Page.PageIndex == index)
        {
    <li class="active"><a href="/HelloJob/@index">@index</a></li>
        }
        else
        {
    <li><a href="/HelloJob/@index">@index</a></li>
        }
    }
    <li><a href="/HelloJob/@Model.NextPage">&raquo;</a></li>
</ul>

<script type="text/javascript">
    $(function () {
        $(".chkAll").click(function () {
            if (this.checked) {
                $('input[name="subBox"]').attr("checked", this.checked);
            } else {
                $('input[name="subBox"]').removeAttr("checked");
            }
        });

        $("#btnEdit").click(function () {
            var id = GetChooseIds();
            if (id == undefined || id == null || id == "") return;

            $.ajax({
                url: "/HelloJob/Edit/" + id,
                type: "GET",
                dataType: 'json',
                success: function (result) {
                    $("#Id").val(result.Id);
                    $("#GroupName").val(result.GroupName);
                    $("#JobName").val(result.JobName);
                    $("#TriggerName").val(result.TriggerName);
                    $("#Cron").val(result.Cron);
                    $("#Description").val(result.Description);

                    $('#collapseOne').collapse('show');
                    $("#formHelloJob").attr("action", "/HelloJob/Edit");
                    $("#actionType").html("修改作业");
                },
                error: function (e) {
                    alert(e);
                }
            });
        });

        $("#btnDel").click(function () {
            var id = GetChooseIds();
            if (id == undefined || id == null || id == "") return;

            CreateDeleteWindow(function () {
                location.href = "/HelloJob/Delete/" + id;
            });
        });

        $("#btnRun").click(function () {
            var id = GetChooseIds();
            if (id == undefined || id == null || id == "") return;

            CreateRunWindow(function () {
                location.href = "/HelloJob/Run/" + id;
            });
        });

        $("#btnPause").click(function () {
            var id = GetChooseIds();
            if (id == undefined || id == null || id == "") return;

            CreatePauseWindow(function () {
                location.href = "/HelloJob/Pause/" + id;
            });
        });

        $("#btnResume").click(function () {
            var id = GetChooseIds();
            if (id == undefined || id == null || id == "") return;

            CreateResumeWindow(function () {
                location.href = "/HelloJob/Resume/" + id;
            });
        });

        function GetChooseIds() {
            var id = "";
            $('input[name="subBox"]').each(function () {
                id = $(this).attr("value");
            });

            return id;
        }
    });
</script>

1.4、界面代码就完成了，我们去看看

完全没问题，下面我们来完成 执行、暂停、恢复三个操作作业的按钮功能

二、作业管理

2.1、HelloJobHelper改一下，名称我也改了（JobHelper）

2.2、HelloJobController加入上边三个功能

        public ActionResult Run(Guid id)
        {
            var success = this.jobApplication.Update(new JobCURequest()
            {
                Id = id,
                TriggerState = Quartz.TriggerState.Normal.ToString()
            });

            if (success)
            {
                var entity = this.jobApplication.Get(id);
                JobHelper.Run(entity);
            }

            return RedirectToAction("Index", "HelloJob");
        }

        public ActionResult Pause(Guid id)
        {
            var success = this.jobApplication.Update(new JobCURequest()
            {
                Id = id,
                TriggerState = Quartz.TriggerState.Paused.ToString()
            });

            if (success)
            {

                var entity = this.jobApplication.Get(id);
                JobHelper.Pause(entity);
            }
            return RedirectToAction("Index", "HelloJob");
        }

        public ActionResult Resume(Guid id)
        {
            var success = this.jobApplication.Update(new JobCURequest()
            {
                Id = id,
                TriggerState = Quartz.TriggerState.Normal.ToString()
            });

            if (success)
            {
                var entity = this.jobApplication.Get(id);
                JobHelper.Resume(entity);
            }

            return RedirectToAction("Index", "HelloJob");
        }

2.3、好了，现在开启服务端

2.4、执行

2.5、暂停

2.6、恢复

 

好了，基本上就是这些了