丁云鹏 преди 1 година
родител
ревизия
d9d22a0002

+ 16 - 0
recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/remote/FeatureRemoteService.java

@@ -48,15 +48,23 @@ public class FeatureRemoteService {
         feature.setMid(proto.getMid());
         if (proto.hasDay1CntFeature()) {
             feature.setDay1_cnt_features(convert(proto.getDay1CntFeature()));
+        } else {
+            feature.setDay1_cnt_features(new UserActionFeature());
         }
         if (proto.hasDay3CntFeature()) {
             feature.setDay3_cnt_features(convert(proto.getDay3CntFeature()));
+        } else {
+            feature.setDay3_cnt_features(new UserActionFeature());
         }
         if (proto.hasDay7CntFeature()) {
             feature.setDay7_cnt_features(convert(proto.getDay7CntFeature()));
+        } else {
+            feature.setDay7_cnt_features(new UserActionFeature());
         }
         if (proto.hasMonth3CntFeature()) {
             feature.setMonth3_cnt_features(convert(proto.getMonth3CntFeature()));
+        } else {
+            feature.setMonth3_cnt_features(new UserActionFeature());
         }
         feature.setUser_cycle_bucket_7days(proto.getUserCycleBucket7Day());
         feature.setUser_cycle_bucket_30days(proto.getUserCycleBucket30Day());
@@ -110,15 +118,23 @@ public class FeatureRemoteService {
 
         if (proto.hasVideoDay1CntFeature()) {
             feature.setDay1_cnt_features(convert(proto.getVideoDay1CntFeature()));
+        } else {
+            feature.setDay1_cnt_features(new UserActionFeature());
         }
         if (proto.hasVideoDay3CntFeature()) {
             feature.setDay3_cnt_features(convert(proto.getVideoDay3CntFeature()));
+        } else {
+            feature.setDay3_cnt_features(new UserActionFeature());
         }
         if (proto.hasVideoDay7CntFeature()) {
             feature.setDay7_cnt_features(convert(proto.getVideoDay7CntFeature()));
+        } else {
+            feature.setDay7_cnt_features(new UserActionFeature());
         }
         if (proto.hasVideoMonth3CntFeature()) {
             feature.setMonth3_cnt_features(convert(proto.getVideoMonth3CntFeature()));
+        } else {
+            feature.setMonth3_cnt_features(new UserActionFeature());
         }
         return feature;
     }

+ 4 - 2
recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/rank/RankService.java

@@ -2,9 +2,9 @@ package com.tzld.piaoquan.recommend.server.service.rank;
 
 
 import com.tzld.piaoquan.recommend.feature.domain.video.base.ItemFeature;
-import com.tzld.piaoquan.recommend.server.common.base.RankItem;
 import com.tzld.piaoquan.recommend.feature.domain.video.base.RequestContext;
 import com.tzld.piaoquan.recommend.feature.domain.video.base.UserFeature;
+import com.tzld.piaoquan.recommend.server.common.base.RankItem;
 import com.tzld.piaoquan.recommend.server.common.enums.AppTypeEnum;
 import com.tzld.piaoquan.recommend.server.model.MachineInfo;
 import com.tzld.piaoquan.recommend.server.model.Video;
@@ -178,8 +178,10 @@ public class RankService {
         }
 
         // TODO
+        ScoreParam scoreParam = convert(param);
+        log.info("scoreParam {}", JSONUtils.toJson(scoreParam));
         List<RankItem> rovRecallScore = ScorerUtils.getScorerPipeline(ScorerUtils.BASE_CONF)
-                .scoring(convert(param), userFeature, rankItems);
+                .scoring(scoreParam, userFeature, rankItems);
         log.info("mergeAndRankRovRecallNew rovRecallScore={}", JSONUtils.toJson(rovRecallScore));
 
         return CommonCollectionUtils.toList(rovRecallScore, i -> {