ThinkPHP6 秒杀

<?php
namespace app\controller;

use app\BaseController;

class Seckill extends BaseController
{
    /**
     * 商品ID，测试需要
     *
     * @var int
     */
    protected $id;

    /**
     * Redis 实例
     *
     * @var \Predis\Client
     */
    protected $redis;

    /**
     * 库存 缓存key
     *
     * @var string
     */
    protected $stock_key;

    /**
     * 中签记录 缓存key
     *
     * @var string
     */
    protected $stock_get_key;

    /**
     * 配置信息，测试需要
     *
     * @var array
     */
    protected $config = [
        'start_time'    => '2022-05-10 22:00:00', // 开始时间
        'end_time'      => '2022-05-11 22:00:00', // 结束时间
    ];

    public function __construct()
    {
        $this->redis = new \Predis\Client('tcp://IP:端口', [
            'parameters' => [
                'password' => '密码',
            ],
        ]);

        $this->id = (int) input('id', 1);

        if($this->id < 1) {
            $this->id = 1;
        }

        $this->stock_key = sprintf('%s:stock:%d', 'Seckill', $this->id);

        $this->stock_get_key = sprintf('%s:stock_get:%d', 'Seckill', $this->id);
    }

    /**
     * 秒杀
     */
    public function index()
    {
        // 随机生成 UID
        $uid = random_int(1, 10000 * 10000);

        if(time() < strtotime($this->config['start_time'])) {
            return '秒杀未开启';
        }

        if(time() > strtotime($this->config['end_time'])) {
            return '秒杀已结束';
        }

        // 有 10% 的几率可以走正常的流程
        // if(random_int(1, 100) > 10) {
        //     return '重试';
        // }

        /**
         * 秒杀 LUA 脚本
         * -- 目前不考虑同一商品可以中多次情况
         *
         * 1. 判断是否存在中签记录，如果存在则结束
         * 2. 未中签过则减少商品库存（返回值低于 0 则说明已售罄）
         * 3. 追加中签记录
         */
        $eval = <<<LUA
-- 获取用户是否存在记录
local has_get = redis.call('hexists', KEYS[2], KEYS[3])

if(has_get == 1)
then
    -- 存在参与记录则无法重复参与
    return -1
end

-- 先减少库存
local stock = redis.call('decr', KEYS[1])

if(stock < 0)
then
    -- 已无库存
    return -2
end

-- 增加参与记录
local result = redis.call('hsetnx', KEYS[2], KEYS[3], redis.call('time')[1])

if(result == 1)
then
    -- 插入成功
    return 1
else
    -- 插入失败
    redis.call('incr', KEYS[1])
    return 0
end

-- 异常兜底
return -99
LUA;

        // 执行 LUA 脚本，正常返回值是 return 的值
        try {
            $value = (int) $this->redis->eval($eval, 3, $this->stock_key, $this->stock_get_key, $uid);
        } catch (\Exception $e) {
            return '系统异常';
        }

        if($value === -1) {
            return '无法重复参与';
        } else if($value === -2) {
            return '已售罄';
        } else if($value < 0) {
            return '系统异常';
        } else if($value === 0) {
            return '重试';
        }

        // 业务流程
        // 入库等等。

        return '领取成功';
    }

    /**
     * 初始化商品
     */
    public function init()
    {
        // 库存数
        $value = pow(2, 16);

        // 初始化库存数
        $this->redis->setnx($this->stock_key, $value);

        return '1';
    }
}