zhaohaipeng 3 viikkoa sitten
vanhempi
commit
8628e7654f

+ 8 - 8
recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/rank/tansform/FeatureV6.java

@@ -673,15 +673,11 @@ public class FeatureV6 {
     }
 
     public static void putUserNetworkSeqFeature(Map<String, String> featureMapString, Map<String, String> userNetworkSeqFeatureMap, Map<String, Map<String, Map<String, String>>> videoBaseInfoMap) {
-        featureMapString.put("act_vid_seq", userNetworkSeqFeatureMap.getOrDefault("a_v_s", ""));
-        featureMapString.put("act_type_seq", userNetworkSeqFeatureMap.getOrDefault("a_t_s", ""));
-
-
-        featureMapString.put("net_vid_seq", userNetworkSeqFeatureMap.getOrDefault("n_v_s", ""));
-        featureMapString.put("net_union_id_seq", userNetworkSeqFeatureMap.getOrDefault("n_u_i_s", ""));
-
-
         List<String> actVidSeq = FeatureUtils.extractVidsFromUserNetworkSeqFeature(userNetworkSeqFeatureMap, "a_v_s");
+        List<String> actTypeSeq = FeatureUtils.extractVidsFromUserNetworkSeqFeature(userNetworkSeqFeatureMap, "a_t_s");
+        featureMapString.put("act_vid_seq", String.join(GS_STR, actVidSeq));
+        featureMapString.put("act_type_seq", String.join(GS_STR, actTypeSeq));
+
         List<String> actCate1Seq = new ArrayList<>(actVidSeq.size());
         List<String> actCate2Seq = new ArrayList<>(actVidSeq.size());
         for (String vid : actVidSeq) {
@@ -693,6 +689,10 @@ public class FeatureV6 {
         featureMapString.put("act_cate2_seq", String.join(GS_STR, actCate2Seq));
 
         List<String> netVidSeq = FeatureUtils.extractVidsFromUserNetworkSeqFeature(userNetworkSeqFeatureMap, "n_v_s");
+        List<String> netUnionIdSeq = FeatureUtils.extractVidsFromUserNetworkSeqFeature(userNetworkSeqFeatureMap, "n_u_i_s");
+        featureMapString.put("net_vid_seq", String.join(GS_STR, netVidSeq));
+        featureMapString.put("net_union_id_seq", String.join(GS_STR, netUnionIdSeq));
+
         List<String> netCate1Seq = new ArrayList<>(netVidSeq.size());
         List<String> netCate2Seq = new ArrayList<>(netVidSeq.size());
         for (String vid : netVidSeq) {

+ 1 - 0
recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/util/FeatureUtils.java

@@ -180,6 +180,7 @@ public class FeatureUtils {
         }
         String groupSeparator = "\u001D";
         return Arrays.stream(userNetworkSeqFeature.get(key).split(groupSeparator))
+                .filter(StringUtils::isNotBlank)
                 .collect(Collectors.toList());
     }
 }