update

server/conf_task.py

@@ -24,25 +24,22 @@ conf = get_config()
 @app.route("/v1/crawler/task/dellink", methods=["POST"])
 def delSpiderLink():
     data = request.json
-    spider_links = data['spider_link']
+    spider_link = data['spider_link']
     task_id = data['task_id']
-    del_link = []
-    for link in spider_links:
-        up_sql = f'update crawler_author_map set is_del=0 where spider_link="{link}"'
-        MysqlHelper.update_values(up_sql)
-        del_link.append(link)
+    up_sql = f'update crawler_author_map set is_del=0 where spider_link="{spider_link}"'
+    MysqlHelper.update_values(up_sql)
 
     sql = f'select spider_link from crawler_task where task_id ={task_id}'
     task = mysql_con.get_values(sql)
-    spider_link = eval(task[0]['spider_link'])
-    for link in spider_link:
-        spider_link.remove(link)
-    u_sql = f'update crawler_task set spider_link="{spider_link}" where task_id={task_id}'
+    spider_links = eval(task[0]['spider_link'])
+    for link in spider_links:
+        spider_links.remove(link)
+    u_sql = f'update crawler_task set spider_link="{spider_links}" where task_id={task_id}'
     mysql_con.update_values(u_sql)
-    if del_link:
-        return jsonify({'code': 200, 'message': '抓取名单删除成功', 'del_link': del_link})
+    if spider_link:
+        return jsonify({'code': 200, 'message': '抓取名单删除成功', 'del_link': spider_link})
     else:
-        return jsonify({'code': 400, 'message': '抓取名单删除失败', 'del_link': del_link, 'spider_link': spider_links})
+        return jsonify({'code': 400, 'message': '抓取名单删除失败', 'del_link': spider_link, 'spider_link': spider_links})
 
 
 @app.route("/v1/crawler/task/getcategory", methods=["GET"])