#1494

fix bug

models/wechat_bind.go

@@ -32,10 +32,16 @@ func BindWechatOpenId(userId int64, wechatOpenId string) error {
 	n, err := sess.Where("ID = ?", userId).Update(param)
 	if err != nil {
 		log.Error("update wechat_open_id failed,e=%v", err)
+		if e := sess.Rollback(); e != nil {
+			log.Error("BindWechatOpenId: sess.Rollback: %v", e)
+		}
 		return err
 	}
 	if n == 0 {
 		log.Error("update wechat_open_id failed,user not exist,userId=%d", userId)
+		if e := sess.Rollback(); e != nil {
+			log.Error("BindWechatOpenId: sess.Rollback: %v", e)
+		}
 		return nil
 	}
 
@@ -70,10 +76,16 @@ func UnbindWechatOpenId(userId int64, oldWechatOpenID string) error {
 	n, err := x.Table(new(User)).Where("ID = ? AND wechat_open_id =?", userId, oldWechatOpenID).Update(map[string]interface{}{"wechat_open_id": "", "wechat_bind_unix": nil})
 	if err != nil {
 		log.Error("update wechat_open_id failed,e=%v", err)
+		if e := sess.Rollback(); e != nil {
+			log.Error("UnbindWechatOpenId: sess.Rollback: %v", e)
+		}
 		return err
 	}
 	if n == 0 {
 		log.Error("update wechat_open_id failed,user not exist,userId=%d", userId)
+		if e := sess.Rollback(); e != nil {
+			log.Error("UnbindWechatOpenId: sess.Rollback: %v", e)
+		}
 		return nil
 	}
 	logParam := &WechatBindLog{