919 lines
42 KiB
PHP
919 lines
42 KiB
PHP
<?php
|
||
class MaxClass {
|
||
private $db = null;
|
||
private $dbpg = null;
|
||
private $token = 'f9LHodD0cOLzH1dzzkfKhiejD2HWpnGxmoq_iGDbTrOuj2PoGlY9kJPzHCplH0M4Ycc8RBbEj3kdLu-BQavu';
|
||
private $metod = 'get';
|
||
private $base_url = 'https://platform-api.max.ru/';
|
||
private $href = '';
|
||
private $bodyPost = null;
|
||
private $idСhannel = -70963110483455; //id канала по которому проверяем подписку
|
||
|
||
public function __construct()
|
||
{
|
||
//throw new \Exception('Not implemented');
|
||
$pdo = new MysqlPdo(hst, ndb, user, pass);
|
||
$pdo->query("SET NAMES 'utf8'");
|
||
$this->db = $pdo;
|
||
}
|
||
|
||
private function clearInputElement($el2) // очистка входящего элимента
|
||
{
|
||
|
||
$el = $el2;
|
||
|
||
$el = strip_tags($el); // от тегов
|
||
|
||
$el = htmlspecialchars($el); // от кавычек и прочего
|
||
|
||
$el = str_replace("\n", "<br>", $el);
|
||
|
||
$el = str_replace("\r", "", $el);
|
||
|
||
$el = mysql_real_escape_string($el); // от MySQL-инъекций
|
||
|
||
$el = trim($el); // от лишних пробелов
|
||
|
||
$el = stripslashes($el); // от слэшей
|
||
|
||
return $el;
|
||
|
||
}
|
||
|
||
public function set_token($token){
|
||
$this->token = $token;
|
||
}
|
||
|
||
public function set_metod($metod){
|
||
$this->metod = $metod;
|
||
}
|
||
|
||
public function set_href($href){
|
||
$this->href = $href;
|
||
}
|
||
|
||
/**
|
||
* Получение информации о боте
|
||
* @return array
|
||
*/
|
||
public function me(){
|
||
$this->set_metod('get');
|
||
$this->set_href('me');
|
||
return $this->send();
|
||
}
|
||
|
||
|
||
public function get_chats(){
|
||
$this->set_metod('get');
|
||
$this->set_href('chats');
|
||
return $this->send();
|
||
// https://platform-api.max.ru/chats
|
||
}
|
||
|
||
/**
|
||
* Возвращает список участников группового чата
|
||
* @param int $user_id id пользователя max для получения информации тошльок об этом пользователе,
|
||
* если null то будет получен массив из 20 поьзователей
|
||
* @return array $response Если members пустой, то пользователь не подписан
|
||
*/
|
||
public function get_members($user_id = null){
|
||
$this->set_metod('get');
|
||
$href = 'chats/'.$this->idСhannel.'/members';
|
||
if(!is_null($user_id)){
|
||
$href .= '?user_ids='.$user_id;
|
||
}
|
||
$this->set_href($href);
|
||
return $this->send();
|
||
}
|
||
|
||
|
||
/**
|
||
* Получение текущих подписок
|
||
* @return array
|
||
*/
|
||
public function get_subscriptions(){
|
||
$this->set_metod('get');
|
||
$this->set_href('subscriptions');
|
||
return $this->send();
|
||
}
|
||
|
||
/**
|
||
* Отписка от обновлений
|
||
* @param string $url адрес от которого отписываемся не получаем вебхуки
|
||
* @return array
|
||
*/
|
||
public function delete_subscriptions($url){
|
||
$this->set_metod('delete');
|
||
$this->set_href('subscriptions?url='.$url);
|
||
return $this->send();
|
||
}
|
||
|
||
|
||
/**
|
||
* Подписка на обновления
|
||
* Webhook-endpoint должен быть доступен по HTTPS на порту 443. Ваш сервер должен прослушивать этот порт. Порт в URL не указывается
|
||
* @param string $url URL HTTPS-endpoint вашего бота. Должен начинаться с https://
|
||
* @param array $update_types Список типов обновлений, которые хочет получать ваш бот. Для полного списка типов
|
||
* @param string $secret Cекрет, который должен быть отправлен в заголовке X-Max-Bot-Api-Secret в каждом запросе Webhook.
|
||
* Разрешены только символы A-Z, a-z, 0-9, и дефис.
|
||
* Заголовок рекомендован, чтобы запрос поступал из установленного веб-узла
|
||
*/
|
||
public function set_subscription($url, $update_types, $secret = null){
|
||
$this->set_metod('post');
|
||
$this->set_href('subscriptions');
|
||
$data = [
|
||
'url'=>$url,
|
||
'update_types'=>$update_types
|
||
];
|
||
if(!is_null($secret)){
|
||
$data['secret'] = $secret;
|
||
}
|
||
$this->bodyPost = $data;
|
||
return $this->send();
|
||
}
|
||
|
||
/**
|
||
* Отправка сообщения пользователю
|
||
* @param int $user_id - id пользователя max
|
||
* @param string $text Текст сообщения
|
||
* @param array $attachments вложение в сообщение (кнопки, файлы, избражения и т.д.)
|
||
* @return array $response
|
||
*/
|
||
public function send_messages_to_user($user_id, $text, $attachments = []){
|
||
$this->set_metod('post');
|
||
$this->set_href("messages?user_id={$user_id}");
|
||
$data = [
|
||
'text'=>$text,
|
||
'format'=>'html',
|
||
'attachments'=>$attachments
|
||
];
|
||
$this->bodyPost = $data;
|
||
return $this->send();
|
||
}
|
||
|
||
/**
|
||
* Отправка сообщения в чат
|
||
* @param int $chat_id - Если сообщение отправляется в чат, укажите его ID
|
||
* @param string $text Текст сообщения
|
||
* @param array $attachments вложение в сообщение (кнопки, файлы, избражения и т.д.)
|
||
* @return array $response
|
||
*/
|
||
public function send_messages_to_chat($chat_id, $text, $attachments = []){
|
||
$this->set_metod('post');
|
||
$this->set_href("messages?chat_id={$chat_id}");
|
||
$data = [
|
||
'text'=>$text,
|
||
'format'=>'html',
|
||
|
||
];
|
||
$this->bodyPost = $data;
|
||
return $this->send();
|
||
}
|
||
|
||
/**
|
||
*
|
||
*/
|
||
|
||
/**
|
||
* Отправка запроса
|
||
* @return array $response
|
||
*/
|
||
private function send(){
|
||
$url = $this->base_url . $this->href;
|
||
$ch = curl_init();
|
||
|
||
curl_setopt($ch, CURLOPT_HTTPHEADER, array('Authorization: '.$this->token, 'Content-Type: application/json'));
|
||
curl_setopt($ch, CURLOPT_URL, $url); // Устанавливаем URL
|
||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); // Возвращать результат в виде строки
|
||
// Если отправляем через POST (часто предпочтительнее для больших данных или JSON):
|
||
if($this->metod == 'post'){
|
||
curl_setopt($ch, CURLOPT_POST, 1);
|
||
curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($this->bodyPost, JSON_UNESCAPED_UNICODE));
|
||
}
|
||
|
||
if($this->metod == 'delete'){
|
||
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "DELETE");
|
||
}
|
||
|
||
|
||
// Выполнение запроса
|
||
$result = curl_exec($ch);
|
||
//var_dump($result);
|
||
$response = array();
|
||
// Проверка на ошибки
|
||
if (curl_errno($ch)) {
|
||
echo 'Ошибка cURL: ' . curl_error($ch);
|
||
$response['error'] = true;
|
||
$response['message'] = 'Ошибка cURL: ' . curl_error($ch);
|
||
file_put_contents($_SERVER['DOCUMENT_ROOT']."/max_error.log", date('d.m.y H:i:s').' '.$url.' '.curl_error($ch).' '.json_encode($this->bodyPost, JSON_UNESCAPED_UNICODE)."\n", FILE_APPEND);
|
||
|
||
} else {
|
||
// Обработка ответа
|
||
$response = json_decode($result, true);
|
||
if(isset($response['code'])){
|
||
$response['error'] = true;
|
||
file_put_contents($_SERVER['DOCUMENT_ROOT']."/max_error.log", date('d.m.y H:i:s').' '.$url.' '.$response['code'].' '.json_encode($this->bodyPost, JSON_UNESCAPED_UNICODE)."\n", FILE_APPEND);
|
||
|
||
}
|
||
}
|
||
// Закрытие сессии cURL
|
||
curl_close($ch);
|
||
return $response;
|
||
}
|
||
|
||
//Выборка клиентов
|
||
public function get_clients_array($client_ids){
|
||
$clients = array();
|
||
$sql_cl = "SELECT id, phone, fio, of_objects, opis FROM clients WHERE id in (".implode(',',$client_ids).")";
|
||
|
||
$q_cl = $this->db->query($sql_cl, true);
|
||
while($r_cl = $this->db->fetch_assoc($q_cl)){
|
||
$clients[$r_cl['id']] = $r_cl;
|
||
}
|
||
|
||
return $clients;
|
||
}
|
||
|
||
//Выборка заявок
|
||
public function get_reqs_array($req_ids){
|
||
$result = array('reqs'=>array(), 'client_ids'=>array());
|
||
$reqs=array();
|
||
$client_req_ids = array();
|
||
$sql_req = "SELECT id, object_id, name as fio, client_id, '' as `phone`, `object_id` as `of_objects`, client_id, description as opis, type_id, (SELECT heir FROM requisitions_type WHERE requisitions.type_id = requisitions_type.id) as heir FROM requisitions WHERE id in (" . implode(',', $req_ids) . ")";
|
||
$q_req = $this->db->query($sql_req);
|
||
while($r_req = $this->db->fetch_assoc($q_req)){
|
||
$reqs[$r_req['id']] = $r_req;
|
||
$client_req_ids[] = $r_req['client_id'];
|
||
}
|
||
$result['reqs'] = $reqs;
|
||
$result['client_ids'] = $client_req_ids;
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* Отметка задачи выполненной
|
||
*/
|
||
public function task_completed($max_user_id, $event_id, $type='client_req', $is_comment = false){
|
||
if($max_user_id > 0 && $event_id > 0){
|
||
$user_id = 0;
|
||
$stage = 0;
|
||
$status = 0;
|
||
$sql_user = "SELECT * FROM users WHERE max_user_id = {$max_user_id}";
|
||
$q_user = $this->db->query($sql_user);
|
||
$r_user = $this->db->fetch_assoc($q_user);
|
||
$user_id = (int)$r_user['id'];
|
||
$agency_id = (int)$r_user['company_id'] > 0 ? $r_user['company_id'] : $user_id;
|
||
$event = 'task_completed';
|
||
$table = 'user_client_events';
|
||
if($type == 'object'){
|
||
$event = 'task_completed_object';
|
||
$table = 'user_object_events';
|
||
}
|
||
$this->db->query("UPDATE max_events SET status = 1 WHERE max_user_id = {$max_user_id}");
|
||
if(!$is_comment){
|
||
$stage = 0;
|
||
$status = 1;
|
||
}
|
||
$description = date('d-m-Y H:i:s').' - Запрос на отметку выполнено';
|
||
$sql = "INSERT INTO max_events (max_user_id, mess_id, event, stage, service, status, description, user_id, agency_id)
|
||
VALUE ({$max_user_id}, {$event_id}, '{$event}', 1, 0, '{$status}', '{$description}', {$user_id}, {$agency_id})";
|
||
|
||
|
||
if(!$this->db->query($sql)){
|
||
$errors[] = $this->db->error();
|
||
}
|
||
if(!$is_comment){
|
||
$sql = "UPDATE {$table} SET calendar_view = 1 WHERE id = {$event_id}";
|
||
$this->db->query($sql);
|
||
}
|
||
|
||
|
||
|
||
$result = array('result'=>$event, 'stage'=>$stage, 'event_id' => $event_id);
|
||
} else {
|
||
$errors[] = 'Empty data';
|
||
}
|
||
|
||
if(!empty($errors)){
|
||
file_put_contents($_SERVER['DOCUMENT_ROOT']."/log_task_max.txt", date('d.m.y H:i:s').' max_user_id '.$max_user_id.' id:'.$event_id." ".json_encode($errors, JSON_UNESCAPED_UNICODE)."\n", FILE_APPEND);
|
||
return array('result'=>'error');
|
||
}
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* отправка комментария для задачи
|
||
*/
|
||
public function send_comment_task($max_user_id, $mess, $event_table, $type='client_req'){
|
||
$event = 'task_completed';
|
||
$table = 'user_client_events';
|
||
if($type == 'object'){
|
||
$event = 'task_completed_object';
|
||
$table = 'user_object_events';
|
||
}
|
||
if(empty($mess)) $errors[] = "Пустое сообщение";
|
||
if(empty($event_table)){
|
||
|
||
$sql_ev = "SELECT * FROM max_events WHERE max_user_id = {$max_user_id} AND status = 0 AND event='$event' ORDER BY id DESC LIMIT 1";
|
||
//file_put_contents($_SERVER['DOCUMENT_ROOT']."/log_task_max.txt", date('d.m.y H:i:s').' max_user_id '.$max_user_id.' id:'.$sql_ev."\n", FILE_APPEND);
|
||
$q_ev = $this->db->query($sql_ev);
|
||
if($this->db->num_rows($q_ev) > 0){
|
||
$event_table = $this->db->fetch_assoc($q_ev);
|
||
}
|
||
}
|
||
if(empty($event_table)) $errors[] = "Не найдено связаное событие";
|
||
if($event_table['user_id'] == 0) $errors[] = "Не определен user_id";
|
||
|
||
$event_id = (int)$event_table['mess_id'];
|
||
$user_id = (int)$event_table['user_id'];
|
||
|
||
if(empty($errors)){
|
||
$sql = "UPDATE {$table} SET calendar_view = 1 WHERE id = {$event_id}";
|
||
$this->db->query($sql);
|
||
|
||
$field = '';
|
||
$field_val = 0;
|
||
$sql_ev = "SELECT * FROM {$table} WHERE id = {$event_id}";
|
||
|
||
$q_ev = $this->db->query($sql_ev);
|
||
$r_ev = $this->db->fetch_assoc($q_ev);
|
||
if(isset($r_ev['req_id']) && $r_ev['req_id'] > 0){
|
||
$field = 'req_id';
|
||
$field_val = $r_ev['req_id'];
|
||
} else if (isset($r_ev['client_id']) && $r_ev['client_id'] > 0){
|
||
$field = 'client_id';
|
||
$field_val = $r_ev['client_id'];
|
||
|
||
} else if (isset($r_ev['object_id']) && $r_ev['object_id'] > 0){
|
||
$field = 'object_id';
|
||
$field_val = $r_ev['object_id'];
|
||
|
||
}
|
||
if($field_val > 0){
|
||
$sql_comment = "INSERT INTO {$table} (user_id, from_id, type, comment, max, {$field}) VALUES ({$user_id}, {$user_id}, 'comment', '{$mess}', 1, {$field_val})";
|
||
|
||
$this->db->query($sql_comment);
|
||
}
|
||
}
|
||
|
||
$result = array('result'=>'add_task_comment', 'event_id' => $event_table['mess_id']);
|
||
|
||
if(!empty($errors)){
|
||
file_put_contents($_SERVER['DOCUMENT_ROOT']."/log_task_telega.txt", date('d.m.y H:i:s').' id:'.$event_id." ".json_encode($errors, JSON_UNESCAPED_UNICODE)."\n", FILE_APPEND);
|
||
return array('result'=>'error');
|
||
}
|
||
|
||
return $result;
|
||
|
||
}
|
||
|
||
/**
|
||
* Отмена отправки сообщения для задачи
|
||
*/
|
||
public function no_task_completed($max_user_id, $event_id, $type='client_req'){
|
||
$event = 'task_completed';
|
||
|
||
if($type == 'object'){
|
||
$event = 'task_completed_object';
|
||
|
||
}
|
||
$sql_ev = "UPDATE max_events SET status=1 WHERE max_user_id = {$max_user_id} AND mess_id={$event_id} AND event='{$event}'";
|
||
|
||
|
||
if(!$this->db->query($sql_ev)){
|
||
$errors[] = $this->db->error();
|
||
}
|
||
$result = array('result'=>'no_task_completed', 'event_id' => $event_id);
|
||
|
||
if(!empty($errors)){
|
||
file_put_contents($_SERVER['DOCUMENT_ROOT']."/log_task_telega.txt", date('d.m.y H:i:s').' id:'.$event_id." ".json_encode($errors, JSON_UNESCAPED_UNICODE)."\n", FILE_APPEND);
|
||
return array('result'=>'error');
|
||
}
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* Принять в работу
|
||
*/
|
||
public function accept_work($maxUserId, $event_id, $type='client_req'){
|
||
if($maxUserId > 0 && $event_id > 0){
|
||
$db_sphinx = new MysqlPdo(hstsph2, null, null, null, true, '9306');
|
||
$user_id = 0;
|
||
$stage = 0;
|
||
$status = 1;
|
||
$section = '';
|
||
$sql_user = "SELECT * FROM users WHERE max_user_id = {$maxUserId}";
|
||
$q_user = $this->db->query($sql_user);
|
||
$r_user = $this->db->fetch_assoc($q_user);
|
||
$user_id = (int)$r_user['id'];
|
||
$agency_id = (int)$r_user['company_id'] > 0 ? $r_user['company_id'] : $user_id;
|
||
$event = 'accept_work';
|
||
$table = 'events_clients';
|
||
$text = '';
|
||
if($type == 'object'){
|
||
$event = 'accept_work_object';
|
||
$table = 'objects_to_send';
|
||
$section = 'object';
|
||
}
|
||
$this->db->query("UPDATE max_events SET status = 1 WHERE max_user_id = {$maxUserId}");
|
||
|
||
$description = date('d-m-Y H:i:s').' - Запрос на принятие в работу';
|
||
$sql = "INSERT INTO max_events (max_user_id, mess_id, event, stage, service, status, description, user_id, agency_id)
|
||
VALUE ({$maxUserId}, {$event_id}, '{$event}', 1, 0, '{$status}', '{$description}', {$user_id}, {$agency_id})";
|
||
|
||
|
||
|
||
|
||
if(!$this->db->query($sql)){
|
||
$errors[] = $this->db->error();
|
||
}
|
||
|
||
$sql_ev = "SELECT * FROM {$table} WHERE id = {$event_id}";
|
||
|
||
$q_ev = $this->db->query($sql_ev);
|
||
$row_ev = $this->db->num_rows($q_ev);
|
||
$r_ev = $this->db->fetch_assoc($q_ev);
|
||
$field = '';
|
||
$field_val = 0;
|
||
$cancel_confirm = false;
|
||
if($row_ev == 0){
|
||
$cancel_confirm = true;
|
||
} else if(isset($r_ev['req_id']) && $r_ev['req_id'] > 0){
|
||
$field = 'req_id';
|
||
$field_val = $r_ev['req_id'];
|
||
$section = 'req';
|
||
} else if (isset($r_ev['client_id']) && $r_ev['client_id'] > 0){
|
||
$field = 'client_id';
|
||
$field_val = $r_ev['client_id'];
|
||
$section = 'client';
|
||
} else if (isset($r_ev['object_id']) && $r_ev['object_id'] > 0){
|
||
$field = 'object_id';
|
||
$field_val = $r_ev['object_id'];
|
||
|
||
}
|
||
$no_accept = false;
|
||
$is_confirm = false;
|
||
$is_rejected = false;
|
||
|
||
if($field_val > 0){
|
||
|
||
switch($section){
|
||
case 'req':{
|
||
$tr = 0;
|
||
|
||
if($r_ev['event'] == 'transmitted_parallel') $tr = 1;
|
||
|
||
$sql_cl = "SELECT `name` as `fio`, object_id, type_id, who_work, funnel_id, confirm, doers, (SELECT heir FROM requisitions_type WHERE id = requisitions.type_id) as heir FROM `requisitions` WHERE `id` = {$field_val}";
|
||
|
||
$q_cl = $this->db->query($sql_cl);
|
||
$r_cl = $this->db->fetch_assoc($q_cl);
|
||
if($tr == 0){
|
||
if($r_cl['who_work'] == $user_id){
|
||
if($r_cl['confirm'] == 1){
|
||
$sql_no = "SELECT * FROM events_clients WHERE user_id={$user_id} AND req_id = {$field_val} AND event = 'notadopted' AND `read` = 0";
|
||
$q_no = $this->db->query($sql_no);
|
||
if($this->db->num_rows($q_no) > 0){
|
||
$cl_fio_disp = should_hide_contacts_for_user_id($user_id) ? mask_fio_if_contains_phone($r_cl['fio']) : $r_cl['fio'];
|
||
$text = "«<b>" . $cl_fio_disp . "</b>»";
|
||
$is_rejected = true;
|
||
} else {
|
||
$is_confirm = true;
|
||
}
|
||
} else {
|
||
$sql_no = "SELECT * FROM events_clients WHERE user_id={$user_id} AND req_id = {$field_val} AND event = 'notadopted' AND `read` = 0";
|
||
$q_no = $this->db->query($sql_no);
|
||
if($this->db->num_rows($q_no) > 0){
|
||
$cl_fio_disp = should_hide_contacts_for_user_id($user_id) ? mask_fio_if_contains_phone($r_cl['fio']) : $r_cl['fio'];
|
||
$text = "«<b>" . $cl_fio_disp . "</b>»";
|
||
$is_rejected = true;
|
||
} else {
|
||
$sql = "UPDATE requisitions SET confirm=1, deleted=0, who_work={$user_id} WHERE id={$field_val}";
|
||
$this->db->query($sql);
|
||
// Автопривязка ответственного по заявке к клиенту из заявки
|
||
$sql = "UPDATE `clients`
|
||
JOIN `requisitions` AS `req` ON
|
||
`clients`.`id` = `req`.`client_id` AND
|
||
`clients`.`who_work` = 0 AND
|
||
`clients`.`confirm` = 0 AND
|
||
`req`.`id` = '{$field_val}' AND
|
||
`clients`.`who_work` = 0 AND
|
||
`clients`.`confirm` = 0
|
||
SET `clients`.`who_work` = '{$user_id}',
|
||
`clients`.`confirm` = 1";
|
||
|
||
$this->db->query($sql);
|
||
//Смена срока закрытия этапа
|
||
$sql_step = "SELECT * FROM clients_funnel_step WHERE req_id = {$field_val}";
|
||
$q_step = $this->db->query($sql_step);
|
||
if($this->db->num_rows($q_step) > 0){
|
||
$sql_op_step = "UPDATE clients_funnel_step SET date_update = NOW() WHERE req_id = {$field_val}";
|
||
$this->db->query($sql_op_step);
|
||
} else {
|
||
|
||
if($r_cl['funnel_id'] > 0){
|
||
$this->db->query("INSERT INTO clients_funnel_step (req_id) VALUES ({$field_val})");
|
||
}
|
||
}
|
||
$sql = "UPDATE user_client_events SET user_id={$user_id} WHERE req_id={$field_val} and type != 'step' and type != 'file'";
|
||
$this->db->query($sql);
|
||
$sql = "UPDATE `events_clients` SET `read` = 1, date_update='".date('Y-m-d H:i:s')."' WHERE req_id = {$field_val} AND event IN ('transmitted', 'notadopted')";
|
||
$this->db->query($sql);
|
||
$sql = "INSERT INTO `events_clients` (user_id, req_id, from_id, event, `read`) VALUES ({$user_id}, {$field_val}, {$user_id}, 'accepted', '1')";
|
||
$this->db->query($sql);
|
||
|
||
//Передача объекта
|
||
$agency = new User;
|
||
$agency->get($user_id);
|
||
|
||
$sqlUser = "SELECT `first_name`, `last_name`, `middle_name`, `phone` FROM `users` where id=".$user_id;
|
||
$qUser = $this->db->query($sqlUser);
|
||
$rUser = $this->db->fetch_assoc($qUser);
|
||
$sobstv = trim($rUser['last_name'] . ' ' . $rUser['first_name'] . ' ' . $rUser['middle_name']);
|
||
if ($_SESSION['agency']) {
|
||
$sobstv = $sobstv . ", агентство " . $rUser['agency_name'];
|
||
} else {
|
||
|
||
if (isset($agency->agencyName)) {
|
||
$sobstv = trim($rUser['last_name'] . ' ' . $rUser['first_name'] . ' ' . $rUser['middle_name']) . ", агентство " . $agency->agencyName;
|
||
} else {
|
||
$sobstv = trim($rUser['last_name'] . ' ' . $rUser['first_name'] . ' ' . $rUser['middle_name']);
|
||
}
|
||
}
|
||
|
||
|
||
if($r_cl['object_id'] && ($r_cl['type_id'] == 2 || $r_cl['heir'] == 2)){
|
||
$sql_up = "UPDATE objects SET id_add_user = {$user_id}, phone='".$rUser['phone']."', sobstv='".$sobstv."' WHERE id = ".$r_cl['object_id'];
|
||
//echo $sql_up;
|
||
$this->db->query($sql_up);
|
||
$sql_sph = "UPDATE objects SET id_add_user = {$user_id} WHERE id = ".$r_cl['object_id'];
|
||
|
||
$db_sphinx->query($sql_sph);
|
||
}
|
||
}
|
||
}
|
||
} else {
|
||
$sql_no = "SELECT * FROM events_clients WHERE user_id={$user_id} AND req_id = {$field_val} AND event = 'notadopted'";
|
||
$q_no = $this->db->query($sql_no);
|
||
if($this->db->num_rows($q_no) > 0){
|
||
$cl_fio_disp = should_hide_contacts_for_user_id($user_id) ? mask_fio_if_contains_phone($r_cl['fio']) : $r_cl['fio'];
|
||
$text = "«<b>" . $cl_fio_disp . "</b>»";
|
||
$is_rejected = true;
|
||
} else {
|
||
$no_accept = true;
|
||
}
|
||
$sql = "UPDATE `events_clients` SET `read` = 1, date_update='".date('Y-m-d H:i:s')."' WHERE req_id = {$field_val} AND event IN ('transmitted', 'notadopted')";
|
||
$this->db->query($sql);
|
||
|
||
}
|
||
} else if ($tr == 1){
|
||
|
||
|
||
if(!empty($r_cl['doers'])){
|
||
$confirm = 1;
|
||
$doers = json_decode(html_entity_decode($r_cl['doers']), true);
|
||
if($doers[$user_id] == 1){
|
||
$is_confirm = true;
|
||
} else {
|
||
$doers[$user_id] = 1;
|
||
foreach($doers as $doer){
|
||
if($doer == 0) $confirm = 0;
|
||
}
|
||
|
||
|
||
|
||
$sql_up = "UPDATE requisitions SET doers='".$this->clearInputElement(json_encode($doers))."', doers_confirm=$confirm WHERE id={$field_val}";
|
||
|
||
|
||
$this->db->query($sql_up);
|
||
|
||
|
||
foreach($doers as $key => $agent) {
|
||
$sql_up_d = "UPDATE requisition_doers SET confirm = {$agent} WHERE requisition_id ={$field_val} and user_id = {$key}";
|
||
$this->db->query($sql_up_d);
|
||
}
|
||
|
||
|
||
|
||
$sql_up_doer = "UPDATE doers_emp_client SET confirm=1 WHERE req_id ={$field_val} and who_work = $user_id and doer_id = $user_id";
|
||
|
||
$this->db->query($sql_up_doer);
|
||
|
||
|
||
$sql_2 = "UPDATE `events_clients` SET `read` = 1, date_update='".date('Y-m-d H:i:s')."' WHERE req_id = {$field_val} AND event IN ('transmitted_parallel', 'notadopted_doer') AND from_id = ".$user_id;
|
||
|
||
$this->db->query($sql_2);
|
||
|
||
$sql = "INSERT INTO `events_clients` (user_id, req_id, from_id, event, `read`) VALUES ('".$user_id."', '{$field_val}', '".$user_id."', 'accepted_doer', '1')";
|
||
|
||
$this->db->query($sql);
|
||
}
|
||
}
|
||
}
|
||
break;
|
||
}
|
||
case 'client': {
|
||
$tr = 0;
|
||
|
||
if($r_ev['event'] == 'transmitted_parallel') $tr = 1;
|
||
$sql_client = "SELECT objects, funnel_id, who_work, confirm, fio, phone, doers FROM clients WHERE id={$field_val}";
|
||
$q_client = $this->db->query($sql_client);
|
||
$r_client = $this->db->fetch_assoc($q_client);
|
||
|
||
if($tr == 0){
|
||
if($r_client['who_work'] == $user_id){
|
||
if($r_client['confirm'] == 1){
|
||
$sql_no = "SELECT * FROM events_clients WHERE client_id = {$field_val} AND `read`= 0 AND user_id={$user_id} AND event = 'notadopted'";
|
||
$q_no = $this->db->query($sql_no);
|
||
if($this->db->num_rows($q_no) > 0){
|
||
$cl_phone_disp = should_hide_contacts_for_user_id($user_id) ? mask_client_phone($r_client['phone']) : $r_client['phone'];
|
||
$cl_fio_disp = should_hide_contacts_for_user_id($user_id) ? mask_fio_if_contains_phone($r_client['fio']) : $r_client['fio'];
|
||
$text = "«<b>" . $cl_phone_disp." ".$cl_fio_disp . "</b>»";
|
||
$is_rejected = true;
|
||
} else {
|
||
$is_confirm = true;
|
||
}
|
||
} else {
|
||
|
||
$sql_no = "SELECT * FROM events_clients WHERE client_id = {$field_val} AND `read`= 0 AND user_id={$user_id} AND event = 'notadopted'";
|
||
$q_no = $this->db->query($sql_no);
|
||
if($this->db->num_rows($q_no) > 0){
|
||
$cl_phone_disp = should_hide_contacts_for_user_id($user_id) ? mask_client_phone($r_client['phone']) : $r_client['phone'];
|
||
$cl_fio_disp = should_hide_contacts_for_user_id($user_id) ? mask_fio_if_contains_phone($r_client['fio']) : $r_client['fio'];
|
||
$text = "«<b>" . $cl_phone_disp." ".$cl_fio_disp . "</b>»";
|
||
$is_rejected = true;
|
||
} else {
|
||
|
||
$sql = "UPDATE clients SET confirm=1, deleted=0, who_work={$user_id} WHERE id={$field_val}";
|
||
$this->db->query($sql);
|
||
//Смена срока закрытия этапа
|
||
$sql_step = "SELECT * FROM clients_funnel_step WHERE client_id = {$field_val}";
|
||
$q_step = $this->db->query($sql_step);
|
||
if($this->db->num_rows($q_step) > 0){
|
||
$sql_op_step = "UPDATE clients_funnel_step SET date_update = NOW() WHERE client_id = {$field_val}";
|
||
$this->db->query($sql_op_step);
|
||
} else {
|
||
|
||
if($r_client['funnel_id'] > 0){
|
||
$this->db->query("INSERT INTO clients_funnel_step (client_id) VALUES ({$field_val})");
|
||
}
|
||
}
|
||
|
||
$sql="UPDATE user_client_events SET user_id={$user_id} WHERE client_id={$field_val} and type != 'step' and type != 'file'";
|
||
$this->db->query($sql);
|
||
$sql = "UPDATE `events_clients` SET `read` = 1, date_update='".date('Y-m-d H:i:s')."' WHERE client_id = {$field_val} AND event IN ('transmitted', 'notadopted')";
|
||
$this->db->query($sql);
|
||
$sql = "INSERT INTO `events_clients` (user_id, client_id, from_id, event, `read`) VALUES ({$user_id}, {$field_val}, {$user_id}, 'accepted', '1')";
|
||
$this->db->query($sql);
|
||
//Передача объекта
|
||
$agency = new User;
|
||
$agency->get($user_id);
|
||
|
||
$sqlUser = "SELECT `first_name`, `last_name`, `middle_name`, `phone` FROM `users` where id=".$user_id;
|
||
$qUser = $this->db->query($sqlUser);
|
||
$rUser = $this->db->fetch_assoc($qUser);
|
||
$sobstv = trim($rUser['last_name'] . ' ' . $rUser['first_name'] . ' ' . $rUser['middle_name']);
|
||
if ($_SESSION['agency']) {
|
||
$sobstv = $sobstv . ", агентство " . $rUser['agency_name'];
|
||
} else {
|
||
|
||
if (isset($agency->agencyName)) {
|
||
$sobstv = trim($rUser['last_name'] . ' ' . $rUser['first_name'] . ' ' . $rUser['middle_name']) . ", агентство " . $agency->agencyName;
|
||
} else {
|
||
$sobstv = trim($rUser['last_name'] . ' ' . $rUser['first_name'] . ' ' . $rUser['middle_name']);
|
||
}
|
||
}
|
||
|
||
$sql_confirm_obj = "SELECT * FROM client_confirm_objects WHERE client_id = {$field_val} AND status = 0";
|
||
$q_confirm_obj = $this->db->query($sql_confirm_obj);
|
||
|
||
$is_confirm_obj = false;
|
||
if($this->db->num_rows($q_confirm_obj) > 0){
|
||
$r_confirm_obj = $this->db->fetch_assoc($q_confirm_obj);
|
||
|
||
$is_confirm_obj = (bool)$r_confirm_obj['confirm_objects'];
|
||
|
||
}
|
||
|
||
|
||
|
||
if($is_confirm_obj){
|
||
$sql_client = "SELECT * FROM `client_objects` WHERE client_id = {$field_val}";
|
||
$q_client = $this->db->query($sql_client);
|
||
|
||
|
||
while($object = $this->db->fetch_assoc($q_client)){
|
||
$sql_up = "UPDATE objects SET id_add_user = '".$user_id."', phone='".$rUser['phone']."', sobstv='".$sobstv."' WHERE id = ".$object;
|
||
//echo $sql_up;
|
||
$this->db->query($sql_up);
|
||
$sql_sph = "UPDATE objects SET id_add_user = {$user_id} WHERE id = ".$object;
|
||
|
||
$db_sphinx->query($sql_sph);
|
||
}
|
||
}
|
||
|
||
$this->db->query("UPDATE client_confirm_objects SET status = 1 WHERE client_id = {$field_val} AND status = 0");
|
||
}
|
||
}
|
||
} else {
|
||
$sql_no = "SELECT * FROM events_clients WHERE client_id = {$field_val} AND user_id={$user_id} AND event = 'notadopted'";
|
||
$q_no = $this->db->query($sql_no);
|
||
if($this->db->num_rows($q_no) > 0){
|
||
$cl_phone_disp = should_hide_contacts_for_user_id($user_id) ? mask_client_phone($r_client['phone']) : $r_client['phone'];
|
||
$cl_fio_disp = should_hide_contacts_for_user_id($user_id) ? mask_fio_if_contains_phone($r_client['fio']) : $r_client['fio'];
|
||
$text = "«<b>" . $cl_phone_disp." ".$cl_fio_disp . "</b>»";
|
||
$is_rejected = true;
|
||
} else {
|
||
$no_accept = true;
|
||
}
|
||
$sql = "UPDATE `events_clients` SET `read` = 1, date_update='".date('Y-m-d H:i:s')."' WHERE client_id = {$field_val} AND event IN ('transmitted', 'notadopted')";
|
||
$this->db->query($sql);
|
||
|
||
}
|
||
} else if ($tr == 1){
|
||
|
||
|
||
if(!empty($r_client['doers'])){
|
||
$confirm = 1;
|
||
$doers = json_decode(html_entity_decode($r_client['doers']), true);
|
||
if($doers[$user_id] == 1){
|
||
$is_confirm = true;
|
||
} else {
|
||
$doers[$user_id] = 1;
|
||
foreach($doers as $doer){
|
||
if($doer == 0) $confirm = 0;
|
||
}
|
||
|
||
|
||
|
||
$sql_up = "UPDATE clients SET doers='".$this->clearInputElement(json_encode($doers))."', doers_confirm=$confirm WHERE id={$field_val}";
|
||
|
||
|
||
$this->db->query($sql_up);
|
||
|
||
|
||
foreach($doers as $key => $agent) {
|
||
$sql_up_d = "UPDATE clients_doers SET confirm = {$agent} WHERE client_id ={$field_val} and user_id = {$key}";
|
||
$this->db->query($sql_up_d);
|
||
}
|
||
|
||
|
||
|
||
$sql_up_doer = "UPDATE doers_emp_client SET confirm=1 WHERE client_id ={$field_val} and who_work = $user_id and doer_id = $user_id";
|
||
|
||
$this->db->query($sql_up_doer);
|
||
|
||
|
||
$sql_2 = "UPDATE `events_clients` SET `read` = 1, date_update='".date('Y-m-d H:i:s')."' WHERE client_id = {$field_val} AND event IN ('transmitted_parallel', 'notadopted_doer') AND from_id = ".$user_id;
|
||
|
||
$this->db->query($sql_2);
|
||
|
||
$sql = "INSERT INTO `events_clients` (user_id, client_id, from_id, event, `read`) VALUES ('".$user_id."', '{$field_val}', '".$user_id."', 'accepted_doer', '1')";
|
||
|
||
$this->db->query($sql);
|
||
}
|
||
}
|
||
}
|
||
break;
|
||
} case 'object':{
|
||
if(!isset($r_ev['object_id']) || (int)$r_ev['object_id'] == 0){
|
||
$cancel_confirm = true;
|
||
} else
|
||
if($r_ev['new_user_id'] == $user_id){
|
||
if($r_ev['accept_state'] != 'NEW'){
|
||
if($r_ev['accept_state'] == 'REJECTED'){
|
||
$sql_obj = "SELECT * FROM objects WHERE id = {$field_val}";
|
||
$q_obj = $this->db->query($sql_obj);
|
||
$r_obj = $this->db->fetch_assoc($q_obj);
|
||
$text = "«<b>" . $r_obj['nazv'] . "</b>»";
|
||
$is_rejected = true;
|
||
|
||
} else {
|
||
$is_confirm = true;
|
||
}
|
||
} else {
|
||
$newUserId = $user_id;
|
||
$objectId = $field_val;
|
||
$newUser = new User;
|
||
$newUser->get($newUserId);
|
||
|
||
if (!$newUser->agencyId) {
|
||
$newUser->agencyId = $newUserId;
|
||
}
|
||
|
||
$currentUser = $newUser;
|
||
|
||
|
||
$phone = $newUser->phone;
|
||
$num_search = User::num_search($phone);
|
||
|
||
$sobstv = trim($newUser->last_name . ' ' . $newUser->first_name . ' ' . $newUser->middle_name);
|
||
|
||
if ($newUser->agency == 0) {
|
||
$sql="SELECT * FROM users WHERE id=$newUser->id_manager";
|
||
$rez=$this->db->query($sql);
|
||
$manager = $this->db->fetch_assoc($rez);
|
||
|
||
if($manager['id_manager']) {
|
||
$agency = $this->db->fetch_assoc($this->db->query("SELECT * FROM users WHERE id=$manager[id_manager]"));
|
||
} else {
|
||
$agency = $manager;
|
||
}
|
||
if ($agency) {
|
||
$sobstv = trim($currentUser->last_name . ' ' . $currentUser->first_name . ' ' . $currentUser->middle_name) . ", агентство " . $agency['agency_name'];
|
||
}
|
||
} else {
|
||
$sobstv = $sobstv . ", агентство " . $newUser->agency_name;
|
||
}
|
||
|
||
$webHookIn = new WebHookIn(null, $agency_id);
|
||
|
||
$is_send_webhook = $webHookIn->check_hook('object_update', 'object');
|
||
|
||
|
||
if($is_send_webhook){
|
||
$webHookIn->save_temp_object($objectId);
|
||
}
|
||
|
||
// перенос всех объектов
|
||
$sql = "UPDATE objects SET id_add_user = $newUser->id, phone = '$phone', phone_search = '$num_search', sobstv = '$sobstv', is_main = 0 WHERE id=$objectId";
|
||
$rez = $this->db->query($sql);
|
||
|
||
//Запись в сфинкс
|
||
$sql_sph = "UPDATE objects SET id_add_user=$newUser->id, phone_search = '$num_search' WHERE id=$objectId";
|
||
$db_sphinx->query($sql_sph);
|
||
|
||
|
||
//перенос событий объектов
|
||
$sqlObjEvents = "UPDATE user_object_events SET user_id=$newUser->id WHERE object_id=$objectId";
|
||
$this->db->query($sqlObjEvents);
|
||
|
||
//перенос комментариев объектов
|
||
$sqlObjCom = "UPDATE user_object_comments SET user_id=$newUser->id WHERE object_id=$objectId";
|
||
$this->db->query($sqlObjCom);
|
||
|
||
// перенос Зипал
|
||
$sql = "UPDATE zipal_objects SET user_id=$newUser->id, send_to_update=1 WHERE object_id=$objectId";
|
||
$rez = $this->db->query($sql);
|
||
|
||
$sqlPack = "UPDATE advertising_package_object_publish SET send_to_update = '1', error_when_send_to_update = '' WHERE object_id=$objectId";
|
||
$this->db->query($sqlPack);
|
||
|
||
|
||
$sql = "UPDATE objects_to_send SET accept_date=NOW(), accept_state='ACCEPTED' WHERE id=$event_id";
|
||
$this->db->query($sql);
|
||
|
||
/**
|
||
* Передача заявок Реализация
|
||
*/
|
||
$sql_req = "SELECT id, `name`, object_id, type_id, who_work, funnel_id, confirm FROM `requisitions` WHERE object_id = {$objectId} AND cancel=0 AND deleted=0 AND (type_id = 2 or (SELECT heir FROM requisitions_type WHERE id = requisitions.type_id) = 2) AND who_work != '".$newUser->id."'";
|
||
//echo $sql_req."\n";
|
||
$q_req = $this->db->query($sql_req);
|
||
if($this->db->num_rows($q_req) > 0){
|
||
while($r_req = $this->db->fetch_assoc($q_req)){
|
||
$sql_up = "UPDATE requisitions SET confirm=1, who_work={$newUser->id} WHERE id={$r_req['id']}";
|
||
//echo $sql_up."\n";
|
||
if($this->db->query($sql_up)){
|
||
$sql_ev = "INSERT INTO `events_clients` (user_id, req_id, from_id, event, `read`, dop_text) VALUES ('".$user_id."', '{$r_req['id']}', '".$newUser->id."', 'update', '1', 'Переведена на ответственного при принятии объекта ID {$objectId}')";
|
||
//file_put_contents($_SERVER['DOCUMENT_ROOT']."/log_task_telega.txt", date('d.m.y H:i:s').' chat_id '.$chatId.' id:'.$event_id." ". $sql_ev."\n", FILE_APPEND);
|
||
$this->db->query($sql_ev);
|
||
}
|
||
}
|
||
}
|
||
if($is_send_webhook){
|
||
$dataWhook = array('action'=>'object_update', 'object_id'=>$objectId, 'section'=>'object', 'user_id'=>$user_id, 'agency_id'=>$agency_id);
|
||
$webHookIn->check_send($dataWhook);
|
||
|
||
}
|
||
}
|
||
} else {
|
||
$no_accept = true;
|
||
}
|
||
break;
|
||
}
|
||
}
|
||
|
||
|
||
}
|
||
|
||
$result = array('result'=>$event, 'section'=>$section, 'event_id' => $event_id, 'id' => $field_val);
|
||
|
||
if($no_accept) $result['no_accept'] = 1;
|
||
if($is_confirm) $result['is_confirm'] = 1;
|
||
if($cancel_confirm) $result['cancel_confirm'] = 1;
|
||
if($is_rejected) $result['is_rejected'] = 1;
|
||
if(!empty($text)) $result['text'] = $text;
|
||
// file_put_contents($_SERVER['DOCUMENT_ROOT']."/log_task_telega.txt", date('d.m.y H:i:s').' chat_id '.$chatId.' id:'.$event_id." ".json_encode($result, JSON_UNESCAPED_UNICODE)."\n", FILE_APPEND);
|
||
} else {
|
||
$errors[] = 'Empty data';
|
||
}
|
||
|
||
if(!empty($errors)){
|
||
file_put_contents($_SERVER['DOCUMENT_ROOT']."/log_task_max.txt", date('d.m.y H:i:s').' user_id '.$maxUserId.' id:'.$event_id." ".json_encode($errors, JSON_UNESCAPED_UNICODE)."\n", FILE_APPEND);
|
||
return array('result'=>'error');
|
||
}
|
||
return $result;
|
||
}
|
||
|
||
} |