crm.clientright.ru/courtpars.php

<?php
set_time_limit(0); // Снимаем ограничение по времени работы скрипта

// Функция для записи логов
function log_message($message) {
    $date = date('Y-m-d H:i:s');
    file_put_contents('logs/parser.log', "[$date] $message" . PHP_EOL, FILE_APPEND);
}

// Подключение к базе данных
$host = 'localhost'; // хост
$dbname = 'court'; // имя базы данных
$user = 'court_usr'; // пользователь
$password = 'yOrjA9HdgwXO4JGJ'; // пароль

try {
    $pdo = new PDO("mysql:host=$host;dbname=$dbname;charset=utf8", $user, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    log_message("Успешное подключение к базе данных '$dbname'.");
} catch (PDOException $e) {
    log_message("Ошибка подключения к базе данных: " . $e->getMessage());
    die("Ошибка подключения: " . $e->getMessage());
}

// Запрос на получение данных из таблицы project
$query = "SELECT * FROM project WHERE status IN ('представительство в суде 1й инстанции', 'апелляция', 'кассация')";
$stmt = $pdo->prepare($query);
$stmt->execute();
$results = $stmt->fetchAll(PDO::FETCH_ASSOC);

log_message("Всего записей в таблице project: " . count($results));

if (count($results) === 0) {
    log_message("Нет записей для парсинга.");
    echo "<p>Нет записей для парсинга.</p>";
} else {
    foreach ($results as $row) {
        $status = $row['status'];
        $case_number = $row['case_number'];
        $uid = $row['uid'];
        $link = '';

        // Определяем, какую ссылку использовать для парсинга
        if ($status === 'представительство в суде 1й инстанции') {
            $link = $row['link1'];
        } elseif ($status === 'апелляция') {
            $link = $row['link2'];
        } elseif ($status === 'кассация') {
            $link = $row['link3'];
        }

        log_message("Парсим данные из ссылки: $link для дела: $case_number");

        // Загружаем HTML-контент страницы дела
        $html = @file_get_contents($link);

        if ($html === false) {
            log_message("Ошибка: не удалось загрузить страницу по ссылке: $link");
            continue;
        }

        log_message("Страница успешно загружена. Начинаем парсинг...");

        // Парсим HTML с помощью DOMDocument и XPath
        $dom = new DOMDocument();
        @$dom->loadHTML($html);
        $xpath = new DOMXPath($dom);

        // Определяем div для парсинга
        $div_id = ($status === 'представительство в суде 1й инстанции') ? 'cont2' : 'cont3';
        $rows = $xpath->query("//div[@id='$div_id']//tr");
        log_message("Найдено строк (tr) в div с id '$div_id': " . $rows->length);

        // Обрабатываем каждую строку таблицы
        foreach ($rows as $row) {
            $event_name = trim($xpath->query('./td[1]', $row)->item(0)->nodeValue ?? '');
            $event_date = trim($xpath->query('./td[2]', $row)->item(0)->nodeValue ?? '');
            $event_time = trim($xpath->query('./td[3]', $row)->item(0)->nodeValue ?? '');
            $location = trim($xpath->query('./td[4]', $row)->item(0)->nodeValue ?? '');
            $event_result = trim($xpath->query('./td[5]', $row)->item(0)->nodeValue ?? '');
            $event_basis = trim($xpath->query('./td[6]', $row)->item(0)->nodeValue ?? '');
            $note = trim($xpath->query('./td[7]', $row)->item(0)->nodeValue ?? '');
            $publication_date = trim($xpath->query('./td[8]', $row)->item(0)->nodeValue ?? '');

            // Логируем каждую строку
            log_message("Найдено событие: $event_name, Дата: $event_date, Время: $event_time, Место: $location, Результат: $event_result, Основание: $event_basis, Примечание: $note, Дата размещения: $publication_date");

            // Пропускаем записи, если название события не указано или дата неверная
    if (empty($event_name) || empty($event_date) || $event_date === '1970-01-01') {
        log_message("Пропущено событие: название или дата не указаны.");
        continue; // Пропустить итерацию
    }

    // Форматируем даты
    $formatted_date = date('Y-m-d', strtotime($event_date));
    $current_datetime = date('Y-m-d H:i:s');
    $formatted_publication_date = date('Y-m-d', strtotime($publication_date));

    // Проверяем на дублирование
    $checkQuery = "SELECT COUNT(*) FROM subject WHERE event_name = ? AND event_date = ? AND publication_date = ?";
    $checkStmt = $pdo->prepare($checkQuery);
    $checkStmt->execute([$event_name, $formatted_date, $formatted_publication_date]);
    $exists = $checkStmt->fetchColumn() > 0;

    if ($exists) {
        log_message("Дубликат найден для события: $event_name, пропускаем запись.");
        continue; // Пропустить запись
    }

            // Запись данных в таблицу subject
            $insertQuery = "INSERT INTO subject (case_number, uid, event_name, event_date, event_time, location, event_result, event_basis, note, publication_date, update_datetime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
            $insertStmt = $pdo->prepare($insertQuery);
            $insertStmt->execute([$case_number, $uid, $event_name, $formatted_date, $event_time, $location, $event_result, $event_basis, $note, $formatted_publication_date, $current_datetime]);

            log_message("Данные успешно записаны в таблицу subject для события: $event_name");
        }
    }
}

log_message("Парсинг завершен.");
?>