This commit is contained in:
eson
2023-08-29 18:06:39 +08:00
parent 7a2b66f5ab
commit 15692d6075
10 changed files with 158 additions and 7 deletions

View File

@@ -148,8 +148,7 @@ func (u *FsUserModel) RegisterByFusen(ctx context.Context, token *auth.RegisterT
user = &FsUser{}
var err error
userTx := tx.Model(user)
err = userTx.Where("email = ?", token.Email).Take(user).Error
err = tx.Model(user).Where("email = ?", token.Email).Take(user).Error
if err == gorm.ErrRecordNotFound {
FirstName := token.Extend["first_name"].(string)
@@ -234,3 +233,47 @@ func (u *FsUserModel) UpdateUserBasicInfoById(ctx context.Context, Id int64, use
}).Error
return err
}
func (u *FsUserModel) DebugAuthDelete(ctx context.Context, email string) (err error) {
err = u.db.WithContext(ctx).Transaction(func(tx *gorm.DB) error {
user := &FsUser{}
txUser := tx.Model(user)
err = txUser.Where("email = ?", email).Take(user).Error
if err == nil {
err = txUser.Where("email = ?", email).Delete(user).Error
if err != nil {
return err
}
txRes := tx.Model(&FsResource{})
txUserMaterial := tx.Model(&FsUserMaterial{})
txUserInfo := tx.Model(&FsUserInfo{})
// 继承guest_id的资源表
err = txRes.
Where("user_id = ?", user.Id).Delete(&FsResource{}).Error
if err != nil && err != gorm.ErrRecordNotFound {
return err
}
err = txUserMaterial.
Where("user_id = ?", user.Id).
Delete(&FsUserMaterial{}).Error
if err != nil && err != gorm.ErrRecordNotFound {
return err
}
err = txUserInfo.
Where("user_id = ?", user.Id).
Delete(&FsResource{}).Error
if err != nil && err != gorm.ErrRecordNotFound {
return err
}
}
return nil
})
return err
}