violet/ensign-crm-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

log:add log output

Browse Source
This commit is contained in:
zzs 2024-09-25 11:44:19 +08:00
parent 57fbed7ee0
commit 2064080d78
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
ensign-module-crm/ensign-module-crm-biz/src/main/java/com/ensign/crm/module/crm/controller/crm/ProxyController.java
View File

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