diff --git a/app/Amqp/Consumer/SendSmsMessageConsumer.php b/app/Amqp/Consumer/SendSmsMessageConsumer.php index dfa5565..28c50b7 100644 --- a/app/Amqp/Consumer/SendSmsMessageConsumer.php +++ b/app/Amqp/Consumer/SendSmsMessageConsumer.php @@ -33,7 +33,7 @@ class SendSmsMessageConsumer extends ConsumerMessage public function consumeMessage($data, AMQPMessage $message): string { Log::getInstance()->error("开始执行 短信推送 队列:" . json_encode($data, JSON_UNESCAPED_UNICODE)); - + dump($data); if (!isset($data['template_code']) || !isset($data['template_param'])){ Log::getInstance()->error("短信推送失败:发送参数错误"); return Result::DROP;// 销毁 @@ -41,6 +41,7 @@ class SendSmsMessageConsumer extends ConsumerMessage // 验证发送参数 $res = $this->checkTemplateParam($data['template_code'],$data['template_param']); + if (!$res){ Log::getInstance()->error("短信推送失败:发送参数错误"); return Result::DROP;// 销毁 @@ -97,6 +98,7 @@ class SendSmsMessageConsumer extends ConsumerMessage if (!isset($template_param['name'])) { return false; } + break; case 'SMS_271905266': // 医师还未接诊 if (!isset($template_param['name']) || !isset($template_param['type'])) { @@ -187,7 +189,6 @@ class SendSmsMessageConsumer extends ConsumerMessage default: // 非法模版 return false; - break; } return true; diff --git a/app/Controller/TestController.php b/app/Controller/TestController.php index 5d04530..e85086c 100644 --- a/app/Controller/TestController.php +++ b/app/Controller/TestController.php @@ -7,6 +7,7 @@ use App\Amqp\Producer\AssignDoctorProducer; use App\Amqp\Producer\AutoCompleteInquiryDelayDirectProducer; use App\Amqp\Producer\AutoFinishInquiryDelayDirectProducer; use App\Amqp\Producer\CancelUnpayOrdersDelayDirectProducer; +use App\Amqp\Producer\SendSmsMessageProducer; use App\Constants\HttpEnumCode; use App\Exception\BusinessException; use App\Model\DoctorInquiryTime; @@ -326,13 +327,22 @@ class TestController extends AbstractController } public function test_15(){ + // 短信 $data = array(); - $data['order_inquiry_id'] = 1; + $data['template_code'] = "SMS_271540920"; + $data['scene_desc'] = "处方审核通过"; + $data['phone'] = "18221234167"; - $message = new AssignDoctorDelayDirectProducer($data); - $message->setDelayMs(1000 * 10); - $producer = $this->container->get(Producer::class); - $res = $producer->produce($message); + $template_param = array(); + $template_param['name'] = "吴医生"; + $data['template_param'] = $template_param; + + $message = new SendSmsMessageProducer($data); + $producer = ApplicationContext::getContainer()->get(Producer::class); + $result = $producer->produce($message); + if (!$result) { + Log::getInstance("MessagePush")->error("错误:加入推送队列失败" . json_encode($data,JSON_UNESCAPED_UNICODE)); + } } } \ No newline at end of file