增加定时任务前端（部分）

applications/view/admin/task.py

@@ -1,8 +1,10 @@
-from flask import Blueprint, request, jsonify
-from applications.common.tasks.tasks import task4
-from applications.extensions.init_apscheduler import scheduler
+from flask import Blueprint, request, render_template
 from flask_apscheduler.utils import job_to_dict
 
+from applications.common.tasks.tasks import task2, task3, task4
+from applications.common.utils.http import table_api, fail_api, success_api
+from applications.extensions.init_apscheduler import scheduler
+
 admin_task = Blueprint('adminTask', __name__, url_prefix='/admin/task')
 
 
@@ -14,41 +16,66 @@ admin_task = Blueprint('adminTask', __name__, url_prefix='/admin/task')
 # 删除任务
 # scheduler.remove_job('first')
 
-@admin_task.route('/pause', methods=['GET'])
-def pause_job():  # 暂停
-    job_id = request.args.get('id')
-    scheduler.pause_job(str(job_id))
-    return "pause success!"
+
+@admin_task.route('/add_job', methods=['GET'])
+def add_task():
+    tasks = {
+        "task2": task2,
+        "task3":task3,
+        "task4":task4
+    }
+    scheduler.add_job(func=tasks.get(), id='4', args=(1, 1), trigger='interval', seconds=3,
+                      replace_existing=True)
+    return '6'
 
 
-@admin_task.route('/resume', methods=['GET'])
-def resume_job():  # 恢复
-    job_id = request.args.get('id')
-    scheduler.resume_job(str(job_id))
-    return "Success!"
+@admin_task.get('/')
+def main():
+    return render_template('admin/task/main.html')
 
 
-@admin_task.route('/get_jobs', methods=['GET'])
+@admin_task.route('/data', methods=['GET'])
 def get_task():  # 获取
     jobs = scheduler.get_jobs()
     jobs_list = []
     for job in jobs:
         jobs_list.append(job_to_dict(job))
-    return jsonify(jobs_list)
+    return table_api(data=jobs_list)
 
 
-@admin_task.route('/remove_job', methods=['GET'])
-def remove_job():  # 移除
-    job_id = request.args.get('id')
-    scheduler.remove_job(str(job_id))
-    return 'remove success'
+# 增加
+@admin_task.get('/add')
+def add():
+    return render_template('admin/task/add.html')
+
+
+# 恢复
+@admin_task.put('/enable')
+def enable():
+    id = request.json.get('id')
+    # print(id)
+    if id:
+        scheduler.resume_job(str(id))
+        return success_api(msg="启动成功")
+    return fail_api(msg="数据错误")
+
+
+# 暂停
+@admin_task.put('/disable')
+def dis_enable():
+    _id = request.json.get('id')
+    if _id:
+        scheduler.pause_job(str(_id))
+        return success_api(msg="暂停成功")
+    return fail_api(msg="数据错误")
+
+
+@admin_task.delete('/remove/<int:_id>')
+def remove_job(_id):  # 移除
+    scheduler.remove_job(str(_id))
+    return success_api(msg="删除成功")
 
 
-@admin_task.route('/add_job', methods=['GET'])
-def add_task():
-    scheduler.add_job(func=task4, id='4', args=(1, 1), trigger='interval', seconds=3,
-                      replace_existing=True)
-    return '6'
 
     #     scheduler.add_job(func=task1, id='2', args=(1, 1), trigger='cron', day_of_week='0-6', hour=18, minute=24,
     #                       second=10, replace_existing=True)