分布式事务服务优惠活动

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

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

    def execute(self):
        executed_steps = []
        try:
            for step in self.steps:
                step()
                executed_steps.append(step)
        except Exception as e:
            for compensation in reversed(executed_steps):
                compensation()
            raise e

# 使用示例
def reserve_inventory():
    print("Inventory reserved")

def release_inventory():
    print("Inventory released")

def charge_customer():
    print("Customer charged")

def refund_customer():
    print("Customer refunded")

orchestrator = SagaOrchestrator()
orchestrator.add_step(reserve_inventory, release_inventory)
orchestrator.add_step(charge_customer, refund_customer)

try:
    orchestrator.execute()
except Exception as e:
    print(f"Transaction failed: {e}")