变更

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);
+    }
 }

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);
+    }
 }