Как решить проблему состояния гонки в API Yii2?

Question

[Mark]

Проблема: При отправке множества запросов одновременно на метод API - создания заказа возникает некорректная работа: создается заказов больше, чем сумма на балансе. Фактически проблема связана с "Состоянием гонки".

Основные действия метода

1. Валидация данных, в том числе баланса.
2. Выполнение коммерческого действия.
3. Создание заказа.
4. Списание баланса.
Обернуто в транзакции.

Пример: у пользователя баланс 2200 поинтов. Шлем запросы, и на момент когда баланс становится нулевым, сумма заказов превышает 3400 поинтов.

Вопросы:
1. Как решить проблему "Состоянии гонки" в API Yii2?
2. Разве "блокировка сессий PHP" не служит для предотвращения такого поведения? Или же это нарушение принципа REST об "Отсутствии состояния" и поэтому она не фигурирует в API модуле?

Comments

[Decadal]

по идее ваш вопрос не связан с фреймворком, а связан с базой данных.
Почитайте про блокировку таблиц на примере postgres
https://postgrespro.ru/docs/postgrespro/9.5/sql-lock
на вскидку - попробуйте применить LOCK TABLE your table IN SHARE MODE или что-то альтернативное для вашей БД

[Mark]

Decadal, для связи с БД используется ActiveRecord от Yii2. БД: MySQL. Статью прочёл, совместно с Блокировки в MySQL.
Но смутно понял: Данный механизм блокирует всю таблицу на момент работы с запросом или же конкретную запись?

[Дмитрий]

Вечер добрый.

1. Валидация данных, в том числе баланса.

Как баланс валидируете?

Шлем запросы, и на момент когда баланс становится нулевым, сумма заказов превышает 3400 поинтов.

Как обрабатываете запросы?

Answer 1

[Lander]

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

Comments

[Mark]

Транзакции для операции использую. Могу приложить код, если необходимо наглядно оценить.

Answer 2

[LAV45]

Используйте `select for update` для вашей базы данных.
Таким образом вы сможете SELECT-ом заблокировать доступ к данным и спокойно выполнить UPDATE

$sql = Wallet::find()
  ->where(['id' => $id])
  ->createCommand()
  ->getRawSql();

/** @var Wallet $model */
$model = Wallet::findBySql($sql . ' FOR UPDATE')->one();
$model->amount += $amount;
$model->save(false);