Étape 3 : Suivi du statut

const cron = require("node-cron");

// Exécuter toutes les 20 minutes
cron.schedule("*/20 * * * *", async () => {
  console.log("Vérification des paiements en attente...");

  try {
    // Récupérer les commandes en attente des dernières 24 heures
    const pendingOrders = await db.orders.find({
      status: "PENDING",
      paymentRef: { $exists: true },
      createdAt: { $gte: new Date(Date.now() - 24 * 60 * 60 * 1000) },
    });

    for (const order of pendingOrders) {
      await checkAndUpdateOrder(order.id, order.paymentRef);
      await sleep(100); // Petit délai entre les requêtes
    }

    console.log(`Vérifié ${pendingOrders.length} commandes`);
  } catch (error) {
    console.error("Erreur tâche cron :", error);
  }
});

async function checkAndUpdateOrder(orderId, paymentRef) {
  try {
    const response = await fetch(
      `https://api.oneclickdz.com/v3/ocpay/checkPayment/${paymentRef}`,
      {
        headers: { "X-Access-Token": process.env.ONECLICK_API_KEY },
      }
    );

    const data = await response.json();
    const status = data.data.status;

    if (status === "CONFIRMED") {
      await db.orders.update(orderId, { status: "PAID" });
      console.log(`✅ Commande ${orderId} marquée comme PAYÉE`);
    } else if (status === "FAILED") {
      await db.orders.update(orderId, { status: "FAILED" });
      console.log(`❌ Commande ${orderId} marquée comme ÉCHOUÉE`);
    }
  } catch (error) {
    console.error(`Erreur vérification commande ${orderId} :`, error);
  }
}

function sleep(ms) {
  return new Promise((resolve) => setTimeout(resolve, ms));
}

from apscheduler.schedulers.background import BackgroundScheduler
import requests
import os
from datetime import datetime, timedelta
import time

scheduler = BackgroundScheduler()

# Exécuter toutes les 20 minutes
@scheduler.scheduled_job('interval', minutes=20)
def check_pending_payments():
    print('Vérification des paiements en attente...')

    try:
        # Récupérer les commandes en attente des dernières 24 heures
        yesterday = datetime.now() - timedelta(days=1)
        pending_orders = db.orders.find({
            'status': 'PENDING',
            'paymentRef': {'$exists': True},
            'createdAt': {'$gte': yesterday}
        })

        count = 0
        for order in pending_orders:
            check_and_update_order(order['id'], order['paymentRef'])
            time.sleep(0.1)  # Petit délai entre les requêtes
            count += 1

        print(f'Vérifié {count} commandes')
    except Exception as e:
        print(f'Erreur tâche cron : {e}')

def check_and_update_order(order_id, payment_ref):
    try:
        response = requests.get(
            f'https://api.oneclickdz.com/v3/ocpay/checkPayment/{payment_ref}',
            headers={'X-Access-Token': os.getenv('ONECLICK_API_KEY')}
        )

        data = response.json()
        status = data['data']['status']

        if status == 'CONFIRMED':
            db.orders.update(order_id, {'status': 'PAID'})
            print(f'✅ Commande {order_id} marquée comme PAYÉE')
        elif status == 'FAILED':
            db.orders.update(order_id, {'status': 'FAILED'})
            print(f'❌ Commande {order_id} marquée comme ÉCHOUÉE')
    except Exception as e:
        print(f'Erreur vérification commande {order_id} : {e}')

# Démarrer le planificateur
scheduler.start()

<?php
// cron-check-payments.php
// Ajouter au crontab : */20 * * * * php /path/to/cron-check-payments.php

require_once 'config.php';

echo "Vérification des paiements en attente...\n";

try {
    // Récupérer les commandes en attente des dernières 24 heures
    $yesterday = date('Y-m-d H:i:s', strtotime('-24 hours'));

    $stmt = $db->prepare("
        SELECT id, payment_ref
        FROM orders
        WHERE status = 'PENDING'
        AND payment_ref IS NOT NULL
        AND created_at >= ?
    ");
    $stmt->execute([$yesterday]);
    $pendingOrders = $stmt->fetchAll(PDO::FETCH_ASSOC);

    foreach ($pendingOrders as $order) {
        checkAndUpdateOrder($order['id'], $order['payment_ref']);
        usleep(100000); // Délai de 100ms
    }

    echo "Vérifié " . count($pendingOrders) . " commandes\n";
} catch (Exception $e) {
    echo "Erreur tâche cron : " . $e->getMessage() . "\n";
}

function checkAndUpdateOrder($orderId, $paymentRef) {
    global $db;

    try {
        $ch = curl_init("https://api.oneclickdz.com/v3/ocpay/checkPayment/{$paymentRef}");
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_HTTPHEADER, [
            'X-Access-Token: ' . getenv('ONECLICK_API_KEY')
        ]);

        $response = curl_exec($ch);
        $data = json_decode($response, true);
        $status = $data['data']['status'];

        if ($status === 'CONFIRMED') {
            $stmt = $db->prepare("UPDATE orders SET status = 'PAID' WHERE id = ?");
            $stmt->execute([$orderId]);
            echo "✅ Commande {$orderId} marquée comme PAYÉE\n";
        } elseif ($status === 'FAILED') {
            $stmt = $db->prepare("UPDATE orders SET status = 'FAILED' WHERE id = ?");
            $stmt->execute([$orderId]);
            echo "❌ Commande {$orderId} marquée comme ÉCHOUÉE\n";
        }
    } catch (Exception $e) {
        echo "Erreur vérification commande {$orderId} : " . $e->getMessage() . "\n";
    }
}
?>