diff --git a/mallinkAdmin/src/main/java/com/iformall/config/RedisConfig.java b/mallinkAdmin/src/main/java/com/iformall/config/RedisConfig.java index c4202c602..d82cce4f8 100644 --- a/mallinkAdmin/src/main/java/com/iformall/config/RedisConfig.java +++ b/mallinkAdmin/src/main/java/com/iformall/config/RedisConfig.java @@ -125,21 +125,4 @@ public class RedisConfig extends CachingConfigurerSupport { return template; } - @Bean("cuserTokenRedisTemplate") - public RedisTemplate getCUserTokenRedisTemplate(RedisConnectionFactory connectionFactory) { - RedisTemplate template = new RedisTemplate(); - - Jackson2JsonRedisSerializer j = new Jackson2JsonRedisSerializer(WxScoreRules.class); - // value值的序列化 - template.setValueSerializer(j); - template.setHashKeySerializer(j); - - // key的序列化 - template.setKeySerializer(new StringRedisSerializer()); - template.setHashKeySerializer(new StringRedisSerializer()); - - template.setConnectionFactory(connectionFactory); - return template; - } - } diff --git a/mallinkBApi/src/main/java/com/iformall/config/RedisConfig.java b/mallinkBApi/src/main/java/com/iformall/config/RedisConfig.java index 6d41807b9..98851927b 100644 --- a/mallinkBApi/src/main/java/com/iformall/config/RedisConfig.java +++ b/mallinkBApi/src/main/java/com/iformall/config/RedisConfig.java @@ -87,21 +87,4 @@ public class RedisConfig extends CachingConfigurerSupport { return template; } - @Bean("cuserTokenRedisTemplate") - public RedisTemplate getCUserTokenRedisTemplate(RedisConnectionFactory connectionFactory) { - RedisTemplate template = new RedisTemplate(); - - Jackson2JsonRedisSerializer j = new Jackson2JsonRedisSerializer(WxScoreRules.class); - // value值的序列化 - template.setValueSerializer(j); - template.setHashKeySerializer(j); - - // key的序列化 - template.setKeySerializer(new StringRedisSerializer()); - template.setHashKeySerializer(new StringRedisSerializer()); - - template.setConnectionFactory(connectionFactory); - return template; - } - } diff --git a/mallinkCApi/src/main/java/com/iformall/config/RedisConfig.java b/mallinkCApi/src/main/java/com/iformall/config/RedisConfig.java index 6d41807b9..98851927b 100644 --- a/mallinkCApi/src/main/java/com/iformall/config/RedisConfig.java +++ b/mallinkCApi/src/main/java/com/iformall/config/RedisConfig.java @@ -87,21 +87,4 @@ public class RedisConfig extends CachingConfigurerSupport { return template; } - @Bean("cuserTokenRedisTemplate") - public RedisTemplate getCUserTokenRedisTemplate(RedisConnectionFactory connectionFactory) { - RedisTemplate template = new RedisTemplate(); - - Jackson2JsonRedisSerializer j = new Jackson2JsonRedisSerializer(WxScoreRules.class); - // value值的序列化 - template.setValueSerializer(j); - template.setHashKeySerializer(j); - - // key的序列化 - template.setKeySerializer(new StringRedisSerializer()); - template.setHashKeySerializer(new StringRedisSerializer()); - - template.setConnectionFactory(connectionFactory); - return template; - } - } diff --git a/mallinkSchedule/src/main/java/com/iformall/config/RedisConfig.java b/mallinkSchedule/src/main/java/com/iformall/config/RedisConfig.java index 944217c2f..49aba8792 100644 --- a/mallinkSchedule/src/main/java/com/iformall/config/RedisConfig.java +++ b/mallinkSchedule/src/main/java/com/iformall/config/RedisConfig.java @@ -110,21 +110,4 @@ public class RedisConfig extends CachingConfigurerSupport { return template; } - @Bean("cuserTokenRedisTemplate") - public RedisTemplate getCUserTokenRedisTemplate(RedisConnectionFactory connectionFactory) { - RedisTemplate template = new RedisTemplate(); - - Jackson2JsonRedisSerializer j = new Jackson2JsonRedisSerializer(WxScoreRules.class); - // value值的序列化 - template.setValueSerializer(j); - template.setHashKeySerializer(j); - - // key的序列化 - template.setKeySerializer(new StringRedisSerializer()); - template.setHashKeySerializer(new StringRedisSerializer()); - - template.setConnectionFactory(connectionFactory); - return template; - } - } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCUserServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCUserServiceImpl.java index 2c40f2754..d1417f803 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCUserServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCUserServiceImpl.java @@ -12,7 +12,6 @@ import com.iformall.mapper.WxScoreHistoryMapper; import com.iformall.mapper.WxScoreRulesMapper; import com.iformall.service.WxCUserService; import com.iformall.service.WxScoreRulesService; -import com.iformall.utils.BaseConstant; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; @@ -44,11 +43,6 @@ public class WxCUserServiceImpl implements WxCUserService { WxScoreHistoryMapper wxScoreHistoryMapper; - @Autowired - @Qualifier("cuserTokenRedisTemplate") - RedisTemplate cUserTokenRedisTemplate; - - @Override public PageInfo listAsPage(WxCUser record, Integer pageIndex, Integer pageSize) { return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> wxCUserMapper.findList(record)); @@ -66,22 +60,7 @@ public class WxCUserServiceImpl implements WxCUserService { @Override public WxCUser getByToken(String token) { - logger.info("获取用户信息start ..."); - String key = "token_" + token; - ValueOperations operations = cUserTokenRedisTemplate.opsForValue(); - - // 缓存 - boolean hasKey = cUserTokenRedisTemplate.hasKey(key); - if(hasKey) { - // 从缓存获取用户信息 - WxCUser user = operations.get(key); - return user; - } - WxCUser user = wxCUserMapper.findByToken(token); - // 插入缓存 - operations.set(key, user, 3600, TimeUnit.SECONDS); - - return user; + return wxCUserMapper.findByToken(token); } @Override @@ -101,14 +80,6 @@ public class WxCUserServiceImpl implements WxCUserService { user.setUpdateDate(curr); ret = wxCUserMapper.updateByPrimaryKeySelective(user); } - String key = "token_" + user.getToken(); - // 缓存已存在,删除 - boolean hasKey = cUserTokenRedisTemplate.hasKey(key); - if(hasKey) { - cUserTokenRedisTemplate.delete(key); - logger.info("更新用户,从缓存中删除用户 token >> " + user.getToken()); - } - return ret; } diff --git a/mallinkWechatOpen/src/main/java/com/iformall/config/RedisConfig.java b/mallinkWechatOpen/src/main/java/com/iformall/config/RedisConfig.java index 1106d0f95..387d76499 100644 --- a/mallinkWechatOpen/src/main/java/com/iformall/config/RedisConfig.java +++ b/mallinkWechatOpen/src/main/java/com/iformall/config/RedisConfig.java @@ -108,22 +108,4 @@ public class RedisConfig extends CachingConfigurerSupport { template.setConnectionFactory(connectionFactory); return template; } - - @Bean("cuserTokenRedisTemplate") - public RedisTemplate getCUserTokenRedisTemplate(RedisConnectionFactory connectionFactory) { - RedisTemplate template = new RedisTemplate(); - - Jackson2JsonRedisSerializer j = new Jackson2JsonRedisSerializer(WxScoreRules.class); - // value值的序列化 - template.setValueSerializer(j); - template.setHashKeySerializer(j); - - // key的序列化 - template.setKeySerializer(new StringRedisSerializer()); - template.setHashKeySerializer(new StringRedisSerializer()); - - template.setConnectionFactory(connectionFactory); - return template; - } - }