From daac4f8c5ff687e53ece1a0e340131d5308663a4 Mon Sep 17 00:00:00 2001
From: YXY <932687738@qq.com>
Date: Mon, 24 Jul 2023 21:59:20 +0800
Subject: [PATCH] =?UTF-8?q?=E5=85=B1=E4=BA=ABtoken?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java   | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

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