增加汤普森逻辑

ad-engine-server/src/main/resources/feeds_score_config_thompson.conf

@@ -1,9 +1,4 @@
 scorer-config = {
-  tf-ctr-score-config = {
-    scorer-name = "com.tzld.piaoquan.ad.engine.service.score.VlogAdThompsonScorer"
-    scorer-priority = 99
-    model-path = "ad_thompson_model/model_ad_thompson.txt"
-  }
 
   tf-ecpm-merge-config = {
         scorer-name = "com.tzld.piaoquan.ad.engine.service.score.VlogMergeEcpmScorer"

ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/score/VlogAdThompsonScorer.java

@@ -96,8 +96,8 @@ public class VlogAdThompsonScorer extends BaseThompsonSamplingScorer {
             LOGGER.error("score error for doc={} exception={}", new Object[]{
                     item.getAdId(), ExceptionUtils.getFullStackTrace(e)});
         }
-        item.setCtr(pctr);
-        item.setCvr(pcvr);
+        item.setTf_ctr(pctr);
+        item.setTf_cvr(pcvr);
         item.setEcpm1(ecpm);
         item.setScore(ecpm);
         return ecpm;

ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/score/VlogMergeEcpmScorer.java

@@ -51,6 +51,7 @@ public class VlogMergeEcpmScorer extends BaseLRModelScorer {
                 double bid2 = item.getBid2();
                 double pctr = isTfType?item.getTf_ctr():item.getCtr();
                 double pcvr = isTfType?item.getTf_cvr():item.getCvr();
+                item.setScore_type( isTfType?1:0);
                 //todo
                 double ecpm = cpa * bid1 * bid2 * pcvr * pctr * 1000d;
 //                double ecpm = cpa * bid1 * bid2 * pcvr * pctr;
@@ -60,7 +61,7 @@ public class VlogMergeEcpmScorer extends BaseLRModelScorer {
                 LOGGER.error("merge Ecpm Score: {} error", "");
                 item.setCtr(0.0);
             }
-            LOGGER.debug("merge Ecpm ranker , score: {}->{}", "");
+            LOGGER.debug("merge Ecpm ranker , score: {}->{}", item.getScore());
         }
         Collections.sort(items);
         return items;