|
@@ -62,31 +62,33 @@ public class CtopOauthTokenServiceImpl extends ServiceImpl<CtopOauthTokenMapper,
|
|
param.put("refresh_token", refreshToken);
|
|
param.put("refresh_token", refreshToken);
|
|
String result = HttpUtils.httpPostRequest(url, param, new HashMap<>());
|
|
String result = HttpUtils.httpPostRequest(url, param, new HashMap<>());
|
|
JSONObject resultObject = JSONObject.parseObject(result);
|
|
JSONObject resultObject = JSONObject.parseObject(result);
|
|
- XxlJobLogger.log("头条刷新token入参,token:{},refreshToken:{},返回信息:{}", token, refreshToken, resultObject);
|
|
|
|
- Integer code = resultObject.getInteger("code");
|
|
|
|
- if (code == 0) {
|
|
|
|
- JSONObject data = resultObject.getJSONObject("data");
|
|
|
|
- CtopOauthToken updateRefreshToken = new CtopOauthToken();
|
|
|
|
- updateRefreshToken.setAccessToken(data.getString("access_token"));
|
|
|
|
- updateRefreshToken.setRefreshToken(data.getString("refresh_token"));
|
|
|
|
- Date now = new Date();
|
|
|
|
- Integer refreshTokenExpiresIn = data.getInteger("refresh_token_expires_in");
|
|
|
|
- Integer expiresIn = data.getInteger("expires_in");
|
|
|
|
- updateRefreshToken.setRefreshTokenExpiresIn(addSecond(now, refreshTokenExpiresIn));
|
|
|
|
- updateRefreshToken.setAccessTokenExpiresIn(addSecond(now, expiresIn));
|
|
|
|
- QueryWrapper<CtopOauthToken> queryWrapper = new QueryWrapper<>();
|
|
|
|
- queryWrapper.eq("access_token", token);
|
|
|
|
- queryWrapper.eq("media_id", 1);
|
|
|
|
- int i = cTopOauthTokenMapper.update(updateRefreshToken, queryWrapper);
|
|
|
|
- if (i > 0) {
|
|
|
|
- XxlJobLogger.log("头条刷新token成功:token:{}", token);
|
|
|
|
|
|
+ if (!Check.isNull(resultObject)) {
|
|
|
|
+ XxlJobLogger.log("头条刷新token入参,token:{},refreshToken:{},返回信息:{}", token, refreshToken, resultObject);
|
|
|
|
+ Integer code = resultObject.getInteger("code");
|
|
|
|
+ if (code == 0) {
|
|
|
|
+ JSONObject data = resultObject.getJSONObject("data");
|
|
|
|
+ CtopOauthToken updateRefreshToken = new CtopOauthToken();
|
|
|
|
+ updateRefreshToken.setAccessToken(data.getString("access_token"));
|
|
|
|
+ updateRefreshToken.setRefreshToken(data.getString("refresh_token"));
|
|
|
|
+ Date now = new Date();
|
|
|
|
+ Integer refreshTokenExpiresIn = data.getInteger("refresh_token_expires_in");
|
|
|
|
+ Integer expiresIn = data.getInteger("expires_in");
|
|
|
|
+ updateRefreshToken.setRefreshTokenExpiresIn(addSecond(now, refreshTokenExpiresIn));
|
|
|
|
+ updateRefreshToken.setAccessTokenExpiresIn(addSecond(now, expiresIn));
|
|
|
|
+ QueryWrapper<CtopOauthToken> queryWrapper = new QueryWrapper<>();
|
|
|
|
+ queryWrapper.eq("access_token", token);
|
|
|
|
+ queryWrapper.eq("media_id", 1);
|
|
|
|
+ int i = cTopOauthTokenMapper.update(updateRefreshToken, queryWrapper);
|
|
|
|
+ if (i > 0) {
|
|
|
|
+ XxlJobLogger.log("头条刷新token成功:token:{}", token);
|
|
|
|
+ }
|
|
|
|
+ resultMap.put("message", "token刷新成功");
|
|
|
|
+ resultMap.put("code", 0);
|
|
|
|
+ } else {
|
|
|
|
+ resultMap.put("message", "token刷新失败");
|
|
|
|
+ resultMap.put("token", token);
|
|
|
|
+ resultMap.put("code", 0);
|
|
}
|
|
}
|
|
- resultMap.put("message", "token刷新成功");
|
|
|
|
- resultMap.put("code", 0);
|
|
|
|
- } else {
|
|
|
|
- resultMap.put("message", "token刷新失败");
|
|
|
|
- resultMap.put("token", token);
|
|
|
|
- resultMap.put("code", 0);
|
|
|
|
}
|
|
}
|
|
return resultMap;
|
|
return resultMap;
|
|
}
|
|
}
|
|
@@ -212,10 +214,11 @@ public class CtopOauthTokenServiceImpl extends ServiceImpl<CtopOauthTokenMapper,
|
|
calendar.add(Calendar.SECOND, seconds);
|
|
calendar.add(Calendar.SECOND, seconds);
|
|
return calendar.getTime();
|
|
return calendar.getTime();
|
|
}
|
|
}
|
|
|
|
+
|
|
@Override
|
|
@Override
|
|
public List<CtopOauthToken> getByProjectId(long projectId) {
|
|
public List<CtopOauthToken> getByProjectId(long projectId) {
|
|
- QueryWrapper<CtopOauthToken>queryWrapper = new QueryWrapper<>();
|
|
|
|
- queryWrapper.eq("project_id",projectId).eq("account_status",0);
|
|
|
|
|
|
+ QueryWrapper<CtopOauthToken> queryWrapper = new QueryWrapper<>();
|
|
|
|
+ queryWrapper.eq("project_id", projectId).eq("account_status", 0);
|
|
return this.list(queryWrapper);
|
|
return this.list(queryWrapper);
|
|
}
|
|
}
|
|
|
|
|