|
@@ -269,7 +269,10 @@ def insertTask():
|
|
|
task_id = mysql_con.insert_values(sql, tuple(data.values()))
|
|
|
if task_id:
|
|
|
spider_link = user_data['spider_link']
|
|
|
- success_list, fail_list = create_uid(user_data, task_id, spider_link)
|
|
|
+ success_list, fail_list, repeat_list = create_uid(user_data, task_id, spider_link)
|
|
|
+ if repeat_list:
|
|
|
+ message = f'该任务和其他任务抓取名单重复:{repeat_list}'
|
|
|
+ return jsonify({'code':200, 'message':message})
|
|
|
return jsonify(
|
|
|
{'code': 200, 'message': 'task create success', 'success_list': success_list, 'fail_list': fail_list})
|
|
|
except Exception as e:
|
|
@@ -511,8 +514,7 @@ def create_uid(task, task_id, spider_link):
|
|
|
else:
|
|
|
create_user_list.append(author_url)
|
|
|
if repeat_list:
|
|
|
- message = f'该任务和其他任务抓取名单重复:{repeat_list}'
|
|
|
- return jsonify({'code': 400, 'message': message})
|
|
|
+ return success_list, fail_list, repeat_list
|
|
|
else:
|
|
|
for author_url in create_user_list:
|
|
|
|