support compress

recommend-feature-produce/src/main/java/com/tzld/piaoquan/recommend/feature/produce/service/DTSConfigService.java

@@ -34,7 +34,7 @@ public class DTSConfigService {
     public DTSConfig getDTSConfig(Map<String, String> argMap) {
 
         List<DTSConfig> dtsConfigs = JSONUtils.fromJson(
-                ConfigService.getAppConfig().getProperty("dts.config.v2", ""),
+                ConfigService.getAppConfig().getProperty("dts.config", ""),
                 new TypeToken<List<DTSConfig>>() {
                 },
                 Collections.emptyList());

recommend-feature-produce/src/main/java/com/tzld/piaoquan/recommend/feature/produce/service/RedisService.java

@@ -62,10 +62,10 @@ public class RedisService implements Serializable {
 
         Pipeline pipeline = jedis.pipelined();
         for (Map.Entry<String, String> e : batch.entrySet()) {
-            pipeline.setex(e.getKey(), expireSeconds, e.getValue());
+            // pipeline.setex(e.getKey(), expireSeconds, e.getValue());
             // 压缩后的key，升级后进行替换
             try {
-                pipeline.setex("snappy:" + e.getKey(), expireSeconds, CompressionUtil.snappyCompress(e.getValue()));
+                pipeline.setex(e.getKey(), expireSeconds, CompressionUtil.snappyCompress(e.getValue()));
             } catch (Exception ex) {
             }
         }