<?php
set_time_limit(0);
require_once($_SERVER['DOCUMENT_ROOT'] . "/config.php");

ini_set('display_errors', 1);
error_reporting(E_ALL & ~E_DEPRECATED & ~E_STRICT & ~E_NOTICE);
header('Content-Type: application/json');

$pdo = new MysqlPdo(hst, ndb, user, pass);
$pdo->query("SET NAMES 'utf8'");
$db_sphinx = new MysqlPdo(hstsph2, null, null, null, true, '9306');

$arrDestination = [
    'AVITO_JW_FEED' => 'Авито',
    'EMLS_JW_FEED' => 'Jcat',
    'CIAN_JW_FEED' => 'Циан',
    'YANDEX_JW_FEED' => 'Яндекс',
    'FREE_JW_FEED' => 'Бесплатные',
    'DOMCLICK_JW_FEED' => 'Домклик',
];

$user_ids = array();
$object_sends = array();
$object_ids = array();

$object_users = array();
$object_adres = array();
$object_archive = array();

$users = array();
$sql = "SELECT * FROM object_unpublish_telegram_send WHERE is_read = 0";
$q = $pdo->query($sql);
while($r = $pdo->fetch_assoc($q)){
//$user_ids[] = (int)$r['user_id'];
    $object_sends[] = $r;
    $object_ids[] = (int)$r['object_id'];
}

$sql_obj = "SELECT id_add_user, id, adres, archive FROM objects WHERE id in (".implode(',',$object_ids).") LIMIT 1000000 OPTION max_matches=1000000";
$q_obj = $db_sphinx->query($sql_obj);
while($r_obj = $db_sphinx->fetch_assoc($q_obj)){
    $user_ids[] = (int)$r_obj['id_add_user'];
    $object_users[$r_obj['id']] = (int)$r_obj['id_add_user'];
    $object_adres[$r_obj['id']] = $r_obj['adres'];
    $object_archive[$r_obj['id']] = (int)$r_obj['archive'];
}


$user_ids = array_unique($user_ids);
$sql_user = "SELECT * FROM users WHERE id in (".implode(',', $user_ids).")";
$q_user = $pdo->query($sql_user);
while($r_user = $pdo->fetch_assoc($q_user)){
    $users[$r_user['id']] = $r_user;
}

//var_dump($users);

$Telega = new Telegram(false, $pdo);
$max = new MaxClass();
//var_dump($object_sends);

foreach($object_sends as $send){
    if($object_archive[$send['object_id']] == 0){
        $send_t = 0;
        $send_m = 0;
        $user_id = $object_users[$send['object_id']];

        if(isset($users[$user_id])){
            $user = $users[$user_id];
            if($user['telegramm_notice'] > 0 && $user['telegramm_chat_id'] > 0){
                $chatId = $user['telegramm_chat_id'];
                $text = "Истек срок размещения объекта ID {$send['object_id']} на ";
                if(isset($arrDestination[$send['destination']])){
                    $text .= $arrDestination[$send['destination']];
                } else {
                    $text .= $send['destination'];
                }
                $text .= "\nАдрес: ".$object_adres[$send['object_id']];
                $Telega->send($text, $chatId);
                $send_t = 1;

            }

            if($user['max_notice'] > 0 && $user['max_user_id'] > 0){
                $userMaxId = $user['max_user_id'];
                $text = "Истек срок размещения объекта ID {$send['object_id']} на ";
                if(isset($arrDestination[$send['destination']])){
                    $text .= $arrDestination[$send['destination']];
                } else {
                    $text .= $send['destination'];
                }
                $text .= "\nАдрес: ".$object_adres[$send['object_id']];
                $max->send_messages_to_user($userMaxId, $text);
                $send_m = 1;

            }

        
        }
    } else {
        $send_t = 2;
    }
   
    $pdo->query("UPDATE object_unpublish_telegram_send SET is_read=1, send={$send_t}, send_max={$send_m} WHERE id = {$send['id']}", true);

}