update

utils/piaoquan.py

@@ -104,10 +104,12 @@ class PQ:
                     data = response['data']
                     video_path = data["videoPath"]
                     cover_path = data["coverImgPath"]
-                    return video_path, cover_path
-            return None, None
+                    title = data["title"]
+
+                    return video_path, cover_path, title
+            return None, None, None
         except Exception as e:
-            return None, None
+            return None, None, None
 
     @classmethod
     def video_tag(cls, pq_id: str, tag: str):

workers/consumption_work.py

@@ -29,7 +29,7 @@ class ConsumptionRecommend(object):
         logger.info(f"[处理] 获取redis数据{task}")
         video_id = task['video_id']
         logger.info(f"[处理] 开始获取原视频OSS地址")
-        video_path, cover_path = PQ.get_pq_oss(video_id)
+        video_path, cover_path, old_title = PQ.get_pq_oss(video_id)
         if not video_path:
             return
         logger.info(f"[处理] 获取原视频OSS地址，视频链接:{video_path},封面链接:{cover_path}")
@@ -64,7 +64,7 @@ class ConsumptionRecommend(object):
         current_time = datetime.now()
         formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
         logger.info(f"[处理] 开始写入飞书表格")
-        values = [[video_id,code_vid,new_title,task['channel'],task["time"],task["partition"],formatted_time]]
+        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", "qFpmD4", "A2:Z2", values)