✨ Add pagination for topology

Author: Cairry

internal/repo/topology.go

@@ -1,8 +1,9 @@
 package repo
 
 import (
-	"gorm.io/gorm"
 	"watchAlert/internal/models"
+
+	"gorm.io/gorm"
 )
 
 type (
@@ -14,7 +15,7 @@ type (
 		Create(params models.Topology) error
 		Update(params models.Topology) error
 		Delete(tenantId, id string) error
-		List(tenantId, query string) ([]models.TopologyList, error)
+		List(tenantId, query string, page models.Page) ([]models.TopologyList, int64, error)
 		Get(tenantId, id string) (models.Topology, error)
 		GetDetail(tenantId, id string) (models.Topology, error)
 	}
@@ -68,10 +69,11 @@ func (t topologyRepo) Delete(tenantId, id string) error {
 	return nil
 }
 
-func (t topologyRepo) List(tenantId, query string) ([]models.TopologyList, error) {
+func (t topologyRepo) List(tenantId, query string, page models.Page) ([]models.TopologyList, int64, error) {
 	var (
-		data []models.TopologyList
-		db   = t.db.Model(&models.Topology{})
+		data  []models.TopologyList
+		db    = t.db.Model(&models.Topology{})
+		count int64
 	)
 
 	if tenantId != "" {
@@ -81,12 +83,14 @@ func (t topologyRepo) List(tenantId, query string) ([]models.TopologyList, error
 		db.Where("name LIKE ? OR id LIKE ?", "%"+query+"%", "%"+query+"%")
 	}
 
+	db.Count(&count)
+	db.Limit(int(page.Size)).Offset(int((page.Index - 1) * page.Size))
 	err := db.Find(&data).Error
 	if err != nil {
-		return nil, err
+		return nil, 0, err
 	}
 
-	return data, nil
+	return data, count, nil
 }
 
 func (t topologyRepo) Get(tenantId, id string) (models.Topology, error) {
@@ -112,4 +116,4 @@ func (t topologyRepo) Get(tenantId, id string) (models.Topology, error) {
 // GetDetail 获取拓扑的完整信息，包括nodes和edges
 func (t topologyRepo) GetDetail(tenantId, id string) (models.Topology, error) {
 	return t.Get(tenantId, id)
-}
+}

internal/services/topology.go

@@ -86,11 +86,19 @@ func (t topologyService) Delete(req interface{}) (data interface{}, err interfac
 
 func (t topologyService) List(req interface{}) (data interface{}, err interface{}) {
 	r := req.(*types.RequestTopologyQuery)
-	data, err = t.ctx.DB.Topology().List(r.TenantId, r.Query)
+	list, count, err := t.ctx.DB.Topology().List(r.TenantId, r.Query, r.Page)
 	if err != nil {
 		return nil, err
 	}
-	return data, nil
+
+	return types.ResponseTopologyList{
+		List: list,
+		Page: models.Page{
+			Total: count,
+			Index: r.Page.Index,
+			Size:  r.Page.Size,
+		},
+	}, nil
 }
 
 // GetDetail 获取拓扑的完整信息，包括nodes和edges

internal/types/topology.go

@@ -29,10 +29,16 @@ type RequestTopologyQuery struct {
 	ID       string `form:"id"`
 	Name     string `form:"name"`
 	Query    string `form:"query"`
+	models.Page
 }
 
 // RequestTopologyDelete 请求删除拓扑图
 type RequestTopologyDelete struct {
 	TenantId string `json:"tenantId"`
 	ID       string `json:"id"`
 }
+
+type ResponseTopologyList struct {
+	List []models.TopologyList `json:"list"`
+	models.Page
+}