增加权重

ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/predict/container/PredictPidContainer.java

@@ -126,7 +126,9 @@ public class PredictPidContainer {
                 try {
                     String[] cols=line.split(",");
                     String group=cols[0].trim();
-                    latestThresholdCache.put(group,Double.parseDouble(cols[4].trim()));
+                    if(group!=null&&cols[4].trim()!=null){
+                        latestThresholdCache.put(group,Double.parseDouble(cols[4].trim()));
+                    }
                 }catch (Exception e){
                     e.printStackTrace();
                 }

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

@@ -22,9 +22,11 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
+import javax.annotation.PostConstruct;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 @Service
@@ -42,6 +44,13 @@ public class RankServiceImpl implements RankService {
     @Value("${ad.model.cpm.min:30}")
     Double cpmMin=30d;
 
+    static Map<String,Double> bidMap=new HashMap<>();
+    @PostConstruct
+    private void init(){
+        bidMap.put("42",3d);
+    }
+
+
     public AdRankItem adItemRank(RankRecommendRequestParam request){
         ScoreParam param= RequestConvert.requestConvert(request);
         LocalDateTime currentTime = LocalDateTime.now();
@@ -72,7 +81,7 @@ public class RankServiceImpl implements RankService {
             }
         }
         for(AdRankItem item:rankItems){
-            item.setBid1(1d);
+            item.setBid1(bidMap.getOrDefault(item.getItemFeature().getAdvertiserId(),1d));
             item.setBid2(1d);
             item.setCpa(75d);
             item.setPidLambda(PidLambdaContainer.getPidLambda(item.getAdId()));