新增正是环境提现限制,修改队列变量获取方式
This commit is contained in:
@@ -386,6 +386,8 @@ class MessagePush extends BaseService
|
||||
return;
|
||||
}
|
||||
|
||||
$producer = ApplicationContext::getContainer()->get(Producer::class);
|
||||
|
||||
// 站内
|
||||
// 服务消息
|
||||
$inquiry_type_string = inquiryTypeToString($this->order_inquiry['inquiry_type']);
|
||||
@@ -410,7 +412,6 @@ class MessagePush extends BaseService
|
||||
$data['button_type'] = 4; // 订单详情
|
||||
|
||||
$message = new SendStationMessageProducer($data);
|
||||
$producer = ApplicationContext::getContainer()->get(Producer::class);
|
||||
$result = $producer->produce($message);
|
||||
if (!$result) {
|
||||
Log::getInstance("MessagePush")->error("错误:加入推送队列失败" . json_encode($data,JSON_UNESCAPED_UNICODE));
|
||||
@@ -442,7 +443,6 @@ class MessagePush extends BaseService
|
||||
$data['sms_data'] = array();
|
||||
|
||||
$message = new SendSubMessageProducer($data);
|
||||
$producer = ApplicationContext::getContainer()->get(Producer::class);
|
||||
$result = $producer->produce($message);
|
||||
if (!$result) {
|
||||
Log::getInstance("MessagePush")->error("错误:加入推送队列失败" . json_encode($data,JSON_UNESCAPED_UNICODE));
|
||||
|
||||
Reference in New Issue
Block a user