817实验不走保量

ad-engine-commons/src/main/java/com/tzld/piaoquan/ad/engine/commons/param/RankRecommendRequestParam.java

@@ -6,6 +6,7 @@ import lombok.EqualsAndHashCode;
 import lombok.ToString;
 
 import java.util.List;
+import java.util.Map;
 
 @Data
 @EqualsAndHashCode(callSuper = true)
@@ -17,4 +18,5 @@ public class RankRecommendRequestParam extends RecommendRequestParam{
      String rootSessionId;
      String rootSourceId;
      Boolean isFilterUser;
+     Map<String,Object> engineInfo;
 }

ad-engine-commons/src/main/java/com/tzld/piaoquan/ad/engine/commons/score/ScoreParam.java

@@ -30,5 +30,7 @@ public class ScoreParam {
     private String expCode;
 
     private Boolean isFilterUser;
+
+    Map<String,Object> engineInfo;
 }
 

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

@@ -1,6 +1,7 @@
 package com.tzld.piaoquan.ad.engine.service.score.convert;
 
 import com.tzld.piaoquan.ad.engine.commons.dto.AdPlatformCreativeDTO;
+import com.tzld.piaoquan.ad.engine.commons.param.RankRecommendRequestParam;
 import com.tzld.piaoquan.ad.engine.commons.param.RecommendRequestParam;
 import com.tzld.piaoquan.ad.engine.commons.score.ScoreParam;
 import com.tzld.piaoquan.ad.engine.commons.util.AbUtil;
@@ -45,6 +46,9 @@ public class RequestConvert {
         // 本次命中的实验
         String expCode = AbUtil.chooseAdAlgExpCode(expCodeSet, request.getAppType(), request.getNewExpGroup());
         scoreParam.setExpCode(expCode);
+        if (request instanceof RankRecommendRequestParam) {
+            scoreParam.setEngineInfo(((RankRecommendRequestParam) request).getEngineInfo());
+        }
         return scoreParam;
     }
 

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

@@ -431,6 +431,10 @@ public abstract class RankStrategyBasic implements RankStrategy {
 
 
     protected boolean getIsGuaranteedFlow(ScoreParam scoreParam) {
+        // 817实验不要保量
+        if( scoreParam.getEngineInfo() != null && "817".equals(scoreParam.getEngineInfo().get("model"))){
+            return false;
+        }
         if (System.currentTimeMillis() < guaranteeSwitchingTime) {
             return scoreParam.getExpCodeSet().contains(guaranteeExp);
         }