{
    "ResponseCode": 0,
    "ResponseDescription": "Success. Request accepted for processing",
    "MerchantRequestID": "dab3-4cb9-9110-99918efd35e39105683",
    "CheckoutRequestID": "ws_CO_28092024222014167769290734",
    "TransactionID": "SOFTPID2809202422201241148",
    "TransactionAmount": 100,
    "TransactionReceipt": "SIS88JC7AM",
    "TransactionDate": "20240928222012",
    "TransactionReference": "ORDER_12345",
    "Msisdn": "254769290734"
}

<?php
// webhook.php - Handle PesaFlux webhook notifications

// Get the raw POST data
$json = file_get_contents('php://input');
$data = json_decode($json, true);

// Log the webhook data for debugging
error_log("PesaFlux Webhook: " . $json);

// Validate the webhook data
if (!$data || !isset($data['TransactionID'])) {
    http_response_code(400);
    echo "Invalid webhook data";
    exit;
}

// Extract transaction details
$responseCode = $data['ResponseCode'];
$transactionId = $data['TransactionID'];
$amount = $data['TransactionAmount'];
$receipt = $data['TransactionReceipt'];
$phone = $data['Msisdn'];
$reference = $data['TransactionReference'];

// Process the transaction based on response code
if ($responseCode == 0) {
    // Transaction successful
    processSuccessfulPayment($transactionId, $amount, $receipt, $phone, $reference);
    
    // Send success response
    http_response_code(200);
    echo json_encode(['status' => 'success', 'message' => 'Webhook processed']);
    
} else {
    // Transaction failed
    processFailedPayment($transactionId, $responseCode, $data['ResponseDescription']);
    
    // Send success response (acknowledge receipt)
    http_response_code(200);
    echo json_encode(['status' => 'received', 'message' => 'Failed transaction logged']);
}

function processSuccessfulPayment($transactionId, $amount, $receipt, $phone, $reference) {
    // Your business logic here
    // Example: Update database, send confirmation email, etc.
    
    // Database connection (replace with your details)
    $pdo = new PDO('mysql:host=localhost;dbname=your_db', 'username', 'password');
    
    // Update payment status in database
    $stmt = $pdo->prepare("
        UPDATE payments 
        SET status = 'completed', 
            transaction_receipt = ?, 
            completed_at = NOW() 
        WHERE transaction_id = ?
    ");
    $stmt->execute([$receipt, $transactionId]);
    
    // Send confirmation email/SMS to customer
    sendConfirmation($phone, $amount, $receipt);
}

function processFailedPayment($transactionId, $responseCode, $description) {
    // Log failed transaction
    $pdo = new PDO('mysql:host=localhost;dbname=your_db', 'username', 'password');
    
    $stmt = $pdo->prepare("
        UPDATE payments 
        SET status = 'failed', 
            failure_reason = ?, 
            failed_at = NOW() 
        WHERE transaction_id = ?
    ");
    $stmt->execute([$description, $transactionId]);
}

function sendConfirmation($phone, $amount, $receipt) {
    // Send SMS confirmation using FluxSMS API
    $message = "Payment of KES {$amount} received successfully. Receipt: {$receipt}. Thank you!";
    
    // Use FluxSMS API to send confirmation
    // Implementation depends on your SMS setup
}
?>

curl -X POST https://your-domain.com/webhook.php \
  -H "Content-Type: application/json" \
  -d '{
    "ResponseCode": 0,
    "ResponseDescription": "Success. Request accepted for processing",
    "MerchantRequestID": "test-merchant-id",
    "CheckoutRequestID": "test-checkout-id",
    "TransactionID": "TEST_TRANSACTION_123",
    "TransactionAmount": 100,
    "TransactionReceipt": "TEST_RECEIPT",
    "TransactionDate": "20241201120000",
    "TransactionReference": "TEST_REF_123",
    "Msisdn": "254712345678"
  }'