TP5 utilise Redis pour gérer les ventes flash du commerce électronique

Cet article présente comment ThinkPHP utilise Redis pour mettre en œuvre les ventes flash du commerce électronique. Il a une certaine valeur de référence. J'espère qu'il sera utile aux amis qui apprennent ThinkPHP !

TP5 utilise Redis pour gérer les ventes flash du commerce électronique

1 Créez d'abord le fichier de bibliothèque de classes Redis requis pour le rush. activité de vente dans TP5, le code est le suivant :

<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. Traitez la logique d'achat précipité dans la couche de service ou le contrôleur, le code est le suivant :

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());
 
    }
 
}
 
}

Dans la logique de traitement, vous pouvez utiliser une partie supprimée au hasard de la demande d'achat pour garantir que l'activité d'achat urgente se termine en douceur

Bien sûr, vous pouvez également utiliser des méthodes de filtrage similaires dans les demandes frontales en même temps

Vous peut se référer à la file d'attente pour déterminer si la commande a été traitée et calibrer l'inventaire restant

(tutoriel recommandé : tutoriel thinkphp)

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!