В одной стандартной организации работает достаточно много людей. Большой отдел маркетинга, который постоянно генерирует миллион классных идей, большой отдел продаж, которому требуется оперативно видеть все изменения в CRM, и т.д. и т.п. 

Деятельность организации, взаимодействие сотрудников порождает множество бизнес-процессов, которые хочется автоматизировать. 

Вариант, когда множество систем общаются между собой напрямую уже был испробован и пришло понимание, что он не подходит, т.к. сложно поддерживать и развивать. 

Чтобы избавиться от этого, принято решение реализовать центральную систему, которая будет обеспечивать взаимодействие сервисов. Некий оркестратор. 

Получился конвейер обработки запросов. Пришедший набор данных встает на “конвейер” и обрабатывается по шагам. На каждом шаге данные получает один из модулей, который может быть как отдельным сервисом, так и частью целого. 

Путь заявки по обработчикам задан в настройках. Пока настройки это массив PHP неограниченной вложенности, но когда-нибудь появится интерфейс. 

Пример настроек: 

'get-bitrix-deal'                             => [
	'id'        => 'get-bitrix-deal',
	'subsystem' => 'find-deal',
	'next'      => ['remember-deal'],
	'prev'      => ['prev-step'],
	'condition' => [
		[
			'field'     => 'get-bitrix-deal.value',
			'operation' => 'empty',
			'success'   => [
				[
					'field'     => 'bitrix-find-contact.ID',
					'operation' => 'empty',
					'result'    => ['bitrix-lead-set-default-values'],
				],
			],
		],
		[
			'field'     => 'get-bitrix-deal.value',
			'operation' => '!|empty',
			'result'    => ['get-bitrix-deal-by-id'],
		],
	],
]

Верхнеуровнево система выглядит следующим образом: 

Реализация на PHP и Laravel. 

Т.к. все модули должны быть слабо связанными, напрямую друг к другу обращаться не могут, поэтому взаимодействие основано на событиях. 

Еще одним требованием была универсальность системы. Нельзя было затачивать ее функционал под конкретные нужды, т.к. сегодня они одни, а завтра другие. Поэтому на вход могут поступать совершенно разные наборы данных, обработка которых настраивается. 

Есть модуль API, который принимает запросы из-вне. Этот модуль имеет расширение, которое позволяет буферизировать запросы и выполнять их либо по расписанию, либо пачками, например, по 10 штук в минуту. 

Далее формируется событие NewRequest, которое перехватывается модулем маршрутизации(supervisor). Супервайзер определяет следующий шаг и передаёт диспетчеру. 

Диспетчер определяет как отправлять запрос в указанный модуль – событием внутри системы, по HTTP, либо поставить задачу в очередь. 

Модуль перехватывает событие, обрабатывает как надо, добавляет в него необходимые данные и отправляет событие обратно. 

Супервайзер в свою очередь перехватывает ответ модуля, фиксирует изменения, вычисляет следующий шаг и т.д. до тех пор пока не дойдет до конца бизнес-процесса. 

На текущий момент реализованы следующие модули: 

• API

• Bitrix24

• Postaffiliate

• Отправка данных по http

• Агрегация данных 

• Выгрузка для AdvCake 

• Маппинг данных 

• Установка значений по-умолчанию 

• Буфер

• Передача данных в Sendsay

И основные модули: 

• Базовые классы (ядро системы) 

• Supervisor 

• DB 

Пример реальной схемы бизнес-процессов, построенных с помощью этих модулей: