<?php

require_once($_SERVER['DOCUMENT_ROOT']."/config.php");

ini_set('display_errors', 1);
error_reporting(E_ALL & ~E_DEPRECATED & ~E_STRICT & ~E_NOTICE);

if($_SESSION['id'] && $_GET['id']) {
    $db_sphinx = new MysqlPdo(hstsph2, null, null, null, true, '9306');
    $get = clearInputData($_GET);

    $sql="SELECT * FROM objects_to_send WHERE id=$get[id]";
    $rez=mysql_query($sql);
    $rec = mysql_fetch_assoc($rez);

    $newUserId = $rec['new_user_id'];
    $objectId = $rec['object_id'];

    $newUser = new User;
    $newUser->get($newUserId);

    if (!$newUser->agencyId) {
        $newUser->agencyId = $newUserId;
    }

    $currentUser = new User;
    $currentUser->get($_SESSION['id']);

    if (!$currentUser->agencyId) {
        $currentUser->agencyId = $_SESSION['id'];
    }

    $phone = $newUser->phone;
    $num_search = User::num_search($phone);
    /*if(!empty($newUser->phone2)){
        $phone = $phone.' '.$newUser->phone2;
    }*/
    $sobstv = trim($newUser->last_name . ' ' . $newUser->first_name . ' ' . $newUser->middle_name);

    if ($newUser->agency == 0) {
        $sql="SELECT * FROM users WHERE id=$newUser->id_manager";
        $rez=mysql_query($sql);
        $manager = mysql_fetch_assoc($rez);

        if($manager['id_manager']) {
            $agency = mysql_fetch_assoc(mysql_query("SELECT * FROM users WHERE id=$manager[id_manager]"));
        } else {
            $agency = $manager;
        }
        if ($agency) {
            $sobstv = trim($currentUser->last_name . ' ' . $currentUser->first_name . ' ' . $currentUser->middle_name) . ", агентство " . $agency['agency_name'];
        }
    } else {
        $sobstv = $sobstv . ", агентство " . $newUser->agency_name;
    }

    $webHookIn = new WebHookIn(null, $currentUser->agencyId);
                
    $is_send_webhook = $webHookIn->check_hook('object_update', 'object');
               
                
    if($is_send_webhook){
        $webHookIn->save_temp_object($objectId);
    }

    // перенос всех объектов
    $sql = "UPDATE objects SET id_add_user = $newUser->id, phone = '$phone', phone_search = '$num_search', sobstv = '$sobstv', is_main = 0 WHERE id=$objectId";
    $rez = mysql_query($sql);
    
    //Запись в сфинкс
    $sql_sph = "UPDATE objects SET id_add_user=$newUser->id, phone_search = '$num_search' WHERE id=$objectId";
    $db_sphinx->query($sql_sph);
    /*$sql_sph_replace = "REPLACE INTO objects_rt (id,id_add_user, phone_search) VALUES ('".$objectId."', '".$newUser->id."', '".$num_search."')";
    $db_sphinx->query($sql_sph_replace);*/

    //перенос событий объектов
    $sqlObjEvents = "UPDATE user_object_events SET user_id=$newUser->id WHERE object_id=$objectId";
    mysql_query($sqlObjEvents);

    //перенос комментариев объектов
    $sqlObjCom = "UPDATE user_object_comments SET user_id=$newUser->id WHERE object_id=$objectId";
    mysql_query($sqlObjCom);

    // перенос Зипал
    $sql = "UPDATE zipal_objects SET user_id=$newUser->id, send_to_update=1 WHERE object_id=$objectId";
    $rez = mysql_query($sql);

    $sqlPack = "UPDATE advertising_package_object_publish SET send_to_update = '1', error_when_send_to_update = '' WHERE object_id=$objectId";
    mysql_query($sqlPack);

    /**
     * Передача заявок Реализация
     */
    $sql_req = "SELECT id, `name`, object_id, type_id, who_work, funnel_id, confirm FROM `requisitions` WHERE object_id = {$objectId} AND cancel=0 AND deleted=0 AND (type_id = 2 or (SELECT heir FROM requisitions_type WHERE id = requisitions.type_id) = 2) AND who_work != '".$newUser->id."'";
    //echo $sql_req."\n";
    $q_req = mysql_query($sql_req);
    if(mysql_num_rows($q_req) > 0){
        while($r_req = mysql_fetch_assoc($q_req)){
            $sql_up = "UPDATE requisitions SET confirm=1, who_work={$newUser->id} WHERE id={$r_req['id']}";
            //echo $sql_up."\n";
            if(mysql_query($sql_up)){
                $sql_ev = "INSERT INTO `events_clients` (user_id, req_id, from_id, event, `read`, dop_text) VALUES ('".$_SESSION['id']."', '{$r_req['id']}', '".$newUser->id."', 'update', '1', 'Переведена на ответственного при принятии объекта ID {$objectId}')";
                //echo $sql_ev."\n";
                mysql_query($sql_ev);
            }
        }
    }

    //передаем клиентов
    /*$q_client = mysql_query("SELECT client_id FROM client_objects WHERE object_id = {$objectId}");
    $client_ids = array();
    while($r_client = mysql_fetch_assoc($q_client)){
        $client_ids[] = $r_client['client_id'];
    }
    if(!empty($client_ids)){
        $sql_clients = "SELECT `id`, `fio`, `email` FROM `clients` WHERE id in (".implode(',', $client_ids).")";
        $q_client = mysql_query($sql_clients);
        if(mysql_num_rows($q_client) > 0){
            while($client = mysql_fetch_assoc($q_client)) {
                $sql = "UPDATE clients SET confirm=1, who_work=$newUser->id WHERE id=$client[id]";
                mysql_query($sql);

                $sql="UPDATE user_client_events SET user_id=$newUser->id WHERE client_id=$client[id]";
                mysql_query($sql);

                $sql = "UPDATE `events_clients` set `read` = 1,  date_update='".date('Y-m-d H:i:s')."' WHERE client_id=$client[id] and from_id = ".$_SESSION['id'];
                mysql_query($sql);

                $sql = "INSERT INTO `events_clients` (user_id, client_id, from_id, event, `read`) VALUES ('".$_SESSION['id']."', '".$client['id']."', '".$_SESSION['id']."', 'accepted', '1')";
                mysql_query($sql);
            }
        }
    }*/

    if($is_send_webhook){
        $dataWhook = array('action'=>'object_update', 'object_id'=>$objectId, 'section'=>'object', 'user_id'=>$_SESSION['id'], 'agency_id'=>$currentUser->agencyId);
        $webHookIn->check_send($dataWhook);
      
    }

    $sql = "UPDATE objects_to_send SET accept_date=NOW(), accept_state='ACCEPTED' WHERE id=$get[id]";
    mysql_query($sql);
}