浏览代码

fix:埋点

zqbao 9 月之前
父节点
当前提交
728f80a779
共有 3 个文件被更改,包括 38 次插入1 次删除
  1. 5 0
      controllers/wechat.go
  2. 30 0
      services/alarm_msg/alarm_msg.go
  3. 3 1
      utils/config.go

+ 5 - 0
controllers/wechat.go

@@ -6,6 +6,7 @@ import (
 	"eta/eta_mini_api/models"
 	"eta/eta_mini_api/models/request"
 	"eta/eta_mini_api/models/response"
+	"eta/eta_mini_api/services/alarm_msg"
 	"eta/eta_mini_api/services/wechat"
 	"eta/eta_mini_api/services/wx_app"
 	"eta/eta_mini_api/utils"
@@ -282,6 +283,8 @@ func (this *WechatController) Subscribe() {
 		br.ErrMsg = "获取失败,Err:" + err.Error()
 		return
 	}
+	bodyInfo, _ := json.Marshal(info)
+	alarm_msg.SendAlarmMsg(string(bodyInfo), 1)
 	if info.ErrCode != 0 {
 		br.Msg = "获取失败"
 		br.ErrMsg = "获取失败,Err:" + info.ErrMsg
@@ -304,6 +307,8 @@ func (this *WechatController) Subscribe() {
 			br.ErrMsg = "获取失败,Err:" + er.Error()
 			return
 		}
+		wxBody, _ := json.Marshal(wxInfo)
+		alarm_msg.SendAlarmMsg(string(wxBody), 1)
 		u.UnionId = wxInfo.UnionID
 		er = u.Update([]string{"union_id"})
 		if er != nil {

+ 30 - 0
services/alarm_msg/alarm_msg.go

@@ -0,0 +1,30 @@
+package alarm_msg
+
+import (
+	"encoding/json"
+	"eta/eta_mini_api/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")
+}

+ 3 - 1
utils/config.go

@@ -37,6 +37,8 @@ var (
 	SMS_TPLID string // 短信模板
 )
 
+var AlarmMsgUrl string // 报警地址
+
 // 微信相关
 var (
 	HZ_WX_APPID            string
@@ -99,7 +101,7 @@ func init() {
 	// HZ_WX_APP_SECRET = config["hz_wx_app_secret"]
 	HZ_WX_APPID = "wx9b5d7291e581233a"
 	HZ_WX_APP_SECRET = "f4d52e34021eee262dce9682b31f8861"
-
+	AlarmMsgUrl = "http://127.0.0.1:8606/api/alarm/send"
 	initRedis(config)
 }