commentlistener.php

См. документацию.

<?php
 
namespace Bitrix\Bizproc\Integration;
 
use Bitrix\Bizproc\Api\Request\WorkflowCommentService\CommentRequest;
use Bitrix\Bizproc\Api\Request\WorkflowCommentService\MarkAsReadRequest;
use Bitrix\Bizproc\Api\Service\WorkflowCommentService;
use Bitrix\Main\Event;
use Bitrix\Main\Loader;
use Bitrix\Main\Type\DateTime;
 
class CommentListener
{
    public static function onAfterCommentAdd(Event $event): void
    {
        [$entityType, $workflowIdInt, $fields] = $event->getParameters();
 
        if ($entityType !== 'WF' || isset($fields['PARAMS']['SERVICE_TYPE']))
        {
            return;
        }
 
        $authorId = (int)($fields['PARAMS']['AUTHOR_ID'] ?? 0);
        if (!$authorId)
        {
            return;
        }
 
        $workflowId = \CBPStateService::getWorkflowByIntegerId($workflowIdInt);
        if (!$workflowId)
        {
            return;
        }
 
        $created = $fields['PARAMS']['POST_DATE'] ?? new DateTime();
        $mentions = [];
        $messageText = $fields['PARAMS']['POST_MESSAGE'] ?? '';
 
        if(preg_match_all("/(?<=\[USER=)(?P<id>\d+)(?=])/", $messageText, $matches))
        {
            $mentions = $matches['id'];
        }
 
        $service = new WorkflowCommentService();
        $service->registerComment(new CommentRequest($workflowId, $authorId, $created, $mentions));
    }
 
    public static function onCommentDelete(Event $event): void
    {
        [$entityType, $workflowIdInt, $fields] = $event->getParameters();
 
        if ($entityType !== 'WF')
        {
            return;
        }
 
        $authorId = (int)($fields['MESSAGE']['AUTHOR_ID'] ?? 0);
        if (!$authorId)
        {
            return;
        }
 
        $workflowId = \CBPStateService::getWorkflowByIntegerId($workflowIdInt);
        if (!$workflowId)
        {
            return;
        }
 
        $created = DateTime::createFromUserTime($fields['MESSAGE']['POST_DATE']);
 
        $service = new WorkflowCommentService();
        $service->unRegisterComment(new CommentRequest($workflowId, $authorId, $created));
    }
 
    public static function onListsProcessesCommentAdd(string $workflowId, int $authorId, array $mentions): void
    {
        $service = new WorkflowCommentService();
        $service->registerComment(new CommentRequest($workflowId, $authorId, new DateTime(), $mentions));
    }
 
    public static function onListsProcessesCommentDelete(string $workflowId,  int $authorId, DateTime $created): void
    {
        $service = new WorkflowCommentService();
        $service->unRegisterComment(new CommentRequest($workflowId, $authorId, $created));
    }
 
    public static function onSocnetContentViewed(Event $event): void
    {
        $params = $event->getParameters();
 
        if (($params['typeId'] ?? '') !== 'FORUM_POST' || empty($params['entityId']) || empty($params['userId']))
        {
            return;
        }
 
        if (!Loader::includeModule('forum'))
        {
            return;
        }
 
        $xmlId = \Bitrix\Forum\MessageTable::query()
            ->setSelect(['XML_ID'])
            ->where('ID', $params['entityId'])
            ->fetch()['XML_ID'] ?? null
        ;
 
        if (!$xmlId || strpos($xmlId, 'WF_') !== 0)
        {
            return;
        }
 
        $workflowId = substr($xmlId, 3);
 
        $service = new WorkflowCommentService();
        $service->markAsRead(new MarkAsReadRequest($workflowId, (int)$params['userId']));
    }
}