<?php

ini_set('error_reporting', E_ALL);
ini_set('display_errors', 1);
ini_set('display_startup_errors', 1);

class BeelineApiClass extends MangoApiClass {
    private $api_key;
    private $base_url = "https://cloudpbx.beeline.ru/apis/portal/";

    private $metod;
    private $post='';
    private $client_id;
    private $header;
    private $users = array();
    private $phone_type;
    private $phone_types = [0 => 'beelineAbonentNoAnswer',
        1 => 'beelineAbonentAnswer',
        2 => 'abonentBeelineAnswer',
        3 => 'abonentBeelineNoAnswer'];
    private $client_stage = 0;
    public $subscription_url;
    private $dbpg = null;

  public function __construct($api_key){
    $this->api_key = $api_key;
    $this->header = ['Content-type:application/json',
    'X-MPBX-API-AUTH-TOKEN:'.$api_key];
    $this->dbpg = new MysqlPdo(hstpg, ndbpg, userpg, passpg, false, '5432', true);
  }

  public function set_users($users){
      $this->users = $users;
  }
  public function checkSubscription($id)
  {
      $sql = "SELECT * FROM call_subscription WHERE batc_id = $id";
      $subscription = mysql_fetch_assoc(mysql_query($sql));
      if(!$subscription){
          $result = $this->setSubscription();
          if(isset($result['subscriptionId'])) {
              $sql = "INSERT INTO `call_subscription`(`batc_id`, `api_key`, `subscriptionId`, `expires`) VALUES ($id,'".$this->api_key."','".$result['subscriptionId']."',".$result['expires'].")";
              mysql_query($sql);
          }
      } else {
          $result = $this->doSubscription($subscription);
          if(isset($result['subscriptionId'])){
              if($result['expires'] > 172800){
                  $sql = "UPDATE `call_subscription` SET `expires`=".$result['expires']." WHERE id=".$subscription['id'];
                  mysql_query($sql);
              } else {
                  $result = $this->setSubscription();
                  if(!empty($result['subscriptionId'])) {
                      $sql = "UPDATE `call_subscription` SET `expires`=" . $result['expires'] . ", `subscriptionId`='" . $result['subscriptionId'] . "' WHERE id=" . $subscription['id'];
                      mysql_query($sql);
                      $this->deleteSubscription($subscription);
                  }

              }
          } else {
              $result = $this->setSubscription();
              if(!empty($result['subscriptionId'])) {
                  $sql = "UPDATE `call_subscription` SET `expires`=" . $result['expires'] . ", `subscriptionId`='" . $result['subscriptionId'] . "' WHERE id=" . $subscription['id'];
                  mysql_query($sql);
                  $this->deleteSubscription($subscription);
              }
          }
      }
  }
  public function renewSubscription($subscriptionId){
      $sql = "SELECT * FROM call_subscription WHERE subscriptionId = '$subscriptionId'";
      $subscription = mysql_fetch_assoc(mysql_query($sql));
      if($subscription){
          $this->api_key = $subscription['api_key'];
          $result = $this->setSubscription();
          if(!empty($result['subscriptionId'])) {
              $sql = "UPDATE `call_subscription` SET `expires`=" . $result['expires'] . ", `subscriptionId`='" . $result['subscriptionId'] . "' WHERE id=" . $subscription['id'];
              mysql_query($sql);
          }

      }
 }
  private function doSubscription($subscription){
      $subscriptionId = $subscription['subscriptionId'];
      $this->metod = "subscription?subscriptionId=$subscriptionId";
      return json_decode($this->sendCurl(),true);
  }

  private function deleteSubscription($subscription){
      $subscriptionId = $subscription['subscriptionId'];
      $this->metod = "subscription?subscriptionId= $subscriptionId";
      return json_decode($this->sendCurl(false, ["type"=>"DELETE", "body"=>""]),true);
  }

  private function setSubscription(){
      $this->metod = 'subscription';
      $body = [
          "expires" => 2592000,
          "subscriptionType" => "BASIC_CALL",
          "url" => $this->subscription_url,
      ];

      return json_decode($this->sendCurl(false,['type'=>"PUT","body"=>json_encode($body)]), true);


  }
  private function sendCurl($post = false, $custom = false){
      $response = 0;
      $url = $this->base_url . $this->metod;
     // echo $url.'<br>';
      $ch = curl_init($url);
      curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
      //if($header){

      curl_setopt($ch, CURLOPT_HEADER,0);
      curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
      curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
      if($post){
          $this->header = ['X-MPBX-API-AUTH-TOKEN:'.$this->api_key];
          curl_setopt($ch, CURLOPT_POST, 1);
          curl_setopt($ch, CURLOPT_POSTFIELDS, $this->post);
      }
      curl_setopt($ch, CURLOPT_HTTPHEADER, $this->header);
      if($custom){
          curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $custom['type']);
          curl_setopt($ch, CURLOPT_POSTFIELDS,$custom['body']);
      }

      $response = curl_exec($ch);
    //  var_dump($response);

      if($errno = curl_errno($ch)) {
           $error_message = curl_strerror($errno);
           echo "cURL error ({$errno}):\n {$error_message}";
      }
      curl_close($ch);

      return $response;
  }

  public function callTransfer($user_id,$call_id,$phone)
  {
      $this->metod = "abonents/$user_id/callTransfer";
      $this->post = "callId=$call_id&phoneNumber=$phone";

      $res = $this->sendCurl(true);
      //$result['ps'] = "abonents/$user_id/callTransfer callId=$call_id&phoneNumber=$phone";
      return $res;
  }

  public function callTransferConsult($user_id,$call_id,$phone)
    {
        $this->metod = "abonents/$user_id/callTransferConsult";
        $this->post = "callId=$call_id&callIdConsult=$phone";
        $this->sendCurl(true);
    }

    public function callrelease($user_id,$call_id,$phone)
    {
        $this->metod = "abonents/$user_id/callTransferConsult";
        $this->post = "callId=$call_id&callIdConsult=$phone";
        $this->sendCurl(true);
    }

  public function getRoute(){
    $this->metod = "icr/route";
    $res = $this->sendCurl();
    return $res;
  }

  public function put_route($phone, $extension){
    $phone = str_replace('+7', '', $phone);
    $this->metod = 'icr/route';
      $body = [array(
          "inboundNumber" => $phone,
          "extension" => $extension,
        )
      ];

      return json_decode($this->sendCurl(false,['type'=>"PUT","body"=>json_encode($body)]), true);
  }

  public function checkRoute($call, $agency_id){
    $department = isset($call->department) ? $call->department : '';
    if(strpos(mb_strtolower($department), 'sip') !== false){
      $phone = $call->phone;
      $extension = $call->abonent->extension;
      if(!empty($phone) && !empty($extension)){
        $sql = "SELECT * FROM rule_route WHERE phone = '{$phone}' AND extension = '{$extension}' AND agency_id = {$agency_id}";
        $q = $this->dbpg->query($sql);
        
        if($this->dbpg->num_rows($q) == 0){
          
          $result = $this->put_route($phone, $extension);
          
          if($result[0]['status'] == 'SUCCESS'){
            $sql_in = "INSERT INTO rule_route (phone, extension, agency_id) VALUES ('{$phone}', '{$extension}', {$agency_id})";
            $this->dbpg->query($sql_in);
          }
        }
        
      }
    }
  }

  public function getUsers(){
    $this->metod = 'abonents';
    $res = $this->sendCurl(false);
    return $res;
  }

  public function stat_records($start_datetime, $lastId = false){
    $this->metod = 'records?dateFrom='.$start_datetime;//.'&dateTo='.$end_date;//api/ver1.0/client/'.$this->client_id.'/call_history/?start_datetime='.$start_datetime.'&order=asc&end_datetime='.$end_datetime.'&per_page=100000&page=1';
    if($lastId > 0){
      $this->metod = 'records?id='.$lastId;
    }
   // echo $this->metod."\n";
    $res = $this->sendCurl(false);
    return $res;
  }

  public function calls($start_datetime){
    $this->metod = 'statistics?dateFrom='.$start_datetime.'&page=0&pageSize=100';
    $res = $this->sendCurl(false);
    return $res;
  }

  public function get_record($record_uuid){
    $this->metod = 'v2/records/'.$record_uuid.'/download';
    $res = $this->sendCurl(false);
    return $res;
  }

  private function type_phone($call){
    //call);
    //var_dump($call);
    $result = '';
    $find_user = '';
    //$result = $call->result;
    //if(isset($call->abonent->))
    $find_user = $call->abonent->userId;
    $part_user = explode('@', $call->abonent->userId);
    if(isset($part_user[0])){
      $find_user = $part_user[0];
    }

    if(isset($call->status) && $call->status == 'MISSED'){
      if($call->direction == 'INBOUND'){
          $type = 3;
      } else {
          $type = 0;
      }

    } else {
      if($call->direction == 'INBOUND'){

          $type = 2;

      } else {
          $type = 1;

      }
    }


    $this->phone_type = $this->phone_types[$type];
  //  echo $find_user.'*****<br>';
    return $find_user;
  }

  public function get_phone_type($phone){
      $find_user = $this->type_phone($phone);
      return json_encode(array('type'=>$this->phone_type, 'find_user'=>$find_user));
  }

  //Установка стадии клиента
  private function set_client_stage($stage){
      $this -> client_stage = $stage;
  }

  public function find_user($phone, $agency_id=0){
  // echo  $phone."\n";
      $user_id = 0;
      $part_user = explode('@', $phone);
      if(isset($part_user[0])){
        $phone = $part_user[0];
      }
      $phone = $this->ver_phone($phone);

      $sql_user = "SELECT id FROM users WHERE phone = '".$phone."' and blocked=0";

     // echo $sql_user."\n";

      $q_user = mysql_query($sql_user);
      if(mysql_num_rows($q_user) > 0){
          $r_user = mysql_fetch_assoc($q_user);
          $user_id = $r_user['id'];
      }

      return $user_id;
  }

  public function find_client($phone, $no = false){
      $this -> set_client_stage(0);
      $client_id = 0;
      $phone_client = $this -> ver_phone($phone);

      $sql_cl = "SELECT `id`, `stage` FROM `clients` WHERE (phone = '$phone_client' OR id in (SELECT client_id FROM clients_phone2 WHERE phone = '$phone_client')) and (who_work in (".implode(',', $this->users).") or id_agent in (".implode(',', $this->users)."))";
      if($no){
        $sql_cl = "SELECT `id`, `stage` FROM `clients` WHERE (phone = '$phone_client' OR id in (SELECT client_id FROM clients_phone2 WHERE phone = '$phone_client'))";

      }
      //echo $sql_cl.'****************';
      $q_cl = mysql_query($sql_cl);
      if(mysql_num_rows($q_cl) > 0){
          $r_cl = mysql_fetch_assoc($q_cl);
          $client_id = $r_cl['id'];
          $this -> set_client_stage($r_cl['stage']);
      }
      return $client_id;
  }


  public function recordSave($p){
     if (!is_dir($_SERVER['DOCUMENT_ROOT'] . "/server/beeline")) {
         mkdir($_SERVER['DOCUMENT_ROOT'] . "/server/beeline", 0777);
     }
     $records = array();

     $records[] = $p->externalId;
     $file = trim($this->get_record($p->id));
     $name = $p->externalId.'.mp3';
     if(!file_exists($_SERVER['DOCUMENT_ROOT'].'/server/beeline/'.$name)){
         file_put_contents($_SERVER['DOCUMENT_ROOT'].'/server/beeline/'.$name, $file);
     }
         //var_dump($file);*/

     return json_encode($records);
  }

  public function find_user_comment($call, $type){

    $number = $call->abonent->userId;

    $mes = '';
    $sql = "SELECT fio FROM mango_call_users WHERE number_sip = '".$number."'";
    //echo $sql;
    $q = mysql_query($sql);
    if(mysql_num_rows($q) > 0){
      $r = mysql_fetch_assoc($q);
      $mes = '(Сотрудник '.$r['fio'].')';
    }

    return $mes;
  }

  public function stat($call, $agency_id){
    $id = 0;
    $idpg = 0;
    $from_extension = '';
    $to_extension = '';

    if($call->direction == 'INBOUND'){
        $to_number = $call->abonent->userId;
        $from_number = $call->phone;
        $to_extension = $call->abonent->extension;
        if(empty($to_extension)){
          $to_extension = $call->abonent->userId;
        }
        $entry_id = $call->abonent->userId;
    } else {
       $to_number = $call->phone;
       $from_number = $call->abonent->userId;
       $from_extension = $call->abonent->extension;
       if(empty($from_extension)){
        $from_extension = $call->abonent->userId;
      }
       $entry_id = $call->phone;
    }

    $call_id = false;
    $operator_call_id = 0;

    if(isset($call->callId)){
       $operator_call_id = (int)str_replace(['callhalf-',':'],'',$call->callId);
    }


    if(!isset($call->id)){
      $call->id = $call->startDate+$call->duration;
    }
    //echo $to_number.'<br>';
    $sql = "SELECT id FROM mango_calls WHERE uuid = '".$call->id."'";
    $q = mysql_query($sql);
    $qpg = $this->dbpg->query($sql);
    $date = floor($call->date/1000);
  /*  if(mysql_num_rows($q) == 0){

      if(isset($call->externalId)){
        $record = $this->recordSave($call);
      } else {
        $record = json_encode([]);
      }


      $answerResult = 'answered';
      $answer = $date;
      if(isset($call->status) && $call->status == 'MISSED'){
        $answerResult = 'not answered';
        $answer = 0;
      }
        $start = $date;
        $finish = floor(($call->date + $call->duration)/1000);
      // проверка записанных звонков с виджета
        $update = false;
        if($call->direction == 'INBOUND'){
            //$uuid = $entry_id .".".($call->startDate);
            $_sql = "SELECT id FROM mango_calls WHERE operator_id = 2 and `operator_call_id`=$operator_call_id";
            if(!empty($from_number)){
                $_sql .= "and from_number = '$from_number'";
            }
            $_c = mysql_fetch_assoc(mysql_query($sql));
            if(isset($_c['id'])){
                $update = true;
            }
        }

      if($update){
          $in = "UPDATE `mango_calls` SET
              `records`='" . $record . "',
              `start`= $start,
              `finish`=$finish,
              `to_extension`='" . $to_extension . "',
              `operator_id`=2,
              `operator_call_id`=$operator_call_id,
              `uuid`='" . $call->id . "' WHERE id =".$_c['id'];
          $id = (int)$_c['id'];
      }
      else {

          $in = "INSERT INTO `mango_calls` SET
              `records`='" . $record . "',
              `start`= $start,
              `finish`=$finish,
              `answer`=$answer,
              `from_extension`='" . $from_extension . "',
              `from_number`= '" . $from_number . "',
              `to_extension`='" . $to_extension . "',
              `to_number`='" . $to_number . "',
              `disconnect_reason`='" . $answerResult . "',
              `entry_id`='" . $entry_id . "',
              `line_number`='beeline',
              `location`='',
              `uuid`='" . $call->id . "',
              `agency_id`=$agency_id,
              `operator_id`=2,
              `operator_call_id`=$operator_call_id,
               `vpbx_id`='" . $call->abonent->userId ."'
              ";
      }

       mysql_query($in);
       if(!$update){
         $id = mysql_insert_id();
       }
    } else {
      $r = mysql_fetch_assoc($q);
      $id = (int)$r['id'];
    }
*/

    if($this->dbpg->num_rows($qpg) == 0){

      if(isset($call->externalId)){
        $record = $this->recordSave($call);
      } else {
        $record = json_encode([]);
      }


      $answerResult = 'answered';
      $answer = $date;
      if(isset($call->status) && $call->status == 'MISSED'){
        $answerResult = 'not answered';
        $answer = 0;
      }
        $start = $date;
        $finish = floor(($call->date + $call->duration)/1000);
      // проверка записанных звонков с виджета
        $update = false;
        if($call->direction == 'INBOUND'){
            //$uuid = $entry_id .".".($call->startDate);
            $_sql = "SELECT id FROM mango_calls WHERE operator_id = 2 and operator_call_id='{$operator_call_id}'";
            if(!empty($from_number)){
                $_sql .= "and from_number = '$from_number'";
            }
            $_c = $this->dbpg->fetch_assoc($this->dbpg->query($sql));
            if(isset($_c['id'])){
                $update = true;
            }
        }

      if($update){
          $in = "UPDATE mango_calls SET
              records='" . $record . "',
              start= $start,
              finish=$finish,
              to_extension='" . $to_extension . "',
              from_extension='".$from_extension."',
              operator_id=2,
              operator_call_id='{$operator_call_id}',
              uuid='" . $call->id . "' WHERE id =".$_c['id'];
          $id = (int)$_c['id'];
      }
      else {

          $in = "INSERT INTO mango_calls (records, 
                                          start, 
                                          finish, 
                                          answer, 
                                          from_extension, 
                                          from_number, 
                                          to_extension, 
                                          to_number, 
                                          disconnect_reason, 
                                          entry_id, 
                                          line_number, 
                                          location, 
                                          uuid, 
                                          agency_id, 
                                          operator_id, 
                                          operator_call_id, 
                                          vpbx_id
                                        ) 
                                        VALUES (
                                          '" . $record . "', 
                                          $start, 
                                          $finish, 
                                          $answer, 
                                          '" . $from_extension . "', 
                                          '" . $from_number . "', 
                                          '" . $to_extension . "', 
                                          '" . $to_number . "', 
                                          '" . $answerResult . "', 
                                          '" . $entry_id . "', 
                                          'beeline', 
                                          '', 
                                          '" . $call->id . "', 
                                          $agency_id, 
                                          2, 
                                          '{$operator_call_id}',
                                          '" . $call->abonent->userId ."'
                                          )";
             
      }
      //file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_call_sql.txt", $in."\n", FILE_APPEND);
      $this->dbpg->query($in);
       if(!$update){
         $idpg = $this->dbpg->insert_id();
       }
    } else {
      $r = $this->dbpg->fetch_assoc($qpg);
      $idpg = (int)$r['id'];
    }
    $result['id'] = $id;
    $result['idpg'] = $idpg;
    $result['call_id'] = $call->id;
    return $result;
  }

  public function saveUser($user, $agency_id){
    $phone = '';

    if(isset($user->email) && !empty($user->email)){
      $user_id = $user->userId;

      $part_user = explode('@', $user_id);
      if(isset($part_user[0])){
        $user_id = $part_user[0];
      }

      $sql = "SELECT id, number_phone FROM mango_call_users WHERE user_id='".$user_id."'";
      $q = mysql_query($sql);


      $sql_p = "SELECT phone FROM users WHERE email = '".$user->email."' AND company_id = {$agency_id}";
      if($agency_id == 19895){
        //echo $sql_p."\n";
      }
      $q_p = mysql_query($sql_p);
      if(mysql_num_rows($q_p) > 0){
        $r_p = mysql_fetch_assoc($q_p);
        $phone = $r_p['phone'];
      } else {
        $part_phone = str_replace('@ip.beeline.ru', '', $user_id);
        $in_vdx = "'".$user_id."', '".$part_phone."', '".$this->ver_phone($part_phone)."'";
        $sql_p = "SELECT phone FROM users WHERE vpbx_id in ({$in_vdx}) AND company_id = {$agency_id}";
        if($agency_id == 19895){
          //echo $sql_p."\n";
        }

        $q_p = mysql_query($sql_p);
        if(mysql_num_rows($q_p) > 0){
          $r_p = mysql_fetch_assoc($q_p);
          $phone = $r_p['phone'];
        }
      }

      $user_name = '';
      if(isset($user->lastName) && !empty($user->lastName)){
        $user_name .= $user->lastName;
      }

      if(isset($user->firstName)  && !empty($user->firstName)){
        if($user_name != ''){
            $user_name .= ' ';
        }
        $user_name .= $user->firstName;
      }

      $department = '';

      if(isset($user->department)){
        $department = $user->department;
      }
      //Записываем
      if(mysql_num_rows($q) == 0){
          /*f($phone == ''){
            $phone = mysql_fetch_assoc($q)['number_phone'];
          }*/
          $in = "INSERT INTO `mango_call_users` SET
                user_id = '".$user_id."',
                fio = '".$user_name."',
                number_phone = '".$phone."',
                number_sip = '".$user_id."',
                department = '".trim($department)."',
                extension = '".(isset($user->extension) ? $user->extension : '')."',
                agency_id = $agency_id
                  ";
          // echo $in."\n";     
          mysql_query($in);
      } else {
        $up = "UPDATE `mango_call_users` SET
              fio = '".$user_name."',
              number_phone = '".$phone."',
              number_sip = '".$user_id."',
              department = '".trim($department)."',
              extension = '".(isset($user->extension) ? $user->extension : '')."',
              agency_id = $agency_id
                WHERE user_id = '".$user_id."'";
         // echo $up."\n";      
        mysql_query($up);
      }
    }

    return $phone;
  }

  public function findSource($phone){
    $source = 0;
    $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 FROM advertising_sources WHERE id = ".$r['adv_id']." AND user_id in (".implode(', ',$this->users).")";
      $q_v = mysql_query($sql_v);

      if(mysql_num_rows($q_v) > 0){
        $r_v = mysql_fetch_assoc($q_v);
        $source = $r_v['id'];
      }
    }

    return $source;
  }

  public function save_user_call($id_call, $user_find, $main_user, $agency_id=0){
    $user_id = 0;

    if($id_call > 0){
        $user_id = (int)$this->find_user($user_find);
        if($user_id == 0){
          $user_id = (int)$main_user;
        }
    }

    if($user_id > 0){
      $sql = "SELECT id FROM user_call WHERE call_id = {$id_call}";
      $q = mysql_query($sql);
      if(mysql_num_rows($q) == 0){
        $sql_in = "INSERT INTO user_call SET call_id = {$id_call}, user_id = {$user_id}";
        mysql_query($sql_in); 
      }
    }
  }

  public function save_user_call_pg($id_call, $user_find, $main_user, $agency_id=0){
    $user_id = 0;

    if($id_call > 0){
        $user_id = (int)$this->find_user($user_find);
        if($user_id == 0){
          $user_id = (int)$main_user;
        }
    }
    
    if($user_id > 0){
      $sql = "SELECT id FROM user_call WHERE call_id = {$id_call}";
      $q = $this->dbpg->query($sql);
      if($this->dbpg->num_rows($q) == 0){
        $sql_in = "INSERT INTO user_call (call_id, user_id) VALUES ($id_call, $user_id)";
        if($agency_id == 11916){
          //file_put_contents($_SERVER['DOCUMENT_ROOT']."/webhooks/log_call_sql.txt", $sql_in."\n", FILE_APPEND);
        }
        $this->dbpg->query($sql_in); 
      }
    }
  }

}