diff --git a/app/Amqp/Consumer/AutoPharmacistCaVerifyDelayDirectConsumer.php b/app/Amqp/Consumer/AutoPharmacistCaVerifyDelayDirectConsumer.php index 4b500ab..bc519d4 100644 --- a/app/Amqp/Consumer/AutoPharmacistCaVerifyDelayDirectConsumer.php +++ b/app/Amqp/Consumer/AutoPharmacistCaVerifyDelayDirectConsumer.php @@ -94,24 +94,16 @@ class AutoPharmacistCaVerifyDelayDirectConsumer extends ConsumerMessage // 获取医生数据 $params = array(); $params['doctor_id'] = $order_prescription['doctor_id']; + // 获取抄方医生数据 (如果存在抄方操作) + if(!empty($order_inquiry['transfer_doctor_id'])){ + $params['doctor_id'] = $order_inquiry['transfer_doctor_id']; + } $user_doctor = UserDoctor::getOne($params); if (empty($user_doctor)) { Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误:医生数据错误"); return Result::ACK; } - - // 获取抄方医生数据 (如果存在抄方操作) - if(!empty($order_inquiry['transfer_doctor_id'])){ - $params = array(); - $params['doctor_id'] = $order_inquiry['transfer_doctor_id']; - $user_doctor = UserDoctor::getOne($params); - if (empty($user_doctor)) { - Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误:抄方医生数据错误"); - return Result::ACK; - } - } - // 获取用户数据 $params = array(); $params['patient_id'] = $order_prescription['patient_id']; @@ -283,7 +275,16 @@ class AutoPharmacistCaVerifyDelayDirectConsumer extends ConsumerMessage // 药师审核成功 // 发送IM消息-处方已开具 $imService = new ImService(); - $imService->prescriptionIssued($order_inquiry,$user_doctor['user_id'],$order_inquiry['user_id'],$product_name,(string)$data['order_prescription_id'],7); + + $doctor_im_id = $user_doctor['user_id']; + //如果为抄方,则发送给原医生IM + if(!empty($order_inquiry["transfer_doctor_id"])){ + $params = array(); + $params['doctor_id'] = $order_inquiry['doctor_id']; + $user_doctor = UserDoctor::getOne($params); + $doctor_im_id = $user_doctor['user_id']; + } + $imService->prescriptionIssued($order_inquiry,$doctor_im_id,$order_inquiry['user_id'],$product_name,(string)$data['order_prescription_id'],7); // 发送站内、短信消息-患者的处方被药师审核通过 $MessagePush = new MessagePush($order_inquiry['user_id'],$order_inquiry['inquiry_no']);