|
@@ -301,7 +301,27 @@ func (this *WechatCommonController) Notify() {
|
|
|
</xml>`
|
|
|
createTime := strconv.FormatInt(time.Now().Unix(), 10)
|
|
|
xmlTpl = fmt.Sprintf(xmlTpl, openId, utils.WxId, createTime, contactMsg)
|
|
|
- wxUser, err := models.GetUserDetailBuOpenid(openId)
|
|
|
+ accessToken, err := services.GetWxAccessTokenByXzs()
|
|
|
+ if err != nil {
|
|
|
+ utils.FileLog.Info("accessToken:" + err.Error())
|
|
|
+ }
|
|
|
+ if accessToken == "" {
|
|
|
+ utils.FileLog.Info("access_token 为空 openId:" + openId)
|
|
|
+ }
|
|
|
+ wxUserInfo, err := services.WxGetUserInfo(openId, accessToken)
|
|
|
+ if err != nil {
|
|
|
+ utils.FileLog.Info("accessToken:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if wxUserInfo.Errcode != 0 {
|
|
|
+ userInfoJson, _ := json.Marshal(wxUserInfo)
|
|
|
+ utils.FileLog.Info("获取用户信息失败,err:" + string(userInfoJson))
|
|
|
+ }
|
|
|
+ unionId := wxUserInfo.Unionid
|
|
|
+ if unionId == "" {
|
|
|
+ utils.FileLog.Info("获取unionid失败,openId:" + openId)
|
|
|
+ }
|
|
|
+ wxUser, err := models.GetUserRecordByUnionId(unionId)
|
|
|
if err != nil {
|
|
|
utils.FileLog.Info("GetUserDetailBuOpenid:" + err.Error())
|
|
|
}
|