блокировка записи сотрудника если назначен другой

mirzaev/spetsresurs/telegram/registry/requests/system/public/robot.php

@@ -236,10 +236,11 @@ function generateMenu(Context $ctx): void
  * @param int $amount Количество
  * @param ?string $date За какую дату (unixtime)
  * @param int $page Страница
+ * @param _document $worker Сотрудник
  *
  * @return Cursor
  */
-function requests(int $amount = 5, ?string $date = null, int $page = 1): Cursor
+function requests(int $amount = 5, ?string $date = null, int $page = 1, _document $worker): Cursor
 {
 	global $arangodb;
 
@@ -260,11 +261,12 @@ function requests(int $amount = 5, ?string $date = null, int $page = 1): Cursor
 		[
 			'query' => sprintf(
 				// d.date < %s там специально, не менять на <=
-				"FOR d IN task FILTER ((d.date >= %s && d.date < %s && d.start >= '05:00') || (d.date >= %s && d.date < %s && d.start < '05:00')) && d.worker == null && d.market != null && d.confirmed != true && d.published == true && d.completed != true SORT d.created DESC, d._key DESC LIMIT %d, %d RETURN d",
+				"FOR d IN task FILTER ((d.date >= %s && d.date < %s && d.start >= '05:00') || (d.date >= %s && d.date < %s && d.start < '05:00')) && d.worker == null && d.market != null && d.confirmed != true && d.published == true && d.completed != true && (FOR m IN market FILTER m.id == d.market && IS_ARRAY(m.bans) SORT m.created DESC, m._key DESC LIMIT 1 RETURN !POSITION(m.bans, \"%s\"))[0] SORT d.created DESC, d._key DESC LIMIT %d, %d RETURN d",
 				$from = (new DateTime("@$date"))->setTime(0, 0)->format('U'),
 				$to = (new DateTime("@$date"))->modify('+1 day')->setTime(0, 0)->format('U'),
 				$to,
 				(new DateTime("@$date"))->modify('+2 day')->setTime(0, 0)->format('U'),
+				$worker->id,
 				$offset,
 				$amount + $offset - ($page > 0)
 			),
@@ -344,37 +346,43 @@ function request_confirmed(Context $ctx): void
 			// Прочитана запрашиваемая заявка
 
 			// Инициализация инстанции task в базе данных (выбранного задания)
-			$task = collection::search($arangodb->session, sprintf("FOR d IN task FILTER d._key == '%s' && d.published == true && d.completed != true RETURN d", $_key));
+			$task = collection::search($arangodb->session, sprintf("FOR d IN task FILTER d._key == '%s' && d.published == true && d.completed != true && worker == null RETURN d", $_key));
 
-			if ($worker ??= worker($account->getId())) {
-				// Найден сотрудник
+			if ($task instanceof _document) {
+				// Найдена заявка (подразумевается, что не занята)
 
-				// Запись идентификатора нового сотрудника
-				$task->worker = $worker->id;
+				if ($worker ??= worker($account->getId())) {
+					// Найден сотрудник
 
-				// Снятие с публикации
-				$task->published = false;
+					// Запись идентификатора нового сотрудника
+					$task->worker = $worker->id;
 
-				if (document::update($arangodb->session, $task)) {
-					// Записано обновление в базу данных
+					// Снятие с публикации
+					$task->published = false;
 
-					$ctx->getChatDataItem("request_all")->then(function ($requests = []) use ($ctx) {
-						// Удаление сообщений связанных с запросом
-						foreach ($requests ?? [] as $_message) $ctx->deleteMessage($_message->getChat()->getId(), $_message->getMessageId());
-					});
-					$ctx->setChatDataItem("request_all", []);
+					if (document::update($arangodb->session, $task)) {
+						// Записано обновление в базу данных
 
-					$ctx->getChatDataItem("request_confirmation")->then(function ($message) use ($ctx) {
-						$ctx->deleteMessage($message->getChat()->getId(), $message->getMessageId());
-					});
-					$ctx->setChatDataItem("request_confirmation_target", null);
+						$ctx->getChatDataItem("request_all")->then(function ($requests = []) use ($ctx) {
+							// Удаление сообщений связанных с запросом
+							foreach ($requests ?? [] as $_message) $ctx->deleteMessage($_message->getChat()->getId(), $_message->getMessageId());
+						});
+						$ctx->setChatDataItem("request_all", []);
 
-					$ctx->sendMessage("✅ *Вы зарегистрировались на заявку:* \#$_key", ['reply_markup' =>	['remove_keyboard' => true]])->then(function () use ($ctx) {
+						$ctx->getChatDataItem("request_confirmation")->then(function ($message) use ($ctx) {
+							$ctx->deleteMessage($message->getChat()->getId(), $message->getMessageId());
+						});
+						$ctx->setChatDataItem("request_confirmation_target", null);
+
+						$ctx->sendMessage("✅ *Вы зарегистрировались на заявку:* \#$_key", ['reply_markup' =>	['remove_keyboard' => true]])->then(function () use ($ctx) {
+							generateMenu($ctx);
+						});
+
+						// End of the process
+						$ctx->endConversation();
+					} else $ctx->sendMessage("❎ *Не удалось принять заявку:* \#$_key", ['reply_markup' =>	['remove_keyboard' => true]])->then(function () use ($ctx) {
 						generateMenu($ctx);
 					});
-
-					// End of the process
-					$ctx->endConversation();
 				} else $ctx->sendMessage("❎ *Не удалось принять заявку:* \#$_key", ['reply_markup' =>	['remove_keyboard' => true]])->then(function () use ($ctx) {
 					generateMenu($ctx);
 				});
@@ -459,7 +467,7 @@ function search(Context $ctx): void
 		else {
 			// Активен аккаунт
 
-			$ctx->getChatDataItem('requests_page')->then(function ($page) use ($ctx, $arangodb) {
+			$ctx->getChatDataItem('requests_page')->then(function ($page) use ($ctx, $arangodb, $worker) {
 				// Найдена текущая страница
 
 				// Значение страницы по умолчанию
@@ -468,9 +476,9 @@ function search(Context $ctx): void
 					$ctx->setChatDataItem('requests_page', 1);
 				}
 
-				$generate = function ($date) use ($ctx, $page, $arangodb) {
+				$generate = function ($date) use ($ctx, $page, $arangodb, $worker) {
 					// Поиск заявок в ArangoDB
-					$tasks = requests(4, (string) $date, $page);
+					$tasks = requests(4, (string) $date, $page, $worker);
 
 					// Подсчёт количества прочитанных заявок из базы данных
 					$count = $tasks->getCount();

telegram-robot.service

@@ -1,6 +1,9 @@
 [Unit]
 Description=Telegram-robot
 
+Wants=network.target
+After=syslog.target network-online.target
+
 [Service]
 ExecStart=sudo -u www-data /usr/bin/php /var/www/spetsresurs-telegram-registry-requests/mirzaev/spetsresurs/telegram/registry/requests/system/public/robot.php
 PIDFile=/var/run/php/telegram-robot.pid
@@ -8,3 +11,6 @@ RemainAfterExit=no
 RuntimeMaxSec=3600s
 Restart=always
 RestartSec=5s
+
+[Install]    
+WantedBy=multi-user.target