workTasks/sendBidToSftp/send/qywx.go

package send

import (
	"context"
	"github.com/gogf/gf/v2/errors/gerror"
	"github.com/gogf/gf/v2/frame/g"
	"github.com/gogf/gf/v2/util/gconv"
)

type qywxCommonRes struct {
	Errcode int    `json:"errcode"`
	Errmsg  string `json:"errmsg"`
}

func SendSimpleMsg2ChatBot(content string, atList ...string) error {
	var qwRobotNotice = g.Cfg().MustGet(context.Background(), "qwRobotNotice").String()
	if qwRobotNotice == "" {
		return nil
	}
	res, err := g.Client().Header(g.MapStrStr{"Content-Type": "application/json"}).
		Post(context.TODO(), qwRobotNotice,
			g.Map{
				"msgtype": "text",
				"text": g.Map{
					"content":        content,
					"mentioned_list": atList,
				},
			})
	if err != nil {
		return err
	}
	var commonRes qywxCommonRes
	if err := gconv.Struct(res.ReadAll(), &commonRes); err != nil {
		return gerror.Wrap(err, "读取企业微信消息异常")
	}
	if commonRes.Errcode == 0 {
		return nil
	}
	return gerror.New(commonRes.Errmsg)
}