weborsha/Joywork
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
f593915c05
Joywork/engine/classes/Tele2ApiClass.php

492 lines
16 KiB
PHP
Raw Normal View History

Init
2026-05-22 20:21:54 +02:00
<?php
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
/**
* Description of Tele2ApiClass
*
* @author Ira
*/
ini_set('error_reporting', E_ALL);
ini_set('display_errors', 1);
ini_set('display_startup_errors', 1);
class Tele2ApiClass extends MangoApiClass {
private $company_id;
private $region_id;
private $base_url = "https://ats2.t2.ru/crm/openapi";
private $metod;
private $header;
private $users = array();
private $phone_type;
private $refreshToken;
private $accessToken;
private $phone_types = [0 => 'tele2AbonentNoAnswer',
1 => 'tele2AbonentAnswer',
2 => 'abonentTele2Answer',
3 => 'abonentTele2NoAnswer'];
private $start;
private $end;
public function __construct($company_id, $region_id, $refreshToken, $accessToken){
$this->company_id = $company_id;
$this->region_id = $region_id;
$this->refreshToken = $refreshToken;
$this->accessToken = $accessToken;
}
private function set_header($refreshToken = false){
// var_dump($refreshToken);
if($refreshToken){
$this->header = ['Content-type:application/json',
'Authorization:'.$this->refreshToken];
} else {
$this->header = ['Content-type:application/json',
'Authorization:'.$this->accessToken];
}
}
public function getToken($agency_id){
$result = false;
$this->metod = '/authorization/refresh/token';
$tokens = json_decode($this->sendCurl(false,['type'=>"PUT","body"=>[]], true));
if(isset($tokens->accessToken) && isset($tokens->refreshToken)){
$this->accessToken = $tokens->accessToken;
$this->refreshToken = $tokens->refreshToken;
$sql_up = "UPDATE agency_tele2 SET access_token='{$tokens->accessToken}', refresh_token='$tokens->refreshToken' WHERE agency_id={$agency_id}";
if(mysql_query($sql_up))
$result = true;
}
return $result;
}
private function sendCurl($post = false, $custom = false, $refreshToken = false){
$response = 0;
$url = $this->base_url . $this->metod;
//echo $url.'<br>';
$ch = curl_init($url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
//if($header){
$this->set_header($refreshToken);
//var_dump($this->header);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
curl_setopt($ch, CURLOPT_HTTPHEADER, $this->header);
curl_setopt($ch, CURLOPT_HEADER,0);
if($post){
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, $this->post);
}
if($custom){
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $custom['type']);
curl_setopt($ch, CURLOPT_POSTFIELDS,$custom['body']);
}
$response = curl_exec($ch);
$response_info = curl_getinfo($ch);
//var_dump($response);
//var_dump($response_info['http_code']);
if($response_info['http_code'] != 200){
$response = 0;
}
if($errno = curl_errno($ch)) {
$error_message = curl_strerror($errno);
echo "cURL error ({$errno}):\n {$error_message}";
}
curl_close($ch);
return $response;
}
public function getUsers() {
$this->metod = "/employees?company_id=".$this->company_id;
$res = $this->sendCurl(false);
return $res;
}
//Сохранение пользователя МТС
private function saveUserTele2($user, $agency_id){
$user_id = 0;
$tele2_id = $user->employeeId;
$fio = '';
$set = " SET ";
if(isset($user->surname) && !empty(trim($user->surname))){
$fio .= trim($user->surname);
}
if(isset($user->name) && !empty(trim($user->name))){
if(!empty($fio)) $fio .= ' ';
$fio .= trim($user->name);
}
if(isset($fio) && !empty($fio)){
if($set != " SET ") $set .= ", ";
$set .= "fio='$fio'";
}
if(isset($user->fullNumber) && !empty($user->fullNumber)){
$phone = $user->fullNumber;
if($set != " SET ") $set .= ", ";
$set .= "phone='$phone'";
}
if(isset($user->shortNumber) && !empty($user->shortNumber)){
$ext = $user->shortNumber;
if($set != " SET ") $set .= ", ";
$set .= "ext='$ext'";
}
if(isset($user->email) && !empty($user->email)){
$email = $user->email;
if($set != " SET ") $set .= ", ";
$set .= "email='$email'";
}
//Поиск user_id
if(isset($phone)){
$sql = "SELECT id FROM users WHERE phone='".$this->ver_phone($phone)."'";
$q = mysql_query($sql);
if(mysql_num_rows($q) > 0){
$user_id = mysql_fetch_array($q)[0];
}
}
if(isset($email) && $user_id == 0){
$sql = "SELECT id FROM users WHERE email='$email'";
$q = mysql_query($sql);
if(mysql_num_rows($q) > 0){
$user_id = mysql_fetch_array($q)[0];
}
}
if($set != " SET ") $set .= ", ";
$set .= "user_id='$user_id'";
if($user_id > 0) {
$sql = "SELECT id FROM tele2_users WHERE tele2_id = $tele2_id";
$q = mysql_query($sql);
$row = mysql_num_rows($q);
if($row > 0){
$sql_up = "UPDATE tele2_users $set WHERE tele2_id = $tele2_id";
mysql_query($sql_up);
} else {
if($set != " SET ") $set .= ", ";
$set .= "tele2_id='$tele2_id', agency_id=$agency_id";
$sql_in = "INSERT INTO tele2_users $set";
mysql_query($sql_in);
}
}
}
public function find_user($phone, $agency_id=0){
$user_id = 0;
$phone = $this->ver_phone($phone);
$sql_user = "SELECT id FROM users WHERE phone = '".$phone."' and blocked=0";
$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 saveUser($user, $agency_id){
$this->saveUserTele2($user, $agency_id);
$user_id = $user->employeeId;
$poles = array();
$poles_up = array();
//Проверка есть ли запись
$sql = "SELECT id FROM mango_call_users WHERE user_id='".$user_id."'";
$q = mysql_query($sql);
//Записываем
$fio = '';
$poles[] = "user_id = '".$user_id."'";
if(isset($user->surname) && !empty(trim($user->surname))){
$fio .= trim($user->surname);
}
if(isset($user->name) && !empty(trim($user->name))){
if(!empty($fio)) $fio .= ' ';
$fio .= trim($user->name);
}
if(!empty($fio)){
$poles[] = "fio = '".$fio."'";
$poles_up[] = "fio = '".$fio."'";
}
$number_sip = '';
if(isset($user->fullNumber) && !empty($user->fullNumber)){
$poles[] = "number_phone = '".$user->fullNumber."'";
$number_sip = $user->fullNumber;
}
if(isset($user->shortNumber) && !empty($user->shortNumber)){
$poles[] = "extension = '".$user->shortNumber."'";
}
$poles[] = "number_sip = '".$number_sip."'";
$poles_up[] = "number_sip = '".$number_sip."'";
if(mysql_num_rows($q) == 0){
$poles[] = "agency_id = '".$agency_id."'";
$insert = "INSERT INTO `mango_call_users` set ".implode(', ', $poles);
mysql_query($insert);
} else {
$insert = "UPDATE `mango_call_users` set ".implode(', ', $poles_up)." WHERE user_id = ".$user_id;
mysql_query($insert);
}
}
private function getListRecords($call){
$result = false;
$this->metod = '/record/list?'.
'company_id='.$this->company_id.
'&region_id='.$this->region_id.
'&start='.$this->start.
'&end='.$this->end.
'&caller='.$call->callerNumber.
'&callee='.$call->calleeNumber;
//echo $this->metod."\n";
$res = $this->sendCurl();
//var_dump($res);
return $result;
}
public function get_record($record_uuid){
$this->metod = '/call-records/file?filename='.rawurlencode($record_uuid);
$res = $this->sendCurl();
return $res;
}
//
public function recordSaveTele2($call, $agency_id){
$records = array();
if(isset($call->recordFileName) && !empty($call->recordFileName)){
if (!is_dir($_SERVER['DOCUMENT_ROOT'] . "/server/tele2")) {
mkdir($_SERVER['DOCUMENT_ROOT'] . "/server/tele2", 0777);
}
if (!is_dir($_SERVER['DOCUMENT_ROOT'] . "/server/tele2/".$agency_id)) {
mkdir($_SERVER['DOCUMENT_ROOT'] . "/server/tele2/".$agency_id, 0777);
}
$date = date("Ymd", $call->date);
if (!is_dir($_SERVER['DOCUMENT_ROOT'] . "/server/tele2/".$agency_id."/".$date)) {
mkdir($_SERVER['DOCUMENT_ROOT'] . "/server/tele2/".$agency_id."/".$date, 0777);
}
$file = trim($this->get_record($call->recordFileName));
if(!empty($file)){
$name = explode('/', $call->recordFileName)[1].'.mp3';
if(!file_exists($_SERVER['DOCUMENT_ROOT'].'/server/tele2/'.$agency_id.'/'.$date.'/'.$name)){
file_put_contents($_SERVER['DOCUMENT_ROOT'].'/server/tele2/'.$agency_id.'/'.$date.'/'.$name, $file);
}
$records[] = explode('/', $call->recordFileName)[1];
}
}
return json_encode($records);
}
public function callHistory($start, $end) {
$this->start = $start;
$this->end = $end;
$this->metod = "/call-records/info?start=$start&end=$end&size=50";
$res = json_decode($this->sendCurl());
return $res;
}
public function get_phone_type($phone){
$this->type_phone($phone);
return $this -> phone_type;
}
public function type_phone($phone){
$type = 0;
$number_phone = $phone->callerNumber;
$sql = "SELECT id FROM tele2_users WHERE phone = '$number_phone'";
//echo $sql."\n";
$q = mysql_query($sql);
if(mysql_num_rows($q) > 0){
if($phone->callStatus == 'ANSWERED_COMMON'
|| $phone->callStatus == 'ANSWERED_BY_ORIGINAL_CLIENT'
|| $phone->callStatus == 'ANSWERED_BY_BUSY_FORWARD_CLIENT'
|| $phone->callStatus == 'ANSWERED_BY_NO_ANSWER_FORWARD_CLIENT'
){
$type = 1;
}
} else {
$type = 3;
if($phone->callStatus == 'ANSWERED_COMMON'
|| $phone->callStatus == 'ANSWERED_BY_ORIGINAL_CLIENT'
|| $phone->callStatus == 'ANSWERED_BY_BUSY_FORWARD_CLIENT'
|| $phone->callStatus == 'ANSWERED_BY_NO_ANSWER_FORWARD_CLIENT'
){
$type = 2;
}
}
$this->phone_type = $this->phone_types[$type];
}
public function stat($call, $agency_id){
$id = 0;
$this->type_phone($call);
if(!isset($call->calleeNumber)){
$call->calleeNumber = $call->destinationNumber;
}
$to_number = $call->calleeNumber;
$from_number = $call->callerNumber;
$entry_id = $to_number;
$id_uuid = $call->date;
$answer = 0;
$answerResult = $call->callStatus;
if(isset($call->conversationDuration))
{
$answer = $call->date;
}
$from_extension = '';
if($this->phone_type == 'tele2AbonentAnswer' || $this->phone_type == 'tele2AbonentNoAnswer'){
$from_extension = $call->calleeNumber;
$to_number = $call->callerNumber;
}
$start = $call->date;
$finish = $call->date + $call->callDuration;
//echo $to_number.'<br>';
$sql = "SELECT id FROM mango_calls WHERE operator_id=6 and operator_call_id = '".$id_uuid."'";
$q = mysql_query($sql);
$row = mysql_num_rows($q);
$record = "[]";
if($this->phone_type == 'tele2AbonentAnswer' || $this->phone_type == 'abonentTele2Answer'){
$record = $this->recordSaveTele2($call, $agency_id);
}
if($row == 0){
$in = "INSERT INTO `mango_calls` SET
`records`='".$record."',
`start`= $start,
`finish`=$finish,
`answer`=$answer,
`from_extension`='".$from_extension."',
`from_number`= '".$from_number."',
`to_extension`='".$call->calleeNumber."',
`to_number`='".$to_number."',
`disconnect_reason`='".$answerResult."',
`entry_id`='".$entry_id."',
`line_number`='tele2',
`operator_id`=6,
`location`='',
`operator_call_id`='{$id_uuid}',
`agency_id`=$agency_id
";
//echo $in."\n";
mysql_query($in);
$id = mysql_insert_id();
} else {
$r = mysql_fetch_assoc($q);
$id = (int)$r['id'];
$in = "UPDATE `mango_calls` SET
`records`='".$record."',
`start`= $start,
`finish`=$finish,
`answer`=$answer,
`from_extension`='".$from_extension."',
`from_number`= '".$from_number."',
`to_extension`='".$call->calleeNumber."',
`to_number`='".$to_number."',
`disconnect_reason`='".$answerResult."',
`entry_id`='".$entry_id."',
`agency_id`=$agency_id
WHERE
id = {$id}";
mysql_query($in);
} /*else if($row > 0) {
$in = "UPDATE `mango_calls` SET
`records`='".$record."',
`start`= $start,
`finish`=$finish,
`answer`=$answer,
`from_extension`='".$from_extension."',
`from_number`= '".$from_number."',
`to_extension`='".$call->calledNumber."',
`to_number`='".$to_number."',
`disconnect_reason`='".$answerResult."',
`entry_id`='".$entry_id."',
`line_number`='tele2',
`agency_id`=$agency_id
WHERE
operator_id=6 and operator_call_id = '".$id_uuid."'
";
echo $in;
//mysql_query($in);
}*/
return $id;
}
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);
}
}
}
}
Reference in New Issue Copy Permalink