临时测试自动完成队列

This commit is contained in:
wucongxing 2023-11-03 17:17:19 +08:00
parent 4011cbed8d
commit 9e1ff5f760

View File

@ -989,7 +989,8 @@ class InquiryService extends BaseService
$data['order_inquiry_id'] = $order_inquiry['order_inquiry_id']; $data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
$message = new AutoFinishInquiryDelayDirectProducer($data); $message = new AutoFinishInquiryDelayDirectProducer($data);
$message->setDelayMs(1000 * 60 * 60 * 24 * 3); // $message->setDelayMs(1000 * 60 * 60 * 24 * 3);
$message->setDelayMs(1000 * 60 * 2);
$producer = $this->container->get(Producer::class); $producer = $this->container->get(Producer::class);
$res = $producer->produce($message); $res = $producer->produce($message);
if (!$res) { if (!$res) {