ママリ抽選会の裏側〜CakePHPで排他処理を使って実装してみた〜

こんにちは。ママリアプリ開発チームでエンジニアをしております高橋です。

今日は3月1日よりリリースされているママリ抽選会の実装についてお話ししていきます。

ママリ抽選会とは

ママリポイントを使用して参加できる抽選会のことです。

ママリポイントとはアプリ内で回答をしたり、ベストアンサーをもらったりすると付与されるポイントのことです。ただ現状でポイントを使用する用途があまりなく、ユーザーからのたくさんのお声とコネヒトとしてポイントを活用してユーザーに感謝の気持ちを伝えたいという背景から今回の「ママリ抽選会」プロジェクトがスタートしました。

テーブル設計

まずは簡単にテーブル設計を説明します。

以下は今回新規で作成した抽選会に関わるデータベースのER図です。

前提として開催期間に対して賞品それぞれに最大在庫があります。

在庫管理をするだけなら履歴テーブルは必要なく商品テーブルの最大在庫数を減らしていくという方法もあります。

ですが以下の懸念点を考えて最大在庫は固定でデータベースに保存するようにしました。

本来の最大在庫がわからなくなる
抽選会の参加履歴画面などが仕様が出てきた時に対応できなくなる

テーブル設計についてはそこまで複雑なことはないので本題の内部の実装についてお話しして行きます。

排他処理

排他処理とは簡単に説明すると「ダブルブッキングしないように制御すること」です。

前提として履歴を登録する前に次の抽選処理が始めると残在庫に誤差が生まれてしまうので順番に抽選する必要があります。そこで排他処理を利用して正しく処理できるようにしました。

今回はテーブル全体ではなく行に対してロックをかけて実現しました。

SQLでは排他処理はこのように書きます。idが1のデータのみ行ロックされています。

select *
from table_name
where id = 1
for update; // 行ロック

CakePHPでは以下のように書くことができます。念の為キャッシュ削除をすると安心です。

$table->find()
    ->modifier('SQL_NO_CACHE')
    ->epilog('FOR UPDATE')
    ->first(); // 行ロック

実装の流れは以下のようになっています。

$user = $this->ユーザーテーブル->get($id);
try {
    $connection->begin();　// トランザクション開始
    $lottery = $this->抽選会テーブル->find('active')
                　　　　->contain(['賞品テーブル'])
                　　　　->modifier('SQL_NO_CACHE')
                　　　　->epilog('FOR UPDATE')　// 行ロック
                　　　　　->first();
    // 参加資格があるかバリデーションをする
    // 抽選をする
    $connection->commit(); // トランザクション終了
} catch (Exception $e) {
    $connection->rollback();
    throw new InternalErrorException($e->getMessage());
}