多实体聚合事件处理不工作

Question

我有一个这样的聚合根它的信用卡汇总有付款记录，ID，汇款

@NoArgsConstructor
@EqualsAndHashCode
@Log4j2
@Aggregate
public class CreditCard {
@AggregateIdentifier
private String id;
@AggregateMember
private List<CreditCardTransaction> transactions= new ArrayList<>();
private int limit; 
@CommandHandler
public CreditCard(CreditCardCreatedCmd cmd) {
log.info(cmd.getId()+","+cmd.getLimit());
AggregateLifecycle.apply(new CreditCardCreatedEvt(cmd.getId(), cmd.getLimit())); 
}
@EventSourcingHandler
public void on(CreditCardCreatedEvt evt) {
id = evt.getId();
limit = evt.getLimit();
log.info("[CreditCardCreatedEvt] id : "+id);
}
@CommandHandler
public void on(PaymentCmd cmd) throws LimitExceededException {
if (limit < cmd.getValue())
throw new LimitExceededException();

AggregateLifecycle.apply(new PaymentSuccessEvt(UUID.randomUUID().toString(), cmd.getValue())); 
}
@EventSourcingHandler
public void handle(PaymentSuccessEvt evt) {
log.info("[PaymentSuccessEvt] transactionId : "+evt.getTransactionId());
transactions.add(new CreditCardTransaction(evt.getTransactionId(), evt.getValue()));
}
}

---

和有付款记录的子实体

@Log4j2
@NoArgsConstructor
public class CreditCardTransaction {
@EntityId
private String transactionId;
private int transactionValue;
private boolean refund = false;
private LocalDateTime paymentDate;
public CreditCardTransaction(String transactionId, int transactionValue) {
this.transactionId = transactionId;
this.transactionValue = transactionValue;
this.paymentDate = LocalDateTime.now();
}
public String getTransactionId() {
return transactionId;
}
@CommandHandler
public void on(RefundCmd cmd) {
if (ChronoUnit.DAYS.between(paymentDate, cmd.getToday()) >= 30)
throw new DueTimeOverException();

log.info("[RefundCmd] "+cmd.getTransactionId());
AggregateLifecycle.apply(new RefundEvt(cmd.getCardId(), cmd.getTransactionId()));
}
@EventSourcingHandler
public void hanlde(RefundEvt evt) {
if (transactionId.equals(evt.getTransactionId())) {
transactionValue*=-1;
paymentDate=LocalDateTime.now(); 
refund = true;
log.info("[RefundEvt accepted] transactionId : "+transactionId);
}
log.info("[RefundEvt rejected] transactionId : "+transactionId);
}
}

---

@Data@NoArgsConstructor@AllArgsConstructor
public class RefundCmd {
@TargetAggregateIdentifier
String cardId;
String transactionId;
LocalDateTime today;
}
@Data@NoArgsConstructor
public class RefundEvt {
String cardId; 
String transactionId; 
LocalDateTime today;
public RefundEvt(String cardId, String transactionId) {
this.cardId = cardId;
this.transactionId = transactionId;
today=LocalDateTime.now();
}
}

当我向子实体发送命令时，像这样

commandGateway.send(new RefundCmd(cardId, transactionId,LocalDateTime.now()));

子实体的CommandHandler工作，但eventsourcinghandler不能获取事件

下面出现了异常

Command 'com.cqrs.order.demo.command.RefundCmd' resulted in org.axonframework.commandhandling.CommandExecutionException(Cannot request current Scope if none is 
active)

我做这件事是参考这个。

Answer 1

发布事件时使用org.axonframework.modelling.command.AggregateLifecycle.apply非org.axonframework.commandhandling.model.AggregateLifecycle.apply