org.hswebframework.web.system.authorization.defaults.service

Class DefaultReactiveUserService

java.lang.Object

org.hswebframework.web.crud.service.GenericReactiveCrudService<UserEntity,String>

org.hswebframework.web.system.authorization.defaults.service.DefaultReactiveUserService

All Implemented Interfaces:

ReactiveCrudService<UserEntity,String>, ReactiveUserService

public class DefaultReactiveUserService
extends GenericReactiveCrudService<UserEntity,String>
implements ReactiveUserService

Constructor Summary

Constructors

Constructor and Description
DefaultReactiveUserService()

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Mono<Boolean>	changePassword(String userId, String oldPassword, String newPassword) 修改用户密码
reactor.core.publisher.Mono<Integer>	changeState(org.reactivestreams.Publisher<String> userId, byte state) 修改用户状态
reactor.core.publisher.Mono<Integer>	countUser(org.hswebframework.ezorm.core.param.QueryParam queryParam) 根据查询条件查询用户数量
reactor.core.publisher.Mono<Boolean>	deleteUser(String userId) 删除用户
protected reactor.core.publisher.Mono<UserEntity>	doAdd(UserEntity userEntity)
protected reactor.core.publisher.Mono<UserEntity>	doUpdate(UserEntity userEntity)
reactor.core.publisher.Mono<UserEntity>	findById(String id) 根据用户名查询用户实体，如果用户不存在则返回Mono.empty()
reactor.core.publisher.Mono<UserEntity>	findByUsername(String username) 根据用户名查询用户实体，如果用户不存在则返回Mono.empty()
reactor.core.publisher.Mono<UserEntity>	findByUsernameAndPassword(String username, String plainPassword) 根据用户名和密码查询用户实体，如果用户不存在或者密码不匹配则返回Mono.empty()
reactor.core.publisher.Flux<UserEntity>	findUser(org.hswebframework.ezorm.core.param.QueryParam queryParam) 根据查询条件查询用户
reactor.core.publisher.Mono<UserEntity>	newUserInstance() 创建一个新的用户实例
reactor.core.publisher.Mono<Boolean>	saveUser(reactor.core.publisher.Mono<UserEntity> request) 保存用户

Methods inherited from class org.hswebframework.web.crud.service.GenericReactiveCrudService

getRepository

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.hswebframework.web.crud.service.ReactiveCrudService

count, count, createDelete, createQuery, createUpdate, deleteById, deleteById, findById, findById, findById, insert, insert, insertBatch, query, query, queryPager, queryPager, queryPager, queryPager, save, save, save, updateById, updateById

Constructor Detail

DefaultReactiveUserService

public DefaultReactiveUserService()

Method Detail

newUserInstance

public reactor.core.publisher.Mono<UserEntity> newUserInstance()

Description copied from interface: ReactiveUserService

创建一个新的用户实例

Specified by:

newUserInstance in interface ReactiveUserService

Returns:

用户实例

saveUser

@Transactional(rollbackFor=java.lang.Exception.class,
               transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Mono<Boolean> saveUser(reactor.core.publisher.Mono<UserEntity> request)

Description copied from interface: ReactiveUserService

保存用户

Specified by:

saveUser in interface ReactiveUserService

Parameters:

request - 用户实体

Returns:

是否成功

doAdd

protected reactor.core.publisher.Mono<UserEntity> doAdd(UserEntity userEntity)

doUpdate

protected reactor.core.publisher.Mono<UserEntity> doUpdate(UserEntity userEntity)

findById

@Transactional(readOnly=true,
               transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Mono<UserEntity> findById(String id)

Description copied from interface: ReactiveUserService

根据用户名查询用户实体，如果用户不存在则返回Mono.empty()

Specified by:

findById in interface ReactiveCrudService<UserEntity,String>

Specified by:

findById in interface ReactiveUserService

Parameters:

id - 用户名

Returns:

用户实体

findByUsername

@Transactional(readOnly=true,
               transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Mono<UserEntity> findByUsername(String username)

Description copied from interface: ReactiveUserService

根据用户名查询用户实体，如果用户不存在则返回Mono.empty()

Specified by:

findByUsername in interface ReactiveUserService

Parameters:

username - 用户名

Returns:

用户实体

findByUsernameAndPassword

@Transactional(readOnly=true,
               transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Mono<UserEntity> findByUsernameAndPassword(String username,
                                                                                                                                                                                String plainPassword)

Description copied from interface: ReactiveUserService

根据用户名和密码查询用户实体，如果用户不存在或者密码不匹配则返回Mono.empty()

Specified by:

findByUsernameAndPassword in interface ReactiveUserService

Parameters:

username - 用户名

plainPassword - 明文密码

Returns:

用户实体

changeState

@Transactional(rollbackFor=java.lang.Exception.class,
               transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Mono<Integer> changeState(org.reactivestreams.Publisher<String> userId,
                                                                                                                                                                                       byte state)

Description copied from interface: ReactiveUserService

修改用户状态

Specified by:

changeState in interface ReactiveUserService

Parameters:

userId - 用户ID

state - 状态

Returns:

修改数量

changePassword

@Transactional(rollbackFor=java.lang.Exception.class,
               transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Mono<Boolean> changePassword(String userId,
                                                                                                                                                                                          String oldPassword,
                                                                                                                                                                                          String newPassword)

Description copied from interface: ReactiveUserService

修改用户密码

Specified by:

changePassword in interface ReactiveUserService

Parameters:

userId - 用户ID

oldPassword - 旧密码

newPassword - 新密码

Returns:

是否成功

findUser

@Transactional(readOnly=true,
               transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Flux<UserEntity> findUser(org.hswebframework.ezorm.core.param.QueryParam queryParam)

Description copied from interface: ReactiveUserService

根据查询条件查询用户

Specified by:

findUser in interface ReactiveUserService

Parameters:

queryParam - 动态查询条件

Returns:

用户列表

countUser

@Transactional(readOnly=true,
               transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Mono<Integer> countUser(org.hswebframework.ezorm.core.param.QueryParam queryParam)

Description copied from interface: ReactiveUserService

根据查询条件查询用户数量

Specified by:

countUser in interface ReactiveUserService

Parameters:

queryParam - 查询条件

Returns:

用户数量

deleteUser

@Transactional(readOnly=true,
               transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Mono<Boolean> deleteUser(String userId)

Description copied from interface: ReactiveUserService

删除用户

Specified by:

deleteUser in interface ReactiveUserService

Parameters:

userId - 用户ID

Returns:

是否成功

See Also:

UserDeletedEvent