TP5 は Redis を使用して e コマースのフラッシュ セールを処理します

この記事では、ThinkPHP が Redis を使用して電子商取引フラッシュ セールを実装する方法を紹介します。一定の参考価値があります。ThinkPHP を学習している友人の役に立てば幸いです。

TP5 は Redis を使用して e-commerce フラッシュ セールを処理します

1. まず、必要な Redis クラス ライブラリ ファイルを作成します。 TP5 のラッシュセールアクティビティのコードは次のとおりです:

<php
    namespace app\base\service;

    use mikkle\tp_redis\RedisHashInfoBase;
 
    use think\Exception;
 
    class ScheduleDetail extends RedisHashInfoBase
 
    {
 
        protected $table="gopar_schedule_detail"; //数据表的
 
        protected $pk = "id"; //数据表的主键
 
        public function _initialize()
 
        {
 
            //判断数据存在 并设置检查周期10分钟
 
            if (!$this->checkLock("dataExists") && !$this->checkTableDataExists()){
 
                throw new Exception("相关产品数据不存在");
 
            }else{
 
                //设置检查锁10分钟
 
                $this->setLock("dataExists",600);
 
            }
 
            //如果数据不存在 初始化读取数据
 
            if (!$this->checkExists()){
 
                $this->initTableData();
 
            }
 
        }
 

        public function getScheduleCenter()
 
        {
 
            return Schedule::instance( $this->getInfoFieldValue("schedule_id"));
 
        }

        public function __destruct()
 
        {
 
            //设置15天自动回收redis
 
            $this->setExpire((int);
 
$this>getScheduleCenter()->getInfoFieldValue("end_time")+3600*24*15);
 
        }
 
    }

2. サービス層またはコントローラーでラッシュ購入ロジックを処理します。コードは次のとおりです:

public function index($data=["user_id"=>1,"ticket_detail_id"=>1,"buy_num"=>1]){
 
    try {
 
        //检测数据存在
 
        if (!$this->checkArrayValueEmpty($data,["user_id","ticket_detail_id","buy_num"])){
 
            throw new Exception($this->error);
 
        }
 
        $user_id= $data["user_id"] ; //用户Id
 
        $ticket_detail_id = $data["ticket_detail_id"] ; //产品Id
 
        $buy_num = $data["buy_num"] ; //购买数量
 
        $infoCenter= ScheduleDetail::instance( $ticket_detail_id );
 
        $scheduleDetailInfo =$infoCenter->getInfoList();
 
        //修改数据库后 需要运行initTableData()方法重新初始化 推荐写到Hook里
 
     // $infoCenter->initTableData();
 
        if ( $infoCenter->getInfoFieldValue( "hot_schedule")){
 
            //热门抢购随机过滤随机过滤
 
            if (!in_array(rand(100, 200) % 11, [1, 3, 5, 7, 9])) {
 
                throw new Exception("抢票人数众多 ,你被挤出抢购队伍,还有余票,请重新再抢");
 
            };
 
        }
 
        // 这里判断 购买数量和销售日期 不符合就 throw new Exception
 
        if (!true){
 
            throw new Exception("这里写不符合原因");
 
        }
 
        if (((int)$infoCenter->getInfoFieldValue("{$user_id}_num")+$buy_num)>$scheduleDetailInfo["limit_num"] ){
 
            throw new Exception("你超过最大购买数量");
 
        }
 
        if ($infoCenter->setInfoFieldIncre("pay_num",$buy_num) >$scheduleDetailInfo["limit_num"] ){
 
            //
 
            $infoCenter->setInfoFieldIncre("pay_num", -$buy_num);
 
            throw new Exception("对不起,票已经卖光了!");
 
        }
 
        //这里写主逻辑 启用事务功能创建订单
 
        //事务参见下节源码
 
        //升级已销售数量
 
        $infoCenter->updateTableData(["pay_num"]);
 
        //在这里推荐埋钩子 处理订单完成的后续事情
 
         //返回结果
 
    } catch (Exception $e) {
 
        Log::error($e->getMessage());
 
        return ShowCode::jsonCodeWithoutData(1008, $e->getMessage());
 
    }
 
}
 
}

処理ロジック内、購入リクエストのランダムに削除された部分を使用して、急ぎの購入アクティビティを確実にスムーズに完了させることができます

もちろん、同様の方法を使用してフロントエンド リクエストを同時にフィルタリングすることもできます

タイミング キューを参照して、注文が処理されたかどうかを判断し、残りの在庫を調整できます

(推奨チュートリアル: thinkphp チュートリアル)

以上がTP5 は Redis を使用して e コマースのフラッシュ セールを処理しますの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。