分布式事务服务新年活动

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

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

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

# 使用示例
def reserve_inventory():
    print("库存预留成功")

def cancel_inventory_reservation():
    print("库存预留取消")

def process_payment():
    print("支付处理成功")

def refund_payment():
    print("支付退款")

orchestrator = SagaOrchestrator()
orchestrator.add_step(reserve_inventory, cancel_inventory_reservation)
orchestrator.add_step(process_payment, refund_payment)

orchestrator.execute()