update

product.env

@@ -2,6 +2,6 @@ ENV=prod
 
 GEMINI_API_KEY_8=AIzaSyCTFPsbSfESF0Xybm8_qz7st_SH5E7wsdg
 GEMINI_API_KEY_9=AIzaSyAJ8kUcEXRu37SuNx2w5qllaowMcUoPhoU
-GEMINI_API_KEY_1=AIzaSyC-2Es4bk1uE-6u3lW5AOQuGqXWNzb92eQ
-GEMINI_API_KEY_2=AIzaSyD6R8tIOO11yh6WOXVQMBA2wzSZiREGUrA
+GEMINI_API_KEY_1=AIzaSyCOytzMj28Z2u8JXrzptACJp21qOapeasg
+GEMINI_API_KEY_2=AIzaSyCmLB67QIPwXznMnIe72vhyU-3wTPes_JU
 GEMINI_API_KEY_3=AIzaSyAwGqthDADh5NPVe3BMcOJBQkJaf0HWBuQ

utils/piaoquan.py

@@ -126,6 +126,72 @@ class PQ:
         requests.request("POST", url, headers=headers, data=payload)
 
 
+    @classmethod
+    def get_pd_id(cls, video_id: str):
+        """获取封面id"""
+        url = "https://admin.piaoquantv.com/manager/video/multiTitleV2/listV2?muid=999"
+
+        payload = json.dumps({
+            "videoId": video_id,
+            "range": "4h"
+        })
+        headers = {
+            'accept': 'application/json',
+            'accept-language': 'zh-CN,zh;q=0.9',
+            'cache-control': 'no-cache',
+            'content-type': 'application/json',
+            'cookie': 'SESSION=YjVlOTI0ZWMtN2JkMy00MWIyLTk1NWItNmY5NTFlYjgxNjAy',
+            'origin': 'https://admin.piaoquantv.com',
+            'pragma': 'no-cache',
+            'priority': 'u=1, i',
+            'sec-ch-ua-mobile': '?0',
+            'sec-ch-ua-platform': '"macOS"',
+            'sec-fetch-dest': 'empty',
+            'sec-fetch-mode': 'cors',
+            'sec-fetch-site': 'same-origin'
+        }
+        response = requests.request("POST", url, headers=headers, data=payload)
+        response = response.json()
+        code = response['code']
+        if code != 0:
+            return None
+        pq_id = response['content'][0]['id']
+        return pq_id
+
+
+    @classmethod
+    def update_pq_title(cls ,video_id: str, new_title: str):
+        pq_id = cls.get_pd_id(video_id)
+        if not pq_id:
+            return
+        url = "https://admin.piaoquantv.com/manager/video/multiTitleV2/update?muid=999"
+        payload = json.dumps([
+            {
+                "id": pq_id,
+                "title": new_title,
+                "videoId": video_id,
+                "distributionWeight": 1000,
+                "shareWeight": 1000
+            }
+        ])
+        headers = {
+            'accept': 'application/json',
+            'accept-language': 'zh-CN,zh;q=0.9',
+            'content-type': 'application/json',
+            'cookie': 'SESSION=YjVlOTI0ZWMtN2JkMy00MWIyLTk1NWItNmY5NTFlYjgxNjAy',
+            'origin': 'https://admin.piaoquantv.com',
+            'priority': 'u=1, i',
+            'sec-ch-ua-mobile': '?0',
+            'sec-ch-ua-platform': '"macOS"',
+            'sec-fetch-dest': 'empty',
+            'sec-fetch-mode': 'cors',
+            'sec-fetch-site': 'same-origin',
+        }
+
+        response = requests.request("POST", url, headers=headers, data=payload)
+        response = response.json()
+        code = response['code']
+        return code
 
 
 

workers/consumption_work.py

@@ -51,23 +51,27 @@ class ConsumptionRecommend(object):
             logger.error(f"[处理] 口播文案通过gpt无法生成标题")
             return
         logger.info(f"[处理] 口播文案通过gpt生成标题完成，{new_title}")
-        n_id = "78354423"
-        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"[处理] 视频写入标签成功")
+        # 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"[处理] 视频写入标签成功")
         current_time = datetime.now()
         formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
         logger.info(f"[处理] 开始写入飞书表格")
-        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)
+        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)
         time.sleep(0.5)
-        Feishu.update_values("JY4esfYvShLbTkthHEqcTw5qnsh", "qFpmD4", "A2:Z2", values)
+        Feishu.update_values("JY4esfYvShLbTkthHEqcTw5qnsh", "hpNlXt", "A2:Z2", values)
         logger.info(f"[处理] 写入飞书表格成功")
 
 

workers/select_work.py

@@ -39,7 +39,7 @@ class StartGetRecommend(object):
 async def run():
     scheduler = AsyncIOScheduler()
     try:
-        scheduler.add_job(StartGetRecommend.run, trigger=CronTrigger(minute=50, second=0))  # 每小时获取一次
+        scheduler.add_job(StartGetRecommend.run, trigger=CronTrigger(minute=55, second=0))  # 每小时获取一次
         scheduler.start()
         await asyncio.Event().wait()
     except KeyboardInterrupt: