diff --git a/app/Amqp/Consumer/SendVideoNoticeDelayDirectConsumer.php b/app/Amqp/Consumer/SendVideoNoticeDelayDirectConsumer.php new file mode 100644 index 0000000..66222bc --- /dev/null +++ b/app/Amqp/Consumer/SendVideoNoticeDelayDirectConsumer.php @@ -0,0 +1,187 @@ +info("开始：" . json_encode($data, JSON_UNESCAPED_UNICODE)); + + // 检测参数 + if (!isset($data['order_inquiry_id'])){ + Log::getInstance("queue-SendVideoNotice")->error("入参错误"); + return Result::DROP; + } + + // 获取问诊订单数据 + $params = array(); + $params['order_inquiry_id'] = $data['order_inquiry_id']; + $order_inquiry = OrderInquiry::getOne($params); + if (empty($order_inquiry)){ + Log::getInstance("queue-SendVideoNotice")->error("订单错误" ); + return Result::ACK; + } + + // 检测订单状态 + if ($order_inquiry['inquiry_status'] == 7) { + // 问诊订单状态（1:待支付 2:待分配 3:待接诊 4:已接诊 5:已完成 6:已结束 7:已取消） + Log::getInstance("queue-SendVideoNotice")->error("订单已取消" ); + return Result::ACK; + } + + // 检测订单状态 + if ($order_inquiry['inquiry_status'] == 5) { + // 问诊订单状态（1:待支付 2:待分配 3:待接诊 4:已接诊 5:已完成 6:已结束 7:已取消） + Log::getInstance("queue-SendVideoNotice")->error("订单已完成" ); + return Result::ACK; + } + + // 检测订单状态 + if ($order_inquiry['inquiry_status'] == 6) { + // 问诊订单状态（1:待支付 2:待分配 3:待接诊 4:已接诊 5:已完成 6:已结束 7:已取消） + Log::getInstance("queue-SendVideoNotice")->error("订单已结束" ); + return Result::ACK; + } + + // 检测订单状态 + if ($order_inquiry['inquiry_status'] == 3) { + // 问诊订单状态（1:待支付 2:待分配 3:待接诊 4:已接诊 5:已完成 6:已结束 7:已取消） + Log::getInstance("queue-SendVideoNotice")->error("订单待接诊" ); + return Result::ACK; + } + + // 检测订单状态 + if ($order_inquiry['inquiry_status'] == 1) { + // 问诊订单状态（1:待支付 2:待分配 3:待接诊 4:已接诊 5:已完成 6:已结束 7:已取消） + Log::getInstance("queue-SendVideoNotice")->error("订单待支付" ); + return Result::ACK; + } + + if (!in_array($order_inquiry['inquiry_refund_status'], [0, 4, 5])) { + // 问诊订单退款状态（0:无退款 1:申请退款 2:退款中 3:退款成功 4:拒绝退款 5:退款关闭） + Log::getInstance("queue-SendVideoNotice")->error("订单存在退款" ); + return Result::DROP; + } + + // 获取视频预约状态 + $params = array(); + $params['order_inquiry_id'] = $data['order_inquiry_id']; + $order_inquiry_video = OrderInquiryVideo::getOne($params); + if (empty($order_inquiry_video)){ + Log::getInstance("queue-SendVideoNotice")->error("缺少视频预约数据" ); + return Result::DROP; + } + + if ($order_inquiry_video['is_send_reservation_notice'] == 1){ + Log::getInstance("queue-SendVideoNotice")->info("已发送过一次通知,无需发送" ); + return Result::ACK; + } + + // 检测是否已开过视频 + if ($order_inquiry_video['is_video'] == 1){ + Log::getInstance("queue-SendVideoNotice")->info("已开过视频,无需发送" ); + return Result::ACK; + } + + // 检测通知时间 + $reservation_time = strtotime($order_inquiry_video['reservation_time']); + if ($reservation_time < time()){ + Log::getInstance("queue-SendVideoNotice")->info("当前时间已超过预约时间,无需发送" ); + return Result::ACK; + } + + // 5分钟以内 + $diff_time = $reservation_time - time(); + if ($diff_time > 5* 60){ + Log::getInstance("queue-SendVideoNotice")->info("不在发送时间内,无需发送" ); + return Result::ACK; + } + + // 获取患者用户数据 + $params = array(); + $params['user_id'] = $order_inquiry['user_id']; + $user = User::getOne($params); + if (empty($user)){ + Log::getInstance("queue-SendVideoNotice")->error("患者用户数据错误" ); + return Result::ACK; + } + + // 获取医生数据 + $params = array(); + $params['doctor_id'] = $order_inquiry['doctor_id']; + $user_doctor = UserDoctor::getOne($params); + if (empty($user_doctor)){ + Log::getInstance("queue-SendVideoNotice")->error("医生数据错误" ); + return Result::ACK; + } + + // 获取医生用户表数据 + $params = array(); + $params['user_id'] = $user_doctor['user_id']; + $doctor_user = User::getOne($params); + if (empty($doctor_user)){ + Log::getInstance("queue-SendVideoNotice")->error("医生用户数据错误" ); + return Result::ACK; + } + + Db::beginTransaction(); + try { + // 患者-通知患者视频 + $sendSmsService = new SendSmsService($user['mobile']); + $sendSmsService->noticePatientVideo($user_doctor['user_name']); + + // 医生-通知医生视频 + $sendSmsService = new SendSmsService($doctor_user['mobile']); + $sendSmsService->noticeDoctorVideo($order_inquiry['patient_name']); + + // 修改通知表 + $data = array(); + $data['is_send_reservation_notice'] = 1; + + $params = array(); + $params['inquiry_video_id'] = $order_inquiry_video['inquiry_video_id']; + $res = OrderInquiryVideo::edit($params,$data); + if (!$res){ + Db::rollBack(); + Log::getInstance("queue-SendVideoNotice")->error("修改失败"); + return Result::ACK; + } + }catch (\Throwable $e){ + Db::rollBack(); + Log::getInstance("queue-SendVideoNotice")->error($e->getMessage()); + return Result::ACK; + } + + return Result::ACK; + } +} diff --git a/app/Amqp/Producer/SendVideoNoticeDelayDirectProducer.php b/app/Amqp/Producer/SendVideoNoticeDelayDirectProducer.php new file mode 100644 index 0000000..e21506f --- /dev/null +++ b/app/Amqp/Producer/SendVideoNoticeDelayDirectProducer.php @@ -0,0 +1,36 @@ +payload = $data; + } +} diff --git a/app/Services/ImService.php b/app/Services/ImService.php index 7cea176..6a74cb7 100644 --- a/app/Services/ImService.php +++ b/app/Services/ImService.php @@ -917,7 +917,7 @@ class ImService extends BaseService } /** - * 订单结束，提醒赠送回合数（医生端） + * 订单结束，提醒赠送回合数-发送医生 * @param array|object $order_inquiry 问诊订单数据 * @param string $doctor_user_id 医生用户id * @param string $patient_user_id 患者用户id @@ -951,4 +951,160 @@ class ImService extends BaseService throw new BusinessException($e->getMessage()); } } + + /** + * 新增视频预约时间-发送医生 + * @param array|object $order_inquiry 问诊订单数据 + * @param string $doctor_user_id 医生用户id + * @param string $patient_user_id 患者用户id + * @param string $reservation_time 预约时间 + * @return void + */ + public function addVideoReservationTimeToDoctor(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id,string $reservation_time): void + { + try { + // 发送消息 + $cloud_custom_data = array(); + $cloud_custom_data['order_inquiry_id'] = $order_inquiry['order_inquiry_id']; + $cloud_custom_data['is_system'] = 1; + $cloud_custom_data['inquiry_type'] = $order_inquiry['inquiry_type']; + $cloud_custom_data['inquiry_mode'] = $order_inquiry['inquiry_mode']; + $cloud_custom_data['message_rounds'] = 0; + $cloud_custom_data['patient_family_data']['patient_name'] = $order_inquiry['patient_name']; + $cloud_custom_data['patient_family_data']['patient_sex'] = $order_inquiry['patient_sex']; + $cloud_custom_data['patient_family_data']['patient_age'] = $order_inquiry['patient_age']; + + $date = date("Y年m月d日 H点i分",strtotime($reservation_time)); + + // 消息内容 医生-患者 + $message_content_data = array(); + $message_content_data['message_type'] = 16; + $message_content_data['title'] = ""; + $message_content_data['desc'] = "您和患者已约定于{$date}进行视频问诊，请提前进入聊天页面，再约定时间发起视频"; + $message_content = [ + 'Data' => json_encode($message_content_data, JSON_UNESCAPED_UNICODE), + ]; + + $this->sendMessage($doctor_user_id, $patient_user_id, $message_content, "TIMCustomElem", $cloud_custom_data); + } catch (\Exception $e) { + throw new BusinessException($e->getMessage()); + } + } + + /** + * 修改视频预约时间-发送医生 + * @param array|object $order_inquiry 问诊订单数据 + * @param string $doctor_user_id 医生用户id + * @param string $patient_user_id 患者用户id + * @param string $reservation_time 预约时间 + * @return void + */ + public function modifyVideoReservationTimeToDoctor(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id,string $reservation_time): void + { + try { + // 发送消息 + $cloud_custom_data = array(); + $cloud_custom_data['order_inquiry_id'] = $order_inquiry['order_inquiry_id']; + $cloud_custom_data['is_system'] = 1; + $cloud_custom_data['inquiry_type'] = $order_inquiry['inquiry_type']; + $cloud_custom_data['inquiry_mode'] = $order_inquiry['inquiry_mode']; + $cloud_custom_data['message_rounds'] = 0; + $cloud_custom_data['patient_family_data']['patient_name'] = $order_inquiry['patient_name']; + $cloud_custom_data['patient_family_data']['patient_sex'] = $order_inquiry['patient_sex']; + $cloud_custom_data['patient_family_data']['patient_age'] = $order_inquiry['patient_age']; + + $date = date("Y年m月d日 H点i分",strtotime($reservation_time)); + + // 消息内容 医生-患者 + $message_content_data = array(); + $message_content_data['message_type'] = 16; + $message_content_data['title'] = ""; + $message_content_data['desc'] = "您和患者重新约定于{$date}进行视频问诊，请提前进入聊天页面，再约定时间发起视频"; + $message_content = [ + 'Data' => json_encode($message_content_data, JSON_UNESCAPED_UNICODE), + ]; + + $this->sendMessage($doctor_user_id, $patient_user_id, $message_content, "TIMCustomElem", $cloud_custom_data); + } catch (\Exception $e) { + throw new BusinessException($e->getMessage()); + } + } + + /** + * 新增视频预约时间-发送患者 + * @param array|object $order_inquiry 问诊订单数据 + * @param string $doctor_user_id 医生用户id + * @param string $patient_user_id 患者用户id + * @param string $reservation_time 预约时间 + * @return void + */ + public function addVideoReservationTimeToPatient(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id,string $reservation_time): void + { + try { + // 发送消息 + $cloud_custom_data = array(); + $cloud_custom_data['order_inquiry_id'] = $order_inquiry['order_inquiry_id']; + $cloud_custom_data['is_system'] = 1; + $cloud_custom_data['inquiry_type'] = $order_inquiry['inquiry_type']; + $cloud_custom_data['inquiry_mode'] = $order_inquiry['inquiry_mode']; + $cloud_custom_data['message_rounds'] = 0; + $cloud_custom_data['patient_family_data']['patient_name'] = $order_inquiry['patient_name']; + $cloud_custom_data['patient_family_data']['patient_sex'] = $order_inquiry['patient_sex']; + $cloud_custom_data['patient_family_data']['patient_age'] = $order_inquiry['patient_age']; + + $date = date("Y年m月d日 H点i分",strtotime($reservation_time)); + + // 消息内容 医生-患者 + $message_content_data = array(); + $message_content_data['message_type'] = 17; + $message_content_data['title'] = ""; + $message_content_data['desc'] = "您和医生已约定于{$date}进行视频问诊，请提前进入聊天页面，准备接听。"; + $message_content = [ + 'Data' => json_encode($message_content_data, JSON_UNESCAPED_UNICODE), + ]; + + $this->sendMessage($doctor_user_id, $patient_user_id, $message_content, "TIMCustomElem", $cloud_custom_data); + } catch (\Exception $e) { + throw new BusinessException($e->getMessage()); + } + } + + /** + * 修改视频预约时间-发送患者 + * @param array|object $order_inquiry 问诊订单数据 + * @param string $doctor_user_id 医生用户id + * @param string $patient_user_id 患者用户id + * @param string $reservation_time 预约时间 + * @return void + */ + public function modifyVideoReservationTimeToPatient(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id,string $reservation_time): void + { + try { + // 发送消息 + $cloud_custom_data = array(); + $cloud_custom_data['order_inquiry_id'] = $order_inquiry['order_inquiry_id']; + $cloud_custom_data['is_system'] = 1; + $cloud_custom_data['inquiry_type'] = $order_inquiry['inquiry_type']; + $cloud_custom_data['inquiry_mode'] = $order_inquiry['inquiry_mode']; + $cloud_custom_data['message_rounds'] = 0; + $cloud_custom_data['patient_family_data']['patient_name'] = $order_inquiry['patient_name']; + $cloud_custom_data['patient_family_data']['patient_sex'] = $order_inquiry['patient_sex']; + $cloud_custom_data['patient_family_data']['patient_age'] = $order_inquiry['patient_age']; + + $date = date("Y年m月d日 H点i分",strtotime($reservation_time)); + + // 消息内容 医生-患者 + $message_content_data = array(); + $message_content_data['message_type'] = 17; + $message_content_data['title'] = ""; + $message_content_data['desc'] = "您和医生重新约定于{$date}进行视频问诊，请提前进入聊天页面，准备接听。"; + $message_content = [ + 'Data' => json_encode($message_content_data, JSON_UNESCAPED_UNICODE), + ]; + + $this->sendMessage($doctor_user_id, $patient_user_id, $message_content, "TIMCustomElem", $cloud_custom_data); + } catch (\Exception $e) { + throw new BusinessException($e->getMessage()); + } + } } \ No newline at end of file diff --git a/app/Services/InquiryService.php b/app/Services/InquiryService.php index 6dd4afd..153ed01 100644 --- a/app/Services/InquiryService.php +++ b/app/Services/InquiryService.php @@ -5,6 +5,8 @@ namespace App\Services; use App\Amqp\Producer\AutoFinishInquiryDelayDirectProducer; use App\Amqp\Producer\CancelUnInquiryOrdersDelayDirectProducer; use App\Amqp\Producer\CancelUnpayOrdersDelayDirectProducer; +use App\Amqp\Producer\SendSmsMessageProducer; +use App\Amqp\Producer\SendVideoNoticeDelayDirectProducer; use App\Constants\DoctorTitleCode; use App\Constants\HttpEnumCode; use App\Exception\BusinessException; @@ -41,6 +43,7 @@ use App\Utils\PcreMatch; use Extend\Wechat\WechatPay; use GuzzleHttp\Exception\GuzzleException; use Hyperf\Amqp\Producer; +use Hyperf\Context\ApplicationContext; use Hyperf\DbConnection\Db; use Hyperf\Redis\Redis; use Hyperf\Snowflake\IdGeneratorInterface; @@ -1314,8 +1317,6 @@ class InquiryService extends BaseService /** * 医生设置视频预约时间 * @return array - * @throws ContainerExceptionInterface - * @throws NotFoundExceptionInterface */ public function addVideoReservationDate(): array { @@ -1391,8 +1392,6 @@ class InquiryService extends BaseService // 创建订单 Db::beginTransaction(); - $generator = $this->container->get(IdGeneratorInterface::class); - try { if (empty($order_inquiry_video)){ // 创建视频预约数据 @@ -1433,7 +1432,15 @@ class InquiryService extends BaseService $params['doctor_id'] = $order_inquiry['doctor_id']; $user_doctor = UserDoctor::getOne($params); if (empty($user_doctor)) { - return fail(HttpEnumCode::SERVER_ERROR, "赠送失败"); + return fail(HttpEnumCode::SERVER_ERROR, "设置失败"); + } + + // 获取订单用户数据 + $params = array(); + $params['user_id'] = $order_inquiry['user_id']; + $user = User::getOne($params); + if (empty($user)){ + return fail(HttpEnumCode::SERVER_ERROR, "设置失败"); } // 发送im消息 @@ -1441,23 +1448,33 @@ class InquiryService extends BaseService if ($is_reservation){ // 修改 + // 已成功预约视频问诊时间-医生 + $imService->addVideoReservationTimeToDoctor($order_inquiry,$user_doctor['user_id'],$order_inquiry['user_id'],$reservation_time); + + // 已成功预约视频问诊时间-患者 + $imService->addVideoReservationTimeToPatient($order_inquiry,$user_doctor['user_id'],$order_inquiry['user_id'],$reservation_time); }else{ // 新增 + // 已成功修改视频问诊时间-医生 + $imService->modifyVideoReservationTimeToDoctor($order_inquiry,$user_doctor['user_id'],$order_inquiry['user_id'],$reservation_time); + + // 已成功修改视频问诊时间-患者 + $imService->modifyVideoReservationTimeToPatient($order_inquiry,$user_doctor['user_id'],$order_inquiry['user_id'],$reservation_time); } - // 发送短信-患者-视频预约成功 + // 患者-通知患者视频时间 + $sendSmsService = new SendSmsService($user['mobile']); + $sendSmsService->noticePatientVideoTime($user_doctor['user_name'],$reservation_time); - - // 成功预约视频问诊时间 - // 成功修改视频问诊时间 - - - // 赠送回合数消息 - $imService->giveFreeRounds($order_inquiry, $user_doctor['user_id'], $order_inquiry['user_id'],$times_number,$give_expiration_time); - - // 发送站内、订阅失败发送短信消息-患者-赠送回合数 - $MessagePush = new MessagePush($order_inquiry['user_id'], $order_inquiry['order_inquiry_id']); - $MessagePush->doctorGiveFreeRounds($times_number,$give_expiration_time); + // 增加延迟队列通知-视频问诊即将开始 + $time = strtotime($reservation_time) - 4*60; + $message = new SendVideoNoticeDelayDirectProducer($data); + $message->setDelayMs(1000 * $time); + $producer = $this->container->get(Producer::class); + $res = $producer->produce($message); + if (!$res) { + return fail(HttpEnumCode::SERVER_ERROR, "设置失败"); + } }catch (\Throwable $e){ Log::getInstance("InquiryService-addDoctorGiveInquiryOrder")->error($e->getMessage()); } diff --git a/app/Services/MessagePush.php b/app/Services/MessagePush.php index fa53051..fb5556b 100644 --- a/app/Services/MessagePush.php +++ b/app/Services/MessagePush.php @@ -2607,7 +2607,7 @@ class MessagePush extends BaseService // 短信 $sms_data = array(); - $sms_data['template_code'] = "SMS_464531282"; + $sms_data['template_code'] = "SMS_464725006"; $sms_data['scene_desc'] = "医生赠送免费回合数"; $sms_data['phone'] = $this->user['mobile']; $sms_data['user_id'] = $this->user['user_id']; diff --git a/app/Services/SendSmsService.php b/app/Services/SendSmsService.php new file mode 100644 index 0000000..2d8e1af --- /dev/null +++ b/app/Services/SendSmsService.php @@ -0,0 +1,72 @@ +mobile = $mobile; + } + } + + // 患者-通知患者视频时间 + public function noticePatientVideoTime(string $doctor_name,$reservation_time){ + try { + // 发送短信-患者-视频预约成功 + $template_code = "SMS_464481352"; + $scene_desc = "通知患者视频时间"; + + $template_param = array(); + $template_param['name'] = $doctor_name; + $template_param['time'] = date('Y-m-d H:i', strtotime($reservation_time)); + + Dysms::sendSms($this->mobile,$template_param,$template_code,$scene_desc); + }catch (\Throwable $e){ + throw new BusinessException("短信发送失败",HttpEnumCode::CODE_FAIL); + } + } + + // 患者-通知患者视频 + public function noticePatientVideo(string $doctor_name){ + try { + // 发送短信-患者-视频预约成功 + $template_code = "SMS_464436348"; + $scene_desc = "通知患者视频"; + + $template_param = array(); + $template_param['name'] = $doctor_name; + + Dysms::sendSms($this->mobile,$template_param,$template_code,$scene_desc); + }catch (\Throwable $e){ + throw new BusinessException("短信发送失败",HttpEnumCode::CODE_FAIL); + } + } + + // 医生-通知医生视频 + public function noticeDoctorVideo(string $patient_name){ + try { + // 发送短信-患者-视频预约成功 + $template_code = "SMS_464486306"; + $scene_desc = "通知医生视频"; + + $template_param = array(); + $template_param['name'] = $patient_name; + + Dysms::sendSms($this->mobile,$template_param,$template_code,$scene_desc); + }catch (\Throwable $e){ + throw new BusinessException("短信发送失败",HttpEnumCode::CODE_FAIL); + } + } +} \ No newline at end of file