为什么completablefuture从不返回我需要的响应，而api调用挂起？

我有一个方法，用post-to-some-url调用两个api，从第一个响应得到accountbalanceresponse对象的几乎所有值，然后我需要用第一个api的响应调用第二个api，这两个调用都返回mono对象，然后，当我使用“mapfuture.get（）”来填充响应对象的最后一个值，但是api调用什么都不做。。。在日志中我看到“o.s.w.r.f.client.exchangefunctions:[20852e1]httpposthttps://apiurlicall“但是程序就这样一直没有结果。有什么线索吗？谢谢你。

private Mono<AccountBalanceResponse> getDebts(UserInfo userInfo, String msisdn, String 
       codService, String documentType,
        String documentNumber) {
    AccountBalanceResponse accountBalance = new AccountBalanceResponse();
    HashMap<String, Object> listPositiveAmount = new LinkedHashMap<>();
    LOGGER.info("UserInfo: {}", userInfo);
    LOGGER.info("msisdn: {}", msisdn);
    LOGGER.info("codService: {}", codService);
    LOGGER.info("documentType: {}", documentType);
    LOGGER.info("documentNumber: {}", documentNumber);

        String accountCode = userInfo.getAccountCode();
        if (StringUtils.equals(accountCode, null)) {
            accountBalance.setErrorCode(userInfo.getErrorCode());
            accountBalance.setErrorDescription(userInfo.getErrorDescription());
            accountBalance.setStatusResponse(500);
            return Mono.just(accountBalance);
    }
        LOGGER.info("Account code: {}", accountCode);

        Mono<JsonNode> objectNode = accountBalanceRestClient.getAccountBalance(accountCode, documentNumber);
        return objectNode.map(jsonNodeResponse->{
            AccountBalanceResponse accountBalanceFuture = new AccountBalanceResponse();
            LOGGER.info("<Response Account Balance>: {}", objectNode);
            Double amountRA;
            String unitsRA;

            Integer amountPA = 0;
            String unitsPA = null;

            Mono<String> webViewPagos = null;

            JsonNode remainedAmount = jsonNodeResponse.get(0).get("remainedAmount");
            JsonNode positiveAmount = jsonNodeResponse.get(0).get("positiveAmount");

            String issueDate = StringUtils
                    .substring(jsonNodeResponse.get(0).get("validFor").get("startDateTime").asText(), 0,
                            10);
            String issueDateParsed = StringUtils.replaceEach(issueDate, new String[] { "-", "-" },
                    new String[] { "", "" });
            LOGGER.info("Issue Date: {}", issueDate);
            LOGGER.info("Issue Date Parsed: {}", issueDateParsed);
            String dueDate = calculateBillDatesUtil.calculateDueDate(issueDateParsed, "C");
            Integer statusNew = Utils.compareDateWithToday(dueDate, DATE_FORMAT);
            String statusDebt = DeudaUtil.getEstadoDeuda(statusNew.intValue());
            String codeStatusDebt = DeudaUtil.getCodigoEstadoDeuda(statusNew.intValue());

            amountRA = remainedAmount.get(AMOUNT).asDouble();
            unitsRA = remainedAmount.get(UNITS).asText();
            int receiptsTotal = 1;
            int receiptsToPay = 0;
            if (amountRA <= Double.valueOf(0.0)) {
                statusDebt = "Sin deuda";
                codeStatusDebt = "S";
            } else {
                webViewPagos = webViewPagosService.getWebViewPagosProd(msisdn, codService, documentType,
                        documentNumber);
                receiptsToPay++;
            }
            if (positiveAmount != null && positiveAmount.has(AMOUNT)) {
                amountPA = positiveAmount.get(AMOUNT).asInt();
                unitsPA = positiveAmount.get(UNITS).asText();
            }

            ObjectMapper mapper = new ObjectMapper();

            listPositiveAmount.put(AMOUNT, amountPA);
            listPositiveAmount.put(UNITS, unitsPA == null ? unitsRA : unitsPA);
            accountBalanceFuture.setSumTaxTotal(String.format("%.2f", amountRA));
            accountBalanceFuture.setInvoiceCurrency(unitsRA);
            accountBalanceFuture.setPositiveAmount(listPositiveAmount);
            accountBalanceFuture.setInvoiceDate(dueDate == null ? "null" : dueDate);
            accountBalanceFuture.setCodeStatusDebt(codeStatusDebt);
            accountBalanceFuture.setStatusDebt(statusDebt);
            accountBalanceFuture.setStatusResponse(200);
            accountBalanceFuture.setInvoiceList(mapper.createArrayNode());
            accountBalanceFuture.setReceiptsTotal(receiptsTotal);
            accountBalanceFuture.setReceiptsToPay(receiptsToPay);
            accountBalanceFuture.setCodPayment(msisdn);
            CompletableFuture<AccountBalanceResponse> mapFuture = webViewPagos.toFuture()
                .thenApplyAsync(urlResponse -> {
                    AccountBalanceResponse accountBFuture = new AccountBalanceResponse();
                    accountBFuture.setWebViewPagosURL(urlResponse);
                    return accountBFuture;
                });
            try {
            accountBalanceFuture.setWebViewPagosURL(mapFuture.get().getWebViewPagosURL());
        } catch (InterruptedException | ExecutionException e) {
            LOGGER.error(e.toString());
            Thread.currentThread().interrupt();
        }

        return accountBalanceFuture;
        });
      }

我必须重构所有我这样做的方法才能正常工作：

public Mono<MTDebtsResponse> data(List<OpenDebtsCall> products) {

    MTDebtsResponse mtDebtsResponse = new MTDebtsResponse();
    AccountBalanceResponse responseDebtMovil = new AccountBalanceResponse();
    OpenDebtsCustomizedResponse responseDebtHogar = new OpenDebtsCustomizedResponse();
    List<String> listInvoiceTotal = new ArrayList<>();
    List<Integer> listStatusR = new ArrayList<>();

    GeneralSettingsBean beanGS = generalSettingsRepository.findByGsKey(IS_SUM_TAX_PRODUCTS_MT);
    String flagMT = beanGS.getGsValue();
    mtDebtsResponse.setDebtConsolidatorMode(flagMT);

    MTdebt mtDebt = new MTdebt();
    mtDebt.mtDebtsResponseg = new MTDebtsResponse();
    mtDebt.responseDebtHogarg = new OpenDebtsCustomizedResponse();
    mtDebt.responseDebtMovilg = new AccountBalanceResponse();
    mtDebt.listInvoiceTotalg =  new ArrayList<>();
    mtDebt.listStatusRg = new ArrayList<>();

    DebtData debData = new DebtData();
    debData.amountRADebtMovil = 0.0;
    debData.sumTaxTotal = 0.0;
    debData.receiptsToPay = 0;
    debData.receiptsTotal = 0;
    debData.traceIdDebt = null;
    debData.invoiceListNew = this.mapper.createArrayNode();

    Map<String, OpenDebtsOnlyResponse> mapOpenDebtsRest = new HashMap<>();
    Map<String, String> codMap = new HashMap<>();
    /*
     * switch true 1: consulta deuda MT: hogar + movil switch false 0: consulta solo
     * hogar
     */
    QATokenCloudBean qaTokenCloudBean = qaTokenCloudRepository.findTopByCodeToken(CLOUD);
    String accessToken = qaTokenCloudBean.getAccessToken();

    StringBuilder bearer = new StringBuilder();
    bearer.append("Bearer ");
    bearer.append(accessToken);

    return Flux.fromIterable(products).flatMap(product -> {
        String codPayment = product.getCodPayment();
        String codService = product.getCodService();
        String originalCodPayment = product.getCodPayment();

        if (StringUtils.equals(flagMT, FLAG_PRODUCTS_MT_VALUE_FALSE) && !StringUtils.equals(codService, "T")) {
            return Flux.empty();
        } else if (StringUtils.equals(codService, "T") && StringUtils.startsWith(codPayment, "1")) {
            codPayment = StringUtils.substring(codPayment, 1);
        }
        codMap.put(Constants.CODSERVICE, codService);
        codMap.put(Constants.CODPAYMENT, codPayment);
        codMap.put(Constants.ORIGINALCODPAYMENT, originalCodPayment);
        return openDebtsRestClient.getOpenDebts(codPayment, codService, bearer,
                product.getDocumentNumber()).flatMapMany(openDebtsResponse->{
                    addMapBrainyBill(openDebtsResponse, originalCodPayment, codService, mapOpenDebtsRest);

                    ObjectNode data = openDebtsResponse.getOpenDebts();
                    debData.traceIdDebt = String.valueOf(openDebtsResponse.getTraceId());
                    Integer statusR = data.get(STATUS).asInt();
                    listStatusR.add(statusR);
                    mtDebt.listStatusRg = listStatusR;
                    JsonNode response = data.get(RESPONSE);

                    if (StringUtils.equals(codService, "T")) {
                        responseDebtHogar.setStatusResponse(statusR);
                        mtDebt.responseDebtHogarg = responseDebtHogar;
                    } else if (StringUtils.equals(codService, "C")) {
                        responseDebtMovil.setStatusResponse(statusR);
                        mtDebt.responseDebtMovilg = responseDebtMovil;
                    }

                    if (statusR != 200) {
                        statusR = statusR == 432 ? 200 : statusR;
                        if (StringUtils.equals(codService, "T")) {
                            responseDebtHogar.setStatusResponse(statusR);
                            responseDebtHogar.setErrorDescription(response.toString());
                            mtDebt.responseDebtHogarg = responseDebtHogar;
                        } else if (StringUtils.equals(codService, "C")) {
                            responseDebtMovil.setStatusResponse(statusR);
                            responseDebtMovil.setErrorDescription(response.toString());
                            mtDebt.responseDebtMovilg = responseDebtMovil;
                        }

                        LOGGER.info("codPayment: {}", codMap.get(Constants.CODPAYMENT));
                        LOGGER.info("codService: {}", codMap.get(Constants.CODSERVICE));
                        LOGGER.info("originalCodPayment: {}", codMap.get(Constants.ORIGINALCODPAYMENT));

                        return Flux.just(mtDebt);
                    }
                    LOGGER.info("Response OpenDebts: {}", response);

                    String cityCode = response.get(CITYCODE).asText();
                    ArrayNode invoiceListArray = (ArrayNode) response.get("invoiceList");

                    if (invoiceListArray == null || invoiceListArray.isEmpty())
                        return Flux.just(mtDebt);

                    debData.receiptsTotal += invoiceListArray.size();
                    List<JsonNode> listTaxTotal = invoiceListArray.findValues(TAX_TOTAL);
                    List<JsonNode> listInvoiceDate = invoiceListArray.findValues(INVOICE_DATE);
                    List<JsonNode> listInvoiceCurrency = invoiceListArray.findValues(INVOICE_CURRENCY);
                    List<JsonNode> listInvoiceNumber = invoiceListArray.findValues(INVOICE_NUMBER);
                    LOGGER.info("listTaxTotal: {}", listTaxTotal);
                    // suma de todos los recibos
                    debData.sumTaxTotal = listTaxTotal.stream().map(l -> (l.asDouble()) / 100).reduce(debData.sumTaxTotal,
                            Double::sum);

                    Map<String, CalculateBillDatesBean> dueDatesBeans = calculateBillDatesUtil.retrieveDueDatesMap(
                            listInvoiceDate.stream().distinct().map(JsonNode::asText).collect(Collectors.toList()), codService);

                    listInvoiceDate.stream().distinct().map(JsonNode::asText).map(string -> {
                        if (StringUtils.equals(codService, "T")) {
                            string = calculateBillDatesUtil.calculateDueDate(string, codService, dueDatesBeans);
                        }
                        return string;
                    }).forEachOrdered(listInvoiceTotal::add);

                    mtDebtsResponse.setInvoiceCurrency(listInvoiceCurrency.get(0).asText());
                    mtDebtsResponse.setInvoiceNumber(listInvoiceNumber.get(0).asText());
                    String originalInvoiceDate = listInvoiceDate.get(0).asText();
                    mtDebtsResponse.setOriginalInvoiceDate(originalInvoiceDate == null ? "" : originalInvoiceDate);
                    mtDebtsResponse.setCodService(codService);

                    LOGGER.info("Sum Tax Total: {}", debData.sumTaxTotal);
                    LOGGER.info("Iniciando recorrido de invoiceList");

                    // for que inserta todos los recibos sean moviles o fijo
                     debData.invoiceListNew = elementsToArray(invoiceListArray, codMap.get(Constants.CODPAYMENT), codService, debData.traceIdDebt,
                            originalCodPayment, dueDatesBeans, cityCode);

                    debData.receiptsToPay = calculateReceiptsToPay(invoiceListArray, debData.receiptsToPay);

                    mtDebtsResponse.setReceiptsToPay(debData.receiptsToPay);

                    mtDebt.listInvoiceTotalg = listInvoiceTotal;
                    mtDebt.mtDebtsResponseg = mtDebtsResponse;
                    if (!StringUtils.equals(flagMT, FLAG_PRODUCTS_MT_VALUE_TRUE))
                        return Flux.just(mtDebt);

                    debData.amountRADebtMovil = listTaxTotal.stream().filter(taxTotal -> (StringUtils.equals(codService, "C")))
                            .map(taxTotal -> taxTotal.asDouble() / 100)
                            .reduce(debData.amountRADebtMovil, (accumulator, item) -> accumulator + item);

                    LOGGER.info("codPayment: {}", codMap.get(Constants.CODPAYMENT));
                    LOGGER.info("codService: {}", codMap.get(Constants.CODSERVICE));
                    LOGGER.info("originalCodPayment: {}", codMap.get(Constants.ORIGINALCODPAYMENT));
                    return Flux.just(mtDebt);
                });
    }).last().map(mtDebtResponse -> {

        String codeStatusDebt = "S";
        String statusDebt = "No tiene deudas pendientes";
        String date = null;
        LOGGER.info("Size elements Date: {}", mtDebtResponse.listInvoiceTotalg.size());
        if (!mtDebtResponse.listInvoiceTotalg.isEmpty()) {
            date = mtDebtResponse.listInvoiceTotalg.get(0);
            Integer status = Utils.compareDateWithToday(date, DATE_FORMAT);
            statusDebt = DeudaUtil.getEstadoDeuda(status.intValue());
            codeStatusDebt = DeudaUtil.getCodigoEstadoDeuda(status.intValue());
        }

        mtDebtsResponse.setTraceId(debData.traceIdDebt);
        mtDebtsResponse.setInvoiceDate(date == null ? "" : date);
        mtDebtsResponse.setSumTaxTotal(String.format("%.2f", debData.sumTaxTotal));
        mtDebtsResponse.setCodeStatusDebt(codeStatusDebt);
        mtDebtsResponse.setStatusDebt(statusDebt);
        mtDebtsResponse.setReceiptsTotal(debData.receiptsTotal);
        mtDebtsResponse.setInvoiceList(debData.invoiceListNew);
        mtDebtsResponse.setDebtMovil(String.format("%.2f", debData.amountRADebtMovil));
        mtDebtsResponse.setResponseDebtHogar(mtDebtResponse.responseDebtHogarg);
        mtDebtsResponse.setResponseDebtMovil(mtDebtResponse.responseDebtMovilg);
        // Valores obtenidos del ultimo producto en el flux
        mtDebtsResponse.setReceiptsToPay(mtDebtResponse.mtDebtsResponseg.getReceiptsToPay());
        mtDebtsResponse.setInvoiceCurrency(mtDebtResponse.mtDebtsResponseg.getInvoiceCurrency());
        mtDebtsResponse.setInvoiceNumber(mtDebtResponse.mtDebtsResponseg.getInvoiceNumber());
        mtDebtsResponse.setOriginalInvoiceDate(mtDebtResponse.mtDebtsResponseg.getOriginalInvoiceDate());
        mtDebtsResponse.setCodService(mtDebtResponse.mtDebtsResponseg.getCodService());

        // Validar que al menos 1 producto haya respondido bien el api de deudas
        setStatusResponse(mtDebtsResponse, mtDebtResponse.listStatusRg);

        return mtDebtsResponse;
    });
}

为什么completablefuture从不返回我需要的响应，而api调用挂起？

1条答案

相关问题

热门标签

最新问答