diff --git a/ensign-module-crm/ensign-module-crm-biz/src/main/java/com/ensign/crm/module/crm/controller/crm/ProxyController.java b/ensign-module-crm/ensign-module-crm-biz/src/main/java/com/ensign/crm/module/crm/controller/crm/ProxyController.java index 117300d..e1c073f 100644 --- a/ensign-module-crm/ensign-module-crm-biz/src/main/java/com/ensign/crm/module/crm/controller/crm/ProxyController.java +++ b/ensign-module-crm/ensign-module-crm-biz/src/main/java/com/ensign/crm/module/crm/controller/crm/ProxyController.java @@ -5,6 +5,7 @@ import cn.hutool.json.JSONUtil; import com.ensign.crm.module.crm.exception.AllKingdeeException; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.tags.Tag; +import lombok.extern.slf4j.Slf4j; import org.apache.http.HttpEntity; import org.apache.http.HttpResponse; import org.apache.http.client.HttpClient; @@ -45,6 +46,7 @@ import java.util.concurrent.TimeUnit; @Tag(name = "CRM - Proxy") @RequestMapping("/crm-api/proxy") @Validated +@Slf4j public class ProxyController { @Value("${ensign.kingdee.is-public}") @@ -82,6 +84,12 @@ public class ProxyController { target = target + "?" + query; } URI newUri = new URI(target); + + log.info("================request kingdee start================"); + log.info("Request Parameters:"); + log.info("URI: {}", newUri); + log.info("Method: {}", request.getMethod()); + // 执行代理查询 String methodName = request.getMethod(); HttpMethod httpMethod = HttpMethod.resolve(methodName); @@ -98,11 +106,16 @@ public class ProxyController { while (v.hasMoreElements()) { arr.add(v.nextElement()); } + log.info("Header: {}: {}", headerName, arr); delegate.getHeaders().addAll(headerName, arr); } try { - delegate.getHeaders().add("access_token", initAccessToken()); + String accessToken = initAccessToken(); + delegate.getHeaders().add("access_token", accessToken); + log.info("Header: access_token: {}", accessToken); } catch (AllKingdeeException e) { + log.error("获取accessToken时失败:{}", e.getMessage()); + log.info("================request kingdee end================"); response.setStatus(HttpServletResponse.SC_OK); response.setContentType("application/json"); response.setCharacterEncoding("UTF-8"); @@ -116,11 +129,17 @@ public class ProxyController { StreamUtils.copy(request.getInputStream(), delegate.getBody()); // 执行远程调用 ClientHttpResponse clientHttpResponse = delegate.execute(); + log.info("Response Status: {}", clientHttpResponse.getStatusCode().value()); + clientHttpResponse.getHeaders().forEach((key, value) -> value.forEach(it -> { + log.info("Response Header: {}: {}", key, it); + })); + response.setStatus(clientHttpResponse.getStatusCode().value()); // 设置响应头 clientHttpResponse.getHeaders().forEach((key, value) -> value.forEach(it -> { response.setHeader(key, it); })); + log.info("================request kingdee end================"); StreamUtils.copy(clientHttpResponse.getBody(), response.getOutputStream()); }