331 lines
14 KiB
PHP
331 lines
14 KiB
PHP
|
<?php
|
||
|
|
require_once($_SERVER['DOCUMENT_ROOT']."/config.php");
|
||
|
|
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;
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
header('Content-Type: application/json');
|
||
|
|
|
||
|
|
ini_set('display_errors', 1);
|
||
|
|
error_reporting(E_ALL & ~E_DEPRECATED & ~E_STRICT & ~E_NOTICE);
|
||
|
|
|
||
|
|
$pdo = new MysqlPdo(hst, ndb, user, pass);
|
||
|
|
$sql = "SET NAMES 'utf8'";
|
||
|
|
$pdo->query($sql);
|
||
|
|
|
||
|
|
$content = file_get_contents('php://input');
|
||
|
|
|
||
|
|
|
||
|
|
if($_SESSION['id'] == 19895){
|
||
|
|
|
||
|
|
$content = '{"visit":{"user_agent":"Mozilla\/5.0 (iPhone; CPU iPhone OS 18_3_2 like Mac OS X) AppleWebKit\/605.1.15 (KHTML, like Gecko) Version\/18.3.1 Mobile\/15E148 Safari\/604.1","ip":"81.195.139.102","geolocation":"Russia","referer":"","utm_source":"yandex","utm_medium":"cpc","utm_campaign":"105004781","utm_content":"15735512868","utm_term":""},"member":{"id":"0"},"site":{"id":"254627","name":"Алеан","url":"https:\/\/sochialean.ru"},"page":{"id":"1500754","name":"ALEAN RESORT MONTVERT","url":"https:\/\/sochialean.ru","path":"","query":{"utm_source":"yandex","utm_medium":"cpc","utm_campaign":"105004781","utm_content":"15735512868","utm_term":"","yclid":"6223342296479301631","y_ref":"ru.mail.mail"}},"order":{"id":"14045815","form_name":"Планировка - 22 м","fields":[{"id":"","name":"Имя","value":"Виктор"},{"id":"","name":"Номер телефона","value":"+7 (918) 525-77-04"},{"id":"","name":"Куда отправить ?","value":"Отправить в WhatsApp"},{"id":"","name":"utm_source","value":"yandex"},{"id":"","name":"utm_medium","value":"cpc"},{"id":"","name":"utm_campaign","value":"105004781"},{"id":"","name":"utm_content","value":"15735512868"},{"id":"","name":"utm_term","value":""}],"fields_by_name":{"Имя":"Виктор","Номер телефона":"+7 (918) 525-77-04","Куда отправить ?":"Отправить в WhatsApp","utm_source":"yandex","utm_medium":"cpc","utm_campaign":"105004781","utm_content":"15735512868","utm_term":""}},"cart":{"text":"","subtotal":"0"},"token":"61d64a35558b92a5dc79dc4f5d6bbc5f"}';
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
$message = json_decode($content, true);
|
||
|
|
|
||
|
|
//var_dump($message);
|
||
|
|
|
||
|
|
if(!isset($message['token']) || empty($message['token'])) die();
|
||
|
|
|
||
|
|
$sql_user = "SELECT api_key, users.id FROM user_api_keys LEFT JOIN users ON users.id = user_api_keys.user_id WHERE api_key = '{$message['token']}'";
|
||
|
|
|
||
|
|
$q_user = $pdo->query($sql_user, true);
|
||
|
|
|
||
|
|
$r_user = $pdo->fetch_assoc($q_user);
|
||
|
|
|
||
|
|
if(!$r_user || empty($r_user['id'])) {
|
||
|
|
die();
|
||
|
|
} else if ((int)$r_user['id'] > 0){
|
||
|
|
$user_id = (int)$r_user['id'];
|
||
|
|
$user = new User();
|
||
|
|
$user->get($user_id);
|
||
|
|
$url = parse_url($message['site']['url']);
|
||
|
|
|
||
|
|
$domain = $url['host'];
|
||
|
|
$nameSourse = trim($message['site']['name']);
|
||
|
|
|
||
|
|
$CallEvents = new CallEvents();
|
||
|
|
|
||
|
|
$funnel_id = 0;
|
||
|
|
$user_id = 0;
|
||
|
|
$funnel_id_req = 0;
|
||
|
|
$activities_id = 0;
|
||
|
|
$source_id = 0;
|
||
|
|
$users = array();
|
||
|
|
$client_id = 0;
|
||
|
|
$email = '';
|
||
|
|
$partner = 0;
|
||
|
|
$user_id_req = 0;
|
||
|
|
$agency_id = 0;
|
||
|
|
|
||
|
|
if($user->agencyId == 19895){
|
||
|
|
$user_id = 19895;
|
||
|
|
$agency_id = 19895;
|
||
|
|
$funnel_id_req = 1513;
|
||
|
|
$user_id_req = 19895;
|
||
|
|
}
|
||
|
|
|
||
|
|
$users = array_keys($CallEvents->getAllUserAgency($user->agencyId, $users));
|
||
|
|
|
||
|
|
$fio_client = "Имя не указано";
|
||
|
|
$opis = 'Сайт: '.$nameSourse;
|
||
|
|
if(isset($message['order']['fields'])){
|
||
|
|
foreach($message['order']['fields'] as $field){
|
||
|
|
if($opis != '') $opis .= "<br>";
|
||
|
|
$opis .= $field['name'] . ": " . $field['value'];
|
||
|
|
if(mb_strtolower($field['name']) == 'имя'){
|
||
|
|
$fio_client = $field['value'];
|
||
|
|
} else if (mb_strtolower($field['name']) == 'номер телефона'
|
||
|
|
|| mb_strtolower($field['name']) == 'телефон')
|
||
|
|
{
|
||
|
|
$phone = str_replace(['(',')',' ','-'], '', $field['value']);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if($agency_id == 19895){
|
||
|
|
$opis = '';
|
||
|
|
}
|
||
|
|
|
||
|
|
if(!isset($phone)) die();
|
||
|
|
|
||
|
|
|
||
|
|
if($source_id == 0){
|
||
|
|
//Поиск источника по домену
|
||
|
|
$sql_d = "SELECT *, (SELECT group_id FROM advertising_sources WHERE id = advertising_sources_domain.adv_id) AS group_id FROM `advertising_sources_domain` WHERE domain = '{$domain}' AND `type` = 3";
|
||
|
|
|
||
|
|
$q_d = $pdo->query($sql_d, true);
|
||
|
|
$r_d = $pdo->fetch_assoc($q_d);
|
||
|
|
if($r_d){
|
||
|
|
$source_id = (int)$r_d['adv_id'];
|
||
|
|
$group_id = (int)$r_d['group_id'];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if($source_id == 0){
|
||
|
|
//Поиск источника
|
||
|
|
$sql_source = "SELECT id FROM `advertising_sources` WHERE source
|
||
|
|
= '".$nameSourse."' AND (user_id in (".implode(',', $users).") or manager_id in (".implode(',', $users)."))";
|
||
|
|
$q_source = $pdo->query($sql_source);
|
||
|
|
$r_source = $pdo->fetch_assoc($q_source);
|
||
|
|
if($r_source['id'] > 0){
|
||
|
|
$source_id = $r_source['id'];
|
||
|
|
//echo $source_id."\n";
|
||
|
|
} else {
|
||
|
|
$sql_up = "INSERT INTO `advertising_sources` SET source='".$nameSourse."', user_id={$user_id}, manager_id={$user->agencyId}";
|
||
|
|
$pdo->query($sql_up);
|
||
|
|
$source_id = $pdo->insert_id();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
//Поиск тега
|
||
|
|
if($agency_id == 19895){
|
||
|
|
if($source_id > 0){
|
||
|
|
$sql_aa = "SELECT * FROM advertising_sources_activities WHERE source_id = {$source_id}";
|
||
|
|
|
||
|
|
$q_aa = $pdo->query($sql_aa, true);
|
||
|
|
while($r_aa = $pdo->fetch_assoc($q_aa)) {
|
||
|
|
$activities_ids[] = (int)$r_aa['activities_id'];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// var_dump($activities_ids);
|
||
|
|
} else {
|
||
|
|
$sql_activites = "SELECT id FROM `activities` WHERE name = '".$nameSourse."' AND (user_id in (".implode(',', $users).") or manager_id in (".implode(',', $users)."))";
|
||
|
|
|
||
|
|
$q_aclivites = $pdo->query($sql_activites);
|
||
|
|
$r_activites = $pdo->fetch_assoc($q_aclivites);
|
||
|
|
if($r_activites['id'] > 0){
|
||
|
|
$activities_id = $r_activites['id'];
|
||
|
|
//echo $activities_id."\n";
|
||
|
|
} else {
|
||
|
|
$sql_up = "INSERT INTO `activities` SET name='".$nameSourse."', user_id={$user_id}, manager_id={$user->agencyId}";
|
||
|
|
$pdo->query($sql_up);
|
||
|
|
$activities_id = $pdo->insert_id();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
$hot = 0;
|
||
|
|
if($agency_id == 19895 && $group_id == 290){
|
||
|
|
$hot = 1;
|
||
|
|
}
|
||
|
|
$confirm = 1;
|
||
|
|
$who_work = $user_id;
|
||
|
|
if($agency_id == 19895){
|
||
|
|
//Поиск ответственного по источнику
|
||
|
|
$sql_w = "SELECT * FROM advertising_sources_who_work WHERE adv_id = {$source_id}";
|
||
|
|
|
||
|
|
$q_w = $pdo->query($sql_w);
|
||
|
|
if($pdo->num_rows($q_w) > 0){
|
||
|
|
$r_w = $pdo->fetch_assoc($q_w);
|
||
|
|
$user_id = $who_work = (int)$r_w['who_work'];
|
||
|
|
} else {
|
||
|
|
$confirm = 0;
|
||
|
|
$who_work = 0;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
$sql = "SELECT `id`, `stage`, `deleted` FROM `clients` WHERE cancel=0 AND (phone = '$phone' OR id in (SELECT client_id FROM clients_phone2 WHERE phone = '$phone')) and (who_work in (".implode(',', $users).") or id_agent in (".implode(',', $users)."))";
|
||
|
|
|
||
|
|
$client = $pdo->fetch_assoc($pdo->query($sql));
|
||
|
|
if(!empty($client) && $client){
|
||
|
|
$client_id = $client['id'];
|
||
|
|
} else {
|
||
|
|
|
||
|
|
$sql = "INSERT INTO clients SET phone='{$phone}', hot={$hot}, email='{$email}', fio='{$fio_client}', opis='{$opis}', id_agent={$user_id}, who_work={$who_work}, date_add=NOW(), confirm={$confirm}, funnel_id={$funnel_id}, stage=1, source= '{$source_id}', integration=4";
|
||
|
|
//echo $sql;
|
||
|
|
$pdo->query($sql);
|
||
|
|
$client_id = $pdo->insert_id();
|
||
|
|
|
||
|
|
if($funnel_id > 0){
|
||
|
|
$Clients = new Clients;
|
||
|
|
$Clients->get_class_etap($client_id, $funnel_id);
|
||
|
|
}
|
||
|
|
if($activities_id){
|
||
|
|
$sql_a = "INSERT INTO `clients_activities` (`activity_id`, `client_id`) VALUES ({$activities_id}, {$client_id})";
|
||
|
|
$pdo->query($sql_a);
|
||
|
|
} else if($activities_ids && !empty($activities_ids)){
|
||
|
|
foreach($activities_ids as $activities_id){
|
||
|
|
$sql_a = "INSERT INTO `clients_activities` (`activity_id`, `client_id`) VALUES ({$activities_id}, {$client_id})";
|
||
|
|
$pdo->query($sql_a);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
if($client_id > 0){
|
||
|
|
$web_hook_in = new WebHookIn($pdo);
|
||
|
|
$reqid=(int)$web_hook_in->check_is_req($who_work, $source_id, $client_id);
|
||
|
|
if($reqid > 0 && $agency_id == 19895) {
|
||
|
|
$comment = "Обращался повторно<br>";
|
||
|
|
if(!empty($activities_ids)){
|
||
|
|
$sql_activites = "SELECT * FROM activities WHERE id in (".implode(',', $activities_ids).")";
|
||
|
|
$q_aclivites = $pdo->query($sql_activites);
|
||
|
|
$comment .= "Теги: ";
|
||
|
|
while($r_activites = $pdo->fetch_assoc($q_aclivites)){
|
||
|
|
$comment .= $r_activites['name']." ";
|
||
|
|
}
|
||
|
|
$sql_ev = "INSERT INTO user_client_events (req_id, `type`, comment, user_id, from_id, create_date, calendar_view)
|
||
|
|
VALUES ($reqid, 'comment', '{$comment}', {$user_id}, {$user_id}, NOW(), 1)";
|
||
|
|
$pdo->query($sql_ev);
|
||
|
|
|
||
|
|
}
|
||
|
|
die();
|
||
|
|
}
|
||
|
|
$name_req = 'Подбор объекта для '.$fio_client;
|
||
|
|
if($agency_id == 19895){
|
||
|
|
$name_req = $fio_client;
|
||
|
|
}
|
||
|
|
//Поиск воронки по источнику
|
||
|
|
if($source_id > 0){
|
||
|
|
$sql_req_funnel="SELECT * FROM advertising_sources_funnel WHERE source_id = {$source_id}";
|
||
|
|
$q_req_funnel = $pdo->query($sql_req_funnel, true);
|
||
|
|
$r_req_funnel = $pdo->fetch_assoc($q_req_funnel);
|
||
|
|
if($r_req_funnel && $r_req_funnel['funnel_id_req'] > 0){
|
||
|
|
$funnel_id_req = (int)$r_req_funnel['funnel_id_req'];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
$sql = "INSERT INTO requisitions SET client_id={$client_id}, hot={$hot}, name='{$name_req}', description='{$opis}', user_id={$user_id}, integration=4, who_work={$who_work}, type_id=1, confirm={$confirm}, funnel_id={$funnel_id_req}, stage=1, source= '{$source_id}'";
|
||
|
|
|
||
|
|
|
||
|
|
$pdo->query($sql);
|
||
|
|
$req_id = $pdo->insert_id();
|
||
|
|
if($funnel_id_req > 0){
|
||
|
|
$Requisitions = new Requisitions();
|
||
|
|
$Requisitions->get_class_etap($req_id, $funnel_id_req);
|
||
|
|
}
|
||
|
|
if($activities_ids && !empty($activities_ids)){
|
||
|
|
foreach($activities_ids as $activities_id){
|
||
|
|
$sql_a = "INSERT INTO `requisitions_activities` (`activity_id`, `req_id`) VALUES ({$activities_id}, {$req_id})";
|
||
|
|
$pdo->query($sql_a);
|
||
|
|
}
|
||
|
|
} else
|
||
|
|
if($activities_id){
|
||
|
|
$sql_a = "INSERT INTO `requisitions_activities` (`activity_id`, `req_id`) VALUES ({$activities_id}, {$req_id})";
|
||
|
|
$pdo->query($sql_a);
|
||
|
|
}
|
||
|
|
|
||
|
|
if($who_work > 0){
|
||
|
|
$comment = "Сайт ".$nameSourse;
|
||
|
|
|
||
|
|
$sql_add = "INSERT INTO `events_clients` (`user_id`, `req_id`, `from_id`, `event`, `dop_text`, `read`) ".
|
||
|
|
"VALUES ({$who_work}, {$req_id}, {$who_work}, 'add', '{$comment}', 2)";
|
||
|
|
$pdo->query($sql_add);
|
||
|
|
|
||
|
|
/*$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, $req_id, '".date('Y-m-d H:i:s')."', '".date('Y-m-d H:i:s', strtotime('+15 minutes'))."', 'call', '{$comment}', 0, {$user_id_req})";
|
||
|
|
$pdo->query($sql_in_ev);*/
|
||
|
|
}
|
||
|
|
|
||
|
|
if($agency_id == 19895 && $req_id > 0){
|
||
|
|
$arr_data = array();
|
||
|
|
if(isset($message['order']['fields'])){
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
foreach($message['order']['fields'] as $field){
|
||
|
|
$field_name = str_replace('utm_', 'UTM ',trim($field['name']));
|
||
|
|
$field_val = trim($field['value']);
|
||
|
|
$sql_fields = "SELECT * FROM `client_req_fields` WHERE title = '{$field_name}' AND agency_id = {$agency_id}";
|
||
|
|
//echo $sql_fields."\n";
|
||
|
|
$q_fields = $pdo->query($sql_fields);
|
||
|
|
$r_fields = $pdo->fetch_assoc($q_fields);
|
||
|
|
if($r_fields){
|
||
|
|
|
||
|
|
if($r_fields['type'] == 1 || $r_fields['type'] == 0){
|
||
|
|
|
||
|
|
|
||
|
|
$arr_data[] = "({$req_id}, {$r_fields['id']}, 1, '\"{$field_val}\"')";
|
||
|
|
|
||
|
|
} elseif ($r_fields['type'] == 2){
|
||
|
|
$params = json_decode($r_fields['params'], true);
|
||
|
|
//var_dump($params['items']);
|
||
|
|
foreach($params['items'] as $item){
|
||
|
|
if(trim($item['name']) == $field_val){
|
||
|
|
$id_item = $item['value'];
|
||
|
|
$arr_data[] = "({$req_id}, {$r_fields['id']}, 1, {$id_item})";
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
}
|
||
|
|
if(!empty($arr_data)){
|
||
|
|
$sql_data = "INSERT INTO requisition_data (`req_id`, `field_id`, `type`, `value`) VALUES ".implode(',' , $arr_data);
|
||
|
|
//echo $sql_data;
|
||
|
|
$pdo->query($sql_data);
|
||
|
|
}
|
||
|
|
|
||
|
|
$rqClass = new Requisitions(null, true);
|
||
|
|
$rqClass->set_agencyId($agency_id);
|
||
|
|
$rqClass->set_userId($user_id);
|
||
|
|
$rqClass->autoUnitReq(1, $req_id);
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|