From e32c50b153bcdd5f3922f949a368cb7ae9ae1c87 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 26 Apr 2019 13:11:15 +0800 Subject: [PATCH] =?UTF-8?q?[redis][=E4=BF=AE=E6=94=B9]:database?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../wechat/FmOpenInRedisDBConfigStorage.java | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java b/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java index eb5228c..f8e9e2f 100644 --- a/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java +++ b/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java @@ -1,8 +1,6 @@ package com.iformall.service.wechat; import com.iformall.common.FmHttpClientBuilder; -import com.iformall.domain.po.WxAuthorizerInfo; -import com.iformall.domain.po.WxComponentVerifyTicket; import com.iformall.mapper.WxAuthorizerInfoMapper; import com.iformall.mapper.WxComponentVerifyTicketMapper; import me.chanjar.weixin.common.util.http.apache.ApacheHttpClientBuilder; @@ -15,8 +13,6 @@ import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.util.Pool; -import java.util.Date; - public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { private final static String COMPONENT_VERIFY_TICKET_KEY = "wechat_component_verify_ticket:"; private final static String COMPONENT_ACCESS_TOKEN_KEY = "wechat_component_access_token:"; @@ -112,13 +108,15 @@ public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { public void updateComponentAccessTokent(String componentAccessToken, int expiresInSeconds) { try (Jedis jedis = this.jedisPool.getResource()) { jedis.setex(this.componentAccessTokenKey, expiresInSeconds - 200, componentAccessToken); - + /* WxComponentVerifyTicket ticket = new WxComponentVerifyTicket(); ticket.setComponentAppid(getComponentAppId()); ticket.setAccessToken(componentAccessToken); ticket.setAccessTokenExpire(new Date(Long.valueOf(System.currentTimeMillis() + (expiresInSeconds * 1000)))); int num = wxComponentVerifyTicketMapper.updateAccessToken(ticket); logger.info("updateComponentVerifyTicketAccessToken rows: " + num); + */ + logger.info("updateComponentVerifyTicketAccessToken " + componentAccessToken); } } @@ -137,12 +135,14 @@ public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { public void setAuthorizerRefreshToken(String appId, String authorizerRefreshToken) { try (Jedis jedis = this.jedisPool.getResource()) { jedis.set(this.getKey(this.authorizerRefreshTokenKey, appId), authorizerRefreshToken); + /* WxAuthorizerInfo authorizerInfo = new WxAuthorizerInfo(); authorizerInfo.setAuthorizerAppid(appId); authorizerInfo.setRefreshToken(authorizerRefreshToken); int num = wxAuthorizerInfoMapper.updateRefreshToken(authorizerInfo); - logger.info("setAuthorizerRefreshToken " + appId + " rows: " + num); + */ + logger.info("setAuthorizerRefreshToken " + appId); } } @@ -170,13 +170,15 @@ public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { @Override public void updateAuthorizerAccessToken(String appId, WxOpenAuthorizerAccessToken authorizerAccessToken) { this.updateAuthorizerAccessToken(appId, authorizerAccessToken.getAuthorizerAccessToken(), authorizerAccessToken.getExpiresIn()); - + /* WxAuthorizerInfo authorizerInfo = new WxAuthorizerInfo(); authorizerInfo.setAuthorizerAppid(appId); authorizerInfo.setAccessToken(authorizerAccessToken.getAuthorizerAccessToken()); authorizerInfo.setAccessTokenExpire(new Date(Long.valueOf(System.currentTimeMillis() + (authorizerAccessToken.getExpiresIn() * 1000)))); int num = wxAuthorizerInfoMapper.updateAccessToken(authorizerInfo); logger.info("updateAuthorizerAccessToken " + appId + " rows: " + num); + */ + logger.info("updateAuthorizerAccessToken " + appId); } @Override