修改延迟队列时间
This commit is contained in:
@@ -318,7 +318,7 @@ class InquiryService extends BaseService
|
||||
$data['order_type'] = 1;
|
||||
|
||||
$message = new CancelUnpayOrdersDelayDirectProducer($data);
|
||||
$message->setDelayMs(1000 * 60 * 5);
|
||||
$message->setDelayMs(1000 * 60 * 30);
|
||||
$producer = $this->container->get(Producer::class);
|
||||
$res = $producer->produce($message);
|
||||
if (!$res) {
|
||||
@@ -332,7 +332,7 @@ class InquiryService extends BaseService
|
||||
$data = array();
|
||||
$data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
|
||||
$message = new CancelUnInquiryOrdersDelayDirectProducer($data);
|
||||
$message->setDelayMs(1000 * 60 * 5);
|
||||
$message->setDelayMs(1000 * 60 * 60 * 24);
|
||||
$producer = $this->container->get(Producer::class);
|
||||
$res = $producer->produce($message);
|
||||
if (!$res) {
|
||||
@@ -920,7 +920,7 @@ class InquiryService extends BaseService
|
||||
$data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
|
||||
|
||||
$message = new AutoFinishInquiryDelayDirectProducer($data);
|
||||
$message->setDelayMs(1000 * 60 * 1);
|
||||
$message->setDelayMs(1000 * 60 * 60 * 24 * 3);
|
||||
$producer = $this->container->get(Producer::class);
|
||||
$res = $producer->produce($message);
|
||||
if (!$res) {
|
||||
|
||||
Reference in New Issue
Block a user