分布式事务服务促销活动

from flask import Flask, jsonify
import requests

app = Flask(__name__)

@app.route('/transfer', methods=['POST'])
def transfer_money():
    try:
        # Step 1: Deduct money from sender
        response1 = requests.post('http://bank1/deduct', json={'amount': 100})
        if response1.status_code != 200:
            raise Exception("Failed to deduct money from sender")

        # Step 2: Add money to receiver
        response2 = requests.post('http://bank2/add', json={'amount': 100})
        if response2.status_code != 200:
            # Compensate: Add back the money to sender
            requests.post('http://bank1/add', json={'amount': 100})
            raise Exception("Failed to add money to receiver")

        return jsonify({"status": "success"})
    except Exception as e:
        return jsonify({"status": "failed", "message": str(e)})

if __name__ == '__main__':
    app.run(debug=True)