离线更新画像时同时更新画像的状态

eda/smart_rank/dist_update_user_portrait_service.py

@@ -103,12 +103,19 @@ def get_user_service_portrait(cl_id, all_word_tags, all_tag_tag_type, all_3tag_2
             redis_client.hmset(cl_id_portrait_key3, gmkv_tag_score3_sum_dict)
             redis_client.expire(cl_id_portrait_key3, time=30 * 24 * 60 * 60)
 
-            # 记录用户画像更新了的flag
+            # 记录用户画像更新了的flag,以及用户最新行为信息
             device_latest_action_key = "device:latest:action:tag:names:update:flag" + str(cl_id)
             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)
+            # 如果该用户不存在最新行为的标签，则用分数最低的标签代替，且更新该用户的最新行为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))
+                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)
 
             # 写tidb，redis同步
             stat_date = datetime.datetime.today().strftime('%Y-%m-%d')