@@ -32,10 +32,21 @@ func (l *BindMobileLogic) BindMobile(req types.BindMobileRequest) (*types.Respon
return nil, err
}
_, err = l.svcCtx.SqlConn.Exec(`update i2bill_user set mobile = ? where id = ?`, mobile, l.UserId)
+ tx := l.svcCtx.DB.NewSession()
+ tx.Begin()
+ _, err = tx.Exec("update i2bill_user set mobile = ? where id = ?", mobile, l.UserId)
if err != nil {
+ tx.Rollback()
logx.Error(err)
+ tx.Exec("update i2bill_mkt_part_time_user set ipone_number = ? where user_id = ?", mobile, l.UserId)
+ if err != nil {
+ logx.Error(err)
+ return nil, err
+ }
+ tx.Commit()
resp := make(map[string]interface{})
resp["id"] = l.UserId
resp["mobile"] = mobile