浏览代码

feat:热点宝召回修改

zhaohaipeng 1 周之前
父节点
当前提交
9f5b6e179a

+ 1 - 1
recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/flowpool/FlowPoolService.java

@@ -174,7 +174,7 @@ public class FlowPoolService {
             Map<String, Double> douHotLevelWeight = flowPoolConfigService.getDouHotFLowPoolWithLevel();
             for (Map.Entry<String, Double> entry : douHotLevelWeight.entrySet()) {
                 // 从流量池缓存中移除达到分发次数限制的视频ID
-                String itemKey = String.format(RedisKeyConstants.DouHot.ITEM_REDIS_KEY_FORMAT, province, entry.getKey());
+                String itemKey = String.format(RedisKeyConstants.DouHot.ITEM_REDIS_KEY_FORMAT, RecallUtils.douHotProvinceConvert(province), entry.getKey());
                 log.info("[DouHot view distribute count remove cache] key: {}, item: {}", itemKey, needRemoveVideoIds);
                 redisTemplate.opsForZSet().remove(itemKey, needRemoveVideoIds.toArray());
             }