recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/repository/DouHotVideoPortraitDataRepository.java

@@ -18,7 +18,8 @@ public interface DouHotVideoPortraitDataRepository extends JpaRepository<DouHotV
             "SUM(CASE WHEN d.type = 2 THEN d.value ELSE 0 END)" +
             ") FROM DouHotVideoPortraitData d " +
             "WHERE d.option = 4 AND d.vid IN (:videos) " +
-            "GROUP BY d.vid, d.name, d.option " +
-            "HAVING SUM(CASE WHEN d.type = 2 THEN d.value ELSE 0 END) >= 100")
+            "GROUP BY d.vid, d.name, d.option "
+            // + "HAVING SUM(CASE WHEN d.type = 2 THEN d.value ELSE 0 END) >= 100"
+    )
     List<DouHotVideoProvince> findRecordTGIGe100AndRateDesc(@Param("videos") List<String> videos);
 }

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

@@ -273,7 +273,9 @@ public class FlowPoolService {
                                 Collectors.toList(),
                                 list -> list.stream()
                                         .sorted(Comparator.comparingDouble(DouHotVideoProvince::getRate).reversed()) // 按 占比 降序
-                                        .limit(10) // 取前10个
+                                        .limit(3) // 取前10个
+                                        .sorted(Comparator.comparingDouble(DouHotVideoProvince::getTgi).reversed()) // 按 TGI 降序
+                                        .limit(1) // 取第一个
                                         .collect(Collectors.toMap(i -> RecallUtils.douHotProvinceConvert(i.getName()), DouHotVideoProvince::getTgi, (o1, o2) -> o1)))
                         )
                 );