From b087e5d2fce0b1a73eb3c007b629324f2664c271 Mon Sep 17 00:00:00 2001
From: liuy <37787198+LiuyCodes@users.noreply.github.com>
Date: Thu, 11 Sep 2025 16:55:45 +0800
Subject: [PATCH] =?UTF-8?q?refactor(ApiTokenManager):=20=E4=BC=98=E5=8C=96?=
 =?UTF-8?q?Token=E7=AE=A1=E7=90=86=E9=80=BB=E8=BE=91=E5=B9=B6=E7=A7=BB?=
 =?UTF-8?q?=E9=99=A4=E6=9C=AA=E4=BD=BF=E7=94=A8=E7=9A=84=E5=AF=BC=E5=85=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

在`ApiTokenManager`类中，对Token的获取和刷新逻辑进行了重构。具体改动包括：
- 将原有的Token过期处理逻辑从直接调用`refreshToken()`改为调用`fetchNewToken()`。
- 添加了注释掉的代码块用于调试目的，但不影响实际运行逻辑。
- 移除了`ZsyhCbsProcessor`类中未被使用的`java.io.InputStream`导入语句。这些修改旨在提高代码可读性和维护性。
---
 .../java/com/hzya/frame/ZsyhCbsProcessor.java  |  1 -
 .../com/hzya/frame/util/ApiTokenManager.java   | 18 ++++++++++++++++--
 2 files changed, 16 insertions(+), 3 deletions(-)

diff --git a/nifi-hzyadev-bundle/hzya-nifi-Zsyh-cbs-processors/src/main/java/com/hzya/frame/ZsyhCbsProcessor.java b/nifi-hzyadev-bundle/hzya-nifi-Zsyh-cbs-processors/src/main/java/com/hzya/frame/ZsyhCbsProcessor.java
index e9a945f..2d55630 100644
--- a/nifi-hzyadev-bundle/hzya-nifi-Zsyh-cbs-processors/src/main/java/com/hzya/frame/ZsyhCbsProcessor.java
+++ b/nifi-hzyadev-bundle/hzya-nifi-Zsyh-cbs-processors/src/main/java/com/hzya/frame/ZsyhCbsProcessor.java
@@ -24,7 +24,6 @@ import org.apache.nifi.processor.util.StandardValidators;
 import org.bouncycastle.jce.provider.BouncyCastleProvider;
 
 import java.io.IOException;
-import java.io.InputStream;
 import java.nio.charset.StandardCharsets;
 import java.security.Security;
 import java.util.*;
diff --git a/nifi-hzyadev-bundle/hzya-nifi-Zsyh-cbs-processors/src/main/java/com/hzya/frame/util/ApiTokenManager.java b/nifi-hzyadev-bundle/hzya-nifi-Zsyh-cbs-processors/src/main/java/com/hzya/frame/util/ApiTokenManager.java
index 49f37aa..47701ae 100644
--- a/nifi-hzyadev-bundle/hzya-nifi-Zsyh-cbs-processors/src/main/java/com/hzya/frame/util/ApiTokenManager.java
+++ b/nifi-hzyadev-bundle/hzya-nifi-Zsyh-cbs-processors/src/main/java/com/hzya/frame/util/ApiTokenManager.java
@@ -88,16 +88,30 @@ public class ApiTokenManager {
 
         long now = System.currentTimeMillis();
 
+//        if (cachedToken == null) {
+//            logger.info("Token为空，首次获取新Token...");
+//            fetchNewToken();
+//        } else if (now >= expiryTimestamp) {
+//            logger.info("Token已过期或即将过期（在10分钟容差内），正在刷新Token...");
+//            refreshToken();
+//        } else {
+//            logger.debug("从缓存中获取有效Token。");
+//        }
+
         if (cachedToken == null) {
             logger.info("Token为空，首次获取新Token...");
             fetchNewToken();
         } else if (now >= expiryTimestamp) {
-            logger.info("Token已过期或即将过期（在10分钟容差内），正在刷新Token...");
-            refreshToken();
+            logger.info("Token已过期或即将过期（在10分钟容差内），正在重新获取Token...");
+//            refreshToken();
+            fetchNewToken();
         } else {
             logger.debug("从缓存中获取有效Token。");
         }
 
+        //2025-09-11 16:34:27
+
+
         return "Bearer " + this.cachedToken;
     }