get_highlight_v2

data_sync/answer/transfer.py

@@ -203,16 +203,16 @@ def get_answers(pks):
             # 首页精选增加内容分类 明星列表和网红列表
             tagv4 = answer.get_answer_tagv4_names(answer_id=answer.id)
             if tagv4:
-                tags_info = answer.get_answer_tag(tagv4)
+                tags_info = answer.get_om_answer_tags_info(ids=tagv4)
                 item['selected_stars'] = []
                 item['selected_internet_celebrity'] = []
                 all_tags = []
                 for tag in tags_info:
                     all_tags.append(tag.get("id", None))
-                    if tag.get("id", 0) in (15928, 10682):
-                        item['selected_stars'].append(tag.get("tag_name", None))
-                    elif tag.get("id", 0) in (15930, 10683):
-                        item['selected_internet_celebrity'].append(tag.get("tag_name", None))
+                    if tag.get("tag_type", 0) == TAG_TYPE.STAR:
+                        item['selected_stars'].append(tag.get("name", None))
+                    elif tag.get("tag_type", 0) == TAG_TYPE.INFLUENCER:
+                        item['selected_internet_celebrity'].append(tag.get("name", None))
                     else:
                         pass
                     if tag.get("id") == 14288:

data_sync/tractate/transfer.py

@@ -254,20 +254,21 @@ def get_tractate(pks):
             # 首页精选增加内容分类 明星列表和网红列表
             tagv4 = tractate.get_tractate_tagv4_names(tractate_id=tractate.id)
             if tagv4:
-                tags_info = tractate.get_tag(list(tagv4))
+                tags_info = tractate.get_om_tags_info(ids=tagv4);
                 item['selected_stars'] = []
                 item['selected_internet_celebrity'] = []
                 all_tags = []
                 for tag in tags_info:
                     all_tags.append(tag.get("id", None))
-                    if tag.get("id", 0) in (15928, 10682):
-                        item['selected_stars'].append(tag.get("tag_name", None))
-                    elif tag.get("id", 0) in (15930, 10683):
-                        item['selected_internet_celebrity'].append(tag.get("tag_name", None))
+                    if tag.get("tag_type", 0) ==TAG_TYPE.STAR:
+                        item['selected_stars'].append(tag.get("name", None))
+                    elif tag.get("tag_type", 0) ==TAG_TYPE.INFLUENCER:
+                        item['selected_internet_celebrity'].append(tag.get("name", None))
                     else:
                         pass
                     if tag.get("id") == 14288:
                         item['operators_add_tags'].append(14288)
+
                 if 15928 in all_tags:
                     item['selected_content_type'] = SELECTED_CONTENT_TYPE.BEAUTY_STAR
                 elif 10682 in all_tags:

qa/models/answer.py

@@ -29,6 +29,7 @@ from gm_types.mimas import (
 from gm_types.mimas.qa import CONTENT_CLASS, VIDEO_SOURCE_TYPE
 from gm_types.push import AUTOMATED_PUSH
 from gm_upload import ImgUrlField, IMG_TYPE
+from talos.rpc import get_current_rpc_invoker
 
 from talos.services import UserConvertService
 from talos.services.tag_v3 import TagV3Service
@@ -1124,6 +1125,16 @@ class Answer(models.Model):
             logging.error("catch exception,err_msg:%s" % traceback.format_exc())
             return []
 
+    def get_om_answer_tags_info(self, ids):
+        r = get_current_rpc_invoker()
+        try:
+            res_list = []
+            result = r['pims/catalog/usertags/ids2tag'](ids=ids).unwrap()
+            res_list = result.get("result", [])
+        except Exception:
+            return []
+        return res_list
+
 
 class SendAnswer(models.Model):
     class Meta:

talos/models/tractate/tractate.py

@@ -32,6 +32,7 @@ from gm_types.gaia import (
 from talos.cache.base import tractate_pv_cache, tractate_favor_count_cache, tractate_vote_count_cache
 from utils.rpc import RPCMixin
 from utils.pic import PictureTools
+from talos.rpc import get_current_rpc_invoker
 
 doris_redis_client = redis.StrictRedis.from_url(settings.REDIS_URL)
 
@@ -323,6 +324,16 @@ class Tractate(models.Model):
             logging.error("catch exception,err_msg:%s" % traceback.format_exc())
             return []
 
+    def get_om_tags_info(self, ids):
+        r = get_current_rpc_invoker()
+        try:
+            res_list = []
+            result = r['pims/catalog/usertags/ids2tag'](ids=ids).unwrap()
+            res_list = result.get("result", [])
+        except Exception:
+            return []
+        return res_list
+
     def get_tag_names(self, tag_list):
         try:
             association_tags_id_list = list()