1

app/Http/Controllers/API/Redis/CheckArrivalCl.php

@@ -10,12 +10,11 @@ class CheckArrivalCl
 {
 {
     public function check($hash, $price, $address, $to)
     public function check($hash, $price, $address, $to)
     {
     {
-        Log::error('执行异步任务');
         # 添加订单后--查询是否到账--最多检测20次
         # 添加订单后--查询是否到账--最多检测20次
         for ($i = 1; $i <= 10; $i++) {
         for ($i = 1; $i <= 10; $i++) {
             $type = self::IntervalCheck($hash, $price, $address, $to);
             $type = self::IntervalCheck($hash, $price, $address, $to);
-            Log::error($type);
             if ($type) {
             if ($type) {
+                Log::error('购买成功');
                 break;
                 break;
             }
             }
             sleep(1);
             sleep(1);
@@ -32,7 +31,6 @@ public function IntervalCheck($hash, $price, $address, $to)
         if ($item->status == 1) {
         if ($item->status == 1) {
             return true;
             return true;
         }
         }
-        Log::error('插入redis');
         # 获取交易
         # 获取交易
         $obj = (object)[];
         $obj = (object)[];
         $obj->hash = $hash;
         $obj->hash = $hash;

app/Jobs/CheckArrival.php

@@ -25,11 +25,11 @@ class CheckArrival implements ShouldQueue
      */
      */
     public function __construct(string $hash, int $price, string $address, string $to)
     public function __construct(string $hash, int $price, string $address, string $to)
     {
     {
+        $this->queue = "{check-arrival}";
         $this->hash = $hash;
         $this->hash = $hash;
         $this->price = $price;
         $this->price = $price;
         $this->address = $address;
         $this->address = $address;
         $this->to = $to;
         $this->to = $to;
-        $this->queue = "{check-check-arrival}";
     }
     }
 
 
     /**
     /**