refactor(service_manager): 重构服务管理模块数据库模型和API

- 重构数据库模型，简化部署任务和状态管理结构
- 移除不再使用的部署批次相关代码
- 更新数据库连接配置和SQL查询语句
- 添加CORS中间件支持
- 调整API路由顺序和移除不再使用的端点
- 更新健康状态枚举命名和类型定义
- 添加数据库schema文件定义表结构

Author: JaD1ng

go.mod

@@ -4,6 +4,7 @@ go 1.24
 
 require (
 	github.com/fox-gonic/fox v0.0.6
+	github.com/lib/pq v1.10.9
 	github.com/rs/zerolog v1.34.0
 )
 

go.sum

@@ -50,6 +50,8 @@ github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
 github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ=
 github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI=
+github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw=
+github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
 github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovkB8vQcUbaXHg=
 github.com/mattn/go-colorable v0.1.14 h1:9A9LHSqF/7dyVVX6g0U9cwm9pG3kP9gSzcuIPHPsaIE=
 github.com/mattn/go-colorable v0.1.14/go.mod h1:6LmQG8QLFO4G5z1gPvYEzlUgJ2wF+stgPZH1UqBm1s8=

internal/config/config.go

@@ -39,8 +39,8 @@ func Load() (*Config, error) {
 		Database: DatabaseConfig{
 			Host:     getEnv("DB_HOST", "localhost"),
 			Port:     getEnvInt("DB_PORT", 5432),
-			User:     getEnv("DB_USER", "postgres"),
-			Password: getEnv("DB_PASSWORD", ""),
+			User:     getEnv("DB_USER", "admin"),
+			Password: getEnv("DB_PASSWORD", "password"),
 			DBName:   getEnv("DB_NAME", "zeroops"),
 			SSLMode:  getEnv("DB_SSLMODE", "disable"),
 		},

internal/middleware/cors.go

@@ -0,0 +1,33 @@
+package middleware
+
+import (
+	"net/http"
+
+	"github.com/fox-gonic/fox"
+)
+
+// CORS 跨域中间件
+func CORS() fox.HandlerFunc {
+	return func(c *fox.Context) {
+		origin := c.Request.Header.Get("Origin")
+
+		// 设置CORS头
+		c.Header("Access-Control-Allow-Origin", "*")
+		c.Header("Access-Control-Allow-Credentials", "true")
+		c.Header("Access-Control-Allow-Headers", "Content-Type, Content-Length, Accept-Encoding, X-CSRF-Token, Authorization, accept, origin, Cache-Control, X-Requested-With")
+		c.Header("Access-Control-Allow-Methods", "POST, OPTIONS, GET, PUT, DELETE, PATCH")
+
+		// 处理预检请求
+		if c.Request.Method == "OPTIONS" {
+			c.AbortWithStatus(http.StatusNoContent)
+			return
+		}
+
+		// 设置实际的Origin（如果有的话）
+		if origin != "" {
+			c.Header("Access-Control-Allow-Origin", origin)
+		}
+
+		c.Next()
+	}
+}

internal/service_manager/api/api.go

@@ -2,6 +2,7 @@ package api
 
 import (
 	"github.com/fox-gonic/fox"
+	"github.com/qiniu/zeroops/internal/middleware"
 	"github.com/qiniu/zeroops/internal/service_manager/database"
 	"github.com/qiniu/zeroops/internal/service_manager/service"
 )
@@ -18,6 +19,10 @@ func NewApi(db *database.Database, service *service.Service, router *fox.Engine)
 		service: service,
 		router:  router,
 	}
+
+	// 添加CORS中间件
+	router.Use(middleware.CORS())
+
 	api.setupRouters(router)
 	return api, nil
 }

internal/service_manager/api/deploy_api.go

@@ -14,9 +14,9 @@ import (
 func (api *Api) setupDeployRouters(router *fox.Engine) {
 	// 部署任务基本操作
 	router.POST("/v1/deployments", api.CreateDeployment)
+	router.GET("/v1/deployments", api.GetDeployments)
 	router.GET("/v1/deployments/:deployID", api.GetDeploymentByID)
 	router.POST("/v1/deployments/:deployID", api.UpdateDeployment)
-	router.GET("/v1/deployments", api.GetDeployments)
 	router.DELETE("/v1/deployments/:deployID", api.DeleteDeployment)
 
 	// 部署任务控制操作

internal/service_manager/api/info_api.go

@@ -13,7 +13,6 @@ import (
 func (api *Api) setupInfoRouters(router *fox.Engine) {
 	// 服务列表和信息查询
 	router.GET("/v1/services", api.GetServices)
-	router.GET("/v1/services/:service", api.GetServiceByName)
 	router.GET("/v1/services/:service/activeVersions", api.GetServiceActiveVersions)
 	router.GET("/v1/services/:service/availableVersions", api.GetServiceAvailableVersions)
 	router.GET("/v1/metrics/:service/:name", api.GetServiceMetricTimeSeries)
@@ -185,39 +184,6 @@ func (api *Api) CreateService(c *fox.Context) {
 	})
 }
 
-// GetServiceByName 获取单个服务信息（GET /v1/services/:service）
-func (api *Api) GetServiceByName(c *fox.Context) {
-	ctx := c.Request.Context()
-	serviceName := c.Param("service")
-
-	if serviceName == "" {
-		c.JSON(http.StatusBadRequest, map[string]any{
-			"error":   "bad request",
-			"message": "service name is required",
-		})
-		return
-	}
-
-	svc, err := api.service.GetServiceByName(ctx, serviceName)
-	if err != nil {
-		if err == service.ErrServiceNotFound {
-			c.JSON(http.StatusNotFound, map[string]any{
-				"error":   "not found",
-				"message": "service not found",
-			})
-			return
-		}
-		log.Error().Err(err).Str("service", serviceName).Msg("failed to get service")
-		c.JSON(http.StatusInternalServerError, map[string]any{
-			"error":   "internal server error",
-			"message": "failed to get service",
-		})
-		return
-	}
-
-	c.JSON(http.StatusOK, svc)
-}
-
 // UpdateService 更新服务信息（PUT /v1/services/:service）
 func (api *Api) UpdateService(c *fox.Context) {
 	ctx := c.Request.Context()

internal/service_manager/database/database.go

@@ -3,7 +3,9 @@ package database
 import (
 	"context"
 	"database/sql"
+	"fmt"
 
+	_ "github.com/lib/pq" // PostgreSQL driver
 	"github.com/qiniu/zeroops/internal/config"
 )
 
@@ -13,7 +15,27 @@ type Database struct {
 }
 
 func NewDatabase(cfg *config.DatabaseConfig) (*Database, error) {
-	database := &Database{config: cfg}
+	// 构建PostgreSQL连接字符串
+	dsn := fmt.Sprintf("host=%s port=%d user=%s password=%s dbname=%s sslmode=%s",
+		cfg.Host, cfg.Port, cfg.User, cfg.Password, cfg.DBName, cfg.SSLMode)
+
+	// 连接数据库
+	db, err := sql.Open("postgres", dsn)
+	if err != nil {
+		return nil, fmt.Errorf("failed to open database connection: %w", err)
+	}
+
+	// 测试连接
+	if err := db.Ping(); err != nil {
+		db.Close()
+		return nil, fmt.Errorf("failed to ping database: %w", err)
+	}
+
+	database := &Database{
+		db:     db,
+		config: cfg,
+	}
+
 	return database, nil
 }