diff --git a/src/main/java/com/dsideal/FengHuang/Yp/Controller/YpController.java b/src/main/java/com/dsideal/FengHuang/Yp/Controller/YpController.java index 2f61421..c3e1641 100644 --- a/src/main/java/com/dsideal/FengHuang/Yp/Controller/YpController.java +++ b/src/main/java/com/dsideal/FengHuang/Yp/Controller/YpController.java @@ -10,6 +10,7 @@ import com.jfinal.aop.Before; import com.jfinal.core.Controller; import com.jfinal.ext.interceptor.GET; import com.jfinal.ext.interceptor.POST; +import com.jfinal.kit.Kv; import com.jfinal.plugin.activerecord.Page; import com.jfinal.plugin.activerecord.Record; @@ -52,4 +53,55 @@ public class YpController extends Controller { renderJson(list); } + /** + * 功能:增加任务 + */ + @Before(POST.class) + @EmptyInterface({"task_name"}) + public void addTask(String task_name) { + model.addTask(task_name); + Kv kv = Kv.by("success", true); + kv.set("message", "保存成功!"); + renderJson(kv); + } + + /** + * 功能:修改任务 + */ + @Before(POST.class) + @IsNumericInterface({"task_id"}) + @EmptyInterface({"task_name"}) + public void updateTask(int task_id, String task_name) { + model.updateTask(task_id, task_name); + Kv kv = Kv.by("success", true); + kv.set("message", "保存成功!"); + renderJson(kv); + } + + /** + * 功能:删除任务 + * + * @param task_id + */ + @Before(POST.class) + @IsNumericInterface({"task_id"}) + public void delTask(int task_id) { + model.delTask(task_id); + Kv kv = Kv.by("success", true); + kv.set("message", "保存成功!"); + renderJson(kv); + } + + + /** + 功能:启动任务 + */ + @Before(POST.class) + @IsNumericInterface({"task_id"}) + public void startTask(int task_id) { + model.startTask(task_id); + Kv kv = Kv.by("success", true); + kv.set("message", "保存成功!"); + renderJson(kv); + } } \ No newline at end of file diff --git a/src/main/java/com/dsideal/FengHuang/Yp/Model/YpModel.java b/src/main/java/com/dsideal/FengHuang/Yp/Model/YpModel.java index 599f0c3..8a80099 100644 --- a/src/main/java/com/dsideal/FengHuang/Yp/Model/YpModel.java +++ b/src/main/java/com/dsideal/FengHuang/Yp/Model/YpModel.java @@ -1,8 +1,13 @@ package com.dsideal.FengHuang.Yp.Model; +import cn.hutool.core.date.DateTime; +import com.dsideal.FengHuang.Interceptor.EmptyInterface; +import com.dsideal.FengHuang.Interceptor.IsNumericInterface; import com.dsideal.FengHuang.LoginPerson.Model.LoginPersonModel; import com.dsideal.FengHuang.Util.CommonUtil; import com.dsideal.FengHuang.Util.IpUtil; +import com.jfinal.aop.Before; +import com.jfinal.ext.interceptor.POST; import com.jfinal.plugin.activerecord.Db; import com.jfinal.plugin.activerecord.Page; import com.jfinal.plugin.activerecord.Record; @@ -42,4 +47,43 @@ public class YpModel { } return list; } + + /** + * 功能:增加任务 + */ + public void addTask(String task_name) { + Record record = new Record(); + record.set("task_name", task_name); + record.set("create_time", DateTime.now()); + record.set("b_use", 0); + record.set("is_run", 0); + Db.save("t_yp_task", "task_id", record); + } + + /** + * 功能:修改任务 + */ + public void updateTask(int task_id, String task_name) { + String sql = "update t_yp_task set task_name=? where task_id=?"; + Db.update(sql, task_name, task_id); + } + + /** + * 功能:删除任务 + * + * @param task_id + */ + public void delTask(int task_id) { + String sql = "update t_yp_task set b_use=0 where task_id=?"; + Db.update(sql, task_id); + } + /** + * 功能:启动任务 + * + * @param task_id + */ + public void startTask(int task_id){ + String sql = "update t_yp_task set b_use=1,is_run=1 where task_id=?"; + Db.update(sql, task_id); + } } \ No newline at end of file