gdxz/hospital-applets-api
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改短信发送

Browse Source
This commit is contained in:
wucongxing 2023-04-27 15:05:35 +08:00
parent 0bbbc0ef83
commit d9afeb8d23
2 changed files with 18 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
app/Amqp/Consumer/SendSmsMessageConsumer.php
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;// 销毁
@ -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;

20
app/Controller/TestController.php
View File

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