gufengshou1 před 1 rokem
rodič
revize
e124661e79

+ 1 - 1
ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/score/VlogAdCtrLRScorer.java

@@ -122,7 +122,7 @@ public class VlogAdCtrLRScorer extends BaseLRModelScorer {
         }
         lrSamples.toBuilder().setPredictCtr(pro);
         //
-//        System.out.println("svc=lrSamplePrint  lrSamples="+lrSamples.toString());
+        System.out.println("svc=lrSamplePrint  lrSamples="+lrSamples.toString());
         item.setCtr(pro);
         return pro;
     }

+ 1 - 0
ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/score/VlogAdCvrLRScorer.java

@@ -118,6 +118,7 @@ public class VlogAdCvrLRScorer extends BaseLRModelScorer {
                         item.getAdId(), ExceptionUtils.getFullStackTrace(e)});
             }
         }
+//        lrSamples.toBuilder().setPredictCtr(pro);
         item.setCvr(pro);
         return pro;
     }

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

@@ -15,7 +15,6 @@ import com.tzld.piaoquan.ad.engine.service.score.FeatureRemoteService;
 import com.tzld.piaoquan.ad.engine.service.score.RankService;
 import com.tzld.piaoquan.ad.engine.service.score.convert.RequestConvert;
 import com.tzld.piaoquan.ad.engine.service.score.param.RankRecommendRequestParam;
-import org.joda.time.LocalTime;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.BeanUtils;
@@ -23,9 +22,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
-import java.time.DayOfWeek;
-import java.time.LocalDate;
 import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -33,7 +31,8 @@ import java.util.stream.Collectors;
 public class RankServiceImpl implements RankService {
 
     private final static Logger log = LoggerFactory.getLogger(RankServiceImpl.class);
-
+    DateTimeFormatter dateFormatter = DateTimeFormatter.ofPattern("yyyyMMdd");
+    DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("yyyyMMdd HH:mm:ss");
     @Autowired
     FeatureRemoteService featureRemoteService;
 
@@ -41,13 +40,15 @@ public class RankServiceImpl implements RankService {
     RankServiceThompsonImpl rankServiceThompson;
 
     public AdRankItem adItemRank(RankRecommendRequestParam request){
-
         ScoreParam param= RequestConvert.requestConvert(request);
         LocalDateTime currentTime = LocalDateTime.now();
         int currentHour = currentTime.getHour();
         int dayOfWeek = currentTime.getDayOfWeek().getValue();
         param.getRequestContext().setHour(currentHour+"");
         param.getRequestContext().setWeek(dayOfWeek+"");
+        param.getRequestContext().setRegion(request.getRegion().replace("省",""));
+        param.getRequestContext().setCity(request.getCity().replace("市",""));
+        param.getRequestContext().setDay(currentTime.format(dateFormatter));
 
         UserAdFeature userAdFeature=featureRemoteService.getUserAdFeature(request.getMid());
         if(userAdFeature==null){
@@ -82,8 +83,13 @@ public class RankServiceImpl implements RankService {
 
             rankResult=rank(param, userAdFeature, rankItems,ScorerUtils.BASE_CONF);
         }
-        log.info("svc=adItemRank rankResult={}", JSONObject.toJSONString(rankResult));
+        JSONObject object=new JSONObject();
+        object.put("request",request);
+        object.put("rankResult",rankResult.get(0));
+        object.put("dataTime",currentTime.format(timeFormatter));
         if (!CollectionUtils.isEmpty(rankResult)) {
+//            log.info("svc=adItemRank request={} rankResult={} dataTime={}", JSONObject.toJSONString(request),JSONObject.toJSONString(rankResult),currentTime.format(timeFormatter));
+            log.info("svc=adItemRank {}", JSONObject.toJSONString(object));
             return rankResult.get(0);
         }else {
             //空返回值