|
@@ -1,7 +1,6 @@
|
|
package com.tzld.piaoquan.recommend.server.service.filter;
|
|
package com.tzld.piaoquan.recommend.server.service.filter;
|
|
|
|
|
|
import com.ctrip.framework.apollo.spring.annotation.ApolloJsonValue;
|
|
import com.ctrip.framework.apollo.spring.annotation.ApolloJsonValue;
|
|
-import com.google.common.base.Stopwatch;
|
|
|
|
import com.google.common.collect.Lists;
|
|
import com.google.common.collect.Lists;
|
|
import com.tzld.piaoquan.recommend.server.common.ThreadPoolFactory;
|
|
import com.tzld.piaoquan.recommend.server.common.ThreadPoolFactory;
|
|
import com.tzld.piaoquan.recommend.server.service.PreViewedService;
|
|
import com.tzld.piaoquan.recommend.server.service.PreViewedService;
|
|
@@ -119,7 +118,7 @@ public abstract class AbstractFilterService {
|
|
for (final List<Long> ids : chunks) {
|
|
for (final List<Long> ids : chunks) {
|
|
Future<List<Long>> future = pool.submit(() ->
|
|
Future<List<Long>> future = pool.submit(() ->
|
|
viewedService.filterViewedVideo(param.getAppType(), param.getMid(), param.getUid(), ids, param.getCityCode(),
|
|
viewedService.filterViewedVideo(param.getAppType(), param.getMid(), param.getUid(), ids, param.getCityCode(),
|
|
- param.getAbExpCodes(), param.getHotSceneType()));
|
|
|
|
|
|
+ param.getAbExpCodes(), param.getHotSceneType(), param.getClientIp()));
|
|
futures.add(future);
|
|
futures.add(future);
|
|
}
|
|
}
|
|
try {
|
|
try {
|
|
@@ -150,7 +149,7 @@ public abstract class AbstractFilterService {
|
|
return videoIds;
|
|
return videoIds;
|
|
}
|
|
}
|
|
return viewedService.filterViewedVideo(param.getAppType(), param.getMid(), param.getUid(), videoIds, param.getCityCode(),
|
|
return viewedService.filterViewedVideo(param.getAppType(), param.getMid(), param.getUid(), videoIds, param.getCityCode(),
|
|
- param.getAbExpCodes(), param.getHotSceneType());
|
|
|
|
|
|
+ param.getAbExpCodes(), param.getHotSceneType(), param.getClientIp());
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|