|
|
@ -86,8 +86,6 @@ public abstract class SyncAccountsJobAbstract {
|
|
|
|
log.info("===================== {} strat ======================",this.getClassName());
|
|
|
|
log.info("===================== {} strat ======================",this.getClassName());
|
|
|
|
//重置ticket
|
|
|
|
//重置ticket
|
|
|
|
resetTicket(context);
|
|
|
|
resetTicket(context);
|
|
|
|
//获取token
|
|
|
|
|
|
|
|
generateToken(context);
|
|
|
|
|
|
|
|
//初始化飞书信息及相关配置
|
|
|
|
//初始化飞书信息及相关配置
|
|
|
|
initLarkInfo(context);
|
|
|
|
initLarkInfo(context);
|
|
|
|
//执行分页同步
|
|
|
|
//执行分页同步
|
|
|
@ -185,6 +183,7 @@ public abstract class SyncAccountsJobAbstract {
|
|
|
|
if (cjtRequest == null) {
|
|
|
|
if (cjtRequest == null) {
|
|
|
|
cjtRequest = buildCJTRequest(context, cjtRequestBody);
|
|
|
|
cjtRequest = buildCJTRequest(context, cjtRequestBody);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
cjtRequest.setOpenToken(generateToken(context));
|
|
|
|
//请求接口并序列化数据
|
|
|
|
//请求接口并序列化数据
|
|
|
|
CJTResponseBodyDetail response = request(cjtRequest);
|
|
|
|
CJTResponseBodyDetail response = request(cjtRequest);
|
|
|
|
//同步总页数方便循环
|
|
|
|
//同步总页数方便循环
|
|
|
@ -325,7 +324,7 @@ public abstract class SyncAccountsJobAbstract {
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* 生成调用接口的token信息
|
|
|
|
* 生成调用接口的token信息
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
private void generateToken(CJTJobContext context) {
|
|
|
|
private String generateToken(CJTJobContext context) {
|
|
|
|
String openToken = (String) redisCache.getCacheObject(RedisConstants.CJT_TOKEN_CACHE_KEY);
|
|
|
|
String openToken = (String) redisCache.getCacheObject(RedisConstants.CJT_TOKEN_CACHE_KEY);
|
|
|
|
if (StringUtils.isEmpty(openToken)){
|
|
|
|
if (StringUtils.isEmpty(openToken)){
|
|
|
|
CJTRequest cjtRequest = new CJTRequest(REQUEST_GENERATE_TOKEN_PATH
|
|
|
|
CJTRequest cjtRequest = new CJTRequest(REQUEST_GENERATE_TOKEN_PATH
|
|
|
@ -339,8 +338,10 @@ public abstract class SyncAccountsJobAbstract {
|
|
|
|
String token = value.getString("accessToken");
|
|
|
|
String token = value.getString("accessToken");
|
|
|
|
context.setOpenToken(token);
|
|
|
|
context.setOpenToken(token);
|
|
|
|
redisCache.setCacheObject(RedisConstants.CJT_TOKEN_CACHE_KEY,token,10, TimeUnit.MINUTES);
|
|
|
|
redisCache.setCacheObject(RedisConstants.CJT_TOKEN_CACHE_KEY,token,10, TimeUnit.MINUTES);
|
|
|
|
|
|
|
|
return token;
|
|
|
|
}else{
|
|
|
|
}else{
|
|
|
|
context.setOpenToken(openToken);
|
|
|
|
context.setOpenToken(openToken);
|
|
|
|
|
|
|
|
return openToken;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -367,7 +368,7 @@ public abstract class SyncAccountsJobAbstract {
|
|
|
|
* 构建畅捷通请求对象
|
|
|
|
* 构建畅捷通请求对象
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
protected CJTRequest buildCJTRequest(CJTJobContext context, CJTRequestBody body) {
|
|
|
|
protected CJTRequest buildCJTRequest(CJTJobContext context, CJTRequestBody body) {
|
|
|
|
CJTRequest req = new CJTRequest(getRequestUrl(), context.getAppKey(), context.getAppSecret(), context.getOpenToken());
|
|
|
|
CJTRequest req = new CJTRequest(getRequestUrl(), context.getAppKey(), context.getAppSecret(), null);
|
|
|
|
req.setBody(body);
|
|
|
|
req.setBody(body);
|
|
|
|
return req;
|
|
|
|
return req;
|
|
|
|
}
|
|
|
|
}
|
|
|
|