<?php
namespace appindexcontroller;
use thinkController;
use thinkDb;
use thinkcachedriverRedis;

class Miaosha extends Controller
{

 private $redis = null;
 private $cachekey = null; //緩存變量名
 private $basket = []; //私有數(shù)組，存放商品信息

 private $store = 50;

 /**
 * 購物車初始化，傳入用戶id
 */
 public function __construct()
 {
 parent::__construct();

 $this->redis = new Redis(); // 實(shí)例化
 $this->redis->connect("127.0.0.1","6379");
 $this->redis->auth("zxf123456");

 }

 /**
 * 秒殺初始化
 */
 public function Ms_init()
 {
 // 刪除緩存列表
 $this->redis->del($this->cachekey);

 $len = $this->redis->llen($this->cachekey);
 $count = $this->store - $len;

 for ($i=0; $i < $count; $i++) { 

  // 向庫存列表推進(jìn)50個,模擬50個商品庫存
  $this->redis->lpush($this->cachekey,1);
 }

 echo "庫存初始化完成:".$this->redis->llen($this->cachekey);
 }
 

 /**
 * 秒殺入口
 */
 public function index()
 {
 $id = 1; //商品編號
 
 if (empty($id)) {
  // 記錄失敗日志
  return $this->writeLog(0,"商品編號不存在"); 
 }

 // 計算庫存列表長度
 $count = $this->redis->llen($this->cachekey);

 // 先判斷庫存是否為0,為0秒殺失敗,不為0,則進(jìn)行先移除一個元素,再進(jìn)行數(shù)據(jù)庫操作
 if ($count == 0) { //庫存為0

  $this->writeLog(0,"庫存為0");
  echo "庫存為0";
  exit;

 }else{
  // 有庫存
  //先移除一個列表元素
  $this->redis->lpop($this->cachekey);

  $ordersn = $this->build_order_no(); //生成訂單
  $uid = rand(0,9999); //隨機(jī)生成用戶id
  $status = 1;
  // 再進(jìn)行數(shù)據(jù)庫操作
  $data = Db::table("ab_goods")->field("count,amount")->where("id",$id)->find(); //查找商品

  if (!$data) {
  return $this->writeLog(0,"該商品不存在");
  }

  $insert_data = [
  "order_sn" => $ordersn,
  "user_id" => $uid,
  "goods_id" => $id,
  "price" => $data["amount"],
  "status" => $status,
  "addtime" => date("Y-m-d H:i:s")
  ];

  // 訂單入庫
  $result = Db::table("ab_order")->insert($insert_data);
  // 自動減少一個庫存
  $res = Db::table("ab_goods")->where("id",$id)->setDec("count");

  if ($res) {
  echo "第".$count."件秒殺成功";
  $this->writeLog(1,"秒殺成功");
  }else{
  echo "第".$count."件秒殺失敗";
  $this->writeLog(0,"秒殺失敗");
  }
 }
 }

 /**
 * 生成訂單號
 */
 public function build_order_no()
 {
 return date("ymd").substr(implode(NULL, array_map("ord", str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
 }

 /**
 * 生成日志 1成功 0失敗
 */
 public function writeLog($status = 1,$msg)
 {
 $data["count"] = 1;
 $data["status"] = $status;
 $data["addtime"] = date("Y-m-d H:i:s");
 $data["msg"] = $msg;
 return Db::table("ab_log")->insertGetId($data);
 }

}

public function sqlMs()
 {
 $id = 1; //商品編號

 $count = 50;
 $ordersn = $this->build_order_no(); //生成訂單
 $uid = rand(0,9999); //隨機(jī)生成用戶id
 $status = 1;
 // 再進(jìn)行數(shù)據(jù)庫操作
 $data = Db::table("ab_goods")->field("count,amount")->where("id",$id)->find(); //查找商品

 // 查詢還剩多少庫存
 $rs = Db::table("ab_goods")->where("id",$id)->value("count");
 if ($rs <= 0) {
  
  $this->writeLog(0,"庫存為0");
 }else{

  $insert_data = [
  "order_sn" => $ordersn,
  "user_id" => $uid,
  "goods_id" => $id,
  "price" => $data["amount"],
  "status" => $status,
  "addtime" => date("Y-m-d H:i:s")
  ];

  // 訂單入庫
  $result = Db::table("ab_order")->insert($insert_data);
  // 自動減少一個庫存
  $res = Db::table("ab_goods")->where("id",$id)->setDec("count");

  if ($res) {
  echo "第".$data["count"]."件秒殺成功";
  $this->writeLog(1,"秒殺成功");
  }else{
  echo "第".$data["count"]."件秒殺失敗";
  $this->writeLog(0,"秒殺失敗");
  }
 }
 }