Spring webflow不运行无功调用

Question

我有以下方法。

@Transactional
        public Mono<Long> processPollResult(final PollReport pollReport, final String xmlResult,
                final String ref, final String clientId, int orgId) {
            return pollOrderRepository.save(toNewOrphanPollOrder(clientId, orgId)).flatMap(pollOder -> {
                List<Mono<?>> monoPubs = new ArrayList<>();
                monoPubs.add(pollOrderOrphanRepository.save(toPollOrderOrphan(pollOder.getPollOrderId())));
                labReport.getLabResults().getLabResultList().forEach(labResult -> {
                    monoPubs.add((Mono<?>) saveOrphanPollOrderResult(ref, clientId, pollOder, pollResult).subscribe());
                });
    
                List<Polls> polls = buildAcknowledgePoll(ref, clientId);
                return Mono.when(monoPubs).then(deviceService.acknowledgePolls(polls, clientId)).thenReturn(pollOder.getPollOrderId());
            });
        }
    
        private Mono<Long> saveOrphanPollOrderResult(final String ref, final String clientId, PollOrder pollOder,
                PollResult pollResult) {
            return pollOrderTestRepository.save(toPollOrderTest(pollOrder, pollResult.getPollResultHeader()))
                    .flatMap(pollOrderTestRes -> {
                        if (pollResult.getPollResultItems() != null
                                && pollResult.getPollResultItems().getPollResultItemsList() != null) {
                            List<PollOrderTestItem> testResultItemsList = labResult.getPollResultItems()
                                    .getPollResultItemsList().stream().map(pollOrderItem -> toPollOrderItem(pollOrderItem,
                                            pollOrder.getPollOrderId(), pollResult.getPollResultHeader().getTestCode()))
                                    .collect(Collectors.toList());
                            return pollOrderTestItemRepository.saveAll(testResultItemsList).collectList()
                                    .flatMap(pollOrderItemResp -> {
                                        return Mono.just(pollOrder.getPollOrderId());
                                    });
                        } else {
                            return Mono.just(pollOrder.getPollOrderId());
                        }
                    });
        }

在这里

1、单一UBS。添加（（单声道

这里，获取类型转换错误。

如果我不放。subscribe（），未调用saveOrphanPollOrderResult中的语句。

在saveOrphanPollOrderResult中添加subscribe（），如下所示，会导致编译时错误，因为它无法返回任何值，也无法将其添加到monos列表中。

private Mono<Long> saveOrphanPollOrderResult(final String ref, final String clientId, PollOrder pollOder,
                    PollResult pollResult) {
                return pollOrderTestRepository.save(toPollOrderTest(pollOrder, pollResult.getPollResultHeader()))
                        .flatMap(pollOrderTestRes -> {
                            if (pollResult.getPollResultItems() != null
                                    && pollResult.getPollResultItems().getPollResultItemsList() != null) {
                                List<PollOrderTestItem> testResultItemsList = labResult.getPollResultItems()
                                        .getPollResultItemsList().stream().map(pollOrderItem -> toPollOrderItem(pollOrderItem,
                                                pollOrder.getPollOrderId(), pollResult.getPollResultHeader().getTestCode()))
                                        .collect(Collectors.toList());
                                return pollOrderTestItemRepository.saveAll(testResultItemsList).collectList()
                                        .flatMap(pollOrderItemResp -> {
                                            return Mono.just(pollOrder.getPollOrderId());
                                        });
                            } else {
                                return Mono.just(pollOrder.getPollOrderId());
                            }
                        }).subscribe();   /// --> 
            }

Answer 1

您的问题在于：

var id = pollOder.getPollOrderId();
var pollOrderOrphan = toPollOrderOrphan(id);

List<Mono<?>> monoPubs = new ArrayList<>();
monoPubs.add(pollOrderOrphanRepository.save(pollOrderOrphan));

labReport.getLabResults().getLabResultList().forEach(labResult -> {
    monoPubs.add((Mono<?>) saveOrphanPollOrderResult(ref, clientId, pollOder, pollResult).subscribe());
});

有几个问题，首先是使用Mono

其次，您不能使用forEach循环。这是命令式编程，而不是被动编程，它假设您有要放在列表中的项目。但你没有。

这就是为什么您必须调用subscribe的原因，因为您需要“等待具体项目”，以便将它们放在列表中。

您需要做的是开始使用Flux，这是一个假定项目流。

我不知道您在这里的确切逻辑，因为您的代码非常混乱，但作为一个例子：

var labresultList = labReport.getLabResults().getLabResultList();
Mono<List<PollOrderResult> = Flux.fromIterable(labResultList)
    .flatMap(saveOrphanPollOrderResult(ref, clientId, pollOder, pollResult))
    .collectList();

还有一些OT：

我不知道您的商品类型，但请尽量避免使用

为了易读性，请多使用一些函数，因为代码很难阅读，函数可以自由使用。分配变量而不是嵌套调用也提高了易读性。