redis

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/common/base/UserFeature.java

@@ -1,5 +1,6 @@
 package com.tzld.piaoquan.recommend.server.common.base;
 
+import com.tzld.piaoquan.recommend.server.util.JSONUtils;
 import lombok.Data;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
@@ -79,8 +80,7 @@ public class UserFeature {
     }
 
     public String getValue(){
-        return "user_cycle_bucket_7days:" + this.user_cycle_bucket_7days + ","
-                + "user_cycle_bucket_30days" + this.user_cycle_bucket_30days;
+        return JSONUtils.toJson(this);
     }
 
 }

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/dataloader/FeatureToRedisLoader.java

@@ -15,6 +15,7 @@ import com.tzld.piaoquan.recommend.server.dataloader.OfflineSamplesLoader;
 import com.tzld.piaoquan.recommend.server.util.JSONUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Component;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -27,11 +28,13 @@ import java.util.concurrent.Executors;
 import java.util.stream.Collectors;
 
 
+@Component
 public class FeatureToRedisLoader {
 
     @Autowired
     private RedisTemplate<String, String> redisTemplate;
     private final String userKeyFormat = "user:%s";
+    private final String videoKeyFormat = "video:%s";
     private ExecutorService pool = ThreadPoolFactory.defaultPool();