分离钉钉消息到通知管理

internal/logic/systemCron/listener.go

@@ -3,6 +3,7 @@ package systemCron
 import (
 	"encoding/json"
 	"fmt"
+	"github.com/ayflying/utility_go/package/message"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/net/gclient"
 	"github.com/gogf/gf/v2/os/gtime"
@@ -28,14 +29,14 @@ func (s *sSystemCron) Guardian(DingTalkWebHook string) {
 
 		defer get.Close()
 		if err != nil {
-			s.DingTalk(DingTalkWebHook, fmt.Sprintf("监控报警：服务端访问失败 (%v 服务器),err=%v", v.Name, err))
+			message.New(message.DingTalk, DingTalkWebHook).Send(fmt.Sprintf("监控报警：服务端访问失败 (%v 服务器),err=%v", v.Name, err))
 		} else if get.StatusCode != 200 {
-			s.DingTalk(DingTalkWebHook, fmt.Sprintf("监控报警：服务端访问失败 (%v 服务器),code=%v,err=%v", v.Name, get.StatusCode, err))
+			message.New(message.DingTalk, DingTalkWebHook).Send(fmt.Sprintf("监控报警：服务端访问失败 (%v 服务器),code=%v,err=%v", v.Name, get.StatusCode, err))
 		} else {
 			var ststus Status
 			err = json.Unmarshal(get.ReadAll(), &ststus)
 			if ststus.Code != 0 {
-				s.DingTalk(DingTalkWebHook, fmt.Sprintf("监控报警：服务端访问失败 (%v 服务器),msg=%v", v.Name, ststus.Message))
+				message.New(message.DingTalk, DingTalkWebHook).Send(fmt.Sprintf("监控报警：服务端访问失败 (%v 服务器),msg=%v", v.Name, ststus.Message))
 			}
 		}
 	}
@@ -46,7 +47,11 @@ func (s *sSystemCron) Guardian(DingTalkWebHook string) {
 // @Description: 向指定的钉钉机器人发送消息。
 // @receiver s: 系统定时任务结构体指针。
 // @param value: 要发送的消息内容。
+// Deprecated: Use message.New(message.DingTalk, DingTalkWebHook).Send(value)
 func (s *sSystemCron) DingTalk(DingTalkWebHook string, value string) (res *gclient.Response) {
+	message.New(message.DingTalk, DingTalkWebHook).Send(value)
+	return
+
 	// 从配置中获取发送者名称
 	name, _ := g.Cfg().Get(ctx, "name")
 

package/message/consts.go

@@ -0,0 +1,11 @@
+package message
+
+type MessageType int32
+
+const (
+	DingTalk MessageType = iota
+	Wechat
+	Email
+	Sms
+	Voice
+)

package/message/drive/dingtalk.go

@@ -0,0 +1,43 @@
+package drive
+
+import (
+	"github.com/gogf/gf/v2/frame/g"
+	"github.com/gogf/gf/v2/os/gctx"
+	"github.com/gogf/gf/v2/os/gtime"
+)
+
+type Mod struct {
+	DingTalkWebHook string
+}
+
+func Load(webHook string) *Mod {
+	return &Mod{
+		DingTalkWebHook: webHook,
+	}
+}
+
+func (m Mod) Send(value string) {
+	ctx := gctx.New()
+	// 从配置中获取发送者名称
+	name, _ := g.Cfg().Get(ctx, "name")
+
+	// 定义钉钉机器人发送消息的URL，其中access_token为固定值
+	url := m.DingTalkWebHook
+	url += "&timestamp=" + gtime.Now().TimestampMilliStr()
+	// 使用goroutine异步发送消息
+
+	var post = g.Map{
+		"msgtype": "text",
+		"text": g.Map{
+			"content": "通知姬 " + name.String() + "：\n" + value + "\n" + gtime.Now().String(),
+		},
+	}
+
+	// 构建发送的消息体，包含消息类型和内容
+	_, err := g.Client().Discovery(nil).ContentJson().Post(ctx, url, post)
+	if err != nil {
+		g.Log().Info(ctx, err)
+	}
+
+	return
+}

package/message/message.go

@@ -0,0 +1,16 @@
+package message
+
+import "github.com/ayflying/utility_go/package/message/drive"
+
+type MessageV1 interface {
+	Send(value string)
+}
+
+func New(typ MessageType, host string) MessageV1 {
+	switch typ {
+	case DingTalk:
+		return drive.Load(host)
+
+	}
+	return nil
+}

service/system_cron.go

@@ -18,6 +18,7 @@ type (
 		// @Description: 向指定的钉钉机器人发送消息。
 		// @receiver s: 系统定时任务结构体指针。
 		// @param value: 要发送的消息内容。
+		// Deprecated: Use message.New(message.DingTalk, DingTalkWebHook).Send(value)
 		DingTalk(DingTalkWebHook string, value string) (res *gclient.Response)
 		ReadLog()
 		// AddCron 添加一个定时任务到相应的调度列表中。