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

1

Browse Source
This commit is contained in:
wucongxing 2023-03-08 12:01:59 +08:00
parent 4cbb2f5307
commit 220aea3530
1 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
app/Amqp/Consumer/AssignDoctorConsumer.php
View File

@ -93,7 +93,9 @@ class AssignDoctorConsumer extends ConsumerMessage
} }
if ($diff_time > 300){ if ($diff_time > 300){
try {
// 超出5分钟，执行退款 // 超出5分钟，执行退款
Log::getInstance()->info("超出5分钟，执行退款");
$InquiryService = new InquiryService(); $InquiryService = new InquiryService();
$InquiryService->inquiryRefund($order_inquiry['order_inquiry_id'],"分配医生失败"); $InquiryService->inquiryRefund($order_inquiry['order_inquiry_id'],"分配医生失败");
@ -104,6 +106,12 @@ class AssignDoctorConsumer extends ConsumerMessage
// 加入消息通知队列 // 加入消息通知队列
return Result::ACK; return Result::ACK;
} catch (\Exception $e) {
Db::rollBack();
Log::getInstance()->error("队列执行失败原因：" . "执行退款失败" . $e->getMessage());
return Result::REQUEUE; // 重回队列
}
} }
$redis = $this->container->get(Redis::class); $redis = $this->container->get(Redis::class);