2026-04-21 19:55:31 +08:00
5 changed files with 883 additions and 1 deletions
@@ -91,7 +91,7 @@ $RECYCLE.BIN/
 # Logs
 logs/
 *.log
-log/
+/log/

 # Testing
 coverage/
@@ -0,0 +1,153 @@
+package cn.novalon.gym.manage.sys.handler.log;
+
+import cn.novalon.gym.manage.sys.core.domain.OperationLog;
+import cn.novalon.gym.manage.sys.core.query.OperationLogQuery;
+import cn.novalon.gym.manage.sys.core.service.IOperationLogService;
+import cn.novalon.gym.manage.sys.core.util.ExcelExportUtil;
+import cn.novalon.gym.manage.common.dto.PageRequest;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.function.server.ServerRequest;
+import org.springframework.web.reactive.function.server.ServerResponse;
+import reactor.core.publisher.Mono;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+/**
+ * 操作日志处理器
+ * 
+ * 文件定义：处理操作日志相关的HTTP请求
+ * 涉及业务：操作日志查询、分页、统计、导出
+ * 算法：使用WebFlux函数式编程模型处理响应式请求
+ * 
+ * @author 张翔
+ * @date 2026-03-18
+ */
+@Component
+@Tag(name = "操作日志", description = "操作日志相关操作")
+public class OperationLogHandler {
+
+    private final IOperationLogService logService;
+
+    public OperationLogHandler(IOperationLogService logService) {
+        this.logService = logService;
+    }
+
+    @Operation(summary = "获取所有操作日志", description = "获取系统中所有操作日志列表")
+    public Mono<ServerResponse> getAllOperationLogs(ServerRequest request) {
+        return ServerResponse.ok()
+                .body(logService.findAll(), OperationLog.class);
+    }
+
+    @Operation(summary = "根据ID获取操作日志", description = "根据操作日志ID获取详细信息")
+    public Mono<ServerResponse> getOperationLogById(ServerRequest request) {
+        Long id = Long.valueOf(request.pathVariable("id"));
+        return logService.findById(id)
+                .flatMap(log -> ServerResponse.ok().bodyValue(log))
+                .switchIfEmpty(ServerResponse.notFound().build());
+    }
+
+    @Operation(summary = "分页获取操作日志", description = "根据分页参数获取操作日志列表")
+    public Mono<ServerResponse> getOperationLogsByPage(ServerRequest request) {
+        int page = Integer.parseInt(request.queryParam("page").orElse("0"));
+        int size = Integer.parseInt(request.queryParam("size").orElse("10"));
+        String sort = request.queryParam("sort").orElse("createdAt");
+        String order = request.queryParam("order").orElse("desc");
+        String keyword = request.queryParam("keyword").orElse(null);
+        String username = request.queryParam("username").orElse(null);
+        String operation = request.queryParam("operation").orElse(null);
+        String status = request.queryParam("status").orElse(null);
+        String startTimeStr = request.queryParam("startTime").orElse(null);
+        String endTimeStr = request.queryParam("endTime").orElse(null);
+        String ip = request.queryParam("ip").orElse(null);
+        String method = request.queryParam("method").orElse(null);
+
+        PageRequest pageRequest = new PageRequest();
+        pageRequest.setPage(page);
+        pageRequest.setSize(size);
+        pageRequest.setSort(sort);
+        pageRequest.setOrder(order);
+        pageRequest.setKeyword(keyword);
+
+        OperationLogQuery query = new OperationLogQuery();
+        query.setUsername(username);
+        query.setOperation(operation);
+        query.setStatus(status);
+        query.setKeyword(keyword);
+        query.setIp(ip);
+        query.setMethod(method);
+
+        if (startTimeStr != null && !startTimeStr.isEmpty()) {
+            query.setStartTime(LocalDateTime.parse(startTimeStr));
+        }
+        if (endTimeStr != null && !endTimeStr.isEmpty()) {
+            query.setEndTime(LocalDateTime.parse(endTimeStr));
+        }
+
+        return logService.findByQueryWithPagination(query, pageRequest)
+                .flatMap(response -> ServerResponse.ok().bodyValue(response));
+    }
+
+    @Operation(summary = "获取操作日志总数", description = "获取系统中操作日志总数")
+    public Mono<ServerResponse> getOperationLogCount(ServerRequest request) {
+        return logService.count()
+                .flatMap(count -> ServerResponse.ok().bodyValue(count));
+    }
+
+    @Operation(summary = "创建操作日志", description = "手动创建操作日志")
+    public Mono<ServerResponse> createOperationLog(ServerRequest request) {
+        return request.bodyToMono(OperationLog.class)
+                .flatMap(logService::save)
+                .flatMap(log -> ServerResponse.status(HttpStatus.CREATED).bodyValue(log));
+    }
+
+    @Operation(summary = "导出操作日志", description = "导出操作日志为Excel文件")
+    public Mono<ServerResponse> exportOperationLogs(ServerRequest request) {
+        String username = request.queryParam("username").orElse(null);
+        String operation = request.queryParam("operation").orElse(null);
+        String status = request.queryParam("status").orElse(null);
+        String startTimeStr = request.queryParam("startTime").orElse(null);
+        String endTimeStr = request.queryParam("endTime").orElse(null);
+        String ip = request.queryParam("ip").orElse(null);
+        String method = request.queryParam("method").orElse(null);
+        String keyword = request.queryParam("keyword").orElse(null);
+
+        OperationLogQuery query = new OperationLogQuery();
+        query.setUsername(username);
+        query.setOperation(operation);
+        query.setStatus(status);
+        query.setIp(ip);
+        query.setMethod(method);
+        query.setKeyword(keyword);
+
+        if (startTimeStr != null && !startTimeStr.isEmpty()) {
+            query.setStartTime(LocalDateTime.parse(startTimeStr));
+        }
+        if (endTimeStr != null && !endTimeStr.isEmpty()) {
+            query.setEndTime(LocalDateTime.parse(endTimeStr));
+        }
+
+        return logService.findAll()
+                .collectList()
+                .flatMap(logs -> {
+                    try {
+                        byte[] excelData = ExcelExportUtil.exportOperationLogs(logs);
+                        String filename = "operation_logs_" + 
+                                LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMdd_HHmmss")) + 
+                                ".xlsx";
+                        
+                        return ServerResponse.ok()
+                                .header("Content-Disposition", "attachment; filename=\"" + filename + "\"")
+                                .contentType(MediaType.APPLICATION_OCTET_STREAM)
+                                .bodyValue(excelData);
+                    } catch (Exception e) {
+                        return ServerResponse.status(HttpStatus.INTERNAL_SERVER_ERROR)
+                                .bodyValue("导出失败: " + e.getMessage());
+                    }
+                });
+    }
+}
@@ -0,0 +1,139 @@
+package cn.novalon.gym.manage.sys.handler.log;
+
+import cn.novalon.gym.manage.sys.core.domain.SysLoginLog;
+import cn.novalon.gym.manage.sys.core.domain.SysExceptionLog;
+import cn.novalon.gym.manage.sys.core.service.ISysLoginLogService;
+import cn.novalon.gym.manage.sys.core.service.ISysExceptionLogService;
+import cn.novalon.gym.manage.common.dto.PageRequest;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.http.HttpStatus;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.function.server.ServerRequest;
+import org.springframework.web.reactive.function.server.ServerResponse;
+import reactor.core.publisher.Mono;
+
+/**
+ * 系统日志处理器
+ * 
+ * @author 张翔
+ * @date 2026-03-14
+ */
+@Component
+@Tag(name = "日志管理", description = "登录日志和异常日志相关操作")
+public class SysLogHandler {
+
+    private final ISysLoginLogService loginLogService;
+    private final ISysExceptionLogService exceptionLogService;
+
+    public SysLogHandler(ISysLoginLogService loginLogService, ISysExceptionLogService exceptionLogService) {
+        this.loginLogService = loginLogService;
+        this.exceptionLogService = exceptionLogService;
+    }
+
+    @Operation(summary = "获取所有登录日志", description = "获取系统中所有登录日志列表")
+    public Mono<ServerResponse> getAllLoginLogs(ServerRequest request) {
+        return ServerResponse.ok()
+                .body(loginLogService.findAll(), SysLoginLog.class);
+    }
+
+    @Operation(summary = "根据ID获取登录日志", description = "根据登录日志ID获取详细信息")
+    public Mono<ServerResponse> getLoginLogById(ServerRequest request) {
+        Long id = Long.valueOf(request.pathVariable("id"));
+        return loginLogService.findById(id)
+                .flatMap(log -> ServerResponse.ok().bodyValue(log))
+                .switchIfEmpty(ServerResponse.notFound().build());
+    }
+
+    @Operation(summary = "创建登录日志", description = "创建新的登录日志")
+    public Mono<ServerResponse> createLoginLog(ServerRequest request) {
+        return request.bodyToMono(SysLoginLog.class)
+                .flatMap(loginLogService::save)
+                .flatMap(log -> ServerResponse.status(HttpStatus.CREATED).bodyValue(log));
+    }
+
+    @Operation(summary = "分页获取登录日志", description = "根据分页参数获取登录日志列表")
+    public Mono<ServerResponse> getLoginLogsByPage(ServerRequest request) {
+        int page = Integer.parseInt(request.queryParam("page").orElse("0"));
+        int size = Integer.parseInt(request.queryParam("size").orElse("10"));
+        String sort = request.queryParam("sort").orElse("loginTime");
+        String order = request.queryParam("order").orElse("desc");
+        String keyword = request.queryParam("keyword").orElse(null);
+
+        PageRequest pageRequest = new PageRequest();
+        pageRequest.setPage(page);
+        pageRequest.setSize(size);
+        pageRequest.setSort(sort);
+        pageRequest.setOrder(order);
+        pageRequest.setKeyword(keyword);
+
+        return loginLogService.findLoginLogsByPage(pageRequest)
+                .flatMap(response -> ServerResponse.ok().bodyValue(response));
+    }
+
+    @Operation(summary = "获取登录日志总数", description = "获取系统中登录日志总数")
+    public Mono<ServerResponse> getLoginLogCount(ServerRequest request) {
+        return loginLogService.count()
+                .flatMap(count -> ServerResponse.ok().bodyValue(count));
+    }
+
+    @Operation(summary = "获取今日登录次数", description = "获取今日登录次数统计")
+    public Mono<ServerResponse> getTodayLoginCount(ServerRequest request) {
+        return loginLogService.countToday()
+                .flatMap(count -> ServerResponse.ok().bodyValue(count));
+    }
+
+    @Operation(summary = "获取最近登录日志", description = "获取最近N条登录日志记录")
+    public Mono<ServerResponse> getRecentLoginLogs(ServerRequest request) {
+        int limit = Integer.parseInt(request.queryParam("limit").orElse("10"));
+        return ServerResponse.ok()
+                .body(loginLogService.findRecent(limit), SysLoginLog.class);
+    }
+
+    @Operation(summary = "获取所有异常日志", description = "获取系统中所有异常日志列表")
+    public Mono<ServerResponse> getAllExceptionLogs(ServerRequest request) {
+        return ServerResponse.ok()
+                .body(exceptionLogService.findAll(), SysExceptionLog.class);
+    }
+
+    @Operation(summary = "根据ID获取异常日志", description = "根据异常日志ID获取详细信息")
+    public Mono<ServerResponse> getExceptionLogById(ServerRequest request) {
+        Long id = Long.valueOf(request.pathVariable("id"));
+        return exceptionLogService.findById(id)
+                .flatMap(log -> ServerResponse.ok().bodyValue(log))
+                .switchIfEmpty(ServerResponse.notFound().build());
+    }
+
+    @Operation(summary = "创建异常日志", description = "创建新的异常日志")
+    public Mono<ServerResponse> createExceptionLog(ServerRequest request) {
+        return request.bodyToMono(SysExceptionLog.class)
+                .flatMap(exceptionLogService::save)
+                .flatMap(log -> ServerResponse.status(HttpStatus.CREATED).bodyValue(log));
+    }
+
+    @Operation(summary = "分页获取异常日志", description = "根据分页参数获取异常日志列表")
+    public Mono<ServerResponse> getExceptionLogsByPage(ServerRequest request) {
+        int page = Integer.parseInt(request.queryParam("page").orElse("0"));
+        int size = Integer.parseInt(request.queryParam("size").orElse("10"));
+        String sort = request.queryParam("sort").orElse("id");
+        String order = request.queryParam("order").orElse("desc");
+        String keyword = request.queryParam("keyword").orElse(null);
+
+        PageRequest pageRequest = new PageRequest();
+        pageRequest.setPage(page);
+        pageRequest.setSize(size);
+        pageRequest.setSort(sort);
+        pageRequest.setOrder(order);
+        pageRequest.setKeyword(keyword);
+
+        return exceptionLogService.findExceptionLogsByPage(pageRequest)
+                .flatMap(response -> ServerResponse.ok().bodyValue(response));
+    }
+
+    @Operation(summary = "获取异常日志总数", description = "获取系统中异常日志总数")
+    public Mono<ServerResponse> getExceptionLogCount(ServerRequest request) {
+        return exceptionLogService.count()
+                .flatMap(count -> ServerResponse.ok().bodyValue(count));
+    }
+}
@@ -0,0 +1,180 @@
+package cn.novalon.gym.manage.sys.handler.log;
+
+import cn.novalon.gym.manage.sys.core.domain.OperationLog;
+import cn.novalon.gym.manage.sys.core.query.OperationLogQuery;
+import cn.novalon.gym.manage.sys.core.service.IOperationLogService;
+import cn.novalon.gym.manage.common.dto.PageRequest;
+import cn.novalon.gym.manage.common.dto.PageResponse;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+import org.springframework.http.HttpStatus;
+import org.springframework.mock.web.reactive.function.server.MockServerRequest;
+import org.springframework.web.reactive.function.server.ServerRequest;
+import org.springframework.web.reactive.function.server.ServerResponse;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import reactor.test.StepVerifier;
+
+import java.time.LocalDateTime;
+
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+@ExtendWith(MockitoExtension.class)
+class OperationLogHandlerTest {
+
+    @Mock
+    private IOperationLogService logService;
+
+    private OperationLogHandler logHandler;
+    private OperationLog testOperationLog;
+
+    @BeforeEach
+    void setUp() {
+        logHandler = new OperationLogHandler(logService);
+
+        testOperationLog = new OperationLog();
+        testOperationLog.setId(1L);
+        testOperationLog.setUsername("testuser");
+        testOperationLog.setOperation("测试操作");
+        testOperationLog.setMethod("testMethod");
+        testOperationLog.setParams("test params");
+        testOperationLog.setDuration(100L);
+        testOperationLog.setIp("192.168.1.1");
+        testOperationLog.setCreatedAt(LocalDateTime.now());
+    }
+
+    @Test
+    void testGetAllOperationLogs() {
+        when(logService.findAll()).thenReturn(Flux.just(testOperationLog));
+
+        ServerRequest request = MockServerRequest.builder().build();
+        Mono<ServerResponse> response = logHandler.getAllOperationLogs(request);
+
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+
+        verify(logService).findAll();
+    }
+
+    @Test
+    void testGetOperationLogById() {
+        when(logService.findById(1L)).thenReturn(Mono.just(testOperationLog));
+
+        ServerRequest request = MockServerRequest.builder()
+                .pathVariable("id", "1")
+                .build();
+        Mono<ServerResponse> response = logHandler.getOperationLogById(request);
+
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+
+        verify(logService).findById(1L);
+    }
+
+    @Test
+    void testGetOperationLogById_NotFound() {
+        when(logService.findById(999L)).thenReturn(Mono.empty());
+
+        ServerRequest request = MockServerRequest.builder()
+                .pathVariable("id", "999")
+                .build();
+        Mono<ServerResponse> response = logHandler.getOperationLogById(request);
+
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> serverResponse.statusCode() == HttpStatus.NOT_FOUND)
+                .verifyComplete();
+
+        verify(logService).findById(999L);
+    }
+
+    @Test
+    void testGetOperationLogsByPage() {
+        PageResponse<OperationLog> pageResponse = new PageResponse<>();
+        pageResponse.setContent(java.util.Collections.singletonList(testOperationLog));
+        pageResponse.setTotalElements(1L);
+        pageResponse.setTotalPages(1);
+        pageResponse.setPageSize(10);
+        pageResponse.setCurrentPage(0);
+
+        when(logService.findByQueryWithPagination(any(OperationLogQuery.class), any(PageRequest.class)))
+                .thenReturn(Mono.just(pageResponse));
+
+        ServerRequest request = MockServerRequest.builder()
+                .queryParam("page", "0")
+                .queryParam("size", "10")
+                .queryParam("sort", "createdAt")
+                .queryParam("order", "desc")
+                .build();
+        Mono<ServerResponse> response = logHandler.getOperationLogsByPage(request);
+
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+
+        verify(logService).findByQueryWithPagination(any(OperationLogQuery.class), any(PageRequest.class));
+    }
+
+    @Test
+    void testGetOperationLogsByPageWithKeyword() {
+        PageResponse<OperationLog> pageResponse = new PageResponse<>();
+        pageResponse.setContent(java.util.Collections.singletonList(testOperationLog));
+        pageResponse.setTotalElements(1L);
+        pageResponse.setTotalPages(1);
+        pageResponse.setPageSize(10);
+        pageResponse.setCurrentPage(0);
+
+        when(logService.findByQueryWithPagination(any(OperationLogQuery.class), any(PageRequest.class)))
+                .thenReturn(Mono.just(pageResponse));
+
+        ServerRequest request = MockServerRequest.builder()
+                .queryParam("page", "0")
+                .queryParam("size", "10")
+                .queryParam("sort", "createdAt")
+                .queryParam("order", "desc")
+                .queryParam("keyword", "test")
+                .build();
+        Mono<ServerResponse> response = logHandler.getOperationLogsByPage(request);
+
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+
+        verify(logService).findByQueryWithPagination(any(OperationLogQuery.class), any(PageRequest.class));
+    }
+
+    @Test
+    void testGetOperationLogCount() {
+        when(logService.count()).thenReturn(Mono.just(100L));
+
+        ServerRequest request = MockServerRequest.builder().build();
+        Mono<ServerResponse> response = logHandler.getOperationLogCount(request);
+
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+
+        verify(logService).count();
+    }
+
+    @Test
+    void testCreateOperationLog() {
+        when(logService.save(any(OperationLog.class))).thenReturn(Mono.just(testOperationLog));
+
+        ServerRequest request = MockServerRequest.builder()
+                .body(Mono.just(testOperationLog));
+        Mono<ServerResponse> response = logHandler.createOperationLog(request);
+
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> serverResponse.statusCode() == HttpStatus.CREATED)
+                .verifyComplete();
+
+        verify(logService).save(any(OperationLog.class));
+    }
+}
@@ -0,0 +1,410 @@
+package cn.novalon.gym.manage.sys.handler.log;
+
+import cn.novalon.gym.manage.sys.core.domain.SysLoginLog;
+import cn.novalon.gym.manage.sys.core.domain.SysExceptionLog;
+import cn.novalon.gym.manage.sys.core.service.ISysLoginLogService;
+import cn.novalon.gym.manage.sys.core.service.ISysExceptionLogService;
+import cn.novalon.gym.manage.common.dto.PageResponse;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+import org.springframework.http.HttpStatus;
+import org.springframework.mock.web.reactive.function.server.MockServerRequest;
+import org.springframework.web.reactive.function.server.ServerRequest;
+import org.springframework.web.reactive.function.server.ServerResponse;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import reactor.test.StepVerifier;
+
+import java.time.LocalDateTime;
+
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+@ExtendWith(MockitoExtension.class)
+class SysLogHandlerTest {
+
+    @Mock
+    private ISysLoginLogService loginLogService;
+
+    @Mock
+    private ISysExceptionLogService exceptionLogService;
+
+    private SysLogHandler logHandler;
+    private SysLoginLog testLoginLog;
+    private SysExceptionLog testExceptionLog;
+
+    @BeforeEach
+    void setUp() {
+        logHandler = new SysLogHandler(loginLogService, exceptionLogService);
+        
+        testLoginLog = new SysLoginLog();
+        testLoginLog.setId(1L);
+        testLoginLog.setUsername("testuser");
+        testLoginLog.setIp("192.168.1.1");
+        testLoginLog.setStatus("1");
+        testLoginLog.setLoginTime(LocalDateTime.now());
+        
+        testExceptionLog = new SysExceptionLog();
+        testExceptionLog.setId(1L);
+        testExceptionLog.setUsername("testuser");
+        testExceptionLog.setTitle("test operation");
+        testExceptionLog.setExceptionName("NullPointerException");
+        testExceptionLog.setExceptionMsg("Test exception");
+        testExceptionLog.setCreateTime(LocalDateTime.now());
+    }
+
+    @Test
+    void testGetAllLoginLogs() {
+        when(loginLogService.findAll()).thenReturn(Flux.just(testLoginLog));
+        
+        ServerRequest request = MockServerRequest.builder().build();
+        Mono<ServerResponse> response = logHandler.getAllLoginLogs(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+        
+        verify(loginLogService).findAll();
+    }
+
+    @Test
+    void testGetAllLoginLogs_WithPagination() {
+        PageResponse<SysLoginLog> pageResponse = new PageResponse<>();
+        pageResponse.setContent(java.util.Collections.singletonList(testLoginLog));
+        pageResponse.setTotalElements(1L);
+        pageResponse.setTotalPages(1);
+        
+        when(loginLogService.findLoginLogsByPage(any())).thenReturn(Mono.just(pageResponse));
+        
+        ServerRequest request = MockServerRequest.builder()
+                .queryParam("page", "0")
+                .queryParam("size", "10")
+                .build();
+        Mono<ServerResponse> response = logHandler.getLoginLogsByPage(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+        
+        verify(loginLogService).findLoginLogsByPage(any());
+    }
+
+    @Test
+    void testGetAllLoginLogs_WithOnlyPageParam() {
+        PageResponse<SysLoginLog> pageResponse = new PageResponse<>();
+        pageResponse.setContent(java.util.Collections.singletonList(testLoginLog));
+        pageResponse.setTotalElements(1L);
+        
+        when(loginLogService.findLoginLogsByPage(any())).thenReturn(Mono.just(pageResponse));
+        
+        ServerRequest request = MockServerRequest.builder()
+                .queryParam("page", "0")
+                .build();
+        Mono<ServerResponse> response = logHandler.getLoginLogsByPage(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+        
+        verify(loginLogService).findLoginLogsByPage(any());
+    }
+
+    @Test
+    void testGetLoginLogById() {
+        when(loginLogService.findById(1L)).thenReturn(Mono.just(testLoginLog));
+        
+        ServerRequest request = MockServerRequest.builder()
+                .pathVariable("id", "1")
+                .build();
+        Mono<ServerResponse> response = logHandler.getLoginLogById(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+        
+        verify(loginLogService).findById(1L);
+    }
+
+    @Test
+    void testGetLoginLogById_NotFound() {
+        when(loginLogService.findById(999L)).thenReturn(Mono.empty());
+        
+        ServerRequest request = MockServerRequest.builder()
+                .pathVariable("id", "999")
+                .build();
+        Mono<ServerResponse> response = logHandler.getLoginLogById(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.NOT_FOUND)
+                .verifyComplete();
+        
+        verify(loginLogService).findById(999L);
+    }
+
+    @Test
+    void testCreateLoginLog() {
+        SysLoginLog newLoginLog = new SysLoginLog();
+        newLoginLog.setUsername("newuser");
+        newLoginLog.setIp("192.168.1.2");
+        newLoginLog.setStatus("1");
+        
+        when(loginLogService.save(any())).thenReturn(Mono.just(testLoginLog));
+        
+        ServerRequest request = MockServerRequest.builder()
+                .body(Mono.just(newLoginLog));
+        Mono<ServerResponse> response = logHandler.createLoginLog(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.CREATED)
+                .verifyComplete();
+        
+        verify(loginLogService).save(any());
+    }
+
+    @Test
+    void testGetLoginLogsByPage() {
+        PageResponse<SysLoginLog> pageResponse = new PageResponse<>();
+        pageResponse.setContent(java.util.Collections.singletonList(testLoginLog));
+        pageResponse.setTotalElements(1L);
+        pageResponse.setTotalPages(1);
+        
+        when(loginLogService.findLoginLogsByPage(any())).thenReturn(Mono.just(pageResponse));
+        
+        ServerRequest request = MockServerRequest.builder()
+                .queryParam("page", "0")
+                .queryParam("size", "10")
+                .build();
+        Mono<ServerResponse> response = logHandler.getLoginLogsByPage(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+        
+        verify(loginLogService).findLoginLogsByPage(any());
+    }
+
+    @Test
+    void testGetLoginLogsByPage_WithKeyword() {
+        PageResponse<SysLoginLog> pageResponse = new PageResponse<>();
+        pageResponse.setContent(java.util.Collections.singletonList(testLoginLog));
+        pageResponse.setTotalElements(1L);
+        
+        when(loginLogService.findLoginLogsByPage(any())).thenReturn(Mono.just(pageResponse));
+        
+        ServerRequest request = MockServerRequest.builder()
+                .queryParam("page", "0")
+                .queryParam("size", "10")
+                .queryParam("keyword", "test")
+                .build();
+        Mono<ServerResponse> response = logHandler.getLoginLogsByPage(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+        
+        verify(loginLogService).findLoginLogsByPage(any());
+    }
+
+    @Test
+    void testGetLoginLogCount() {
+        when(loginLogService.count()).thenReturn(Mono.just(100L));
+        
+        ServerRequest request = MockServerRequest.builder().build();
+        Mono<ServerResponse> response = logHandler.getLoginLogCount(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+        
+        verify(loginLogService).count();
+    }
+
+    @Test
+    void testGetAllExceptionLogs() {
+        when(exceptionLogService.findAll()).thenReturn(Flux.just(testExceptionLog));
+        
+        ServerRequest request = MockServerRequest.builder().build();
+        Mono<ServerResponse> response = logHandler.getAllExceptionLogs(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+        
+        verify(exceptionLogService).findAll();
+    }
+
+    @Test
+    void testGetAllExceptionLogs_WithPagination() {
+        PageResponse<SysExceptionLog> pageResponse = new PageResponse<>();
+        pageResponse.setContent(java.util.Collections.singletonList(testExceptionLog));
+        pageResponse.setTotalElements(1L);
+        pageResponse.setTotalPages(1);
+        
+        when(exceptionLogService.findExceptionLogsByPage(any())).thenReturn(Mono.just(pageResponse));
+        
+        ServerRequest request = MockServerRequest.builder()
+                .queryParam("page", "0")
+                .queryParam("size", "10")
+                .build();
+        Mono<ServerResponse> response = logHandler.getExceptionLogsByPage(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+        
+        verify(exceptionLogService).findExceptionLogsByPage(any());
+    }
+
+    @Test
+    void testGetAllExceptionLogs_WithOnlySizeParam() {
+        PageResponse<SysExceptionLog> pageResponse = new PageResponse<>();
+        pageResponse.setContent(java.util.Collections.singletonList(testExceptionLog));
+        pageResponse.setTotalElements(1L);
+        
+        when(exceptionLogService.findExceptionLogsByPage(any())).thenReturn(Mono.just(pageResponse));
+        
+        ServerRequest request = MockServerRequest.builder()
+                .queryParam("size", "10")
+                .build();
+        Mono<ServerResponse> response = logHandler.getExceptionLogsByPage(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+        
+        verify(exceptionLogService).findExceptionLogsByPage(any());
+    }
+
+    @Test
+    void testGetExceptionLogById() {
+        when(exceptionLogService.findById(1L)).thenReturn(Mono.just(testExceptionLog));
+        
+        ServerRequest request = MockServerRequest.builder()
+                .pathVariable("id", "1")
+                .build();
+        Mono<ServerResponse> response = logHandler.getExceptionLogById(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+        
+        verify(exceptionLogService).findById(1L);
+    }
+
+    @Test
+    void testGetExceptionLogById_NotFound() {
+        when(exceptionLogService.findById(999L)).thenReturn(Mono.empty());
+        
+        ServerRequest request = MockServerRequest.builder()
+                .pathVariable("id", "999")
+                .build();
+        Mono<ServerResponse> response = logHandler.getExceptionLogById(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.NOT_FOUND)
+                .verifyComplete();
+        
+        verify(exceptionLogService).findById(999L);
+    }
+
+    @Test
+    void testCreateExceptionLog() {
+        SysExceptionLog newExceptionLog = new SysExceptionLog();
+        newExceptionLog.setUsername("newuser");
+        newExceptionLog.setTitle("new operation");
+        newExceptionLog.setExceptionName("RuntimeException");
+        newExceptionLog.setExceptionMsg("New exception");
+        
+        when(exceptionLogService.save(any())).thenReturn(Mono.just(testExceptionLog));
+        
+        ServerRequest request = MockServerRequest.builder()
+                .body(Mono.just(newExceptionLog));
+        Mono<ServerResponse> response = logHandler.createExceptionLog(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.CREATED)
+                .verifyComplete();
+        
+        verify(exceptionLogService).save(any());
+    }
+
+    @Test
+    void testGetExceptionLogsByPage() {
+        PageResponse<SysExceptionLog> pageResponse = new PageResponse<>();
+        pageResponse.setContent(java.util.Collections.singletonList(testExceptionLog));
+        pageResponse.setTotalElements(1L);
+        pageResponse.setTotalPages(1);
+        
+        when(exceptionLogService.findExceptionLogsByPage(any())).thenReturn(Mono.just(pageResponse));
+        
+        ServerRequest request = MockServerRequest.builder()
+                .queryParam("page", "0")
+                .queryParam("size", "10")
+                .build();
+        Mono<ServerResponse> response = logHandler.getExceptionLogsByPage(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+        
+        verify(exceptionLogService).findExceptionLogsByPage(any());
+    }
+
+    @Test
+    void testGetExceptionLogsByPage_WithKeyword() {
+        PageResponse<SysExceptionLog> pageResponse = new PageResponse<>();
+        pageResponse.setContent(java.util.Collections.singletonList(testExceptionLog));
+        pageResponse.setTotalElements(1L);
+        
+        when(exceptionLogService.findExceptionLogsByPage(any())).thenReturn(Mono.just(pageResponse));
+        
+        ServerRequest request = MockServerRequest.builder()
+                .queryParam("page", "0")
+                .queryParam("size", "10")
+                .queryParam("keyword", "test")
+                .build();
+        Mono<ServerResponse> response = logHandler.getExceptionLogsByPage(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+        
+        verify(exceptionLogService).findExceptionLogsByPage(any());
+    }
+
+    @Test
+    void testGetExceptionLogCount() {
+        when(exceptionLogService.count()).thenReturn(Mono.just(50L));
+        
+        ServerRequest request = MockServerRequest.builder().build();
+        Mono<ServerResponse> response = logHandler.getExceptionLogCount(request);
+        
+        StepVerifier.create(response)
+                .expectNextMatches(serverResponse -> 
+                    serverResponse.statusCode() == HttpStatus.OK)
+                .verifyComplete();
+        
+        verify(exceptionLogService).count();
+    }
+}