From f5247cc21fb9bcafbb550f9a92d1001389ffc02a Mon Sep 17 00:00:00 2001 From: PengJ <2413927716@qq.com> Date: Wed, 24 Dec 2025 14:35:38 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90=E5=AE=89=E7=9C=BC=E3=80=91=E6=8B=A6?= =?UTF-8?q?=E6=88=AA=E5=99=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../anyan/config/AnYanRestTemplateConfig.java | 17 ++--------------- 1 file changed, 2 insertions(+), 15 deletions(-) diff --git a/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/config/AnYanRestTemplateConfig.java b/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/config/AnYanRestTemplateConfig.java index 8b5c37e..d695569 100644 --- a/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/config/AnYanRestTemplateConfig.java +++ b/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/config/AnYanRestTemplateConfig.java @@ -2,7 +2,6 @@ package com.renkang.restaurant.config; import com.renkang.anyan.client.AnYanClient; import com.renkang.anyan.config.AnYanProperties; -import com.renkang.anyan.enums.AnYanApiEnum; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.jeecg.common.exception.ExceptionAssertsUtil; @@ -22,7 +21,6 @@ import java.nio.charset.StandardCharsets; import java.time.Duration; import java.time.temporal.ChronoUnit; import java.util.Arrays; -import java.util.concurrent.atomic.AtomicInteger; /** * @Description: AnYanClient xj安眼系统接口调用客户端 @@ -55,27 +53,16 @@ public class AnYanRestTemplateConfig { * 自定义拦截器处理接口鉴权失败, 配合spring retry使用从而避免因token失效导致的接口调用失败 */ public ClientHttpRequestInterceptor authInterceptor() { - // 添加重试次数限制 - AtomicInteger retryCount = new AtomicInteger(0); - int maxRetries = 5; return (httpRequest, bytes, clientHttpRequestExecution) -> { ClientHttpResponse execute; try { - // 获取请求URL - String url = httpRequest.getURI().toString(); - // 排除特定接口不执行拦截逻辑 - boolean shouldSkip = url.contains(AnYanApiEnum.QUERY_AUTH_TOKEN.getMethodPath()); execute = clientHttpRequestExecution.execute(httpRequest, bytes); - if (shouldSkip) { - return execute; - } HttpStatus httpStatus = execute.getStatusCode(); - if (Arrays.asList(HttpStatus.UNAUTHORIZED, HttpStatus.FORBIDDEN).contains(httpStatus) - && retryCount.getAndIncrement() < maxRetries) { + if (Arrays.asList(HttpStatus.UNAUTHORIZED, HttpStatus.FORBIDDEN).contains(httpStatus)) { SpringContextUtils.getBean("anYanClientExecutor", AnYanClient.class).refreshToken(); } } catch (Exception e) { - log.error("---------安眼平台API调用异常-------e{}", e.getMessage(), e); + log.error("---------安眼平台API调用异常-------e{},接口:{}", e.getMessage(), httpRequest.getURI(), e); ExceptionAssertsUtil.fail("安眼平台API调用失败"); throw e; }