refactor(ApiTokenManager): 优化Token管理逻辑并移除未使用的导入

在`ApiTokenManager`类中,对Token的获取和刷新逻辑进行了重构。具体改动包括:
- 将原有的Token过期处理逻辑从直接调用`refreshToken()`改为调用`fetchNewToken()`。
- 添加了注释掉的代码块用于调试目的,但不影响实际运行逻辑。
- 移除了`ZsyhCbsProcessor`类中未被使用的`java.io.InputStream`导入语句。这些修改旨在提高代码可读性和维护性。
This commit is contained in:
liuy 2025-09-11 16:55:45 +08:00
parent ca263155c0
commit b087e5d2fc
2 changed files with 16 additions and 3 deletions

View File

@ -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.*;

View File

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