处理回写患者病例1

This commit is contained in:
wucongxing 2023-12-19 10:18:46 +08:00
parent 0d5ee9e6ad
commit 2aea3c3f5f
2 changed files with 211 additions and 205 deletions

View File

@ -311,6 +311,7 @@ class AutoFinishInquiryDelayDirectConsumer extends ConsumerMessage
*/ */
protected function handleOrderInquiryCase(array|object $order_inquiry): bool protected function handleOrderInquiryCase(array|object $order_inquiry): bool
{ {
try {
// 获取订单-问诊病例表 // 获取订单-问诊病例表
$params = array(); $params = array();
$params['order_inquiry_id'] = $order_inquiry['order_inquiry_id']; $params['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
@ -390,7 +391,7 @@ class AutoFinishInquiryDelayDirectConsumer extends ConsumerMessage
$data['drugs_name'] = $order_inquiry_case['drugs_name']; // 正在服药名称 $data['drugs_name'] = $order_inquiry_case['drugs_name']; // 正在服药名称
$patient_family_health = PatientFamilyHealth::addPatientFamilyHealth($data); $patient_family_health = PatientFamilyHealth::addPatientFamilyHealth($data);
if (empty($patient_family_health)) { if (empty($patient_family_health)) {
Log::getInstance("queue-AutoFinishInquiry")->error("错误:回写患者家庭成员信息表-健康情况表失败"); Log::getInstance("queue-AutoFinishInquiry")->error("回写患者家庭成员信息表-健康情况表失败");
} }
} else { } else {
$data = array(); $data = array();
@ -475,7 +476,7 @@ class AutoFinishInquiryDelayDirectConsumer extends ConsumerMessage
$patient_family_personal = PatientFamilyPersonal::addPatientFamilyPersonal($data); $patient_family_personal = PatientFamilyPersonal::addPatientFamilyPersonal($data);
if (empty($patient_family_personal)) { if (empty($patient_family_personal)) {
Log::getInstance("queue-AutoFinishInquiry")->error("错误:回写患者家庭成员信息表-个人情况表失败"); Log::getInstance("queue-AutoFinishInquiry")->error("回写患者家庭成员信息表-个人情况表失败");
} }
} else { } else {
$data = array(); $data = array();
@ -546,6 +547,12 @@ class AutoFinishInquiryDelayDirectConsumer extends ConsumerMessage
PatientFamilyPersonal::edit($params, $data); PatientFamilyPersonal::edit($params, $data);
} }
} }
return true;
}catch (\Throwable $e){
Log::getInstance("queue-AutoFinishInquiry")->error($e->getMessage());
return false;
}
} }
/** /**

View File

@ -288,7 +288,6 @@ class PatientCaseService extends BaseService
// 缓存 // 缓存
if (!empty($redis_value)){ if (!empty($redis_value)){
dump($redis_value);
$redis_value = json_decode($redis_value,true); $redis_value = json_decode($redis_value,true);
} }