1

application/common.php

@@ -704,6 +704,36 @@ function checkCollectionState($id=''){
 }
 
 
+/**
+ * redis加锁
+ */
+function redisSetNx($id){
+    $redis = new \think\cache\driver\Redis();
+    $key = 'stock_'.$id;
+    $is_lock = $redis->setnx($key,time()+5);
+    if ($is_lock){
+        return true;
+    }else{
+        //加锁失败的情况下，判断锁是否已经存在，如果存在切已经过期，删除锁，重新加锁
+        $val = $redis->get($key);
+        if ($val && $val<time()){
+            $redis->del($key);
+        }
+        return $redis->setnx($key,time()+5);
+    }
+}
+
+/**
+ * 删除锁
+ */
+function DelRedisSetNx($id){
+    $redis = new \think\cache\driver\Redis();
+    $key = 'stock_'.$id;
+    $redis->del($key);
+}
+
+
+
 /***********************************************人脸识别*****************************************************************/
 
 /**

application/index/controller/Index.php

@@ -109,101 +109,109 @@ class Index extends Controller
         $hashCount = getLenCollection($id);
       //  if (!$hashCount || $hashCount<$num) $this->error('hash未铸造,无法购买');
 
-        $redis2 = new \think\cache\driver\Redis();
-        $max = $redis2->get('max_30');
-        if ($max>100){
-            $this->error('排队中...');
-        }
-        $redis2->Incr('max_30');
-
-        //先减掉库存
-        loseCollectionInventory($id,$num);
-        //先减掉抢购卡数量
-        loseMembercard($this->uid);
-        //先增加购买数量
-        IncrByCount($this->uid,$id,$num);
-
-
-        $com = true;
-        Db::startTrans();
-        try {
-            $order_no = get_order_sn();
-            $total_fee = bcmul($coll_info['price'],$num,2);
-            $order_int =[
-                'mid'           => $this->uid,
-                'c_id'          => $id,
-                'inventory'     => $coll_info['inventory'],
-                'order_no'      => $order_no,
-                'num'           => $num,
-                'pro_info'      => json_encode($coll_info),
-                'pay_type'      => $pay_type,
-                'pay_price'     => $total_fee
-            ];
-            Db::name('store_order2')->insert($order_int);
-            $body = '象寻购买藏品';
-            switch ($pay_type){
-                case 'wx':
-                    $config = retrunWxConfig();
-                    $total_fee = $total_fee * 100;
-                    $config['notify_url'] = $this->request->root(true).'/api/Pay/WxOrderNotify';
-                    $app = Factory::payment($config);
-
-                    $result = $app->order->unify([
-                        'body' => $body,
-                        'out_trade_no' => $order_no,
-                        'total_fee' => $total_fee,
-                        'trade_type' => 'APP', // 请对应换成你的支付方式对应的值类型
-                    ]);
-                    if ($result['return_code']=='SUCCESS'){
-                        $jssdk      =   $app->jssdk;
-                        $order1 = $jssdk->appConfig($result['prepay_id']);
-                        Db::name('store_order2')->where('order_no',$order_no)->update(['wx_order'=>json_encode($order1,true)]);
+//        $redis2 = new \think\cache\driver\Redis();
+//        $max = $redis2->get('max_30');
+//        if ($max>100){
+//            $this->error('排队中...');
+//        }
+//        $redis2->Incr('max_30');
+
+
+        if (redisSetNx($id)){
+            //先减掉库存
+            loseCollectionInventory($id,$num);
+            //先减掉抢购卡数量
+            loseMembercard($this->uid);
+            //先增加购买数量
+            IncrByCount($this->uid,$id,$num);
+
+            $com = true;
+            Db::startTrans();
+            try {
+                $order_no = get_order_sn();
+                $total_fee = bcmul($coll_info['price'],$num,2);
+                $order_int =[
+                    'mid'           => $this->uid,
+                    'c_id'          => $id,
+                    'inventory'     => $coll_info['inventory'],
+                    'order_no'      => $order_no,
+                    'num'           => $num,
+                    'pro_info'      => json_encode($coll_info),
+                    'pay_type'      => $pay_type,
+                    'pay_price'     => $total_fee
+                ];
+                Db::name('store_order2')->insert($order_int);
+                $body = '象寻购买藏品';
+                switch ($pay_type){
+                    case 'wx':
+                        $config = retrunWxConfig();
+                        $total_fee = $total_fee * 100;
+                        $config['notify_url'] = $this->request->root(true).'/api/Pay/WxOrderNotify';
+                        $app = Factory::payment($config);
+
+                        $result = $app->order->unify([
+                            'body' => $body,
+                            'out_trade_no' => $order_no,
+                            'total_fee' => $total_fee,
+                            'trade_type' => 'APP', // 请对应换成你的支付方式对应的值类型
+                        ]);
+                        if ($result['return_code']=='SUCCESS'){
+                            $jssdk      =   $app->jssdk;
+                            $order1 = $jssdk->appConfig($result['prepay_id']);
+                            Db::name('store_order2')->where('order_no',$order_no)->update(['wx_order'=>json_encode($order1,true)]);
+                            $retrun_data['order_no'] = $order_no;
+                            $retrun_data['pay'] = $order1;
+                            //减少数据库库存
+                            Db::name('store_collection')->where('id',$id)->setDec('now_inventory',$num);
+                            //减少用户抢购卡数量
+                            Db::name('store_member')->where('id',$this->uid)->setDec('snap_card');
+                            Db::commit();
+                        }else{
+                            $com=false;
+                            Db::rollback();
+                        }
+                        break;
+                    case 'zfb':
+                        $zfb = new AliPay();
+                        $notify_url = $this->request->root(true).'/api/Pay/alipayOrderNotify';//回调地址
+                        $order = $zfb->aliPay($body, $total_fee, $order_no, $notify_url);//调用支付宝支付的方法
                         $retrun_data['order_no'] = $order_no;
-                        $retrun_data['pay'] = $order1;
+                        $retrun_data['pay'] = $order;
                         //减少数据库库存
                         Db::name('store_collection')->where('id',$id)->setDec('now_inventory',$num);
                         //减少用户抢购卡数量
                         Db::name('store_member')->where('id',$this->uid)->setDec('snap_card');
                         Db::commit();
-                    }else{
-                        $com=false;
-                        Db::rollback();
-                    }
-                    break;
-                case 'zfb':
-                    $zfb = new AliPay();
-                    $notify_url = $this->request->root(true).'/api/Pay/alipayOrderNotify';//回调地址
-                    $order = $zfb->aliPay($body, $total_fee, $order_no, $notify_url);//调用支付宝支付的方法
-                    $retrun_data['order_no'] = $order_no;
-                    $retrun_data['pay'] = $order;
-                    //减少数据库库存
-                    Db::name('store_collection')->where('id',$id)->setDec('now_inventory',$num);
-                    //减少用户抢购卡数量
-                    Db::name('store_member')->where('id',$this->uid)->setDec('snap_card');
-                    Db::commit();
-                    break;
-            }
+                        break;
+                }
 
-        }catch (\Exception $e){
-            $com=false;
-            Db::rollback();
-        }
-        if ($com){
-            $redis2->Decr('max_30');
-            // $this->savetest($order_no);
-            $this->success('成功',$retrun_data);
+            }catch (\Exception $e){
+                $com=false;
+                Db::rollback();
+            }
+            if ($com){
+
+                 DelRedisSetNx($id);
+                //$redis2->Decr('max_30');
+                // $this->savetest($order_no);
+                $this->success('成功',$retrun_data);
+            }else{
+
+                // $redis2->Decr('max_30');
+                //加上库存
+                addCollectionInventory($id,$num);
+                //加上抢购卡数量
+                addMembercard($this->uid);
+                //减少用户购买数量
+                DecrByCount($this->uid,$id,$num);
+
+                $this->error('抢购失败，请稍后重试');
+            }
         }else{
+            $this->error('排队中...');
+        }
 
-            $redis2->Decr('max_30');
-            //加上库存
-            addCollectionInventory($id,$num);
-            //加上抢购卡数量
-            addMembercard($this->uid);
-            //减少用户购买数量
-            DecrByCount($this->uid,$id,$num);
 
-            $this->error('抢购失败，请稍后重试');
-        }
 
     }
 

thinkphp/library/think/cache/driver/Redis.php

@@ -343,6 +343,18 @@ class Redis extends Driver
         return	$this->handler->ltrim($key,$start,$end);
     }
 
+
+    /**
+     * 加锁
+     */
+    public function Setnx($key,$exptime){
+        return $this->handler->setnx($key,$exptime);
+    }
+
+    public function del($key){
+        return $this->handler->del($key);
+    }
+
     /**
      * 缓存标签
      * @access public