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

未接诊取消订单延迟队列修改了入参数据

Browse Source
This commit is contained in:
wucongxing8150 2024-04-08 16:30:42 +08:00
parent b2a9272723
commit f87de0a595
3 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
app/Amqp/Consumer/AssignDoctorDelayDirectConsumer.php
View File

@ -252,6 +252,7 @@ class AssignDoctorDelayDirectConsumer extends ConsumerMessage
// 加入未接诊取消订单延迟队列 // 加入未接诊取消订单延迟队列
$data = array(); $data = array();
$data['order_inquiry_id'] = $order_inquiry['order_inquiry_id']; $data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
$data['order_no'] = $order_inquiry['inquiry_no'];
$message = new CancelUnInquiryOrdersDelayDirectProducer($data); $message = new CancelUnInquiryOrdersDelayDirectProducer($data);
// 快速/购药-5分钟 // 快速/购药-5分钟
$message->setDelayMs(1000 * 60 * 10); $message->setDelayMs(1000 * 60 * 10);

2
app/Amqp/Consumer/CancelUnInquiryOrdersDelayDirectConsumer.php
View File

@ -57,7 +57,7 @@ class CancelUnInquiryOrdersDelayDirectConsumer extends ConsumerMessage
try { try {
// 检测执行次数 // 检测执行次数
$Utils = new Utils(); $Utils = new Utils();
$redis_key = "orderRefund" . $data['order_no']; $redis_key = "orderRefund" . $data['order_inquiry_id'];
$res = $Utils->checkHandleNumber($redis_key); $res = $Utils->checkHandleNumber($redis_key);
if (!$res) { if (!$res) {
Log::getInstance("queue-CancelUnInquiryOrders")->error("超出最大执行次数或检测错误"); Log::getInstance("queue-CancelUnInquiryOrders")->error("超出最大执行次数或检测错误");

1
app/Services/InquiryService.php
View File

@ -505,6 +505,7 @@ class InquiryService extends BaseService
$data = array(); $data = array();
$data['order_inquiry_id'] = $order_inquiry['order_inquiry_id']; $data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
$data['order_no'] = $order_inquiry['inquiry_no'];
$message = new CancelUnInquiryOrdersDelayDirectProducer($data); $message = new CancelUnInquiryOrdersDelayDirectProducer($data);
$message->setDelayMs(1000 * $time); $message->setDelayMs(1000 * $time);
$producer = $this->container->get(Producer::class); $producer = $this->container->get(Producer::class);