zhangyong 2 months ago
parent
commit
8ec10bbe93
1 changed files with 16 additions and 16 deletions
  1. 16 16
      workers/consumption_work.py

+ 16 - 16
workers/consumption_work.py

@@ -51,27 +51,27 @@ class ConsumptionRecommend(object):
             logger.error(f"[处理] 口播文案通过gpt无法生成标题")
             return
         logger.info(f"[处理] 口播文案通过gpt生成标题完成,{new_title}")
-        # n_id = "78354423"
-        # logger.info(f"[处理] 开始写入票圈后台")
-        logger.info(f"[处理] 开始修改票圈后台标题")
-        PQ.update_pq_title(video_id, new_title)
-        logger.info(f"[处理] 修改票圈后台标题成功")
+        n_id = "78354423"
+        logger.info(f"[处理] 开始写入票圈后台")
+        # logger.info(f"[处理] 开始修改票圈后台标题")
+        # PQ.update_pq_title(video_id, new_title)
+        # logger.info(f"[处理] 修改票圈后台标题成功")
 
-        # code_vid = PQ.install_tj_pq(video_id, video_path, new_title, n_id, cover_path)
-        # if not code_vid:
-        #     logger.error(f"[处理] 写入票圈后台失败")
-        #     return
-        # logger.info(f"[处理] 写入票圈后台成功,视频id:{code_vid}")
-        # tag = f"lev-供给,rol-机器,#str-内容理解优化标题_51,{video_id}"
-        # PQ.video_tag(code_vid,tag)
-        # logger.info(f"[处理] 视频写入标签成功")
+        code_vid = PQ.install_tj_pq(video_id, video_path, new_title, n_id, cover_path)
+        if not code_vid:
+            logger.error(f"[处理] 写入票圈后台失败")
+            return
+        logger.info(f"[处理] 写入票圈后台成功,视频id:{code_vid}")
+        tag = f"lev-供给,rol-机器,#str-内容理解优化标题_51,{video_id}"
+        PQ.video_tag(code_vid,tag)
+        logger.info(f"[处理] 视频写入标签成功")
         current_time = datetime.now()
         formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
         logger.info(f"[处理] 开始写入飞书表格")
-        values = [[video_id,f"https://admin.piaoquantv.com/cms/post-detail/{video_id}/detail",old_title,new_title,task['channel'],task["time"],task["partition"],formatted_time]]
-        Feishu.insert_columns("JY4esfYvShLbTkthHEqcTw5qnsh", "hpNlXt", "ROWS", 1, 2)
+        values = [[video_id, code_vid ,f"https://admin.piaoquantv.com/cms/post-detail/{code_vid}/detail",old_title,new_title,task['channel'],task["time"],task["partition"],formatted_time]]
+        Feishu.insert_columns("JY4esfYvShLbTkthHEqcTw5qnsh", "qFpmD4", "ROWS", 1, 2)
         time.sleep(0.5)
-        Feishu.update_values("JY4esfYvShLbTkthHEqcTw5qnsh", "hpNlXt", "A2:Z2", values)
+        Feishu.update_values("JY4esfYvShLbTkthHEqcTw5qnsh", "qFpmD4", "A2:Z2", values)
         logger.info(f"[处理] 写入飞书表格成功")