zqbao 9 luni în urmă
părinte
comite
d8381cf106
2 a modificat fișierele cu 4 adăugiri și 0 ștergeri
  1. 2 0
      controllers/wechat.go
  2. 2 0
      services/wechat/wechat.go

+ 2 - 0
controllers/wechat.go

@@ -301,12 +301,14 @@ func (this *WechatController) Subscribe() {
 		return
 	}
 	if u.UnionId == "" {
+		alarm_msg.SendAlarmMsg("开始获取用户信息成功", 1)
 		wxInfo, er := wechat.GetUserInfo(u.OpenId)
 		if er != nil {
 			br.Msg = "获取失败"
 			br.ErrMsg = "获取失败,Err:" + er.Error()
 			return
 		}
+		alarm_msg.SendAlarmMsg("获取用户信息成功", 1)
 		wxBody, _ := json.Marshal(wxInfo)
 		alarm_msg.SendAlarmMsg(string(wxBody), 1)
 		u.UnionId = wxInfo.UnionID

+ 2 - 0
services/wechat/wechat.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"eta/eta_mini_api/models"
+	"eta/eta_mini_api/services/alarm_msg"
 	"eta/eta_mini_api/utils"
 	"fmt"
 	"io"
@@ -162,6 +163,7 @@ func GetWxUserInfo(code string) (info *WxUserInfo, err error) {
 	if err != nil {
 		return
 	}
+	alarm_msg.SendAlarmMsg(string(body), 1)
 	if err = json.Unmarshal(body, &info); err != nil {
 		return
 	}