|
@@ -6,6 +6,7 @@ import com.tzld.piaoquan.recommend.server.service.filter.FlowPoolWithLevelFilter
|
|
|
import com.tzld.piaoquan.recommend.server.service.recall.FilterParamFactory;
|
|
|
import com.tzld.piaoquan.recommend.server.service.recall.RecallParam;
|
|
|
import com.tzld.piaoquan.recommend.server.service.recall.RecallStrategy;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.collections4.CollectionUtils;
|
|
|
import org.apache.commons.lang3.RandomUtils;
|
|
|
import org.apache.commons.lang3.math.NumberUtils;
|
|
@@ -22,6 +23,7 @@ import java.util.Map;
|
|
|
/**
|
|
|
* @author dyp
|
|
|
*/
|
|
|
+@Slf4j
|
|
|
public abstract class AbstractFlowPoolWithLevelRecallStrategy implements RecallStrategy {
|
|
|
@Autowired
|
|
|
@Qualifier("redisTemplate")
|
|
@@ -38,6 +40,7 @@ public abstract class AbstractFlowPoolWithLevelRecallStrategy implements RecallS
|
|
|
int getSize = param.getSize() * 5;
|
|
|
List<Video> results = new ArrayList<>();
|
|
|
List<String> data = redisTemplate.opsForSet().randomMembers(flowPoolKey, getSize);
|
|
|
+ log.info("supply flowpool flowPoolKey = {} level = {} data = {}", flowPoolKey, level, data);
|
|
|
if (CollectionUtils.isEmpty(data)) {
|
|
|
return null;
|
|
|
}
|