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

修改了 未接诊取消订单延迟队列、加入xx时间未接诊通知队列的时间判断

Browse Source
This commit is contained in:
wucongxing8150 2024-05-06 14:01:58 +08:00
parent 51fa86fd4e
commit dee389f10d
1 changed files with 26 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
app/Services/OrderServicePackageService.php
View File

@ -731,6 +731,10 @@ class OrderServicePackageService extends BaseService
if (empty($system_inquiry_config)) { if (empty($system_inquiry_config)) {
return fail(HttpEnumCode::SERVER_ERROR, "订单创建失败"); return fail(HttpEnumCode::SERVER_ERROR, "订单创建失败");
} }
// 检测问诊是否服务包首次问诊
$OrderServicePackageService = new OrderServicePackageService();
$is_first = $OrderServicePackageService->isFirstInquiryServicePackage($order_no);
}catch (\Throwable $e){ }catch (\Throwable $e){
return fail(HttpEnumCode::HTTP_ERROR, $e->getMessage()); return fail(HttpEnumCode::HTTP_ERROR, $e->getMessage());
} }
@ -925,10 +929,17 @@ class OrderServicePackageService extends BaseService
} }
// 加入未接诊取消订单延迟队列 // 加入未接诊取消订单延迟队列
if ($is_first){
$time = 60 * 60 * 72; $time = 60 * 60 * 72;
if (\Hyperf\Config\config('app_env') == "dev"){ if (\Hyperf\Config\config('app_env') == "dev"){
$time = 60 * 10; $time = 60 * 10;
} }
}else{
$time = 60 * 60 * 24;
if (\Hyperf\Config\config('app_env') == "dev"){
$time = 60 * 10;
}
}
$data = array(); $data = array();
$data['order_inquiry_id'] = $order_inquiry['order_inquiry_id']; $data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
@ -964,25 +975,29 @@ class OrderServicePackageService extends BaseService
// 等待医生接诊 // 等待医生接诊
$imService->waitDoctorInquiry($order_inquiry, $user_doctor['user_id'], $order_inquiry['user_id']); $imService->waitDoctorInquiry($order_inquiry, $user_doctor['user_id'], $order_inquiry['user_id']);
// 检测问诊是否服务包首次问诊
$OrderServicePackageService = new OrderServicePackageService();
$is_first = $OrderServicePackageService->isFirstInquiryServicePackage($order_no);
if ($is_first){ if ($is_first){
// 首次 // 首次
// 发送站内、订阅失败发送短信消息-医生有新服务包订单 // 发送站内、订阅失败发送短信消息-医生有新服务包订单
$MessagePush = new MessagePush($user_doctor['user_id'], $order_inquiry['inquiry_no']); $MessagePush = new MessagePush($user_doctor['user_id'], $order_inquiry['inquiry_no']);
$MessagePush->doctorHaveNewServicePackage(); $MessagePush->doctorHaveNewServicePackage();
}else{
// 发送站内、订阅失败-医生有新的服务包问诊订单
$MessagePush = new MessagePush($user_doctor['user_id'], $order_inquiry['inquiry_no']);
$MessagePush->doctorHaveNewServicePackageInquiry();
}
// 加入xx时间未接诊通知队列 // 加入xx时间未接诊通知队列
$data = array(); $data = array();
$data['order_inquiry_id'] = $order_inquiry['order_inquiry_id']; $data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
$time = 1000 * 60 * 60 * 24; $time = 1000 * 60 * 60 * 24;
}else{
// 发送站内、订阅失败-医生有新的服务包问诊订单
$MessagePush = new MessagePush($user_doctor['user_id'], $order_inquiry['inquiry_no']);
$MessagePush->doctorHaveNewServicePackageInquiry();
// 加入xx时间未接诊通知队列
$data = array();
$data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
$time = 1000 * 60 * 60 * 2;
}
$message = new DoctorNotYetInquiryDelayDirectProducer($data); $message = new DoctorNotYetInquiryDelayDirectProducer($data);
$message->setDelayMs($time); $message->setDelayMs($time);
$producer = $this->container->get(Producer::class); $producer = $this->container->get(Producer::class);