添加自动完成队列修改为10分钟
This commit is contained in:
parent
4726538d45
commit
cc253c2d0e
@ -123,7 +123,6 @@ class InquiryController extends AbstractController
|
|||||||
/**
|
/**
|
||||||
* 结束问诊
|
* 结束问诊
|
||||||
* @return ResponseInterface
|
* @return ResponseInterface
|
||||||
* @throws GuzzleException
|
|
||||||
*/
|
*/
|
||||||
public function putFinishInquiry(): ResponseInterface
|
public function putFinishInquiry(): ResponseInterface
|
||||||
{
|
{
|
||||||
|
|||||||
@ -1127,7 +1127,13 @@ 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);
|
|
||||||
|
$time = 60 * 60 * 24 * 3;
|
||||||
|
if (\Hyperf\Config\config("app_env") == "dev"){
|
||||||
|
$time = 60 * 10;
|
||||||
|
}
|
||||||
|
|
||||||
|
$message->setDelayMs(1000 * $time);
|
||||||
$producer = $this->container->get(Producer::class);
|
$producer = $this->container->get(Producer::class);
|
||||||
$res = $producer->produce($message);
|
$res = $producer->produce($message);
|
||||||
if (!$res) {
|
if (!$res) {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user