fix:完善关注

controllers/wechat.go

@@ -132,6 +132,8 @@ func subscribe(openId string) {
 					fmt.Println("关注后，修改绑定用户状态异常，err：", err)
 					return
 				}
+				userRecord.UserId = user.UserId
+				userRecord.Update([]string{"user_id"})
 			}
 		}
 		return
@@ -176,6 +178,8 @@ func subscribe(openId string) {
 			fmt.Println("关注后，修改绑定用户状态异常，ERR：", err)
 			return
 		}
+		newUserRecord.UserId = user.UserId
+		newUserRecord.Update([]string{"user_id"})
 	}
 
 }
@@ -290,9 +294,6 @@ func (this *WechatController) Login() {
 func (this *WechatController) Subscribe() {
 	br := new(models.BaseResponse).Init()
 	defer func() {
-		if err := recover(); err != nil {
-			fmt.Println(err)
-		}
 		if br.Ret != 200 {
 			b, _ := json.Marshal(br)
 			alarm_msg.SendAlarmMsg(string(b), 1)
@@ -349,8 +350,6 @@ func (this *WechatController) Subscribe() {
 			br.ErrMsg = "获取失败,Err:" + er.Error()
 			return
 		}
-		wxBody, _ := json.Marshal(wxInfo)
-		alarm_msg.SendAlarmMsg(string(wxBody), 1)
 		userRecord.UnionId = wxInfo.UnionID
 		er = userRecord.Update([]string{"union_id"})
 		if er != nil {
@@ -374,6 +373,8 @@ func (this *WechatController) Subscribe() {
 			br.ErrMsg = "更新用户信息失败,Err:" + err.Error()
 			return
 		}
+		userRecord.UserId = user.UserId
+		userRecord.Update([]string{"user_id"})
 	}
 
 	br.Msg = "获取成功"