feat:修改定时任务

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

@@ -256,15 +256,14 @@ public class FlowPoolService {
         // 按vid和name分组，并取每组TGI倒排前10条
         Map<String, List<String>> vidAndProvinceListMap = douHotVideoProvince.stream()
                 .collect(Collectors.groupingBy(
-                        DouHotVideoProvince::getVid,
+                        DouHotVideoProvince::getVid,  // 按 vid 分组
-                        Collectors.mapping(
+                        Collectors.collectingAndThen(
-                                DouHotVideoProvince::getName,
+                                Collectors.toList(),
-                                Collectors.collectingAndThen(
+                                list -> list.stream()
-                                        Collectors.toList(),
+                                        .sorted(Comparator.comparingDouble(DouHotVideoProvince::getTgi).reversed()) // 按 tgi 降序
-                                        list -> list.stream()
+                                        .limit(10) // 取前10个
-                                                .distinct()  // 去重
+                                        .map(DouHotVideoProvince::getName) // 只取 name 字段
-                                                .collect(Collectors.toList())
+                                        .collect(Collectors.toList())
-                                )
                         )
                 ));
         vidAndProvinceListMap.forEach((key, value) -> log.info("[DouHot vid and province mapping]: vid: {}, province: {}", key, value));