Notes

public ResponseEnttty<XlsUploadingRespDto> uploadXls(MultipartFile file, Boolean isCorrection) {
UUID traceld = UUID.randomUUID();
log.info("[TraceID: {}] Received ’{}' request to uploading xls file {}",
traceld, FIXED-PRELIMINARY.getEngName(), file.getOriginalFilename());
try {
List<FixedPreliminaryRateXlsx> fixedRatesXls = xlsParser.parse(file);
List<VerificationResult> errorResults = validator.validate(fixedRatesXls);
if (!errorResults.isEmpty()) {
throw new ValidationException(errorResults);
}
List<FixedPreliminaryRateDto> fixedRatesDto = converter.convertAllBack(fixedRatesXls);
// Call the calculateRates method in the target microservice
Flux<RateDto> calculatedRates = callCalculateRates(fixedRatesDto);
// Add any further processing logic for the calculatedRates here

SaveChangedResult<FixedPreliminaryRateDto> saveResult =
preliminaryRateDao.saveChanged(fixedRatesDto);
if (!saveResult.isChanged()) {
log.info("[TraceID: {}] xls file '{}' was already uploaded before", traceld,
file.getOriginalFilename());
return ResponseEntity.ok()
.body(XlsUploadingRespDto.builder()
.message(format("Файл '%s' уже был загружен ранее",
file.getOriginalFilename()))
.uploadingTimestamp(Instant.now()).build());
}
log.info("[TraceID: {}] xls file '{}' was uploaded", traceld, file.getOriginalFilename());
} catch (Exception e) {
log.error("[TraceID: {}] Occurred error while xls file '{}' uploading", traceld,
file.getOriginalFilename(), e);
throw e;
}
return ResponseEntity.ok()
.body(XlsUploadingRespDto.builder()
.uploadingTimestamp(Instant.now()).build());
}


private Flux<RateDto> callCalculateRates(List<FixedPreliminaryRateDto> fixedRatesDto) {
// Convert the List<FixedPreliminaryRateDto> to List<RateDto> before sending the request
List<RateDto> rateDtoList = convertFixedPreliminaryRateDtoToRateDto(fixedRatesDto);

return webClient.post()
.uri("/calculate")
.contentType(MediaType.APPLICATION_JSON)
.body(BodyInserters.fromValue(rateDtoList))
.retrieve()
.bodyToFlux(RateDto.class);
}


private List<RateDto> convertFixedPreliminaryRateDtoToRateDto(List<FixedPreliminaryRateDto> fixedRatesDto) {
return fixedRatesDto.stream().map(fixedRate -> {
RateDto rateDto = new RateDto();
rateDto.setCurrency(fixedRate.getCurrency().getIsoCode());
rateDto.setFrequency(fixedRate.getFrequency());
rateDto.setPeriod(fixedRate.getPeriod().getDays());
rateDto.setInterestRate(fixedRate.getInterestRate());
return rateDto;
}).collect(Collectors.toList());
}


@Configuration
public class WebClientConfig {

@Bean
public WebClient.Builder webClientBuilder() {
return WebClient.builder();
}
}

private List<FixedPreliminaryRateDto> convertRateDtoToFixedPreliminaryRateDto(List<RateDto> rateDtoList) {
return rateDtoList.stream().map(rateDto -> {
FixedPreliminaryRateDto fixedRate = new FixedPreliminaryRateDto();

CurrencyDto currencyDto = new CurrencyDto();
currencyDto.setIsoCode(rateDto.getCurrency());
fixedRate.setCurrency(currencyDto);

fixedRate.setFrequency(rateDto.getFrequency());
fixedRate.setPeriod(Period.ofDays(rateDto.getPeriod()));
fixedRate.setInterestRate(rateDto.getInterestRate());

// Set any other required fields in the FixedPreliminaryRateDto object

return fixedRate;
}).collect(Collectors.toList());
}

private List<FixedPreliminaryRateDto> callCalculateRates(List<FixedPreliminaryRateDto> fixedRatesDto) {
List<RateDto> rateDtoList = convertFixedPreliminaryRateDtoToRateDto(fixedRatesDto);

List<RateDto> calculatedRateDtoList = webClient.post()
.uri("/calculate")
.contentType(MediaType.APPLICATION_JSON)
.body(BodyInserters.fromValue(rateDtoList))
.retrieve()
.bodyToFlux(RateDto.class)
.collectList() // Convert the Flux to a List
.block(); // Block the current thread to retrieve the list

// Convert the List<RateDto> to List<FixedPreliminaryRateDto>
List<FixedPreliminaryRateDto> calculatedFixedRates = convertRateDtoToFixedPreliminaryRateDto(calculatedRateDtoList);

return calculatedFixedRates;
}