// 訂單服務(wù)：創(chuàng)建訂單（正向操作）
public void createOrder(Order order) {
    // 持久化訂單到數(shù)據(jù)庫
}

// 訂單服務(wù)：補償操作（取消訂單）
public void cancelOrder(Order order) {
    // 標(biāo)記訂單狀態(tài)為已取消
}

// 庫存服務(wù)：扣減庫存（正向操作）
public void reduceStock(String productId, int num) {
    // 扣減商品庫存
}

// 庫存服務(wù)：補償操作（恢復(fù)庫存）
public void compensateStock(String productId, int num) {
    // 恢復(fù)庫存數(shù)量
}

// 積分服務(wù)TCC接口
publicinterface PointsService {
    @Transactional
    boolean tryDeductPoints(Long userId, int points);
    
    @Transactional
    boolean confirmDeductPoints(Long userId, int points);
    
    @Transactional
    boolean cancelDeductPoints(Long userId, int points);
}

// 實現(xiàn)類示例
@Service
publicclass PointsServiceImpl implements PointsService {
    // Try階段：預(yù)扣積分
    public boolean tryDeductPoints(Long userId, int points) {
        // 檢查積分是否充足
        // 預(yù)扣積分到臨時表
    }

    // Confirm階段：實際扣減
    public boolean confirmDeductPoints(Long userId, int points) {
        // 刪除臨時表記錄
        // 更新用戶積分
    }

    // Cancel階段：返還積分
    public boolean cancelDeductPoints(Long userId, int points) {
        // 從臨時表恢復(fù)積分
    }
}

// RabbitMQ補償示例
@RabbitListener(queues = "order.queue")
public void handleOrderMessage(OrderMessage message, Channel channel) {
    try {
        orderService.processOrder(message);
        channel.basicAck(deliveryTag, false);
    } catch (Exception e) {
        // 記錄重試次數(shù)
        if (retryCount >= MAX_RETRY) {
            channel.basicNack(deliveryTag, false, false);
            deadLetterService.sendToDlq(message);
        } else {
            channel.basicNack(deliveryTag, false, true);
        }
    }
}

// 訂單狀態(tài)機示例
publicclass OrderStateMachine {
    private OrderState currentState;

    public void transitionTo(OrderState newState) {
        // 校驗狀態(tài)流轉(zhuǎn)是否合法
        this.currentState = newState;
        orderRepository.save(this);
    }

    public void compensate() {
        if (currentState == OrderState.COMMITTED) {
            transitionTo(OrderState.COMPENSATING);
            // 執(zhí)行補償邏輯
            transitionTo(OrderState.ROLLBACKED);
        }
    }
}

// 補償任務(wù)管理后臺
@RestController
@RequestMapping("/compensation")
publicclass CompensationController {
    
    @GetMapping("/failed-orders")
    public List<Order> listFailedOrders() {
        return orderRepository.findByStatus(OrderStatus.FAILED);
    }

    @PostMapping("/manual-compensate")
    public void manualCompensate(@RequestParam Long orderId) {
        // 人工驗證后觸發(fā)補償
        orderService.triggerCompensation(orderId);
    }
}