投流sourceId增加账号特征

applications/deal/recall_deal.py

@@ -44,8 +44,9 @@ class RecallDeal(object):
         }
         return response
 
-    def create_gzh_path(self, video_id, shared_uid):
+    def create_gzh_path(self, video_id, shared_uid, gh_id):
         """
+        :param gh_id: 公众号账号的gh_id
         :param video_id: 视频 id
         :param shared_uid: 分享 id
         """
@@ -62,7 +63,7 @@ class RecallDeal(object):
 
         root_share_id = str(uuid.uuid4())
         if self.mini_program_type == 2:
-            source_id = "touliu_tencentGzhArticle_" + generate_source_id()
+            source_id = "touliu_tencentGzhArticle_{}_".format(gh_id) + generate_source_id()
         elif self.mini_program_type == 1:
             source_id = "longArticles_" + generate_source_id()
         else:
@@ -93,7 +94,7 @@ class RecallDeal(object):
             programName = "刷刷有趣生活"
         return programAvatar, programId, programName
 
-    async def generate_card(self, video_id, kimi_title, index):
+    async def generate_card(self, video_id, kimi_title, index, gh_id):
         """
         生成分享卡片
         :return:
@@ -104,7 +105,7 @@ class RecallDeal(object):
         videoUrl = response['data'][0]['videoPath']
         user_id = response['data'][0]['user']['uid']
         programAvatar, programId, programName = self.choose_mini_program()
-        root_share_id, source_id, productionPath = self.create_gzh_path(video_id, user_id)
+        root_share_id, source_id, productionPath = self.create_gzh_path(video_id, user_id, gh_id)
         source = "Web"
         logging(
             code="1002",
@@ -180,7 +181,7 @@ class RecallDeal(object):
             L = []
             unEmptyList = [i for i in response['vid_list'] if i]
             for index, best_video_id in enumerate(unEmptyList, 1):
-                card = await self.generate_card(best_video_id, response.get("kimi_title"), index)
+                card = await self.generate_card(best_video_id, response.get("kimi_title"), index, response['gh_id'])
                 L.append(card)
             if L:
                 result = {