gdxz/hospital-applets-api
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加未支付取消订单延迟队列时间环境区分，测试环境5分钟。增加未接诊取消订单延迟队列时间环境区分，测试环境为10分钟

Browse Source
This commit is contained in:
wucongxing8150 2024-04-08 15:53:35 +08:00
parent dd01d8fe2d
commit b2a9272723
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
app/Services/InquiryService.php
View File

@ -477,12 +477,17 @@ class InquiryService extends BaseService
} }
// 增加至未支付取消订单延迟队列 // 增加至未支付取消订单延迟队列
$time = 60 * 30;
if (\Hyperf\Config\config('app_env') == "dev"){
$time = 60 * 5;
}
$data = array(); $data = array();
$data['order_no'] = $order_inquiry['inquiry_no']; $data['order_no'] = $order_inquiry['inquiry_no'];
$data['order_type'] = 1; $data['order_type'] = 1;
$message = new CancelUnpayOrdersDelayDirectProducer($data); $message = new CancelUnpayOrdersDelayDirectProducer($data);
$message->setDelayMs(1000 * 60 * 30); $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) {
@ -493,10 +498,15 @@ class InquiryService extends BaseService
// 加入未接诊取消订单延迟队列 // 加入未接诊取消订单延迟队列
// 专家问诊-公益问诊 // 专家问诊-公益问诊
if (!empty($request_params['doctor_id']) && ($request_params['inquiry_type'] == 1 || $request_params['inquiry_type'] == 3)) { if (!empty($request_params['doctor_id']) && ($request_params['inquiry_type'] == 1 || $request_params['inquiry_type'] == 3)) {
$time = 60 * 60 * 24;
if (\Hyperf\Config\config('app_env') == "dev"){
$time = 60 * 10;
}
$data = array(); $data = array();
$data['order_inquiry_id'] = $order_inquiry['order_inquiry_id']; $data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
$message = new CancelUnInquiryOrdersDelayDirectProducer($data); $message = new CancelUnInquiryOrdersDelayDirectProducer($data);
$message->setDelayMs(1000 * 60 * 60 * 24); $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) {