Aggregate Recurring scheduled command | Notion

Scheduled command <Aggregate root>	Свойства/Действия	Тип	Комментарий
Запланированная команда. Содержит команду, которая выполнится в указанную дату и время	Id	UUID	Идентификатор
	Command	Command	Команда для выполнения
	Scheduled time	CRON or Time	Время выполнения команды
	Time zone	time zone
	Error message	Text (Nullable)	Текст ошибки, если произошла ошибка
	Attempts	Number	Количество попыток выполнения. Максимальное количество 5.
	Next execution time	Date time (utc)	Дата следующего выполнения
	Create	Action	Создает запланированную команду
	Change executed	Action	Изменить дату и время выполнения команды

Command <Value object>
Команда для выполнения. Может быть сколько угодно типов

Инфрастуктура

Отправка уведомлений пользователю по событию

Создаем событие
В обработке события создаем новый Recurring scheduled command и сохраняем
Отдельный сервис или функция ходит постоянно в бд c небольшим периодом и получает те команды, которые необходимо обработать, и отправляет их в очередь на обработку
Подписанные обработчики на эти команды выполняют операцию

Необходимо:

Создать хранилище для повторяющихся запланированных команда (Например, sql table)
Создать очередь, которая будет хранить команды на обработку

Примечание:

Если команда будет для пользователя, то необходимо в Command хранить UserProfileId . И в случае изменения time zone **у пользователя, необходимо обновить time zone для всех команд принадлежащие ему.
Так как индексы по json невозможены, то необходимо для быстрого поиска выделить два поля и создать для них индексы:
- User id :: uuid? - индентификатор пользователя
- Discriminator :: text - тип команды