diff --git a/app/Amqp/Consumer/AutoPharmacistCaVerifyDelayDirectConsumer.php b/app/Amqp/Consumer/AutoPharmacistCaVerifyDelayDirectConsumer.php index b1421e3..89b1d93 100644 --- a/app/Amqp/Consumer/AutoPharmacistCaVerifyDelayDirectConsumer.php +++ b/app/Amqp/Consumer/AutoPharmacistCaVerifyDelayDirectConsumer.php @@ -143,6 +143,13 @@ class AutoPharmacistCaVerifyDelayDirectConsumer extends ConsumerMessage return Result::ACK; } + $message_doctor_id = $user_doctor['doctor_id']; + if(!empty($order_inquiry["transfer_doctor_id"])){ + $params = array(); + $params['doctor_id'] = $order_inquiry['doctor_id']; + $user_doctor = UserDoctor::getOne($params); + $message_doctor_id = $user_doctor['user_id']; + } if (!$res) { Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误:超出最大执行次数或检测错误"); @@ -152,10 +159,6 @@ class AutoPharmacistCaVerifyDelayDirectConsumer extends ConsumerMessage $this->modifyOrderPrescription($data['order_prescription_id'], 2, "请联系平台客服,请勿重开处方"); // 医生-开具的处方审核未通过 - $message_doctor_id = $user_doctor['doctor_id']; - if(!empty($order_inquiry["transfer_doctor_id"])){ - $message_doctor_id = $order_inquiry['doctor_id']; - } $MessagePush = new MessagePush($message_doctor_id, $order_inquiry['inquiry_no']); $MessagePush->prescriptionVerifyFail($data['order_prescription_id']); @@ -276,11 +279,7 @@ class AutoPharmacistCaVerifyDelayDirectConsumer extends ConsumerMessage // 发送IM消息-处方已开具 $imService = new ImService(); - $message_doctor_id = $user_doctor['doctor_id']; //如果为抄方,则发送给原医生IM - if(!empty($order_inquiry["transfer_doctor_id"])){ - $message_doctor_id = $order_inquiry['doctor_id']; - } $imService->prescriptionIssued($order_inquiry,$message_doctor_id,$order_inquiry['user_id'],$product_name,(string)$data['order_prescription_id'],7); // 发送站内、短信消息-患者的处方被药师审核通过