Method ChangePassword

internal/repository/user.go:46–70

ChangePassword 修改密码

(ctx context.Context, username string, newPassword string)

// ChangePassword 修改密码
func (ur *userRepository) ChangePassword(ctx context.Context, username string, newPassword string) error {
	err := ur.dao.UpdatePasswordByUsername(ctx, username, newPassword)
	if err != nil {
		ur.l.Error("修改密码失败", zap.Error(err))
		return err
	}

	// 重新设置缓存,避免缓存不一致
	user, err := ur.dao.FindByUsername(ctx, username)
	if err != nil {
		ur.l.Error("密码修改后获取用户信息失败", zap.Error(err))
		return err
	}

	// 异步设置缓存
	go func() {
		ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
		defer cancel()
		if err := ur.cache.Set(ctx, toDomainUser(user)); err != nil {
			ur.l.Error("密码修改后更新缓存失败", zap.Error(err))
		}
	}()

	return nil
}

// CreateUser 创建用户
func (ur *userRepository) CreateUser(ctx context.Context, u domain.User) error {