gdxz/hospital-applets-api
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新增患者的问诊服务结束通知，修改问诊结束的消息通知为单独try catch

Browse Source
This commit is contained in:
wucongxing 2023-04-23 15:11:05 +08:00
parent 0a3f4ae13c
commit 4890eea107
2 changed files with 20 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/Controller/TestController.php
View File

@ -39,6 +39,7 @@ use Extend\RegulatoryPlatform\regulatoryPlatform;
use Extend\TencentIm\RecentContact; use Extend\TencentIm\RecentContact;
use Hyperf\Amqp\Producer; use Hyperf\Amqp\Producer;
use Hyperf\DbConnection\Db; use Hyperf\DbConnection\Db;
use Hyperf\Redis\Redis;
use Hyperf\Utils\ApplicationContext; use Hyperf\Utils\ApplicationContext;
use Hyperf\Utils\Coroutine\Concurrent; use Hyperf\Utils\Coroutine\Concurrent;
use Imagick; use Imagick;
@ -800,9 +801,6 @@ class TestController extends AbstractController
} }
public function test_15(){ public function test_15(){
Log::getInstance("auto-pharmacist-ca-verify-queue")->info("ninhao");
dump(111);die;
$wg = new \Hyperf\Utils\WaitGroup(); $wg = new \Hyperf\Utils\WaitGroup();
$channel = new Channel(); $channel = new Channel();
$wg->add(2); $wg->add(2);

30
app/Services/InquiryService.php
View File

@ -867,17 +867,6 @@ class InquiryService extends BaseService
return fail(HttpEnumCode::SERVER_ERROR, "添加患者历史问诊表失败"); return fail(HttpEnumCode::SERVER_ERROR, "添加患者历史问诊表失败");
} }
// 发送IM消息-问诊已结束
$imService = new ImService();
$imService->inquiryEnd($order_inquiry,$user_doctor['user_id'],$order_inquiry['user_id']);
// 发送IM消息-问诊结束评价通知
$imService->inquiryEndEvaluation($order_inquiry,$user_doctor['user_id'],$order_inquiry['user_id']);
// 发送站内消息-问诊结束
$MessagePush = new MessagePush($user_doctor['user_id'],$order_inquiry['order_inquiry_id']);
$MessagePush->finishInquiryToDoctor();
// 添加自动完成队列 // 添加自动完成队列
$data = array(); $data = array();
$data['order_inquiry_id'] = $order_inquiry['order_inquiry_id']; $data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
@ -896,6 +885,25 @@ class InquiryService extends BaseService
return fail(HttpEnumCode::SERVER_ERROR, $e->getMessage()); return fail(HttpEnumCode::SERVER_ERROR, $e->getMessage());
} }
try {
// 发送IM消息-问诊已结束
$imService = new ImService();
$imService->inquiryEnd($order_inquiry,$user_doctor['user_id'],$order_inquiry['user_id']);
// 发送IM消息-问诊结束评价通知
$imService->inquiryEndEvaluation($order_inquiry,$user_doctor['user_id'],$order_inquiry['user_id']);
// 医生-发送通知消息-问诊结束
$MessagePush = new MessagePush($user_doctor['user_id'],$order_inquiry['order_inquiry_id']);
$MessagePush->finishInquiryToDoctor();
// 患者-发送通知消息-患者的问诊服务结束
$MessagePush = new MessagePush($order_inquiry['user_id'],$order_inquiry['order_inquiry_id']);
$MessagePush->patientInquiryFinish();
}catch(\Exception $e){
return success([],HttpEnumCode::HTTP_SUCCESS,"消息发送失败");
}
return success(); return success();
} }