修正无医生数据

2023-03-09 18:35:13 +08:00
parent f8e60425f4
commit bd49332f64
9 changed files with 335 additions and 45 deletions
@@ -5,10 +5,14 @@ declare(strict_types=1);
 namespace App\Amqp\Consumer;

 use App\Model\OrderInquiry;
+use App\Model\UserDoctor;
+use App\Services\ImService;
 use App\Services\InquiryService;
 use App\Services\UserDoctorService;
 use App\Utils\Log;
+use Extend\TencentIm\Message;
 use Extend\Wechat\WechatPay;
+use GuzzleHttp\Exception\GuzzleException;
 use Hyperf\Amqp\Result;
 use Hyperf\Amqp\Annotation\Consumer;
 use Hyperf\Amqp\Message\ConsumerMessage;
@@ -29,6 +33,7 @@ class AssignDoctorConsumer extends ConsumerMessage
    /**
     * @throws ContainerExceptionInterface
     * @throws NotFoundExceptionInterface
+     * @throws GuzzleException
     */
    public function consumeMessage($data, AMQPMessage $message): string
    {
@@ -166,12 +171,65 @@ class AssignDoctorConsumer extends ConsumerMessage
            Db::commit();
            Log::getInstance()->error("分配医生 队列执行成功");

-            // 加入消息通知队列
-            return Result::ACK;
        } catch (\Exception $e) {
            Db::rollBack();
            Log::getInstance()->error("队列执行失败原因：" . $e->getMessage());
            return Result::REQUEUE; // 重回队列
        }
+
+        try {
+            // 专家-公益
+            $ImService = new ImService();
+
+            // 检测并创建患者账号
+            $ImService->createAccount($order_inquiry['user_id']);
+
+            // 获取订单医生数据
+            $params = array();
+            $params['doctor_id'] = $doctor_id;
+            $user_doctor = UserDoctor::getOne($params);
+            if (empty($user_doctor)){
+                Log::getInstance()->info("医生数据错误");
+                return Result::ACK;
+            }
+
+            // 检测并创建医生账号
+            $ImService->createAccount($doctor_id);
+
+            // 医生给患者发送消息
+            $message = new Message();
+
+            $arg = array();
+            $arg['From_Account'] = $user_doctor['user_id']; // 发送方user_id 如系统发送，无需填写
+            $arg['To_Account'] = $order_inquiry['user_id']; // 接收方user_id
+
+            $arg['MsgBody'] = [
+                [
+                    "MsgType" => "TIMTextElem",
+                    "MsgContent" => [
+                        "Text" => "等待医生接诊",
+                    ],
+                ]
+            ];
+
+            // 自定义消息
+            $cloud_custom_data = array();
+            $cloud_custom_data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
+            $cloud_custom_data['inquiry_type'] = $order_inquiry['inquiry_type'];
+            $cloud_custom_data['message_type'] = 1;//1：系统发送 其余：用户发送
+
+            $arg['CloudCustomData'] = json_encode($cloud_custom_data,JSON_UNESCAPED_UNICODE);
+
+            $message->sendMessage($arg);
+
+        }catch (\Exception $e) {
+            // 验证失败
+            Log::getInstance()->error("分配医生成功，发送系统问诊消息失败:" . $e->getMessage());
+            // 加入消息通知队列
+            return Result::ACK;
+        }
+
+        // 加入消息通知队列
+        return Result::ACK;
    }
 }
@@ -135,4 +135,21 @@ function addAliyunOssWebsite($path): string
        return "";
    }
    return config('alibaba.oss.custom_domain_name') . '/' . $path;
+}
+
+/**
+ * 转换性别至im识别的性别
+ * @param string|int $sex
+ * @return string
+ */
+function sexToImSex(string|int $sex): string
+{
+    $result = "Gender_Type_Unknown";
+    if ($sex == 1){
+        $result = "Gender_Type_Male";
+    }elseif ($sex == 2){
+        $result = "Gender_Type_Female";
+    }
+
+    return $result;
 }
@@ -3,11 +3,19 @@
 namespace App\Controller;

 use App\Amqp\Producer\AssignDoctorProducer;
+use App\Constants\DoctorTitleCode;
 use App\Constants\HttpEnumCode;
 use App\Exception\BusinessException;
+use App\Model\Hospital;
 use App\Model\OrderInquiry;
+use App\Model\UserDoctor;
+use App\Model\UserPatient;
 use App\Services\BaseService;
+use App\Services\ImService;
 use App\Utils\Log;
+use Extend\TencentIm\Account;
+use Extend\TencentIm\Message;
+use Extend\TencentIm\Profile;
 use Extend\Wechat\WechatPay;
 use Hyperf\Amqp\Producer;
 use Hyperf\DbConnection\Db;
@@ -25,8 +33,6 @@ class CallBackController extends AbstractController
     */
    public function wxPaySuccessCallBack(): ResponseInterface
    {
-        Db::beginTransaction();
-
        try {
            // 处理支付结果事件
            $WechatPay = new WechatPay(1);
@@ -35,7 +41,6 @@ class CallBackController extends AbstractController

            $message = $server->getRequestMessage();
            if (empty($message)){
-                Db::rollBack();
                return $this->response->withStatus(500)->withBody(new SwooleStream(strval(json_encode(['code' => 'ERROR', 'message' => "回调数据为空"], JSON_UNESCAPED_UNICODE))));
            }

@@ -45,7 +50,6 @@ class CallBackController extends AbstractController
            Log::getInstance()->info("微信支付回调数据：" . json_encode($message->toArray(),JSON_UNESCAPED_UNICODE));

            if (empty($message['out_trade_no'])){
-                Db::rollBack();
                Log::getInstance()->info("微信支付回调数据错误");
                return $server->serve();
            }
@@ -55,7 +59,6 @@ class CallBackController extends AbstractController
            $params['inquiry_no'] = $message['out_trade_no'];
            $order_inquiry = OrderInquiry::getOne($params);
            if (empty($order_inquiry)){
-                Db::rollBack();
                Log::getInstance()->info("非法订单");
                return $server->serve();
            }
@@ -63,7 +66,6 @@ class CallBackController extends AbstractController
            // 验证订单状态
            if ($order_inquiry['inquiry_status'] != 1){
                // 问诊订单状态（1:待支付 2:待分配 3:待接诊 4:已接诊 5:已完成 6:已结束 7:已取消）
-                Db::rollBack();
                Log::getInstance()->info("订单状态错误：当前为" . $order_inquiry['inquiry_status']);
                return $server->serve();
            }
@@ -103,8 +105,13 @@ class CallBackController extends AbstractController
            $params = array();
            $params['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
            OrderInquiry::edit($params,$data);
+        }catch (\Exception $e) {
+            // 验证失败
+            Log::getInstance()->error("微信支付回调数据验证失败:" . $e->getMessage());
+            return $this->wxPayErrorReturn($e->getMessage());
+        }

-            // 处理分配医生问题
+        try {
            if ($message['trade_state'] == "SUCCESS"){
                if ($order_inquiry['inquiry_type'] == 2 || $order_inquiry['inquiry_type'] == 4){
                    // 快速-购药
@@ -116,27 +123,62 @@ class CallBackController extends AbstractController
                    $producer = ApplicationContext::getContainer()->get(Producer::class);
                    $result = $producer->produce($message);
                    if (!$result) {
-                        Db::rollBack();
                        Log::getInstance()->info("加入分配医生队列失败");
-                        return $this->wxPayErrorReturn("加入分配医生队列失败");
+                        return $server->serve();
                    }
                }elseif ($order_inquiry['inquiry_type'] == 1 || $order_inquiry['inquiry_type'] == 3){
                    // 专家-公益
-                    // 创建患者im账号
-                    // 检测医生im账号
-                    // 患者给医生发送im问诊消息
-                    // 消息订阅通知队列
+                    $ImService = new ImService();
+
+                    // 检测并创建患者账号
+                    $ImService->createAccount($order_inquiry['user_id']);
+
+                    // 获取订单医生数据
+                    $params = array();
+                    $params['doctor_id'] = $order_inquiry['doctor_id'];
+                    $user_doctor = UserDoctor::getOne($params);
+                    if (empty($user_doctor)){
+                        Log::getInstance()->info("医生数据错误");
+                        return $server->serve();
+                    }
+
+                    // 检测并创建医生账号
+                    $ImService->createAccount($user_doctor['user_id']);
+
+                    // 医生给患者发送消息
+                    $message = new Message();
+
+                    $arg = array();
+                    $arg['From_Account'] = $user_doctor['user_id']; // 发送方user_id 如系统发送，无需填写
+                    $arg['To_Account'] = $order_inquiry['user_id']; // 接收方user_id
+
+                    $arg['MsgBody'] = [
+                        [
+                            "MsgType" => "TIMTextElem",
+                            "MsgContent" => [
+                                "Text" => "等待医生接诊",
+                            ],
+                        ]
+                    ];
+
+                    // 自定义消息
+                    $cloud_custom_data = array();
+                    $cloud_custom_data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
+                    $cloud_custom_data['inquiry_type'] = $order_inquiry['inquiry_type'];
+                    $cloud_custom_data['message_type'] = 1;//1：系统发送 其余：用户发送
+
+                    $arg['CloudCustomData'] = json_encode($cloud_custom_data,JSON_UNESCAPED_UNICODE);
+
+                    $message->sendMessage($arg);
                }
            }
-
-            Db::commit();
-            return $server->serve();
        }catch (\Exception $e) {
            // 验证失败
-            Db::rollBack();
-            Log::getInstance()->error("微信支付回调数据验证失败:" . $e->getMessage());
-            return $this->wxPayErrorReturn($e->getMessage());
+            Log::getInstance()->error("微信支付回调数据处理成功,发送系统问诊消息失败:" . $e->getMessage());
+            return $server->serve();
        }
+
+        return $server->serve();
    }

    public function wxPayRefundCallBack(): ResponseInterface
@@ -125,7 +125,7 @@ class UserController extends AbstractController
        $group = new Group();
        $friend = new Friend();
        $message = new Message();
-//        $result = $account->createAccount(1234567,'测试患者',"https://img.applets.igandanyiyuan.com/applet/doctor/avatar/03dc8df2-e7c0-4ad9-b87e-5133e40e0f76.jpg");
+        $result = $account->createAccount(10009,'测试患者9',"https://img.applets.igandanyiyuan.com/applet/doctor/avatar/03dc8df2-e7c0-4ad9-b87e-5133e40e0f76.jpg");

        // 查询账号导入状态
 //        $result = $account->checkAccountStatus("123456");
@@ -148,21 +148,23 @@ class UserController extends AbstractController
 //        $result = $friend->addFriend("123456",'1234567',"快速问诊");

        // 发送消息
-        $arg = array();
-        $arg['From_Account'] = "1234567"; // 发送方user_id 如系统发送，无需填写
-        $arg['To_Account'] = "123456"; // 接收方user_id
-        $arg['ForbidCallbackControl'] = ['ForbidBeforeSendMsgCallback'];
+//        $arg = array();
+//        $arg['From_Account'] = "1234567"; // 发送方user_id 如系统发送，无需填写
+//        $arg['To_Account'] = "123456"; // 接收方user_id
+//        $arg['ForbidCallbackControl'] = ['ForbidBeforeSendMsgCallback'];
+//
+//        $arg['MsgBody'] = [
+//            [
+//                "MsgType" => "TIMTextElem",
+//                "MsgContent" => [
+//                    "Text" => "测试消息1",
+//                ],
+//            ]
+//        ];
+//
+//        $result = $message->sendMessage($arg);

-        $arg['MsgBody'] = [
-            [
-                "MsgType" => "TIMTextElem",
-                "MsgContent" => [
-                    "Text" => "测试消息1",
-                ],
-            ]
-        ];
-
-        $result = $message->sendMessage($arg);
+        $result = $profile->getOneAccountPortraitList("123456");
        dump($result);


@@ -0,0 +1,123 @@
+<?php
+
+namespace App\Services;
+
+use App\Constants\DoctorTitleCode;
+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\Profile;
+use GuzzleHttp\Exception\GuzzleException;
+
+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("用户数据错误");
+            }
+
+            if ($user['user_type'] == 1){
+                // 患者
+                $params = array();
+                $params['user_id'] = $user['user_id'];
+                $user_patient = UserPatient::getOne($params);
+                if (empty($user_patient)){
+                    throw new BusinessException("患者数据错误");
+                }
+
+                $avatar = addAliyunOssWebsite($user_patient['avatar']);
+                $user_name = $user_patient['user_name'];
+            }elseif ($user['user_type'] == 2){
+                // 医生
+                $params = array();
+                $params['user_id'] = $user['user_id'];
+                $user_doctor = UserDoctor::getOne($params);
+                if (empty($user_doctor)){
+                    throw new BusinessException("医生数据错误");
+                }
+
+                $avatar = addAliyunOssWebsite($user_doctor['avatar']);
+                $user_name = $user_doctor['user_name'];
+            }elseif ($user['user_type'] == 3){
+                // 药师
+                $params = array();
+                $params['user_id'] = $user['user_id'];
+                $user_pharmacist = UserPharmacist::getOne($params);
+                if (empty($user_pharmacist)){
+                    throw new BusinessException("药师数据错误");
+                }
+
+                $avatar = addAliyunOssWebsite($user_pharmacist['avatar']);
+                $user_name = $user_pharmacist['user_name'];
+            }
+
+            $account = new Account();
+            // 查询账号导入状态
+            $res = $account->checkAccountStatus($user_patient['user_id']);
+            if (!$res){
+
+                // 创建单个账号
+                $account->createAccount($user_id,$user_name,$avatar);
+            }
+
+            // 医生检测并设置资料
+            if ($user['user_type'] == 2){
+                // 检测用户资料
+                $profile = new Profile();
+                $result = $profile->getOneAccountPortraitList("123456");
+                if (!empty($result)){
+                    // 获取订单医生医院
+                    $params = array();
+                    $params['hospital_id'] = $user_doctor['hospital_id'];
+                    $hospital = Hospital::getOne($params);
+                    if (empty($hospital)){
+                        throw new BusinessException("医生医院数据错误");
+                    }
+
+                    // 设置用户资料
+                    $arg = array();
+                    // 性别
+                    if (in_array('Tag_Profile_IM_Gender',$result)){
+                        $arg['Tag_Profile_IM_Gender'] = sexToImSex($user_doctor['sex']);
+                    }
+
+                    // 医院
+                    if (in_array('Tag_Profile_Custom_Hname',$result)){
+                        $arg['Tag_Profile_Custom_Hname'] = $hospital['hospital'];
+                    }
+
+                    // 职称
+                    if (in_array('Tag_Profile_Custom_Hname',$result)){
+                        $arg['Tag_Profile_Custom_Title'] = $user_doctor['doctor_title'] ?? DoctorTitleCode::getMessage($user_doctor['doctor_title']);
+                    }
+
+                    if (!empty($arg)){
+                        $profile->setProfile($user_doctor['user_id'],$arg);
+                    }
+                }
+            }
+
+            return true;
+        } catch (\Exception $e) {
+            throw new BusinessException($e->getMessage());
+        }
+
+    }
+
+}
@@ -493,8 +493,8 @@ class PatientDoctorService extends BaseService
            $data['is_online'] = $recommend_doctor['is_online'];
            $data['is_img_welfare_reception'] = $recommend_doctor['is_img_welfare_reception'];
            $data['be_good_at'] = $recommend_doctor['be_good_at'];
-            $data['hospital_name'] = $recommend_doctor['Hospital']['hospital_name'];
-            $data['hospital_level_name'] = $recommend_doctor['Hospital']['hospital_level_name'];
+            $data['hospital_name'] = $recommend_doctor['Hospital']['hospital_name'] ?? "";
+            $data['hospital_level_name'] = $recommend_doctor['Hospital']['hospital_level_name'] ?? "";

            // 处理接诊价格
            $data['price'] = 0;