切换redis_queue

app/Console/Commands/Test.php

@@ -60,7 +60,7 @@ class Test extends Command
 
         // 回传业务
         $job = new QappTikTokUser($tikTokRegisterRequest);
-        dispatch($job->onConnection('rabbitmq')->onQueue('qapp_tiktok_user_register_queue'));
+        dispatch($job->onConnection('redis_queue')->onQueue('{qapp_tiktok_user_register_queue}'));
         dd('success');
 
         $sign      = 'd1192936959b3c79be1e1582f7b7c27f';

app/Http/Controllers/QuickApp/Book/ChapterController.php

@@ -375,7 +375,7 @@ class ChapterController extends BaseController
         $is_next_day = date('Y-m-d', strtotime($this->user_info->created_at)) == date('Y-m-d', strtotime('-1 days'));
         if ($is_next_day) {
             $job = new UserRententionJob($this->uid, now(), $this->user_info->created_at);
-            dispatch($job)->onConnection('rabbitmq')->onQueue('user_rentention_queue');
+            dispatch($job)->onConnection('redis_queue')->onQueue('{user_rentention_queue}');
         }
         //自定义vip章节
         //$vip_sequence = Redis::hget('channel:chapterfee:setting:' . $this->distribution_channel_id, $bid);

app/Jobs/Push/NewUserPushMsgDelay.php

@@ -58,7 +58,7 @@ class NewUserPushMsgDelay implements ShouldQueue
         if ($tasks) {
             foreach ($tasks as $task) {
                 $job = new NewUserPushMsg($this->uid, $task);
-                dispatch($job)->onConnection('rabbitmq')->onQueue('new_user_push_msg')->delay($task->time_delay);
+                dispatch($job)->onConnection('redis_queue')->onQueue('{new_user_push_msg}')->delay($task->time_delay);
                 myLog('new_user_push_msg')->info("task_id:{$task->id}; uid: {$this->uid}");
             }
         }

app/Modules/Trade/Pay/OrderPaySuccess.php

@@ -42,7 +42,7 @@ EOF;
             try {
                 //添加异步任务队列
                 $job = new QappOrder($trade_no);
-                dispatch($job->onConnection('redis')->delay(5)->onQueue('{qapp_order_pay_success}'));
+                dispatch($job->onConnection('redis_queue')->delay(5)->onQueue('{qapp_order_pay_success}'));
             } catch (Exception $e) {
                 sendNotice($e->getMessage());
             }

app/Modules/Trade/Pay/PaySuccessAbstract.php

@@ -114,9 +114,9 @@ abstract class PaySuccessAbstract
         $callback_type = getProp($quickSendOrder, 'callback_type');
         if ($callback_type == 'cycle_report') {
             $cycjob = new CycleCallBack($this->order->trade_no);
-            dispatch($cycjob->onConnection('redis')->onQueue('{qapp_tiktok_cycle_user_charge_queue}'));
+            dispatch($cycjob->onConnection('redis_queue')->onQueue('{qapp_tiktok_cycle_user_charge_queue}'));
         }else{
-            dispatch($job->onConnection('rabbitmq')->onQueue('qapp_tiktok_user_charge_queue'));
+            dispatch($job->onConnection('redis_queue')->onQueue('{qapp_tiktok_user_charge_queue}'));
         }
 
         // 同步数据

app/Modules/User/Services/QappUserService.php

@@ -267,7 +267,7 @@ class QappUserService
             $start = time();
             // 回传业务
             $job = new QappTikTokUser($tikTokRegisterRequest);
-            dispatch($job->onConnection('redis')->onQueue('{qapp_tiktok_user_register_queue}'));
+            dispatch($job->onConnection('redis_queue')->onQueue('{qapp_tiktok_user_register_queue}'));
             $time = time() - $start;
             if ($time >= 1 ){
                 myLog('mq-put-timeout')->info("注册qapp_tiktok_user_register_queue-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/QappUserService.php 270行");
@@ -276,7 +276,7 @@ class QappUserService
             UserTaskService::addUserTaskQueue($user->id, BaseTask::register, UserTaskService::add_trigger);
 
             $job = new NewUserPushMsgDelay($user->id);
-            dispatch($job->onConnection('redis')->onQueue('{new_user_push_msg}'));
+            dispatch($job->onConnection('redis_queue')->onQueue('{new_user_push_msg}'));
             $time = time() - $start;
             if ($time >= 1 ){
                 myLog('mq-put-timeout')->info("注册new_user_push_msg-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/QappUserService.php 279行");

app/Modules/UserTask/Services/UserTaskService.php

@@ -89,7 +89,7 @@ class UserTaskService
     public static function addUserTaskQueue(int $uid, string $type, string $trigger_type)
     {
         $job = new UserTaskJob($uid, $type, $trigger_type);
-        dispatch($job)->onConnection('redis')->onQueue('{qapp_user_task_queue}');
+        dispatch($job)->onConnection('redis_queue')->onQueue('{qapp_user_task_queue}');
     }
 
     /**