短剧app关键行为优化

src/main/java/com/lwby/marketing/att/videoapp/VideoAppUniversalProcess.java

@@ -35,7 +35,7 @@ public class VideoAppUniversalProcess extends UniversalProcess {
     private static final Logger VIDEOAPP_ERROR_LOG = LoggerFactory.getLogger("videoapp.error");
 
     @Resource
-    private RedisTemplate<Object,Object> oldMarketRedisTemplate;
+    private RedisTemplate<String,String> oldMarketRedisTemplate;
 
     /**
      * 通知处理结果
@@ -69,7 +69,7 @@ public class VideoAppUniversalProcess extends UniversalProcess {
     }
 
     public <T> T getOldMarket(Class<T> clazz, String key) {
-        String value = (String) oldMarketRedisTemplate.opsForValue().get(key);
+        String value = oldMarketRedisTemplate.opsForValue().get(key);
         if(!Objects.isNull(value)){
             return JSON.parseObject(value,clazz);
         }

src/main/java/com/lwby/marketing/conf/OldMarketRedisConfig.java

@@ -8,6 +8,7 @@ import org.springframework.data.redis.connection.RedisConnectionFactory;
 import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
 import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
 import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
 import org.springframework.data.redis.serializer.StringRedisSerializer;
 
 @Configuration
@@ -34,6 +35,9 @@ public class OldMarketRedisConfig {
         StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
         template.setKeySerializer(stringRedisSerializer);
         template.setValueSerializer(stringRedisSerializer);
+        template.setHashKeySerializer(new StringRedisSerializer());
+        template.setHashValueSerializer(new Jackson2JsonRedisSerializer<>(Object.class));
+
         template.setConnectionFactory(redisConnectionFactory);
         return template;
     }