修改im推送患者病例消息时机

This commit is contained in:
wucongxing 2023-08-24 16:57:21 +08:00
parent 52657e2b50
commit aa5d4e7724
5 changed files with 21 additions and 9 deletions

View File

@ -276,9 +276,6 @@ class AssignDoctorDelayDirectConsumer extends ConsumerMessage
// 发送im消息 // 发送im消息
$imService = new ImService(); $imService = new ImService();
// 患者病例
$imService->patientCase($order_inquiry,$user_doctor['user_id'],$order_inquiry_case['disease_desc']);
// 等待医生接诊 // 等待医生接诊
$imService->waitDoctorInquiry($order_inquiry,$user_doctor['user_id'],$order_inquiry['user_id']); $imService->waitDoctorInquiry($order_inquiry,$user_doctor['user_id'],$order_inquiry['user_id']);

View File

@ -188,8 +188,7 @@ class CallBackController extends AbstractController
// 发送im消息 // 发送im消息
$imService = new ImService(); $imService = new ImService();
// 患者病例
$imService->patientCase($order_inquiry,$user_doctor['user_id'],$order_inquiry_case['disease_desc']);
// 等待医生接诊 // 等待医生接诊
$imService->waitDoctorInquiry($order_inquiry, $user_doctor['user_id'], $order_inquiry['user_id']); $imService->waitDoctorInquiry($order_inquiry, $user_doctor['user_id'], $order_inquiry['user_id']);
@ -1528,6 +1527,7 @@ class CallBackController extends AbstractController
// 发送im消息 // 发送im消息
$imService = new ImService(); $imService = new ImService();
// 患者病例 // 患者病例
$imService->patientCase( $imService->patientCase(
$order_inquiry, $order_inquiry,

View File

@ -235,8 +235,6 @@ class MessagePush extends BaseService
* 患者-通知患者医生已接诊 * 患者-通知患者医生已接诊
* 站内、订阅、短信 * 站内、订阅、短信
* @return void * @return void
* @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface
*/ */
public function patientAcceptedInquiry(): void public function patientAcceptedInquiry(): void
{ {

View File

@ -976,8 +976,6 @@ class PatientOrderService extends BaseService
// 发送im消息 // 发送im消息
$imService = new ImService(); $imService = new ImService();
// 患者病例
$imService->patientCase($order_inquiry,$user_doctor['user_id'],$order_inquiry_case['disease_desc']);
// 等待医生接诊 // 等待医生接诊
$imService->waitDoctorInquiry($order_inquiry, $user_doctor['user_id'], $order_inquiry['user_id']); $imService->waitDoctorInquiry($order_inquiry, $user_doctor['user_id'], $order_inquiry['user_id']);

View File

@ -1810,10 +1810,29 @@ class UserDoctorService extends BaseService
} }
try { try {
// 获取订单医生数据
$params = array();
$params['doctor_id'] = $order_inquiry['doctor_id'];
$user_doctor = UserDoctor::getOne($params);
if (empty($user_doctor)) {
return success([],HttpEnumCode::HTTP_SUCCESS,"医生数据错误");
}
// 获取病例数据
$params = array();
$params['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
$order_inquiry_case = OrderInquiryCase::getOne($params);
if (empty($order_inquiry_case)){
return success([],HttpEnumCode::HTTP_SUCCESS,"患者病例错误");
}
// 发送IM消息-医生接诊 // 发送IM消息-医生接诊
$imService = new ImService(); $imService = new ImService();
$imService->doctorInquiry($order_inquiry,$user_info['user_id'],$order_inquiry['user_id']); $imService->doctorInquiry($order_inquiry,$user_info['user_id'],$order_inquiry['user_id']);
// 发送IM消息-患者病例
$imService->patientCase($order_inquiry,$user_doctor['user_id'],$order_inquiry_case['disease_desc']);
// 发送站内、订阅、短信消息-医生已接诊 // 发送站内、订阅、短信消息-医生已接诊
$MessagePush = new MessagePush($order_inquiry['user_id'],$order_inquiry['order_inquiry_id']); $MessagePush = new MessagePush($order_inquiry['user_id'],$order_inquiry['order_inquiry_id']);
$MessagePush->patientAcceptedInquiry(); $MessagePush->patientAcceptedInquiry();