Дублирование, перенос платежей на второй биллинг

import requests
import xml.etree.ElementTree as ET
BILLING_URL = "https://billing.example.com/paysys_check.cgi"
def send_request(params):
    response = requests.get(BILLING_URL, params=params)
    response.encoding = 'utf-8'
    print(f"Request: {response.url}")
    print(f"Response: {response.text}")
    
    # Парсинг XML
    root = ET.fromstring(response.text)
    result_code = root.find('result').text
    return int(result_code), root
# 1. Проверка пользователя
params_check = {
    'command': 'check',
    'account': 'user123',
    'sum': '100.00',
    'txn_id': 'TXN_001'
}
code, xml = send_request(params_check)
if code == 0:
    print("Пользователь найден:", xml.find('fio').text)
    
    # 2. Проведение платежа
    params_pay = {
        'command': 'pay',
        'account': 'user123',
        'sum': '100.00',
        'txn_id': 'TXN_001',
        'txn_date': '20231025120000'
    }
    code, xml = send_request(params_pay)
    
    if code == 0:
        print("Платеж успешен. ID в биллинге:", xml.find('prv_txn').text)
    else:
        print("Ошибка платежа:", code)
else:
    print("Ошибка проверки пользователя:", code)

<?php

$billing_url = "https://billing.example.com/paysys_check.cgi";

function send_request($url, $params) {
    $query = http_build_query($params);
    $full_url = $url . '?' . $query;
    
    // Инициализация cURL
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $full_url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // Для тестов, в продакшене лучше включить
    
    $response = curl_exec($ch);
    
    if (curl_errno($ch)) {
        echo 'Error:' . curl_error($ch);
        return [300, null];
    }
    
    curl_close($ch);
    
    echo "Request: $full_url\n";
    echo "Response: $response\n";
    
    // Парсинг XML
    try {
        $xml = new SimpleXMLElement($response);
        return [(int)$xml->result, $xml];
    } catch (Exception $e) {
        echo "Error parsing XML\n";
        return [300, null];
    }
}

// 1. Проверка пользователя
$params_check = [
    'command' => 'check',
    'account' => 'user123',
    'sum'     => '100.00',
    'txn_id'  => 'TXN_001'
];

list($code, $xml) = send_request($billing_url, $params_check);

if ($code === 0) {
    echo "Пользователь найден: " . (string)$xml->fio . "\n";
    
    // 2. Проведение платежа
    $params_pay = [
        'command'  => 'pay',
        'account'  => 'user123',
        'sum'      => '100.00',
        'txn_id'   => 'TXN_001',
        'txn_date' => date('YmdHis')
    ];
    
    list($code_pay, $xml_pay) = send_request($billing_url, $params_pay);
    
    if ($code_pay === 0) {
        echo "Платеж успешен. ID в биллинге: " . (string)$xml_pay->prv_txn . "\n";
    } else {
        echo "Ошибка платежа: $code_pay\n";
    }
} else {
    echo "Ошибка проверки пользователя: $code\n";
}
?>

<?php
header('Content-Type: text/xml; charset=utf-8');
// Получаем параметры
$command = $_GET['command'] ?? '';
$account = $_GET['account'] ?? '';
$txn_id  = $_GET['txn_id'] ?? '';
$sum     = $_GET['sum'] ?? 0;
// Генерация ответа
function response($code, $data = []) {
    echo '<?xml version="1.0" encoding="UTF-8"?>';
    echo '<response>';
    echo "<result>{$code}</result>";
    foreach ($data as $key => $val) {
        echo "<{$key}>" . htmlspecialchars($val) . "</{$key}>";
    }
    echo '</response>';
    exit;
}
// Логика обработки
try {
    switch ($command) {
        case 'check':
            // TODO: Проверка пользователя в вашей БД
            if ($account === 'test_user') {
                response(0, [
                    'fio' => 'Test User',
                    'balance' => '50.00',
                    'comment' => 'Found'
                ]);
            } else {
                response(5, ['comment' => 'User not found']);
            }
            break;
        case 'pay':
            // TODO: Зачисление средств в вашей системе
            // Проверка на дубликат по $txn_id!
            
            $my_payment_id = time(); // Генерируем внутренний ID
            
            response(0, [
                'prv_txn' => $my_payment_id,
                'sum' => $sum,
                'comment' => 'Payment accepted'
            ]);
            break;
            
        case 'status':
            // TODO: Проверка статуса платежа по $txn_id
            response(0, ['comment' => 'Payment exists']);
            break;
            
        case 'cancel':
            response(0, ['comment' => 'Cancelled']);
            break;
        default:
            response(300, ['comment' => 'Unknown command']);
    }
} catch (Exception $e) {
    response(1, ['comment' => 'Internal error']);
}
?>

from flask import Flask, request, Response
app = Flask(__name__)
def make_xml(result_code, extra_fields=None):
    xml = '<?xml version="1.0" encoding="UTF-8"?>\n<response>\n'
    xml += f'    <result>{result_code}</result>\n'
    if extra_fields:
        for key, value in extra_fields.items():
            xml += f'    <{key}>{value}</{key}>\n'
    xml += '</response>'
    return Response(xml, mimetype='text/xml')
@app.route('/api/callback', methods=['GET'])
def handle_request():
    command = request.args.get('command')
    account = request.args.get('account')
    txn_id = request.args.get('txn_id')
    
    if command == 'check':
        # Эмуляция проверки пользователя
        if account == 'test_user':
            return make_xml(0, {
                'fio': 'Test User',
                'balance': '100.00',
                'comment': 'OK'
            })
        else:
            return make_xml(5, {'comment': 'User not found'})
    elif command == 'pay':
        # Эмуляция платежа
        # Здесь должна быть запись в БД
        return make_xml(0, {
            'prv_txn': '999999', # ID платежа в вашей системе
            'sum': request.args.get('sum'),
            'comment': 'Success'
        })
        
    elif command == 'status':
        return make_xml(0, {'comment': 'OK'})
        
    return make_xml(300, {'comment': 'Unknown command'})
if __name__ == '__main__':
    app.run(port=8080)

const express = require('express');
const app = express();
app.get('/api/callback', (req, res) => {
    const { command, account, sum, txn_id } = req.query;
    
    res.set('Content-Type', 'text/xml');
    
    let responseBody = '';
    
    if (command === 'check') {
        if (account === 'test_user') {
            responseBody = `
                <result>0</result>
                <fio>Test User</fio>
                <balance>100.00</balance>
                <comment>OK</comment>
            `;
        } else {
            responseBody = `<result>5</result><comment>Not found</comment>`;
        }
    } else if (command === 'pay') {
        responseBody = `
            <result>0</result>
            <prv_txn>${Date.now()}</prv_txn>
            <sum>${sum}</sum>
            <comment>Success</comment>
        `;
    } else {
        responseBody = `<result>300</result><comment>Unknown command</comment>`;
    }
    
    res.send(`<?xml version="1.0" encoding="UTF-8"?><response>${responseBody}</response>`);
});
app.listen(3000, () => console.log('Server running on port 3000'));