<?php
$host = "localhost";
$dbname = "ahrommag_core";
$user = "ahrommag";
$pass = "RJjdZFm8p6s7L4WYvIKdiFl5y";
$charset = "utf8mb4";

$from = "https://ahromstorage.ir/ahrominvest/mag/";
$to   = "https://ahrommag.ahromstorage.ir/";

try {
    $dsn = "mysql:host=$host;dbname=$dbname;charset=$charset";
    $pdo = new PDO($dsn, $user, $pass, [
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC
    ]);

    echo "✅ اتصال به دیتابیس برقرار شد.\n";

    $sqlSelect = "SELECT id, content FROM blogs WHERE content LIKE :pattern";
    $stmtSelect = $pdo->prepare($sqlSelect);
    $stmtSelect->execute([':pattern' => '%' . $from . '%']);

    $updated = 0;
    $total = 0;
 
    while ($row = $stmtSelect->fetch()) {
        $total++;
        $id = $row['id'];
        $content = $row['content'];

        $newContent = str_replace($from, $to, $content);

        if ($newContent !== $content) {
            $stmtUpdate = $pdo->prepare("UPDATE blogs SET content = :content WHERE id = :id");
            $stmtUpdate->execute([
                ':content' => $newContent,
                ':id' => $id
            ]);
            $updated++;
            echo "🟢 رکورد $id به‌روزرسانی شد.\n";
        }
    }

    echo "\n🎯 عملیات انجام شد.\n";
    echo "کل رکوردهای بررسی‌شده: $total\n";
    echo "تعداد رکوردهای تغییرکرده: $updated\n";

} catch (PDOException $e) {
    echo "❌ خطا در اتصال یا اجرا: " . $e->getMessage() . "\n";
    exit(1);
}