feat: 添加访问日志分页功能，优化相关接口和前端组件

atsf_server/service/access_log.go

@@ -6,7 +6,10 @@ import (
 	"time"
 )
 
-const accessLogListLimit = 500
+const (
+	defaultAccessLogPageSize = 50
+	maxAccessLogPageSize     = 200
+)
 
 type AccessLogView struct {
 	ID         uint      `json:"id"`
@@ -19,8 +22,23 @@ type AccessLogView struct {
 	StatusCode int       `json:"status_code"`
 }
 
-func ListAccessLogs(nodeID string) ([]AccessLogView, error) {
-	logs, err := model.ListNodeAccessLogs(strings.TrimSpace(nodeID), time.Now().Add(-nodeAccessLogRetentionWindow), accessLogListLimit)
+type AccessLogList struct {
+	Items    []AccessLogView `json:"items"`
+	Page     int             `json:"page"`
+	PageSize int             `json:"page_size"`
+	HasMore  bool            `json:"has_more"`
+}
+
+func ListAccessLogs(nodeID string, page int, pageSize int) (*AccessLogList, error) {
+	normalizedPage := normalizeAccessLogPage(page)
+	normalizedPageSize := normalizeAccessLogPageSize(pageSize)
+	offset := normalizedPage * normalizedPageSize
+	logs, err := model.ListNodeAccessLogs(
+		strings.TrimSpace(nodeID),
+		time.Now().Add(-nodeAccessLogRetentionWindow),
+		offset,
+		normalizedPageSize+1,
+	)
 	if err != nil {
 		return nil, err
 	}
@@ -35,6 +53,10 @@ func ListAccessLogs(nodeID string) ([]AccessLogView, error) {
 		}
 		nodeNames[node.NodeID] = node.Name
 	}
+	hasMore := len(logs) > normalizedPageSize
+	if hasMore {
+		logs = logs[:normalizedPageSize]
+	}
 	views := make([]AccessLogView, 0, len(logs))
 	for _, item := range logs {
 		if item == nil {
@@ -51,5 +73,27 @@ func ListAccessLogs(nodeID string) ([]AccessLogView, error) {
 			StatusCode: item.StatusCode,
 		})
 	}
-	return views, nil
+	return &AccessLogList{
+		Items:    views,
+		Page:     normalizedPage,
+		PageSize: normalizedPageSize,
+		HasMore:  hasMore,
+	}, nil
+}
+
+func normalizeAccessLogPage(page int) int {
+	if page < 0 {
+		return 0
+	}
+	return page
+}
+
+func normalizeAccessLogPageSize(pageSize int) int {
+	if pageSize <= 0 {
+		return defaultAccessLogPageSize
+	}
+	if pageSize > maxAccessLogPageSize {
+		return maxAccessLogPageSize
+	}
+	return pageSize
 }

atsf_server/service/node_update_test.go

@@ -673,7 +673,7 @@ func TestHeartbeatNodePersistsObservabilityPayload(t *testing.T) {
 		t.Fatalf("unexpected request reports: %+v", reports)
 	}
 
-	accessLogs, err := model.ListNodeAccessLogs(node.NodeID, time.Time{}, 10)
+	accessLogs, err := model.ListNodeAccessLogs(node.NodeID, time.Time{}, 0, 10)
 	if err != nil {
 		t.Fatalf("expected node access logs query to succeed: %v", err)
 	}
@@ -780,7 +780,7 @@ func TestHeartbeatNodePersistsBufferedObservabilityPayload(t *testing.T) {
 		t.Fatalf("expected current and buffered reports, got %+v", reports)
 	}
 
-	accessLogs, err := model.ListNodeAccessLogs(node.NodeID, time.Time{}, 10)
+	accessLogs, err := model.ListNodeAccessLogs(node.NodeID, time.Time{}, 0, 10)
 	if err != nil {
 		t.Fatalf("expected node access logs query to succeed: %v", err)
 	}
@@ -836,6 +836,75 @@ func TestHeartbeatNodePersistsBufferedObservabilityPayload(t *testing.T) {
 	}
 }
 
+func TestListAccessLogsUsesPagination(t *testing.T) {
+	setupServiceTestDB(t)
+
+	node := &model.Node{
+		NodeID:       "node-access-log-page",
+		Name:         "access-log-edge",
+		IP:           "10.0.0.40",
+		AgentToken:   "token-access-log-page",
+		AgentVersion: "v0.6.0",
+		NginxVersion: "1.27.1.2",
+		Status:       NodeStatusOnline,
+	}
+	if err := node.Insert(); err != nil {
+		t.Fatalf("failed to seed node: %v", err)
+	}
+
+	now := time.Now().UTC()
+	if err := model.DB.Create([]*model.NodeAccessLog{
+		{
+			NodeID:     node.NodeID,
+			LoggedAt:   now.Add(-10 * time.Second),
+			RemoteAddr: "203.0.113.1",
+			Host:       "example.com",
+			Path:       "/one",
+			StatusCode: 200,
+		},
+		{
+			NodeID:     node.NodeID,
+			LoggedAt:   now.Add(-9 * time.Second),
+			RemoteAddr: "203.0.113.2",
+			Host:       "example.com",
+			Path:       "/two",
+			StatusCode: 200,
+		},
+		{
+			NodeID:     node.NodeID,
+			LoggedAt:   now.Add(-8 * time.Second),
+			RemoteAddr: "203.0.113.3",
+			Host:       "example.com",
+			Path:       "/three",
+			StatusCode: 502,
+		},
+	}).Error; err != nil {
+		t.Fatalf("failed to seed access logs: %v", err)
+	}
+
+	pageOne, err := ListAccessLogs(node.NodeID, 0, 2)
+	if err != nil {
+		t.Fatalf("ListAccessLogs page 1 failed: %v", err)
+	}
+	if len(pageOne.Items) != 2 || !pageOne.HasMore {
+		t.Fatalf("unexpected first page: %+v", pageOne)
+	}
+	if pageOne.Items[0].Path != "/three" || pageOne.Items[1].Path != "/two" {
+		t.Fatalf("unexpected first page ordering: %+v", pageOne.Items)
+	}
+
+	pageTwo, err := ListAccessLogs(node.NodeID, 1, 2)
+	if err != nil {
+		t.Fatalf("ListAccessLogs page 2 failed: %v", err)
+	}
+	if len(pageTwo.Items) != 1 || pageTwo.HasMore {
+		t.Fatalf("unexpected second page: %+v", pageTwo)
+	}
+	if pageTwo.Items[0].Path != "/one" {
+		t.Fatalf("unexpected second page ordering: %+v", pageTwo.Items)
+	}
+}
+
 func TestHeartbeatNodeResolvesMissingHealthEvents(t *testing.T) {
 	setupServiceTestDB(t)