feat: add qyweixin message

service/send_message_service/send_message.go

@@ -139,6 +139,15 @@ func (sm *SendMessageService) Send() string {
 			sm.LogsAndStatusMark(sm.TransError(errMsg), errStrIsSuccess(errMsg))
 			continue
 		}
+		// 企业微信类型的实例发送
+		qywxAuth, ok := msgObj.(send_way_service.WayDetailQyWeiXin)
+		if ok {
+			es := QyWeiXinService{}
+			res, errMsg := es.SendQyWeiXinMessage(qywxAuth, ins.SendTasksIns, typeC, sm.Title, content)
+			sm.LogsAndStatusMark(fmt.Sprintf("返回内容：%s", res), sm.Status)
+			sm.LogsAndStatusMark(sm.TransError(errMsg), errStrIsSuccess(errMsg))
+			continue
+		}
 		// 自定义webhook类型的实例发送
 		customAuth, ok := msgObj.(send_way_service.WayDetailCustom)
 		if ok {

service/send_message_service/send_qywexin.go

@@ -0,0 +1,46 @@
+package send_message_service
+
+import (
+	"fmt"
+	"message-nest/models"
+	"message-nest/pkg/message"
+	"message-nest/service/send_ins_service"
+	"message-nest/service/send_way_service"
+)
+
+type QyWeiXinService struct {
+}
+
+// SendDtalkMessage 执行发送钉钉
+func (s *QyWeiXinService) SendQyWeiXinMessage(auth send_way_service.WayDetailQyWeiXin, ins models.SendTasksIns, typeC string, title string, content string) (string, string) {
+	insService := send_ins_service.SendTaskInsService{}
+	errStr, c := insService.ValidateDiffIns(ins)
+	if errStr != "" {
+		return errStr, ""
+	}
+	_, ok := c.(models.InsQyWeiXinConfig)
+	if !ok {
+		return "企业微信config校验失败", ""
+	}
+
+	errMsg := ""
+	var res []byte
+	var err error
+	cli := message.QyWeiXin{
+		AccessToken: auth.AccessToken,
+	}
+	if typeC == "text" {
+		res, err = cli.SendMessageText(content)
+		if err != nil {
+			errMsg = fmt.Sprintf("发送失败：%s", ins.ContentType)
+		}
+	} else if typeC == "markdown" {
+		res, err = cli.SendMessageMarkdown(title, content)
+		if err != nil {
+			errMsg = fmt.Sprintf("发送失败：%s", ins.ContentType)
+		}
+	} else {
+		errMsg = fmt.Sprintf("未知的企业微信发送内容类型：%s", ins.ContentType)
+	}
+	return string(res), errMsg
+}