kazuki43zoo / demo-reactive-mybatis Goto Github PK

2018-05-14 00:22:15,300-Predicate "((POST && /login) && Accept: [application/json])" matches against "POST /login"
2018-05-14 00:22:15,579-User info User(username=111, password=111, scope=user, client_id=SU_DI, client_secret=hz_su_di, user_uuid=)
2018-05-14 00:22:15,597-==>  Preparing: select * from WxUser where user_name=? 
2018-05-14 00:22:15,611-==> Parameters: 111(String)
2018-05-14 00:22:15,625-<==      Total: 1
2018-05-14 00:22:15,630-Predicate "org.springframework.web.reactive.function.server.RequestPredicates$$Lambda$632/565824767@d9c4fdc" matches against "POST /login"
2018-05-14 00:22:15,641-Failed to handle request [POST http://127.0.0.1:8080/login]
java.lang.NullPointerException: value

@Override
    public Mono<ServerResponse> userLogin(ServerRequest request) {
        return request
                .bodyToMono(User.class)
                .flatMap(user -> ok()
                        .body(BodyInserters
                                .fromObject(loginService.test(user))));
    }
    @Override
    public Mono<WxUser> test(User user) {
        log.info("User info {}", user);
        return Flux.just(userMapper.login(user.getUsername())).singleOrEmpty().subscribeOn(Schedulers.elastic());
    }
@Mapper
public interface WxUserMapper {
    /**
     *
     * @param username
     * @return
     */
    WxUser login(@Param(value = "username") String username);
}
@Data
@NoArgsConstructor
@AllArgsConstructor
public class WxUser implements Serializable {
    public Integer userID;
    public String username;
    public String password;

    public WxUser(String username, String password) {
        this.username = username;
        this.password = password;
    }
}