241 lines
6.9 KiB
SQL
241 lines
6.9 KiB
SQL
-- ============================================================
|
||
-- Bug #318 历史数据修复 - 简化版SQL脚本
|
||
-- 为已存在但未生成手术医嘱的手术申请单补齐数据
|
||
-- ============================================================
|
||
-- 执行说明：
|
||
-- 1. 在数据库管理工具中执行（如 DBeaver、pgAdmin）
|
||
-- 2. 建议先执行查询部分确认数据
|
||
-- 3. 备份数据库后再执行修复
|
||
-- ============================================================
|
||
|
||
-- 步骤1: 查看需要修复的记录数
|
||
-- ============================================================
|
||
SELECT
|
||
'需要修复的手术申请单数量' as 检查项,
|
||
COUNT(*) as 数量
|
||
FROM doc_request_form rf
|
||
LEFT JOIN wor_service_request sr ON sr.prescription_no = rf.prescription_no
|
||
AND sr.delete_flag = '0'
|
||
WHERE rf.type_code = 'PROCEDURE'
|
||
AND rf.delete_flag = '0'
|
||
AND sr.id IS NULL;
|
||
|
||
-- 步骤2: 查看详细列表（可选）
|
||
-- ============================================================
|
||
/*
|
||
SELECT
|
||
rf.id as request_form_id,
|
||
rf.prescription_no as 手术单号,
|
||
rf.encounter_id as 就诊ID,
|
||
rf.patient_id as 患者ID,
|
||
rf.create_time as 申请时间
|
||
FROM doc_request_form rf
|
||
LEFT JOIN wor_service_request sr ON sr.prescription_no = rf.prescription_no
|
||
AND sr.delete_flag = '0'
|
||
WHERE rf.type_code = 'PROCEDURE'
|
||
AND rf.delete_flag = '0'
|
||
AND sr.id IS NULL
|
||
ORDER BY rf.create_time DESC
|
||
LIMIT 10;
|
||
*/
|
||
|
||
-- 步骤3: 执行修复 - 生成手术医嘱（ServiceRequest）
|
||
-- ============================================================
|
||
-- ⚠️ 请在确认备份数据库后执行以下语句
|
||
|
||
INSERT INTO wor_service_request (
|
||
bus_no,
|
||
prescription_no,
|
||
status_enum,
|
||
generate_source_enum,
|
||
therapy_enum,
|
||
quantity,
|
||
unit_code,
|
||
category_enum,
|
||
patient_id,
|
||
requester_id,
|
||
encounter_id,
|
||
authored_time,
|
||
org_id,
|
||
content_json,
|
||
delete_flag,
|
||
create_time,
|
||
create_by,
|
||
tenant_id
|
||
)
|
||
SELECT
|
||
LPAD(FLOOR(RANDOM() * 10000)::TEXT, 4, '0') as bus_no, -- 生成4位随机数
|
||
rf.prescription_no,
|
||
1 as status_enum, -- 1-待签发
|
||
1 as generate_source_enum, -- 1-医生处方
|
||
2 as therapy_enum, -- 2-临时医嘱
|
||
1 as quantity,
|
||
'次' as unit_code,
|
||
4 as category_enum, -- 4-手术
|
||
rf.patient_id,
|
||
rf.requester_id,
|
||
rf.encounter_id,
|
||
rf.create_time as authored_time,
|
||
rf.org_id,
|
||
rf.desc_json as content_json, -- 存储手术详情
|
||
'0' as delete_flag,
|
||
rf.create_time,
|
||
rf.requester_id as create_by,
|
||
1 as tenant_id
|
||
FROM doc_request_form rf
|
||
LEFT JOIN wor_service_request sr ON sr.prescription_no = rf.prescription_no
|
||
AND sr.delete_flag = '0'
|
||
WHERE rf.type_code = 'PROCEDURE'
|
||
AND rf.delete_flag = '0'
|
||
AND sr.id IS NULL;
|
||
|
||
-- 步骤4: 查看生成的手术医嘱数量
|
||
-- ============================================================
|
||
SELECT
|
||
'生成的手术医嘱数量' as 检查项,
|
||
COUNT(*) as 数量
|
||
FROM wor_service_request
|
||
WHERE category_enum = 4
|
||
AND delete_flag = '0'
|
||
AND create_time > CURRENT_TIMESTAMP - INTERVAL '1 hour'; -- 最近1小时生成的
|
||
|
||
-- 步骤5: 生成手术收费项目（ChargeItem）
|
||
-- ============================================================
|
||
-- 先创建临时表存储新生成的ServiceRequest
|
||
CREATE TEMPORARY TABLE temp_new_service_requests AS
|
||
SELECT
|
||
sr.id as service_request_id,
|
||
sr.bus_no,
|
||
sr.prescription_no,
|
||
sr.patient_id,
|
||
sr.encounter_id,
|
||
sr.requester_id,
|
||
sr.create_time,
|
||
sr.org_id,
|
||
sr.content_json
|
||
FROM wor_service_request sr
|
||
WHERE sr.category_enum = 4
|
||
AND sr.delete_flag = '0'
|
||
AND sr.create_time > CURRENT_TIMESTAMP - INTERVAL '1 hour'; -- 最近1小时生成的
|
||
|
||
-- 插入手术费用收费项目
|
||
INSERT INTO adm_charge_item (
|
||
bus_no,
|
||
status_enum,
|
||
generate_source_enum,
|
||
patient_id,
|
||
context_enum,
|
||
encounter_id,
|
||
enterer_id,
|
||
entered_date,
|
||
service_table,
|
||
service_id,
|
||
product_table,
|
||
requesting_org_id,
|
||
quantity_value,
|
||
quantity_unit,
|
||
unit_price,
|
||
total_price,
|
||
delete_flag,
|
||
create_time,
|
||
create_by,
|
||
tenant_id
|
||
)
|
||
SELECT
|
||
'CI' || t.bus_no as bus_no,
|
||
1 as status_enum, -- 1-草稿
|
||
1 as generate_source_enum, -- 1-医生处方
|
||
t.patient_id,
|
||
3 as context_enum, -- 3-诊疗
|
||
t.encounter_id,
|
||
t.requester_id as enterer_id,
|
||
t.create_time as entered_date,
|
||
'wor_service_request' as service_table,
|
||
t.service_request_id as service_id,
|
||
'wor_activity_definition' as product_table,
|
||
t.org_id as requesting_org_id,
|
||
1 as quantity_value,
|
||
'次' as quantity_unit,
|
||
COALESCE((t.content_json::jsonb->>'surgeryFee')::numeric, 0) as unit_price,
|
||
COALESCE((t.content_json::jsonb->>'surgeryFee')::numeric, 0) as total_price,
|
||
'0' as delete_flag,
|
||
t.create_time,
|
||
t.requester_id as create_by,
|
||
1 as tenant_id
|
||
FROM temp_new_service_requests t
|
||
WHERE COALESCE((t.content_json::jsonb->>'surgeryFee')::numeric, 0) >= 0;
|
||
|
||
-- 插入麻醉费用收费项目（如果有麻醉费用）
|
||
INSERT INTO adm_charge_item (
|
||
bus_no,
|
||
status_enum,
|
||
generate_source_enum,
|
||
patient_id,
|
||
context_enum,
|
||
encounter_id,
|
||
enterer_id,
|
||
entered_date,
|
||
service_table,
|
||
service_id,
|
||
product_table,
|
||
requesting_org_id,
|
||
quantity_value,
|
||
quantity_unit,
|
||
unit_price,
|
||
total_price,
|
||
delete_flag,
|
||
create_time,
|
||
create_by,
|
||
tenant_id
|
||
)
|
||
SELECT
|
||
'CI' || t.bus_no || '_A' as bus_no,
|
||
1 as status_enum,
|
||
1 as generate_source_enum,
|
||
t.patient_id,
|
||
3 as context_enum,
|
||
t.encounter_id,
|
||
t.requester_id as enterer_id,
|
||
t.create_time as entered_date,
|
||
'wor_service_request' as service_table,
|
||
t.service_request_id as service_id,
|
||
'wor_activity_definition' as product_table,
|
||
t.org_id as requesting_org_id,
|
||
1 as quantity_value,
|
||
'次' as quantity_unit,
|
||
(t.content_json::jsonb->>'anesthesiaFee')::numeric as unit_price,
|
||
(t.content_json::jsonb->>'anesthesiaFee')::numeric as total_price,
|
||
'0' as delete_flag,
|
||
t.create_time,
|
||
t.requester_id as create_by,
|
||
1 as tenant_id
|
||
FROM temp_new_service_requests t
|
||
WHERE t.content_json::jsonb->>'anesthesiaFee' IS NOT NULL
|
||
AND (t.content_json::jsonb->>'anesthesiaFee')::numeric > 0;
|
||
|
||
-- 步骤6: 验证修复结果
|
||
-- ============================================================
|
||
SELECT
|
||
'手术医嘱总数' as 检查项,
|
||
COUNT(*) as 数量
|
||
FROM wor_service_request
|
||
WHERE category_enum = 4
|
||
AND delete_flag = '0';
|
||
|
||
SELECT
|
||
'手术收费项目总数' as 检查项,
|
||
COUNT(*) as 数量
|
||
FROM adm_charge_item ci
|
||
WHERE ci.service_table = 'wor_service_request'
|
||
AND EXISTS (
|
||
SELECT 1 FROM wor_service_request sr
|
||
WHERE sr.id = ci.service_id AND sr.category_enum = 4
|
||
);
|
||
|
||
-- 清理临时表
|
||
DROP TABLE IF EXISTS temp_new_service_requests;
|
||
|
||
-- ============================================================
|
||
-- ✓ 修复完成！
|
||
-- ============================================================
|