完成
This commit is contained in:
@@ -76,7 +76,7 @@ class ApplySmsTemp extends Command
|
|||||||
$data = $msg->body;
|
$data = $msg->body;
|
||||||
Log::info('MQ收到消息[申请新短信模版/营销短信发送/微信模版消息]--->' . $data . "\n");
|
Log::info('MQ收到消息[申请新短信模版/营销短信发送/微信模版消息]--->' . $data . "\n");
|
||||||
$arr = explode(',', $data);
|
$arr = explode(',', $data);
|
||||||
if(is_array($arr)) {
|
if(isset($arr[2])) {
|
||||||
$type = $arr[2];
|
$type = $arr[2];
|
||||||
if($type == 'applySmsTemp') {
|
if($type == 'applySmsTemp') {
|
||||||
// 发给队列 短信模版审核
|
// 发给队列 短信模版审核
|
||||||
@@ -90,7 +90,6 @@ class ApplySmsTemp extends Command
|
|||||||
}
|
}
|
||||||
}else {
|
}else {
|
||||||
Log::info('MQ收到消息[申请新短信模版/营销短信发送/微信模版消息]格式错误');
|
Log::info('MQ收到消息[申请新短信模版/营销短信发送/微信模版消息]格式错误');
|
||||||
return false;
|
|
||||||
}
|
}
|
||||||
$msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
|
$msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
|
||||||
};
|
};
|
||||||
|
|||||||
Reference in New Issue
Block a user