瀏覽代碼

add migrate wx_user function

abiao 5 年之前
父節點
當前提交
966c60fb7e

+ 5 - 3
go/gopath/src/fohow.com/apps/controllers/user_controller/user_controller.go

@@ -462,6 +462,7 @@ func (self *UserController) SysUserBind() {
 	if sysWxUser == nil {
 		self.ReturnError(403, apps.NoExist, "", nil)
 	}
+
 	//同步会员资料--原会员迁移至新会员(除ID,invite_id之外)
 	sysWxUser.UserId = wxUser.UserId
 	sysWxUser.MpOpenid = wxUser.MpOpenid
@@ -476,12 +477,13 @@ func (self *UserController) SysUserBind() {
 	sysWxUser.ChannelQrcodeId = wxUser.ChannelQrcodeId
 	sysWxUser.ShowInviteMode = wxUser.ShowInviteMode
 	sysWxUser.Rank = wxUser.Rank
-	err := sysWxUser.Save()
+	//迁移该会员至备份表,删除微信表记录
+	err := wxUser.MigrateWxUsers()
 	if err != nil {
 		self.ReturnError(403, apps.BindFail, "", nil)
 	}
-	//迁移该会员至备份表,删除微信表记录
-	wxUser.MigrateWxUsers()
+	sysWxUser.Save()
+
 	//创建绑定记录
 	record := new(user_model.BindUser).Create(wxUser.Id, userNo, remark)
 	if record == nil {

+ 8 - 4
go/gopath/src/fohow.com/apps/models/user_model/bind_user.go

@@ -84,7 +84,7 @@ func GetWxUserByUserNo(userNo string) *WxUser {
 }
 
 //迁移微信老会员
-func (self *WxUser) MigrateWxUsers() {
+func (self *WxUser) MigrateWxUsers() error {
 	o := orm.NewOrm()
 	//迁移当前记录
 	sql := `
@@ -93,13 +93,17 @@ func (self *WxUser) MigrateWxUsers() {
 	_, err := o.Raw(sql, self.Id).Exec()
 	if err != nil {
 		beego.BeeLogger.Warn("models.MigrateWxUsers() err[%s]", err)
-		return
+		return err
 	} else {
 		//迁移当前记录
 		sql = `
 		delete from wx_users where id = ?
 	`
-		o.Raw(sql, self.Id).Exec()
+		_, err := o.Raw(sql, self.Id).Exec()
+		if err != nil {
+			beego.BeeLogger.Warn("models.MigrateWxUsers() err[%s]", err)
+			return err
+		}
 	}
-	return
+	return nil
 }