428 lines
18 KiB
PHP
428 lines
18 KiB
PHP
<?php
|
||
error_reporting(E_ALL);
|
||
ini_set('display_errors', '1');
|
||
|
||
// Для POST запросов отключаем вывод ошибок в HTML
|
||
$IS_POST = ($_SERVER['REQUEST_METHOD'] === 'POST');
|
||
if ($IS_POST) {
|
||
ini_set('display_errors', '0');
|
||
ini_set('display_startup_errors', '0');
|
||
}
|
||
|
||
// Функция для записи в лог
|
||
function writeLog($message) {
|
||
$timestamp = date('Y-m-d H:i:s');
|
||
$line = "[$timestamp] $message\n";
|
||
// Пробуем писать в основной лог
|
||
@file_put_contents(__DIR__ . '/logs/upload_documents_v2.log', $line, FILE_APPEND | LOCK_EX);
|
||
// И в /tmp как запасной вариант
|
||
@file_put_contents('/tmp/upload_documents_v2.log', $line, FILE_APPEND | LOCK_EX);
|
||
// И в системный лог
|
||
error_log('[upload_documents_v2] ' . $message);
|
||
}
|
||
|
||
// Функция для JSON ответа
|
||
function json_response($data, $code = 200) {
|
||
if (!headers_sent()) {
|
||
http_response_code($code);
|
||
header('Content-Type: application/json; charset=utf-8');
|
||
}
|
||
echo json_encode($data, JSON_UNESCAPED_UNICODE);
|
||
exit;
|
||
}
|
||
|
||
// Быстрый ping
|
||
if (isset($_GET['ping'])) {
|
||
header('Content-Type: text/plain; charset=utf-8');
|
||
echo 'pong v2';
|
||
exit;
|
||
}
|
||
|
||
// Для POST запросов регистрируем обработчик фатальных ошибок
|
||
if ($IS_POST) {
|
||
register_shutdown_function(function() {
|
||
$error = error_get_last();
|
||
if ($error && in_array($error['type'], [E_ERROR, E_PARSE, E_CORE_ERROR, E_COMPILE_ERROR])) {
|
||
writeLog('FATAL: ' . $error['message'] . ' in ' . $error['file'] . ':' . $error['line']);
|
||
json_response([
|
||
'success' => false,
|
||
'error' => [
|
||
'type' => 'fatal',
|
||
'message' => 'Internal error'
|
||
]
|
||
], 500);
|
||
}
|
||
});
|
||
}
|
||
|
||
// Функция для инициализации CRM (вызывается только при необходимости)
|
||
function initializeCRM() {
|
||
global $adb, $crmPath;
|
||
|
||
$crmPath = '/var/www/fastuser/data/www/crm.clientright.ru/';
|
||
|
||
require_once $crmPath . 'config.inc.php';
|
||
require_once $crmPath . 'include/utils/utils.php';
|
||
require_once $crmPath . 'includes/Loader.php';
|
||
vimport('includes.runtime.Globals');
|
||
require_once $crmPath . 'include/database/PearDatabase.php';
|
||
require_once $crmPath . 'modules/Users/Users.php';
|
||
require_once $crmPath . 'include/Webservices/Utils.php';
|
||
require_once $crmPath . 'include/Webservices/Create.php';
|
||
require_once $crmPath . 'include/Webservices/AddRelated.php';
|
||
|
||
$adb = PearDatabase::getInstance();
|
||
}
|
||
|
||
// Вспомогательные функции
|
||
function getUserWsPrefix() {
|
||
global $adb;
|
||
$rs = $adb->pquery("SELECT id FROM vtiger_ws_entity WHERE name=?", ['Users']);
|
||
return ($rs && $adb->num_rows($rs) > 0) ? $adb->query_result($rs, 0, 'id') : 19;
|
||
}
|
||
|
||
function getProjectWsIdFromDB($projectId) {
|
||
global $adb;
|
||
$rs = $adb->pquery("SELECT id FROM vtiger_ws_entity WHERE name=?", ['Project']);
|
||
return ($rs && $adb->num_rows($rs) > 0) ? $adb->query_result($rs, 0, 'id') . 'x' . (int)$projectId : null;
|
||
}
|
||
|
||
function getDocumentFoldersWsPrefix() {
|
||
global $adb;
|
||
$rs = $adb->pquery("SELECT id FROM vtiger_ws_entity WHERE name=?", ['DocumentFolders']);
|
||
return ($rs && $adb->num_rows($rs) > 0) ? (int)$adb->query_result($rs, 0, 'id') : 22;
|
||
}
|
||
|
||
function getFolderWsIdByName($folderName) {
|
||
global $adb;
|
||
$rs = $adb->pquery('SELECT folderid FROM vtiger_attachmentsfolder WHERE foldername = ? LIMIT 1', [$folderName]);
|
||
if ($rs && $adb->num_rows($rs) > 0) {
|
||
$folderId = (int)$adb->query_result($rs, 0, 'folderid');
|
||
$prefix = getDocumentFoldersWsPrefix();
|
||
return $prefix . 'x' . $folderId;
|
||
}
|
||
return null;
|
||
}
|
||
|
||
// 🚀 НОВАЯ ФУНКЦИЯ: Создание документов с готовой сессией (формат v3)
|
||
function createDocumentsWithSession($data) {
|
||
global $adb, $current_user;
|
||
|
||
// Инициализируем CRM только при необходимости
|
||
initializeCRM();
|
||
|
||
$sessionName = $data['sessionName'];
|
||
$projectId = (int)$data['projectid'];
|
||
$contactId = (int)$data['contactid'];
|
||
$userId = (int)($data['user_id'] ?? 1);
|
||
$filesArray = $data['files'] ?? [];
|
||
|
||
writeLog('🚀 Начинаем создание документов с готовой сессией: ' . $sessionName);
|
||
writeLog("📋 Проект: $projectId, Контакт: $contactId, Пользователь: $userId");
|
||
writeLog('📋 Файлов к обработке: ' . count($filesArray));
|
||
|
||
// Устанавливаем current_user для CRMEntity
|
||
$current_user = new Users();
|
||
$current_user->retrieveCurrentUserInfoFromFile($userId);
|
||
|
||
// Получаем WS ID проекта один раз
|
||
$projectWsId = getProjectWsIdFromDB($projectId);
|
||
if (!$projectWsId) {
|
||
writeLog("❌ Не найден Project ID $projectId");
|
||
return ['error' => "Не найден Project ID $projectId"];
|
||
}
|
||
writeLog("✅ Project WS ID: $projectWsId");
|
||
|
||
// WS ID пользователя
|
||
$usersPrefix = getUserWsPrefix();
|
||
$assignedUserWsId = $usersPrefix . 'x' . $userId;
|
||
|
||
// Папка (сначала Суд, потом Default)
|
||
$folderWsId = getFolderWsIdByName('Суд');
|
||
if (!$folderWsId) {
|
||
$folderWsId = '22x1';
|
||
writeLog("⚠️ Папка 'Суд' не найдена, используем Default");
|
||
}
|
||
writeLog("📁 Папка: $folderWsId");
|
||
|
||
// Инициализируем CURL
|
||
$ch = curl_init();
|
||
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
|
||
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
|
||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
||
curl_setopt($ch, CURLOPT_URL, 'https://crm.clientright.ru/webservice.php');
|
||
curl_setopt($ch, CURLOPT_POST, 1);
|
||
|
||
$results = [];
|
||
|
||
foreach ($filesArray as $i => $file) {
|
||
$fileName = $file['original_file_name'] ?? $file['file_name'] ?? 'Unknown';
|
||
writeLog("📄 Обрабатываем файл #{$i}: $fileName");
|
||
|
||
try {
|
||
// Проверяем обязательные поля
|
||
if (empty($file['file_url'])) {
|
||
throw new Exception("Отсутствует file_url");
|
||
}
|
||
|
||
// Определяем название и описание документа
|
||
$documentTitle = $file['upload_description'] ?? $file['original_file_name'] ?? $file['file_name'] ?? 'Документ';
|
||
$documentContent = sprintf(
|
||
'Загружено через n8n. ID: %s, Контакт: %d, Проект: %d, Загружено: %s',
|
||
$file['id'] ?? 'N/A',
|
||
$contactId,
|
||
$projectId,
|
||
$file['uploaded_at'] ?? date('Y-m-d H:i:s')
|
||
);
|
||
|
||
// Создаём документ
|
||
$docElement = [
|
||
'notes_title' => $documentTitle,
|
||
'filename' => $file['file_url'],
|
||
'assigned_user_id' => $assignedUserWsId,
|
||
'notecontent' => $documentContent,
|
||
'filetype' => 'application/pdf',
|
||
'filesize' => '0',
|
||
'filelocationtype' => 'E', // External URL
|
||
'fileversion' => '1.0',
|
||
'filestatus' => '1', // Active
|
||
'folderid' => $folderWsId,
|
||
];
|
||
|
||
writeLog("📤 Создаём документ '$documentTitle'");
|
||
|
||
// Отправляем запрос на создание документа
|
||
curl_setopt($ch, CURLOPT_POSTFIELDS, [
|
||
'operation' => 'create',
|
||
'sessionName' => $sessionName,
|
||
'elementType' => 'Documents',
|
||
'element' => json_encode($docElement, JSON_UNESCAPED_UNICODE),
|
||
]);
|
||
|
||
$resp = curl_exec($ch);
|
||
if ($resp === false) {
|
||
throw new Exception('CURL error: ' . curl_error($ch));
|
||
}
|
||
|
||
$resp = ltrim($resp, "\xEF\xBB\xBF\x00\x09\x0A\x0D\x20");
|
||
writeLog("📥 Ответ создания документа: " . substr($resp, 0, 300));
|
||
|
||
$doc = json_decode($resp, true);
|
||
if (!$doc || !$doc['success'] || empty($doc['result']['id'])) {
|
||
throw new Exception('Failed to create document: ' . substr($resp, 0, 200));
|
||
}
|
||
|
||
$documentWsId = $doc['result']['id'];
|
||
list(, $docNumericId) = explode('x', $documentWsId, 2);
|
||
|
||
writeLog("✅ Документ создан: $documentWsId");
|
||
|
||
// Привязываем к проекту
|
||
writeLog("🔗 Привязываем документ $documentWsId к проекту $projectWsId");
|
||
|
||
curl_setopt($ch, CURLOPT_POSTFIELDS, [
|
||
'operation' => 'AddRelated',
|
||
'sessionName' => $sessionName,
|
||
'sourceRecordId' => $projectWsId,
|
||
'relatedRecordId' => $documentWsId,
|
||
]);
|
||
|
||
$resp = curl_exec($ch);
|
||
$relationOk = false;
|
||
|
||
if ($resp !== false) {
|
||
$resp = ltrim($resp, "\xEF\xBB\xBF\x00\x09\x0A\x0D\x20");
|
||
writeLog("📥 Ответ AddRelated: " . substr($resp, 0, 200));
|
||
|
||
$rel = json_decode($resp, true);
|
||
$relationOk = isset($rel['result']['message']) && $rel['result']['message'] === 'successfull';
|
||
}
|
||
|
||
// Если webservice не сработал - используем прямую привязку
|
||
if (!$relationOk) {
|
||
writeLog("⚠️ AddRelated не сработал, используем прямую привязку");
|
||
try {
|
||
global $crmPath;
|
||
require_once $crmPath . 'data/CRMEntity.php';
|
||
require_once $crmPath . 'modules/Vtiger/CRMEntity.php';
|
||
$focus = CRMEntity::getInstance('Project');
|
||
relateEntities($focus, 'Project', $projectId, 'Documents', (int)$docNumericId);
|
||
writeLog("✅ Прямая привязка успешна");
|
||
} catch (Exception $e) {
|
||
writeLog("❌ Прямая привязка не удалась: " . $e->getMessage());
|
||
}
|
||
} else {
|
||
writeLog("✅ AddRelated успешен");
|
||
}
|
||
|
||
// Возвращаем результат с сохранением всех исходных данных
|
||
$result = array_merge($file, [
|
||
'status' => 'success',
|
||
'projectid' => $projectId,
|
||
'contactid' => $contactId,
|
||
'crm_result' => [
|
||
'document_id' => $documentWsId,
|
||
'document_numeric_id' => $docNumericId,
|
||
'project_id' => $projectId,
|
||
'contact_id' => $contactId,
|
||
'folder_id' => $folderWsId,
|
||
'message' => 'Документ создан и привязан к проекту' . (!$relationOk ? ' (прямая привязка)' : '')
|
||
]
|
||
]);
|
||
|
||
$results[] = $result;
|
||
writeLog("✅ Файл '$fileName' успешно обработан");
|
||
|
||
} catch (Exception $e) {
|
||
writeLog("❌ Ошибка для файла '$fileName': " . $e->getMessage());
|
||
|
||
$results[] = array_merge($file, [
|
||
'status' => 'error',
|
||
'projectid' => $projectId,
|
||
'contactid' => $contactId,
|
||
'crm_result' => [
|
||
'message' => $e->getMessage()
|
||
]
|
||
]);
|
||
}
|
||
}
|
||
|
||
curl_close($ch);
|
||
$successCount = count(array_filter($results, function($r) { return $r['status'] === 'success'; }));
|
||
writeLog("🏁 Обработка завершена. Успешно: $successCount/" . count($results));
|
||
|
||
return $results;
|
||
}
|
||
|
||
// Обработка запроса
|
||
if ($IS_POST) {
|
||
writeLog('=== START POST REQUEST V2 ===');
|
||
writeLog('Headers: ' . json_encode(getallheaders(), JSON_UNESCAPED_UNICODE));
|
||
|
||
// Получаем и проверяем входные данные
|
||
$input = file_get_contents('php://input');
|
||
writeLog('Raw input: ' . substr($input, 0, 1000) . (strlen($input) > 1000 ? '...(truncated)' : ''));
|
||
|
||
$input = ltrim($input, "\xEF\xBB\xBF\x00\x09\x0A\x0D\x20");
|
||
$data = json_decode($input, true);
|
||
|
||
if (json_last_error() !== JSON_ERROR_NONE) {
|
||
writeLog('❌ JSON Error: ' . json_last_error_msg());
|
||
json_response([
|
||
'success' => false,
|
||
'error' => ['message' => 'Invalid JSON: ' . json_last_error_msg()]
|
||
], 400);
|
||
}
|
||
|
||
writeLog('Parsed data keys: ' . implode(', ', array_keys($data)));
|
||
|
||
// 🔑 НОВЫЙ ФОРМАТ: Ожидаем все данные в одном объекте
|
||
if (empty($data['sessionName'])) {
|
||
writeLog('❌ Error: sessionName is required');
|
||
json_response([
|
||
'success' => false,
|
||
'error' => ['message' => 'sessionName is required in request data']
|
||
], 400);
|
||
}
|
||
|
||
if (empty($data['projectid'])) {
|
||
writeLog('❌ Error: projectid is required');
|
||
json_response([
|
||
'success' => false,
|
||
'error' => ['message' => 'projectid is required in request data']
|
||
], 400);
|
||
}
|
||
|
||
if (empty($data['contactid'])) {
|
||
writeLog('❌ Error: contactid is required');
|
||
json_response([
|
||
'success' => false,
|
||
'error' => ['message' => 'contactid is required in request data']
|
||
], 400);
|
||
}
|
||
|
||
// Поддерживаем оба формата: files и documents
|
||
$filesArray = null;
|
||
if (!empty($data['files']) && is_array($data['files'])) {
|
||
$filesArray = $data['files'];
|
||
} elseif (!empty($data['documents']) && is_array($data['documents'])) {
|
||
$filesArray = $data['documents'];
|
||
}
|
||
|
||
if (empty($filesArray)) {
|
||
writeLog('❌ Error: files or documents array is required');
|
||
json_response([
|
||
'success' => false,
|
||
'error' => ['message' => 'files or documents array is required in request data']
|
||
], 400);
|
||
}
|
||
|
||
writeLog("🔑 Сессия: {$data['sessionName']}");
|
||
writeLog("📋 Проект: {$data['projectid']}, Контакт: {$data['contactid']}");
|
||
writeLog('📄 Файлов: ' . count($filesArray));
|
||
|
||
// Нормализуем данные: всегда используем 'files' внутри функции
|
||
$normalizedData = $data;
|
||
$normalizedData['files'] = $filesArray;
|
||
|
||
// Создаём документы с готовой сессией
|
||
$results = createDocumentsWithSession($normalizedData);
|
||
|
||
// Успешный ответ
|
||
writeLog('✅ Success: processed ' . count($results) . ' files');
|
||
json_response([
|
||
'success' => true,
|
||
'total_processed' => count($filesArray),
|
||
'results' => $results,
|
||
'session_used' => $sessionName
|
||
]);
|
||
|
||
} else {
|
||
// GET запрос - документация API
|
||
header('Content-Type: application/json; charset=utf-8');
|
||
echo json_encode([
|
||
'success' => true,
|
||
'message' => 'Upload Documents API v2 - Ready',
|
||
'endpoint' => 'POST to this URL with complete data object',
|
||
'format' => [
|
||
'sessionName' => 'string (required - from n8n CRM login)',
|
||
'projectid' => 'string (required - project ID)',
|
||
'contactid' => 'string (required - contact ID)',
|
||
'user_id' => 'string (optional - default "1")',
|
||
'files' => [ // или 'documents' - поддерживаются оба формата
|
||
[
|
||
'id' => 'string (file UUID)',
|
||
'file_id' => 'string (S3 path)',
|
||
'file_url' => 'string (required - full S3 URL)',
|
||
'file_name' => 'string (S3 filename)',
|
||
'field_name' => 'string (form field)',
|
||
'uploaded_at' => 'string (ISO datetime)',
|
||
'original_file_name' => 'string (user filename)',
|
||
'upload_description' => 'string (document description)',
|
||
'filename_for_upload' => 'string (display filename)'
|
||
]
|
||
]
|
||
],
|
||
'example' => [
|
||
'sessionName' => '27c160f968cc0cea6dd38',
|
||
'projectid' => '392790',
|
||
'contactid' => '320096',
|
||
'user_id' => '1',
|
||
'documents' => [ // пример с 'documents' (как от n8n)
|
||
[
|
||
'id' => 'd0d3d844-2db0-4c68-82e4-a803881b7527',
|
||
'file_id' => 'clpr_claims/5eac8512-1bc5-49ee-952c-3ec390db6964/d0d3d844-2db0-4c68-82e4-a803881b7527__pretenzionnaya-rabota.pdf',
|
||
'file_url' => 'https://s3.twcstorage.ru/f9825c87-4e3558f6-f9b6-405c-ad3d-d1535c49b61c/clpr_claims/5eac8512-1bc5-49ee-952c-3ec390db6964/d0d3d844-2db0-4c68-82e4-a803881b7527__pretenzionnaya-rabota.pdf',
|
||
'file_name' => 'd0d3d844-2db0-4c68-82e4-a803881b7527__pretenzionnaya-rabota.pdf',
|
||
'field_name' => 'uploads[1][0]',
|
||
'uploaded_at' => '2025-09-15T22:46:51.913+03:00',
|
||
'original_file_name' => '1757965604702.pdf',
|
||
'upload_description' => 'Претензионная работа',
|
||
'filename_for_upload' => '1757965604702.pdf'
|
||
]
|
||
]
|
||
]
|
||
], JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT);
|
||
}
|
||
?>
|