452 lines
21 KiB
PHP
452 lines
21 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\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', "ForbidAfterSendMsgCallback"];
|
||
$arg['SendMsgControl'] = ['NoUnread'];
|
||
|
||
$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 inquiryEnd(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id): 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['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'] = 8;
|
||
$message_content_data['title'] = "--问诊已结束--";
|
||
$message_content_data['desc'] = "线上咨询不能代替问诊，医生的回复仅为建议。";
|
||
$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);
|
||
|
||
// 消息内容 医生-患者
|
||
$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'] = $order_inquiry['order_inquiry_id'];
|
||
$cloud_custom_data['is_system'] = 1;
|
||
$cloud_custom_data['inquiry_type'] = $order_inquiry['inquiry_type'];
|
||
$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'] = 8;
|
||
$message_content_data['title'] = "--等待医生接诊--";
|
||
|
||
if ($order_inquiry['inquiry_type'] == 1){
|
||
$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'] = "温馨提示：当前服务为公益问诊，可以在24小时内和医生沟通10个回合。医生均为一线工作，还请耐心等待，医生接诊会第一时间短信通知您。";
|
||
}
|
||
|
||
$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);
|
||
|
||
// 消息内容 医生-患者
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 1;
|
||
$message_content_data['title'] = "--等待医生接诊--";
|
||
if ($order_inquiry['inquiry_type'] == 1){
|
||
$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'] = "温馨提示：当前服务为公益问诊，可以在24小时内和医生沟通10个回合。医生均为一线工作，还请耐心等待，医生接诊会第一时间短信通知您。";
|
||
}
|
||
$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 doctorInquiry(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id): 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['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'] = 8;
|
||
|
||
if ($order_inquiry['inquiry_type'] == 1){
|
||
$message_content_data['title'] = "--问诊已开始，本次问诊可持续24小时--";
|
||
$message_content_data['desc'] = "医生已接诊，您可继续补充问诊内容，如目前症状、患病时长、检查及用药情况、需要的帮助等，线上咨询不能代表面诊，医生的回复仅为建议。";
|
||
} elseif ($order_inquiry['inquiry_type'] == 2){
|
||
$message_content_data['title'] = "--问诊已开始，本次问诊可持续60分钟--";
|
||
$message_content_data['desc'] = "医生已接诊，您可继续补充问诊内容，如目前症状、患病时长、检查及用药情况、需要的帮助等，线上咨询不能代表面诊，医生的回复仅为建议。";
|
||
} elseif ($order_inquiry['inquiry_type'] == 3){
|
||
$message_content_data['title'] = "--问诊已开始，本次问诊可持续24小时--";
|
||
$message_content_data['desc'] = "医生已接诊，您可一次描述需要问诊的内容，以免浪费问诊次数，如目前症状、患病时长、检查及用药情况、需要的帮助等，线上咨询不能代表面诊，医生的回复仅为建议。";
|
||
} elseif ($order_inquiry['inquiry_type'] == 4){
|
||
$message_content_data['title'] = "--问诊已开始，本次问诊可持续30分钟--";
|
||
$message_content_data['desc'] = "医生已接诊，您可继续补充问诊内容，如目前症状、患病时长、检查及用药情况、需要的帮助等，线上咨询不能代表面诊，医生的回复仅为建议。";
|
||
}
|
||
|
||
$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);
|
||
|
||
// 消息内容 医生-患者
|
||
$message_content_data = array();
|
||
$message_content_data['message_type'] = 1;
|
||
|
||
if ($order_inquiry['inquiry_type'] == 1){
|
||
$message_content_data['title'] = "--问诊已开始，本次问诊可持续24小时--";
|
||
$message_content_data['desc'] = "医生已接诊，您可继续补充问诊内容，如目前症状、患病时长、检查及用药情况、需要的帮助等，线上咨询不能代表面诊，医生的回复仅为建议。";
|
||
} elseif ($order_inquiry['inquiry_type'] == 2){
|
||
$message_content_data['title'] = "--问诊已开始，本次问诊可持续60分钟--";
|
||
$message_content_data['desc'] = "医生已接诊，您可继续补充问诊内容，如目前症状、患病时长、检查及用药情况、需要的帮助等，线上咨询不能代表面诊，医生的回复仅为建议。";
|
||
} elseif ($order_inquiry['inquiry_type'] == 3){
|
||
$message_content_data['title'] = "--问诊已开始，本次问诊可持续24小时--";
|
||
$message_content_data['desc'] = "医生已接诊，您可一次描述需要问诊的内容，以免浪费问诊次数，如目前症状、患病时长、检查及用药情况、需要的帮助等，线上咨询不能代表面诊，医生的回复仅为建议。";
|
||
} elseif ($order_inquiry['inquiry_type'] == 4){
|
||
$message_content_data['title'] = "--问诊已开始，本次问诊可持续30分钟--";
|
||
$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());
|
||
}
|
||
}
|
||
} |