feat: 服务管理部分功能点实现

Author: Mecozea

internal/api/dashboard.go

@@ -167,6 +167,7 @@ func (h *DashboardHandler) HandleGetTunnelStats(c *gin.Context) {
 		Error          int64 `json:"error"`
 		Offline        int64 `json:"offline"`
 		TotalEndpoints int64 `json:"total_endpoints"`
+		TotalServices  int64 `json:"total_services"`
 	}
 
 	// 使用原生 SQL 查询统计数据
@@ -199,6 +200,16 @@ func (h *DashboardHandler) HandleGetTunnelStats(c *gin.Context) {
 		return
 	}
 
+	// 获取服务总数
+	err = h.dashboardService.DB().Raw("SELECT COUNT(*) FROM services").Scan(&stats.TotalServices).Error
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{
+			"success": false,
+			"error":   "获取服务总数失败: " + err.Error(),
+		})
+		return
+	}
+
 	c.JSON(http.StatusOK, gin.H{
 		"success": true,
 		"data":    stats,

internal/api/services.go

@@ -0,0 +1,100 @@
+package api
+
+import (
+	"NodePassDash/internal/services"
+	"net/http"
+
+	"github.com/gin-gonic/gin"
+)
+
+// ServicesHandler 服务处理器
+type ServicesHandler struct {
+	servicesService *services.ServiceImpl
+}
+
+// NewServicesHandler 创建服务处理器
+func NewServicesHandler(servicesService *services.ServiceImpl) *ServicesHandler {
+	return &ServicesHandler{servicesService: servicesService}
+}
+
+// SetupServicesRoutes 设置服务相关路由
+func SetupServicesRoutes(rg *gin.RouterGroup, servicesService *services.ServiceImpl) {
+	// 创建ServicesHandler实例
+	servicesHandler := NewServicesHandler(servicesService)
+
+	// 服务相关路由
+	rg.GET("/services", servicesHandler.GetServices)
+	rg.GET("/services/:sid/:type", servicesHandler.GetServiceByID)
+	rg.GET("/services/available-instances", servicesHandler.GetAvailableInstances)
+	rg.POST("/services/assemble", servicesHandler.AssembleService)
+}
+
+// GetServices 获取所有服务
+func (h *ServicesHandler) GetServices(c *gin.Context) {
+	serviceList, err := h.servicesService.GetServices()
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
+		return
+	}
+
+	response := services.ServiceResponse{
+		Success:  true,
+		Services: serviceList,
+	}
+
+	c.JSON(http.StatusOK, response)
+}
+
+// GetServiceByID 根据 SID 和 Type 获取单个服务
+func (h *ServicesHandler) GetServiceByID(c *gin.Context) {
+	sid := c.Param("sid")
+	serviceType := c.Param("type")
+
+	service, err := h.servicesService.GetServiceByID(sid, serviceType)
+	if err != nil {
+		c.JSON(http.StatusNotFound, gin.H{"error": "服务不存在"})
+		return
+	}
+
+	response := services.ServiceResponse{
+		Success: true,
+		Service: service,
+	}
+
+	c.JSON(http.StatusOK, response)
+}
+
+// GetAvailableInstances 获取可用实例
+func (h *ServicesHandler) GetAvailableInstances(c *gin.Context) {
+	instances, err := h.servicesService.GetAvailableInstances()
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
+		return
+	}
+
+	response := services.AvailableInstancesResponse{
+		Success:   true,
+		Instances: instances,
+	}
+
+	c.JSON(http.StatusOK, response)
+}
+
+// AssembleService 组装服务
+func (h *ServicesHandler) AssembleService(c *gin.Context) {
+	var req services.AssembleServiceRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "请求参数错误: " + err.Error()})
+		return
+	}
+
+	if err := h.servicesService.AssembleService(&req); err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"error": "组装服务失败: " + err.Error()})
+		return
+	}
+
+	c.JSON(http.StatusOK, gin.H{
+		"success": true,
+		"message": "组装服务成功",
+	})
+}

internal/db/db.go

@@ -14,10 +14,10 @@ import (
 	"sync"
 	"time"
 
+	_ "github.com/mattn/go-sqlite3"
 	"gorm.io/driver/sqlite"
 	"gorm.io/gorm"
 	"gorm.io/gorm/logger"
-	_ "github.com/mattn/go-sqlite3"
 )
 
 var (
@@ -193,6 +193,9 @@ func QuickInitSchema(db *gorm.DB) error {
 		&models.TrafficHourlySummary{},
 		&models.DashboardTrafficSummary{},
 		&models.ServiceHistory{},
+
+		// 服务管理表
+		&models.Services{},
 	)
 }
 
@@ -220,6 +223,9 @@ func StandardMigrate(db *gorm.DB) error {
 		&models.TrafficHourlySummary{},
 		&models.DashboardTrafficSummary{},
 		&models.ServiceHistory{},
+
+		// 服务管理表
+		&models.Services{},
 	)
 }
 

internal/models/models.go

@@ -143,6 +143,29 @@ type TunnelRecycle struct {
 	DeletedAt     time.Time  `json:"deletedAt" gorm:"autoCreateTime;column:deleted_at"`
 }
 
+type Services struct {
+	Sid                string    `json:"sid" gorm:"type:text;primaryKey;column:sid"`
+	Type               string    `json:"type" gorm:"type:text;primaryKey;column:type"`
+	Alias              *string   `json:"alias,omitempty" gorm:"type:text;column:alias"`
+	ServerInstanceId   *string   `json:"serverInstanceId,omitempty" gorm:"type:text;column:server_instance_id"`
+	ClientInstanceId   *string   `json:"clientInstanceId,omitempty" gorm:"type:text;column:client_instance_id"`
+	ServerEndpointId   *int64    `json:"serverEndpointId,omitempty" gorm:"type:int;column:server_endpoint_id"`
+	ClientEndpointId   *int64    `json:"clientEndpointId,omitempty" gorm:"type:int;column:server_endpoint_id"`
+	TunnelPort         *int64    `json:"tunnelPort,omitempty" gorm:"type:int;column:tunnel_port"`
+	TunnelEndpointName *string   `json:"tunnelEndpointName,omitempty" gorm:"type:text;column:tunnel_endpoint_name"`
+	EntrancePort       *int64    `json:"entrancePort,omitempty" gorm:"type:int;column:entrance_port"`
+	EntranceHost       *string   `json:"entranceHost,omitempty" gorm:"type:text;column:entrance_host"`
+	ExitPort           *int64    `json:"exitPort,omitempty" gorm:"type:int;column:exit_port"`
+	ExitHost           *string   `json:"exitHost,omitempty" gorm:"type:text;column:exit_host"`
+	CreatedAt          time.Time `json:"createdAt" gorm:"autoCreateTime;column:created_at"`
+	UpdatedAt          time.Time `json:"updatedAt" gorm:"autoUpdateTime;column:updated_at"`
+}
+
+// TableName 设置表名
+func (Services) TableName() string {
+	return "services"
+}
+
 // TableName 设置表名
 func (TunnelRecycle) TableName() string {
 	return "tunnel_recycle"

internal/router/router.go

@@ -5,9 +5,10 @@ import (
 	"NodePassDash/internal/auth"
 	"NodePassDash/internal/dashboard"
 	"NodePassDash/internal/endpoint"
+	"NodePassDash/internal/group"
 	"NodePassDash/internal/metrics"
+	"NodePassDash/internal/services"
 	"NodePassDash/internal/sse"
-	"NodePassDash/internal/group"
 	"NodePassDash/internal/tunnel"
 	"NodePassDash/internal/websocket"
 	"fmt"
@@ -50,6 +51,7 @@ func setupAPIRoutes(r *gin.Engine, db *gorm.DB, sseService *sse.Service, sseMana
 		endpointService := endpoint.NewService(db)
 		tunnelService := tunnel.NewService(db)
 		groupService := group.NewService(db)
+		servicesService := services.NewService(db)
 		dashboardService := dashboard.NewService(db)
 
 		// 创建 Metrics 系统相关的处理器
@@ -65,6 +67,7 @@ func setupAPIRoutes(r *gin.Engine, db *gorm.DB, sseService *sse.Service, sseMana
 		api.SetupDashboardRoutes(apiGroup, dashboardService)
 		api.SetupDataRoutes(apiGroup, db, sseManager, endpointService, tunnelService)
 		api.SetupGroupRoutes(apiGroup, groupService)
+		api.SetupServicesRoutes(apiGroup, servicesService)
 		api.SetupVersionRoutes(apiGroup, version)
 		api.SetupDebugRoutes(apiGroup)
 	}
@@ -74,22 +77,22 @@ func setupAPIRoutes(r *gin.Engine, db *gorm.DB, sseService *sse.Service, sseMana
 func docsProxyHandler(c *gin.Context) {
 	// 获取路径参数
 	path := c.Param("path")
-	
+
 	// 构建目标 URL
 	targetURL := fmt.Sprintf("https://raw.githubusercontent.com%s", path)
-	
+
 	// 创建 HTTP 客户端
 	client := &http.Client{
 		Timeout: 30 * time.Second,
 	}
-	
+
 	// 创建请求
 	req, err := http.NewRequest(c.Request.Method, targetURL, c.Request.Body)
 	if err != nil {
 		c.JSON(http.StatusInternalServerError, gin.H{"error": "创建请求失败"})
 		return
 	}
-	
+
 	// 复制请求头（排除某些不需要的头）
 	for name, values := range c.Request.Header {
 		if !shouldSkipHeader(name) {
@@ -98,15 +101,15 @@ func docsProxyHandler(c *gin.Context) {
 			}
 		}
 	}
-	
+
 	// 发送请求
 	resp, err := client.Do(req)
 	if err != nil {
 		c.JSON(http.StatusBadGateway, gin.H{"error": "代理请求失败"})
 		return
 	}
 	defer resp.Body.Close()
-	
+
 	// 复制响应头
 	for name, values := range resp.Header {
 		if !shouldSkipHeader(name) {
@@ -115,10 +118,10 @@ func docsProxyHandler(c *gin.Context) {
 			}
 		}
 	}
-	
+
 	// 设置状态码
 	c.Status(resp.StatusCode)
-	
+
 	// 复制响应体
 	_, err = io.Copy(c.Writer, resp.Body)
 	if err != nil {
@@ -139,7 +142,7 @@ func shouldSkipHeader(name string) bool {
 		"Transfer-Encoding",
 		"Upgrade",
 	}
-	
+
 	for _, skip := range skipHeaders {
 		if strings.EqualFold(name, skip) {
 			return true