{"id":473829,"date":"2025-09-03T15:01:04","date_gmt":"2025-09-03T15:01:04","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=473829"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=473829","title":{"rendered":"WhatsApp Web \u0438 Telegram \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440 \u0434\u043b\u044f Bitrix24: \u043d\u0430\u0448 \u043e\u043f\u044b\u0442 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u0438 \u0432\u043d\u0435\u0434\u0440\u0435\u043d\u0438\u044f. \u0427\u0430\u0441\u0442\u044c 1 \u2014 \u0418\u043d\u0442\u0435\u0433\u0440\u0430\u0446\u0438\u044f Bitrix24<\/span>"},"content":{"rendered":"
<\/div>\n
\n
\n
\n
\n

\u041f\u0440\u0438\u0432\u0435\u0442, \u043c\u0438\u0440! \u041c\u0435\u043d\u044f \u0437\u043e\u0432\u0443\u0442 \u041f\u0430\u0432\u0435\u043b, \u044f IT \u0438\u043d\u0436\u0435\u043d\u0435\u0440 \u0438 \u0440\u0443\u043a\u043e\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c \u0441\u043b\u0443\u0436\u0431\u044b \u0442\u0435\u0445\u043d\u0438\u0447\u0435\u0441\u043a\u043e\u0439 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u043a\u0438.<\/p>\n

\u0420\u0430\u0431\u043e\u0442\u0430\u044f \u0432 \u0444\u043e\u0440\u043c\u0430\u0442\u0435 \u043a\u0440\u0443\u043f\u043d\u043e\u0433\u043e IT-\u0430\u0443\u0442\u0441\u043e\u0440\u0441\u0438\u043d\u0433\u0430, \u043c\u044b \u0432 \u043a\u043e\u043c\u043f\u0430\u043d\u0438\u0438 \u0441\u0442\u043e\u043b\u043a\u043d\u0443\u043b\u0438\u0441\u044c \u0441 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u043e\u0439: \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435 \u043e\u0431\u0449\u0435\u0433\u043e WhatsApp\/Telegram Web, \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0451\u043d\u043d\u043e\u0433\u043e \u043d\u0430 \u043a\u043e\u043c\u043f\u044c\u044e\u0442\u0435\u0440\u0430\u0445 \u0441\u043e\u0442\u0440\u0443\u0434\u043d\u0438\u043a\u043e\u0432 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u043a\u0438, \u043e\u043a\u0430\u0437\u0430\u043b\u043e\u0441\u044c \u043d\u0435\u044d\u0444\u0444\u0435\u043a\u0442\u0438\u0432\u043d\u044b\u043c. \u0422\u0430\u043a\u043e\u0439 \u043f\u043e\u0434\u0445\u043e\u0434 \u043d\u0435 \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u043b \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u043a\u0430\u0447\u0435\u0441\u0442\u0432\u043e \u0434\u0438\u0430\u043b\u043e\u0433\u043e\u0432, \u0430 \u0442\u0430\u043a\u0436\u0435 \u0437\u0430\u0442\u0440\u0443\u0434\u043d\u044f\u043b \u043f\u0435\u0440\u0435\u0432\u043e\u0434 \u043e\u0431\u0440\u0430\u0449\u0435\u043d\u0438\u0439 \u043a\u043b\u0438\u0435\u043d\u0442\u043e\u0432 \u0432 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0435 \u0442\u0438\u043a\u0435\u0442\u044b, \u0432\u0441\u043b\u0435\u0434\u0441\u0442\u0432\u0438\u0435 \u0447\u0435\u0433\u043e \u0431\u044b\u043b\u0430 \u043d\u0430\u0447\u0430\u0442\u0430 \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u043a\u0430 \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430 \u043a \u043d\u0430\u0448\u0435\u043c\u0443 \u043a\u043e\u0440\u043f\u043e\u0440\u0430\u0442\u0438\u0432\u043d\u043e\u043c\u0443 \u043f\u043e\u0440\u0442\u0430\u043b\u0443 Bitrix24<\/strong>.<\/p>\n

\u0412 \u0434\u0430\u043d\u043d\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0435 \u044f \u0431\u044b \u0445\u043e\u0442\u0435\u043b \u043f\u043e\u0434\u0435\u043b\u0438\u0442\u044c\u0441\u044f \u043e\u0441\u043d\u043e\u0432\u0430\u043c\u0438 \u0442\u0435\u0445\u043d\u0438\u0447\u0435\u0441\u043a\u043e\u0439 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u0438 \u043a\u043b\u044e\u0447\u0435\u0432\u044b\u043c \u0444\u0443\u043d\u043a\u0446\u0438\u043e\u043d\u0430\u043b\u043e\u043c \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430. \u0414\u0435\u0442\u0430\u043b\u0438 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 — \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u0432\u0435\u0440\u0441\u0442\u043a\u0443 html \u0441\u0442\u0440\u0430\u043d\u0438\u0446, \u0442\u0435\u0441\u0442\u044b, \u043a\u0430\u0441\u0442\u043e\u043c\u0438\u0437\u0430\u0446\u0438\u044e \u043f\u0430\u043d\u0435\u043b\u0438 \u0430\u0434\u043c\u0438\u043d\u0438\u0441\u0442\u0440\u0430\u0442\u043e\u0440\u0430 \u0438 \u0442\u0430\u043a \u0434\u0430\u043b\u0435\u0435 — \u043e\u0441\u0442\u0430\u0432\u043b\u044f\u044e \u043d\u0430 \u0432\u0430\u0448\u0435 \u0443\u0441\u043c\u043e\u0442\u0440\u0435\u043d\u0438\u0435.<\/p>\n

\u0422\u0435\u0445\u043d\u043e\u043b\u043e\u0433\u0438\u0447\u0435\u0441\u043a\u0438\u0439 \u0441\u0442\u0435\u043a<\/h2>\n

\u041e\u0441\u043d\u043e\u0432\u0443 \u043f\u0440\u043e\u0435\u043a\u0442\u0430 \u0441\u043e\u0441\u0442\u0430\u0432\u043b\u044f\u044e\u0442 Python <\/strong>\u0438 Django<\/strong>, \u0447\u0442\u043e \u043e\u0431\u0443\u0441\u043b\u043e\u0432\u043b\u0435\u043d\u043e \u0438\u0445 \u043f\u0440\u043e\u0441\u0442\u043e\u0442\u043e\u0439, \u0433\u0438\u0431\u043a\u043e\u0441\u0442\u044c\u044e \u0438 \u0448\u0438\u0440\u043e\u043a\u0438\u043c \u043d\u0430\u0431\u043e\u0440\u043e\u043c \u0433\u043e\u0442\u043e\u0432\u044b\u0445 \u0440\u0435\u0448\u0435\u043d\u0438\u0439. \u0422\u0430\u043a\u043e\u0439 \u0432\u044b\u0431\u043e\u0440 \u0434\u0430\u043b \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u044c \u0431\u044b\u0441\u0442\u0440\u043e \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u0442\u044c \u043c\u0438\u043d\u0438\u043c\u0430\u043b\u044c\u043d\u043e \u0436\u0438\u0437\u043d\u0435\u0441\u043f\u043e\u0441\u043e\u0431\u043d\u044b\u0439 \u043f\u0440\u043e\u0434\u0443\u043a\u0442 (MVP) \u0438 \u0437\u0430\u043b\u043e\u0436\u0438\u0442\u044c \u0444\u0443\u043d\u0434\u0430\u043c\u0435\u043d\u0442 \u0434\u043b\u044f \u0434\u0430\u043b\u044c\u043d\u0435\u0439\u0448\u0435\u0433\u043e \u043c\u0430\u0441\u0448\u0442\u0430\u0431\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f.<\/p>\n

\u0422\u0430\u043a\u0436\u0435 \u0432\u0430\u043c \u043f\u043e\u043d\u0430\u0434\u043e\u0431\u0438\u0442\u0441\u044f \u0443\u0441\u0442\u0430\u043d\u043e\u0432\u0438\u0442\u044c redis, celery \u0438 \u043d\u0430\u0441\u0442\u0440\u043e\u0438\u0442\u044c \u0438\u0445.<\/p>\n

\u041e\u0441\u043d\u043e\u0432\u043d\u043e\u0439 \u0444\u0443\u043d\u043a\u0446\u0438\u043e\u043d\u0430\u043b Bitrix<\/h2>\n

\u041e\u043f\u0443\u0441\u0442\u0438\u043c \u0443\u0441\u0442\u0430\u043d\u043e\u0432\u043a\u0443 Django \u0438 \u043f\u043e\u0434\u0433\u043e\u0442\u043e\u0432\u043a\u0443 \u0432\u0438\u0440\u0442\u0443\u0430\u043b\u044c\u043d\u043e\u0433\u043e \u043e\u043a\u0440\u0443\u0436\u0435\u043d\u0438\u044f \u0438 \u043f\u0440\u0438\u0441\u0442\u0443\u043f\u0438\u043c \u043a \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u0438\u043d\u0442\u0435\u0433\u0440\u0430\u0446\u0438\u0438 \u0441 \u0411\u0438\u0442\u0440\u0438\u043a\u0441\u043e\u043c. \u0414\u043b\u044f \u044d\u0442\u043e\u0433\u043e \u0441\u043e\u0437\u0434\u0430\u0434\u0438\u043c Django \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435 bitrix. \u041d\u0430\u0447\u043d\u0435\u043c \u0441 \u0441\u043e\u0437\u0434\u0430\u043d\u0438\u044f \u043c\u043e\u0434\u0435\u043b\u0435\u0439 \u0432 models.py<\/strong>:<\/p>\n

import uuid from django.conf import settings from django.contrib.sites.models import Site from django.db import models<\/code><\/pre>\n
\u041c\u043e\u0434\u0435\u043b\u044c \u0434\u043b\u044f \u0445\u0440\u0430\u043d\u0435\u043d\u0438\u044f \u0434\u0430\u043d\u043d\u044b\u0445 \u043e \u043f\u043e\u0440\u0442\u0430\u043b\u0435:<\/p>\n
class Bitrix(models.Model):     PROTOCOL_CHOICES = [         ('http', 'HTTP'),         ('https', 'HTTPS'),     ]     protocol = models.CharField(max_length=5, choices=PROTOCOL_CHOICES, default='https')     domain = models.CharField(max_length=255)     owner = models.ForeignKey(         User, on_delete=models.SET_NULL, blank=True, null=True     )     user_id = models.CharField(max_length=255, blank=True, null=True)     member_id = models.CharField(max_length=255, unique=True, blank=True, null=True)     license_expired = models.BooleanField(default=False)      def __str__(self):         return self.domain<\/code><\/pre>\n
\u041c\u043e\u0434\u0435\u043b\u044c \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430:<\/p>\n
class Connector(models.Model):     TYPE_CHOICES = [         ('telegram', 'Telegram Bot'),         ('waweb', 'WhatsApp Web'),     ]     code = models.CharField(max_length=255, default=uuid.uuid4(), unique=True)     service = models.CharField(max_length=255, choices=TYPE_CHOICES, blank=True, null=True)     name = models.CharField(max_length=255, default=\"itsource.kg\", unique=False)     icon = models.FileField(upload_to='connector_icons\/', blank=True, null=True,                             default='connector_icons\/cloud-rain-alt.svg') # \u0417\u0430\u043c\u0435\u043d\u0438\u0442\u044c \u043d\u0430 \u0432\u0430\u0448\u0443 svg \u0438\u043a\u043e\u043d\u043a\u0443      def __str__(self):         return self.name<\/code><\/pre>\n
\u041a\u043e\u043d\u0444\u0438\u0433\u0443\u0440\u0430\u0446\u0438\u044f \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u0411\u0438\u0442\u0440\u0438\u043a\u0441:<\/p>\n
class App(models.Model):     id = models.UUIDField(primary_key=True, default=uuid.uuid4, editable=False)     owner = models.ForeignKey(         settings.AUTH_USER_MODEL, on_delete=models.SET_NULL, blank=True, null=True     )     site = models.ForeignKey(         Site, on_delete=models.SET_NULL, related_name=\"apps\", blank=True, null=True     )     name = models.CharField(max_length=255, blank=True, unique=False)     page_url = models.CharField(max_length=255, blank=True, default=\"\/\")     connectors = models.ManyToManyField(Connector, blank=True, related_name='apps')     asterisk = models.BooleanField(default=False, help_text=\"Chek for Asterisk connector\")     client_id = models.CharField(max_length=255, blank=True, unique=False)     client_secret = models.CharField(max_length=255, blank=True)      def __str__(self):         return self.name<\/code><\/pre>\n
\u041c\u043e\u0434\u0435\u043b\u044c \u0434\u043b\u044f \u0445\u0440\u0430\u043d\u0435\u043d\u0438\u044f \u0441\u0443\u0449\u043d\u043e\u0441\u0442\u0435\u0439 \u043b\u043e\u043a\u0430\u043b\u044c\u043d\u044b\u0445 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0439 \u0438 \u043e\u0442\u043a\u0440\u044b\u0442\u044b\u0445 \u043b\u0438\u043d\u0438\u0439:<\/p>\n
class AppInstance(models.Model):     id = models.UUIDField(primary_key=True, default=uuid.uuid4, editable=False)     owner = models.ForeignKey(         settings.AUTH_USER_MODEL, on_delete=models.SET_NULL, blank=True, null=True     )     app = models.ForeignKey(App, on_delete=models.SET_NULL, related_name=\"installations\", blank=True, null=True)     portal = models.ForeignKey(         Bitrix, on_delete=models.CASCADE, related_name=\"installations\", blank=True, null=True     )     auth_status = models.CharField(max_length=1)     application_token = models.CharField(max_length=255, blank=True)     storage_id = models.CharField(max_length=255, blank=True)     status = models.IntegerField(default=0, blank=True)     attempts = models.IntegerField(default=0, blank=True)     access_token = models.CharField(max_length=255, blank=True, null=True, editable=False)     refresh_token = models.CharField(max_length=255, blank=True, null=True, editable=False)      def __str__(self):         return f\"{self.app.name} on {self.portal.domain}\"   class Line(models.Model):     line_id = models.CharField(max_length=50)     owner = models.ForeignKey(         settings.AUTH_USER_MODEL, on_delete=models.SET_NULL, blank=True, null=True     )     app_instance = models.ForeignKey(AppInstance, on_delete=models.CASCADE, related_name=\"lines\", null=True)     connector = models.ForeignKey(Connector, on_delete=models.SET_NULL, related_name=\"lines\", null=True)     portal = models.ForeignKey(Bitrix, on_delete=models.CASCADE, related_name=\"lines\", blank=True, null=True)      def __str__(self):         return f\"Line {self.line_id}\"<\/code><\/pre>\n
\u042f \u043f\u0440\u0438\u0432\u0435\u0440\u0436\u0435\u043d\u0435\u0446 \u043c\u043e\u0434\u0443\u043b\u044c\u043d\u043e\u0439 \u0430\u0440\u0445\u0438\u0442\u0435\u043a\u0442\u0443\u0440\u044b, \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u0441\u043e\u0437\u0434\u0430\u0434\u0438\u043c \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0439 \u043c\u043e\u0434\u0443\u043b\u044c api \u0432\u043d\u0443\u0442\u0440\u0438 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f bitrix \u0434\u043b\u044f \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 api \u0432\u0435\u0431\u0445\u0443\u043a\u043e\u0432<\/p>\n
api\/serializers.py<\/strong><\/p>\n
from rest_framework import serializers  from bitrix.models import Bitrix   class PortalSerializer(serializers.ModelSerializer):     class Meta:         model = Bitrix         fields = [             \"owner\",             \"user_id\",             \"domain\",         ]      def create(self, validated_data):         return Bitrix.objects.create(**validated_data) <\/code><\/pre>\n
api\/views.py<\/strong><\/p>\n
from rest_framework.mixins import CreateModelMixin from rest_framework.renderers import JSONRenderer from rest_framework.viewsets import GenericViewSet from rest_framework.response import Response  from bitrix.models import Bitrix  from bitrix.utils import event_processor from .serializers import PortalSerializer   class PortalViewSet(CreateModelMixin, GenericViewSet):     queryset = Bitrix.objects.all()     serializer_class = PortalSerializer      def create(self, request, *args, **kwargs):         print(\"create func\")         return event_processor(request)      def head(self, request, *args, **kwargs):         print(\"head func\")         return Response(headers={'Allow': 'POST, HEAD'}) <\/code><\/pre>\n
\u0412 settings.py <\/strong>\u0432 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0438 \u0441 \u044f\u0434\u0440\u043e\u043c \u043f\u0440\u043e\u0435\u043a\u0442\u0430 \u0432\u043a\u043b\u044e\u0447\u0438\u043c \u0430\u0432\u0442\u043e\u0440\u0438\u0437\u0430\u0446\u0438\u044e \u043f\u043e \u0442\u043e\u043a\u0435\u043d\u0430\u043c<\/p>\n
REST_FRAMEWORK = {     \"DEFAULT_AUTHENTICATION_CLASSES\": (         \"rest_framework.authentication.SessionAuthentication\",         \"rest_framework.authentication.TokenAuthentication\",         \"core.qpta.QueryParamTokenAuthentication\",     ),     \"DEFAULT_PERMISSION_CLASSES\": (\"rest_framework.permissions.IsAuthenticated\",),     'DEFAULT_RENDERER_CLASSES': ('rest_framework.renderers.JSONRenderer',) }<\/code><\/pre>\n
\u0422\u0430\u043c \u0436\u0435 \u0441\u043e\u0437\u0434\u0430\u0434\u0438\u043c qpta.py<\/strong>:<\/p>\n
from rest_framework.authentication import TokenAuthentication   class QueryParamTokenAuthentication(TokenAuthentication):     def authenticate(self, request):         # Try to get the token from the URL query parameter         token = request.query_params.get(\"api-key\")          if not token:             # Fall back to default token authentication             return super().authenticate(request)          # Authenticate the token manually         user, token = self.authenticate_credentials(token)         return (user, token) <\/code><\/pre>\n
\u0418 api_router.py<\/strong>:<\/p>\n
from django.conf import settings from rest_framework.routers import DefaultRouter from rest_framework.routers import SimpleRouter  from bitrix.api.views import PortalViewSet from users.api.views import UserViewSet from waweb.api.views import EventsHandler from telegram.api.views import TelegramEventsHandler  router = DefaultRouter() if settings.DEBUG else SimpleRouter()  router.register(\"users\", UserViewSet) router.register(\"bitrix\", PortalViewSet) router.register(\"waweb\", EventsHandler, basename=\"waevents\") router.register(\"telegram\", TelegramEventsHandler, basename=\"tgevents\")   app_name = \"api\" urlpatterns = router.urls<\/code><\/pre>\n
\u0412 urls.py<\/strong> \u0434\u043e\u0431\u0430\u0432\u0438\u043c:<\/p>\n
urlpatterns += [     path(\"api\/\", include(\"core.api_router\")), # core \u0437\u0430\u043c\u0435\u043d\u0438\u0442\u044c \u043d\u0430 \u043d\u0430\u0437\u0432\u0430\u043d\u0438\u0435 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u0433\u0434\u0435 \u043b\u0435\u0436\u0438\u0442 \u044f\u0434\u0440\u043e \u043f\u0440\u043e\u0435\u043a\u0442\u0430   ]<\/code><\/pre>\n
\u0421\u043e\u0437\u0434\u0430\u0434\u0438\u043c \u0444\u0430\u0439\u043b utils.py<\/strong> \u0441 \u043e\u0441\u043d\u043e\u0432\u043d\u044b\u043c\u0438 \u0444\u0443\u043d\u043a\u0446\u0438\u044f\u043c\u0438:<\/p>\n
import base64 import json import logging import re import redis  import requests from django.core.exceptions import ObjectDoesNotExist from django.db import transaction from django.contrib import messages from django.conf import settings from django.shortcuts import redirect, get_object_or_404  from rest_framework import status from rest_framework.authtoken.models import Token from rest_framework.response import Response from django.http import HttpResponse  from waweb.models import Session import waweb.utils as waweb import waweb.tasks as waweb_tasks import telegram.tasks as telegram_tasks  from .crest import call_method from .models import App, AppInstance, Bitrix, Line, Connector import bitrix.tasks as bitrix_tasks  from telegram.models import TelegramBot  redis_client = redis.StrictRedis(host=settings.REDIS_HOST, port=6379, db=0)   logger = logging.getLogger(\"django\")  GENERAL_EVENTS = [     \"ONAPPUNINSTALL\", ]  CONNECTOR_EVENTS = [     \"ONIMCONNECTORMESSAGEADD\",     \"ONIMCONNECTORLINEDELETE\",     \"ONIMCONNECTORSTATUSDELETE\", ] <\/code><\/pre>\n
\u0424\u0443\u043d\u043a\u0446\u0438\u044f \u0434\u043b\u044f \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u044f \u043e\u0442\u043a\u0440\u044b\u0442\u043e\u0439 \u043b\u0438\u043d\u0438\u0438 \u0440\u0430\u0437\u0434\u0435\u043b\u044f\u0435\u0442\u0441\u044f \u043d\u0430 2 \u043b\u043e\u0433\u0438\u0447\u0435\u0441\u043a\u0438\u0445 \u0431\u043b\u043e\u043a\u0430: \u0441\u043e\u0437\u0434\u0430\u043d\u0438\u0435 \u0438 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0435 \u0443\u0436\u0435 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u044e\u0449\u0435\u0439 \u043b\u0438\u043d\u0438\u0438. \u0415\u0441\u043b\u0438 id \u043b\u0438\u043d\u0438\u0438 \u043d\u0430\u0447\u0438\u043d\u0430\u0435\u0442\u0441\u044f \u0441 create, \u0442\u043e \u0441\u043e\u0437\u0434\u0430\u0435\u043c \u043d\u043e\u0432\u0443\u044e \u043e\u0442\u043a\u0440\u044b\u0442\u0443\u044e \u043b\u0438\u043d\u0438\u044e \u0438 AppInstance. \u0414\u0430\u043b\u0435\u0435 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u0432 \u0411\u0438\u0442\u0440\u0438\u043a\u0441 \u043a\u043e\u043d\u0444\u0438\u0433\u0438 \u043e\u0442\u043a\u0440\u044b\u0442\u043e\u0439 \u043b\u0438\u043d\u0438\u0438 (imopenlines.config.add<\/strong>), \u043f\u0440\u043e\u0432\u0435\u0440\u044f\u0435\u043c AppInstance \u043d\u0430 \u043d\u0430\u043b\u0438\u0447\u0438\u0435 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u043d\u043e\u0439 \u043e\u0442\u043a\u0440\u044b\u0442\u043e\u0439 \u043b\u0438\u043d\u0438\u0438 \u0438 \u0434\u0435\u0430\u043a\u0442\u0438\u0432\u0438\u0440\u0443\u0435\u043c \u0435\u0435, \u0435\u0441\u043b\u0438 \u0442\u0430\u043a\u043e\u0432\u0430\u044f \u0438\u043c\u0435\u0435\u0442\u0441\u044f. \u0424\u0438\u043d\u0430\u043b\u044c\u043d\u044b\u043c \u0448\u0430\u0433\u043e\u043c \u0430\u043a\u0442\u0438\u0432\u0438\u0440\u0443\u0435\u043c \u043d\u0430\u0448\u0443 \u043e\u0442\u043a\u0440\u044b\u0442\u0443\u044e \u043b\u0438\u043d\u0438\u044e \u0432 \u0411\u0438\u0442\u0440\u0438\u043a\u0441\u0435 \u043c\u0435\u0442\u043e\u0434\u043e\u043c imconnector.activate <\/strong>\u0438 \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u043c \u0440\u0435\u0434\u0438\u0440\u0435\u043a\u0442 \u043d\u0430 \u0441\u0442\u0440\u0430\u043d\u0438\u0446\u0443 \u0437\u0430\u0432\u0435\u0440\u0448\u0435\u043d\u0438\u044f \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u044f:<\/p>\n
def connect_line(request, line_id, entity, connector, redirect_to):     line_id = str(line_id)     if line_id.startswith(\"create__\"):         instance_id = line_id.split(\"__\")[1]         app_instance = get_object_or_404(AppInstance, id=instance_id, owner=request.user)         if not app_instance.portal:             messages.error(request, \"\u041d\u0435\u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e \u0441\u043e\u0437\u0434\u0430\u0442\u044c \u043b\u0438\u043d\u0438\u044e: \u043f\u043e\u0440\u0442\u0430\u043b \u043d\u0435 \u043d\u0430\u0439\u0434\u0435\u043d\")             return redirect(redirect_to)         if entity.line:             call_method(app_instance, \"imconnector.activate\", {                 \"CONNECTOR\": connector.code,                 \"LINE\": entity.line.line_id,                 \"ACTIVE\": 0,             })         if connector.service == \"telegram\":             line_name = entity.bot_username         else:             line_name = entity.phone         create_payload = {\"PARAMS\": {\"LINE_NAME\": line_name}}         result = call_method(app_instance, \"imopenlines.config.add\", create_payload)         if result and result.get(\"result\"):             new_line_id = result[\"result\"]             line = Line.objects.create(                 line_id=new_line_id,                 portal=app_instance.portal,                 connector=connector,                 app_instance=app_instance,                 owner=request.user             )             entity.line = line             entity.app_instance = app_instance             entity.save()              activate_payload = {                 \"CONNECTOR\": connector.code,                 \"LINE\": new_line_id,                 \"ACTIVE\": 1,             }             call_method(app_instance, \"imconnector.activate\", activate_payload)             messages.success(request, f\"\u0421\u043e\u0437\u0434\u0430\u043d\u0430 \u0438 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0430 \u043b\u0438\u043d\u0438\u044f {new_line_id}\")         else:             messages.error(request, f\"\u041e\u0448\u0438\u0431\u043a\u0430 \u043f\u0440\u0438 \u0441\u043e\u0437\u0434\u0430\u043d\u0438\u0438 \u043b\u0438\u043d\u0438\u0438: {result}\")         return redirect(redirect_to)     else:         line = get_object_or_404(Line, id=line_id)         if not line:             messages.error(request, f\"\u041b\u0438\u043d\u0438\u044f {line_id} \u043d\u0435 \u043d\u0430\u0439\u0434\u0435\u043d\u0430\")             return redirect(redirect_to)         entity_model = type(entity)         usage_count = entity_model.objects.filter(line=line).exclude(pk=entity.pk).count()         if usage_count > 0:             messages.error(request, \"\u042d\u0442\u0430 \u043b\u0438\u043d\u0438\u044f \u0443\u0436\u0435 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f.\")             return redirect(redirect_to)          app_instance = line.app_instance          if entity.line == line:             messages.success(request, \"\u0412\u044b\u0431\u0440\u0430\u043d\u0430 \u0442\u0430 \u0436\u0435 \u043b\u0438\u043d\u0438\u044f\")             return redirect(redirect_to)         if entity.line:             call_method(app_instance, \"imconnector.activate\", {                 \"CONNECTOR\": connector.code,                 \"LINE\": entity.line.line_id,                 \"ACTIVE\": 0,             })         response = call_method(app_instance, \"imconnector.activate\", {             \"CONNECTOR\": connector.code,             \"LINE\": line.line_id,             \"ACTIVE\": 1,         })         if response.get(\"result\"):             entity.line = line             entity.app_instance = app_instance             entity.save()             messages.success(request, \"\u041b\u0438\u043d\u0438\u044f \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0430\")      messages.success(request, \"\u041d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438 \u043e\u0431\u043d\u043e\u0432\u043b\u0435\u043d\u044b\")     return redirect(redirect_to)<\/code><\/pre>\n
\u041f\u043e\u0434\u043f\u0438\u0441\u043a\u0430 \u043d\u0430 \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u0411\u0438\u0442\u0440\u0438\u043a\u0441 \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u043b\u044f\u0435\u0442 \u0438\u0437 \u0441\u0435\u0431\u044f \u0432\u0441\u0435\u0433\u043e 1 \u0437\u0430\u043f\u0440\u043e\u0441 \u043d\u0430 \u044d\u043d\u0434\u043f\u043e\u0438\u043d\u0442 event.bind<\/strong>, \u0432 \u043a\u043e\u0442\u043e\u0440\u043e\u043c \u043c\u044b \u0441\u043e\u043e\u0431\u0449\u0430\u0435\u043c \u0430\u0434\u0440\u0435\u0441 \u043d\u0430\u0448\u0435\u0433\u043e \u0432\u0435\u0431\u0445\u0443\u043a\u0430, \u043f\u0440\u0438\u043d\u0438\u043c\u0430\u044e\u0449\u0435\u0433\u043e \u0441\u043e\u0431\u044b\u0442\u0438\u044f:<\/p>\n
def events_bind(events: dict, appinstance: AppInstance, api_key: str):     url = appinstance.app.site     for event in events:         payload = {             \"event\": event,             \"HANDLER\": f\"https:\/\/{url}\/api\/bitrix\/?api-key={api_key}\",         }          try:             return call_method(appinstance, \"event.bind\", payload)         except (ObjectDoesNotExist, Exception) as exc:             print(exc, \" in events_bind\")             return None<\/code><\/pre>\n
\u0420\u0435\u0433\u0438\u0441\u0442\u0440\u0430\u0446\u0438\u044f \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430 \u0432\u043a\u043b\u044e\u0447\u0430\u0435\u0442 \u0432 \u0441\u0435\u0431\u044f 2 \u0444\u0443\u043d\u043a\u0446\u0438\u0438: \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0430\u0446\u0438\u044f \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430 (register_connector<\/strong>) \u0438 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0430 \u0435\u0433\u043e \u0443\u0441\u0442\u0430\u043d\u043e\u0432\u043a\u0438 (process_placement<\/strong>). <\/p>\n
\u0424\u0443\u043d\u043a\u0446\u0438\u044f \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0430\u0446\u0438\u0438 \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430 \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u0442 \u0435\u0433\u043e \u0432 \u043c\u0435\u043d\u044e \u0431\u0438\u0442\u0440\u0438\u043a\u0441\u0430 CRM — \u041a\u043e\u043d\u0442\u0430\u043a\u0442-\u0426\u0435\u043d\u0442\u0440. \u0417\u0434\u0435\u0441\u044c \u043c\u044b \u0434\u0435\u043a\u043e\u0434\u0438\u0440\u0443\u0435\u043c \u043d\u0430\u0448\u0443 svg \u0438\u043a\u043e\u043d\u043a\u0443 \u0432 base64 \u0438 \u0432\u044b\u0437\u044b\u0432\u0430\u0435\u043c \u043c\u0435\u0442\u043e\u0434 imconnector.register<\/strong> \u0441 \u0442\u0430\u043a\u0438\u043c\u0438 \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440\u0430\u043c\u0438, \u043a\u0430\u043a uuid \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430, \u043d\u0430\u0437\u0432\u0430\u043d\u0438\u0435 \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430 \u0438 \u0435\u0433\u043e \u0438\u043a\u043e\u043d\u043a\u0430 \u0432 base64. \u041f\u043e\u0441\u043b\u0435 \u0432\u044b\u0437\u043e\u0432\u0430 \u044d\u0442\u043e\u0439 \u0444\u0443\u043d\u043a\u0446\u0438\u0438, \u043a\u0430\u0440\u0442\u043e\u0447\u043a\u0430 \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430 \u043f\u043e\u044f\u0432\u0438\u0442\u0441\u044f \u0432 \u041a\u043e\u043d\u0442\u0430\u043a\u0442-\u0426\u0435\u043d\u0442\u0440\u0435.<\/p>\n
\u0427\u0442\u043e \u043a\u0430\u0441\u0430\u0435\u0442\u0441\u044f \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u0430 \u0443\u0441\u0442\u0430\u043d\u043e\u0432\u043a\u0438, \u0435\u0433\u043e \u0441\u043b\u0435\u0434\u0443\u0435\u0442 \u0432\u043e\u0441\u043f\u0440\u0438\u043d\u0438\u043c\u0430\u0442\u044c \u043a\u0430\u043a \u0432\u0445\u043e\u0434\u044f\u0449\u0438\u0439 \u0432\u0435\u0431\u0445\u0443\u043a \u043e\u0442 \u0431\u0438\u0442\u0440\u0438\u043a\u0441\u0430. \u0417\u0434\u0435\u0441\u044c \u043c\u044b \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u043c \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440\u044b \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430 \u0438 \u043e\u0442\u043a\u0440\u044b\u0442\u043e\u0439 \u043b\u0438\u043d\u0438\u0438, uuid \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u0438 \u0430\u0434\u0440\u0435\u0441 \u043f\u043e\u0440\u0442\u0430\u043b\u0430 \u0411\u0438\u0442\u0440\u0438\u043a\u0441. \u0415\u0441\u043b\u0438 \u0434\u0430\u043d\u043d\u044b\u0435 \u043a\u043e\u0440\u0440\u0435\u043a\u0442\u043d\u044b, \u043f\u0440\u0438\u0432\u044f\u0437\u044b\u0432\u0430\u0435\u043c \u041e\u0442\u043a\u0440\u044b\u0442\u0443\u044e \u041b\u0438\u043d\u0438\u044e \u043a \u0441\u0443\u0449\u043d\u043e\u0441\u0442\u0438 \u043b\u043e\u043a\u0430\u043b\u044c\u043d\u043e\u0433\u043e \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430 \u0438 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044e \u0438 \u043f\u0435\u0440\u0435\u0434\u0430\u0435\u043c HANDLER \u0434\u043b\u044f \u0441\u043e\u0431\u044b\u0442\u0438\u0439, \u0441\u0432\u044f\u0437\u0430\u043d\u043d\u044b\u0445 \u0441 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f\u043c\u0438:<\/p>\n
def register_connector(appinstance: AppInstance, api_key: str, connector):     url = appinstance.app.site      if not connector.icon:         return None      try:         with open(connector.icon.path, \"rb\") as file:             image_data = file.read()             encoded_image = base64.b64encode(image_data).decode(\"utf-8\")             connector_logo = f\"data:image\/svg+xml;base64,{encoded_image}\"          payload = {             \"ID\": connector.code,             \"NAME\": connector.name,             \"ICON\": {                 \"DATA_IMAGE\": connector_logo,             },             \"PLACEMENT_HANDLER\": f\"https:\/\/{url}\/app-settings\/?inst={appinstance.id}\",         }          try:             return call_method(appinstance, \"imconnector.register\", payload)         except (ObjectDoesNotExist, Exception) as exc:             print(exc, \" in register_connector\")             return None          events_bind(CONNECTOR_EVENTS, appinstance, api_key)      except FileNotFoundError:         return None     except Exception as e:         return None   def process_placement(request):     try:         data = request.POST         placement_options = data.get(\"PLACEMENT_OPTIONS\")         instance_id = request.GET.get(\"inst\")         domain = request.GET.get(\"DOMAIN\")         print(\"process placement GET \", request.GET)         print(\"FULL URL:\", request.build_absolute_uri())          placement_options = json.loads(placement_options)         line_id = placement_options.get(\"LINE\")         connector_code = placement_options.get(\"CONNECTOR\")          app_instance = AppInstance.objects.filter(id=instance_id).first()         if not app_instance:             return HttpResponse(\"app not found\")         portal = Bitrix.objects.filter(domain=domain).first()         if not portal:             return HttpResponse(\"bitrix not found\")         connector = Connector.objects.filter(code=connector_code).first()         if not connector:             return HttpResponse(\"connector not found\")         line, created = Line.objects.get_or_create(             line_id=line_id,             portal=portal,             connector=connector,             app_instance=app_instance,             owner=app_instance.owner         )         activate_payload = {             \"CONNECTOR\": connector.code,             \"LINE\": line_id,             \"ACTIVE\": 1,         }         print(\"activate_payload= \", activate_payload)         activate_result = call_method(app_instance, \"imconnector.activate\", activate_payload)          if not activate_result or not activate_result.get(\"result\"):             return HttpResponse(f\"Failed to activate connector: {activate_result}\")          # api_key = request.GET.get(\"api-key\")         api_key = Token.objects.get(user=app_instance.owner).key         print(\"request data= \", request.GET)         print(\"api_key=\", api_key)         print(\"app_instance=\", app_instance)         events = [\"ONIMCONNECTORMESSAGEADD\", \"ONIMCONNECTORSTATUSDELETE\", \"ONIMCONNECTORLINEDELETE\"]         for event in events:             event_payload = {                 \"event\": event,                 \"HANDLER\": f\"https:\/\/{app_instance.app.site}\/api\/bitrix\/?api-key={api_key}\",             }             call_method(app_instance, \"event.bind\", event_payload)          return HttpResponse(             f\"\u041b\u0438\u043d\u0438\u044f \u0443\u0441\u043f\u0435\u0448\u043d\u043e \u0441\u043e\u0437\u0434\u0430\u043d\u0430 \u0438 \u0430\u043a\u0442\u0438\u0432\u0438\u0440\u043e\u0432\u0430\u043d\u0430. \u041d\u0430\u0441\u0442\u0440\u043e\u0439\u0442\u0435 \u0434\u043e\u043f. \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440\u044b \u0432 Bitrix: https:\/\/{app_instance.app.site}\/portals\/\"         )     except Exception as e:         logger.error(f\"Unexpected error: {e}\")         return HttpResponse({\"An unexpected error occurred\"})<\/code><\/pre>\n
\u041e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0430 \u0444\u0430\u0439\u043b\u043e\u0432  \u0438 \u0441\u043e\u0431\u044b\u0442\u0438\u0439. extract_files <\/strong>\u0438 upload_file <\/strong>\u043e\u043f\u0438\u0441\u044b\u0432\u0430\u044e\u0442 \u043b\u043e\u0433\u0438\u043a\u0443 \u0440\u0430\u0431\u043e\u0442\u044b \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430 \u0441 \u0444\u0430\u0439\u043b\u0430\u043c\u0438. \u041d\u0438\u0447\u0435\u0433\u043e \u0441\u0432\u0435\u0440\u0445\u044a\u0435\u0441\u0442\u0435\u0441\u0442\u0432\u0435\u043d\u043d\u043e\u0433\u043e, \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u043f\u0440\u0435\u0434\u043b\u0430\u0433\u0430\u044e \u043d\u0435 \u0437\u0430\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0442\u044c\u0441\u044f \u043d\u0430 \u044d\u0442\u043e\u043c \u0438 \u043f\u0435\u0440\u0435\u0439\u0434\u0435\u043c \u043a event_processor <\/strong>— \u0444\u0443\u043d\u043a\u0446\u0438\u0438, \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u044e\u0449\u0435\u0439 \u0432\u0441\u0435 \u0432\u0445\u043e\u0434\u044f\u0449\u0438\u0435 \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u043e\u0442 \u0411\u0438\u0442\u0440\u0438\u043a\u0441\u0430.<\/p>\n
def extract_files(data):     files = []     i = 0     while True:         name_key = f\"data[MESSAGES][0][message][files][{i}][name]\"         link_key = f\"data[MESSAGES][0][message][files][{i}][link]\"         type_key = f\"data[MESSAGES][0][message][files][{i}][type]\"          if name_key in data and link_key in data:             files.append(                 {                     \"name\": data.get(name_key),                     \"link\": data.get(link_key),                     \"type\": data.get(type_key),                 },             )             i += 1         else:             break      return files   def upload_file(appinstance, storage_id, fileContent, filename):     payload = {         \"id\": storage_id,         \"fileContent\": fileContent,         \"data\": {\"NAME\": filename},         \"generateUniqueName\": True,     }     upload_to_bitrix = call_method(appinstance, \"disk.folder.uploadfile\", payload)     if \"result\" in upload_to_bitrix:         return upload_to_bitrix[\"result\"]     else:         return None<\/code><\/pre>\n
event_processor<\/strong> — \u044d\u0442\u043e \u0435\u0434\u0438\u043d\u044b\u0439 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a \u0432\u0441\u0435\u0445 \u0441\u043e\u0431\u044b\u0442\u0438\u0439, \u043f\u043e\u0441\u0442\u0443\u043f\u0430\u044e\u0449\u0438\u0445 \u043e\u0442 Bitrix24 \u043f\u043e REST-\u0445\u0443\u043a\u0430\u043c. \u041e\u043d \u043f\u0440\u0438\u043d\u0438\u043c\u0430\u0435\u0442 \u0432\u0445\u043e\u0434\u044f\u0449\u0438\u0435 \u0437\u0430\u043f\u0440\u043e\u0441\u044b, \u0438\u0437\u0432\u043b\u0435\u043a\u0430\u0435\u0442 \u0438\u0437 \u043d\u0438\u0445 \u0434\u0430\u043d\u043d\u044b\u0435 (\u0441\u043e\u0431\u044b\u0442\u0438\u044f, \u0442\u043e\u043a\u0435\u043d\u044b, \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440\u044b \u043f\u043e\u0440\u0442\u0430\u043b\u0430) \u0438 \u0432 \u0437\u0430\u0432\u0438\u0441\u0438\u043c\u043e\u0441\u0442\u0438 \u043e\u0442 \u0442\u0438\u043f\u0430 \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u0432\u044b\u043f\u043e\u043b\u043d\u044f\u0435\u0442 \u0441\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0443\u044e \u0431\u0438\u0437\u043d\u0435\u0441-\u043b\u043e\u0433\u0438\u043a\u0443:<\/p>\n