<?php

class CallEvents
{
    public $table = 'call_events';
    public $index = 'id';
    public $fields = array(
        'operator',
        'operator_call_id',
        'internal_number',
        'external_number',
        'transit_number',
        'status',
        'user_id',
        'client_id',
        'agency_id',
        'start_time',
        'answer_time',
        'release_time',
        'uuid_call_id',
        'uuid',


    );
    private $funnel_telephony = array();
    protected $_inputData;
    private $dbpg = null;
   
    public function __construct()
    {
        $this->dbpg = new MysqlPdo(hstpg, ndbpg, 'u0305746_jw', passpg, false, '5432', true);
    }

    public function insert($data)
    {
        
        $query = "INSERT INTO ".$this->table." SET ";
        $query_set = array();
        $array_val = array();
        $array_field = array();
        foreach($this->fields as $field){
            $query_set[] = $field." = '". $data[$field]."'";
            $_data[$field] = $data[$field];
            if(!empty($data[$field])){
                $array_val[] = $data[$field];
                $array_field[] = $field;
            }
        }
        $query .= implode(', ', $query_set);

        mysql_query($query);
        $_data['id'] = mysql_insert_id();
        $querypg = "INSERT INTO ".$this->table." (".implode(',',$array_field).") VALUES ('".implode('\',\'', $array_val)."')";
       // file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_call_sql.txt", $querypg."\n", FILE_APPEND);
        $this->dbpg->query($querypg,true);
        $_data['idpg'] = $this->dbpg->insert_id();
        return $_data;
    }

    public function save($data,$id, $idpg)
    {

        //var_dump($data);
        $query = $querypg = "UPDATE ".$this->table." SET ";
        $query_set = array();
        if($data['redirect']){
            $this->saveRederect($data['redirect'], $idpg);
        }
        unset($data['redirect']);
        if(isset($data['operator_call_id']) && $data['operator'] != 'TELPHIN' && $data['operator'] != 'MEGAFON' ){
            $data['uuid_call_id'] = (int)str_replace(['callhalf-',':'],'', $data['operator_call_id']);
        }
        /*if(isset($data['release_time'])){
            $duration = (int)($data['release_time'] - $data['start_time']);
            var_dump($duration);
            $data['uuid'] = $data['start_time'] + $duration;
        }*/
        foreach($data as $field=>$value){
            if($field != 'id' && $field != 'idpg'){
                $query_set[] = $field." = '". $value."'";
            }
        }
        $query .= implode(', ', $query_set) . " WHERE " . $this->index . " = " .$id;
        $querypg .= implode(', ', $query_set) . " WHERE " . $this->index . " = " .$idpg;
        //file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_call_ev_sql.txt", $querypg."\n", FILE_APPEND);
       // echo $querypg."\n";
        // echo $idpg."\n";
        if($idpg>0){
            $this->dbpg->query($querypg, true);
        }
        if($id>0){
            mysql_query($query);
        }
        return true;
    }

    public function saveRederect($data, $call_id){

       $time = floor($data['xsi:redirectTime']/1000);
       $phone = str_replace('tel:', '',$data['xsi:address']['@content']);
       $user = $this->getUserByField('phone', $phone);
       $sql = "SELECT id FROM `call_events_redirect` WHERE call_id = $call_id and transfer = $time and user_id = $user[id]";

       $q = mysql_query($sql);
       if(mysql_num_rows($q) == 0){
          $sql_u = "INSERT INTO `call_events_redirect` SET call_id = $call_id, transfer = $time, user_id = $user[id], phone = '$phone'";
          mysql_query($sql_u);
       }

    }

    public function selectByField($field, $value, $table = false)
    {
        $result = false;
        $table_table = $this->table;
        if($table){
            $table_table = $table;
        }
        $query = "SELECT * FROM ".$table_table." WHERE $field = '$value'";
        
        if($table != 'telphin_operator_id')
            $arrpg = $this->dbpg->fetch_assoc($this->dbpg->query($query));

        $arr = mysql_fetch_assoc(mysql_query($query));
        if(!empty($arr)){
            if(isset($arrpg))
                $arr['idpg'] = $arrpg['id'];
            $result = $arr;
        } else if (!empty($arrpg)){
            $arrpg['idpg'] = $arrpg['id'];
            $arrpg['id'] = 0;
            $result = $arrpg;
        } 
        
        return $result;
    }

    public function selectByField_pg($field, $value, $table = false)
    {
        $table_table = $this->table;
        if($table){
            $table_table = $table;
        }
        $query = "SELECT * FROM ".$table_table." WHERE $field = '$value'";
        //echo $query."\n";
        return $this->dbpg->fetch_assoc($this->dbpg->query($query));
    }

    public function process($data)
    {
        $this->_inputData = $data;
        //var_dump($data);
        $eventCalls = false;

        if($data['operator'] == 'MTS') {
            $data = $this->getAbonent($data);
           // var_dump($data);
            //die();
        }

        if($data['operator'] == 'MEGAFON') {
            if($data['internal_number'] == '+' && !empty($data['vpbx_id'])){
                $data['internal_number'] = $data['vpbx_id'];
            }
            $this->_inputData = $data;
        }

        if($_data = $this->checkCalls($data['operator_call_id'], $data['operator'], $data['internal_number'])){

            $_data['status'] = $_new_data['status'] = $data['status'];
            if($data['release_time'] != 0){
                $_data['release_time'] = $_new_data['release_time'] =  $data['release_time'];
            }
            if($data['answer_time'] != 0){
                $_data['answer_time'] = $_new_data['answer_time'] =  $data['answer_time'];
            }
            $_data['redirect'] = $_new_data['redirect'] = $data['redirect'];

            $this->save($_new_data,$_data['id'], $_data['idpg']);

            if($data['operator'] == 'TELPHIN'){
                $this->saveCall($data);
            } else if($data['operator'] == 'MEGAFON'){
               
                    $this->saveCallMegafon($data);
                
            }

        } else {
            if($data['operator'] == 'TELPHIN'){
                //var_dump($data);
                $data['uuid_call_id'] = $this->checkID($data);

            } else if ($data['operator'] == 'MEGAFON'){
                $data['uuid_call_id'] = $data['operator_call_id'];
            } else {
                $data['uuid_call_id'] = (int)str_replace(['callhalf-',':'],'', $data['operator_call_id']);
            }
                $eventCalls = $this->insert($data);
                unset($eventCalls['status']);

                if(isset($data['user_id'])){
                    $user = $this->getUserByField('id', [$data['user_id']]);
                } else {
                    $user = $this->getUserByField('vpbx_id', [$data['internal_number'], $data['vpbx_id'], str_replace('@ip.beeline.ru', '', $data['vpbx_id'])]);
                }

                if(!empty($user)){
                    if($user['vpbx_id'] != $data['vpbx_id'] && $user['vpbx_id'] == $data['internal_number'] && $data['operator'] != 'MANGO'){
                        $sql = "UPDATE users SET vpbx_id='".$data['vpbx_id']."' WHERE id = " . $user['id'];
                        mysql_query($sql);
                    }
                    $eventCalls['user_id'] = $addData['user_id'] = $user['id'];
                    if($user['agency'] == 1){
                        $eventCalls['agency_id'] = $addData['agency_id'] = $user['id'];
                    } else {
                        $eventCalls['agency_id'] = $addData['agency_id'] = $this->getAgency($user);
                    }

                    if($eventCalls['agency_id'] == 0){
                        $eventCalls['agency_id'] = $eventCalls['user_id'];
                    }

                    
                    if('+'.str_replace('+','',$data['internal_number']) != '+79258880560' && '+'.str_replace('+','',$data['external_number']) != '+79258880560'){
                        $eventCalls['client_id'] = $this->searchClientByPhone($eventCalls);
                    }
                    

                    $this->save($eventCalls,$eventCalls['id'],$eventCalls['idpg']);


                }

        }
        if($eventCalls && $eventCalls['operator'] == 'TELPHIN'){
            $eventCalls['uuid'] = $data['uuid'];
            $this->saveCall($eventCalls);
        } else if ($eventCalls && $eventCalls['operator'] == 'MEGAFON'){
            $eventCalls['uuid'] = $data['uuid'];
            $this->saveCallMegafon($eventCalls);
        }

    }

    private function getAbonent($data){
        $res = $data;
        if(isset($data['abonentId'])){
            $abonentId = $data['abonentId'];
            $sqlAbonent = "SELECT * FROM mts_users WHERE mts_id = {$abonentId}";
            $qAbonent = mysql_query($sqlAbonent);
            $rAbonent = mysql_fetch_assoc($qAbonent);
            $res['internal_number'] = $rAbonent['phone'];
            $res['agency_id'] = $rAbonent['agency_id'];
            $res['user_id'] = $rAbonent['user_id'];
            $res['vpbx_id'] = $rAbonent['phone'];
        }
        return $res;
    }

    private function checkID($data){
        $res = 0;
        $sql = "SELECT id FROM telphin_operator_id WHERE uuid_call_id = '$data[operator_call_id]'";

        $q = mysql_query($sql);
        if(mysql_num_rows($q) > 0){
            $r = mysql_fetch_assoc($q);
            $res = (int)$r['id'];
        } else {
            $sql_i = "INSERT INTO telphin_operator_id SET uuid_call_id = '$data[operator_call_id]', call_api_id='$data[call_api_id]', uuid='$data[uuid]'";

            if(mysql_query($sql_i)){
                $res = mysql_insert_id();
            }
        }
        return $res;
    }

    private function checkUUId($uuid){
        //var_dump($uuid);
        $res = 0;
        $sql = "SELECT id FROM telphin_uuid WHERE uuid = '$uuid'";
        $q = mysql_query($sql);
        if(mysql_num_rows($q) == 0){
            $sql_i = "INSERT INTO telphin_uuid SET uuid = '$uuid'";
            if(mysql_query($sql_i)){
                $res = mysql_insert_id();
            }
        } else {
            $r = mysql_fetch_assoc($q);
            $res = (int)$r['id'];
        }
        return $res;
    }

    private function saveCall($eventCalls)
    {
        $id_uuid = $this->checkUUId($eventCalls['uuid']);
        //var_dump($id_uuid);
        if($eventCalls['agency_id'] != 12254){
            $query = "SELECT * FROM mango_calls WHERE operator_id = 3 and operator_call_id='".$id_uuid."'";

            $call = mysql_fetch_assoc(mysql_query($query));
            $call_pg = $this->dbpg->fetch_assoc($this->dbpg->query($query));

            if(!empty($eventCalls['answer_time'])){
                    $disconnect_reason = 'answered';
            } else {
                    $disconnect_reason = 'not answered';
            }

            if($call){
                if($eventCalls['start_time'] == 0){
                    $eventCalls['start_time'] = $call['start'];
                }
                if($eventCalls['release_time'] == 0){
                $eventCalls['release_time'] = $call['finish'];
                }
                if($eventCalls['answer_time'] == 0){
                $eventCalls['answer_time'] = $call['answer'];
                }
                if(!isset($eventCalls['agency_id']) || empty($eventCalls['agency_id'])){
                    $eventCalls['agency_id'] = $call['agency_id'];
                }
                if(!isset($eventCalls['client_id']) || empty($eventCalls['client_id'])){
                    $eventCalls['client_id'] = $call['client_id'];
                }
                if($eventCalls['agency_id'] != 12254){
                    $query = "UPDATE `mango_calls` SET
                    `start`= " . $eventCalls['start_time'] . ",
                    `finish`= " . $eventCalls['release_time'] . ",
                    `answer`= " . $eventCalls['answer_time'] . ",
                    `from_number`= '" . $eventCalls['external_number'] . "',
                    `to_extension`='" . $this->_inputData['vpbx_id'] . "',
                    `to_number`='" . $eventCalls['internal_number'] . "',
                    `line_number`='" . strtolower($eventCalls['operator']) . "',
                    `client_id`='".$eventCalls['client_id']."',
                    `agency_id`='" . $eventCalls['agency_id'] . "',
                    `disconnect_reason`='" . $disconnect_reason . "' WHERE
                    `operator_id` = 3 AND
                    `operator_call_id`='".$id_uuid."'
                    ";
                } else {
                    $query = "INSERT INTO `mango_calls` SET
                    `start`= " . $eventCalls['start_time'] . ",
                    `finish`= " . $eventCalls['release_time'] . ",
                    `answer`= " . $eventCalls['answer_time'] . ",
                    `from_number`= '" . $eventCalls['external_number'] . "',
                    `to_extension`='" . $this->_inputData['vpbx_id'] . "',
                    `to_number`='" . $eventCalls['internal_number'] . "',
                    `operator_id` = 3,
                    `line_number`='" . strtolower($eventCalls['operator']) . "',
                    `disconnect_reason`='" . $disconnect_reason . "',
                    `agency_id`='" . $eventCalls['agency_id'] . "',
                    `uuid`='" . $eventCalls['uuid'] . "',
                    `vpbx_id`='".$this->_inputData['vpbx_id']."',
                    `client_id`='".$eventCalls['client_id']."',
                    `operator_call_id`='".$id_uuid."'
                    ";
                }
            }

            if($call_pg){
                if($eventCalls['start_time'] == 0){
                    $eventCalls['start_time'] = $call_pg['start'];
                }
                if($eventCalls['release_time'] == 0){
                $eventCalls['release_time'] = $call_pg['finish'];
                }
                if($eventCalls['answer_time'] == 0){
                $eventCalls['answer_time'] = $call_pg['answer'];
                }
                if(!isset($eventCalls['agency_id']) || empty($eventCalls['agency_id'])){
                    $eventCalls['agency_id'] = $call_pg['agency_id'];
                }
                if(!isset($eventCalls['client_id']) || empty($eventCalls['client_id'])){
                    $eventCalls['client_id'] = $call_pg['client_id'];
                }
                if($eventCalls['agency_id'] != 12254){
                    $querypg = "UPDATE mango_calls SET
                    start= " . $eventCalls['start_time'] . ",
                    finish= " . $eventCalls['release_time'] . ",
                    answer= " . $eventCalls['answer_time'] . ",
                    from_number= '" . $eventCalls['external_number'] . "',
                    to_extension='" . $this->_inputData['vpbx_id'] . "',
                    to_number='" . $eventCalls['internal_number'] . "',
                    line_number='" . strtolower($eventCalls['operator']) . "',
                    client_id='".$eventCalls['client_id']."',
                    agency_id='" . $eventCalls['agency_id'] . "',
                    disconnect_reason='" . $disconnect_reason . "' WHERE
                    operator_id = 3 AND
                    operator_call_id='".$id_uuid."'
                    ";
                } else {
                    $querypg = "INSERT INTO mango_calls (
                        start,
                        finish,
                        answer,
                        from_number,
                        to_extension,
                        to_number,
                        operator_id,
                        line_number,
                        disconnect_reason,
                        agency_id,
                        uuid,
                        vpbx_id,
                        client_id,
                        operator_call_id
                        ) VALUES (
                            " . $eventCalls['start_time'] . ",
                            " . $eventCalls['release_time'] . ",
                            " . $eventCalls['answer_time'] . ",
                            '" . $eventCalls['external_number'] . "',
                            '" . $this->_inputData['vpbx_id'] . "',
                            '" . $eventCalls['internal_number'] . "',
                            3,
                            '" . strtolower($eventCalls['operator']) . "',
                            '" . $disconnect_reason . "',
                            '" . $eventCalls['agency_id'] . "',
                            '" . $eventCalls['uuid'] . "',
                            '".$this->_inputData['vpbx_id']."',
                            '".$eventCalls['client_id']."',
                            '{$id_uuid}'
                        )
                        ";
                }
            }
        }
        //echo $query;
       mysql_query($query);
       $this->dbpg->query($querypg);
    }


    //Сохранение звонка Мегафон
    private function saveCallMegafon($eventCalls){

        //var_dump($this->_inputData['user']);
        $query = "SELECT * FROM mango_calls WHERE operator_id = 4 and operator_call_id='".$eventCalls['operator_call_id']."'";

        //$call = mysql_fetch_assoc(mysql_query($query));

        $call_pg = $this->dbpg->fetch_assoc($this->dbpg->query($query));

        if(!empty($eventCalls['answer_time'])){
                $disconnect_reason = 'answered';
        } else {
                $disconnect_reason = 'not answered';
        }

        $to_number = $eventCalls['internal_number'];
        //var_dump($eventCalls['agency_id']);
        if($eventCalls['agency_id'] > 0){
            $sql_u = "SELECT * FROM agency_megafon WHERE agency_id=$eventCalls[agency_id]";
           // echo $sql_u;
            $q_u = mysql_query($sql_u);
            $r_u = mysql_fetch_assoc($q_u);
            if($r_u){
                $url_main = explode("/", str_replace("https://", "", $r_u['url']))[0];
                $to_number = $this->_inputData['user'].'@'.$url_main;
                echo $to_number;
            }
        }

       /* if($call){
            if($eventCalls['start_time'] == 0){
                $eventCalls['start_time'] = $call['start'];
            }
            if($eventCalls['release_time'] == 0){
               $eventCalls['release_time'] = $call['finish'];
            }
            if($eventCalls['answer_time'] == 0){
               $eventCalls['answer_time'] = $call['answer'];
            }
            if(!isset($eventCalls['agency_id']) || empty($eventCalls['agency_id'])){
                $eventCalls['agency_id'] = $call['agency_id'];
            }
            if(!isset($eventCalls['client_id']) || empty($eventCalls['client_id'])){
                $eventCalls['client_id'] = $call['client_id'];
            }
            $query = "UPDATE `mango_calls` SET
              `start`= " . $eventCalls['start_time'] . ",
              `finish`= " . $eventCalls['release_time'] . ",
              `answer`= " . $eventCalls['answer_time'] . ",
              `from_number`= '" . $eventCalls['external_number'] . "',
              `line_number`='" . strtolower($eventCalls['operator']) . "',
              `client_id`='".$eventCalls['client_id']."',
              `agency_id`='" . $eventCalls['agency_id'] . "',
              `disconnect_reason`='" . $disconnect_reason . "' WHERE
               `operator_id` = 4 AND
              `operator_call_id`='".$eventCalls['operator_call_id']."'
              ";
        } else {
            $query = "INSERT INTO `mango_calls` SET
              `start`= " . $eventCalls['start_time'] . ",
              `finish`= " . $eventCalls['release_time'] . ",
              `answer`= " . $eventCalls['answer_time'] . ",
              `from_number`= '" . $eventCalls['external_number'] . "',
              `to_extension`='" . $to_number . "',
              `to_number`='" . $to_number . "',
              `operator_id` = 4,
              `line_number`='" . strtolower($eventCalls['operator']) . "',
              `disconnect_reason`='" . $disconnect_reason . "',
              `agency_id`='" . $eventCalls['agency_id'] . "',
              `uuid`='" . $eventCalls['uuid'] . "',
              `vpbx_id`='".$this->_inputData['vpbx_id']."',
              `client_id`='".$eventCalls['client_id']."',
               `operator_call_id`=".$eventCalls['operator_call_id']."
              ";
        }
       // echo $query;
       mysql_query($query);*/

       if($call_pg){
            if($eventCalls['start_time'] == 0){
                $eventCalls['start_time'] = $call_pg['start'];
            }
            if($eventCalls['release_time'] == 0){
            $eventCalls['release_time'] = $call_pg['finish'];
            }
            if($eventCalls['answer_time'] == 0){
            $eventCalls['answer_time'] = $call_pg['answer'];
            }
            if(!isset($eventCalls['agency_id']) || empty($eventCalls['agency_id'])){
                $eventCalls['agency_id'] = $call_pg['agency_id'];
            }
            if(!isset($eventCalls['client_id']) || empty($eventCalls['client_id'])){
                $eventCalls['client_id'] = $call_pg['client_id'];
            }
            $query_pg = "UPDATE mango_calls SET
            start= " . $eventCalls['start_time'] . ",
            finish= " . $eventCalls['release_time'] . ",
            answer= " . $eventCalls['answer_time'] . ",
            from_number= '" . $eventCalls['external_number'] . "',
            line_number='" . strtolower($eventCalls['operator']) . "',
            client_id='".$eventCalls['client_id']."',
            agency_id='" . $eventCalls['agency_id'] . "',
            disconnect_reason='" . $disconnect_reason . "' WHERE
            operator_id = 4 AND
            operator_call_id='".$eventCalls['operator_call_id']."'
            ";
        } else {
            $query_pg = "INSERT INTO mango_calls SET
            start= " . $eventCalls['start_time'] . ",
            finish= " . $eventCalls['release_time'] . ",
            answer= " . $eventCalls['answer_time'] . ",
            from_number= '" . $eventCalls['external_number'] . "',
            to_extension='" . $to_number . "',
            to_number='" . $to_number . "',
            operator_id = 4,
            line_number='" . strtolower($eventCalls['operator']) . "',
            disconnect_reason='" . $disconnect_reason . "',
            agency_id='" . $eventCalls['agency_id'] . "',
            uuid='" . $eventCalls['uuid'] . "',
            vpbx_id='".$this->_inputData['vpbx_id']."',
            client_id='".$eventCalls['client_id']."',
            operator_call_id='".$eventCalls['operator_call_id']."'
            ";
        }
        $this->dbpg->query($query_pg);
    }

    private function getAgency($user){
          if($user['agency'] == 1) return $user['id'];
          if($user['id_manager'] > 0){
              $query = "SELECT * FROM users WHERE id = ".$user['id_manager'];
              $result = mysql_fetch_assoc(mysql_query($query));
              if($result['agency'] == 1) return $result['id'];
              return $this->getAgency($result);
          }
    }
    private function checkCalls($value, $operator, $internal_number)
    {
        if($operator == 'TELPHIN'){

            $table = 'telphin_operator_id';
            $valArr = $this->selectByField('uuid_call_id', $value, $table);
            if($valArr){
                return $this->selectByField('uuid_call_id', $valArr['id']);
            } else {
                return $valArr;
            }
        } else if($operator == 'MEGAFON'){
            $result = false;
            $table_table = $this->table;
            $query = "SELECT * FROM ".$table_table." WHERE uuid_call_id = '$value' AND internal_number = '{$internal_number}'";
           // echo $query."\n";
            $arr = mysql_fetch_assoc(mysql_query($query));
            $arrpg = $this->dbpg->fetch_assoc($this->dbpg->query($query));
            if(!empty($arr)){
                $arr['idpg'] = (int)$arrpg['id'];
                $result = $arr;
            } else if (!empty($arrpg)){
                $arrpg['idpg'] = $arrpg['id'];
                $arrpg['id'] = 0;
                $result = $arrpg;
            }
            return $result;
            //return $this->selectByField('uuid_call_id', $value);
        } else if ($operator == 'MANGO'){
            return $this->selectByField('operator_call_id', $value);

        } else {
            $val = (int)str_replace(['callhalf-',':'],'', $value);
            return $this->selectByField('uuid_call_id', $val);
        }
    }

    protected function getUserByField($field, $value)
    {
        if(is_array($value)){
            foreach($value as $_v){
                $_ar[] = "'$_v'";
            }
            $query = "SELECT * FROM users WHERE $field in (".implode(',', $_ar).") LIMIT 1";
        }
        else $query = "SELECT * FROM users WHERE $field = '$value' LIMIT 1";
       // echo $query;
        return mysql_fetch_assoc(mysql_query($query));
    }
    protected function getUsersByField($field, $value)
    {

        if(is_array($value)){
            foreach($value as $_v){
                $_ar[] = "'$_v'";
            }
            $query = "SELECT * FROM users WHERE $field in (".implode(',', $_ar).")";
        } else {
            $query = "SELECT * FROM users WHERE $field = '$value'";
        }

        $result = mysql_query($query);
        $list = [];

        if(mysql_num_rows($result) >0){
            while($row = mysql_fetch_assoc($result)){

                $list[] = $row;
            }
        }
        return $list;
    }

    public function funnel_tel($agency_id){
      $funnel_telephony = array();
      $sql_f_t = "SELECT * FROM funnel_telephony WHERE agency_id = {$agency_id}";
      $q_f_t = mysql_query($sql_f_t);
      while($r_f_t = mysql_fetch_assoc($q_f_t)){
          $funnel_telephony[] = $r_f_t;
      }
      if(!empty($funnel_telephony)){
        $this->funnel_telephony = $funnel_telephony;
      }
    }

    protected function searchClientByPhone($data)
    {
       
        if(($data['agency_id']== 15401 && '+'.str_replace('+','',$this->_inputData['internal_number']) != '+79215648879')  
            || $data['agency_id'] == 18205){
            die();
        }
        $phone = $data['external_number'];
        $user_id = $data['agency_id'];
        $users = [];

        $w = new WebHookIn();
        $users = $w->getAllUserAgency($user_id);

        //$users = array_keys($this->getAllUserAgency($user_id, $users));

        $sql = "SELECT `id`, `stage`, `deleted`, `source` 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(',', $users)."))";
        //file_put_contents($_SERVER['DOCUMENT_ROOT']."/callevents/log_query.txt", $sql."\n", FILE_APPEND);
        if($data['agency_id'] == 8826){
            if($data['user_id'] == 11868) usleep(1000000);
            if($data['user_id'] == 11864) usleep(1500000);
        } else if ($data['agency_id'] == 12061){
            if($data['user_id'] == 17835) usleep(1000000);
            if($data['user_id'] == 12660) usleep(1500000);
            if($data['user_id'] == 12064) usleep(2000000);
            if($data['user_id'] == 12710) usleep(500000);
            if($data['user_id'] == 14648) usleep(1700000);
            if($data['user_id'] == 12659) usleep(2100000);
        }
        $client = mysql_fetch_assoc(mysql_query($sql));
        if(empty($client) && $data['agency_id'] != 11456){
            $client['phone'] = $phone;
            $client['fio'] = "Новый клиент " . $this->_inputData['operator_rus'];
            if($data['agency_id'] == 9588){
              $client['fio'] = "Новый клиент ".$phone;
            } else if ($data['agency_id'] == 12061) {
                $client['fio'] = "Новый клиент " . $this->_inputData['operator_rus'] . " " . $phone;
            }
            $client['opis'] = "Клиент записан по входящему звонку в ".$this->_inputData['operator'];
            $client['date_add'] = date('Y-m-d H:i:s');
            $client['id_agent'] = $data['user_id'];
            $client['who_work'] = $data['user_id'];
            $client['stage'] = 1;
            $client['confirm'] = 1;
            if ($data['agency_id'] == 13154 && '+'.str_replace('+','',$this->_inputData['internal_number']) == '+79111111702'){
                $client['who_work'] = 0;
                $client['confirm'] = 0;
                $client['source'] = 1678;
                
            }

            if ($data['agency_id'] == 12461){
                $client['who_work'] = 0;
                $client['confirm'] = 0;
            }
            
            if($data['agency_id'] == 9588){
               $client['funnel_id'] = 340;
            } else if($data['agency_id'] == 10732){
               $client['funnel_id'] = 441;
            } else if ($data['agency_id'] == 12461){
                $funnel_id = 1854;
            }
            $funnel_id = 0;
            $this->funnel_tel($data['agency_id']);
            if(!empty($this->funnel_telephony)){
              foreach($this->funnel_telephony as $funnel_t){
                if($funnel_t['phone'] == '+'.str_replace('+','',$this->_inputData['internal_number'])){
                  if((int)$funnel_t['funnel_id'] > 0){
                    $funnel_id = (int)$funnel_t['funnel_id'];

                  }
                }
              }
            } else if ($data['agency_id'] == 10387) {
              $funnel_id = 484;
            } else if($data['agency_id'] == 8435) {
                $funnel_id = 503;
            } else if ($data['agency_id'] == 7384){
                $funnel_id = 75;
            } else if ($data['agency_id'] == 8826 || $data['agency_id'] == 12061) {
                $sourse_number = '+'.str_replace('+','',$this->_inputData['internal_number']);
                if($this->_inputData['operator'] == 'MEGAFON' && !empty($this->_inputData['transit_number'])){
                    $sourse_number = '+'.str_replace('+','',$this->_inputData['transit_number']);
                }
                $resS = $this->findSource($sourse_number, $data['agency_id']);
                if(isset($resS['id'])){
                    $responce['source'] = $resS['id'];
                } else {
                    $responce['source'] = 0;
                }
                $client['source'] = $responce['source'];
            } else if($data['agency_id'] == 14191){
                $funnel_id = 844;
            } else if($data['agency_id'] == 16001){
                $funnel_id = 994;
            } else if($data['agency_id'] == 12028){
                $funnel_id = 996;
            } else if($data['agency_id'] == 17460){
                $funnel_id = 1159;
            } else if($data['agency_id'] == 17664){
                $funnel_id = 1180;
            } else if($data['agency_id'] == 17328){
                $funnel_id = 1183;
            } else if($data['agency_id'] == 19322){
                $funnel_id = 1447;
            } else if ($data['agency_id'] == 21213) {
                    $funnel_id = 1793;
            } else if ($data['agency_id'] == 20624){
                $funnel_id = 1832;
            } else if ($data['agency_id'] == 18631){
                $funnel_id = 1350;
            }  else if ($data['agency_id'] == 22432){
                $funnel_id = 2118;
            } else if($data['agency_id'] == 22311){
                $funnel_id = 2106;
            } else if($data['agency_id'] == 22604){
                $funnel_id = 2184;
            } else if($data['agency_id'] == 18846){
                $funnel_id = 2197;
            } 

            if($funnel_id > 0){
              $client['funnel_id'] = $funnel_id;
            }
            if($data['agency_id'] == 12343 && '+'.str_replace('+','',$this->_inputData['internal_number']) == '+79284369993'){ 
                $client['id'] = $this->insertClient($client);
            } else {
                $client['id'] = $this->insertClient($client);
            }
            if($data['agency_id'] == 9588){
               $clientClass = new Clients;
               $clientClass->get_class_etap($client['id'], 340);
            } else
            if($data['agency_id'] == 10732){
               $clientClass = new Clients;
               $clientClass->get_class_etap($client['id'], 441);
            }
            if($funnel_id > 0){
              $clientClass = new Clients;
              $clientClass->get_class_etap($client['id'], $funnel_id);
            }
            if($this->_inputData['operator'] == 'MTS' && $data['agency_id'] == 12061){
                /*** */
            } else 
            if($data['agency_id'] != 7864 && $data['agency_id'] != 8826 && $data['agency_id'] != 11082 && $data['agency_id'] != 12254 && $data['agency_id'] != 12343 && $data['agency_id'] != 12482 && $data['agency_id'] != 12762 
            && $data['agency_id'] != 13285 && $data['agency_id'] != 12556 && $data['agency_id'] != 13394 && $data['agency_id'] != 13430 && $data['agency_id'] != 13934 && $data['agency_id'] != 14191
            && $data['agency_id'] != 14310 && $data['agency_id'] != 12061 && $data['agency_id'] != 14700 && $data['agency_id'] !=11417 && $data['agency_id'] != 17328 && $data['agency_id'] !=16001 && $data['agency_id'] !=16444 
            && $data['agency_id'] != 16490 && $data['agency_id'] != 14548 && $data['agency_id'] != 17157 && $data['agency_id'] != 17832 && $data['agency_id'] != 18455 && $data['agency_id'] != 18785 
            && $data['agency_id'] != 16553 && $data['agency_id'] != 19111 && $data['agency_id'] != 19322 && $data['agency_id'] != 18708 && $data['agency_id'] != 20406 && $data['agency_id'] != 20382 && $data['agency_id'] != 20624 
            && $data['agency_id'] != 12461 && $data['agency_id'] != 18631 && $data['agency_id'] != 21951 && $data['agency_id'] != 4 && $data['agency_id'] != 22432 && $data['agency_id'] != 18846 && $data['agency_id'] != 23103 
            && $data['agency_id'] != 23065){
                $req['client_id'] = $client['id'];
                $req['user_id'] = $data['user_id'];
                $req['who_work'] = $data['user_id'];
                $req['stage'] = 1;
                $req['confirm'] = 1;
                $req['integration'] = 2;
                $req['call_id'] = $this->_inputData['operator_call_id'];

                $req['type_id'] = 1; // @todo: возможно будет изменяться в будующем
                if($data['agency_id'] == 20669){
                    $req['type_id'] = 2;
                }
                $nameDef = "Новая заявка ".$this->_inputData['operator_rus'];
                if($data['agency_id'] == 9588){

                $nameDef = "Новая заявка ".$phone;
                } else if($data['agency_id'] == 10732){
                if('+'.str_replace('+','',$this->_inputData['internal_number']) == '+79673597249' || '+'.str_replace('+','',$this->_inputData['internal_number']) == '+79673400161'){
                    $nameDef = "Новый кандидат";
                }
                }

                switch ($req['type_id']) {
                    case 1:
                        {
                        $req['name'] = "Подбор объекта для " . $client['fio'];
                        if($data['agency_id'] == 10732){
                            if('+'.str_replace('+','',$this->_inputData['internal_number']) == '+79673597249' || '+'.str_replace('+','',$this->_inputData['internal_number']) == '+79673400161'){
                            $req['name'] = "Новый кандидат";
                            }
                        }
                        }
                        break;
                    case 2:
                        $req['name'] = "Реализация объекта для " . $client['fio'];
                        break;
                    case 3:
                        $req['name'] = "Другие услуги для " . $client['fio'];
                        break;
                    case 4:
                        $req['name'] = "Спрос по нашему объекту для " . $client['fio'];
                        break;
                    default :
                        $req['name'] = $nameDef;
                }

                if($data['agency_id'] == 9588){
                $req['funnel_id'] = 340;
                }
                if($data['agency_id'] == 10732){
                $req['funnel_id'] = 441;
                }
                if($data['agency_id'] == 10387){
                $funnel_id = 482;
                }
                if($data['agency_id'] == 11082){
                    $funnel_id = 479;
                }
                if($data['agency_id'] == 8435){
                    $funnel_id = 503;
                }
                else if($data['agency_id'] == 10429) {
                    $funnel_id = 551;
                } else if($data['agency_id'] == 12061) {
                    $funnel_id = 573;
                } else if($data['agency_id'] == 13339){
                    $funnel_id = 665;
                } else if($data['agency_id'] == 12569){
                    $funnel_id = 742;
                } else if($data['agency_id'] == 13386){
                    $funnel_id = 796;
                } else if($data['agency_id'] == 12028){
                    $funnel_id = 997;
                } else if($data['agency_id'] == 17460){
                    $funnel_id = 1159;
                } else if($data['agency_id'] == 17664){
                    $funnel_id = 1180;
                } else if($data['agency_id'] == 19322){
                    $funnel_id = 1447;
                } else if($data['agency_id'] == 19843){
                    $funnel_id = 1614;
                } else if($data['agency_id'] == 20669){
                    $funnel_id = 1675;
                } else if($data['agency_id'] == 19909){
                    $funnel_id = 1613;
                } else if($data['agency_id'] == 19570) {
                    $funnel_id = 1484;
                } else if ($data['agency_id'] == 21213) {
                    $funnel_id = 1793;
                } else if ($data['agency_id'] == 20624){
                    $funnel_id = 1832;
                } else if ($data['agency_id'] == 20947){
                    $funnel_id = 1819;
                } else if ($data['agency_id'] == 21422){
                    $funnel_id = 1858;
                } else if ($data['agency_id'] == 21790) {
                    $funnel_id = 1980;
                } else if ($data['agency_id'] == 19750) {
                    $funnel_id = 1985;
                } else if($data['agency_id'] == 22311){
                    $funnel_id = 2106;
                } else if($data['agency_id'] == 18479){
                    $funnel_id = 2156;
                } else if($data['agency_id'] == 22604){
                    $funnel_id = 2184;
                } else if ($data['agency_id'] == 22666) {
                    $funnel_id = 2096;
                } else if($data['agency_id'] == 22983){
                    $funnel_id = 2175;
                } else if($data['agency_id'] == 23156){
                    
                      $funnel_id = 2299;
                }else if ($data['agency_id'] == 23360){
                    $funnel_id = 2424;
                }

                if($funnel_id > 0){
                $req['funnel_id'] = $funnel_id;
                }
                $source = 0;

                if(str_replace(['+7', '@ip.beeline.ru'], '', $data['internal_number']) != 'SIP00SKIU0133O' && str_replace(['+7', '@ip.beeline.ru'], '', $data['internal_number']) != 'SIP00SKIU00QVJ') {
                    $req['description'] = "Заявка создана по входящему звонку в ".$this->_inputData['operator'];

                            $sourse_number = '+'.str_replace('+','',$this->_inputData['internal_number']);
                        if($this->_inputData['operator'] == 'MEGAFON' && !empty($this->_inputData['transit_number'])){
                            $sourse_number = '+'.str_replace('+','',$this->_inputData['transit_number']);
                        }
                        $resS = $this->findSource($sourse_number, $data['agency_id']);
                    if(isset($resS['id'])){
                        $responce['source'] = $resS['id'];
                    } else {
                        $responce['source'] = 0;
                    }

                    if(isset($responce['source']) && $responce['source'] > 0){
                        $source = $responce['source'];
                    }

                    $req['source'] = $source;
                    if ($data['agency_id'] == 13154 && '+'.str_replace('+','',$this->_inputData['internal_number']) == '+79111111702'){
                        $req['who_work'] = 0;
                        $req['confirm'] = 0;
                        $req['source'] = 1678;
                        
                    }
                    

                    $req['id'] = $this->insertReq($req);
                    if($data['agency_id'] == 13339){
                       // file_put_contents(__DIR__.'/log_test_megafon.txt', $req['id']. "\n", FILE_APPEND); 
                        
                        $sql_in_ev = "INSERT INTO user_client_events (user_id, req_id, create_date, schedule_date, `type`, comment, calendar_view, from_id) ".
                                            "VALUES ({$data['user_id']}, {$req['id']}, '".date('Y-m-d H:i:s')."', '".date('Y-m-d H:i:s', strtotime('+30 minutes'))."', 'call', '".$req['description']."', 0, {$data['user_id']})";
                        //file_put_contents(__DIR__.'/log_test_megafon.txt', $sql_in_ev. "\n", FILE_APPEND);              
                        mysql_query($sql_in_ev);
                    }
                    if($data['agency_id'] == 9588){
                        $pdo = new MysqlPdo(hst, ndb, user, pass);
                        $sql = "SET NAMES 'utf8'";
                        $pdo->query($sql);
                        $reqClass = new Requisitions($pdo);

                        $reqClass->get_class_etap($req['id'], 340);
                    } else
                    if($data['agency_id'] == 10732){
                    $reqClass = new Requisitions();
                    $reqClass->get_class_etap($req['id'], 441);
                    }
                    if($funnel_id > 0){
                    $reqClass = new Requisitions();
                    $reqClass->get_class_etap($req['id'], $funnel_id);
                    }
                }
            }
        }
        else {
            if($this->_inputData['operator'] == 'MTS' && $data['agency_id'] == 12061){
                /*** */
            } else 
            if($data['agency_id'] != 7864 && $data['agency_id'] != 11456 && $data['agency_id'] != 8826 && $data['agency_id'] != 11082 && $data['agency_id'] != 12254 && $data['agency_id'] != 12343 && $data['agency_id'] != 12482 && $data['agency_id'] != 12762 && $data['agency_id'] != 13285 
                && $data['agency_id'] != 12556 && $data['agency_id'] != 13394 && $data['agency_id'] != 13430 && $data['agency_id'] != 13934 && $data['agency_id'] != 14191 && $data['agency_id'] != 14310 && $data['agency_id'] != 12061 
                && $data['agency_id'] != 14700 && $data['agency_id'] !=11417 && $data['agency_id'] != 17328 && $data['agency_id'] !=16001 && $data['agency_id'] !=16444 && $data['agency_id'] != 16490 
                && $data['agency_id'] != 14548 && $data['agency_id'] != 17157 && $data['agency_id'] != 17832 && $data['agency_id'] != 18455 && $data['agency_id'] != 18785 && $data['agency_id'] != 16553 && $data['agency_id'] != 19111 && 
                $data['agency_id'] != 19322 && $data['agency_id'] != 18708 && $data['agency_id'] != 20406 && $data['agency_id'] != 20382 && $data['agency_id'] != 20624 && $data['agency_id'] != 12461 && $data['agency_id'] != 18631 && 
                $data['agency_id'] != 21951 && $data['agency_id'] != 4 && $data['agency_id'] != 22432 && $data['agency_id'] != 18846 && $data['agency_id'] != 23103 && $data['agency_id'] != 23065) {
                $this->checkReq($data, $client['id']);
            }
            if ($client['stage'] == 8 or $client['deleted'] == 1) {
                $sql = "UPDATE `clients` SET stage = 1, deleted = 0, who_work = ".$data['user_id']." WHERE id = ".$client['id'];
                mysql_query($sql);
            }

            if($data['agency_id'] == 8826 || $data['agency_id'] == 12061){
                if((int)$client['source'] == 0 ){
                    $sourse_number = '+'.str_replace('+','',$this->_inputData['internal_number']);
                    if($this->_inputData['operator'] == 'MEGAFON' && !empty($this->_inputData['transit_number'])){
                        $sourse_number = '+'.str_replace('+','',$this->_inputData['transit_number']);
                    }
                    $resS = $this->findSource($sourse_number, $data['agency_id']);
                        if(isset($resS['id'])){
                            $source = $resS['id'];
                        } else {
                            $source = 0;
                        }
                    //$source = $this->findSource('+'.str_replace('+','',$this->_inputData['internal_number']), $data['agency_id']);
                    if($source > 0){
                        $sql = "UPDATE `clients` SET source='{$source}' WHERE id = ".$client['id'];
                        mysql_query($sql);
                    }
                }
            }
        
        }
        return $client['id'];
    }

    protected function insertClient($client)
    {
        $query = "INSERT INTO clients SET ";
        $query_set = array();

        foreach($client as $field => $value){
            $query_set[] = $field." = '". $value."'";
        }
        $query .= implode(', ', $query_set);

        mysql_query($query);
        return mysql_insert_id();
    }

    protected function insertReq($req)
    {
        $query = "INSERT INTO requisitions SET ";
        $query_set = array();

        foreach($req as $field => $value){
            $query_set[] = $field." = '". $value."'";
        }
        $query .= implode(', ', $query_set);

        mysql_query($query);
        return mysql_insert_id();
    }

    protected function checkReq($data, $client_id)
    {
        $user_id = $data['user_id'];
        $sql = "SELECT id, name FROM requisitions WHERE client_id = $client_id AND who_work = $user_id AND deleted = 0 AND cancel = 0";
        if($data['agency_id'] == 13154){
            $sql = "SELECT id, name FROM requisitions WHERE client_id = $client_id AND who_work = $user_id AND cancel = 0";
        }
        $q = mysql_query($sql);
        if(mysql_num_rows($q) == 0){

            $req['type_id'] = 1; // @todo: возможно будет изменяться в будующем
            if($data['agency_id'] == 20669){
                $req['type_id'] = 2;
            }
            $nameDef = "Новая заявка ".$this->_inputData['operator_rus'];
            $sql = "SELECT * FROM `clients` WHERE `id` = $client_id";
            if ($client = mysql_fetch_assoc(mysql_query($sql))) {

                if($data['agency_id'] == 9588){
                  $client['fio'] = $client['fio']." ".$client['phone'];
                  $nameDef = "Новая заявка ".$client['phone'];
                }
                switch ($req['type_id']) {
                    case 1:
                        {
                          $req['name'] = "Подбор объекта для " . $client['fio'];
                          if($data['agency_id'] == 10732){
                            if('+'.str_replace('+','',$this->_inputData['internal_number']) == '+79673597249' || '+'.str_replace('+','',$this->_inputData['internal_number']) == '+79673400161'){
                              $req['name'] = "Новый кандидат";
                            }
                          }
                        }
                        break;
                    case 2:
                        $req['name'] = "Реализация объекта для " . $client['fio'];
                        break;
                    case 3:
                        $req['name'] = "Другие услуги для " . $client['fio'];
                        break;
                    case 4:
                        $req['name'] = "Спрос по нашему объекту для " . $client['fio'];
                        break;
                    default :
                        $req['name'] = $nameDef;
                }
            } else {
                $req['name'] = $nameDef;
            }

            $req['client_id'] = $client_id;
            $req['user_id'] = $user_id;
            $req['who_work'] = $user_id;
            $req['stage'] = 1;
            $req['confirm'] = 1;
            $req['integration'] = 2;

            $req['call_id'] = $this->_inputData['operator_call_id'];

            $req['description'] = "Заявка создана по входящему звонку в ".$this->_inputData['operator'];

            if($data['agency_id'] == 9588){
               $req['funnel_id'] = 340;
            } else if($data['agency_id'] == 10732){

              $req['funnel_id'] = 441;
            } else if($data['agency_id'] == 8435){
                $req['funnel_id'] = 503;
            } else if($data['agency_id'] == 17460){
                $funnel_id = 1159;
            } else if($data['agency_id'] == 19322){
                $funnel_id = 1447;
            }else if($data['agency_id'] == 19843){
                $funnel_id = 1614;
            } else if($data['agency_id'] == 20669){
                    $funnel_id = 1675;
            } else if ($data['agency_id'] == 21213) {
                    $funnel_id = 1793;
            } else if ($data['agency_id'] == 20624){
                $funnel_id = 1832;
            } else if ($data['agency_id'] == 20553){
                $funnel_id = 1897;
            } 
            
            $this->funnel_tel($data['agency_id']);
            $funnel_id = 0;
            if(!empty($this->funnel_telephony)){
              foreach($this->funnel_telephony as $funnel_t){
                if($funnel_t['phone'] == '+'.str_replace('+','',$this->_inputData['internal_number'])){
                  if((int)$funnel_t['funnel_id'] > 0){
                    $funnel_id = (int)$funnel_t['funnel_id'];

                  }
                }
              }
            } else if($data['agency_id'] == 10387){
              $funnel_id = 482;
            } else if($data['agency_id'] == 11082){
                $funnel_id = 479;
            } else if($data['agency_id'] == 10429){
                $funnel_id = 551;
            } else if ($data['agency_id'] == 7384){
                $funnel_id = 75;
            } else if($data['agency_id'] == 12061) {
                $funnel_id = 573;
            } else if($data['agency_id'] == 13339){
                $funnel_id = 665;
            } else if($data['agency_id'] == 12569){
                $funnel_id = 742;
            } else if($data['agency_id'] == 13386){
                $funnel_id = 796;
            } else if($data['agency_id'] == 12028){
                $funnel_id = 997;
            } else if($data['agency_id'] == 17664){
                $funnel_id = 1180;
            } else if($data['agency_id'] == 19909){
                $funnel_id = 1613;
            } else if($data['agency_id'] == 19570) {
                $funnel_id = 1484;
            } else if ($data['agency_id'] == 21213) {
                $funnel_id = 1793;
            } else if ($data['agency_id'] == 20947) {
                $funnel_id = 1819;
            } else if ($data['agency_id'] == 21422){
                $funnel_id = 1858;
            } else if ($data['agency_id'] == 20553){
                $funnel_id = 1897;
            } else if ($data['agency_id'] == 21790) {
                $funnel_id = 1980;
            } else if ($data['agency_id'] == 19750) {
                $funnel_id = 1985;
            } else if ($data['agency_id'] == 22746){
                $funnel_id = 2155;
            } else if($data['agency_id'] == 22604){
                $funnel_id = 2184;
            }
            else if ($data['agency_id'] == 22666) {
                $funnel_id = 2096;
            } else if($data['agency_id'] == 23156){
                $funnel_id = 2299;
            } else if ($data['agency_id'] == 23360){
                $funnel_id = 2424;
            }

            if($funnel_id > 0){
              $req['funnel_id'] = $funnel_id;
            }
            $source = 0;
            $sourse_number = '+'.str_replace('+','',$this->_inputData['internal_number']);
            if($this->_inputData['operator'] == 'MEGAFON' && !empty($this->_inputData['transit_number'])){
                $sourse_number = '+'.str_replace('+','',$this->_inputData['transit_number']);
            }
            $resS = $this->findSource($sourse_number, $data['agency_id']);
            if(isset($resS['id'])){
                $responce['source'] = $resS['id'];
            } else {
                $responce['source'] = 0;
            }

            if(isset($responce['source']) && $responce['source'] > 0){
                $source = $responce['source'];
            }

            $req['source'] = $source;

	        if ($req['type_id'] == 4) {

		        $pdo = new MysqlPdo(hst, ndb, user, pass);
		        $autosearch_instce = new AutoSearch($pdo);
		        if ($req['autosearch_enabled'] == 1 && intval($req['object_id']) > 0) {

			        $objToFilter = $autosearch_instce->syncObjectToFilter(
				        intval($req['asfilter_id']),
				        intval($req['object_id']),
				        intval($req['req_id']),
				        (intval($req['asfilter_id']) > 0)
			        );

			        if ($objToFilter['success'])
				        $req['asfilter_id'] = $objToFilter['filter_id'];

		        }
	        }

            if(str_replace(['+7', '@ip.beeline.ru'], '', $data['internal_number']) != 'SIP00SKIU0133O' && str_replace(['+7', '@ip.beeline.ru'], '', $data['internal_number']) != 'SIP00SKIU00QVJ') {

                $req['id'] = $this->insertReq($req);
                if($data['agency_id'] == 13339){
                    //file_put_contents(__DIR__.'/log_test_megafon.txt', $req['id']. "\n", FILE_APPEND); 
                      
                    $sql_in_ev = "INSERT INTO user_client_events (user_id, req_id, create_date, schedule_date, `type`, comment, calendar_view, from_id) ".
                                        "VALUES ($user_id, {$req['id']}, '".date('Y-m-d H:i:s')."', '".date('Y-m-d H:i:s', strtotime('+30 minutes'))."', 'call', '".$req['description']."', 0, {$user_id})";
                    //file_put_contents(__DIR__.'/log_test_megafon.txt', $sql_in_ev. "\n", FILE_APPEND);              
                    mysql_query($sql_in_ev);
                }
                if($data['agency_id'] == 9588){
                    $pdo = new MysqlPdo(hst, ndb, user, pass);
                    $sql = "SET NAMES 'utf8'";
                    $pdo->query($sql);
                    $reqClass = new Requisitions($pdo);
                    $reqClass->get_class_etap($req['id'], 340);
                } else if($data['agency_id'] == 10732){
                  $reqClass = new Requisitions();
                  $reqClass->get_class_etap($req['id'], 441);
                }
                if($funnel_id > 0){
                  $reqClass = new Requisitions();
                  $reqClass->get_class_etap($req['id'], $funnel_id);
                }
            }

        }
    }

    public function findSource($phone, $agency_id){
        $users = [];
        $users = array_keys($this->getAllUserAgency($agency_id, $users));
        $source = '';
        $sql = "SELECT * FROM advertising_phone WHERE phone = '".$phone."'";
        $q = mysql_query($sql);
        if(mysql_num_rows($q) > 0){
          $r = mysql_fetch_assoc($q);
          $sql_v = "SELECT id, source FROM advertising_sources WHERE id = ".$r['adv_id']." AND user_id in (".implode(',',$users).")";

          $q_v = mysql_query($sql_v);

          if(mysql_num_rows($q_v) > 0){
            $r_v = mysql_fetch_assoc($q_v);
            $source = $r_v;
          }
        }

        return $source;
      }

    public function getCallEvents()
    {
        $userId = $_SESSION['id'];
        if($userId) {
            $query = "SELECT * FROM " . $this->table . " WHERE user_id = $userId and status = 1";

            $event = $this->dbpg->fetch_assoc($this->dbpg->query($query));

            $cannot_create = '0';
            $perm_query = "SELECT cannot_create_req_manually FROM user_permissions WHERE user_id = " . $userId . " LIMIT 1";
            $perm_result = mysql_query($perm_query);
            if ($perm_row = mysql_fetch_assoc($perm_result)) {
                $cannot_create = (isset($perm_row['cannot_create_req_manually']) ? $perm_row['cannot_create_req_manually'] : 0);
            }

            if ($event && (int)$event['client_id'] > 0) {

                $responce = [
                    'call_id' => $event['id'],
                    'call_uuid' => $event['operator_call_id'],
                    'operator' => $event['operator'],

                    'call_type' => $event['external_number'],
                    'line1' => true,
                    'line2' => false,
                    'header_hide' => false,
                    'client_id' => $event['client_id'],
                    'user_id' => $event['user_id'],
                    'cannot_create_req_manually' => $cannot_create,
                ];

                $responce['source'] = '';
                if(!empty($event['transit_number'])){
                    $resS = $this->findSource($event['transit_number'], $event['agency_id']);
                    if(isset($resS['source'])){
                        $responce['source'] = $resS['source'];
                        $responce['source_id'] = (int)$resS['id'];
                    } else {
                        $responce['source'] = '';
                        $responce['source_id'] = 0;
                    }
                }
                return $responce;
            }
        }
            $responce = [
                'call_id' => false,
                'header' => '',
                'call_uuid' => '',
                'operator' => '',
                'call_type'=>"",
                'line1'=> false,
                'line2' => false,
                'header_hide' => true,
                'client_id' => '',
                'source' => '',
                'source_id' => 0
            ];

        return $responce;
    }
    public function getClient($data){
        $userId = $_SESSION['id'];
        if($userId) {
            $client_id = $data->client_id;
            $query = "SELECT fio FROM clients WHERE id = $client_id";
            $result = mysql_fetch_assoc(mysql_query($query));
            if($result){
                return ['header'=>$result['fio']];
            }

        }
    }
    public function getRequisition($data){
        $userId = $_SESSION['id'];
        if($userId) {
            $pdo = new MysqlPdo(hst, ndb, user, pass);
            $sql = "SET NAMES 'utf8'";
            $pdo->query($sql);
            $req = new Requisitions($pdo, true);
            $client_id = $data->client_id;
            $query = "SELECT * FROM requisitions WHERE deleted = 0 and client_id=$client_id";

            $result = mysql_query($query);
            $requisitions = false;

            while ($row = mysql_fetch_assoc($result)) {
                if ($row['funnel_id'] == 0) {
                    $row['step_id'] = $row['stage'];
                }
                $step = $req->get_class_etap($row['id'], $row['funnel_id'], $row['step_id']);
                $requisitions[] = ['id' => $row['id'], 'name' => $row['name'], 'nazv' => $step['stage']];
            }

            $responce = [
                'requisitions' => $requisitions,
            ];
            $query = "SELECT fio FROM clients WHERE id = $client_id";
            $result = mysql_fetch_assoc(mysql_query($query));
            if($result){
                $responce['header'] = $result['fio'];
            }

            return $responce;
        }

    }
    public function getListTransfer(){
        $userId = $_SESSION['id'];
        if ($userId) {
            $user = $this->getUserByField('id', $userId);

            $agency_id = $this->getAgency($user);
            //echo $agency_id;
            $agensy = $this->getUserByField('id', $agency_id);
            $user_list = [];
            $user_list[$agency_id] = $agensy;

            $user_list = $this->getAllUserAgency($agency_id, $user_list);
            $uniquUser = [];

            foreach ($user_list as $user) {
                $uniquUser[] = [
                    'name' => trim($user['last_name'] . ' ' . $user['first_name'] . ' ' . $user['middle_name']),
                    'phone' => $user['phone']
                ];
            }

            $responce = [
                'userlist' => $uniquUser,
            ];


            return $responce;
        }

    }

    public function getAllUserAgency($user_id,$list){

        $agency_id = $user_id;

        $usersIds = array();
        $usersIds[] = $agency_id;
        $sql_users = "SELECT id FROM users WHERE id in (select id from users where id=$agency_id or id_manager=$agency_id or id_manager in
                    (select id from users where id_manager=$agency_id or id_manager in
                (select id from users where id_manager=$agency_id)))";
        $q_users = mysql_query($sql_users);
        while($r_users = mysql_fetch_assoc($q_users)){
          $usersIds[] = (int)$r_users['id'];
        }  
        

        $result = $this->getUsersByField('id', $usersIds);
        foreach($result as $row){
            $list[$row['id']] = $row;
                //$list = $this->getAllUserAgency($row['id'],$list);
        }

        return $list;
    }
    public function callTransfer($data){
        $userId = $_SESSION['id'];

        if ($userId) {
            $user = $this->getUserByField('id', $userId);
            $agency_id = $this->getAgency($user);
            $operator = $data->operator;
            $api_key = $this->getApiKey($agency_id,$operator);
            $phone = str_replace('+7', '',$data->phone);
            $callId = $data->callid;
            $res = array();
            $user_phone = str_replace('+7', '',$user['vpbx_id']);//str_replace('+7', '',$user['phone']);
            $beeline = new BeelineApiClass($api_key);
            switch ($data->method){
                case 'transfer': {
                    $res = $beeline->callTransfer($user_phone,$callId,$phone);

                    break;
                    }
                case 'consult': $beeline->callTransferConsult($user_phone,$callId,$phone);break;
            }
            return [$api_key,$phone,$callId,$user_phone];

        }
    }

    private function getApiKey($agency_id,$operator){
        $operator = strtolower($operator);
        $sql = "SELECT * FROM agency_mango WHERE agency_id = '$agency_id' and `type`= '$operator'";
        $result = mysql_fetch_assoc(mysql_query($sql));
        return $result['api_key'];
    }


    public function getCallHistory(){
        $userId = $_SESSION['id'];
        if ($userId) {
            $user = $this->getUserByField('id', $userId);

            $today = strtotime(date('d.m.Y 00:00:00'));
            $phone = str_replace(['@ip.beeline.ru','+7'],'',$user['vpbx_id']).'@ip.beeline.ru';
            $query = "SELECT m.* FROM mango_calls as m WHERE m.start>'$today' AND (m.vpbx_id =  '$phone' or m.vpbx_id =  '$user[vpbx_id]') ORDER BY id DESC";
            //echo $query;

            $result = $this->dbpg->query($query);
            $incoming = [];
            $total = 0;
            while($row = $this->dbpg->fetch_assoc($result)){
                $start = date('H:i', $row['start']);
                $date = date('Y-m-d',$row['start']);
                $client = (int)$row['client_id'];
                if (strpos($row['to_number'],$phone)!==false) $type = 'incoming';
                else $type = 'outgoing';
                if ($row['disconnect_reason'] == 'answered') $type .= '_answer';
                $sql_u = "SELECT fio FROM clients WHERE id = $row[client_id]";
                $q_u = mysql_query($sql_u);
                $r_u = mysql_fetch_assoc($q_u);
                $incoming[$date][] = ['name'=>$r_u['fio'], 'time'=>$start, 'type'=>$type, 'client_id'=>(int)$row['client_id']];
                $total++;
            }


            $today = date('Y-m-d');
            $yesterday = date('Y-m-d', time() - 86400);
            $responce = [];
            foreach($incoming as $key => $value){

                if($key == $today){
                    $responce[] = ['day'=>'Сегодня', 'calls' => $value];
                } elseif ($key == $yesterday){
                    $responce[] = ['day'=>'Вчера', 'calls' => $value];
                } else {
                    $responce[] = ['day'=>date('d.m', strtotime($key)), 'calls' => $value];
                }
            }

            return [
                'calls' => $responce,
                'totalCalls' => $total,
            ];

        }
    }

    public function endCall($data){
        $call_id = $data->call_id;
        $sql = "UPDATE call_events SET status = 0 WHERE id = {$call_id}";
        //mysql_query($sql);
        $this->dbpg->query($sql, true);
        return['call_id' => $call_id];
    }

}