jyMicroservices/jyBXCore/rpc/util/warn.go

package util

import (
	IC "bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/rpc/init"
	"bytes"
	"encoding/json"
	"github.com/zeromicro/go-zero/core/logx"
	"net/http"
)

// TODO docin 更新保存异常告警
func SendMsgByWXURL(msg string) {
	logx.Info("warn msg:", msg)
	if len(IC.C.LimitSearchText.WebhookURL) > 0 {
		for _, url := range IC.C.LimitSearchText.WebhookURL {
			if ok := SendBot(url, msg); !ok {
				logx.Info("数据加载异常 企业微信机器人提醒失败--：", url, msg)
			}
		}
	}
}

func SendBot(webhookURL, msg string) (b bool) {
	// 构造请求体
	payload := map[string]interface{}{
		"msgtype": "text",
		"text": map[string]string{
			"content": msg,
		},
	}
	// 转换为 JSON 字符串
	payloadBytes, err := json.Marshal(payload)
	if err != nil {
		logx.Info("Error :", err.Error())
		return
	}
	// 发送 POST 请求
	resp, err := http.Post(webhookURL, "application/json", bytes.NewReader(payloadBytes))
	if err != nil {
		logx.Info("Error :", err.Error())
		return
	}
	defer resp.Body.Close()
	b = true
	return
}