الخطوة 3: تتبع الحالة

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

// Run every 20 minutes
cron.schedule("*/20 * * * *", async () => {
  console.log("Checking pending payments...");

  try {
    // Get pending orders from last 24 hours
    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); // Small delay between requests
    }

    console.log(`Checked ${pendingOrders.length} orders`);
  } catch (error) {
    console.error("Cron job error:", 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(`✅ Order ${orderId} marked as PAID`);
    } else if (status === "FAILED") {
      await db.orders.update(orderId, { status: "FAILED" });
      console.log(`❌ Order ${orderId} marked as FAILED`);
    }
  } catch (error) {
    console.error(`Error checking order ${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()

# Run every 20 minutes
@scheduler.scheduled_job('interval', minutes=20)
def check_pending_payments():
    print('Checking pending payments...')

    try:
        # Get pending orders from last 24 hours
        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)  # Small delay between requests
            count += 1

        print(f'Checked {count} orders')
    except Exception as e:
        print(f'Cron job error: {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'✅ Order {order_id} marked as PAID')
        elif status == 'FAILED':
            db.orders.update(order_id, {'status': 'FAILED'})
            print(f'❌ Order {order_id} marked as FAILED')
    except Exception as e:
        print(f'Error checking order {order_id}: {e}')

# Start scheduler
scheduler.start()

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

require_once 'config.php';

echo "Checking pending payments...\n";

try {
    // Get pending orders from last 24 hours
    $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); // 100ms delay
    }

    echo "Checked " . count($pendingOrders) . " orders\n";
} catch (Exception $e) {
    echo "Cron job error: " . $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 "✅ Order {$orderId} marked as PAID\n";
        } elseif ($status === 'FAILED') {
            $stmt = $db->prepare("UPDATE orders SET status = 'FAILED' WHERE id = ?");
            $stmt->execute([$orderId]);
            echo "❌ Order {$orderId} marked as FAILED\n";
        }
    } catch (Exception $e) {
        echo "Error checking order {$orderId}: " . $e->getMessage() . "\n";
    }
}
?>