創建數據庫表

CREATE TABLE `sys_operation_log` (`log_id` bigint NOT NULL AUTO_INCREMENT COMMENT '日志ID',`operation_type` varchar(20) NOT NULL COMMENT '操作類型',`operation_module` varchar(50) NOT NULL COMMENT '操作模塊',`operation_desc` varchar(200) DEFAULT NULL COMMENT '操作描述',`request_method` varchar(10) DEFAULT NULL COMMENT '請求方法',`request_url` varchar(500) DEFAULT NULL COMMENT '請求URL',`request_params` text DEFAULT NULL COMMENT '請求參數',`response_result` text DEFAULT NULL COMMENT '響應結果',`user_id` varchar(36) DEFAULT NULL COMMENT '操作用戶ID',`user_name` varchar(50) DEFAULT NULL COMMENT '操作用戶名',`user_ip` varchar(50) DEFAULT NULL COMMENT '用戶IP',`user_agent` varchar(500) DEFAULT NULL COMMENT '用戶代理',`operation_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '操作時間',`execution_time` bigint DEFAULT NULL COMMENT '執行耗時(ms)',`status` tinyint DEFAULT 1 COMMENT '操作狀態(0失敗 1成功)',`error_msg` text DEFAULT NULL COMMENT '錯誤信息',PRIMARY KEY (`log_id`),KEY `idx_user_id` (`user_id`),KEY `idx_operation_time` (`operation_time`),KEY `idx_module_type` (`operation_module`, `operation_type`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='系統操作日志表';

添加pom.xml依賴

<dependencies><!-- Spring Boot Web --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- MyBatis-Plus --><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>最新版本</version></dependency><!-- AOP --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId></dependency><!-- Lombok --><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency>
</dependencies>

創建實體類

import com.baomidou.mybatisplus.annotation.*;import java.util.Date;@Data
@TableName("sys_operation_log")
public class SysOperationLog {@TableId(value = "log_id", type = IdType.AUTO)private Long logId;private String operationType;private String operationModule;private String operationDesc;private String requestMethod;private String requestUrl;private String requestParams;private String responseResult;private String userId;private String userName;private String userIp;private String userAgent;@TableField(fill = FieldFill.INSERT)private Date operationTime;private Long executionTime;private Integer status;private String errorMsg;
}

添加mapper

import com.baomidou.mybatisplus.core.mapper.BaseMapper;public interface SysOperationLogMapper extends BaseMapper<SysOperationLog> {
}

創建自定義注解

import java.lang.annotation.*;@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Loggable {String operationType() default "";String module() default "";String description() default "";
}

創建AOP切面

import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;import javax.servlet.http.HttpServletRequest;
import java.lang.reflect.Method;
import java.util.Date;@Aspect
@Component
@Slf4j
public class OperationLogAspect {private final SysOperationLogMapper logMapper;private final ObjectMapper objectMapper;public OperationLogAspect(SysOperationLogMapper logMapper, ObjectMapper objectMapper) {this.logMapper = logMapper;this.objectMapper = objectMapper;}@Around("@annotation(com.yourpackage.annotation.Loggable)")public Object logOperation(ProceedingJoinPoint joinPoint) throws Throwable {long startTime = System.currentTimeMillis();SysOperationLog operationLog = new SysOperationLog();Object result = null;try {// 獲取注解信息MethodSignature signature = (MethodSignature) joinPoint.getSignature();Method method = signature.getMethod();Loggable loggable = method.getAnnotation(Loggable.class);// 填充日志基本信息operationLog.setOperationType(loggable.operationType());operationLog.setOperationModule(loggable.module());operationLog.setOperationDesc(loggable.description());operationLog.setOperationTime(new Date());// 獲取請求信息ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();if (attributes != null) {HttpServletRequest request = attributes.getRequest();operationLog.setRequestMethod(request.getMethod());operationLog.setRequestUrl(request.getRequestURI());operationLog.setUserIp(request.getRemoteAddr());operationLog.setUserAgent(request.getHeader("User-Agent"));}// 獲取用戶信息（根據你的系統實現）operationLog.setUserId("當前用戶ID");operationLog.setUserName("當前用戶名");// 獲取請求參數Object[] args = joinPoint.getArgs();operationLog.setRequestParams(objectMapper.writeValueAsString(args));// 執行目標方法result = joinPoint.proceed();// 記錄響應結果operationLog.setResponseResult(objectMapper.writeValueAsString(result));operationLog.setStatus(1);} catch (Exception e) {operationLog.setStatus(0);operationLog.setErrorMsg(e.getMessage());throw e;} finally {long endTime = System.currentTimeMillis();operationLog.setExecutionTime(endTime - startTime);// 異步保存日志（建議使用異步方式）logMapper.insert(operationLog);}return result;}
}

這是一個獲取用戶id和用戶名的示例方法

import org.springframework.security.core.context.SecurityContextHolder;
import org.springframework.stereotype.Component;@Component
public class UserInfoUtils {// 根據你的安全框架實現獲取用戶信息public String getCurrentUserId() {// 示例：從Spring Security獲取return SecurityContextHolder.getContext().getAuthentication().getName();}public String getCurrentUsername() {// 實現獲取用戶名邏輯return "用戶名";}
}

使用

@RestController
@RequestMapping("/api")
public class DemoController {@Loggable(operationType = "QUERY", module = "用戶管理", description = "查詢用戶列表")@GetMapping("/users")public List<User> getUsers() {// 業務邏輯}
}

為了防止數據庫越來越大，可以刪除一年前的數據，我們可以通過數據庫層面實現

1. 創建存儲過程

DELIMITER $$CREATE PROCEDURE clean_old_logs()
BEGINDECLARE batch_size INT DEFAULT 1000;DECLARE deleted_rows INT DEFAULT 1;WHILE deleted_rows > 0 DODELETE FROM sys_operation_log WHERE operation_time < NOW() - INTERVAL 1 YEAR LIMIT batch_size;SET deleted_rows = ROW_COUNT();COMMIT;DO SLEEP(0.5); -- 防止鎖表太久END WHILE;
END$$DELIMITER ;

2. 創建定時事件，一天一次

CREATE EVENT execute_clean_procedure
ON SCHEDULE EVERY 1 DAY
STARTS CURRENT_TIMESTAMP + INTERVAL 1 DAY
DO
BEGINCALL clean_old_logs();
END