分布式事务优惠活动

class SagaOrchestrator:
    def __init__(self):
        self.steps = []

    def add_step(self, action, compensation):
        self.steps.append((action, compensation))

    def execute(self):
        compensations = []
        try:
            for action, _ in self.steps:
                action()
                compensations.append(_)
        except Exception as e:
            for compensation in reversed(compensations):
                compensation()
            raise e

# 示例使用
def create_order():
    print("Creating order...")
    # 实际业务逻辑

def cancel_order():
    print("Canceling order...")
    # 实际业务逻辑

def reserve_inventory():
    print("Reserving inventory...")
    # 实际业务逻辑

def release_inventory():
    print("Releasing inventory...")
    # 实际业务逻辑

orchestrator = SagaOrchestrator()
orchestrator.add_step(create_order, cancel_order)
orchestrator.add_step(reserve_inventory, release_inventory)

orchestrator.execute()