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; }