feat:修改logback配置文件

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

@@ -11,12 +11,12 @@ public interface DouHotVideoPortraitDataRepository extends JpaRepository<DouHotV
 
     List<DouHotVideoPortraitData> findAllByVidInAndType(List<String> videoIds, Integer type);
 
-    @Query(value = "SELECT vid, name, option, " +
-            "SUM(CASE WHEN type = 1 THEN value ELSE 0 END) AS rate, " +
-            "SUM(CASE WHEN type = 2 THEN value ELSE 0 END) AS tgi " +
-            "FROM douhot_video_portrait_data " +
-            "WHERE option = 4 " +
-            "GROUP BY vid, name, option " +
-            "HAVING SUM(CASE WHEN type = 2 THEN value ELSE 0 END) >= 100")
-    List<DouHotVideoProvince> findRecordTGIGe100AndRateDesc(List<String> videos);
+    // @Query(value = "SELECT vid, name, option, " +
+    //         "SUM(CASE WHEN type = 1 THEN value ELSE 0 END) AS rate, " +
+    //         "SUM(CASE WHEN type = 2 THEN value ELSE 0 END) AS tgi " +
+    //         "FROM douhot_video_portrait_data " +
+    //         "WHERE option = 4 " +
+    //         "GROUP BY vid, name, option " +
+    //         "HAVING SUM(CASE WHEN type = 2 THEN value ELSE 0 END) >= 100")
+    // List<DouHotVideoProvince> findRecordTGIGe100AndRateDesc(List<String> videos);
 }

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

@@ -10,10 +10,7 @@ import com.tzld.piaoquan.recommend.server.feign.model.FlowPoolResponse;
 import com.tzld.piaoquan.recommend.server.feign.model.FlowPoolVideoInfo;
 import com.tzld.piaoquan.recommend.server.model.TripleConsumer;
 import com.tzld.piaoquan.recommend.server.model.Video;
-import com.tzld.piaoquan.recommend.server.repository.DouHotVideoMapping;
-import com.tzld.piaoquan.recommend.server.repository.DouHotVideoMappingRepository;
-import com.tzld.piaoquan.recommend.server.repository.DouHotVideoPortraitData;
-import com.tzld.piaoquan.recommend.server.repository.DouHotVideoPortraitDataRepository;
+import com.tzld.piaoquan.recommend.server.repository.*;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
@@ -251,6 +248,9 @@ public class FlowPoolService {
                 .flatMap(List::stream)
                 .collect(Collectors.toMap(DouHotVideoPortraitData::getVid, DouHotVideoPortraitData::getName, (o1, o2) -> o1));
 
+        // List<DouHotVideoProvince> recordTGIGe100AndRateDesc = douHotVideoPortraitDataRepository.findRecordTGIGe100AndRateDesc(vidPartition.get(0));
+        // log.info("recordTGIGe100AndRateDesc.size: {}", recordTGIGe100AndRateDesc.size());
+
         Map<Long, String> resultMap = new HashMap<>(videoIdAndVidMap.size());
         for (Map.Entry<Long, String> entry : videoIdAndVidMap.entrySet()) {
             Long videoId = entry.getKey();