composer

app/controller/IndexController.php

@@ -16,12 +16,13 @@ class IndexController
 {
     public function index(Request $request)
     {
+        return 1;
 //        Client::send('test', [], 0);
 
-        pushQueue(ActivitiesQueue::class, [
-            'userInfo' => 1,
-            'sourceUser' => 1
-        ], 1);
+//        pushQueue(ActivitiesQueue::class, [
+//            'userInfo' => 1,
+//            'sourceUser' => 1
+//        ], 1);
     }
 
     public function view(Request $request)

app/queue/redis/ActivitiesQueue.php

@@ -4,7 +4,7 @@ namespace app\queue\redis;
 
 use support\Log;
 use Webman\RedisQueue\Consumer;
-
+use app\api\model\Orders;
 /**
  * 奖项领取
  */
@@ -12,7 +12,7 @@ class ActivitiesQueue extends BaseQueue implements Consumer
 {
     public function run($data)
     {
-        Log::info("哈哈哈哈");
-//        Orders::activities($data['userInfo'], $data['sourceUser']);
+//        Log::info("哈哈哈哈");
+        Orders::activities($data['userInfo'], $data['sourceUser']);
     }
 }