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:
wucongxing 2023-04-27 10:51:43 +08:00
parent 9d054c2acd
commit 57de8bb743
1 changed files with 25 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -9,6 +9,8 @@ use App\Amqp\Producer\CancelUnInquiryOrdersDelayDirectProducer;
use App\Amqp\Producer\UserCouponExpiredDelayDirectProducer; use App\Amqp\Producer\UserCouponExpiredDelayDirectProducer;
use App\Constants\HttpEnumCode; use App\Constants\HttpEnumCode;
use App\Model\OrderInquiry; use App\Model\OrderInquiry;
use App\Model\UserDoctor;
use App\Services\ImService;
use App\Services\InquiryService; use App\Services\InquiryService;
use App\Services\MessagePush; use App\Services\MessagePush;
use App\Services\UserDoctorService; use App\Services\UserDoctorService;
@ -187,6 +189,7 @@ class AssignDoctorDelayDirectConsumer extends ConsumerMessage
return Result::REQUEUE; return Result::REQUEUE;
} }
Db::commit();
Log::getInstance("queue-AssignDoctor")->info("结束"); Log::getInstance("queue-AssignDoctor")->info("结束");
return Result::ACK; return Result::ACK;
} }
@ -236,10 +239,30 @@ class AssignDoctorDelayDirectConsumer extends ConsumerMessage
$res = $producer->produce($message); $res = $producer->produce($message);
if (!$res) { if (!$res) {
Db::rollBack(); Db::rollBack();
Log::getInstance("queue-AssignDoctor")->error("加入未接诊取消订单延迟队列失败"); Log::getInstance("queue-AssignDoctor")->error("错误：加入未接诊取消订单延迟队列失败");
return Result::ACK; return Result::REQUEUE;
} }
Log::getInstance("queue-AssignDoctor")->info("信息：发送消息");
// 获取订单医生数据
$params = array();
$params['doctor_id'] = $doctor_id;
$user_doctor = UserDoctor::getOne($params);
if (empty($user_doctor)) {
Db::rollBack();
Log::getInstance("queue-AssignDoctor")->error("错误：医生数据错误");
return Result::REQUEUE;
}
// 发送IM消息-等待医生接诊
$imService = new ImService();
$imService->waitDoctorInquiry($order_inquiry,$user_doctor['user_id'],$order_inquiry['user_id']);
// 医生-医生有新问诊 站内、订阅失败发送短信
$MessagePush = new MessagePush($user_doctor['user_id'],$order_inquiry['order_inquiry_id']);
$MessagePush->doctorHaveNewInquiry();
Db::commit(); Db::commit();
Log::getInstance("queue-AssignDoctor")->info("成功"); Log::getInstance("queue-AssignDoctor")->info("成功");
} catch (\Exception $e) { } catch (\Exception $e) {