обработка событий агрегатов с несколькими сущностями не работает

avatar
Yong D
9 августа 2021 в 05:43
71
1
0

У меня есть такой общий корень это агрегаты кредитных карт, в которых есть записи о платежах и идентификаторах, переводах

@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 этого дочернего объекта работает, но обработчик событий не может получить событие

и я получил исключение, как показано ниже

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

Я делаю это со ссылкой на это.

Источник
Yvonne Ceelie
9 августа 2021 в 07:01
0

Вероятно, вам нужно изменить имя агрегатного идентификатора, чтобы оно совпадало с идентификатором агрегата и команды. Либо назовите его cardId в агрегате, либо назовите его id в RefundCmd.

Yong D
10 августа 2021 в 01:34
0

спасибо за ответ, но это не работает

Ответы (1)

avatar
Yong D
10 августа 2021 в 06:18
0

при публикации событий используйте org.axonframework.modelling.command.AggregateLifecycle.apply не org.axonframework.commandhandling.model.AggregateLifecycle.apply

Yvonne Ceelie
10 августа 2021 в 09:36
0

Была ли у вас зависимость от старой версии AxonFramework?