feat: 支持 HTTP 消息推送配置

args/params.go

@@ -3,9 +3,9 @@ package args
 // 日志配置
 
 type ILog struct {
-	Dir    string `yaml:"Dir"`    // 日志目录
-	Level  string `yaml:"Level"`  // 日志级别 debug|info|warn|error
-	Target string `yaml:"Target"` // 日志输出方式 both|file|null|stdout|stderr
+	Dir    string `yaml:"Dir"`    // 存储目录
+	Level  string `yaml:"Level"`  // 记录级别 debug|info|warn|error
+	Target string `yaml:"Target"` // 输出方式 both|file|null|stdout|stderr
 }
 
 var Log = &ILog{
@@ -35,6 +35,7 @@ type IWeb struct {
 	Address string `yaml:"Address"` // Web 监听地址
 	Swagger bool   `yaml:"Swagger"` // 是否启用 Api 文档
 	Token   string `yaml:"Token"`   // 使用 Token 验证请求
+	Webhook string `yaml:"Webhook"` // 消息推送地址
 }
 
 var Web = &IWeb{

config.yml

@@ -1,8 +1,8 @@
 # 运行日志
 Log:
-    Dir: logs # 日志存储目录
-    Level: info # 日志级别，debug|info|warn|error
-    Target: stdout # 日志输出方式，both|file|null|stdout|stderr
+    Dir: logs # 存储目录
+    Level: info # 记录级别，debug|info|warn|error
+    Target: stdout # 输出方式，both|file|null|stdout|stderr
 
 # Wcf 服务
 Wcf:
@@ -17,3 +17,4 @@ Web:
     Address: 127.0.0.1:7600 # 监听地址
     Swagger: true # 是否启用 Api 在线文档
     Token: "" # 使用 Token 验证请求，留空则不验证
+    Webhook: "" # 消息推送地址，留空则不启用

httpd/wcfrest/router.go

@@ -1,8 +1,11 @@
 package wcfrest
 
 import (
+	"strings"
+
 	"github.com/opentdp/go-helper/httpd"
 
+	"github.com/opentdp/wechat-rest/args"
 	"github.com/opentdp/wechat-rest/httpd/midware"
 	"github.com/opentdp/wechat-rest/wclient"
 )
@@ -57,4 +60,12 @@ func Route() {
 
 	rg.GET("socket_receiver", ctrl.socketReceiver)
 
+	// 启用 HTTP 消息推送
+
+	if args.Web.Webhook != "" {
+		for _, url := range strings.Split(args.Web.Webhook, ",") {
+			ctrl.enableUrlReceiver(url)
+		}
+	}
+
 }