首页feed接口合并，更新用户画像行为状态

eda/smart_rank/dist_update_user_portrait_service.py

@@ -86,17 +86,21 @@ def get_user_service_portrait(cl_id, all_word_tags, all_tag_tag_type, all_3tag_2
 
             # 记录用户画像更新了的flag,以及用户最新行为信息
             device_latest_action_key = "device:latest:action:tag:names:update:flag" + str(cl_id)
+            set_dict = dict()
             card_types = ['diary', 'qa', 'topic']
             for card_type in card_types:
                 field_name = "user_portrait_is_change_" + card_type
-                redis_client.hset(device_latest_action_key, field_name, 1)
+                set_dict.update({field_name: 1})
+            set_dict.update({'user_portrait_is_change': 1})
             # 如果该用户不存在最新行为的标签，则用分数最低的标签代替，且更新该用户的最新行为flag
             if not redis_client.hexists(device_latest_action_key, 'latest_action_tags'):
                 tag = [min(gmkv_tag_score3_sum_dict, key=gmkv_tag_score3_sum_dict.get)]
-                redis_client.hset(device_latest_action_key, "latest_action_tags", json.dumps(tag))
+                set_dict.update({"latest_action_tags": json.dumps(tag)})
                 for card_type in card_types:
                     action_field_name = "latest_action_is_change_" + card_type
-                    redis_client.hset(device_latest_action_key, action_field_name, 1)
+                    set_dict.update({action_field_name: 1})
+                set_dict.update({'latest_action_is_change': 1})
+            redis_client.hmset(device_latest_action_key, set_dict)
 
             # 写tidb，redis同步
             stat_date = datetime.datetime.today().strftime('%Y-%m-%d')