✨ feat(防止超卖):

防止超卖

application/api/controller/Secondary.php

@@ -3,12 +3,14 @@
 
 namespace app\api\controller;
 
-use Alipay\EasySDK\Kernel\Util\ResponseChecker;
-use app\common\library\AliPay;
-use app\common\library\Shande;
+use think\Db;
 use EasyWeChat\Factory;
 use think\cache\driver\Redis;
-use think\Db;
+use app\common\library\AliPay;
+use app\common\library\Shande;
+use app\api\service\CacheService;
+use app\index\enum\SecondaryEnum;
+use Alipay\EasySDK\Kernel\Util\ResponseChecker;
 use function EasyWeChat\Kernel\Support\get_client_ip;
 
 
@@ -255,6 +257,7 @@ class Secondary extends Base
         $info = Db::name('store_order_info')->where('id',$id)->find();
         if (!$info) $this->error('藏品不存在');
         if ($info['resale_status']==3) $this->error('藏品已出售');
+
         if ($info['resale_status']==1) $this->error('藏品已撤销出售');
         if ($info['mid']==$this->uid) $this->error('不能购买自己出售的藏品');
 
@@ -268,6 +271,14 @@ class Secondary extends Base
         $count = Db::name('store_order_info_order')->where('info_id',$id)->where('status',0)->count();
         if ($count) $this->error('支付中，无法下单');
 
+        // 拿锁，防止超卖
+        $lockKey = SecondaryEnum::CREATE_ORDER_KEY;
+        $lock = CacheService::incr($lockKey);
+        if ($lock > 1) {//没有拿到锁
+            $this->error('藏品已出售');
+        }
+        CacheService::expire($lockKey, 5);
+
         $service_fee = getConfigValue('service_fee');
         $royalties = getConfigValue('royalties');
         $com = true;

application/api/service/BaseService.php

@@ -0,0 +1,9 @@
+<?php
+
+namespace app\api\service;
+
+
+class BaseService
+{
+
+}

application/api/service/CacheService.php

@@ -0,0 +1,64 @@
+<?php
+
+namespace app\api\service;
+
+use think\cache\driver\Redis;
+
+
+class CacheService
+{
+    /**
+     * redis 实例
+     *
+     * @var think\cache\driver\Redis $redis
+     */
+    private $redis;
+    public function __construct()
+    {
+        $this->redis = new Redis([ 'select'=> 2]);
+    }
+
+    /**
+     * User: YunXi
+     * Date: 2022-05-21 
+     * Time: 22:00 
+     * Notes: 设置自增
+     *
+     * @param [type] $name
+     * @param integer $step
+     * @return integer
+     */
+    public static function incr($name, $step = 1) :int
+    {
+        return (int) self::$redis->inc($name, $step);
+    }
+
+    /**
+     * User: YunXi
+     * Date: 2022-05-21 
+     * Time: 22:00 
+     * Notes: 设置过期时间
+     *
+     * @param [type] $key
+     * @param [type] $ttl
+     * @return void
+     */
+    public static function expire($key,$ttl) 
+    {        
+        return self::$redis->expire($key,$ttl);
+    }
+
+    /**
+     * User: YunXi
+     * Date: 2022-05-21 
+     * Time: 22:03 
+     * Notes: 删除锁
+     *
+     * @param string $key
+     * @return void
+     */
+    public static function del($key) 
+    {
+        return self::$redis->del($key);
+    }
+}

application/enum/SecondaryEnum.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace app\index\enum;
+
+class SecondaryEnum 
+{
+    const CREATE_ORDER_KEY = 'secondary:create_order';
+}