新增医生列表
This commit is contained in:
parent
6f03276d50
commit
dfe630016d
@ -70,7 +70,7 @@ class AssignDoctorDelayDirectConsumer extends ConsumerMessage
|
|||||||
try {
|
try {
|
||||||
// 检测锁定状态
|
// 检测锁定状态
|
||||||
$redis = $this->container->get(Redis::class);
|
$redis = $this->container->get(Redis::class);
|
||||||
$redis_key = "assign_octor_lock_" . $data['order_inquiry_id'];
|
$redis_key = "assign_doctor_lock_" . $data['order_inquiry_id'];
|
||||||
$redis_lock = $redis->setnx($redis_key,1);
|
$redis_lock = $redis->setnx($redis_key,1);
|
||||||
|
|
||||||
// 设置过期时间-10s
|
// 设置过期时间-10s
|
||||||
@ -183,7 +183,7 @@ class AssignDoctorDelayDirectConsumer extends ConsumerMessage
|
|||||||
$params['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
|
$params['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
|
||||||
OrderInquiry::edit($params, $save_data);
|
OrderInquiry::edit($params, $save_data);
|
||||||
|
|
||||||
Log::getInstance("queue-AssignDoctor")->info("结束");
|
Log::getInstance("queue-AssignDoctor")->info("结束:已退款");
|
||||||
Db::commit();
|
Db::commit();
|
||||||
return Result::ACK;
|
return Result::ACK;
|
||||||
}
|
}
|
||||||
@ -210,7 +210,7 @@ class AssignDoctorDelayDirectConsumer extends ConsumerMessage
|
|||||||
return Result::REQUEUE;
|
return Result::REQUEUE;
|
||||||
}
|
}
|
||||||
|
|
||||||
Log::getInstance("queue-AssignDoctor")->info("结束");
|
Log::getInstance("queue-AssignDoctor")->info("重回队列");
|
||||||
return Result::ACK;
|
return Result::ACK;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user