@@ -79,7 +79,7 @@ public class UnionThompsonSamplingScore extends BaseThompsonSamplingScorer {
try {
pctr = model.ctrScore(item);
pcvr = model.cvrScore(item);
- ecpm = item.getCpa() * pctr * pcvr;
+ ecpm = item.getCpa() * pctr * pcvr * item.getBid1() * item.getBid2();
} catch (
Exception e) {
LOGGER.error("score error for doc={} exception={}",
@@ -475,6 +475,7 @@ public class RankServiceImpl implements RankService {
item.setAdId(dto.getCreativeId());
item.setItemFeature(new AdItemFeature());
item.setMediaId(request.getMediaId());
+ item.setCpa(dto.getCpa());
rankItems.add(item);
}
rankResult = rank(param, null, rankItems, ScorerUtils.UNION_THOMPSON_CONF);