...
|
...
|
@@ -80,21 +80,19 @@ public class QueryRecallResultCacheBean extends AbstractCacheBean<RecallParams,R |
|
|
UserPersonalFactorRsp userPersonalFactorRsp = queryUserPersionalFactorBean.queryPersionalFactor(param);
|
|
|
RECALL_NEW_LOGGER.info("QueryRecallResultCacheBean[1]-queryPersionalFactor,cost is [{}]", System.currentTimeMillis()-begin);
|
|
|
//2、构造请求
|
|
|
begin = System.currentTimeMillis();
|
|
|
List<RecallRequest> batchRequests = this.buildBatchRequests(param, userPersonalFactorRsp);
|
|
|
RECALL_NEW_LOGGER.info("QueryRecallResultCacheBean[2]-buildBatchRequests,cost is [{}]", System.currentTimeMillis()-begin);
|
|
|
//3、批量召回
|
|
|
begin = System.currentTimeMillis();
|
|
|
List<CacheRecallRequestRecallResponse> requestResponses = batchRecallCacheBean.batchRecallAndCache(batchRequests);
|
|
|
RECALL_NEW_LOGGER.info("QueryRecallResultCacheBean[3]-batchRecallAndCache,cost is [{}]", System.currentTimeMillis()-begin);
|
|
|
RECALL_NEW_LOGGER.info("QueryRecallResultCacheBean[2]-batchRecallAndCache,cost is [{}]", System.currentTimeMillis()-begin);
|
|
|
//4、获取skn列表[去重]
|
|
|
begin = System.currentTimeMillis();
|
|
|
RecallMergerResult recallMergerResult = recallMergerResultBuilder.buildRecallMergerResult(requestResponses);
|
|
|
RECALL_NEW_LOGGER.info("QueryRecallResultCacheBean[4]-buildRecallMergerResult,cost is [{}]", System.currentTimeMillis()-begin);
|
|
|
RECALL_NEW_LOGGER.info("QueryRecallResultCacheBean[3]-buildRecallMergerResult,cost is [{}]", System.currentTimeMillis()-begin);
|
|
|
//5、构造真实结果[排序,截取skn]
|
|
|
begin = System.currentTimeMillis();
|
|
|
RecallResult recallResult = recallResultBuilder.builderRecallResult(recallMergerResult, param, userPersonalFactorRsp);
|
|
|
RECALL_NEW_LOGGER.info("QueryRecallResultCacheBean[5]-builderRecallResult,cost is [{}]", System.currentTimeMillis()-begin);
|
|
|
RECALL_NEW_LOGGER.info("QueryRecallResultCacheBean[4]-builderRecallResult,cost is [{}]", System.currentTimeMillis()-begin);
|
|
|
return recallResult;
|
|
|
}
|
|
|
|
...
|
...
|
|