wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update - API log 日志记录,增加调用方和客户端版本

Browse Source
This commit is contained in:
wangli 2024-06-28 17:33:52 +08:00
parent f2b49ebfbc
commit 2bebe80382
4 changed files with 46 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
workflow-engine-core/src/main/java/cn/axzo/workflow/core/common/event/ApiLogEvent.java
View File

@ -13,15 +13,20 @@ import org.springframework.context.ApplicationEvent;
public class ApiLogEvent extends ApplicationEvent {
private String traceId;
private String apiUrl;
private String requestApplicationName;
private String clientVersion;
private Object requestBody;
private Object responseBody;
private Double takeTime;
private String type;
public ApiLogEvent(String traceId, String apiUrl, Object requestBody, Object responseBody, Double takeTime, String type) {
public ApiLogEvent(String traceId, String apiUrl, String requestApplicationName, String clientVersion,
Object requestBody, Object responseBody, Double takeTime, String type) {
super(apiUrl);
this.traceId = traceId;
this.apiUrl = apiUrl;
this.requestApplicationName = requestApplicationName;
this.clientVersion = clientVersion;
this.requestBody = requestBody;
this.responseBody = responseBody;
this.takeTime = takeTime;
@ -40,6 +45,14 @@ public class ApiLogEvent extends ApplicationEvent {
return apiUrl;
}
public String getRequestApplicationName() {
return requestApplicationName;
}
public String getClientVersion() {
return clientVersion;
}
public Object getRequestBody() {
return requestBody;
}

10
workflow-engine-core/src/main/java/cn/axzo/workflow/core/repository/entity/ExtAxApiLog.java
View File

@ -28,6 +28,16 @@ public class ExtAxApiLog extends BaseEntity<ExtAxApiLog> {
*/
private String apiUrl;
/**
* 请求方服务名称
*/
private String requestApplicationName;
/**
* 客户端 API 版本
*/
private String clientVersion;
/**
* 请求参数
*/

6
workflow-engine-core/src/main/resources/sql/upgrade_to_1.3.3.1.sql
View File

@ -1,3 +1,9 @@
alter table ext_ax_api_log
modify request_body longblob null comment '请求参数';
alter table ext_ax_api_log
add request_application_name varchar(20) default '' null comment '请求方服务名称' after type;
alter table ext_ax_api_log
add client_version varchar(20) default '' null comment '客户端 API 版本' after request_application_name;

16
workflow-engine-server/src/main/java/cn/axzo/workflow/server/common/aspectj/ErrorReportAspect.java
View File

@ -20,11 +20,16 @@ import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;
import org.springframework.util.StopWatch;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.Arrays;
import java.util.Objects;
import static cn.axzo.workflow.client.config.WorkflowRequestInterceptor.HEADER_API_VERSION;
import static cn.axzo.workflow.client.config.WorkflowRequestInterceptor.HEADER_SERVER_NAME;
import static cn.azxo.framework.common.constatns.Constants.CTX_LOG_ID_MDC;
/**
@ -72,6 +77,8 @@ public class ErrorReportAspect implements Ordered {
String type = getType(joinPoint);
ApiLogEvent event = new ApiLogEvent(MDC.get(CTX_LOG_ID_MDC),
signature.toShortString(),
Objects.isNull(getOriginRequest()) ? "" : getOriginRequest().getHeader(HEADER_SERVER_NAME),
Objects.isNull(getOriginRequest()) ? "" : getOriginRequest().getHeader(HEADER_API_VERSION),
Objects.equals(type, "Controller") ? joinPoint.getArgs() : null,
Objects.equals(type, "Controller") ? result : null,
watch.getTotalTimeSeconds(),
@ -127,4 +134,13 @@ public class ErrorReportAspect implements Ordered {
}
}
}
private HttpServletRequest getOriginRequest() {
try {
ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
return Objects.requireNonNull(requestAttributes).getRequest();
} catch (Exception e) {
return null;
}
}
}