add:添加告警

controllers/wechat.go

@@ -1,8 +1,10 @@
 package controllers
 
 import (
+	"encoding/json"
 	"eta/eta_mini_bridge/models"
 	"eta/eta_mini_bridge/services"
+	"eta/eta_mini_bridge/services/alarm_msg"
 	"eta/eta_mini_bridge/utils"
 	"fmt"
 	"html"
@@ -21,6 +23,10 @@ type WeChatController struct {
 func (this *WeChatController) SendTemplateMsg() {
 	br := new(models.BaseResponse).Init()
 	defer func() {
+		if br.Ret != 200 {
+			b, _ := json.Marshal(br)
+			alarm_msg.SendAlarmMsg(string(b), 1)
+		}
 		this.Data["json"] = br
 		this.ServeJSON()
 	}()

services/alarm_msg/alarm_msg.go

@@ -0,0 +1,30 @@
+package alarm_msg
+
+import (
+	"encoding/json"
+	"eta/eta_mini_bridge/utils"
+
+	"github.com/rdlucklib/rdluck_tools/http"
+)
+
+// SendAlarmMsg
+// projectName-项目名称
+// runMode-运行模式
+// msgBody-消息内容
+// level:消息基本,1:提示消息,2:警告消息,3:严重错误信息,默认为1 提示消息
+func SendAlarmMsg(msgBody string, level int) {
+	if utils.AlarmMsgUrl == `` {
+		return
+	}
+	params := make(map[string]interface{})
+	params["ProjectName"] = utils.APPNAME
+	params["RunMode"] = utils.RunMode
+	params["MsgBody"] = msgBody
+	params["Level"] = level
+	param, err := json.Marshal(params)
+	if err != nil {
+		utils.FileLog.Info("SendAlarmMsg json.Marshal Err:" + err.Error())
+		return
+	}
+	http.Post(utils.AlarmMsgUrl, string(param), "application/json")
+}

utils/config.go

@@ -35,6 +35,9 @@ var (
 	ETA_MINI_API_SECRET string
 )
 
+// 报警地址
+var AlarmMsgUrl string
+
 // 微信相关
 var (
 	WX_MINI_APPID          string
@@ -106,7 +109,7 @@ func init() {
 	// WX_APP_SECRET = config["wx_app_secret"]
 	WX_APPID = "wx9b5d7291e581233a"
 	WX_APP_SECRET = "f4d52e34021eee262dce9682b31f8861"
-
+	AlarmMsgUrl = "http://127.0.0.1:8606/api/alarm/send"
 	// redis缓存配置
 	REDIS_CACHE = config["beego_cache"]
 	if len(REDIS_CACHE) <= 0 {

utils/constants.go

@@ -27,3 +27,6 @@ const (
 const (
 	CACHE_WX_ACCESS_TOKEN_HZ = "wx:accesstoken:hzyj" //弘则研究公众号 微信accessToken
 )
+const (
+	APPNAME = "东吴小程序桥接服务"
+)