Bladeren bron

error fix

jihuaqiang 3 weken geleden
bovenliggende
commit
c220ef30da
1 gewijzigde bestanden met toevoegingen van 11 en 1 verwijderingen
  1. 11 1
      workers/video_insight_trigger_work.py

+ 11 - 1
workers/video_insight_trigger_work.py

@@ -111,8 +111,18 @@ class ConsumptionRecommend(object):
         values = []
         link = f"""https://admin.piaoquantv.com/cms/post-detail/{video_id}/detail"""
         entry = data
+        
+        # 处理视频选题与要点理解
+        analysis_summary = json.dumps(entry.get('视频选题与要点理解', {}), ensure_ascii=False)
+        analysis_timeline = json.dumps(entry.get('视频分段与时间点分析', {}), ensure_ascii=False)
+        
+        # 使用参数化查询来避免 SQL 注入和转义问题
         value = f"""(
-            {video_id}, '{link}', '{video_title}', {MysqlHelper.escape_string(entry.get('视频选题与要点理解', ''))}, '{entry.get('视频分段与时间点分析', '')}'
+            {video_id}, 
+            '{link}', 
+            '{video_title.replace("'", "''")}', 
+            '{analysis_summary.replace("'", "''")}', 
+            '{analysis_timeline.replace("'", "''")}'
         )"""
         values.append(value)
         # Combine SQL statement and values