@Service
public class OrderService {
    @GlobalTransactional(timeoutMills = 300000, name = "create-order")
    public void createOrder(Order order, Payment payment, Inventory inventory) {
        // 更新庫存
        inventoryService.reduceStock(inventory);


        // 創(chuàng)建支付記錄
        paymentService.pay(payment);


        // 創(chuàng)建訂單
        orderRepository.save(order);
    }
}

//定義接口實(shí)現(xiàn)注解
@LocalTCC
public interface PaymentService {
    // "try" 方法，準(zhǔn)備資源，比如凍結(jié)用戶資金
    @TwoPhaseBusinessAction(name = "preparePay", commitMethod = "commitPay", rollbackMethod = "cancelPay")
    boolean preparePay(BusinessActionContext context, String accountId, double amount);
    // "confirm" 方法，確認(rèn)并實(shí)際扣除凍結(jié)的資金
    boolean commitPay(BusinessActionContext context);
    // "cancel" 方法，取消操作，解凍之前凍結(jié)的資金
    boolean cancelPay(BusinessActionContext context);
}


//然后，為接口提供一個(gè)實(shí)現(xiàn)類，并實(shí)現(xiàn)try、confirm和cancel方法：
@Service
public class PaymentServiceImpl implements PaymentService {
    @Autowired
    private AccountRepository accountRepository;


    @Override
    public boolean preparePay(BusinessActionContext context, String accountId, double amount) {
        // 實(shí)現(xiàn)資金的凍結(jié)邏輯
        // ...
        return true;
    }
    @Override
    public boolean commitPay(BusinessActionContext context) {
        // 實(shí)現(xiàn)實(shí)際扣除資金的邏輯
        // ...
        return true;
    }
    @Override
    public boolean cancelPay(BusinessActionContext context) {
        // 實(shí)現(xiàn)取消扣款，即解凍資金的邏輯
        // ...
        return true;
    }
}


//最后，在需要執(zhí)行TCC事務(wù)的業(yè)務(wù)邏輯中注入PaymentService并調(diào)用上述方法：
@Service
public class OrderService {
    @Autowired
    private PaymentService paymentService;
    @GlobalTransactional
    public void createOrder(Order order, String accountId, double amount) {
        // TCC try 階段
        boolean result = paymentService.preparePay(null, accountId, amount);
        if (!result) {
            throw new RuntimeException("Payment preparation failed.");
        }


        // TCC confirm 或 cancel 階段將由Seata框架根據(jù)全局事務(wù)的最終狀態(tài)自動(dòng)調(diào)用
        // ...
    }
}

// 偽代碼，僅為示例說明
StateMachineBuilder stateMachineBuilder = StateMachineBuilderFactory.create();
StateMachine stateMachine = stateMachineBuilder
    .state("Start")
    .initial("CreateOrder")
        .to("ReserveInventory").on("InventoryReserved")
        .to("CancelOrder").on("InventoryReserveFailed")
    .step("ReserveInventory")
        .to("ProcessPayment").on("PaymentProcessed")
        .to("RevertInventory").on("PaymentProcessFailed")
    .step("ProcessPayment")
        .to("End").on("Success")
    .step("CancelOrder")
    .compensateWith("CancelOrderOperation")
    .step("RevertInventory")
    .compensateWith("RevertInventoryOperation")
    .build();
stateMachine.start();

@Service
public class OrderService {
    @Autowired
    private OrderRepository orderRepository;
    @GlobalTransactional
    public void createOrder(Order order) {
        // 此處的數(shù)據(jù)庫操作會(huì)自動(dòng)被Seata管理
        orderRepository.save(order);
        // ...其他可能涉及數(shù)據(jù)庫操作的代碼
    }
}