|
@@ -65,6 +65,12 @@ public class PushMessageStrategyV1 implements ReplyStrategyService {
|
|
|
// 0 获取策略key
|
|
|
JSONObject bucketStrategyConfigJsonObject = JSON.parseObject(bucketStrategyConfig);
|
|
|
Set<String> keyedSet = bucketStrategyConfigJsonObject.keySet();
|
|
|
+ if (Objects.equals(StrategyStatusEnum.DEFAULT.status, bucketDataParam.getStrategyStatus())) {
|
|
|
+ // 使用 Stream API 处理集合
|
|
|
+ keyedSet = keyedSet.stream()
|
|
|
+ .map(key -> key + "default")
|
|
|
+ .collect(Collectors.toSet());
|
|
|
+ }
|
|
|
// 1 处理文章--算法引擎--排序文章数据
|
|
|
// getWenzhangData();
|
|
|
// 2 处理小程序--读取离线数据表--获取策略排序小程序数据
|
|
@@ -211,7 +217,6 @@ public class PushMessageStrategyV1 implements ReplyStrategyService {
|
|
|
continue;
|
|
|
}
|
|
|
if (Objects.equals(StrategyStatusEnum.DEFAULT.status, bucketDataParam.getStrategyStatus())) {
|
|
|
- String defaultKey = key + "default";
|
|
|
if (CollectionUtils.isEmpty(bucketDataParam.getVideos())) {
|
|
|
return null;
|
|
|
}
|