`).ReplaceAllString(t, "\n")
+ t = regexp.MustCompile(`(?i)`).ReplaceAllString(t, "\n")
+ t = regexp.MustCompile(`<[^>]+>`).ReplaceAllString(t, "")
+ t = strings.ReplaceAll(t, " ", " ")
+ t = strings.ReplaceAll(t, "<", "<")
+ t = strings.ReplaceAll(t, ">", ">")
+ t = strings.ReplaceAll(t, "&", "&")
+ t = strings.ReplaceAll(t, """, "\"")
+ t = regexp.MustCompile(`\n{3,}`).ReplaceAllString(t, "\n\n")
+ return strings.TrimSpace(t)
+}
diff --git a/service/send_message_service/unified/channels/dtalk.go b/service/send_message_service/unified/channels/dtalk.go
new file mode 100644
index 0000000..7eedd2a
--- /dev/null
+++ b/service/send_message_service/unified/channels/dtalk.go
@@ -0,0 +1,56 @@
+package channels
+
+import (
+ "fmt"
+ "message-nest/models"
+ "message-nest/pkg/message"
+ "message-nest/service/send_ins_service"
+ "message-nest/service/send_way_service"
+)
+
+type DtalkChannel struct{ *BaseChannel }
+
+func NewDtalkChannel() *DtalkChannel {
+ return &DtalkChannel{BaseChannel: NewBaseChannel(MessageTypeDtalk, []string{FormatTypeMarkdown, FormatTypeText})}
+}
+
+func (c *DtalkChannel) SendUnified(msgObj interface{}, ins models.SendTasksIns, content *UnifiedMessageContent) (string, string) {
+ auth, ok := msgObj.(send_way_service.WayDetailDTalk)
+ if !ok {
+ return "", "类型转换失败"
+ }
+ insService := send_ins_service.SendTaskInsService{}
+ errStr, configInterface := insService.ValidateDiffIns(ins)
+ if errStr != "" {
+ return errStr, ""
+ }
+ _, ok = configInterface.(models.InsDtalkConfig)
+ if !ok {
+ return "钉钉config校验失败", ""
+ }
+ contentType, formattedContent, err := c.FormatContent(content)
+ if err != nil {
+ return "", err.Error()
+ }
+ atMobiles := content.GetAtMobiles()
+ if content.IsAtAll() {
+ atMobiles = append(atMobiles, "all")
+ }
+ cli := message.Dtalk{AccessToken: auth.AccessToken, Secret: auth.Secret}
+ var res []byte
+ var errMsg string
+ if contentType == FormatTypeText {
+ res, err = cli.SendMessageText(formattedContent, atMobiles...)
+ if err != nil {
+ errMsg = fmt.Sprintf("发送失败：%s", err.Error())
+ }
+ } else if contentType == FormatTypeMarkdown {
+ res, err = cli.SendMessageMarkdown(content.Title, formattedContent, atMobiles...)
+ if err != nil {
+ errMsg = fmt.Sprintf("发送失败：%s", err.Error())
+ }
+ } else {
+ errMsg = fmt.Sprintf("未知的钉钉发送内容类型：%s", contentType)
+ }
+ return string(res), errMsg
+}
diff --git a/service/send_message_service/unified/channels/email.go b/service/send_message_service/unified/channels/email.go
new file mode 100644
index 0000000..4926d8c
--- /dev/null
+++ b/service/send_message_service/unified/channels/email.go
@@ -0,0 +1,46 @@
+package channels
+
+import (
+ "fmt"
+ "message-nest/models"
+ "message-nest/pkg/message"
+ "message-nest/service/send_ins_service"
+ "message-nest/service/send_way_service"
+)
+
+type EmailChannel struct{ *BaseChannel }
+
+func NewEmailChannel() *EmailChannel {
+ return &EmailChannel{BaseChannel: NewBaseChannel(MessageTypeEmail, []string{FormatTypeHTML, FormatTypeText})}
+}
+
+func (c *EmailChannel) SendUnified(msgObj interface{}, ins models.SendTasksIns, content *UnifiedMessageContent) (string, string) {
+ auth, ok := msgObj.(send_way_service.WayDetailEmail)
+ if !ok {
+ return "", "类型转换失败"
+ }
+ insService := send_ins_service.SendTaskInsService{}
+ errStr, configInterface := insService.ValidateDiffIns(ins)
+ if errStr != "" {
+ return "", errStr
+ }
+ config, ok := configInterface.(models.InsEmailConfig)
+ if !ok {
+ return "", "邮箱config校验失败"
+ }
+ contentType, formattedContent, err := c.FormatContent(content)
+ if err != nil {
+ return "", err.Error()
+ }
+ var emailer message.EmailMessage
+ emailer.Init(auth.Server, auth.Port, auth.Account, auth.Passwd)
+ var errMsg string
+ if contentType == FormatTypeText {
+ errMsg = emailer.SendTextMessage(config.ToAccount, content.Title, formattedContent)
+ } else if contentType == FormatTypeHTML {
+ errMsg = emailer.SendHtmlMessage(config.ToAccount, content.Title, formattedContent)
+ } else {
+ errMsg = fmt.Sprintf("未知的邮件发送内容类型：%s", contentType)
+ }
+ return "", errMsg
+}
diff --git a/service/send_message_service/unified/channels/nest.go b/service/send_message_service/unified/channels/nest.go
new file mode 100644
index 0000000..17fb182
--- /dev/null
+++ b/service/send_message_service/unified/channels/nest.go
@@ -0,0 +1,38 @@
+package channels
+
+import (
+ "message-nest/models"
+ "message-nest/service/hosted_message_service"
+ "message-nest/service/send_way_service"
+)
+
+type MessageNestChannel struct{ *BaseChannel }
+
+func NewMessageNestChannel() *MessageNestChannel {
+ return &MessageNestChannel{BaseChannel: NewBaseChannel(MessageTypeMessageNest, []string{FormatTypeMarkdown, FormatTypeHTML, FormatTypeText})}
+}
+
+func (c *MessageNestChannel) SendUnified(msgObj interface{}, ins models.SendTasksIns, content *UnifiedMessageContent) (string, string) {
+ _, ok := msgObj.(send_way_service.MessageNest)
+ if !ok {
+ return "", "类型转换失败"
+ }
+ contentType, formattedContent, err := c.FormatContent(content)
+ if err != nil {
+ return "", err.Error()
+ }
+ messageService := hosted_message_service.HostMessageService{
+ Title: content.Title,
+ Content: formattedContent,
+ Type: contentType,
+ }
+ err = messageService.Add()
+ var res, errMsg string
+ if err != nil {
+ errMsg = err.Error()
+ res = "托管消息创建失败！"
+ } else {
+ res = "托管消息创建成功！"
+ }
+ return res, errMsg
+}
diff --git a/service/send_message_service/unified/channels/qyweixin.go b/service/send_message_service/unified/channels/qyweixin.go
new file mode 100644
index 0000000..50377ef
--- /dev/null
+++ b/service/send_message_service/unified/channels/qyweixin.go
@@ -0,0 +1,58 @@
+package channels
+
+import (
+ "fmt"
+ "message-nest/models"
+ "message-nest/pkg/message"
+ "message-nest/service/send_ins_service"
+ "message-nest/service/send_way_service"
+)
+
+type QyWeiXinChannel struct{ *BaseChannel }
+
+func NewQyWeiXinChannel() *QyWeiXinChannel {
+ return &QyWeiXinChannel{BaseChannel: NewBaseChannel(MessageTypeQyWeiXin, []string{FormatTypeMarkdown, FormatTypeText})}
+}
+
+func (c *QyWeiXinChannel) SendUnified(msgObj interface{}, ins models.SendTasksIns, content *UnifiedMessageContent) (string, string) {
+ auth, ok := msgObj.(send_way_service.WayDetailQyWeiXin)
+ if !ok {
+ return "", "类型转换失败"
+ }
+ insService := send_ins_service.SendTaskInsService{}
+ errStr, configInterface := insService.ValidateDiffIns(ins)
+ if errStr != "" {
+ return errStr, ""
+ }
+ _, ok = configInterface.(models.InsQyWeiXinConfig)
+ if !ok {
+ return "企业微信config校验失败", ""
+ }
+ contentType, formattedContent, err := c.FormatContent(content)
+ if err != nil {
+ return "", err.Error()
+ }
+ atList := []string{}
+ atList = append(atList, content.GetAtUserIds()...)
+ atList = append(atList, content.GetAtMobiles()...)
+ if content.IsAtAll() {
+ atList = append(atList, "@all")
+ }
+ cli := message.QyWeiXin{AccessToken: auth.AccessToken}
+ var res []byte
+ var errMsg string
+ if contentType == FormatTypeText {
+ res, err = cli.SendMessageText(formattedContent, atList...)
+ if err != nil {
+ errMsg = fmt.Sprintf("发送失败：%s", err.Error())
+ }
+ } else if contentType == FormatTypeMarkdown {
+ res, err = cli.SendMessageMarkdown(content.Title, formattedContent, atList...)
+ if err != nil {
+ errMsg = fmt.Sprintf("发送失败：%s", err.Error())
+ }
+ } else {
+ errMsg = fmt.Sprintf("未知的企业微信发送内容类型：%s", contentType)
+ }
+ return string(res), errMsg
+}
diff --git a/service/send_message_service/unified/channels/types.go b/service/send_message_service/unified/channels/types.go
new file mode 100644
index 0000000..909b891
--- /dev/null
+++ b/service/send_message_service/unified/channels/types.go
@@ -0,0 +1,53 @@
+package channels
+
+// 消息格式类型常量
+const (
+ FormatTypeText = "text"
+ FormatTypeHTML = "html"
+ FormatTypeMarkdown = "markdown"
+)
+
+// 消息类型常量
+const (
+ MessageTypeEmail = "Email"
+ MessageTypeDtalk = "Dtalk"
+ MessageTypeQyWeiXin = "QyWeiXin"
+ MessageTypeCustom = "Custom"
+ MessageTypeWeChatOFAccount = "WeChatOFAccount"
+ MessageTypeMessageNest = "MessageNest"
+)
+
+// UnifiedMessageContent 统一的消息内容结构
+type UnifiedMessageContent struct {
+ Title string
+ URL string
+ Text string
+ HTML string
+ Markdown string
+ AtMobiles []string
+ AtUserIds []string
+ AtAll bool
+ Summary string
+ ImageURL string
+ Extra map[string]interface{}
+}
+
+func (m *UnifiedMessageContent) HasText() bool { return m.Text != "" }
+func (m *UnifiedMessageContent) HasHTML() bool { return m.HTML != "" }
+func (m *UnifiedMessageContent) HasMarkdown() bool { return m.Markdown != "" }
+
+func (m *UnifiedMessageContent) GetAtMobiles() []string {
+ if m.AtMobiles == nil {
+ return []string{}
+ }
+ return m.AtMobiles
+}
+
+func (m *UnifiedMessageContent) GetAtUserIds() []string {
+ if m.AtUserIds == nil {
+ return []string{}
+ }
+ return m.AtUserIds
+}
+
+func (m *UnifiedMessageContent) IsAtAll() bool { return m.AtAll }
diff --git a/service/send_message_service/unified/channels/wechat.go b/service/send_message_service/unified/channels/wechat.go
new file mode 100644
index 0000000..6743ee9
--- /dev/null
+++ b/service/send_message_service/unified/channels/wechat.go
@@ -0,0 +1,48 @@
+package channels
+
+import (
+ "fmt"
+ "message-nest/models"
+ "message-nest/pkg/message"
+ "message-nest/service/send_ins_service"
+ "message-nest/service/send_way_service"
+)
+
+type WeChatOFAccountChannel struct{ *BaseChannel }
+
+func NewWeChatOFAccountChannel() *WeChatOFAccountChannel {
+ return &WeChatOFAccountChannel{BaseChannel: NewBaseChannel(MessageTypeWeChatOFAccount, []string{FormatTypeText})}
+}
+
+func (c *WeChatOFAccountChannel) SendUnified(msgObj interface{}, ins models.SendTasksIns, content *UnifiedMessageContent) (string, string) {
+ auth, ok := msgObj.(send_way_service.WeChatOFAccount)
+ if !ok {
+ return "", "类型转换失败"
+ }
+ insService := send_ins_service.SendTaskInsService{}
+ errStr, configInterface := insService.ValidateDiffIns(ins)
+ if errStr != "" {
+ return errStr, ""
+ }
+ config, ok := configInterface.(models.InsWeChatAccountConfig)
+ if !ok {
+ return "微信公众号模板消息config校验失败", ""
+ }
+ _, formattedContent, err := c.FormatContent(content)
+ if err != nil {
+ return "", err.Error()
+ }
+ cli := message.WeChatOFAccount{
+ AppID: auth.AppID,
+ AppSecret: auth.APPSecret,
+ TemplateID: auth.TempID,
+ ToUser: config.ToAccount,
+ URL: content.URL,
+ }
+ res, err := cli.Send(content.Title, formattedContent)
+ var errMsg string
+ if err != nil {
+ errMsg = fmt.Sprintf("发送失败：%s", err.Error())
+ }
+ return res, errMsg
+}
diff --git a/web/package-lock.json b/web/package-lock.json
index 176995c..1cb6db1 100644
--- a/web/package-lock.json
+++ b/web/package-lock.json
@@ -10,13 +10,13 @@
"dependencies": {
"@tailwindcss/vite": "^4.1.11",
"@tanstack/vue-table": "^8.21.3",
- "@vueuse/core": "^13.6.0",
+ "@vueuse/core": "^13.9.0",
"axios": "^1.12.0",
"class-variance-authority": "^0.7.1",
"clsx": "^2.1.1",
"lucide-vue-next": "^0.536.0",
"pinia": "^3.0.3",
- "reka-ui": "^2.4.1",
+ "reka-ui": "^2.6.1",
"tailwind-merge": "^3.3.1",
"tailwindcss": "^4.1.11",
"tw-animate-css": "^1.3.6",
@@ -1605,14 +1605,14 @@
}
},
"node_modules/@vueuse/core": {
- "version": "13.6.0",
- "resolved": "https://registry.npmjs.org/@vueuse/core/-/core-13.6.0.tgz",
- "integrity": "sha512-DJbD5fV86muVmBgS9QQPddVX7d9hWYswzlf4bIyUD2dj8GC46R1uNClZhVAmsdVts4xb2jwp1PbpuiA50Qee1A==",
+ "version": "13.9.0",
+ "resolved": "https://registry.npmjs.org/@vueuse/core/-/core-13.9.0.tgz",
+ "integrity": "sha512-ts3regBQyURfCE2BcytLqzm8+MmLlo5Ln/KLoxDVcsZ2gzIwVNnQpQOL/UKV8alUqjSZOlpFZcRNsLRqj+OzyA==",
"license": "MIT",
"dependencies": {
"@types/web-bluetooth": "^0.0.21",
- "@vueuse/metadata": "13.6.0",
- "@vueuse/shared": "13.6.0"
+ "@vueuse/metadata": "13.9.0",
+ "@vueuse/shared": "13.9.0"
},
"funding": {
"url": "https://github.com/sponsors/antfu"
@@ -1622,9 +1622,9 @@
}
},
"node_modules/@vueuse/core/node_modules/@vueuse/shared": {
- "version": "13.6.0",
- "resolved": "https://registry.npmjs.org/@vueuse/shared/-/shared-13.6.0.tgz",
- "integrity": "sha512-pDykCSoS2T3fsQrYqf9SyF0QXWHmcGPQ+qiOVjlYSzlWd9dgppB2bFSM1GgKKkt7uzn0BBMV3IbJsUfHG2+BCg==",
+ "version": "13.9.0",
+ "resolved": "https://registry.npmjs.org/@vueuse/shared/-/shared-13.9.0.tgz",
+ "integrity": "sha512-e89uuTLMh0U5cZ9iDpEI2senqPGfbPRTHM/0AaQkcxnpqjkZqDYP8rpfm7edOz8s+pOCOROEy1PIveSW8+fL5g==",
"license": "MIT",
"funding": {
"url": "https://github.com/sponsors/antfu"
@@ -1634,9 +1634,9 @@
}
},
"node_modules/@vueuse/metadata": {
- "version": "13.6.0",
- "resolved": "https://registry.npmjs.org/@vueuse/metadata/-/metadata-13.6.0.tgz",
- "integrity": "sha512-rnIH7JvU7NjrpexTsl2Iwv0V0yAx9cw7+clymjKuLSXG0QMcLD0LDgdNmXic+qL0SGvgSVPEpM9IDO/wqo1vkQ==",
+ "version": "13.9.0",
+ "resolved": "https://registry.npmjs.org/@vueuse/metadata/-/metadata-13.9.0.tgz",
+ "integrity": "sha512-1AFRvuiGphfF7yWixZa0KwjYH8ulyjDCC0aFgrGRz8+P4kvDFSdXLVfTk5xAN9wEuD1J6z4/myMoYbnHoX07zg==",
"license": "MIT",
"funding": {
"url": "https://github.com/sponsors/antfu"
@@ -2632,9 +2632,9 @@
"license": "MIT"
},
"node_modules/reka-ui": {
- "version": "2.4.1",
- "resolved": "https://registry.npmjs.org/reka-ui/-/reka-ui-2.4.1.tgz",
- "integrity": "sha512-NB7DrCsODN8MH02BWtgiExygfFcuuZ5/PTn6fMgjppmFHqePvNhmSn1LEuF35nel6PFbA4v+gdj0IoGN1yZ+vw==",
+ "version": "2.6.1",
+ "resolved": "https://registry.npmjs.org/reka-ui/-/reka-ui-2.6.1.tgz",
+ "integrity": "sha512-XK7cJDQoNuGXfCNzBBo/81Yg/OgjPwvbabnlzXG2VsdSgNsT6iIkuPBPr+C0Shs+3bb0x0lbPvgQAhMSCKm5Ww==",
"license": "MIT",
"dependencies": {
"@floating-ui/dom": "^1.6.13",
diff --git a/web/package.json b/web/package.json
index 0f7c7e3..491ebed 100644
--- a/web/package.json
+++ b/web/package.json
@@ -13,13 +13,13 @@
"dependencies": {
"@tailwindcss/vite": "^4.1.11",
"@tanstack/vue-table": "^8.21.3",
- "@vueuse/core": "^13.6.0",
+ "@vueuse/core": "^13.9.0",
"axios": "^1.12.0",
"class-variance-authority": "^0.7.1",
"clsx": "^2.1.1",
"lucide-vue-next": "^0.536.0",
"pinia": "^3.0.3",
- "reka-ui": "^2.4.1",
+ "reka-ui": "^2.6.1",
"tailwind-merge": "^3.3.1",
"tailwindcss": "^4.1.11",
"tw-animate-css": "^1.3.6",
@@ -37,4 +37,4 @@
"vite": "^7.0.4",
"vue-tsc": "^2.2.12"
}
-}
\ No newline at end of file
+}
diff --git a/web/src/components/Index.vue b/web/src/components/Index.vue
index 4b896bf..8e6ffbc 100644
--- a/web/src/components/Index.vue
+++ b/web/src/components/Index.vue
@@ -252,6 +252,7 @@ const tabRoutes: TabRoute[] = [
{ name: '发信日志', path: '/sendlogs' },
{ name: '托管消息', path: '/hostedmessage' },
{ name: '定时消息', path: '/cronmessages' },
+ { name: '模板任务', path: '/templates' },
{ name: '发信任务', path: '/sendtasks' },
{ name: '发信渠道', path: '/sendways' },
{ name: '设置偏好', path: '/settings' }
@@ -326,9 +327,9 @@ const siteTitle = computed(() => {
-
+
代码示例
diff --git a/web/src/components/pages/sendTasks/EditTasks.vue b/web/src/components/pages/sendTasks/EditTasks.vue
index 3b3c7ee..c469aa6 100644
--- a/web/src/components/pages/sendTasks/EditTasks.vue
+++ b/web/src/components/pages/sendTasks/EditTasks.vue
@@ -1,5 +1,5 @@
+
+
+
+
+
+
+
+
+
+
diff --git a/web/src/components/ui/checkbox/index.ts b/web/src/components/ui/checkbox/index.ts
new file mode 100644
index 0000000..3391a85
--- /dev/null
+++ b/web/src/components/ui/checkbox/index.ts
@@ -0,0 +1 @@
+export { default as Checkbox } from "./Checkbox.vue"
diff --git a/web/src/constant.js b/web/src/constant.js
index e295f87..ad938de 100644
--- a/web/src/constant.js
+++ b/web/src/constant.js
@@ -55,7 +55,7 @@ const CONSTANT = {
},
{
type: 'QyWeiXin',
- label: '企业微信',
+ label: '企业微信机器人',
inputs: [
{ subLabel: 'token', value: '', col: 'access_token', desc: "企业微信webhook中的token" },
{ subLabel: '渠道名', value: '', col: 'name', desc: "想要设置的渠道名字" },
diff --git a/web/src/router/index.js b/web/src/router/index.js
index 66f18c6..5c65ad8 100644
--- a/web/src/router/index.js
+++ b/web/src/router/index.js
@@ -51,6 +51,11 @@ const router = createRouter({
path: 'cronmessages',
name: 'cronmessages',
component: () => import('../components/pages/cronMessages/CronMessages.vue')
+ },
+ {
+ path: 'templates',
+ name: 'templates',
+ component: () => import('../components/pages/messageTemplate/MessageTemplate.vue')
}
]
},
diff --git a/web/src/util/pageUtils.d.ts b/web/src/util/pageUtils.d.ts
new file mode 100644
index 0000000..09fba2d
--- /dev/null
+++ b/web/src/util/pageUtils.d.ts
@@ -0,0 +1,5 @@
+/**
+ * 获取分页大小配置
+ * @returns 分页大小，默认为8
+ */
+export declare function getPageSize(): number;
diff --git a/web/src/util/uuid.js b/web/src/util/uuid.js
index 3fb718f..c1f1d46 100644
--- a/web/src/util/uuid.js
+++ b/web/src/util/uuid.js
@@ -18,7 +18,7 @@ function generateUniqueID() {
function generateBizUniqueID(flag) {
const randomString = generateRandomString(10);
- return `${flag}-${randomString}`;
+ return `${flag}${randomString}`;
}
export { generateUniqueID, generateBizUniqueID };
diff --git a/web/src/util/viewApi.js b/web/src/util/viewApi.js
index 188619f..cd9046f 100644
--- a/web/src/util/viewApi.js
+++ b/web/src/util/viewApi.js
@@ -1,11 +1,10 @@
-
-
const gethttpOrigin = () => {
return window.location.origin
}
-class ApiStrGenerate {
+// ==================== 公共加密工具 ====================
+class TokenEncryption {
// 根据字符串内容生成确定性 salt（范围 0~255）
static getDeterministicSalt(text) {
let sum = 0;
@@ -17,7 +16,7 @@ class ApiStrGenerate {
// 加密：首字节为salt，后续为按位异或后的数据
static encryptHex(text, key) {
- const salt = ApiStrGenerate.getDeterministicSalt(text);
+ const salt = TokenEncryption.getDeterministicSalt(text);
let result = salt.toString(16).padStart(2, '0');
for (let i = 0; i < text.length; i++) {
const code = text.charCodeAt(i) ^ (key & 0xFF) ^ ((salt + i) & 0xFF);
@@ -25,36 +24,19 @@ class ApiStrGenerate {
}
return result;
}
+}
- static getDataString(task_id, options) {
- // 新版仅展示 token；兼容旧版 task_id（后端依然支持）
- let data = { token: ApiStrGenerate.encryptHex(task_id, 71) };
- data.title = 'message title';
- data.text = 'Hello World!';
- if (options.html) {
- data.html = ' Hello World!
';
- }
- if (options.markdown) {
- data.markdown = '**Hello World!**';
- }
- if (options.url) {
- data.url = 'https://github.com';
- }
- let dataStr = JSON.stringify(data, null, 4);
- return dataStr
+// ==================== 公共代码模板生成器 ====================
+
+class CodeTemplates {
+ static getCurl(url, dataStr) {
+ return `curl -X POST --location '${url}' \\
+--header 'Content-Type: application/json' \\
+--data '${dataStr}'`;
}
- static getCurlString(task_id, options) {
- let dataStr = ApiStrGenerate.getDataString(task_id, options);
- let example = `curl -X POST --location '${gethttpOrigin()}/api/v1/message/send' \\
- --header 'Content-Type: application/json' \\
- --data '${dataStr}'`;
- return example;
- }
-
- static getGolangString(task_id, options) {
- let dataStr = ApiStrGenerate.getDataString(task_id, options);
- let example = `package main
+ static getGolang(url, dataStr) {
+ return `package main
import (
"fmt"
@@ -67,7 +49,7 @@ import (
func main() {
client := &http.Client{}
var data = strings.NewReader(\`${dataStr}\`)
- req, err := http.NewRequest("POST", "${gethttpOrigin()}/api/v1/message/send", data)
+ req, err := http.NewRequest("POST", "${url}", data)
if err != nil {
log.Fatal(err)
}
@@ -82,29 +64,23 @@ func main() {
log.Fatal(err)
}
fmt.Printf("%s\\n", bodyText)
-}
- `;
- return example;
+}`;
}
- static getPythonString(task_id, options) {
- let dataStr = ApiStrGenerate.getDataString(task_id, options);
- let example = `import requests
+ static getPython(url, dataStr) {
+ return `import requests
headers = {
'Content-Type': 'application/json',
}
json_data = ${dataStr}
-response = requests.post('${gethttpOrigin()}/api/v1/message/send', headers=headers, json=json_data)
+response = requests.post('${url}', headers=headers, json=json_data)
-print("response:", response.json())
-`;
- return example;
+print("response:", response.json())`;
}
- static getJaveString(task_id, options) {
- let dataStr = ApiStrGenerate.getDataString(task_id, options);
- let example = `import java.io.IOException;
+ static getJava(url, dataStr) {
+ return `import java.io.IOException;
import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
@@ -116,19 +92,16 @@ HttpClient client = HttpClient.newBuilder()
.build();
HttpRequest request = HttpRequest.newBuilder()
- .uri(URI.create("${gethttpOrigin()}/api/v1/message/send"))
- .POST(BodyPublishers.ofString(${JSON.stringify(dataStr).trim('\"')}))
+ .uri(URI.create("${url}"))
+ .POST(BodyPublishers.ofString(${JSON.stringify(dataStr).trim('"')}))
.setHeader("Content-Type", "application/json")
.build();
-HttpResponse response = client.send(request, HttpResponse.BodyHandlers.ofString());
-`;
- return example;
+HttpResponse response = client.send(request, HttpResponse.BodyHandlers.ofString());`;
}
- static getRustString(task_id, options) {
- let dataStr = ApiStrGenerate.getDataString(task_id, options);
- let example = `extern crate reqwest;
+ static getRust(url, dataStr) {
+ return `extern crate reqwest;
use reqwest::header;
fn main() -> Result<(), Box> {
@@ -136,7 +109,7 @@ fn main() -> Result<(), Box> {
headers.insert("Content-Type", "application/json".parse().unwrap());
let client = reqwest::blocking::Client::new();
- let res = client.post("${gethttpOrigin()}/api/v1/message/send")
+ let res = client.post("${url}")
.headers(headers)
.body(r#"
${dataStr}
@@ -147,43 +120,37 @@ ${dataStr}
println!("{}", res);
Ok(())
-}
-`;
- return example;
+}`;
}
- static getPHPString(task_id, options) {
- let dataStr = ApiStrGenerate.getDataString(task_id, options);
- let example = ` Hello World! ';
+ if (options.markdown) data.markdown = '**Hello World!**';
+ if (options.url) data.url = 'https://github.com';
+ if (options.at_mobiles) data.at_mobiles = ['13800138000', '13900139000'];
+ if (options.at_user_ids) data.at_user_ids = ['zhangsan', 'lisi'];
+ if (options.at_all) data.at_all = true;
+ return JSON.stringify(data, null, 4);
+ }
+
+ static getApiUrl() {
+ return `${gethttpOrigin()}/api/v1/message/send`;
+ }
+
+ static getCurlString(task_id, options) {
+ return CodeTemplates.getCurl(this.getApiUrl(), this.getDataString(task_id, options));
+ }
+
+ static getGolangString(task_id, options) {
+ return CodeTemplates.getGolang(this.getApiUrl(), this.getDataString(task_id, options));
+ }
+
+ static getPythonString(task_id, options) {
+ return CodeTemplates.getPython(this.getApiUrl(), this.getDataString(task_id, options));
+ }
+
+ static getJaveString(task_id, options) {
+ return CodeTemplates.getJava(this.getApiUrl(), this.getDataString(task_id, options));
+ }
+
+ static getRustString(task_id, options) {
+ return CodeTemplates.getRust(this.getApiUrl(), this.getDataString(task_id, options));
+ }
+
+ static getPHPString(task_id, options) {
+ return CodeTemplates.getPHP(this.getApiUrl(), this.getDataString(task_id, options));
+ }
+
+ static getNodeString(task_id, options) {
+ return CodeTemplates.getNode(this.getApiUrl(), this.getDataString(task_id, options));
+ }
+}
+
+// ==================== 模板 API (V2) ====================
+
+class TemplateApiStrGenerate {
+ static getTemplateDataString(template_id, placeholders_json) {
+ // 解析占位符配置
+ let placeholders = {};
+ try {
+ const placeholdersList = JSON.parse(placeholders_json || '[]');
+ // 根据占位符配置生成示例值
+ placeholdersList.forEach(p => {
+ placeholders[p.key] = p.default || `mock_${p.key}`;
+ });
+ } catch (e) {
+ // 如果解析失败，使用默认示例
+ placeholders = {
+ 'username': 'John Doe',
+ 'email': 'john@example.com',
+ 'phone': '13800138000'
+ };
+ }
+
+ let data = {
+ token: TokenEncryption.encryptHex(template_id, 71),
+ title: 'message title',
+ placeholders: placeholders
+ };
+ return JSON.stringify(data, null, 4);
+ }
+
+ static getApiUrl() {
+ return `${gethttpOrigin()}/api/v2/message/send`;
+ }
+
+ static getCurlString(template_id, placeholders_json) {
+ return CodeTemplates.getCurl(this.getApiUrl(), this.getTemplateDataString(template_id, placeholders_json));
+ }
+
+ static getGolangString(template_id, placeholders_json) {
+ return CodeTemplates.getGolang(this.getApiUrl(), this.getTemplateDataString(template_id, placeholders_json));
+ }
+
+ static getPythonString(template_id, placeholders_json) {
+ return CodeTemplates.getPython(this.getApiUrl(), this.getTemplateDataString(template_id, placeholders_json));
+ }
+
+ static getJavaString(template_id, placeholders_json) {
+ return CodeTemplates.getJava(this.getApiUrl(), this.getTemplateDataString(template_id, placeholders_json));
+ }
+
+ static getRustString(template_id, placeholders_json) {
+ return CodeTemplates.getRust(this.getApiUrl(), this.getTemplateDataString(template_id, placeholders_json));
+ }
+
+ static getPHPString(template_id, placeholders_json) {
+ return CodeTemplates.getPHP(this.getApiUrl(), this.getTemplateDataString(template_id, placeholders_json));
+ }
+
+ static getNodeString(template_id, placeholders_json) {
+ return CodeTemplates.getNode(this.getApiUrl(), this.getTemplateDataString(template_id, placeholders_json));
+ }
+}
+
+export { ApiStrGenerate, TemplateApiStrGenerate };