From 2ec222faa4aa055785085dec001d8157fe0135cb Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Mon, 11 Mar 2019 15:00:47 +0800 Subject: [PATCH] =?UTF-8?q?[=E7=94=A8=E6=88=B7TOKEN=E7=BC=93=E5=AD=98][?= =?UTF-8?q?=E4=BF=AE=E6=94=B9]:=E7=A7=BB=E9=99=A4redis=E7=BC=93=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/iformall/config/RedisConfig.java | 17 ---------- .../java/com/iformall/config/RedisConfig.java | 17 ---------- .../java/com/iformall/config/RedisConfig.java | 17 ---------- .../java/com/iformall/config/RedisConfig.java | 17 ---------- .../service/impl/WxCUserServiceImpl.java | 31 +------------------ .../java/com/iformall/config/RedisConfig.java | 18 ----------- 6 files changed, 1 insertion(+), 116 deletions(-) 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; - } - }