TP5使用Redis處理電商秒殺

<php>checkLock("dataExists")?&amp;&amp;?!$this-&gt;checkTableDataExists()){ ? ????????????????throw?new?Exception("相關產品數據不存在"); ? ????????????}else{ ? ????????????????//設置檢查鎖10分鐘 ? ????????????????$this-&gt;setLock("dataExists",600); ? ????????????} ? ????????????//如果數據不存在?初始化讀取數據 ? ????????????if?(!$this-&gt;checkExists()){ ? ????????????????$this-&gt;initTableData(); ? ????????????} ? ????????} ?  ????????public?function?getScheduleCenter() ? ????????{ ? ????????????return?Schedule::instance(?$this-&gt;getInfoFieldValue("schedule_id")); ? ????????}  ????????public?function?__destruct() ? ????????{ ? ????????????//設置15天自動回收redis ? ????????????$this-&gt;setExpire((int); ? $this&gt;getScheduleCenter()-&gt;getInfoFieldValue("end_time")+3600*24*15); ? ????????} ? ????}</php>

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