@RestController
@Api(tags = "Отправка СМС через Девино-Телеком")
public class SmsController extends Controller {
    private static final Logger logger = LoggerFactory.getLogger(SmsController.class);
    private final SmsService smsService;
public SmsController(SmsService smsService) {
    this.smsService = smsService;
}
@GetMapping(value = "/sms/{to}/{text}")
@ApiOperation(value = "Тестирование отправки СМС")
@ApiResponse(code = 200, message = "Результат передачи СМС")
Mono<ResponseEntity<ResultDto>> sendSms(
        @ApiParam(value = "Номер телефона", required = true) @PathVariable(name = "to") String to,
        @ApiParam(value = "Текст сообщения", required = true) @PathVariable(name = "text") String text
) {
    return smsService.sendSms(to, text);
}
}

import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;
@Service
public class SmsService {
    private static final Logger logger = LoggerFactory.getLogger(SmsService.class);
    private static final String PHONE_PREFIX = "7";
    private final WebClient smsClient;
    @Value("${sms.callingSystem}")
    private String callingSystem;
    @Value("${server.site}")
    private String site;
    @Value("${sms.callbackUrl}")
    private String callbackUrl;
public SmsService(WebClient smsClient) {
    this.smsClient = smsClient;
}
public Mono<ResponseEntity<ResultDto>> sendSms(String to, String text) {
    MessageDto message = new MessageDto(callingSystem, PHONE_PREFIX + to, text);
    message.setCallbackUrl(site + callbackUrl);
    MessagesDto messages = new MessagesDto(message);
    return smsClient.post()
            .bodyValue(messages)
            .exchange()
            .flatMap(res -> res.bodyToMono(ResultsDto.class)
                    .map(rs -> {
                        List<ResultDto> results = rs.getResults();
                        return ResponseEntity.ok().body(results.get(0));
                    })
            );
}

@Configuration
public class SmsConfig {
    private static final Logger logger = LoggerFactory.getLogger(SmsConfig.class);
    private static final String CONTENT_TYPE_HEADER = "Content-Type";
    private static final String AUTH_HEADER = "Authorization";
    @Value("${sms.url}")
    private String url;
    @Value("${sms.token}")
    private String token;
@Bean
public WebClient smsClient() {
    HttpClient httpClient = HttpClient
            .create()
            .tcpConfiguration(
                    tc -> tc.bootstrap(
                            b -> BootstrapHandlers.updateLogSupport(b, new CustomLogger(HttpClient.class))));
    WebClient webClient = WebClient.builder()
            .baseUrl(url)
            .defaultHeader(CONTENT_TYPE_HEADER, MediaType.APPLICATION_JSON.toString())
            .defaultHeader(AUTH_HEADER, token)
            .clientConnector(new ReactorClientHttpConnector(httpClient))
            .filters(exchangeFilterFunctions -> {
                exchangeFilterFunctions.add(logRequest());
                exchangeFilterFunctions.add(logResponse());
            })
            .build();
    return webClient;
}
private ExchangeFilterFunction logRequest() {
    return ExchangeFilterFunction.ofRequestProcessor(clientRequest -> {
        logger.info("Sms REST CLIENT REQUEST: **********");
        return Mono.just(clientRequest);
    });
}
private ExchangeFilterFunction logResponse() {
    return ExchangeFilterFunction.ofResponseProcessor(clientResponse -> {
        logger.info("********** Sms REST CLIENT RESPONSE");
        return Mono.just(clientResponse);
    });
}
}

import org.springframework.data.r2dbc.repository.Query;
import org.springframework.data.repository.reactive.ReactiveCrudRepository;
import org.springframework.stereotype.Repository;
import reactor.core.publisher.Mono;
import ru.sksbank.privilege.demo.model.dc.Client;
@Repository
public interface ClientRepository extends ReactiveCrudRepository<Client, Long> {
    @Query("SELECT * FROM client WHERE phone_number = :phone AND passive = 0")
    Mono<Client> findByPhoneActive(String phone);
}

@Table("client")
public class Client {   
   @Id   @Column("id") private Long id;
   @Column("user_id") private Long userId;
   @Column("person_id") private Long personId;
   @Column("phone_number") private String phone;
}