Интеграция ChatGPT в Битрикс24

				
					<?php
/**
 * proxy chatgpt чат-бот для bitrix24
 */

$appsConfig     = array();

$configFileName = '/config_' . trim(str_replace('.', '_', $_REQUEST['auth']['domain'])) . '.php';
if (file_exists(__DIR__ . $configFileName)) {
		include_once __DIR__ . $configFileName;
} else {
	writeToLog($_REQUEST, "NO CONFIG");
	return;
}

// receive event "new message for bot"
if ($_REQUEST['event'] == 'ONIMBOTMESSAGEADD') {
	// check the event - register this application or not
	if (!isset($appsConfig['BITRIX_TOKEN']) or empty($appsConfig['BITRIX_TOKEN'])) {
		return false;
	}
	# если отправлено вложение
	if (isset($_REQUEST['data']['PARAMS']['FILES'])) {
		$arReport['message'] = "К сожаления, я не перевариваю вложенные файла :(";
		$arReport['failed'] = 1;
	} else {
		$rows = fetch($appsConfig['DATABASE'], 'SELECT ID, ROLE, MESSAGE FROM context WHERE DIALOG_ID = :dialog_id ORDER BY ID DESC LIMIT ' . intval($appsConfig['CONTEXT']), array(':dialog_id' => $_REQUEST['data']['PARAMS']['DIALOG_ID']));
		
		$messages['messages'][] = array('role' => 'user', 'content' => $_REQUEST['data']['PARAMS']['MESSAGE']);
		foreach ($rows as $row) {
			array_unshift($messages['messages'], array('role' => $row['ROLE'], 'content' => $row['MESSAGE']));
		}

		$arReport = ask($appsConfig['OPENAI_TOKEN'][array_rand($appsConfig['OPENAI_TOKEN'])], $appsConfig['MODEL'], $messages);
	}
   
	// send answer message
	$result = restCommand($appsConfig['BITRIX_TOKEN'], 'imbot.message.add', array(
			'BOT_ID' 	=> array_shift($_REQUEST['data']['BOT'])['BOT_ID'],
			'CLIENT_ID' => $_REQUEST['auth']['application_token'],
			'DIALOG_ID' => $_REQUEST['data']['PARAMS']['DIALOG_ID'],
			'MESSAGE'   => $arReport['message'],
			'ATTACH' 	=> isset($arReport['attach']) ? $arReport['attach'] : null
		),
		$_REQUEST['auth']);

	if (isset($result['result']) && !isset($arReport['failed'])) {
		query($appsConfig['DATABASE'], 'INSERT INTO context (USER_ID, DIALOG_ID, ROLE, MESSAGE, TIMESTAMP) VALUES (?, ?, ?, ?, CURRENT_TIMESTAMP())', array($_REQUEST['data']['PARAMS']['FROM_USER_ID'], $_REQUEST['data']['PARAMS']['DIALOG_ID'], "user", $_REQUEST['data']['PARAMS']['MESSAGE']));
		query($appsConfig['DATABASE'], 'INSERT INTO context (USER_ID, DIALOG_ID, ROLE, MESSAGE, TIMESTAMP) VALUES (?, ?, ?, ?, CURRENT_TIMESTAMP())', array($_REQUEST['data']['PARAMS']['FROM_USER_ID'], $_REQUEST['data']['PARAMS']['DIALOG_ID'], "assistant", $arReport['message']));
	}
} // receive event "open private dialog with bot" or "join bot to group chat"
else {
    if ($_REQUEST['event'] == 'ONIMBOTJOINCHAT') {
        // check the event - register this application or not
		if (!isset($appsConfig['BITRIX_TOKEN']) or empty($appsConfig['BITRIX_TOKEN'])) {
			return false;
		}
		// send help message how to use chat-bot. For private chat and for group chat need send different instructions.
		$result = restCommand($appsConfig['BITRIX_TOKEN'], 'imbot.message.add', array(
			'BOT_ID' 	=> array_shift($_REQUEST['data']['BOT'])['BOT_ID'],
			'CLIENT_ID' => $_REQUEST['auth']['application_token'],
			'DIALOG_ID' => $_REQUEST['data']['PARAMS']['DIALOG_ID'],
			'MESSAGE'   => 'Привет! Чем могу помочь?'
		),
		$_REQUEST['auth']);
    }
}
/**
 * Send rest query to Bitrix24.
 *
 * @param       $method - Rest method, ex: methods
 * @param array $params - Method params, ex: array()
 * @param array $auth   - Authorize data, ex: array('domain' => 'https://test.bitrix24.com', 'access_token' => '7inpwszbuu8vnwr5jmabqa467rqur7u6')
 *
 * @return mixed
 */
function restCommand($token, $method, array $params = array(), array $auth = array()) {
	$queryUrl  = 'https://' . $auth['domain'] . '/rest/' . $token . '/' . $method;
	$queryData = http_build_query($params);
	#writeToLog(array('URL' => $queryUrl, 'PARAMS' => $params)), 'ReportBot send data');
	$curl = curl_init();
	curl_setopt_array($curl, array(
		CURLOPT_POST           => 1,
		CURLOPT_HEADER         => 0,
		CURLOPT_RETURNTRANSFER => 1,
		CURLOPT_URL            => $queryUrl,
		CURLOPT_POSTFIELDS     => $queryData,
	));
	$result = curl_exec($curl);
	curl_close($curl);
	$result = json_decode($result, 1);
	return $result;
}
/**
 * Write data to log file.
 *
 * @param mixed  $data
 * @param string $title
 *
 * @return bool
 */
function writeToLog($data, $title = '') {
	$log = "\n------------------------\n";
	$log .= date("Y.m.d G:i:s") . "\n";
	$log .= (strlen($title) > 0 ? $title : 'DEBUG') . "\n";
	$log .= print_r($data, 1);
	$log .= "\n------------------------\n";
	file_put_contents('/var/log/imbot.log', $log, FILE_APPEND);
	return true;
}

function ask($token, $model, $messages) {
	$data = [
			"model" => $model,
			'temperature' => 0.5,
			"max_tokens" => 1000,
			"top_p" => 1.0,
			"frequency_penalty" => 0.52,
			"presence_penalty" => 0.5,
			"stop" => ["11."],
		  ];
	$data['messages'] = $messages['messages'];

	$ch = curl_init();
	curl_setopt($ch, CURLOPT_URL, 'https://api.openai.com/v1/chat/completions');
	curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
	curl_setopt($ch, CURLOPT_POST, 1);
	curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 0);
	curl_setopt($ch, CURLOPT_TIMEOUT, 300); //timeout in seconds
	curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
	  
	$headers = [];
	$headers[] = 'Content-Type: application/json';
	$headers[] = 'Authorization: Bearer '.$token;
	curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
	  
	$response = curl_exec($ch);
	if (curl_errno($ch)) {
		echo 'Error:' . curl_error($ch);
	}
	  
	curl_close($ch);
	$response = json_decode($response, 1);
	
	
	if (isset($response['error'])) {
		$arResult['message'] = "Ой, что-то пошло не так ...";
		$arResult['attach'][] = array('MESSAGE' => $response['error']['message']);
		$arResult['failed'] = 1;
		writeToLog(array('TOKEN' => $token, 'ERROR' => $response), 'ERROR');
	} else if (isset($response['choices'][0]['message']['content'])) {
			$arResult['message'] = $response['choices'][0]['message']['content'];
	} else {
		$arResult['message'] = "Ой, что-то пошло не так ...";
		$arResult['failed'] = 1;
		writeToLog(array('TOKEN' => $token, 'ERROR' => $response), 'ERROR');
	}

	return $arResult;
}

function query(array $config, $sql, array $params) {
	try {
		$conn = new PDO('mysql:host=' . $config['HOST'] . ';port=' . $config['PORT'] . ';dbname=' . $config['DB'], $config['USER'], $config['PASSWORD']);
		// установка режима вывода ошибок
		$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
		$stmt = $conn->prepare($sql);
		// через массив передаем значения параметрам по позиции
		$result = $stmt->execute($params);
		return $result;
	} catch (PDOException $e) {
		writeToLog($e, 'DATABASE EXCEPTION');
	}
}

function fetch(array $config, $sql, array $params) {
	try {
		$conn = new PDO('mysql:host=' . $config['HOST'] . ';port=' . $config['PORT'] . ';dbname=' . $config['DB'], $config['USER'], $config['PASSWORD']);
		$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
		$stmt = $conn->prepare($sql);
		$stmt->execute($params);
		return $stmt;
	}
	catch (PDOException $e) {
		writeToLog($e, 'DATABASE EXCEPTION');
	}
}