diff --git a/internal/sdk/messenger/README.md b/internal/sdk/messenger/README.md deleted file mode 100644 index c44be9e..0000000 --- a/internal/sdk/messenger/README.md +++ /dev/null @@ -1,161 +0,0 @@ -# Messenger SDK - -统一消息发送 SDK，可独立于 Message-Push-Nest 业务层使用。 - -## 特点 - -- **零业务依赖**：不依赖数据库、路由、认证等业务代码 -- **开箱即用**：直接传配置 + 消息即可发送 -- **支持 12 种渠道**：Email, 钉钉, 企业微信, 飞书, Telegram, Bark, Ntfy, Gotify, PushMe, 自定义Webhook, 微信公众号, 阿里云短信 -- **可扩展**：通过 `RegisterChannel` 注册自定义渠道 - -## 快速使用 - -```go -import "message-nest/pkg/sdk/messenger" - -// 方式1: 直接发送 -result, err := messenger.Send("Telegram", messenger.ChannelConfig{ - "bot_token": "your-bot-token", - "chat_id": "123456", -}, &messenger.Message{ - Title: "告警通知", - Text: "服务器 CPU 超过 90%", - Markdown: "**服务器 CPU** 超过 `90%`", -}) - -if err != nil { - log.Fatal(err) -} -if !result.Success { - log.Printf("发送失败: %s", result.Error) -} -``` - -### 使用 Client（预设默认配置） - -```go -client := messenger.NewClient() - -// 预设 Telegram 配置 -client.SetDefaultConfig("Telegram", messenger.ChannelConfig{ - "bot_token": "your-bot-token", - "chat_id": "default-chat", -}) - -// 后续发送可以覆盖部分配置，也可以传 nil 使用全部默认值 -result, err := client.Send("Telegram", nil, &messenger.Message{ - Title: "Hello", - Text: "World", -}) -``` - -## 各渠道配置参数 - -### Email -| 参数 | 必填 | 说明 | -|------|------|------| -| `server` | ✅ | SMTP 服务地址 | -| `port` | ✅ | SMTP 端口 | -| `account` | ✅ | 邮箱账号 | -| `passwd` | ✅ | 邮箱密码 | -| `from_name` | ❌ | 发信人名称 | -| `to_account` | ✅ | 收件邮箱 | - -### Dtalk（钉钉） -| 参数 | 必填 | 说明 | -|------|------|------| -| `access_token` | ✅ | 钉钉 access_token | -| `secret` | ❌ | 加签秘钥 | - -### QyWeiXin（企业微信） -| 参数 | 必填 | 说明 | -|------|------|------| -| `access_token` | ✅ | 企业微信 access_token | - -### Feishu（飞书） -| 参数 | 必填 | 说明 | -|------|------|------| -| `access_token` | ✅ | 飞书 access_token | -| `secret` | ❌ | 加签秘钥 | - -### Telegram -| 参数 | 必填 | 说明 | -|------|------|------| -| `bot_token` | ✅ | Bot Token | -| `chat_id` | ✅ | Chat ID | -| `api_host` | ❌ | 自定义 API 地址 | -| `proxy_url` | ❌ | 代理地址 (http/https/socks5) | - -### Bark -| 参数 | 必填 | 说明 | -|------|------|------| -| `push_key` | ✅ | Bark Push Key | -| `archive` | ❌ | 是否存档 | -| `group` | ❌ | 推送分组 | -| `sound` | ❌ | 推送声音 | -| `icon` | ❌ | 推送图标 | -| `level` | ❌ | 时效性 | -| `url` | ❌ | 跳转URL | -| `key` | ❌ | 加密Key | -| `iv` | ❌ | 加密IV | - -### Ntfy -| 参数 | 必填 | 说明 | -|------|------|------| -| `topic` | ✅ | Topic | -| `url` | ❌ | 自定义 API 地址 | -| `priority` | ❌ | 优先级 | -| `icon` | ❌ | 图标 URL | -| `token` | ❌ | Token | -| `username` | ❌ | 用户名 | -| `password` | ❌ | 密码 | -| `actions` | ❌ | Actions | - -### Gotify -| 参数 | 必填 | 说明 | -|------|------|------| -| `url` | ✅ | Gotify 服务地址 | -| `token` | ✅ | Token | -| `priority` | ❌ | 优先级 | - -### PushMe -| 参数 | 必填 | 说明 | -|------|------|------| -| `push_key` | ✅ | PushMe Push Key | -| `url` | ❌ | 自定义 API 地址 | -| `date` | ❌ | 日期 | -| `type` | ❌ | 类型 | - -### Custom（自定义Webhook） -| 参数 | 必填 | 说明 | -|------|------|------| -| `webhook` | ✅ | Webhook URL | -| `body` | ❌ | 请求体模板（`TEXT` 占位符会被替换） | - -### WeChatOFAccount（微信公众号） -| 参数 | 必填 | 说明 | -|------|------|------| -| `appID` | ✅ | 公众号 AppID | -| `appsecret` | ✅ | 公众号 AppSecret | -| `tempid` | ❌ | 模板消息 ID | -| `to_account` | ✅ | 接收者 OpenID | - -### AliyunSMS（阿里云短信） -| 参数 | 必填 | 说明 | -|------|------|------| -| `access_key_id` | ✅ | AccessKeyId | -| `access_key_secret` | ✅ | AccessKeySecret | -| `sign_name` | ✅ | 短信签名 | -| `region_id` | ❌ | 区域ID（默认 cn-hangzhou） | -| `phone_number` | ✅ | 手机号码 | -| `template_code` | ✅ | 短信模板 CODE | - -## 自定义扩展 - -```go -// 注册自定义渠道 -messenger.RegisterChannel("MyChannel", func() messenger.Channel { - return &myCustomChannel{} -}) -``` diff --git a/internal/services/env_service.go b/internal/services/env_service.go index 7e42cda..f10b5b2 100644 --- a/internal/services/env_service.go +++ b/internal/services/env_service.go @@ -118,20 +118,44 @@ func (es *EnvService) DeleteEnvVar(id string, force bool) (bool, []models.Task) } // GetEnvVarsByIDs 根据逗号分隔的ID字符串获取环境变量列表，返回 NAME=VALUE 格式 +// 如果存在重名变量，会类似青龙面板一样使用 & 拼接 func (es *EnvService) GetEnvVarsByIDs(envIDs string) []string { if envIDs == "" { return nil } - var envVars []string ids := splitEnvIDs(envIDs) + type mergedEnv struct { + name string + values []string + } + var mergedList []mergedEnv + nameToIndex := make(map[string]int) + for _, id := range ids { env := es.GetEnvVarByID(id) - if env != nil { - envVars = append(envVars, env.Name+"="+env.Value) + if env == nil { + continue + } + + if idx, ok := nameToIndex[env.Name]; ok { + mergedList[idx].values = append(mergedList[idx].values, env.Value) + } else { + nameToIndex[env.Name] = len(mergedList) + mergedList = append(mergedList, mergedEnv{ + name: env.Name, + values: []string{env.Value}, + }) } } - return envVars + + var result []string + for _, item := range mergedList { + // 多个值使用 & 拼接 + val := strings.Join(item.values, "&") + result = append(result, item.name+"="+val) + } + return result } // splitEnvIDs 解析逗号分隔的ID字符串 diff --git a/internal/services/tasks/executor_service.go b/internal/services/tasks/executor_service.go index 178432c..78de8a8 100644 --- a/internal/services/tasks/executor_service.go +++ b/internal/services/tasks/executor_service.go @@ -936,19 +936,15 @@ func (es *ExecutorService) BuildRepoCommand(task *models.Task) (string, string) return exePath + " " + strings.Join(args, " "), filepath.Dir(exePath) } -// loadEnvVars 加载环境变量 +// loadEnvVars 加载环境变量（支持重名合并） func (es *ExecutorService) loadEnvVars(envIDs string) []string { if envIDs == "" { return nil } - var envVars []models.EnvironmentVariable - ids := strings.Split(envIDs, ",") - database.DB.Where("id IN ?", ids).Find(&envVars) - - result := make([]string, 0, len(envVars)) - for _, env := range envVars { - result = append(result, fmt.Sprintf("%s=%s", env.Name, env.Value)) + if es.envService != nil { + return es.envService.GetEnvVarsByIDs(envIDs) } - return result + + return nil }