<dependency>
    <groupId>io.seata</groupId>
    <artifactId>seata-spring-boot-starter</artifactId>
    <version>1.5.2</version>
</dependency>

seata:
  tx-service-group: my_test_tx_group # 定義事務(wù)服務(wù)組
  service:
    vgroup-mapping:
      my_test_tx_group: default # 配置事務(wù)組映射
  store:
    mode: db # 使用數(shù)據(jù)庫存儲(chǔ)事務(wù)日志
    db:
      datasource:
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://localhost:3306/seata
        username: root
        password: root

<dependency>
    <groupId>io.seata</groupId>
    <artifactId>seata-spring-cloud-starter</artifactId>
    <version>1.5.2</version>
</dependency>

seata:
  tx-service-group: my_test_tx_group
  service:
    vgroup-mapping:
      my_test_tx_group: default
  store:
    mode: db
    db:
      datasource:
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://localhost:3306/seata
        username: root
        password: root

CREATE TABLE `undo_log` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `branch_id` bigint(20) NOT NULL,
  `xid` varchar(128) NOT NULL,
  `context` varchar(128) NOT NULL,
  `rollback_info` blob,
  `log_status` int(11) NOT NULL,
  `log_created` datetime NOT NULL,
  `log_updated` datetime NOT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `UK_XID_BRANCH_ID` (`xid`, `branch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

public interface OrderService {
    void createOrder(Order order);
    void cancelOrder(Long orderId);
    void confirmOrder(Long orderId);
}

@Service
public class OrderServiceImpl implements OrderService {

    @Resource
    private OrderRepository orderRepository;
    @Resource
    private ProductService productService;
    
    @Override
    @Transactional
    public void createOrder(Order order) {
        // 1. 執(zhí)行 Try 操作，預(yù)留庫存
        productService.reserveStock(order.getProductId(), order.getQuantity());
        orderRepository.save(order);
    }

    @Override
    @Transactional
    public void cancelOrder(Long orderId) {
        // 2. 執(zhí)行 Cancel 操作，回滾庫存
        Order order = orderRepository.findById(orderId).orElseThrow(() -> new RuntimeException("Order not found"));
        productService.releaseStock(order.getProductId(), order.getQuantity());
        orderRepository.delete(order);
    }

    @Override
    @Transactional
    public void confirmOrder(Long orderId) {
        // 3. 執(zhí)行 Confirm 操作，完成訂單
        Order order = orderRepository.findById(orderId).orElseThrow(() -> new RuntimeException("Order not found"));
        order.setStatus(OrderStatus.COMPLETED);
        orderRepository.save(order);
    }
}

@RestController
@RequestMapping("/order")
public class OrderController {

    @Resource
    private OrderService orderService;
    
    @PostMapping("/create")
    public ResponseEntity<String> createOrder(@RequestBody Order order) {
        orderService.createOrder(order);
        return ResponseEntity.ok("Order created successfully");
    }

    @PostMapping("/cancel/{orderId}")
    public ResponseEntity<String> cancelOrder(@PathVariable Long orderId) {
        orderService.cancelOrder(orderId);
        return ResponseEntity.ok("Order canceled successfully");
    }

    @PostMapping("/confirm/{orderId}")
    public ResponseEntity<String> confirmOrder(@PathVariable Long orderId) {
        orderService.confirmOrder(orderId);
        return ResponseEntity.ok("Order confirmed successfully");
    }
}

seata:
  tcc:
    enable: true