diff --git a/flyfish-user/src/main/java/com/flyfish/framework/repository/ReactiveUserRepository.java b/flyfish-user/src/main/java/com/flyfish/framework/repository/ReactiveUserRepository.java deleted file mode 100644 index 92780eb..0000000 --- a/flyfish-user/src/main/java/com/flyfish/framework/repository/ReactiveUserRepository.java +++ /dev/null @@ -1,14 +0,0 @@ -package com.flyfish.framework.repository; - -import com.flyfish.framework.domain.po.User; -import reactor.core.publisher.Mono; - -/** - * 异步用户仓库 - * - * @author wybab - */ -public interface ReactiveUserRepository extends DefaultReactiveRepository { - - Mono findByUsername(String username); -} diff --git a/flyfish-user/src/main/java/com/flyfish/framework/repository/UserRepository.java b/flyfish-user/src/main/java/com/flyfish/framework/repository/UserRepository.java index 74d1914..b75fc2b 100644 --- a/flyfish-user/src/main/java/com/flyfish/framework/repository/UserRepository.java +++ b/flyfish-user/src/main/java/com/flyfish/framework/repository/UserRepository.java @@ -1,15 +1,14 @@ package com.flyfish.framework.repository; import com.flyfish.framework.domain.po.User; - -import java.util.Optional; +import reactor.core.publisher.Mono; /** - * 用户repo + * 异步用户仓库 * - * @author wangyu + * @author wybab */ -public interface UserRepository extends DefaultRepository { +public interface UserRepository extends DefaultReactiveRepository { /** * 通过用户名密码查询用户 @@ -18,7 +17,7 @@ public interface UserRepository extends DefaultRepository { * @param password 密码 * @return 结果 */ - Optional findByUsernameAndPassword(String username, String password); + Mono findByUsernameAndPassword(String username, String password); /** * 通过用户名查询 @@ -26,5 +25,5 @@ public interface UserRepository extends DefaultRepository { * @param username 用户名 * @return 结果 */ - Optional findByUsername(String username); + Mono findByUsername(String username); } diff --git a/flyfish-user/src/main/java/com/flyfish/framework/service/UserService.java b/flyfish-user/src/main/java/com/flyfish/framework/service/UserService.java index ea794f3..8bf5ca2 100644 --- a/flyfish-user/src/main/java/com/flyfish/framework/service/UserService.java +++ b/flyfish-user/src/main/java/com/flyfish/framework/service/UserService.java @@ -1,7 +1,7 @@ package com.flyfish.framework.service; import com.flyfish.framework.domain.po.User; -import com.flyfish.framework.repository.ReactiveUserRepository; +import com.flyfish.framework.repository.UserRepository; import com.flyfish.framework.service.impl.BaseReactiveServiceImpl; import org.springframework.stereotype.Service; import reactor.core.publisher.Mono; @@ -22,7 +22,7 @@ public class UserService extends BaseReactiveServiceImpl implements UserFi */ @Override public Mono findByUsername(String username) { - return ((ReactiveUserRepository) repository).findByUsername(username); + return ((UserRepository) repository).findByUsername(username); } }