增加队列超时执行日志

app/Modules/User/Services/QappUserService.php

@@ -264,16 +264,23 @@ class QappUserService
             $tikTokRegisterRequest->register_time = $user->created_at->format('Y-m-d H:i:s');
             $tikTokRegisterRequest->send_order_id = $data['send_order_id'];
             myLog('qapp_register')->info('', compact('tikTokRegisterRequest'));
-
+            $start = time();
             // 回传业务
             $job = new QappTikTokUser($tikTokRegisterRequest);
             dispatch($job->onConnection('rabbitmq')->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行");
+            }
+            $start = time();
             UserTaskService::addUserTaskQueue($user->id, BaseTask::register, UserTaskService::add_trigger);
 
             $job = new NewUserPushMsgDelay($user->id);
             dispatch($job->onConnection('rabbitmq')->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行");
+            }
             // 同步数据
             $user->channel_id = $user->distribution_channel_id;
             // ReportService::reportRegister($user); // 取消上报

app/Modules/User/Services/UserService.php

@@ -59,13 +59,7 @@ class UserService
     {
         $key = "last_add_desktop_status";
         $last_status = Redis::hget($key,$uid);
-        $time = 2;
-        sendNotice("测试勿管-加桌队列-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/UserService.php-qappAddDesktop方法 111行");
-        echo "<pre><hr>";
-        var_export("测试勿管-加桌队列-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/UserService.php-qappAddDesktop方法 111行");
-        echo  "<hr>";
-        die();
-        return ;
+
         if ($last_status != NULL  && $last_status == $status){
             return false;
         }
@@ -80,7 +74,7 @@ class UserService
             UserTaskService::addUserTaskQueue($uid, BaseTask::add_desk, UserTaskService::add_trigger);
             $time = time() - $start;
             if ($time >= 1 ){
-                sendNotice("加桌任务队列-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/UserService.php-qappAddDesktop方法 74行");
+                myLog('mq-put-timeout')->info("加桌任务队列-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/UserService.php-qappAddDesktop方法 74行");
             }
         }
 
@@ -94,7 +88,7 @@ class UserService
                 dispatch($job)->onConnection('rabbitmq')->onQueue('qapp_user_add_desk')->delay(now()->addMinutes(3));
                 $time = time() - $start;
                 if ($time >= 1 ){
-                    sendNotice("加桌队列-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/UserService.php-qappAddDesktop方法 88行");
+                    myLog('mq-put-timeout')->info("加桌队列-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/UserService.php-qappAddDesktop方法 88行");
                 }
             }
             //第一次加桌 没有任何记录，加桌状态为0
@@ -117,7 +111,7 @@ class UserService
                 dispatch($job)->onConnection('rabbitmq')->onQueue('qapp_user_add_desk')->delay(now()->addMinutes(3));
                 $time = time() - $start;
                 if ($time >= 1 ){
-                    sendNotice("加桌队列-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/UserService.php-qappAddDesktop方法 111行");
+                    myLog('mq-put-timeout')->info("加桌队列-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/UserService.php-qappAddDesktop方法 111行");
                 }
                 return false;
             }