Как обработать истечение срока?

Question

[Сергей Гутовский]

Имеются модели Task(задание), Skill(навык). Задание создает человек, ему он указывает срок выполнения deadline_at. Skill имеет поле score(количество очков у навыка). К заданию вы можете через промеж. таблицу присоединять навыки и указывать как они изменятся при выполнении/ невыполнении задания.

Пример
Есть задание Подкачаться
Юзер указывает, что при выполнении навык сила получит 5 очков, иначе же навык потеряет 10.
При очередном заходе на страницу юзер видит, что срок выполнения истек, и задание подкачаться провалено, а навык сила потерял 10 очков.

Так вот, как же сделать эту обработку задний. Нужно неведомым мне образом чекать бд и при наличии заданий, у коих срок истек, выставлять им поле finished_at и обновлять привязанные скилы.
Я пробовал делать это через Task Scheduler. В принципе все работало: каждую минуту в бд посылался запрос, находились необходимые задания и выполнялось обновление как скилов, так и заданий
Но вот проблема. Этот поиск идет раз в минуту. Но что если срок у задания истечет в промежутке между работай Task Scheduler, тогда при заходе на страницу задания юзер увидит, что срок истек, но задание не отмечено законченным, а привязанные к нему скилы не потеряли очков.

Как с этим бороться? И вообще как реализована в больших проектах проверка на истечение срока.(истории в ВК, которые удаляются через 24 ч). Ведь фишка в том, что нужно не просто фильтровать таблицу через where(...), а нужно еще и обновлять ее при необходимости и все это должно происходить до начала работы осн. логики проекта

Comments

[Модератор]

Сергей Гутовский дорогой пользователь, настоятельно рекомендуем еще раз обратить самое пристальное внимание на п. 3.1 регламента работы сервиса (и, в особенности, на его последний абзац).
В противном случае, ваши вопросы будут удаляться по причине тег-спама, а систематические нарушения приведут к блокировке учетной записи.

Это последнее предупреждение.

Answer 1

[JhaoDa]

Раз в N минут собирать собирать задания, которым скоро подойдёт срок. Ставить в очередь их удаление с точностью до минуты/секунды.

P.S. И поменьше тэгов.

Comments

[Сергей Гутовский]

То есть выполнять два действия.
1 находить просроченные задания, обновлять их
2 Ставить в очередь, те у которых скоро подойдет срок
Верно?

[JhaoDa]

Сергей Гутовский, на счёт п. 1 не знаю, это уже дело ваше — что и как обновлять, но в целом верно.

[Сергей Гутовский]

JhaoDa, Окей, звучит как что-то работающее.
Крайне благодарен!

Answer 2

[FeNUMe]

Имхо для описанной вами задачи вообще нет смысла дергать постоянно базу и выставлять флаг, вместо этого в клиентской части просто делайте проверку
текущее_время > deadline_at
и на основе результата проводите нужные манипуляции.

Answer 3

[Дмитрий Евграфович]

Учите очереди, при создании задания добавляете на момент его окончания задачу проверить, истекло ли конкретно это задание (и не обработано ли оно ещё), плюс, реализуете совет от FeNUMe на случай если задания будут исполнены раньше срока (для этого и нужна первая проверка на то, исполнена задача или нет. В идеале ту. Бы удалить задачу из очереди, но ларавел на текущий момент этого не позволяет). Если сделаете то, что отметили решением, то когда задач не будет, ваши ресурсы будут работать вхолостую, отнимая процессорное время (на это наплевать, пока вы не перешли на оплату за ресурсы, но зачем приучаться к говнокоду?), а когда (если) сервис станет огромным и задач станет слишком много, он будет захлёбываться в задачах, очереди же равномерно распределят нагрузку и не дадут вам наговнокодить в попытке решить эту проблему, так как их можно распараллелить на несколько потоков.

Comments

[Сергей Гутовский]

При создании задания добавляете на момент его окончания задачу

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

Я использую Task Scheduler, ведь в каждом контроллере чекать истек ли срок у задания не ахти.
А в очереди, как я понимаю, добавляются те задания, срок у которых выйдет между работай Task Scheduler
Пример:
Проверка была в 12:59, следующая будет в 13:04( каждые 5 минут)
У задания срок истекает в 13:00 следовательно во время 1 проверки он еще не будет просрочен, а во время 2 проверки будет уже поздно.
Значит, во время первой проверки мы находим задания, у которых срок истекает через макс. 5 минут и их добавляем в очередь.

$date = Carbon::now()->format('Y-m-d H:i:s');
$tasks = Task::where('finished', false)->where('deadline', '<', $date)->get();
foreach ($tasks as $task) {
    $task->finish();
}
        
$date = Carbon::now()->addMinutes(5)->format('Y-m-d H:i:s');
$tasks = Task::where('finished', false)->where('deadline', '<', $date)->get();
FinishTasks::dispatch($tasks)->delay($date);

Щас пытаюсь это реализовать

[Дмитрий Евграфович]

Сергей Гутовский, я использую очереди в ларавел с драйвером database, задачу можно назначить на любое время, хоть через 10 минут, хоть через год. В каждом контроллере не надо чекать, да и вообще зачем в контроллере, это бессмысленное дублирование кода. Я делал нечто схожую задачу, проверку ставил в модели. Задача была не 1 в 1, но похожая. На недостатки выбранного вами подхода я уже указал. Кстати, в вашем подходе вам тоже лучше дополнительно добавить дополнительную проверку истекшего срока. На случай, если очередь заглохнет, вылетит демон, сокет в операционке заблокируется или ещё что-то.

[Сергей Гутовский]

Можете подсказать, как добавлять задачи с помощью database

$job = (new FinishTasks($task))->delay($deadline);
$this->dispatch($job);

или
Queue::later($deadline, new FinishTasks($task));
Таблица jobs остается пустой, что не так делаю?

[Дмитрий Евграфович]

Сергей Гутовский, драйвер database в конфиге queue.php выбрать (если там стоит sync как драйвер по-умолчаниюю), проверить файл самой задачи на реализацию интерфейса ShouldQueue и наличие трейтов Dispatchable, InteractsWithQueue, Queueable. Запуск кстати, можно выполнять через dispatch() хелпер без $this. Вроде бы это все условия, чтобы задачи в очередь добавлялись.

[JhaoDa]

Дмитрий Евграфович, драйвер database для разработки и пет-проектов, пока они маленькие. Для нормальной работы нужен beanstal/redis/etc. Кстати, beastalk позволяет удалять задания, правда, это происходит не совсем ларавел-вэй...

[JhaoDa]

Сергей Гутовский,

Вроде как задачи можно ставить задержкой на 10 минут, чуть больше

«чуть больше» это 15 минут и только для одного драйвера (в доке написано, какого именно). У остальных ограничений нет, насколько мне известно.

[Дмитрий Евграфович]

JhaoDa, они оба позволяют ставить любое время для запуска задачи и меняются на лету, если проект вырастет. Впрочем, вы сами это прекрасно знаете