From 872974ee66ff5af875c69d4408cc429b7ca99e20 Mon Sep 17 00:00:00 2001 From: sa0ChunLuyu Date: Sun, 2 Aug 2026 12:19:40 +0800 Subject: [PATCH] =?UTF-8?q?=E6=97=B6=E7=AB=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Controllers/API/Third/YiJiController.php | 121 ++++++++---------- 1 file changed, 55 insertions(+), 66 deletions(-) diff --git a/Laravel/app/Http/Controllers/API/Third/YiJiController.php b/Laravel/app/Http/Controllers/API/Third/YiJiController.php index 91e0e0b..fce78f1 100644 --- a/Laravel/app/Http/Controllers/API/Third/YiJiController.php +++ b/Laravel/app/Http/Controllers/API/Third/YiJiController.php @@ -72,72 +72,61 @@ public function CheckAppointment() $entrust_ids[] = $item['orderNo']; $termCodes[] = $item['termCode']; $execDeptCodes[] = $item['execDeptCode']; - //查询库里是否存在该检医嘱 - $db_item = DB::table('s_list')->where(['entrust_id' => $item['orderNo']])->first(); - if (!$db_item) { - //如果不存在则进行创建 - $params = [ - 'list_status' => 0, - 'reg_num' => $data_v['cardNo'], - 'user_name' =>$data_v['patientName'], - 'user_sex' => $data_v['patientGenderName'] == '男' ? 1 : 2, - 'entrust_code' => $item['termCode'], - 'entrust' => $item['termName'], - 'is_pay' => $data_v["chargeStatusName"] == '已收费' ? 1 : 0, - 'reservation_department' =>$data_v["orderDeptName"], - 'entrust_date' =>$entrust_datePart, - 'entrust_time' =>$entrust_timePart, - 'user_brithday' =>$birthday, - 'docotr' => $data_v["orderPersonName"], - 'patient_type' => $patientType, - 'user_phone' => $data_v["mobile"], - 'implement_department' =>$item['execDeptName'], - 'entrust_id' => $item['orderNo'], - 'episodeid' => $visitSqNo, - // 'RISRExamID' => $order["RISRExamID"] ? $order["RISRExamID"] : null, //检查号,先屏蔽掉，获取不到 - 'RISRAcceptDeptCode' => $item["execDeptCode"], //接收科室代码 - 'warddesc' => $data_v["areaName"], //病区 - 'wardcode' => $data_v["areaCode"], //病区 - 'bedname' => $data_v["bedName"], //病床号 - 'bedno' => $data_v["bedNo"], //病床号 - 'app_num' => $data_v["requestNo"], //申请单号 - 'idCardNumber' => $data_v["idCardNumber"], //身份证号 - 'medicalHistory' => $data_v["medicalHistory"], //病史摘要 - 'diagnosisName' => $data_v["diagnosisName"], //临床诊断（诊断名称） - 'his_is_emergency'=> intval($data_v["urgentFlag"]), //是否加急 - 'reservation_department_code' =>$data_v["orderDeptCode"],//申请科室代码 - 'doctor_code' => $data_v["orderPersonCode"],//申请医生代码 - 'requestComment' => $data_v["requestComment"] ?? null, //申请注意事项 - ]; - $list_id= DB::table('s_list')->insertGetId($params); - if($list_id){ - $i_log = DB::table('s_list_log')->insert([ - 'list_id' =>$list_id, - 'reg_num' => $data_v['cardNo'], - 'old_status' => 0, - 'new_status' => 0, - 'create_user' => 'his', - 'note' => '创建记录', - 'data' => json_encode($params) - ]); - } - - }else{ - //如果存在，更新一下部分字段 - $params = [ - 'medicalHistory' => $data_v["medicalHistory"], //病史摘要 - 'diagnosisName' => $data_v["diagnosisName"], //临床诊断（诊断名称） - 'his_is_emergency'=> intval($data_v["urgentFlag"]), //是否加急 - 'reservation_department_code' =>$data_v["orderDeptCode"],//申请科室代码 - 'doctor_code' => $data_v["orderPersonCode"],//申请医生代码 - 'requestComment' => $data_v["requestComment"] ?? null, //申请注意事项 - ]; - // 如果 wardcode 一致但 warddesc 不一致，同步更新病区名称 - if ($db_item->wardcode == $data_v["areaCode"] && $db_item->warddesc != $data_v["areaName"]) { - $params['warddesc'] = $data_v["areaName"]; - } - DB::table('s_list')->where(['id' => $db_item->id])->update($params); - } + // UPSERT：原子操作，消除 SELECT + INSERT 之间的竞态 + $params = [ + 'list_status' => 0, + 'reg_num' => $data_v['cardNo'], + 'user_name' =>$data_v['patientName'], + 'user_sex' => $data_v['patientGenderName'] == '男' ? 1 : 2, + 'entrust_code' => $item['termCode'], + 'entrust' => $item['termName'], + 'is_pay' => $data_v["chargeStatusName"] == '已收费' ? 1 : 0, + 'reservation_department' =>$data_v["orderDeptName"], + 'entrust_date' =>$entrust_datePart, + 'entrust_time' =>$entrust_timePart, + 'user_brithday' =>$birthday, + 'docotr' => $data_v["orderPersonName"], + 'patient_type' => $patientType, + 'user_phone' => $data_v["mobile"], + 'implement_department' =>$item['execDeptName'], + 'entrust_id' => $item['orderNo'], + 'episodeid' => $visitSqNo, + 'RISRAcceptDeptCode' => $item["execDeptCode"], + 'warddesc' => $data_v["areaName"], + 'wardcode' => $data_v["areaCode"], + 'bedname' => $data_v["bedName"], + 'bedno' => $data_v["bedNo"], + 'app_num' => $data_v["requestNo"], + 'idCardNumber' => $data_v["idCardNumber"], + 'medicalHistory' => $data_v["medicalHistory"], + 'diagnosisName' => $data_v["diagnosisName"], + 'his_is_emergency'=> intval($data_v["urgentFlag"]), + 'reservation_department_code' =>$data_v["orderDeptCode"], + 'doctor_code' => $data_v["orderPersonCode"], + 'requestComment' => $data_v["requestComment"] ?? null, + ]; + + $columns = '`' . implode('`, `', array_keys($params)) . '`'; + $holders = implode(', ', array_fill(0, count($params), '?')); + $assigns = implode(', ', array_map(fn($k) => "`{\$k}` = VALUES(`{\$k}`)", array_keys($params))); + + $sql = "INSERT INTO `s_list` ({$columns}) VALUES ({$holders}) ON DUPLICATE KEY UPDATE {$assigns}"; + DB::statement($sql, array_values($params)); + + $rowCount = DB::select("SELECT ROW_COUNT() AS `affected`")[0]->affected; + $note = ($rowCount == 1) ? '创建记录' : 'MQ冲突更新'; + + $list_id = DB::table('s_list')->where('entrust_id', $item['orderNo'])->value('id'); + + DB::table('s_list_log')->insert([ + 'list_id' => $list_id, + 'reg_num' => $data_v['cardNo'], + 'old_status' => 0, + 'new_status' => 0, + 'create_user' => 'his', + 'note' => $note, + 'data' => json_encode($params), + ]); } } }else{