超节损队列

application/api/controller/OrderSuperLoss.php

@@ -2099,10 +2099,17 @@ class OrderSuperLoss extends Api
             ->select();
 
         // 创建redis
-        $redis = new \Redis();
-        $redis->connect('127.0.0.1', 6379, 0);
-        $redis->auth('');
-        $redis->select(14);
+        $options = [
+            'host'       => '127.0.0.1',
+            'port'       => 6379,
+            'password'   => '',
+            'select'     => 14,
+            'timeout'    => 0,
+            'expire'     => 0,
+            'persistent' => false,
+            'prefix'     => '',
+        ];
+        $redis = new Redis($options);
 
         // 生成批次ID
         $batchId = 'batch_' . uniqid() . '_' . time();

application/job/OrderLossQueueWorker.php

@@ -24,7 +24,7 @@ class OrderLossQueueWorker
             'host'       => '127.0.0.1',
             'port'       => 6379,
             'password'   => '',
-            'select'     => 15,
+            'select'     => 14,
             'timeout'    => 0,
             'expire'     => 0,
             'persistent' => false,