|
@@ -32,10 +32,14 @@ public class MemberSysAccessTokenRefreshTask {
|
|
private HaiKongMemberTemplate haiKongMemberTemplate;
|
|
private HaiKongMemberTemplate haiKongMemberTemplate;
|
|
|
|
|
|
|
|
|
|
- @Scheduled(cron = "0/30 * * * * ?")
|
|
|
|
|
|
+ // @Scheduled(cron = "0/30 * * * * ?")
|
|
public void refresh() {
|
|
public void refresh() {
|
|
|
|
+ JedisUtil.del(Constants.MEMBER_SYS_REFRESH_TOKEN_REDIS_KEY);
|
|
|
|
+ JedisUtil.del(Constants.MEMBER_SYS_ACCESS_TOKEN_REDIS_KEY);
|
|
String refreshToken = JedisUtil.get(Constants.MEMBER_SYS_REFRESH_TOKEN_REDIS_KEY);
|
|
String refreshToken = JedisUtil.get(Constants.MEMBER_SYS_REFRESH_TOKEN_REDIS_KEY);
|
|
String accessToken = JedisUtil.get(Constants.MEMBER_SYS_ACCESS_TOKEN_REDIS_KEY);
|
|
String accessToken = JedisUtil.get(Constants.MEMBER_SYS_ACCESS_TOKEN_REDIS_KEY);
|
|
|
|
+ log.info("refresh accessToken......" + accessToken);
|
|
|
|
+ log.info("refresh refreshToken......" + refreshToken);
|
|
// if (!StringUtils.isEmpty(refreshToken) && !StringUtils.isEmpty(accessToken)) {
|
|
// if (!StringUtils.isEmpty(refreshToken) && !StringUtils.isEmpty(accessToken)) {
|
|
// return;
|
|
// return;
|
|
// }
|
|
// }
|
|
@@ -62,6 +66,7 @@ public class MemberSysAccessTokenRefreshTask {
|
|
}
|
|
}
|
|
|
|
|
|
private void handleResponse(String json, Boolean a) {
|
|
private void handleResponse(String json, Boolean a) {
|
|
|
|
+ log.debug("重新设置accessToken" + json + "!" + a);
|
|
Response<AccessTokenDTO> response = null;
|
|
Response<AccessTokenDTO> response = null;
|
|
try {
|
|
try {
|
|
response = JacksonUtil.getObjectMapper().readValue(json, new TypeReference<Response<AccessTokenDTO>>() {
|
|
response = JacksonUtil.getObjectMapper().readValue(json, new TypeReference<Response<AccessTokenDTO>>() {
|
|
@@ -73,7 +78,9 @@ public class MemberSysAccessTokenRefreshTask {
|
|
if (Objects.nonNull(response) && response.getSuccess()) {
|
|
if (Objects.nonNull(response) && response.getSuccess()) {
|
|
AccessTokenDTO accessTokenDTO = response.getData();
|
|
AccessTokenDTO accessTokenDTO = response.getData();
|
|
JedisUtil.del(Constants.MEMBER_SYS_ACCESS_TOKEN_REDIS_KEY);
|
|
JedisUtil.del(Constants.MEMBER_SYS_ACCESS_TOKEN_REDIS_KEY);
|
|
|
|
+ log.debug("删除accessToken");
|
|
JedisUtil.set(Constants.MEMBER_SYS_ACCESS_TOKEN_REDIS_KEY, JacksonUtil.toJson(accessTokenDTO), (60 * 60 * 2) - (60 * 10));
|
|
JedisUtil.set(Constants.MEMBER_SYS_ACCESS_TOKEN_REDIS_KEY, JacksonUtil.toJson(accessTokenDTO), (60 * 60 * 2) - (60 * 10));
|
|
|
|
+ log.debug("写入新的accessToken");
|
|
if (a) {
|
|
if (a) {
|
|
JedisUtil.del(Constants.MEMBER_SYS_REFRESH_TOKEN_REDIS_KEY);
|
|
JedisUtil.del(Constants.MEMBER_SYS_REFRESH_TOKEN_REDIS_KEY);
|
|
JedisUtil.set(Constants.MEMBER_SYS_REFRESH_TOKEN_REDIS_KEY, Optional.ofNullable(accessTokenDTO.getRefreshToken()).orElse(""), (60 * 60 * 24 * 7));
|
|
JedisUtil.set(Constants.MEMBER_SYS_REFRESH_TOKEN_REDIS_KEY, Optional.ofNullable(accessTokenDTO.getRefreshToken()).orElse(""), (60 * 60 * 24 * 7));
|
|
@@ -90,6 +97,7 @@ public class MemberSysAccessTokenRefreshTask {
|
|
|
|
|
|
public String getAccessToken() throws Exception {
|
|
public String getAccessToken() throws Exception {
|
|
String accessTokenJson = JedisUtil.get(Constants.MEMBER_SYS_ACCESS_TOKEN_REDIS_KEY);
|
|
String accessTokenJson = JedisUtil.get(Constants.MEMBER_SYS_ACCESS_TOKEN_REDIS_KEY);
|
|
|
|
+ log.info("getAccessToken accessToken......" + accessTokenJson);
|
|
if (StringUtils.isEmpty(accessTokenJson)) {
|
|
if (StringUtils.isEmpty(accessTokenJson)) {
|
|
refresh();
|
|
refresh();
|
|
accessTokenJson = JedisUtil.get(Constants.MEMBER_SYS_ACCESS_TOKEN_REDIS_KEY);
|
|
accessTokenJson = JedisUtil.get(Constants.MEMBER_SYS_ACCESS_TOKEN_REDIS_KEY);
|