Jelajahi Sumber

update 任务列表接口,根据update_time倒序查询

kk 2 tahun lalu
induk
melakukan
75e402d974
1 mengubah file dengan 2 tambahan dan 2 penghapusan
  1. 2 2
      server/conf_task.py

+ 2 - 2
server/conf_task.py

@@ -113,7 +113,7 @@ def getAllTask():
         offset = int(get_data.get('offset', 10))
         start_count = (page * offset) - offset
         end_count = page * offset
-        sql = f"""select task_id, task_name, insert_time from crawler_task limit {start_count}, {end_count}"""
+        sql = f"""select task_id, task_name, insert_time from crawler_task order by update_time desc limit {start_count}, {end_count} """
         result = MysqlHelper.get_values(sql)
         if not result:
             return jsonify({'code': '200', 'result': [], 'message': '没有更多任务'})
@@ -160,7 +160,7 @@ def updateTask():
     try:
         task_id = request.json.get('task_id')
         spider_link = request.json.get('spider_link')
-        sql = f"""UPDATE crawler_task SET spider_link="{spider_link}" where task_id = {task_id}"""
+        sql = f"""UPDATE crawler_task SET spider_link="{spider_link}", update_time={int(time.time())}  where task_id = {task_id}"""
         result = MysqlHelper.update_values(sql)
         if result:
             return jsonify({'code': 200, 'message': 'task update success'})