소스 검색

update 创建任务接口数据类型转换

kk 2 년 전
부모
커밋
f1b388a60c
1개의 변경된 파일21개의 추가작업 그리고 4개의 파일을 삭제
  1. 21 4
      server/conf_task.py

+ 21 - 4
server/conf_task.py

@@ -68,13 +68,23 @@ def insertTask():
             return jsonify({'code': 200, 'message': '名单重复', 'repeat_list': exist_outer_info})
 
         # 字段转换
+
+        tag_name_list = []
+        content_tag_list = []
+        user_tag = data['user_tag']
+        user_content_tag = data['user_content_tag']
+
+        for tag in user_tag:
+            tag_name_list.append(tag['tagName'])
+        for tag in user_content_tag:
+            content_tag_list.append(tag['tagName'])
         data['min_publish_time'] = int(data['min_publish_time'] / 1000)
         data['next_time'] = int(data['next_time'] / 1000)
         data['insert_time'] = int(time.time())
         data['update_time'] = int(time.time())
         data['spider_link'] = str(data['spider_link'])
-        data['user_tag'] = ','.join(data['user_tag']) if data['user_tag'] else '',
-        data['user_content_tag'] = ','.join(data['user_content_tag']) if data['user_content_tag'] else '',
+        data['user_tag'] = ','.join(tag_name_list) if tag_name_list else '',
+        data['user_content_tag'] = ','.join(content_tag_list) if content_tag_list else '',
         # 获取到一个以键且为逗号分隔的字符串,返回一个字符串
         keys = ','.join(data.keys())
         values = ','.join(['%s'] * len(data))
@@ -188,6 +198,13 @@ def createUser():
                 success_list.append(author_url)
                 continue
             else:
+                tag_name_list = []
+                content_tag_list = []
+
+                for tag in user_tag:
+                    tag_name_list.append(tag['tagName'])
+                for tag in user_content_tag:
+                    content_tag_list.append(tag['tagName'])
                 data = dict(
                     spider_link=author_url,
                     media_id=media_id,
@@ -195,8 +212,8 @@ def createUser():
                     task_type=task_type,
                     applets_status=applets_status,
                     app_status=app_status,
-                    user_tag=','.join(user_tag) if user_tag else '',
-                    user_content_tag=','.join(user_content_tag) if user_content_tag else '',
+                    user_tag=','.join(tag_name_list) if tag_name_list else '',
+                    user_content_tag=','.join(content_tag_list) if content_tag_list else '',
                     insert_time=int(time.time()),
                     update_time=int(time.time())
                 )