<?php
require_once __DIR__ . '/../configs/configs.php';
require_once __DIR__ . '/../libs/jdf.php';
require_once __DIR__ . '/../libs/functions.php';

if(!isset($pdo)) {
    die("Database connection failed.");
}

$now = date('Y-m-d H:i:s');
$stmt = $pdo->prepare("SELECT user_id, vip_expire FROM `users` WHERE `is_vip` = 1 AND `vip_expire` < ?");
$stmt->execute([$now]);
$expiredUsers = $stmt->fetchAll();

if(count($expiredUsers) > 0) {
    echo "Found " . count($expiredUsers) . " expired subscriptions.\n";

foreach($expiredUsers as $user) {
        $chat_id = $user->user_id;
        $updateStmt = $pdo->prepare("UPDATE `users` SET `is_vip` = 0 WHERE `user_id` = ?");
        $updateStmt->execute([$chat_id]);
        $expireDate = jdate("H:i  Y/m/d", strtotime($user->vip_expire));
        $message = "⚠️ *اشتراک ویژه شما به پایان رسید!*\n\n" .
            "کاربر گرامی،\n" .
            "مدت زمان اشتراک ویژه حساب کاربری شما در تاریخ *$expireDate* به اتمام رسیده است و حساب شما به حالت عادی تغییر یافت.\n\n" .
            "💎 *با تمدید اشتراک، مجدداً به امکانات ویژه دسترسی خواهید داشت:*\n" .
            "✅ اولویت مطلق در انجام سفارش‌ها\n" .
            "✅ درآمد دوبرابری از زیرمجموعه‌ها\n" .
            "✅ ۱۰٪ تخفیف دائمی روی تمام سفارش‌ها\n" .
            "✅ انتقال سکه بدون کارمزد\n" .
            "✅ پشتیبانی اختصاصی\n\n" .
            "👇 *برای تمدید و بازگشت به جمع حرفه‌ای‌ها، همین حالا اقدام کنید:*";
        $keyboard = json_encode([
            "inline_keyboard" => [
                [
                    ['text' => '💎 تمدید اشتراک ویژه', 'callback_data' => 'buy_vip_plan']
                ]
            ]
        ]);
        sendMessage($chat_id, $message, $keyboard);
        echo "Processed user: $chat_id\n";
}

} else {
    echo "No expired subscriptions found.\n";
}

