<?php
class ChatsCianAvito {
    private $db = null;
    private $dbpg = null;
    private $service = 0;

    public function __construct($db = null) {

        if($db){
          $this->db = $db;
        } else {
          $pdo = new MysqlPdo(hst, ndb, user, pass);
          $sql = "SET NAMES 'utf8'";
          $pdo->query($sql);
          $this->db = $pdo;
        }

        // PostgreSQL может быть недоступен в окружении (например, на dev — нет PG-сервера).
        // MysqlPdo для PG-ветки бросает RuntimeException, если хост недоступен (2-сек fsockopen-check).
        // В этом случае $this->dbpg остаётся null; методы, использующие его, должны сами это учитывать.
        // can_chat() PG не использует — он работает только на MySQL, поэтому остальная логика не страдает.
        // Используем catch (Exception) для совместимости с PHP 5.x.
        try {
            if (defined('hstpg') && defined('ndbpg') && defined('passpg')) {
                $pdopg = new MysqlPdo(hstpg, ndbpg, 'u0305746_jw', passpg, false, '5432', true);
                $sql = "SET NAMES 'utf8'";
                $pdopg->query($sql);
                $this->dbpg = $pdopg;
            }
        } catch (Exception $e) {
            // PG недоступен — оставляем dbpg = null.
        }

    }

    public function setService($service){
        $this->service = $service;
    }

    public function ajax_can_chat($data){
        $user_id = $data->user_id;
        $user = new User();
        $user->checkPermissions($user_id);
        return $this->can_chat($user, $data->service_id);
    }

    public function ajax_get_user($data){
        $user_id = $data->user_id;
        return $this->get_user($user_id);
    }

    public function can_chat($global_user, $service_id){
        
       
        $agency_id = $global_user->agencyId;
        $sql = "SELECT * FROM users_api WHERE agency_id = {$agency_id} AND service_id = {$service_id} AND is_messages = 1";
        $q = $this->db->query($sql);
        if($this->db->num_rows($q) == 0) return false;
        

        if($global_user->agency == 0 && $global_user->users_admin == 0 && (int)$global_user->individual == 0) {
            $sql_api = "SELECT * FROM user_api_keys WHERE user_id = {$global_user->id}";
            //echo $sql_api;
            $q_api = $this->db->query($sql_api);
            $r_api = $this->db->fetch_assoc($q_api);
            if($service_id == 1){
               // var_dump($r_api['avito_id'] == 0 && $r_api['is_id_object'] == 0 && $r_api['is_all_avito'] == 0);
                if($r_api['avito_id'] == 0 && $r_api['is_id_object'] == 0 && $r_api['is_all_avito'] == 0) return false; 
            } else if ($service_id == 2){
                if($r_api['cian_id'] == 0 && $r_api['is_id_object_cian'] == 0 && $r_api['is_all_cian'] == 0) return false; 
            }
        }
        return true;
    }

   
    public function get_user($user_id){
        $result = array();
        if($user_id > 0){
            $sql = "SELECT * FROM users WHERE id = {$user_id}";
            $q = $this->db->query($sql);
            $result = $this->db->fetch_assoc($q);
            $sql_api = "SELECT * FROM user_api_keys WHERE user_id = {$user_id}";
            $q_api = $this->db->query($sql_api);
            $r_api = $this->db->fetch_assoc($q_api);
            $result['cian_id'] = 0;
            $result['avito_id'] = 0;
            $result['is_all_cian'] = 0;
            $result['is_all_avito'] = 0;
            $result['is_id_object'] = 0;
            $result['is_id_object_cian'] = 0;
            if(isset($r_api['user_id'])){
                $result['cian_id'] = $r_api['cian_id'];
                $result['avito_id'] = $r_api['avito_id'];
                $result['is_all_cian'] = $r_api['is_all_cian'];
                $result['is_all_avito'] = $r_api['is_all_avito'];
                $result['is_id_object'] = $r_api['is_id_object'];
                $result['is_id_object_cian'] = $r_api['is_id_object_cian'];
            }
            if ($result['id_manager'] == 0 && $result['agency'] == 0) {
                // частник
                $result['individual'] = 1;
            } else {
                $result['individual'] = 0;
            }
        }
        return $result;
    }

    /**
     * 
     */
    public function get_api_chat($api_id){
        $result = array();
        $sql = "SELECT * FROM `users_api` AS `api` WHERE `api`.`id` = '$api_id' LIMIT 1";
        $q = $this->db->query($sql);
        $api = $this->db->fetch_assoc($q);
        if(!empty($api)){
            $result = $api;
        }
        return $result;
    }

    public function add_message($arrayMess){
        $object_id_mes = 0;
        $user_id_mes = 0;
        if(!empty($arrayMess['cian_id'])){
            $sql_user = "SELECT * FROM user_api_keys WHERE cian_id = {$arrayMess['cian_id']}";
            $q_user = $this->db->query($sql_user);
            if($this->db->num_rows($q_user) > 0){
                $r_user = $this->db->fetch_assoc($q_user);
                $arrayMess['user_id'] = $r_user['user_id'];
            }

        }
        if((int)$arrayMess['object_id'] > 0){
            $object_id_mes = $arrayMess['object_id'];
            $user_id_mes = $arrayMess['user_id'];           
            $sql_user_obj = "SELECT * FROM user_api_keys WHERE user_id = (SELECT id_add_user FROM objects WHERE id = {$arrayMess['object_id']}) AND is_id_object_cian = 1";
            $q_user_obj = $this->db->query($sql_user_obj);
            if($this->db->num_rows($q_user_obj) > 0){
                $r_user_obj = $this->db->fetch_assoc($q_user_obj);
                $arrayMess['user_id'] = $r_user_obj['user_id'];
                $user_id_mes = $arrayMess['user_id'];
            }
        }
        unset($arrayMess['object_id']);
        unset($arrayMess['cian_id']);
        $columns = array_keys($arrayMess);
        $arrayMess['details'] = pg_escape_string($arrayMess['details']);
        $sql = "INSERT INTO cian_chat (".implode(',', $columns).") VALUES ('".implode('\',\'',$arrayMess)."')";
       
        $this->dbpg->query($sql);
        $mess_id = $this->dbpg->insert_id(); //Id сообщения в базе
        //file_put_contents($_SERVER['DOCUMENT_ROOT']."/telegramm_mes_chat.txt", date('d.m.y H:i:s')." ".$mess_id."\n", FILE_APPEND);

        if($arrayMess['agency_id'] != 12061){
            $this->send_message($object_id_mes, $user_id_mes, 2, $arrayMess['details'], [], $mess_id, $arrayMess['agency_id']);
        }
      
    }

    /**
     * Добавление чатов Авито
     */
    public function add_message_avito($data){
        $object_id_mes = 0;
        $user_id_mes = 0;
        $obj_mes = array();
        $user_id_chat = $data['payload']['value']['user_id'];
        $chat_id = $data['payload']['value']['chat_id'];
        $user_id = 0;
        $agency_id = 0;
        $sql_user = "SELECT * FROM user_api_keys WHERE avito_id = {$user_id_chat}";
        $q_user = $this->db->query($sql_user);
        if($this->db->num_rows($q_user) > 0){
            $r_user = $this->db->fetch_assoc($q_user);
            $user_id = $r_user['user_id'];
        }
       
        $api_result = $this->get_api_chat($data['api']);

       /* */
       // if(isset($avito) && $avito['success']){
            //unset($data['api']);
            $arrayMess['user_id'] = $user_id;
            $agency_id = $arrayMess['agency_id'] = $api_result['agency_id'];
            $arrayMess['chat_id'] = $chat_id;
            $arrayMess['details'] = pg_escape_string(json_encode($data, JSON_UNESCAPED_UNICODE));
            $arrayMess['create_at_real'] = $data['payload']['value']['created'];
            $arrayMess['update_at_real'] = $data['timestamp'];
            $arrayMess['new'] = 0;
            if($data['payload']['value']['user_id'] == $data['payload']['value']['author_id']){
                $arrayMess['new'] = 0;
            } else {
                $arrayMess['new'] = 1;
            }
           // var_dump($arrayMess);
            $columns = array_keys($arrayMess);
            $sql = "INSERT INTO chat_avito_messages (".implode(',', $columns).") VALUES ('".implode('\',\'',$arrayMess)."')";
           // file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_sql.txt", $sql."\n", FILE_APPEND);
            $this->dbpg->query($sql);
            $mess_id = $this->dbpg->insert_id(); //Id сообщения в базе
       // }
        $arrayMess = array();
        $sql = "SELECT * FROM chat_avito WHERE chat_id  = '{$chat_id}'";
       // file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_sql.txt", $sql."\n", FILE_APPEND);
        //echo $sql;
            $q = $this->dbpg->query($sql);
            if($this->dbpg->num_rows($q) == 0){
                $api = new AdvertStats();
                $avito = $api->get_chat($api_result, $chat_id);
                if($avito['success']){
                    $arrayMess['user_id'] = $user_id;
                    $arrayMess['agency_id'] = $api_result['agency_id'];
                    $arrayMess['chat_id'] = $chat_id;
                    unset($avito['success']);
                    $arrayMess['details'] = pg_escape_string(json_encode($avito, JSON_UNESCAPED_UNICODE));
                    $arrayMess['create_at_real'] = $avito['created'];
                    $arrayMess['update_at_real'] = $avito['updated'];
                    $columns = array_keys($arrayMess);
                    $sql = "INSERT INTO chat_avito (".implode(',', $columns).") VALUES ('".implode('\',\'',$arrayMess)."')";
                   // file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_sql.txt", $sql."\n", FILE_APPEND);
                // echo $sql;
                    $this->dbpg->query($sql);
                }
            } else {
                $chat_avito = $this->dbpg->fetch_assoc($q);
                $api = new AdvertStats();
                $avito = $api->get_chat($api_result, $chat_id);
                if($avito['success']){
                    $details = pg_escape_string(json_encode($avito, JSON_UNESCAPED_UNICODE));
                    $sql = "UPDATE chat_avito SET details = '{$details}', create_at_real = {$avito['created']}, update_at_real = {$avito['updated']} WHERE id = {$chat_avito['id']}";
                    //file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_sql.txt", $sql."\n", FILE_APPEND);
                    $this->dbpg->query($sql);
                }
            }

            if(isset($avito)){
                $id_avito = (int)$avito['context']['value']['id'];
                if($id_avito > 0){
                    $objectUrls = 'https://www.avito.ru/items/'.$id_avito;
                    $sql_obj_stat = "SELECT object_id, url FROM ads_stats WHERE service_id = 1 AND agency_id = {$agency_id} AND url = '{$objectUrls}'";
                    //echo $sql_obj_stat;
                    $q_obj_stat = $this->db->query($sql_obj_stat);
                    while($r_obj_stat = $this->db->fetch_assoc($q_obj_stat)){
                        if((int)$r_obj_stat['object_id'] > 0){
                            $object_id = (int)$r_obj_stat['object_id'];
                        }
                    }
                    if(isset($object_id) && $object_id > 0){
                        if($user_id == 0 || $user_id == $agency_id){
                            $sql_obj = "SELECT id, id_add_user, adres FROM objects WHERE id = {$object_id}";
                            $q_obj = $this->db->query($sql_obj, true);
                            $obj = $this->db->fetch_assoc($q_obj);
                            if((int)$obj['id_add_user'] > 0){
                                $user_id = (int)$obj['id_add_user']; 
                                $object_id_mes = $object_id;
                                $user_id_mes = $user_id;
                                $obj_mes = $obj;
                            }                       
                        }
                    }
                    if(isset($object_id) && $object_id > 0){
                        
                        $sql_up_user = "UPDATE chat_avito_messages SET user_id = $user_id WHERE chat_id = '{$chat_id}'";
                       // file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_sql.txt", $sql_up_user."\n", FILE_APPEND);
                        $this->dbpg->query($sql_up_user);
                        $sql_up_user = "UPDATE chat_avito SET user_id = $user_id, object_id={$object_id} WHERE chat_id = '{$chat_id}'";
                       // file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_sql.txt", $sql_up_user."\n", FILE_APPEND);
                        $this->dbpg->query($sql_up_user);
                        
                    }
                    
                    if($object_id_mes > 0 && $user_id_mes > 0){
                        if($agency_id != 11916 && $agency_id != 12061){
                            $this->send_message($object_id_mes, $user_id_mes, 1, $data, $obj_mes, $mess_id, $agency_id);
                        }
                    }
                }
            }

    }

    /**
     * Отправка сообщений телеграмм
     */
    public function send_message($object_id, $user_id, $servise, $details, $obj=[], $mess_id = 0, $agency_id = 0){
        $keyboardArr = [];
        $attachments = [];
        $tel = new Telegram(false);
        $max = new MaxClass();
        $is_send = false;
        $is_send_max = false;
        if($user_id > 0 && $object_id > 0){
            $chat_id = 0;
            $sql = "SELECT * FROM users WHERE id = {$user_id}";
            $q = $this->db->query($sql);
            $user = $this->db->fetch_assoc($q);
            if($user['telegramm_notice'] == 1 AND $user['telegramm_chat_id'] > 0){
                $chat_id = $user['telegramm_chat_id'];
                if($user['id'] == 14398 || $user['id'] == 19476){
                    $chat_id = 0;
                }
            }

            if($user['max_notice'] == 1 AND $user['max_user_id'] > 0){
                $max_user_id = $user['max_user_id'];
                if($user['id'] == 14398 || $user['id'] == 19476){
                    $max_user_id = 0;
                }
            }
            //$max_user_id = 18529338;
            if($chat_id > 0 || $max_user_id > 0){
                $text = "Получено новое сообщение из чата ";
                if($servise == 1){
                    $text .= "АВИТО";
                } else if($servise == 2){
                    $text .= "ЦИАН";
                }
                $text .= "\nпо объекту ID ".$object_id;
                if($servise == 2){
                    $chat = json_decode($details, true);
                } else {
                    $chat = $details;
                }
                
                $userName = '';
                if($servise == 2){
                    if($mess_id > 0){
                        $keyboardArr = [
                                            [
                                                [
                                                    'text' => 'Прочитано',
                                                    'callback_data' => serialize(array('action'=>5,'id'=>$mess_id))
                                                
                                                ],
                                                [
                                                    'text' => 'Ответить',
                                                    'callback_data' => serialize(array('action'=>4,'id'=>$mess_id))
                                                ],
                                            
                                            ],
                                            [
                                                [
                                                    'text' => 'Создать заявку',
                                                    'callback_data' => serialize(array('action'=>6,'id'=>$mess_id))
                                                ]
                                            ]

                                        ];

                        $attachments = [
                            array(
                            'type'=>'inline_keyboard',
                            'payload' => array(
                                'buttons' => [
                                                [
                                                    [
                                                        "type" => "callback", 
                                                        'text' => 'Прочитано',
                                                        'payload' => serialize(array('action'=>5,'id'=>$mess_id))
                                                        
                                                    ],
                                                    [
                                                        "type" => "callback", 
                                                        'text' => 'Ответить',
                                                        'payload' => serialize(array('action'=>4,'id'=>$mess_id))
                                                        
                                                    ]
                                                ],
                                                [
                                                    [
                                                        "type" => "callback", 
                                                        'text' => 'Создать заявку',
                                                        'payload' => serialize(array('action'=>6,'id'=>$mess_id))
                                                        
                                                    ]
                                                ]
                                            ]
                                        )
                                    ) 
                            ];                   
                    }
                    if(is_numeric($chat['users'][0]['name'])){
                        $userName = "Пользователь ID ".$chat['users'][0]['name'];
                    } else {
                        $userName = $chat['users'][0]['name'];
                    }
                    $address = $chat['offers'][0]['address'];
                
            
                    $text .= " ".$address;
                    $mesages = $chat['chats'][0]['messages'];
                    foreach($mesages as $mesages){
                        if($mesages['direction'] == 'in'){
                            
                            $text .="\n\n";
                            $text .= "Отправитель ".$userName."\n";
                            $text .= $mesages['content']['text']."\n";
                            if($chat_id > 0)
                                $is_send = true;
                            if($max_user_id > 0)
                                $is_send_max = true;
                        }
                    }
                } else if($servise == 1) {
                    if($mess_id > 0){
                        $keyboardArr = [
                                            [
                                                [
                                                    'text' => 'Прочитано',
                                                    'callback_data' => serialize(array('action'=>2,'id'=>$mess_id))
                                                
                                                ],
                                                [
                                                    'text' => 'Ответить',
                                                    'callback_data' => serialize(array('action'=>1,'id'=>$mess_id))
                                                ],
                                            
                                            ],
                                            [
                                                [
                                                    'text' => 'Создать заявку',
                                                    'callback_data' => serialize(array('action'=>3,'id'=>$mess_id))
                                                ]
                                            ]

                                        ];

                        $attachments = [
                            array(
                            'type'=>'inline_keyboard',
                            'payload' => array(
                                'buttons' => [
                                                [
                                                    [
                                                        "type" => "callback", 
                                                        'text' => 'Прочитано',
                                                        'payload' => serialize(array('action'=>2,'id'=>$mess_id))
                                                        
                                                    ],
                                                    [
                                                        "type" => "callback", 
                                                        'text' => 'Ответить',
                                                        'payload' => serialize(array('action'=>1,'id'=>$mess_id))
                                                        
                                                    ]
                                                ],
                                                [
                                                    [
                                                        "type" => "callback", 
                                                        'text' => 'Создать заявку',
                                                        'payload' => serialize(array('action'=>3,'id'=>$mess_id))
                                                        
                                                    ]
                                                ]
                                            ]
                                        )
                                    ) 
                            ];     
                    }
                    $address = $obj['adres'];
                    $text .= " ".$address;
                    $mesages = $details['payload'];
                    if($mesages['type'] == 'message'){
                       
                        $mes_user_id = $mesages['value']['user_id'];
                        $mes_author_id = $mesages['value']['author_id'];
                        if($mes_user_id != $mes_author_id){
                            if($chat_id > 0)
                                $is_send = true;
                            if($max_user_id > 0)
                                $is_send_max = true;
                            $chat_id_avito = $mesages['value']['chat_id'];
                            $sql_chat = "SELECT * FROM chat_avito WHERE chat_id = '{$chat_id_avito}'";
                            $q_chat = $this->dbpg->query($sql_chat);
                            $r_chat = $this->dbpg->fetch_assoc($q_chat);
                            $details_chat = json_decode($r_chat['details'], true);
                            
                            $userName = $details_chat['users'][0]['name'];
                            if($mes_author_id == $details_chat['users'][1]['id']){
                                $userName = $details_chat['users'][1]['name'];
                            }
                            $text .="\n\n";
                            $text .= "Отправитель ".$userName."\n";
                            $text .= $mesages['value']['content']['text']."\n";
                        }
                    }
                    
                }
                
                $text .= "\nОтветить на сообщение можно в чатах JoyWork";
                
                if($is_send){
                    //if($servise == 2)
                        //file_put_contents($_SERVER['DOCUMENT_ROOT']."/telegramm_mes_chat.txt", date('d.m.y H:i:s').' '.$mess_id.' '.$text.' '.json_encode($chat, JSON_UNESCAPED_UNICODE)."\n", FILE_APPEND);
                    if($agency_id == 20197)
                        $chat_id=7712131344;
                    
                    $tel->send($text, $chat_id, null, $keyboardArr);
                       //  $tel->send($text, 689521489);
                   
                }

                if($is_send_max){
                    $max->send_messages_to_user($max_user_id, $text, $attachments);
                }
            }
        }
    }

    /**
     * Получение последних чатов
     */
    public function get_messages($data){
        $agency_id = (int)$data->agency_id;
        $user_id = (int)$data->user_id;
        $user = $data->user;
        if(empty($user)) die();
        $result['chats'] = array();
        $objectIds = array();
        $objects = array();
        
        $sql = "SELECT * FROM cian_chat WHERE agency_id = {$agency_id}";
        if($user->agency > 0 || $user->users_admin > 0 || $user->is_all_cian > 0 || $user->individual){
           // $sql .= " AND agency_id = {$agency_id}";
        } else {
            $sql .= " AND agency_id = {$agency_id} AND user_id = {$user_id}";
        }
        $sql .= "  order by id desc limit 10000";
        //echo $sql;
        $q = $this->dbpg->query($sql);
        $row = $this->dbpg->num_rows($q);
        while($rez = $this->dbpg->fetch_assoc($q)){
            //$rez['is_active'] = ;
            
            //$result['details'][$rez['id']] = json_decode($rez['details'], true);
            //var_dump($result['details'][$rez['id']]);
            $result_temp = json_decode($rez['details'], true);
            if(isset($result_temp['chats'][0]['messages'])){
                foreach($result_temp['chats'][0]['messages'] as $key => $mes){
                    $result_temp['chats'][0]['messages'][0]['new'] = $rez['new'];
                    $result_temp['chats'][0]['messages'][$key]['createdAt'] = date('d.m.Y H:i', strtotime($result_temp['chats'][0]['messages'][$key]['createdAt']));
                    $userName = '';
                    if(is_numeric($result_temp['users'][0]['name'])){
                        $userName = "Пользователь ID ".$result_temp['users'][0]['name'];
                    } else {
                        $userName = $result_temp['users'][0]['name'];
                    }
                    $result_temp['chats'][0]['messages'][$key]['userName'] = $userName;
                    $objectIds[] = (int)$result_temp['offers'][0]['externalId'];
                    $rez['objectId'] = (int)$result_temp['offers'][0]['externalId'];
                    $result_temp['objectId'] = (int)$result_temp['offers'][0]['externalId'];
                    $result['details'][$rez['id']] = $result_temp;
                    $result['details'][$rez['id']]['chats'][0]['update_at'] = date('d.m.Y H:i', strtotime($result['details'][$rez['id']]['chats'][0]['updatedAt']));
                     
                }
            }
            $result['chats'][] = $rez;
        }
       // $result['total_new'] = $row;
        //while($r = $this->db->fetch_assoc($q)){
            //$result
        //}
        $objectIds = array_unique($objectIds);

        //$result['objects_ids'] = $objectIds;
        if(!empty($objectIds)){
            $db_sphinx = new MysqlPdo(hstsph2, null, null, null, true, '9306');
            $sql_obj = "SELECT id, id_add_user FROM objects WHERE id in (".implode(',', $objectIds).") LIMIT 1000000 OPTION max_matches=1000000";
            $q_obj = $db_sphinx->query($sql_obj, true);
            while($obj = $db_sphinx->fetch_assoc($q_obj)){
                $objects[$obj['id']] = $obj;
            }
        }
        foreach($result['chats'] as $key => $chat){
            if(isset($objects[$chat['objectId']])){
                $result['chats'][$key]['id_add_user'] = (int)$objects[$chat['objectId']]['id_add_user'];
                $result['details'][$chat['id']]['id_add_user'] = (int)$objects[$chat['objectId']]['id_add_user'];
            }
        }
        //$result['objects'] = $objects;
        return $result;
    }

    /**
     * Получение последних чатов авито
     */
    public function get_messages_avito($data){
        $agency_id = (int)$data->agency_id;
        $user_id = (int)$data->user_id;
        $user = $data->user;
        $chats = array();
        $chats_list = array();
        //$user = $this->get_user($user_id);
        if(empty($user)) die();
        $result['chats'] = array();

        $messages = array();

        $objects = array();
        $objectIds = array();
        $objectUrls = array();
        $urls = array();
        
        $sql = "SELECT * FROM chat_avito WHERE agency_id = {$agency_id}";
        if($user->agency > 0 || $user->users_admin > 0 || $user->is_all_avito > 0 || $user->individual){
           // $sql .= " AND agency_id = {$agency_id}";
        } else {
            $sql .= " AND user_id = {$user_id}";
        }
        $sql .= " order by update_at_real desc limit 1000";
        if($_SESSION['id'] == 13154){
            //echo $sql;
        }
        $q = $this->dbpg->query($sql);
        //$row = $this->db->num_rows($q);
        while($r = $this->dbpg->fetch_assoc($q)){
            if(!in_array($r['chat_id'], $chats)){
                $chats[] = $r['chat_id'];
                $chats_list[$r['chat_id']] = $r;
            }
        }

        if(!empty($chats)){
            $sql = "SELECT * FROM chat_avito_messages WHERE agency_id = {$agency_id} AND chat_id in ('".implode('\',\'', $chats)."')";
            if($user->agency > 0 || $user->users_admin > 0 || $user->is_all_avito > 0 || $user->individual){
                //$sql .= " AND agency_id = {$agency_id}";
            } else {
                $sql .= " AND user_id = {$user_id}";
            }
            
            $sql .= " order by update_at_real limit 10000";
            
            $q = $this->dbpg->query($sql);
            //$row = $this->db->num_rows($q);
            while($rez = $this->dbpg->fetch_assoc($q)){
                $rez['details'] = json_decode($rez['details'], true);
                $messages[$rez['chat_id']][] = $rez;
            }
        }


        foreach($chats_list as $rez){
           // var_dump($rez);
          //  if(!in_array($rez['chat_id'], $chats)){
               // $chats[] = $rez['chat_id'];    
                //var_dump($messages[$rez['chat_id']]);
                if(isset($messages[$rez['chat_id']])){
                    $rez['details'] = json_decode($rez['details'], true);
                    if(!empty($rez['details'])){
                        if((int)$rez['object_id'] == 0 && (int)$rez['details']['context']['value']['id'] != 0){
                        // var_dump($rez['details']['context']['value']);
                            $objectUrls[] = 'https://www.avito.ru/items/'.$rez['details']['context']['value']['id'];
                            $urls[(int)'https://www.avito.ru/items/'.$rez['details']['context']['value']['id']] = 0;
                        }
                        $rez['update'] = date('d.m.Y H:i', $rez['update_at_real']);
                        $rez['details']['context']['value']['images']['main']['img'] = $rez['details']['context']['value']['images']['main']['140x105'];
                        $rez['new_mess'] = 0;
                        $rez['is_active'] = false;
                        foreach($messages[$rez['chat_id']] as $key => $mes){
                            $userName = $rez['details']['users'][0]['name'];
                            if($mes['details']['payload']['value']['author_id'] == $rez['details']['users'][1]['id']){
                                $userName = $rez['details']['users'][1]['name'];
                            }
                            $messages[$rez['chat_id']][$key]['userName'] = $userName;
                            $messages[$rez['chat_id']][$key]['create'] = date('d.m.Y H:i', $mes['details']['payload']['value']['created']);
                            if($mes['new'] == 1){
                                $rez['new_mess']++;
                            }
                        }
                        $rez['messages'] = $messages[$rez['chat_id']];
                        $result['chats']['chat'.$rez['id']] = $rez;
                    } else {
                        $sql_up = "UPDATE chat_avito_messages SET new = 0 WHERE chat_id = '{$rez['chat_id']}' and new = 1";
                        $this->dbpg->query($sql_up);
                    }
                }
           // }
        }
        $result['urls'] = $objectUrls;
        if(!empty($objectUrls)){
            $sql_stat = "SELECT object_id, url FROM ads_stats WHERE service_id = 1 AND agency_id = {$agency_id} AND url in ('".implode('\',\'', $objectUrls)."')";
            $q_stat = $this->db->query($sql_stat);
            while($r_stat = $this->db->fetch_assoc($q_stat)){
                $objectIds[] = $r_stat['object_id'];
                $urls[(int)str_replace('https://www.avito.ru/items/','',$r_stat['url'])] = $r_stat['object_id'];
            }
            $objectIds = array_unique($objectIds);

            //$result['objects_ids'] = $objectIds;
            if(!empty($objectIds)){
                $db_sphinx = new MysqlPdo(hstsph2, null, null, null, true, '9306');
                $sql_obj = "SELECT id, id_add_user FROM objects WHERE id in (".implode(',', $objectIds).") LIMIT 1000000 OPTION max_matches=1000000";
                $q_obj = $db_sphinx->query($sql_obj, true);
                while($obj = $db_sphinx->fetch_assoc($q_obj)){
                    $objects[$obj['id']] = $obj;
                }
            }
            foreach($result['chats'] as $key => $chat){
                if((int)$result['chats'][$key]['object_id'] == 0){
                    $result['chats'][$key]['object_id'] = $urls[(int)$chat['details']['context']['value']['id']];
                    $result['chats'][$key]['id_add_user'] = (int)$objects[$urls[(int)$chat['details']['context']['value']['id']]]['id_add_user'];
                    if($chat['user_id'] == 0 || $chat['user_id'] == $chat['agency_id']){
                        $user_id = (int)$objects[$urls[(int)$chat['details']['context']['value']['id']]]['id_add_user'];
                        $sql_up_user = "UPDATE chat_avito_messages SET user_id = $user_id WHERE chat_id = '{$chat['chat_id']}'";
                        $this->dbpg->query($sql_up_user);
                        $sql_up_user = "UPDATE chat_avito SET user_id = $user_id WHERE chat_id = '{$chat['chat_id']}'";
                        $this->dbpg->query($sql_up_user);
                    }
                }
               
            }
        }
        return $result;
    }

    public function get_new_messages($data){

        $agency_id = (int)$data->agency_id;
        $user_id = (int)$data->user_id;
        $user = $data->user;
        if(empty($user)) die();
        
        $sql = "SELECT * FROM cian_chat WHERE new=1";
        if($user->agency > 0 || $user->users_admin > 0 || $user->is_all_cian > 0 || $user->individual > 0){
            $sql .= " AND agency_id = {$agency_id}";
        } else {
            $sql .= " AND agency_id = {$agency_id} AND user_id = {$user_id}";
        }
        $sql .= "  order by id desc limit 10000";

        $result = array('total_new'=>0, 'chats' => array());
        //$sql = "SELECT * FROM cian_chat where new=1  order by id desc limit 100";
        $q = $this->dbpg->query($sql);
        $row = $this->dbpg->num_rows($q);
       
        while($rez = $this->dbpg->fetch_assoc($q)){
            
            
            $result['chats'][] = $rez;
           // $result['details'][$rez['id']] = json_decode($rez['details'], true);
            //var_dump($result['details'][$rez['id']]);
            $result_temp = json_decode($rez['details'], true);
            if(isset($result_temp['chats'][0]['messages'])){
                foreach($result_temp['chats'][0]['messages'] as $key => $mes){
                    $result_temp['chats'][0]['messages'][$key]['new'] = $rez['new'];
                    $result_temp['chats'][0]['messages'][$key]['createdAt'] = date('d.m.Y H:i', strtotime($result_temp['chats'][0]['messages'][$key]['createdAt']));
                    $userName = '';
                    if(is_numeric($result_temp['users'][0]['name'])){
                        $userName = "Пользователь ID ".$result_temp['users'][0]['name'];
                    } else {
                        $userName = $result_temp['users'][0]['name'];
                    }
                    $result_temp['chats'][0]['messages'][$key]['userName'] = $userName;
                    $result['details'][$rez['id']] = $result_temp;
                    $result['details'][$rez['id']]['chats'][0]['update_at'] = date('d.m.Y H:i', strtotime($result['details'][$rez['id']]['chats'][0]['updatedAt']));
            
                }
            }
        }
        $result['total_new'] = $row;
        //while($r = $this->db->fetch_assoc($q)){
            //$result
        //}
        return $result;
    }

    /**
     * Получение новых сообщений авито
     */
    public function get_new_messages_avito($data){
        $agency_id = (int)$data->agency_id;
        $user_id = (int)$data->user_id;
        $user = $data->user;
        if(empty($user)) die();
        
        $sql = "SELECT * FROM chat_avito_messages WHERE new=1";
        if($user->agency > 0 || $user->users_admin > 0 || $user->is_all_avito > 0 || $user->individual > 0){
            $sql .= " AND agency_id = {$agency_id}";
        } else {
            $sql .= " AND agency_id = {$agency_id} AND user_id = {$user_id}";
        }
        $sql .= "  order by id desc limit 10000";

        $result = array('total_new'=>0, 'messages' => array());
        //$sql = "SELECT * FROM cian_chat where new=1  order by id desc limit 100";
        $q = $this->dbpg->query($sql);
        $row = $this->dbpg->num_rows($q);
        
        while($rez = $this->dbpg->fetch_assoc($q)){
            
            $result['messages'][$rez['id']] = $rez['id'];
        
        }
        $result['total_new'] = $row;
        //while($r = $this->db->fetch_assoc($q)){
            //$result
        //}
        return $result;
    }

    /**
     * Получение сообщений по чату
     */
    public function get_message_chat($data){
        /*ini_set('display_errors', 1);
error_reporting(E_ALL & ~E_DEPRECATED & ~E_STRICT & ~E_NOTICE);*/
       // var_dump($data);
        $chatId = $data->chatId;
        $chatId = str_replace('chat','',$chatId);
        $sql_up = "UPDATE cian_chat SET new = 0 WHERE chatId = {$chatId}";
        $this->dbpg->query($sql_up);
        $sql = "SELECT * FROM cian_chat WHERE chatid = {$chatId} order by id";
        
        $q = $this->dbpg->query($sql);
        $result = array();
        $temp_chats = array();
        $i = 0;
        $mesages = array();
        while($rez = $this->dbpg->fetch_assoc($q)){
            
            $temp_chats[$i] = json_decode($rez['details'], true);
            foreach($temp_chats[$i]['chats'][0]['messages'] as $key => $mes){
                $temp_chats[$i]['chat_id'] = $rez['chatid'];
                $mes['new'] = $rez['new'];
                $mess_id = $mes['messageId'];
                $mes['createdAt'] = date('d.m.Y H:i', strtotime($mes['createdAt']));
                    $userName = '';
                    
                    $userMesId = $mes['userId'];
                    foreach($temp_chats[$i]['users'] as $userMes){
                        if($userMes['userId'] == $userMesId){
                            if(is_numeric($userMes['name'])){
                                $userName = "Пользователь ID ".$userMes['name'];
                            } else {
                                $userName = $userMes['name'];
                            }
                        }
                    }
                $mes['userName'] = $userName;
                $mesages[$mess_id] = $mes;
            }
            $temp_chats[$i]['count_mes'] = count($temp_chats[$i]['chats'][0]['messages']);

            
            $i++;
        }
       

        if(!empty($temp_chats) &&  !empty($temp_chats[0])){
            $result_temp = $temp_chats[0];
            $messages = array();
            foreach($mesages as $mes){
                $messages[] = $mes;
            }
            $result_temp['chats'][0]['messages'] = $messages;
            $result[0] = $result_temp;
        }
        

        return $result;
    }

    /**
     * 
     */
    public function get_message_chat_avito($data){
        $chatId = $data->chatId;
        $chatId = str_replace('chat','',$chatId);
        $sql = "SELECT * FROM chat_avito  WHERE id = {$chatId}";
        $q = $this->dbpg->query($sql);
        $r = $this->dbpg->fetch_assoc($q);
        $sql_up = "UPDATE chat_avito_messages SET new = 0 WHERE chat_id = '{$r['chat_id']}'";
        $this->dbpg->query($sql_up);
    }

    /**
     * Отметка прочитано
     */
    public function update_read_message($mess_id){
        
        if($this->service > 0 && $mess_id > 0){
            $table = false;
            if($this->service == 1) $table = 'chat_avito_messages';
            if($this->service == 2) $table = 'cian_chat';

            if($table !== false){

                $sql = "UPDATE {$table} SET new = 0 WHERE id = {$mess_id}";
                
                if(!$this->dbpg->query($sql)){
                    file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_cian_sql.txt", date('d.m.y H:i:s').' '.$sql."\n", FILE_APPEND);
                    return array('result'=>'error');
                    
                } else {
                    return array('result'=>'done');
                }
            }
        } else {
            file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_cian_sql.txt", date('d.m.y H:i:s').' service '.$this->service.' id:'.$mess_id."\n", FILE_APPEND);
            return array('result'=>'error');

        }
    }

    /**
     *  Запрос на отправка сообщения из телеграм
     */
    public function query_send_answer($mess_id, $chat_id, $max = false){
        $errors = array();
        $stage = 0;
        $table_event = 'telegram_events';
        $user_field = 'chat_id';
        if($max){
            $table_event = 'max_events';
            $user_field = 'max_user_id';
        }
        if($this->service > 0 && $mess_id > 0){
            $this->db->query("UPDATE {$table_event} SET status = 1 WHERE {$user_field} = {$chat_id}");
            $description = date('d-m-Y H:i:s').' - Запрос на ответ';
            $sql = "INSERT INTO {$table_event} ({$user_field}, mess_id, event, stage, service, description) 
                                                VALUE ({$chat_id}, {$mess_id}, 'answer', 1, {$this->service}, '{$description}')";
            if(!$this->db->query($sql)){
                $errors[] = $this->db->error();
            }
        }
        if(!empty($errors)){
            file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_cian_sql.txt", date('d.m.y H:i:s').' service '.$this->service.' id:'.$mess_id." ".json_encode($errors, JSON_UNESCAPED_UNICODE)."\n", FILE_APPEND);
            return array('result'=>'error');
        }

        return array('result'=>'done', 'stage'=>$stage);

    }

    /**
     * Отправка сообщения ответа из бота телеграм
     */
    public function send_answer($mess_id, $text){
       /* error_reporting(E_ALL | E_STRICT);
        ini_set('display_errors', 1);*/
        file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_cian_sql.txt", date('d.m.y H:i:s').' id:'.$mess_id." text ".$text."\n", FILE_APPEND);
        $service_id = (int)$this->service;
        $service_name = '';
        $table = false;
        if($service_id == 1){
            $table = 'chat_avito_messages';
            $service_name = 'avito';
        } else if ($service_id == 2){
            $table = 'cian_chat';
            $service_name = 'cian';
        } 
        if($table){
            $sql_mess = "SELECT * FROM {$table} WHERE id = {$mess_id}";
            $q_mess = $this->dbpg->query($sql_mess);
            if($this->dbpg->num_rows($q_mess) > 0){
                $r_mess = $this->dbpg->fetch_assoc($q_mess);
                $agency_id = (int)$r_mess['agency_id'];
                if($service_id == 1){
                    $chat_id = $r_mess['chat_id'];
                } else if ($service_id == 2)
                    $chat_id = $r_mess['chatid'];

                $sql = "SELECT * FROM `users_api` AS `api` WHERE `api`.`service_id` = '$service_id' AND `api`.`agency_id` = '$agency_id'";
                if ($query = $this->db->query($sql)) {
                    while($credits = $this->db->fetch_assoc($query)){
                        $api = new AdvertStats();

                        $results = $api->send_message($service_name, $credits['client_id'], $credits['secret_key'], $credits['ext_user_id'], $text, $chat_id);
                        file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_cian_sql.txt", date('d.m.y H:i:s').' service '.$this->service.' id:'.$mess_id." text ".json_encode($results, JSON_UNESCAPED_UNICODE)."\n", FILE_APPEND);
                       
                    }
                } else {
                    //echo $this->db->error();
                    file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_cian_sql.txt", date('d.m.y H:i:s').' service '.$this->service.' id:'.$mess_id." error ".$this->db->error()."\n", FILE_APPEND);
                }
            }
        }
    }


    /**
     *  Отмена отправки сообщения из телеграм
     */
    public function cancel_answer($mess_id, $chat_id, $max= false){
        $table_event = ($max) ? 'max_events' : 'telegram_events';
        $field_user = ($max) ? 'max_user_id' : 'telegramm_chat_id';
        $field_user_event = ($max) ? 'max_user_id' : 'chat_id';
        $errors = array();
        $stage = 0;
        if($this->service > 0 && $mess_id > 0 && $chat_id > 0){
            $sql_ev = "SELECT * FROM {$table_event} WHERE {$field_user_event} = {$chat_id} AND mess_id = {$mess_id} AND event = 'answer' AND status = 0 ORDER BY id DESC LIMIT 1";
            $q_ev = $this->db->query($sql_ev);
            
            if($this->db->num_rows($q_ev) > 0){
                $r_ev = $this->db->fetch_assoc($q_ev);
                   
                $description = mysql_real_escape_string($r_ev['description'] . ' ' . date('d.m.Y H:i:s') . ' - Отправка сообщения отменена');
                $this->db->query("UPDATE {$table_event} SET description = '{$description}', status = 1 WHERE id = {$r_ev['id']}");
                $result['result'] = 'cancel_answer';
            }
                    
            
        }
        if(!empty($errors)){
            file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_cian_sql.txt", date('d.m.y H:i:s').' service '.$this->service.' id:'.$mess_id." ".json_encode($errors, JSON_UNESCAPED_UNICODE)."\n", FILE_APPEND);
            return array('result'=>'error');
        }

        return array('result'=>'done', 'stage'=>$stage);

    }

    /**
     * Добавление заявки
     */
    public function add_req($mess_id, $chat_id, $stage, $mess = null, $event_table = [], $max = false) {
        $errors = array();
        $result = array();

        $table_event = ($max) ? 'max_events' : 'telegram_events';
        $field_user = ($max) ? 'max_user_id' : 'telegramm_chat_id';
        $field_user_event = ($max) ? 'max_user_id' : 'chat_id';

         
        if($this->service > 0 && $mess_id > 0 && $chat_id > 0){
          
            switch ($stage){
                case 0: {
                    $service_id = (int)$this->service;
                    $service_name = '';
                    $table = false;
                    if($service_id == 1){
                        $table = 'chat_avito_messages';
                    } else if ($service_id == 2){
                        $table = 'cian_chat';
                    } 
                    
                    if($table){
                        $objectId = 0;
                        $sql_mess = "SELECT * FROM {$table} WHERE id = {$mess_id}";
                        $q_mess = $this->dbpg->query($sql_mess);
                        $r_mess = $this->dbpg->fetch_assoc($q_mess);
                        $details = json_decode($r_mess['details'], true);
                        if($service_id == 1){
                            $chatid = $r_mess['chat_id'];
                            $sql_chat = "SELECT id, object_id FROM chat_avito WHERE chat_id = '{$chatid}'";
                            $q_chat = $this->dbpg->query($sql_chat);
                            $r_chat = $this->dbpg->fetch_assoc($q_chat);
                            if($r_chat) $objectId = (int)$r_chat['object_id'];
                        } else if ($service_id == 2){ 
                            $objectId = (int)$details['offers'][0]['externalId'];
                        }
                        $user_id = 0;
                        $sql_user = "SELECT * FROM users WHERE {$field_user} = {$chat_id}";
                        $q_user = $this->db->query($sql_user);
                        $r_user = $this->db->fetch_assoc($q_user);
                        $user_id = (int)$r_user['id'];
                        
                        $agency_id = (int)$r_user['company_id'] > 0 ? $r_user['company_id'] : $user_id;
                        if($objectId == 0) 
                            $errors[] = "Объект не найден стадия 1";
                        $this->db->query("UPDATE {$table_event} SET status = 1 WHERE {$field_user_event} = {$chat_id}");
                        $description = date('d-m-Y H:i:s').' - Запрос на добавление';
                        $sql = "INSERT INTO {$table_event} ({$field_user_event}, mess_id, event, stage, service, description, user_id, agency_id, object_id) 
                                                            VALUE ({$chat_id}, {$mess_id}, 'add_req', 1, {$service_id}, '{$description}', {$user_id}, {$agency_id}, {$objectId})";
                        if(!$this->db->query($sql)){
                            $errors[] = $this->db->error();
                        }
                        $stage = 1;

                    } else {
                        $errors[] = "Неверный сервис";
                    }
                    $result = array('result'=>'add_req', 'stage'=>$stage);
                    break;
                }
                case 1:{
                    if(empty($mess)) $errors[] = "Пустое сообщение";
                    $phone = '+'.str_replace(['(', ')', ' ', '-', '+'], '', trim($mess));
                    if(empty($event_table)){
                        $sql_ev = "SELECT * FROM {$table_event} WHERE {$field_user_event} = {$chat_id} AND status = 0 ORDER BY id DESC LIMIT 1";
                        $q_ev = $this->db->query($sql_ev);
                        if($this->db->num_rows($q_ev) > 0){
                            $event_table = $this->db->fetch_assoc($q_ev);
                        }
                    }
                    if(empty($event_table)) $errors[] = "Не найдено связаное событие";
                    if($event_table['object_id'] == 0) $errors[] = "Не найден объект стадия 2";
                    if($event_table['user_id'] == 0) $errors[] = "Не определен user_id";
                    if(empty($errors)){
                        $agency_id = $event_table['agency_id'];
                        $usersIds = array();
                        $wb = new WebHookIn();
                        $usersIds = $wb->getAllUserAgency($agency_id);
                        $sql = "SELECT `id`, `stage`, `deleted`, `fio` FROM `clients` WHERE cancel=0 AND (phone = '$phone'  OR id in (SELECT client_id FROM clients_phone2 WHERE phone = '$phone')) and (id_agent in (".implode(',', $usersIds).")  or who_work in (".implode(',', $usersIds)."))";

                        $client = $this->db->fetch_assoc($this->db->query($sql));
                        if(!empty($client) && $client){
                            $client_id = $client['id'];
                            $description = mysql_real_escape_string($event_table['description'] . ' ' . date('d.m.Y H:i:s') . ' - Найден клиент: ' . $client_id);
                            //if($max === false)
                            $this->db->query("UPDATE {$table_event} SET description = '{$description}', client_id={$client_id}, stage=2, status=0 WHERE id = {$event_table['id']}");
                            $stage = 2;
                            $Funnel = new Funnel();
                            $Funnel->set_agency_id($agency_id);
                            $Funnel->set_user_id($event_table['user_id']);
                            $funnels = $Funnel->get_funnels('requisitions');
                            $result = array('result'=>'add_req', 'stage'=>$stage, 'funnels'=>$funnels, 'service' => $event_table['service'], 'mess_id' => $event_table['mess_id']);
                           
                            
                        } else {
                            $description = mysql_real_escape_string($event_table['description'] . ' ' . date('d.m.Y H:i:s') . ' - Сохранен номер: ' . $phone);
                            $this->db->query("UPDATE {$table_event} SET phone_temp='{$phone}', stage=4 WHERE id = {$event_table['id']}");
                            $stage = 4;
                            $result = array('result'=>'add_req', 'stage'=>$stage, 'service' => $event_table['service'], 'mess_id' => $event_table['mess_id']);
                            
                        }


                    }
                    break;

                    
                }
                case 3: {

                    if(empty($event_table)){
                        $sql_ev = "SELECT * FROM {$table_event} WHERE {$field_user_event} = {$chat_id} AND event='add_req' AND mess_id = $mess_id AND status = 0 ORDER BY id DESC LIMIT 1";
                        $q_ev = $this->db->query($sql_ev);
                        if($this->db->num_rows($q_ev) > 0){
                            $event_table = $this->db->fetch_assoc($q_ev);
                        }
                    }
                    if(empty($event_table)) $errors[] = "Не найдено связаное событие";
                    if($event_table['object_id'] == 0) $errors[] = "Не найден объект стадия 2";
                    if($event_table['user_id'] == 0) $errors[] = "Не определен user_id";
                    if($event_table['client_id'] == 0) $errors[] = "Не определен client_id";
                    if(empty($errors)){
                        $client_id = $event_table['client_id'];
                        $object_id = $event_table['object_id'];
                        $user_id = $event_table['user_id'];
                        $funnel_id_req = $mess;

                        $client = $this->db->fetch_assoc($this->db->query("SELECT * FROM clients WHERE id = {$client_id}"));
                        $name = "Спрос по нашему объекту для ".$client['fio'];
                        $opis = "Создана в боте ТГ";
                        if($max){
                            $opis = "Создана в боте MAX";
                        }
                        $sql_req = "INSERT INTO requisitions SET 
                                                client_id={$client_id}, 
                                                name='{$name}', 
                                                description='{$opis}', 
                                                user_id={$user_id}, 
                                                who_work={$user_id}, 
                                                type_id=4, 
                                                confirm=1, 
                                                funnel_id={$funnel_id_req}, 
                                                stage=1, 
                                                object_id = '{$object_id}',
                                                integration = 15
                                                ";
                                             
                        $this->db->query($sql_req);
                        $req_id = $this->db->insert_id();
                        if($req_id > 0 && $funnel_id_req > 0){
                            $reqClass = new Requisitions($this->db, true);
                            $reqClass->get_class_etap($req_id, $funnel_id_req);
                        }                        
                        $description = mysql_real_escape_string($event_table['description'] . ' ' . date('d.m.Y H:i:s') . ' - Выбрана воронка: ' . $funnel_id_req . ' Добавлена заявка: '.$req_id);
                        $this->db->query("UPDATE {$table_event} SET description = '{$description}', funnel_id_req={$mess}, stage=3, status=1, req_id={$req_id} WHERE id = {$event_table['id']}");
                        $stage = 0;
                        $result = array('result'=>'add_req', 'stage'=>0);
                    }
                    

                    break;        
                }
                case 4:{
                    if(empty($mess)) $errors[] = "Пустое сообщение";
                   // $phone = '+'.str_replace(['(', ')', ' ', '-', '+'], '', trim($mess));
                    if(empty($event_table)){
                        $sql_ev = "SELECT * FROM {$table_event} WHERE {$field_user_event} = {$chat_id} AND status = 0 ORDER BY id DESC LIMIT 1";
                        $q_ev = $this->db->query($sql_ev);
                        if($this->db->num_rows($q_ev) > 0){
                            $event_table = $this->db->fetch_assoc($q_ev);
                        }
                    }
                    if(empty($event_table)) $errors[] = "Не найдено связаное событие";
                    if($event_table['object_id'] == 0) $errors[] = "Не найден объект стадия 2";
                    if($event_table['user_id'] == 0) $errors[] = "Не определен user_id";
                    if(empty($errors)){
                        $agency_id = $event_table['agency_id'];
                        $description = mysql_real_escape_string($event_table['description'] . ' ' . date('d.m.Y H:i:s') . ' - Сохранено имя клиента: ' . $mess);
                        $this->db->query("UPDATE {$table_event} SET fio_temp='{$mess}', description = '{$description}', stage=5 WHERE id = {$event_table['id']}");
                        $stage = 5;
                        $Funnel = new Funnel();
                        $Funnel->set_agency_id($agency_id);
                        $Funnel->set_user_id($event_table['user_id']);
                        $funnels = $Funnel->get_funnels('clients');
                        $result = array('result'=>'add_req', 'stage'=>$stage, 'funnels'=>$funnels, 'service' => $event_table['service'], 'mess_id' => $event_table['mess_id']);
                    
                    }
                    //$stage = 5;
                    //$result = array('result'=>'add_req', 'stage'=>$stage);
                    break;

                }
                case 6: {
                    if(empty($event_table)){
                        $sql_ev = "SELECT * FROM {$table_event} WHERE {$field_user_event} = {$chat_id} AND event='add_req' AND mess_id = $mess_id AND status = 0 ORDER BY id DESC LIMIT 1";
                        $q_ev = $this->db->query($sql_ev);
                        if($this->db->num_rows($q_ev) > 0){
                            $event_table = $this->db->fetch_assoc($q_ev);
                        }
                    }
                    if(empty($event_table)) $errors[] = "Не найдено связаное событие";
                    if($event_table['object_id'] == 0) $errors[] = "Не найден объект стадия 2";
                    if($event_table['user_id'] == 0) $errors[] = "Не определен user_id";
                    
                    if(empty($errors)){
                        $agency_id = $event_table['agency_id'];
                        $user_id = $event_table['user_id'];
                        $funnel_id = $mess;
                        $fio = $event_table['fio_temp'];
                        $phone = $event_table['phone_temp'];
                        $opis = "Создан в боте ТГ";
                        if($max){
                            $opis = "Создан в боте MAX";
                        }
                        $date_add = date('Y-m-d H:i:s');
                        $sql_req = "INSERT INTO clients SET 
                                                fio='{$fio}',
                                                date_add = '{$date_add}', 
                                                phone='{$phone}', 
                                                opis='{$opis}', 
                                                id_agent={$user_id}, 
                                                who_work={$user_id},
                                                confirm=1, 
                                                funnel_id={$funnel_id}, 
                                                stage=1,
                                                integration = 15
                                                ";
                        $this->db->query($sql_req);
                        $client_id = $this->db->insert_id();
                        if($client_id > 0 && $funnel_id > 0){
                            $clientClass = new Clients();
                            $clientClass->get_class_etap($client_id, $funnel_id);
                        }                        
                        $description = mysql_real_escape_string($event_table['description'] . ' ' . date('d.m.Y H:i:s') . ' - Выбрана воронка: ' . $funnel_id . ' Добавлен клиент: '.$client_id);
                        $this->db->query("UPDATE {$table_event} SET description = '{$description}', funnel_id={$mess}, stage=2, status=0, client_id={$client_id} WHERE id = {$event_table['id']}");
                        $stage = 2;
                        $Funnel = new Funnel();
                        $Funnel->set_agency_id($agency_id);
                        $Funnel->set_user_id($event_table['user_id']);
                        $funnels = $Funnel->get_funnels('requisitions');
                        $result = array('result'=>'add_req', 'stage'=>$stage, 'funnels'=>$funnels, 'service' => $event_table['service'], 'mess_id' => $event_table['mess_id']);
                    }
                }
                break;
            }
        } else {
            $errors[] = 'Empty data';
        }
        if(empty($result)){
            $errors[] = "Путой rezult";
        }
        if(!empty($errors)){
            file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_cian_sql.txt", date('d.m.y H:i:s').' service '.$this->service.' id:'.$mess_id." ".json_encode($errors, JSON_UNESCAPED_UNICODE)."\n", FILE_APPEND);
            return array('result'=>'error');
        }
        
        return $result;
    }

    /**
     *  Отмена добавления заявки
     */
    public function cancel_add_req($mess_id, $chat_id, $max = false){
        $table_event = ($max) ? 'max_events' : 'telegram_events';
        $field_user = ($max) ? 'max_user_id' : 'telegramm_chat_id';
        $field_user_event = ($max) ? 'max_user_id' : 'chat_id';
        $errors = array();
        $stage = 0;
        if($this->service > 0 && $mess_id > 0 && $chat_id > 0){
            $sql_ev = "SELECT * FROM {$table_event} WHERE {$field_user_event} = {$chat_id} AND mess_id = {$mess_id} AND event = 'add_req' AND status = 0 ORDER BY id DESC LIMIT 1";
            $q_ev = $this->db->query($sql_ev);
            
            if($this->db->num_rows($q_ev) > 0){
                $r_ev = $this->db->fetch_assoc($q_ev);
                   
                $description = mysql_real_escape_string($r_ev['description'] . ' ' . date('d.m.Y H:i:s') . ' - Создание заявки отменено');
                $this->db->query("UPDATE {$table_event} SET description = '{$description}', status = 1 WHERE id = {$r_ev['id']}");
                $result['result'] = 'cancel_add_req';
            }
                    
            
        }
        if(!empty($errors)){
            file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_avito_cian_sql.txt", date('d.m.y H:i:s').' service '.$this->service.' id:'.$mess_id." ".json_encode($errors, JSON_UNESCAPED_UNICODE)."\n", FILE_APPEND);
            return array('result'=>'error');
        }

        return array('result'=>'done', 'stage'=>$stage);

    }

}