修改短信发送

This commit is contained in:
wucongxing 2023-04-27 15:21:46 +08:00
parent d9afeb8d23
commit aa30dc5e79

View File

@ -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']);
}