В прошлой статье мы посмотрели как возможно сделать Telegram-бота на python с очень простым функционалом. Сейчас мы пойдем немного дальше и подумаем над тем как этого простого бота можно интегрировать с СУС «1С-Битрикс: Управление сайтом».
Не будем далеко отступать от Telegram-бота из прошлой статьи. Лишь постараемся добавить в него следующий функционал. При отправке сообщения в чате это сообщение будем фиксировать в качестве элемента информационного блока Битрикс. Напомню код бота из предыдущей статьи.
import telebot
bot = telebot.TeleBot('ЗДЕСЬ_ВВОДИМ_TOKEN') @bot.message_handler(content_types=["text"])
def handle_text(message):
bot.send_message(message.chat.id, 'Ваше сообщение: ' + message.text)
bot.polling(none_stop=True, interval=0)
Поскольку общение с Telegram у нас построено на python, а Битрикс работает на php, то в качестве интерфейса взаимодействия выберем SOAP (есть и другие варианты, о них попробую написать в следующей статье).
Со стороны Битрикс есть специальный модуль для организация такого рода взаимодействия — «Веб-сервисы». Со стороны python в качестве модуля SOAP-клиента выберем zeep.
Начнем с создания инфраструктуры со стороны 1С-Битрикс. Для этого создадим информационный блок для хранения записей, которые будут приходить от SOAP-клиента на python.
Далее необходимо в Битрикс создать ряд файлов для работы SOAP. Не забудем включить также и модуль «Веб-сервисы»!
Создаем папку компонента в своем пространстве имен. Например /bitrix/components/demo/webservice.addmes/
В этой папке нужно создать следующие файлы:
.parameters.php
<?
if (!defined("B_PROLOG_INCLUDED") || B_PROLOG_INCLUDED!==true) die();
$arComponentParameters = array(
"GROUPS" => array(),
"PARAMETERS" => array(),
);
?>
.description.php
<?
if (!defined("B_PROLOG_INCLUDED") || B_PROLOG_INCLUDED!==true) die();
$arComponentDescription = array(
"NAME" => "Веб-сервис добавления сообщений от Telegram-бота",
"DESCRIPTION" => "Веб-сервис добавления сообщений от Telegram-бота",
"CACHE_PATH" => "Y",
"PATH" => array(
"ID" => "service",
"CHILD" => array(
"ID" => "webservice",
"NAME" => "Веб-сервис добавления сообщений от Telegram-бота"
)
),
);
?>
component.php
<?
if(!defined("B_PROLOG_INCLUDED") || B_PROLOG_INCLUDED!==true) die();
if(!CModule::IncludeModule("webservice") || !CModule::IncludeModule("iblock"))
return;
class CAddMesWS extends IWebService
{
static public function GetWebServiceDesc()
{
$wsdesc = new CWebServiceDesc();
$wsdesc->wsname = "bitrix.webservice.addmes";
$wsdesc->wsclassname = "CAddMesWS"; // название класса
$wsdesc->wsdlauto = true;
$wsdesc->wsendpoint = CWebService::GetDefaultEndpoint();
$wsdesc->wstargetns = CWebService::GetDefaultTargetNS();
$wsdesc->classTypes = array();
$wsdesc->structTypes = Array();
$wsdesc->classes = array(
"CAddMesWS"=> array(
"AddItem" => array(
"type" => "public",
"input" => array(
"TEXT" => array("varType" => "string"),
),
"output" => array(
"id" => array("varType" => "integer")
),
"httpauth" => "Y"
),
)
);
return $wsdesc;
}
public static function AddItem($TEXT)
{
$iblock_permission = CIBlock::GetPermission(920);
if ($iblock_permission < "W")
{
$GLOBALS["USER"]->RequiredHTTPAuthBasic();
return new CSOAPFault('Server Error', 'Unable to authorize user.');
}
$arFields = Array(
"IBLOCK_ID"=>IBLOCK_ID,
"NAME"=>$TEXT
);
$ib_element = new CIBlockElement();
$result = $ib_element->Add($arFields);
if($result>0)
return Array("id"=>$result);
return new CSOAPFault( 'Server Error', 'Error: '.$ib_element->LAST_ERROR );
}
}
$arParams["WEBSERVICE_NAME"] = "bitrix.webservice.addmes";
$arParams["WEBSERVICE_CLASS"] = "CAddMesWS";
$arParams["WEBSERVICE_MODULE"] = "";
// передаем в компонент описание веб-сервиса
$APPLICATION->IncludeComponent(
"bitrix:webservice.server",
"",
$arParams
);
die();
?>
Затем в корне сайта создаем файл-интерфейс для доступа к SOAP извне.
ws_addmes.php
<?
require($_SERVER["DOCUMENT_ROOT"]."/bitrix/header.php");
?>
<?$APPLICATION->IncludeComponent(
"dv:webservice.addmes",
"",
Array(
)
);?>
<?require($_SERVER["DOCUMENT_ROOT"]."/bitrix/footer.php");?>
Если зайти по адресу http://домен/ws_addmes.php в браузере, то мы увидим список доступных методов SOAP и можем даже их протестировать. Мы описывали лишь один метод, так что увидим только метод AddItem с одним параметром «TEXT».
Далее обратимся к клиенту на python. Для начала нам требуется установить zeep. Это выполняется командой sudo apt install python3-zeep. Вероятнее всего тут проблем не возникнет.
Далее модифицируем скрипт telegram-бота.
import telebot
from requests import Session
from requests.auth import HTTPBasicAuth
from zeep import Client
from zeep.transports import Transport
bot = telebot.TeleBot('ЗДЕСЬ_ВВОДИМ_TOKEN')
session = Session()
session.auth = HTTPBasicAuth('логин', 'пароль')
client = Client('http://домен/ws_addmes.php?wsdl', transport=Transport(session=session))
@bot.message_handler(content_types=["text"])
def handle_text(message):
bot.send_message(message.chat.id, 'Вы написали: ' + message.text)
client.service.AddItem(TEXT=message.text)
bot.polling(none_stop=True, interval=0)
Жирным отмечено те строки, которые добавлены по сравнению с прошлой версией кода. Обратите внимание, что в конце адреса url soap добавляется параметр «?wsdl» : http://домен/ws_addmes.php?wsdl . Это важно, лишь в таком случае ответ отдается в xml. В другом случае вы получите ошибку такого вида: «zeep.exceptions.XMLSyntaxError: Invalid XML content received (Input is not proper UTF-8, indicate encoding !».
