Commit 643aeca5 authored by 宋新宇's avatar 宋新宇

Merge branch '7-短剧app关键行为优化' into 'release_20240408_01'

短剧app关键行为优化

See merge request !34
parents 704f5769 157a76d5
...@@ -35,7 +35,7 @@ public class VideoAppUniversalProcess extends UniversalProcess { ...@@ -35,7 +35,7 @@ public class VideoAppUniversalProcess extends UniversalProcess {
private static final Logger VIDEOAPP_ERROR_LOG = LoggerFactory.getLogger("videoapp.error"); private static final Logger VIDEOAPP_ERROR_LOG = LoggerFactory.getLogger("videoapp.error");
@Resource @Resource
private RedisTemplate<Object,Object> oldMarketRedisTemplate; private RedisTemplate<String,String> oldMarketRedisTemplate;
/** /**
* 通知处理结果 * 通知处理结果
...@@ -69,7 +69,7 @@ public class VideoAppUniversalProcess extends UniversalProcess { ...@@ -69,7 +69,7 @@ public class VideoAppUniversalProcess extends UniversalProcess {
} }
public <T> T getOldMarket(Class<T> clazz, String key) { 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)){ if(!Objects.isNull(value)){
return JSON.parseObject(value,clazz); return JSON.parseObject(value,clazz);
} }
......
...@@ -8,6 +8,7 @@ import org.springframework.data.redis.connection.RedisConnectionFactory; ...@@ -8,6 +8,7 @@ import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration; import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory; import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer; import org.springframework.data.redis.serializer.StringRedisSerializer;
@Configuration @Configuration
...@@ -34,6 +35,9 @@ public class OldMarketRedisConfig { ...@@ -34,6 +35,9 @@ public class OldMarketRedisConfig {
StringRedisSerializer stringRedisSerializer = new StringRedisSerializer(); StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
template.setKeySerializer(stringRedisSerializer); template.setKeySerializer(stringRedisSerializer);
template.setValueSerializer(stringRedisSerializer); template.setValueSerializer(stringRedisSerializer);
template.setHashKeySerializer(new StringRedisSerializer());
template.setHashValueSerializer(new Jackson2JsonRedisSerializer<>(Object.class));
template.setConnectionFactory(redisConnectionFactory); template.setConnectionFactory(redisConnectionFactory);
return template; return template;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment