dev

core/framework/libraries/queue.php

@@ -14,15 +14,23 @@ class QueueClient
 
     public static function push($key, $value)
     {
-        if (!C('queue.open')) {
-            Logic('queue')->$key($value); //如果队列没打开，立即执行
-            return;
+        if (defined('USE_COROUTINE') && USE_COROUTINE && defined('COROUTINE_HOOK_TCP') && COROUTINE_HOOK_TCP) {
+            $queue_name = 'QUEUE_TABLE_1';
+            $ins = Cache::getInstance('cacheredis');
+            return $ins->lpush($queue_name, serialize([$key => $value]));
         }
+        else
+        {
+            if (!C('queue.open')) {
+                Logic('queue')->$key($value); //如果队列没打开，立即执行
+                return;
+            }
 
-        if (!is_object(self::$queuedb)) {
-            self::$queuedb = new QueueDB();
+            if (!is_object(self::$queuedb)) {
+                self::$queuedb = new QueueDB();
+            }
+            return self::$queuedb->push(serialize([$key=>$value]));
         }
-        return self::$queuedb->push(serialize([$key=>$value]));
     }
 
     public static function async_push($key, $value, $period_secs = 0)

helper/refill/RefillBase.php

@@ -163,7 +163,7 @@ class RefillBase
         Log::record("proc_notify pop_queue_order 2",Log::DEBUG);
         QueueClient::push("NotifyMerchantComplete", ['order_id' => $order_id,'manual' => false]);
         Log::record("proc_notify pop_queue_order 3",Log::DEBUG);
-        
+
         return true;
     }