ssdb恢复task。恢复自动取消订单。

app/Crontab/AutoCancelOrder.php

@@ -6,9 +6,9 @@ use App\Service\v3\Interfaces\OrderOnlineServiceInterface;
 use Hyperf\Crontab\Annotation\Crontab;
 use Hyperf\Di\Annotation\Inject;
 
-// /**
-//  * @Crontab(name="autocancelorder", rule="*\/1 * * * *", callback="execute", memo="自定取消15分钟过期订单")
-//  */
+/**
+ * @Crontab(name="autocancelorder", rule="*\/10 * * * * *", callback="execute", memo="自定取消15分钟过期订单")
+ */
 class AutoCancelOrder
 {
     /**

app/Libs/SimpleSSDB.php

@@ -26,7 +26,7 @@ class SSDBTimeoutException extends SSDBException
  */
 class SimpleSSDB extends SSDB
 {
-	function __construct($host, $port, $timeout_ms=2000){
+	function __construct($host, $port, $timeout_ms=10000){
 		parent::__construct($host, $port, $timeout_ms);
 		$this->easy();
 	}

app/Service/v3/Implementations/OrderOnlineService.php

@@ -683,8 +683,9 @@ class OrderOnlineService implements OrderOnlineServiceInterface
         try {
 
             $orderMains = OrderMain::query()
-                ->where(['state' => OrderState::UNPAID])
-                ->where('created_at', '<', time()-900)
+                ->where(['state' => OrderState::UNPAID, 'type' => OrderType::ONLINE])
+                ->where('created_at', '<', time()-600)
+                ->orderBy('created_at', 'asc')
                 ->limit(100)
                 ->get();
 

app/TaskWorker/SSDBTask.php

@@ -13,7 +13,9 @@ class SSDBTask
      */
     public $ss = null;
 
-
+    /**
+     * @Task
+     */
     public function exec($method,...$args)
     {
         $result = $this->client()->__call($method,$args);