jy_docs/rpc/partnerlib/warn/warn.go

package warn

import (
	IC "app.yhyue.com/moapp/jy_docs/rpc/partnerlib/init"
	"bytes"
	"encoding/json"
	"log"
	"net/http"
)

// TODO docin 更新保存异常告警
func SendMsgByWXURL(msg string) {
	log.Println("warn msg:", msg)
	if len(IC.Warn.WebhookURL) > 0 {
		for _, url := range IC.Warn.WebhookURL {
			if ok := SendBot(url, msg); !ok {
				log.Println("数据加载异常 企业微信机器人提醒失败--：", 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 {
		log.Println("Error :", err.Error())
		return
	}
	// 发送 POST 请求
	resp, err := http.Post(webhookURL, "application/json", bytes.NewReader(payloadBytes))
	if err != nil {
		log.Println("Error :", err.Error())
		return
	}
	defer resp.Body.Close()
	b = true
	return
}