diff --git a/app/Amqp/Consumer/SendSmsMessageConsumer.php b/app/Amqp/Consumer/SendSmsMessageConsumer.php index 28c50b7..25b1424 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;// 销毁 @@ -60,7 +60,7 @@ class SendSmsMessageConsumer extends ConsumerMessage } } - if ($data['phone'] == "18513026297" || $data['phone'] == "13301296315" || $data['phone'] == "1821234167"){ + if ($data['phone'] == "18513026297" || $data['phone'] == "13301296315" || $data['phone'] == "18221234167" || $data['phone'] == "13419527489"){ // 发送短信 Dysms::sendSms($data['phone'],$data['template_param'],$data['template_code'],$data['scene_desc']); }