jihuaqiang 1 mês atrás
pai
commit
b16eec3aaa
1 arquivos alterados com 3 adições e 3 exclusões
  1. 3 3
      workers/video_insight_consumption_work.py

+ 3 - 3
workers/video_insight_consumption_work.py

@@ -65,7 +65,7 @@ class ConsumptionRecommend(object):
         sql = """
         INSERT INTO video_demand_analysis (
             video_id, video_link, video_title, content_type,
-            demand_order, demand_score, user_demand, demand_category, demand_time,
+            demand_order, demand_score, user_demand, demand_category, demand_show_time,
             demand_reason, product_hook, hook_time, hook_desc,
             hook_type, landing_desc, landing_type, platform_case, reasoning_process,audit_status,audit_desc
         ) VALUES
@@ -73,7 +73,7 @@ class ConsumptionRecommend(object):
         # Add values for each entry
         values = []
         link = f"""https://admin.piaoquantv.com/cms/post-detail/{video_id}/detail"""
-        for entry in data:
+        for index, entry in enumerate(data, 1):  # Start from 1 to match the original numbering
 
             hook_desc = entry.get('需求钩子话术', '')
             result,msg = Security.security(hook_desc)
@@ -86,7 +86,7 @@ class ConsumptionRecommend(object):
 
             value = f"""(
                 {video_id}, '{link}', '{video_title}', NULL,
-                '{entry.get('需求排序序号', '')}', '{entry.get('需求强烈程度分值', '')}', '{entry.get('用户具体的需求描述', '')}', '{entry.get('需求分类', '')}', '{entry.get('需求钩子出现时间', '')}',
+                '{index}', '{entry.get('需求强烈程度分值', '')}', '{entry.get('用户具体的需求描述', '')}', '{entry.get('需求分类', '')}', '{entry.get('需求钩子出现时间', '')}',
                 '{entry.get('推测出该点需求的原因', '')}', '{entry.get('需求详细query', '')}', '', '{entry.get('需求钩子话术', '')}',
                 '', '{entry.get('落地方案形态描述', '')}', '{entry.get('落地方案类型', '')}', '', '','{audit_status}','{audit_desc}'
             )"""