|
@@ -116,10 +116,24 @@ func subscribe(openId string) {
|
|
|
userRecord.SubscribeTime = time.Now()
|
|
|
err = userRecord.Update([]string{"union_id", "subscribe", "subscribe_time"})
|
|
|
if err != nil {
|
|
|
- fmt.Println("关注后,通过openid更新user_record异常,ERR:", err)
|
|
|
+ fmt.Println("关注后,通过openid更新user_record异常,err:", err)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ user, err := models.GetUserByUnionId(unionId)
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println("关注后,通过unionid获取user记录失败,err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if user != nil {
|
|
|
+ user.IsSubscribed = true
|
|
|
+ user.ModifyTime = time.Now()
|
|
|
+ err = user.Update([]string{"modify_time", "is_subscribed"})
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println("关注后,修改绑定用户状态异常,err:", err)
|
|
|
+ return
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
return
|
|
|
}
|
|
|
|