1409 lines
71 KiB
PHP
1409 lines
71 KiB
PHP
<?php
|
||
|
||
namespace App\Services;
|
||
|
||
use App\Constants\DoctorTitleCode;
|
||
use App\Constants\HttpEnumCode;
|
||
use App\Exception\BusinessException;
|
||
use App\Model\Hospital;
|
||
use App\Model\OrderServicePackage;
|
||
use App\Model\OrderServicePackageDetail;
|
||
use App\Model\OrderServicePackageProduct;
|
||
use App\Model\User;
|
||
use App\Model\UserDoctor;
|
||
use App\Model\UserPatient;
|
||
use App\Model\UserPharmacist;
|
||
use App\Utils\Log;
|
||
use Extend\TencentIm\Account;
|
||
use Extend\TencentIm\Message;
|
||
use Extend\TencentIm\Profile;
|
||
use GuzzleHttp\Exception\GuzzleException;
|
||
use Hyperf\Redis\Redis;
|
||
use Psr\Container\ContainerExceptionInterface;
|
||
use Psr\Container\NotFoundExceptionInterface;
|
||
|
||
class ImService extends BaseService
|
||
{
|
||
/**
|
||
* 检测并创建账号
|
||
* @param string $user_id
|
||
* @return bool
|
||
* @throws GuzzleException
|
||
*/
|
||
public function createAccount(string $user_id): bool
|
||
{
|
||
try {
|
||
$params = array();
|
||
$params['user_id'] = $user_id;
|
||
$user = User::getOne($params);
|
||
if (empty($user)) {
|
||
throw new BusinessException("用户数据错误");
|
||
}
|
||
|
||
$avatar = addAliyunOssWebsite($user['avatar']);
|
||
|
||
$account = new Account();
|
||
// 查询账号导入状态
|
||
$res = $account->checkAccountStatus($user['user_id']);
|
||
if (!$res) {
|
||
// 创建单个账号
|
||
$account->createAccount($user_id, $user['user_name'], $avatar);
|
||
}
|
||
|
||
// 检测用户资料
|
||
$profile = new Profile();
|
||
$result = $profile->getOneAccountPortraitList($user['user_id']);
|
||
if (!empty($result)) {
|
||
$arg = array();
|
||
|
||
// 头像
|
||
if (in_array('Tag_Profile_IM_Image', $result)) {
|
||
$arg['Tag_Profile_IM_Image'] = $avatar;
|
||
}
|
||
|
||
// 性别
|
||
if (in_array('Tag_Profile_IM_Gender', $result)) {
|
||
$arg['Tag_Profile_IM_Gender'] = sexToImSex($user['sex']);
|
||
}
|
||
|
||
if ($user['user_type'] == 2) {
|
||
$params = array();
|
||
$params['user_id'] = $user['user_id'];
|
||
$user_doctor = UserDoctor::getOne($params);
|
||
if (empty($user_doctor)) {
|
||
throw new BusinessException("医生数据错误");
|
||
}
|
||
|
||
// 获取订单医生医院
|
||
$params = array();
|
||
$params['hospital_id'] = $user_doctor['hospital_id'];
|
||
$hospital = Hospital::getOne($params);
|
||
if (empty($hospital)) {
|
||
throw new BusinessException("医生医院数据错误");
|
||
}
|
||
|
||
// 医院
|
||
if (in_array('Tag_Profile_Custom_Hname', $result)) {
|
||
$arg['Tag_Profile_Custom_Hname'] = $hospital['hospital_name'];
|
||
}
|
||
|
||
// 职称
|
||
if (in_array('Tag_Profile_Custom_Title', $result)) {
|
||
$arg['Tag_Profile_Custom_Title'] = $user_doctor['doctor_title'] ?? DoctorTitleCode::getMessage($user_doctor['doctor_title']);
|
||
}
|
||
}
|
||
|
||
if (!empty($arg)) {
|
||
$profile->setProfile($user['user_id'], $arg);
|
||
}
|
||
}
|
||
|
||
return true;
|
||
} catch (\Exception $e) {
|
||
throw new BusinessException($e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 设置用户资料
|
||
* @param string $user_id
|
||
* @return bool
|
||
* @throws GuzzleException
|
||
*/
|
||
public function setUserProfile(string $user_id): bool
|
||
{
|
||
try {
|
||
$params = array();
|
||
$params['user_id'] = $user_id;
|
||
$user = User::getOne($params);
|
||
if (empty($user)) {
|
||
throw new BusinessException("用户数据错误");
|
||
}
|
||
|
||
$avatar = addAliyunOssWebsite($user['avatar']);
|
||
|
||
// 检测用户资料
|
||
$profile = new Profile();
|
||
$result = $profile->getOneAccountPortraitList($user['user_id']);
|
||
|
||
if (!empty($result)) {
|
||
$arg = array();
|
||
|
||
// 头像
|
||
if (in_array('Tag_Profile_IM_Image', $result)) {
|
||
$arg['Tag_Profile_IM_Image'] = $avatar;
|
||
}
|
||
|
||
// 性别
|
||
if (in_array('Tag_Profile_IM_Gender', $result)) {
|
||
$arg['Tag_Profile_IM_Gender'] = sexToImSex($user['sex']);
|
||
}
|
||
|
||
if ($user['user_type'] == 2) {
|
||
$params = array();
|
||
$params['user_id'] = $user['user_id'];
|
||
$user_doctor = UserDoctor::getOne($params);
|
||
if (empty($user_doctor)) {
|
||
throw new BusinessException("医生数据错误");
|
||
}
|
||
|
||
// 获取订单医生医院
|
||
$params = array();
|
||
$params['hospital_id'] = $user_doctor['hospital_id'];
|
||
$hospital = Hospital::getOne($params);
|
||
if (empty($hospital)) {
|
||
throw new BusinessException("医生医院数据错误");
|
||
}
|
||
|
||
// 医院
|
||
if (in_array('Tag_Profile_Custom_Hname', $result)) {
|
||
$arg['Tag_Profile_Custom_Hname'] = $hospital['hospital_name'];
|
||
}
|
||
|
||
// 职称
|
||
if (in_array('Tag_Profile_Custom_Title', $result)) {
|
||
$arg['Tag_Profile_Custom_Title'] = $user_doctor['doctor_title'] ?? DoctorTitleCode::getMessage($user_doctor['doctor_title']);
|
||
}
|
||
}
|
||
|
||
if (!empty($arg)) {
|
||
$profile->setProfile($user['user_id'], $arg);
|
||
}
|
||
}
|
||
|
||
return true;
|
||
} catch (\Exception $e) {
|
||
throw new BusinessException($e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 验证回调签名
|
||
* @param string $request_time 签名时间戳
|
||
* @param string $sign 签名
|
||
* @return bool
|
||
*/
|
||
public function validateSign(string $request_time, string $sign): bool
|
||
{
|
||
$token = config('im.token');
|
||
if (empty($token)) {
|
||
throw new BusinessException("Im Token Config Error");
|
||
}
|
||
|
||
$sys_sign = hash("sha256", $token . $request_time);
|
||
if ($sign != $sys_sign) {
|
||
return false;
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 添加最近联系人会话记录缓存
|
||
* @param string $doctor_id 医生id
|
||
* @param string $inquiry_type 订单类型（自定义字段 1:专家问诊 2:快速问诊 3:公益问诊 4:问诊购药）
|
||
* @param string $patient_user_id 患者用户id
|
||
* @param array $content 内容
|
||
* @return void
|
||
* @throws ContainerExceptionInterface
|
||
* @throws NotFoundExceptionInterface
|
||
*/
|
||
public function addRecentContactRecordCache(string $doctor_id, string $inquiry_type, string $patient_user_id, array $content): void
|
||
{
|
||
$redis_key = "recentContact" . $doctor_id . $inquiry_type;
|
||
|
||
$hash_key = $patient_user_id;
|
||
|
||
$redis = $this->container->get(Redis::class);
|
||
|
||
$redis->hSet($redis_key, $hash_key, json_encode($content, JSON_UNESCAPED_UNICODE));
|
||
}
|
||
|
||
/**
|
||
* 发送消息
|
||
* @param string $from_user_id 发送者id
|
||
* @param string $to_user_id 接受者id
|
||
* @param array $message_content 内容 对应 MsgBody.MsgContent
|
||
* @param string $message_type 消息类型 具体查看（https://cloud.tencent.com/document/product/269/2720）
|
||
* @param array $cloud_custom_data 自定义字段
|
||
* @return void
|
||
*/
|
||
public function sendMessage(string $from_user_id, string $to_user_id, array $message_content, string $message_type, array $cloud_custom_data): void
|
||
{
|
||
try {
|
||
if (!empty($from_user_id)) {
|
||
// 检测并创建发送者资料
|
||
$this->setUserProfile($from_user_id);
|
||
}
|
||
|
||
// 检测并创建接收者资料
|
||
$this->setUserProfile($to_user_id);
|
||
|
||
$message = new Message();
|
||
|
||
$arg = array();
|
||
if (!empty($from_user_id)) {
|
||
$arg['From_Account'] = $from_user_id; // 发送方user_id 如系统发送，无需填写
|
||
}
|
||
$arg['To_Account'] = $to_user_id; // 接收方user_id
|
||
$arg['ForbidCallbackControl'] = ['ForbidBeforeSendMsgCallback'];
|
||
$arg['SendMsgControl'] = [];
|
||
|
||
$arg['MsgBody'] = [
|
||
[
|
||
"MsgType" => $message_type,
|
||
"MsgContent" => $message_content,
|
||
]
|
||
];
|
||
|
||
$arg['CloudCustomData'] = "";
|
||
if (!empty($cloud_custom_data)) {
|
||
$arg['CloudCustomData'] = json_encode($cloud_custom_data, JSON_UNESCAPED_UNICODE);
|
||
}
|
||
|
||
// 该条消息是否需要已读回执，0为不需要，1为需要，默认为0
|
||
$arg['IsNeedReadReceipt'] = 1;
|
||
|
||
$message->sendMessage($arg);
|
||
} catch (\Exception $e) {
|
||
throw new BusinessException($e->getMessage());
|
||
} catch (GuzzleException $e) {
|
||
throw new BusinessException($e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 问诊已完成
|
||
* @param array|object $order_inquiry 问诊订单数据
|
||
* @param string $doctor_user_id 医生用户id
|
||
* @param string $patient_user_id 患者用户id
|
||
* @return void
|
||
*/
|
||
public function inquiryComplete(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
// 消息内容 医生-患者
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 1;
|
||
$message_content_data['title'] = "—问诊已结束—";
|
||
$message_content_data['desc'] = "线上咨询不能代替面诊,医生建议仅供参考。";
|
||
$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
|
||
* @return void
|
||
*/
|
||
public function waitDoctorInquiry(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
// 消息内容 医生-患者
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 1;
|
||
$message_content_data['title'] = "—等待医生接诊—";
|
||
if ($order_inquiry['inquiry_type'] == 1) {
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
|
||
// 获取服务包订单编号-通过问诊订单id
|
||
$order_service_no = $OrderServicePackageService->getOrderServiceNoByOrderInquiryId($order_inquiry['inquiry_no']);
|
||
|
||
// 检测问诊是否服务包首次问诊
|
||
$is_first = $OrderServicePackageService->isFirstInquiryServicePackage($order_service_no);
|
||
if ($is_first){
|
||
$message_content_data['desc'] = "温馨提示:医生繁忙请耐心等待，医生接诊后会第一时间通知您。医生接诊后，服务有效期开始计算。";
|
||
}else{
|
||
$message_content_data['desc'] = "温馨提示:医生繁忙请耐心等待，医生接诊后会第一时间通知您。";
|
||
}
|
||
}else{
|
||
$message_content_data['desc'] = "温馨提示：当前服务为专家问诊，医师接诊后可以在24小时内和医生沟通20个回合。医生繁忙请耐心等待，医生接诊会后第一时间短信通知您。";
|
||
}
|
||
} elseif ($order_inquiry['inquiry_type'] == 2) {
|
||
$message_content_data['desc'] = "温馨提示：请耐心等待，您可继续补充病情，便于医生接诊后更快确认病情。";
|
||
} elseif ($order_inquiry['inquiry_type'] == 3) {
|
||
$message_content_data['desc'] = "温馨提示：当前服务为公益问诊，医师接诊后可以在24小时内和医生沟通10个回合。医生繁忙请耐心等待，医生接诊会后第一时间短信通知您。";
|
||
} else {
|
||
$message_content_data['desc'] = "温馨提示：请耐心等待，您可继续补充病情，便于医生接诊后更快确认病情。";
|
||
}
|
||
$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 float|int $time
|
||
* @return void
|
||
*/
|
||
public function doctorInquiry(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id,float|int $time): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
// 消息内容 医生-患者
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 1;
|
||
|
||
$time = $time / 60 / 60;
|
||
if ($time >= 1){
|
||
$time = $time . "小时";
|
||
}else{
|
||
$time = $time * 60 . "分钟";
|
||
}
|
||
|
||
$message_content_data['title'] = "—问诊已开始，本次问诊可持续{$time}—";
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
|
||
// 获取服务包订单编号-通过问诊订单id
|
||
$order_service_no = $OrderServicePackageService->getOrderServiceNoByOrderInquiryId($order_inquiry['inquiry_no']);
|
||
|
||
$params = array();
|
||
$params['order_service_no'] = $order_service_no;
|
||
$order_service_package = OrderServicePackage::getOne($params);
|
||
if (empty($order_service_package)){
|
||
throw new BusinessException("im消息发送失败");
|
||
}
|
||
|
||
// 获取服务包订单详情
|
||
$params = array();
|
||
$params['order_service_no'] = $order_service_package['order_service_no'];
|
||
$order_service_package_detail = OrderServicePackageDetail::getOne($params);
|
||
if (empty($order_service_package_detail)){
|
||
throw new BusinessException("im消息发送失败");
|
||
}
|
||
|
||
// 转换服务包订单类型为汉字
|
||
$order_type = orderServiceTypeToString($order_service_package['order_service_type']);
|
||
|
||
$start_time = date('Y年m月d日 H时i分',strtotime($order_service_package['start_time']));
|
||
$finish_time = date('Y年m月d日 H时i分',strtotime($order_service_package['finish_time']));
|
||
|
||
// 获取服务包当月剩余问诊次数
|
||
if ($order_service_package_detail['monthly_frequency'] != 0 && !empty($order_service_package['start_time'])) {
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$month_inquiry_count = $OrderServicePackageService->getCurrentMonthInquiryCount($order_service_package['pay_time'],$order_service_package['order_service_type'],$order_service_package['user_id'], $order_service_package['doctor_id']);
|
||
$remaining_inquiry_count = $order_service_package_detail['monthly_frequency'] - $month_inquiry_count;
|
||
if ($remaining_inquiry_count < 0){
|
||
$remaining_inquiry_count = 0;
|
||
}
|
||
}else{
|
||
$remaining_inquiry_count = "不限";
|
||
}
|
||
|
||
// 检测问诊是否服务包首次问诊
|
||
$is_first = $OrderServicePackageService->isFirstInquiryServicePackage($order_service_no);
|
||
if ($is_first){
|
||
$message_content_data['desc'] = "医生已接诊，{$order_type}服务开始，服务周期为：{$start_time}~{$finish_time}，线上咨询不能代表面诊，医生的回复仅为建议。";
|
||
}else{
|
||
// 健康包
|
||
if ($order_inquiry['inquiry_mode'] == 8){
|
||
$remaining_quantity = 0;
|
||
if ($order_service_package['order_service_type'] == 1){
|
||
// 获取服务包内所有药品
|
||
$health_package_products = $OrderServicePackageService->getOrderServiceProduct($order_service_package_detail['package_id']);
|
||
foreach ($health_package_products as $health_package_product) {
|
||
// 获取服务包内某一药品的剩余数量
|
||
$remaining_quantity = $OrderServicePackageService->getOrderServiceProductCanUseQuantity($order_service_package['order_service_id'],$health_package_product['product_id'],$health_package_product['quantity']);
|
||
}
|
||
}
|
||
|
||
if ($remaining_quantity > 0){
|
||
$message_content_data['desc'] = "医生已接诊，健康包服务本月剩余{$remaining_inquiry_count}次问诊，且还剩余{$remaining_quantity}盒肝爽颗粒，提醒医生开具处方。";
|
||
}else{
|
||
$message_content_data['desc'] = "医生已接诊，健康包服务本月剩余{$remaining_inquiry_count}次问诊，服务周期为：{$start_time}~{$finish_time}，线上咨询不能代表面诊，医生的回复仅为建议。";
|
||
}
|
||
}
|
||
|
||
// 随访包
|
||
if ($order_inquiry['inquiry_mode'] == 9){
|
||
$message_content_data['desc'] = "医生已接诊，{$order_type}服务本月剩余{$remaining_inquiry_count}次，服务周期为：{$start_time}~{$finish_time}，线上咨询不能代表面诊，医生的回复仅为建议。";
|
||
}
|
||
}
|
||
}else{
|
||
$message_content_data['desc'] = "医生已接诊，为提高沟通效率，您可一次性如实补充病情(具体症状,患病时长,用药情况及想咨询的问题等)。线上咨询不能代替面诊,医生建议仅供参考。";
|
||
}
|
||
|
||
$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
|
||
* @param string $patient_user_id
|
||
* @return void
|
||
*/
|
||
public function doctorUnInquiry(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
// 消息内容 医生-患者
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 1;
|
||
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
|
||
// 获取服务包订单编号-通过问诊订单id
|
||
$order_service_no = $OrderServicePackageService->getOrderServiceNoByOrderInquiryId($order_inquiry['inquiry_no']);
|
||
|
||
$params = array();
|
||
$params['order_service_no'] = $order_service_no;
|
||
$order_service_package = OrderServicePackage::getOne($params);
|
||
if (empty($order_service_package)){
|
||
throw new BusinessException("im消息发送失败");
|
||
}
|
||
|
||
// 转换服务包订单类型为汉字
|
||
$order_type = orderServiceTypeToString($order_service_package['order_service_type']);
|
||
|
||
// 检测问诊是否服务包首次问诊
|
||
$is_first = $OrderServicePackageService->isFirstInquiryServicePackage($order_service_no);
|
||
if ($is_first){
|
||
$message_content_data['title'] = "—医生未接诊—";
|
||
$message_content_data['desc'] = "温馨提示：医生因工作繁忙未能及时进行接诊，请您见谅。{$order_type}订单金额会在24小时内原路退回，感谢您的支持。";
|
||
}else{
|
||
$message_content_data['title'] = "—医生未接诊—";
|
||
$message_content_data['desc'] = "温馨提示：医生因工作繁忙未能及时进行接诊，请您见谅；稍后请再次发起问诊。";
|
||
}
|
||
}else{
|
||
$message_content_data['title'] = "—医生未接诊—";
|
||
$message_content_data['desc'] = "医生因工作繁忙未能及时接诊，请您谅解。所支付金额会在24小时内原路退回，再次感谢您的支持";
|
||
}
|
||
|
||
$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
|
||
* @param string $patient_user_id
|
||
* @param string $product_name
|
||
* @param string $order_prescription_id
|
||
* @param string|int $message_type 6/7
|
||
* @return void
|
||
*/
|
||
public function prescriptionIssued(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id, string $product_name, string $order_prescription_id, string|int $message_type): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
// 消息内容
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = $message_type;
|
||
$message_content_data['title'] = "处方已开具";
|
||
$message_content_data['desc'] = "";
|
||
$message_content_data['data']['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$message_content_data['data']['order_prescription_id'] = $order_prescription_id;
|
||
$message_content_data['data']['product_name'] = $product_name ?? "药品";
|
||
$message_content_data['data']['pharmacist_verify_time'] = date('Y-m-d H:i:s', time());
|
||
|
||
$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
|
||
* @return void
|
||
*/
|
||
public function inquiryRefund(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
// 消息内容 医生-患者
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 1;
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
|
||
// 获取服务包订单编号-通过问诊订单id
|
||
$order_service_no = $OrderServicePackageService->getOrderServiceNoByOrderInquiryId($order_inquiry['inquiry_no']);
|
||
|
||
// 检测问诊是否服务包首次问诊
|
||
$is_first = $OrderServicePackageService->isFirstInquiryServicePackage($order_service_no);
|
||
if ($is_first){
|
||
$message_content_data['title'] = "—服务退款—";
|
||
$message_content_data['desc'] = "平台已自动发起退款，请注意查看账户信息。";
|
||
}else{
|
||
$message_content_data['title'] = "—问诊退款—";
|
||
$message_content_data['desc'] = "平台已自动发起退款，请注意查看账户信息。";
|
||
}
|
||
}else{
|
||
$message_content_data['title'] = "—问诊退款—";
|
||
$message_content_data['desc'] = "平台已自动发起退款，请注意查看账户信息。";
|
||
}
|
||
|
||
$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
|
||
* @param string $patient_user_id
|
||
* @return void
|
||
*/
|
||
public function inquiryEndEvaluation(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id): void
|
||
{
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
// 消息内容 - 患者-医生
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 2; // 订单结束评价弹出
|
||
$message_content_data['desc'] = "";
|
||
$message_content_data['data']['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
|
||
$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);
|
||
}
|
||
|
||
/**
|
||
* 药师审核中
|
||
* @param array|object $order_inquiry
|
||
* @param string $order_prescription_id
|
||
* @param string $product_name
|
||
* @param string $doctor_user_id
|
||
* @param string $patient_user_id
|
||
* @return void
|
||
*/
|
||
public function pharmacistVerify(array|object $order_inquiry, string $order_prescription_id, string $product_name, string $doctor_user_id, string $patient_user_id): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
// 消息内容 医生-患者
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 6;
|
||
$message_content_data['title'] = "药师审核中";
|
||
$message_content_data['desc'] = "";
|
||
$message_content_data['data']['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$message_content_data['data']['order_prescription_id'] = $order_prescription_id;
|
||
$message_content_data['data']['product_name'] = $product_name ?: "药品";
|
||
$message_content_data['data']['pharmacist_verify_time'] = date('Y-m-d H:i:s', time());;
|
||
$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
|
||
* @return void
|
||
*/
|
||
public function inquiryFinish(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
// 消息内容 医生-患者
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 1;
|
||
$message_content_data['title'] = "—问诊已结束—";
|
||
$message_content_data['desc'] = "本次问诊服务已正式结束，祝您早日康复，再次感谢您的支持。";
|
||
$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
|
||
* @return void
|
||
*/
|
||
public function bannerNoticeNewInquiry(array|object $order_inquiry, string $doctor_user_id): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
if ($order_inquiry['inquiry_type'] == 1 || $order_inquiry['inquiry_type'] == 3) {
|
||
// 专家、公益
|
||
$desc = "24小时内未接诊，平台将自动取消问诊";
|
||
}else{
|
||
// 快速、购药
|
||
$desc = "5分钟内未接诊，平台将自动取消问诊";
|
||
}
|
||
|
||
// 消息内容
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 8;
|
||
$message_content_data['title'] = "您有一个新的问诊服务等待接诊";
|
||
$message_content_data['desc'] = $desc;
|
||
$message_content_data['data']['message_path'] = "/Pages/yishi/wenzhen_v2/wenzhen";
|
||
$message_content = [
|
||
'Data' => json_encode($message_content_data, JSON_UNESCAPED_UNICODE),
|
||
];
|
||
|
||
$this->sendMessage("", $doctor_user_id, $message_content, "TIMCustomElem", $cloud_custom_data);
|
||
} catch (\Exception $e) {
|
||
throw new BusinessException($e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 糖组检测报告
|
||
* @param array $data
|
||
* @return void
|
||
*/
|
||
public function detectionTestReport(array $data): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$data['order_inquiry_id'];
|
||
$cloud_custom_data['is_system'] = 1;
|
||
$cloud_custom_data['inquiry_type'] = $data['inquiry_type']; // 订单类型（1:专家问诊 2:快速问诊 3:公益问诊 4:问诊购药 5:检测）
|
||
$cloud_custom_data['inquiry_mode'] = $data['inquiry_mode'];
|
||
$cloud_custom_data['message_rounds'] = 0;
|
||
$cloud_custom_data['order_no'] = $data['detection_no'];
|
||
$cloud_custom_data['patient_family_data']['patient_name'] = $data['patient_name'];
|
||
$cloud_custom_data['patient_family_data']['patient_sex'] = $data['patient_sex'];
|
||
$cloud_custom_data['patient_family_data']['patient_age'] = $data['patient_age'];
|
||
|
||
// 消息内容
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 10;
|
||
$message_content_data['title'] = $data['detection_project_name'];
|
||
$message_content_data['desc'] = "";
|
||
$message_content_data['data']['order_no'] = (string)$data['detection_no'];
|
||
$message_content_data['data']['disease_class_names'] = $data['disease_class_names'];
|
||
$message_content_data['data']['detection_link'] = addAliyunOssWebsite($data['detection_result_pdf']);// 检测结果链接（oss）
|
||
$message_content_data['data']['message_path'] = "sugarCheck/pages/checkOrderDetail/checkOrderDetail?order_detection_id=" . $data['detection_no']; // 跳转地址（小程序内页）
|
||
$message_content = [
|
||
'Data' => json_encode($message_content_data, JSON_UNESCAPED_UNICODE),
|
||
];
|
||
|
||
$this->sendMessage($data['patient_user_id'],$data['doctor_user_id'], $message_content, "TIMCustomElem", $cloud_custom_data);
|
||
|
||
} catch (\Throwable $e) {
|
||
throw new BusinessException($e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 糖组检测报告-文字
|
||
* @param array $data
|
||
* @return void
|
||
*/
|
||
public function detectionTestReportStr(array $data): void
|
||
{
|
||
try {
|
||
// 消息内容
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$data['order_inquiry_id'];
|
||
$cloud_custom_data['is_system'] = 1;
|
||
$cloud_custom_data['inquiry_type'] = $data['inquiry_type']; // 订单类型（1:专家问诊 2:快速问诊 3:公益问诊 4:问诊购药 5:检测）
|
||
$cloud_custom_data['inquiry_mode'] = $data['inquiry_mode'];
|
||
$cloud_custom_data['message_rounds'] = 0;
|
||
$cloud_custom_data['order_no'] = $data['detection_no'];
|
||
$cloud_custom_data['patient_family_data']['patient_name'] = $data['patient_name'];
|
||
$cloud_custom_data['patient_family_data']['patient_sex'] = $data['patient_sex'];
|
||
$cloud_custom_data['patient_family_data']['patient_age'] = $data['patient_age'];
|
||
|
||
$message_content = [
|
||
'Text' => $data['doctor_name'] . "医生您好，您给我开具的【" . $data['detection_project_name'] . "】检测项目报告已经出来啦，请您抽空查看报告并做一下解读，谢谢。",
|
||
];
|
||
|
||
$this->sendMessage($data['patient_user_id'],$data['doctor_user_id'], $message_content, "TIMTextElem", $cloud_custom_data);
|
||
|
||
} catch (\Throwable $e) {
|
||
throw new BusinessException($e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 患者病例
|
||
* @param array|object $order_inquiry
|
||
* @param string $doctor_user_id
|
||
* @param string|null $disease_desc
|
||
* @return void
|
||
*/
|
||
public function patientCase(array|object $order_inquiry, string $doctor_user_id,string|null $disease_desc = ""): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
// 消息内容
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 11;
|
||
$message_content_data['title'] = "患者信息";
|
||
$message_content_data['desc'] = "";
|
||
$message_content_data['data']['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$message_content_data['data']['disease_desc'] = $disease_desc ?: "";
|
||
$message_content_data['data']['message_path'] = "user/pages/case/index?order_inquiry_id=" . $order_inquiry['order_inquiry_id']; // 跳转地址（小程序内页）
|
||
$message_content = [
|
||
'Data' => json_encode($message_content_data, JSON_UNESCAPED_UNICODE),
|
||
];
|
||
|
||
$this->sendMessage($doctor_user_id, $order_inquiry['user_id'], $message_content, "TIMCustomElem", $cloud_custom_data);
|
||
|
||
} catch (\Throwable $e) {
|
||
throw new BusinessException($e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 问诊表-发送患者
|
||
* @param array|object $order_inquiry 问诊表数据
|
||
* @param string|int $doctor_user_id 医生用户id
|
||
* @param string|int $patient_user_id 患者用户id
|
||
* @param string $case_fields 医生选择需填写的病例字段
|
||
* @return void
|
||
*/
|
||
public function CaseUnfilledFieldsToPatient(array|object $order_inquiry,string|int $doctor_user_id,string|int $patient_user_id,string $case_fields): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
// 消息内容
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 12;
|
||
$message_content_data['title'] = "问诊表";
|
||
$message_content_data['desc'] = "";
|
||
$message_content_data['data']['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$message_content_data['data']['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$message_content_data['data']['message_path'] = "patient/pages/sickForm/sickForm"; // 跳转地址（小程序内页）
|
||
$message_content_data['data']['case_not_fill_fields'] = $case_fields; // 病例字段，json格式，医生端发送患者端使用（此字段仅针对message_type为12的情况）
|
||
$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 (\Throwable $e) {
|
||
throw new BusinessException($e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 问诊表-发送医生
|
||
* @param array|object $order_inquiry 问诊表数据
|
||
* @param string|int $doctor_user_id 医生用户id
|
||
* @param string|int $patient_user_id 患者用户id
|
||
* @param string $case_fields 患者填写的病例字段
|
||
* @return void
|
||
*/
|
||
public function CaseUnfilledFieldsToDoctor(array|object $order_inquiry,string|int $doctor_user_id,string|int $patient_user_id,string $case_fields): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
// 消息内容
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 12;
|
||
$message_content_data['title'] = "问诊表-已填写";
|
||
$message_content_data['desc'] = "";
|
||
$message_content_data['data']['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$message_content_data['data']['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$message_content_data['data']['message_path'] = "user/pages/sick_detail/index"; // 跳转地址（小程序内页）
|
||
$message_content_data['data']['case_patient_message_path'] = "/patient/sickDetail/sickDetail"; // 跳转地址（小程序内页）
|
||
$message_content_data['data']['case_filled_fields'] = $case_fields; // 病例字段，json格式，患者端发送医生端使用（此字段仅针对message_type为12的情况）
|
||
$message_content = [
|
||
'Data' => json_encode($message_content_data, JSON_UNESCAPED_UNICODE),
|
||
];
|
||
|
||
$this->sendMessage($patient_user_id, $doctor_user_id, $message_content, "TIMCustomElem", $cloud_custom_data);
|
||
|
||
} catch (\Throwable $e) {
|
||
throw new BusinessException($e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 赠送回合数消息
|
||
* @param array|object $order_inquiry 问诊表数据
|
||
* @param string|int $doctor_user_id 医生用户id
|
||
* @param string|int $patient_user_id 患者用户id
|
||
* @param string $times_number 沟通次数（0为不限制次数）
|
||
* @param string $give_expiration_time 赠送到期时间
|
||
* @return void
|
||
*/
|
||
public function giveFreeRounds(array|object $order_inquiry, string|int $doctor_user_id, string|int $patient_user_id, string $times_number, string $give_expiration_time): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
|
||
// 消息内容
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 13;
|
||
$message_content_data['title'] = "";
|
||
$message_content_data['desc'] = "医生已赠送" . "<span class= " . '"tipRoundsColor"' . ">" . $times_number . "个" . "</span>沟通回合数，将在" . "<span class= " . '"tipRoundsColor"' . ">" . $give_expiration_time . "</span>失效 ，如有需要请尽快给医生留言。";
|
||
$message_content_data['data']['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$message_content_data['data']['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$message_content_data['data']['times_number'] = $times_number;
|
||
$message_content_data['data']['give_expiration_time'] = $give_expiration_time;
|
||
$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 (\Throwable $e) {
|
||
throw new BusinessException($e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 订单结束，提醒赠送回合数-发送医生
|
||
* @param array|object $order_inquiry 问诊订单数据
|
||
* @param string $doctor_user_id 医生用户id
|
||
* @param string $patient_user_id 患者用户id
|
||
* @return void
|
||
*/
|
||
public function remindGiveFreeRounds(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
// 消息内容 医生-患者
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 14;
|
||
$message_content_data['title'] = "";
|
||
$message_content_data['desc'] = "点击更多选择【赠送沟通】，您可以赠送患者沟通回合数。";
|
||
$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 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'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'] = "您和患者已约定于" . "<span class= " . '"tipColor"' . ">" . $date . "</span>进行视频问诊，请提前进入聊天页面，在约定时间发起视频";
|
||
$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'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'] = "您和患者重新约定于" . "<span class= " . '"tipColor"' . ">" . $date . "</span>进行视频问诊，请提前进入聊天页面，再约定时间发起视频";
|
||
$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'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'] = "您和医生已约定于" . "<span class= " . '"tipColor"' . ">" . $date . "</span>进行视频问诊，请提前进入聊天页面，准备接听。";
|
||
$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'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'] = "您和医生重新约定于" . "<span class= " . '"tipColor"' . ">" . $date . "</span>进行视频问诊，请提前进入聊天页面，准备接听。";
|
||
$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
|
||
* @return void
|
||
*/
|
||
public function multiPointDoctorInquiryAutoReply(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id): void
|
||
{
|
||
try {
|
||
// 发送消息
|
||
$cloud_custom_data = array();
|
||
$cloud_custom_data['order_inquiry_id'] = (string)$order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['order_no'] = (string)$order_inquiry['inquiry_no'];
|
||
$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'];
|
||
if ($order_inquiry['inquiry_mode'] == 8 || $order_inquiry['inquiry_mode'] == 9){
|
||
// 获取im消息推送中，服务包订单相关的自定义参数
|
||
$OrderServicePackageService = new OrderServicePackageService();
|
||
$result = $OrderServicePackageService->getImServicePackageCloudCustomData($order_inquiry['inquiry_no']);
|
||
if (!empty($result)){
|
||
$cloud_custom_data = array_merge($cloud_custom_data,$result);
|
||
}
|
||
}
|
||
|
||
$message_content = [
|
||
'Text' => "您好，已查看您提交的病情信息，您可以继续补充病情信息以便更好为您提供服务。如有购药需求，将按照病情及需要开具处方，需要您确认。",
|
||
];
|
||
|
||
$this->sendMessage($doctor_user_id, $patient_user_id, $message_content, "TIMTextElem", $cloud_custom_data);
|
||
} catch (\Throwable $e) {
|
||
throw new BusinessException($e->getMessage());
|
||
}
|
||
}
|
||
} |