feat(deploy): 实现本地部署包支持及部署流程优化

- 添加本地部署包存储路径支持，修改包URL构建逻辑
- 优化部署服务异步执行上下文传递
- 新增部署测试脚本和打包脚本
- 添加数据库schema文件用于部署模块
- 更新配置文件包含数据库连接和私钥信息

Author: JaD1ng

docs/deploy/schema.sql

@@ -0,0 +1,55 @@
+-- Deploy模块数据库架构
+-- 部署相关的主机、实例和版本历史表
+
+-- 创建hosts表：主机信息
+CREATE TABLE hosts (
+    id SERIAL PRIMARY KEY,
+    name VARCHAR(255) UNIQUE,
+    ip_address VARCHAR(45) UNIQUE,
+    is_stopped BOOLEAN
+);
+
+-- 创建instances表：服务实例信息
+CREATE TABLE instances (
+    id VARCHAR(255) NOT NULL PRIMARY KEY,  -- VARCHAR类型主键，非自增，不为空
+    service_name VARCHAR(255),
+    service_version VARCHAR(255),
+    host_id VARCHAR(255),
+    host_ip_address VARCHAR(45),
+    ip_address VARCHAR(45),
+    port INT,
+    status VARCHAR(50),
+    is_stopped BOOLEAN,
+    -- 保留ip_address和port的组合唯一约束
+    CONSTRAINT unique_ip_port UNIQUE (ip_address, port)
+);
+
+-- 1. 创建service_name和service_version的联合索引
+CREATE INDEX idx_instances_service_name_version
+ON instances (service_name, service_version);
+
+-- 2. 创建service_name和ip_address的联合索引
+CREATE INDEX idx_instances_service_name_ip
+ON instances (service_name, ip_address);
+
+-- 3. 创建version_histories表：版本历史记录
+CREATE TABLE version_histories (
+    id SERIAL PRIMARY KEY,
+    instance_id VARCHAR(255),
+    service_name VARCHAR(255),
+    service_version VARCHAR(255),
+    status VARCHAR(50)
+);
+
+-- 初始化主机数据
+-- 插入 jfcs1021 主机数据
+INSERT INTO hosts (name, ip_address, is_stopped)
+VALUES ('jfcs1021', '10.210.10.33', false);
+
+-- 插入 jfcs1022 主机数据
+INSERT INTO hosts (name, ip_address, is_stopped)
+VALUES ('jfcs1022', '10.210.10.30', false);
+
+-- 插入 jfcs1023 主机数据
+INSERT INTO hosts (name, ip_address, is_stopped)
+VALUES ('jfcs1023', '10.210.10.31', false);

internal/deploy/config.yaml

@@ -0,0 +1,24 @@
+database:
+  host: "localhost"
+  port: 5432
+  user: "admin"
+  password: "password"
+  dbname: "zeroops"
+  sslmode: "disable"
+
+privateKey: |
+  -----BEGIN RSA PRIVATE KEY-----
+  MIICXQIBAAKBgQDZsfv1qscqYdy4vY+P4e3cAtmvppXQcRvrF1cB4drkv0haU24Y
+  7m5qYtT52Kr539RdbKKdLAM6s20lWy7+5C0DgacdwYWd/7PeCELyEipZJL07Vro7
+  Ate8Bfjya+wltGK9+XNUIHiumUKULW4KDx21+1NLAUeJ6PeW+DAkmJWF6QIDAQAB
+  AoGBAJlNxenTQj6OfCl9FMR2jlMJjtMrtQT9InQEE7m3m7bLHeC+MCJOhmNVBjaM
+  ZpthDORdxIZ6oCuOf6Z2+Dl35lntGFh5J7S34UP2BWzF1IyyQfySCNexGNHKT1G1
+  XKQtHmtc2gWWthEg+S6ciIyw2IGrrP2Rke81vYHExPrexf0hAkEA9Izb0MiYsMCB
+  /jemLJB0Lb3Y/B8xjGjQFFBQT7bmwBVjvZWZVpnMnXi9sWGdgUpxsCuAIROXjZ40
+  IRZ2C9EouwJBAOPjPvV8Sgw4vaseOqlJvSq/C/pIFx6RVznDGlc8bRg7SgTPpjHG
+  4G+M3mVgpCX1a/EU1mB+fhiJ2LAZ/pTtY6sCQGaW9NwIWu3DRIVGCSMm0mYh/3X9
+  DAcwLSJoctiODQ1Fq9rreDE5QfpJnaJdJfsIJNtX1F+L3YceeBXtW0Ynz2MCQBI8
+  9KP274Is5FkWkUFNKnuKUK4WKOuEXEO+LpR+vIhs7k6WQ8nGDd4/mujoJBr5mkrw
+  DPwqA3N5TMNDQVGv8gMCQQCaKGJgWYgvo3/milFfImbp+m7/Y3vCptarldXrYQWO
+  AQjxwc71ZGBFDITYvdgJM1MTqc8xQek1FXn1vfpy2c6O
+  -----END RSA PRIVATE KEY-----

internal/deploy/packages/storage-v1.0.0.tar.gz

@@ -3,6 +3,8 @@ package service
 import (
 	"fmt"
 	"net/http"
+	"os"
+	"strings"
 
 	deployModel "github.com/qiniu/zeroops/internal/deploy/model"
 	deployService "github.com/qiniu/zeroops/internal/deploy/service"
@@ -19,7 +21,7 @@ type DeployAdapter struct {
 func NewDeployAdapter(instanceManager InstanceManager) *DeployAdapter {
 	return &DeployAdapter{
 		instanceManager: instanceManager,
-		baseURL:         "http://artifacts.zeroops.com", // 默认包仓库URL，可以从配置读取
+		baseURL:         "/Users/dingnanjia/workspace/mock/zeroops/internal/deploy/packages", // 本地包仓库路径
 	}
 }
 
@@ -115,10 +117,10 @@ func (a *DeployAdapter) buildPackageURL(serviceName, version, customURL string)
 		return customURL
 	}
 
-	// 否则基于约定构建URL
-	// 格式：{baseURL}/packages/{service}/{version}/{service}-{version}.tar.gz
-	return fmt.Sprintf("%s/packages/%s/%s/%s-%s.tar.gz",
-		a.baseURL, serviceName, version, serviceName, version)
+	// 否则基于约定构建本地文件路径
+	// 格式：{baseURL}/{service}-{version}.tar.gz
+	return fmt.Sprintf("%s/%s-%s.tar.gz",
+		a.baseURL, serviceName, version)
 }
 
 // ValidatePackageURL 验证包URL是否有效
@@ -128,15 +130,26 @@ func (a *DeployAdapter) ValidatePackageURL(packageURL string) error {
 		return err
 	}
 
-	// 额外的简单HTTP检查
-	resp, err := http.Head(packageURL)
-	if err != nil {
-		return fmt.Errorf("package URL not accessible: %w", err)
-	}
-	defer resp.Body.Close()
-
-	if resp.StatusCode != 200 {
-		return fmt.Errorf("package not found: HTTP %d", resp.StatusCode)
+	// 区分HTTP URL和本地文件路径
+	if strings.HasPrefix(packageURL, "http://") || strings.HasPrefix(packageURL, "https://") {
+		// HTTP URL检查
+		resp, err := http.Head(packageURL)
+		if err != nil {
+			return fmt.Errorf("package URL not accessible: %w", err)
+		}
+		defer resp.Body.Close()
+
+		if resp.StatusCode != 200 {
+			return fmt.Errorf("package not found: HTTP %d", resp.StatusCode)
+		}
+	} else {
+		// 本地文件路径检查
+		if _, err := os.Stat(packageURL); err != nil {
+			if os.IsNotExist(err) {
+				return fmt.Errorf("package file not found: %s", packageURL)
+			}
+			return fmt.Errorf("package file not accessible: %w", err)
+		}
 	}
 
 	return nil

internal/service_manager/service/deploy_adapter.go

@@ -42,7 +42,7 @@ func (s *Service) CreateDeployment(ctx context.Context, req *model.CreateDeploym
 		Msg("deployment created successfully")
 
 	// 异步执行实际部署
-	go s.executeActualDeployment(ctx, req)
+	go s.executeActualDeployment(context.Background(), req)
 
 	// 返回创建的部署信息
 	deployment := &model.Deployment{
@@ -291,7 +291,7 @@ func (s *Service) RollbackDeployment(ctx context.Context, service, version strin
 	}
 
 	// 异步执行实际回滚
-	go s.executeActualRollback(ctx, deployment, req)
+	go s.executeActualRollback(context.Background(), deployment, req)
 
 	// 更新数据库状态
 	err = s.db.RollbackDeployment(ctx, service, version)
@@ -309,7 +309,7 @@ func (s *Service) RollbackDeployment(ctx context.Context, service, version strin
 }
 
 // executeActualRollback 执行实际回滚操作
-func (s *Service) executeActualRollback(_ context.Context, deployment *model.Deployment, req *model.RollbackDeploymentRequest) {
+func (s *Service) executeActualRollback(ctx context.Context, deployment *model.Deployment, req *model.RollbackDeploymentRequest) {
 	// 捕获panic，防止goroutine崩溃
 	defer func() {
 		if r := recover(); r != nil {