<?php
/*********************************************************************************
 * Набор методов для работы с Telegram через родное API
 * All Rights Reserved.
 * Contributor(s): Илья Руденко itsaturn@yandex.ru
 ********************************************************************************/
require_once 'include/utils/utils.php';

function TelegramSendComment($commentid, $message){	
	// Вызывается из /modules/ModComments/actions/SaveAjax.php
	global $adb;
	$isAttach = false;

	$query = 'SELECT e.setype, c.related_to
				FROM vtiger_modcomments c
				LEFT JOIN vtiger_crmentity e on e.crmid = c.related_to 
				where c.modcommentsid = '.$commentid;
	$result = $adb->pquery($query);

	$output = 'YES';

	if ($adb->num_rows($result) == 0) {
		$output = 'Комментарий не найден';
	} else {
		// Проверяем наличие файлов через vtiger_seattachmentsrel
		$attachQuery = 'SELECT COUNT(*) as file_count FROM vtiger_seattachmentsrel WHERE crmid = '.$commentid;
		$attachResult = $adb->pquery($attachQuery);
		$fileCount = $adb->query_result($attachResult, 0, "file_count");
		$isAttach = $fileCount > 0;
		
		file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' Проверка файлов для комментария '.$commentid.': найдено '.$fileCount.' файлов, isAttach='.$isAttach.PHP_EOL, FILE_APPEND);
		$setype = $adb->query_result($result, 0, "setype");
		$related_to = $adb->query_result($result, 0, "related_to");
		if ($setype == 'Contacts') {
			// Если коммент отправляется из Контакта
			$query = 'select phone from vtiger_contactdetails where phone > 0 and contactid = '.$related_to;
			$result = $adb->pquery($query);
			if ($adb->num_rows($result) == 0) {
				$output = 'У Контакта отсутствует идентификатор чата в поле Рабочий телефон';
			} else {
				$chat_id = $adb->query_result($result, 0, "phone");
			}
		} else {
			if ($setype == 'Project') {
				// Если коммент отправляется из Проекта
				$query = 'select cf_1826 from vtiger_projectcf where cf_1826 <> "" and projectid = '.$related_to;
				$result = $adb->pquery($query);
				if ($adb->num_rows($result) == 0) {
					$output = 'У Проекта отсутствует телефон';
				} else {
					$chat_id = $adb->query_result($result, 0, "cf_1826");
				}
			} else {
				$output = 'Комментарий к неизвестной сущности';
			}
		}
	}

	//echo $output.'<br>';
	//echo $query.'<br>';


	if ($output <> 'YES') {		
		$logstring = date('Y-m-d H:i:s').' Отправка комментария ID: '.$commentid.' не удалать по причине: '.$output.PHP_EOL;
		file_put_contents('logs/tg_outbound.log', $logstring, FILE_APPEND);
		//echo $logstring.'<br>';
	} else {
		if ($setype == 'Contacts') {
			$query = 'select cf_1740 from vtiger_contactscf where contactid = '.$related_to;
		} else
			if ($setype == 'Project') {
				$query = 'select cf.cf_1740
							from vtiger_project p
							left join vtiger_contactscf cf on cf.contactid = p.linktoaccountscontacts
							where p.projectid = '.$related_to;
			}
		file_put_contents('logs/tg_outbound.log', $query.PHP_EOL, FILE_APPEND);
		//echo $query.'<br>';

		$result = $adb->pquery($query);
		

		$insurance = $adb->query_result($result, 0, "cf_1740");
		//echo 'Вот оно: "'.$insurance.'"<br>';
		if (empty($insurance)) {
			//echo 'Нет<br>';
			$bot_token = '6118440594:AAGpqeudXF9wHSZ7vpAsXQ4Jp5XXlUoqB1A';
		} else {
			//echo 'Есть<br>';
			$bot_token = '6631721508:AAG0FIXhlprPGeeb_6zh5gjOpNdWzSWIRS8';
		}

		//echo $bot_token.'<br>';
			
		//$bot_token = '6118440594:AAGpqeudXF9wHSZ7vpAsXQ4Jp5XXlUoqB1A';

		$logstring = date('Y-m-d H:i:s').' Отправка комментария ID: '.$commentid.' с токеном: '.$bot_token.' в chat_id'.$chat_id.PHP_EOL;
		file_put_contents('logs/tg_outbound.log', $logstring, FILE_APPEND);				
		//echo $logstring.'<br>';
		$logstring = 'Текст: '.$message.PHP_EOL;
		file_put_contents('logs/tg_outbound.log', $logstring, FILE_APPEND);
		//echo $logstring.'<br>';
		
		// Заменяем одинарные и двойные кавычки в тексте на апострофы
		$message = str_replace('"', '`', $message);
		$message = str_replace("'", "`", $message);
		// Меняем переносы строк на \n
		$message = preg_replace('/\R/u', '\n', $message);
		
		// параметры, которые отправятся в api телеграмм
		$params = array(
			'chat_id' => $chat_id, // id получателя сообщения
			'text' => $message, // текст сообщения
			'parse_mode' => 'HTML', // режим отображения сообщения, не обязательный параметр
		);
		 
		$curl = curl_init();
		$url = 'https://api.telegram.org/bot'.$bot_token.'/sendMessage';
		curl_setopt($curl, CURLOPT_URL, $url); // адрес api телеграмм
		curl_setopt($curl, CURLOPT_POST, true); // отправка данных методом POST
		curl_setopt($curl, CURLOPT_TIMEOUT, 10); // максимальное время выполнения запроса
		curl_setopt($curl, CURLOPT_POSTFIELDS, $params); // параметры запроса
		curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); // чтобы получить нормальный ответ
		
		$output = curl_exec($curl);
		//echo $url.'<br>';
		
		if (curl_errno($curl)) {
			$output = date('Y-m-d H:i:s').' Что-то пошло не так: '.curl_error($curl);
		} else {
			$output = date('Y-m-d H:i:s').' Ответ от Telegram на отправку текста сообщения: '.$output;
			$response = json_decode($output, true);
			$messageid = $response['result']['message_id']; // Выкурили id отправленного сообщения в исчислении Телеграмма
			$updquery = 'update vtiger_modcomments set messageid = ? where modcommentsid = ?';
			$updresult = $adb->pquery($updquery, array($messageid, $commentid));
		}
		file_put_contents('logs/tg_outbound.log', $output.PHP_EOL, FILE_APPEND);
		//echo $output.'<br>';

		if ($isAttach) {
			// Получаем файлы, связанные с комментарием
			// Используем запрос БЕЗ vtiger_notes, так как для файлов комментариев там нет записей
			$query = 'SELECT a.attachmentsid, a.name, a.type, a.path, a.storedname
						FROM vtiger_seattachmentsrel ar
						LEFT JOIN vtiger_attachments a ON a.attachmentsid = ar.attachmentsid  
						LEFT JOIN vtiger_crmentity ce ON ce.crmid = ar.attachmentsid
						WHERE ar.crmid = '.$commentid.' AND ce.setype LIKE "Documents%"';

			$result = $adb->pquery($query);
			$fileCount = $adb->num_rows($result);
			file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' [FIXED_VERSION_v2] Найдено файлов для отправки: '.$fileCount.PHP_EOL, FILE_APPEND);
			file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' Запрос: '.$query.PHP_EOL, FILE_APPEND);
			
			if ($fileCount == 0) {
				// Дополнительная диагностика
				$debugQuery = 'SELECT COUNT(*) as cnt FROM vtiger_seattachmentsrel WHERE crmid = '.$commentid;
				$debugResult = $adb->pquery($debugQuery);
				$debugCount = $adb->query_result($debugResult, 0, "cnt");
				file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' DEBUG: vtiger_seattachmentsrel содержит '.$debugCount.' записей для комментария '.$commentid.PHP_EOL, FILE_APPEND);
				
				// Проверим что именно в vtiger_seattachmentsrel
				$debugQuery2 = 'SELECT attachmentsid FROM vtiger_seattachmentsrel WHERE crmid = '.$commentid;
				$debugResult2 = $adb->pquery($debugQuery2);
				if ($adb->num_rows($debugResult2) > 0) {
					$attachmentId = $adb->query_result($debugResult2, 0, "attachmentsid");
					file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' DEBUG: attachmentsid='.$attachmentId.PHP_EOL, FILE_APPEND);
					
					// Проверим vtiger_crmentity
					$debugQuery3 = 'SELECT crmid, setype FROM vtiger_crmentity WHERE crmid = '.$attachmentId;
					$debugResult3 = $adb->pquery($debugQuery3);
					if ($adb->num_rows($debugResult3) > 0) {
						$crmid = $adb->query_result($debugResult3, 0, "crmid");
						$setype = $adb->query_result($debugResult3, 0, "setype");
						file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' DEBUG: vtiger_crmentity crmid='.$crmid.', setype='.$setype.PHP_EOL, FILE_APPEND);
						
						// Проверим условие LIKE
						$likeMatch = (strpos($setype, 'Documents') === 0) ? 'YES' : 'NO';
						file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' DEBUG: setype LIKE "Documents%" = '.$likeMatch.PHP_EOL, FILE_APPEND);
						
						// Попробуем выполнить упрощенный запрос
						$simpleQuery = 'SELECT COUNT(*) as cnt FROM vtiger_seattachmentsrel ar LEFT JOIN vtiger_crmentity ce ON ce.crmid = ar.attachmentsid WHERE ar.crmid = '.$commentid.' AND ce.setype LIKE "Documents%"';
						$simpleResult = $adb->pquery($simpleQuery);
						$simpleCount = $adb->query_result($simpleResult, 0, "cnt");
						file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' DEBUG: Упрощенный запрос нашел '.$simpleCount.' записей'.PHP_EOL, FILE_APPEND);
					} else {
						file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' DEBUG: НЕТ записи в vtiger_crmentity для attachmentsid='.$attachmentId.PHP_EOL, FILE_APPEND);
					}
				}
			}
			
			curl_setopt($curl, CURLOPT_URL, 'https://api.telegram.org/bot'.$bot_token.'/sendDocument'); // адрес api телеграмм
			curl_setopt($curl, CURLOPT_HEADER, false);
			
			if ($adb->num_rows($result) > 0) {
				for ($i = 0; $i < $adb->num_rows($result); $i++) {
					$attachmentsid = $adb->query_result($result, $i, 'attachmentsid');
					$origname = $adb->query_result($result, $i, 'name');
					$mimetype = $adb->query_result($result, $i, 'type');
					$path = $adb->query_result($result, $i, 'path');
					$storedname = $adb->query_result($result, $i, 'storedname');
					
					file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' DEBUG: Файл '.$i.': attachmentId='.$attachmentsid.', name='.$origname.', path='.$path.', storedname='.$storedname.PHP_EOL, FILE_APPEND);
					
					// Определяем URL файла - строим S3 URL из path и storedname
					$fileUrl = '';
					if (!empty($path) && !empty($storedname)) {
						if (strpos($path, 's3://') === 0) {
							// Новый формат: s3://bucket/path
							$bucket = str_replace('s3://', '', $path);
							$fileUrl = 'https://s3.twcstorage.ru/' . $bucket . '/' . $storedname;
							file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' DEBUG: Строим S3 URL из path+storedname (s3://): '.$fileUrl.PHP_EOL, FILE_APPEND);
						} else {
							// Старый формат: обычный path
							$fileUrl = 'https://s3.twcstorage.ru/f9825c87-4e3558f6-f9b6-405c-ad3d-d1535c49b61c/' . $path . '/' . $storedname;
							file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' DEBUG: Строим S3 URL из path+storedname (обычный): '.$fileUrl.PHP_EOL, FILE_APPEND);
						}
					} else {
						file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' ERROR: Не удалось определить URL файла для attachmentId='.$attachmentsid.', path='.$path.', storedname='.$storedname.PHP_EOL, FILE_APPEND);
						continue;
					}
					
					if (!empty($fileUrl)) {
						// Отправляем файл как бинарные данные (и для S3, и для локальных файлов)
						if (strpos($fileUrl, 'http') === 0) {
							// S3 файл - скачиваем содержимое и создаем временный файл
							$tempFile = tempnam(sys_get_temp_dir(), 'tg_file_');
							$fileContent = file_get_contents($fileUrl);
							if ($fileContent !== false) {
								file_put_contents($tempFile, $fileContent);
								$arrayQuery = array(
									'chat_id' => $chat_id,
									'caption' => $origname,
									'document' => curl_file_create($tempFile, $mimetype, $origname)
								);
								file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' Создан временный файл для S3: '.$tempFile.', размер: '.strlen($fileContent).' байт'.PHP_EOL, FILE_APPEND);
							} else {
								file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' Ошибка скачивания S3 файла: '.$fileUrl.PHP_EOL, FILE_APPEND);
								continue;
							}
						} else {
							// Локальный файл
							$arrayQuery = array(
								'chat_id' => $chat_id,
								'caption' => $origname,
								'document' => curl_file_create($fileUrl, $mimetype, $origname)
							);
						}
						
						curl_setopt($curl, CURLOPT_POSTFIELDS, $arrayQuery);
						$output = curl_exec($curl);
						
						// Удаляем временный файл если он был создан
						if (isset($tempFile) && file_exists($tempFile)) {
							unlink($tempFile);
							file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' Временный файл удален: '.$tempFile.PHP_EOL, FILE_APPEND);
						}
						
						if (curl_errno($curl)) {
							$output = date('Y-m-d H:i:s').' Что-то пошло не так при отправке файла '.$origname.' : '.curl_error($curl);
						} else {
							$output = date('Y-m-d H:i:s').' Ответ от Telegram на отправку файла: '.$output;
						}
						file_put_contents('logs/tg_outbound.log', $output.PHP_EOL, FILE_APPEND);
					} else {
						file_put_contents('logs/tg_outbound.log', date('Y-m-d H:i:s').' Не удалось определить путь к файлу: '.$origname.PHP_EOL, FILE_APPEND);
					}
				}
			}
		}

		curl_close($curl);

	}

	return $output;
}

?>