<?php
require_once __DIR__ . '/../src/config.php';
try {
    $pdo->exec("ALTER TABLE orders ADD COLUMN reminder_29d_sent TINYINT(1) NOT NULL DEFAULT 0");
} catch (Throwable $e) {}
$stmt = $pdo->query("SELECT o.id,o.user_id,o.delivered_at,o.created_at,p.title plan_title FROM orders o LEFT JOIN plans p ON p.id=o.plan_id WHERE o.status='DELIVERED' AND COALESCE(o.reminder_29d_sent,0)=0 AND COALESCE(o.delivered_at,o.created_at) <= DATE_SUB(NOW(), INTERVAL 29 DAY) LIMIT 100");
$rows = $stmt->fetchAll(PDO::FETCH_ASSOC);
$sent = 0;
foreach ($rows as $o) {
    $title = $o['plan_title'] ?: 'اشتراک شما';
    $txt = "⏰ یادآوری پایان اشتراک\n\nاشتراک {$title} شما به پایان دوره نزدیک شده است.\n\nما تمدید اکانت نداریم؛ برای ادامه استفاده، لطفاً یک اکانت جدید تهیه کنید.";
    tg('sendMessage', ['chat_id'=>(int)$o['user_id'], 'text'=>$txt]);
    $pdo->prepare("UPDATE orders SET reminder_29d_sent=1 WHERE id=?")->execute([(int)$o['id']]);
    $sent++;
}
echo "sent={$sent}\n";
