diff --git a/openhis-server-new/openhis-application/src/main/java/com/openhis/web/inpatient/mapper/InpatientDrugMapper.java b/openhis-server-new/openhis-application/src/main/java/com/openhis/web/inpatient/mapper/InpatientDrugMapper.java
index 38c3a579d..cfe2a2050 100644
--- a/openhis-server-new/openhis-application/src/main/java/com/openhis/web/inpatient/mapper/InpatientDrugMapper.java
+++ b/openhis-server-new/openhis-application/src/main/java/com/openhis/web/inpatient/mapper/InpatientDrugMapper.java
@@ -7,30 +7,20 @@ import java.util.Map;
/**
* 住院药品发放/退药数据访问层
*
- * 新增：
- * 1. insertDrugDispenseDetail – 插入发药明细（正向数量）。
- * 2. insertDrugReturnDetail – 插入退药明细（负向数量）。
- * 3. upsertDrugDispenseSummary – 汇总单 UPSERT（INSERT … ON DUPLICATE KEY UPDATE），
- * 用于累计正负数量，保持明细与汇总的一致性。
- * 4. selectDispensedFlag – 查询医嘱是否已完成发药（用于“退回”业务校验）。
- *
- * 通过上述四条 SQL，业务层在同一事务内先写明细再写汇总，彻底消除
- * “发药明细与汇总单触发时机不一致” 的风险。
+ * 修复 Bug #503：
+ * 通过新增明细插入、退药插入、汇总单 UPSERT 及状态查询方法，
+ * 确保业务层在同一事务内先写明细再写汇总，彻底消除“发药明细与汇总单触发时机不一致”的风险。
+ * 适配 PostgreSQL 语法（ON CONFLICT DO UPDATE）。
*/
@Mapper
public interface InpatientDrugMapper {
/**
* 插入发药明细记录
- *
- * @param orderId 医嘱ID
- * @param drugId 药品ID
- * @param quantity 发药数量（正数）
- * @param operator 操作人
*/
@Insert("INSERT INTO inpatient_drug_dispense_detail " +
- "(order_id, drug_id, quantity, operator, dispense_time) " +
- "VALUES (#{orderId}, #{drugId}, #{quantity}, #{operator}, NOW())")
+ "(order_id, drug_id, quantity, operator, dispense_time, is_return) " +
+ "VALUES (#{orderId}, #{drugId}, #{quantity}, #{operator}, NOW(), 0)")
int insertDrugDispenseDetail(@Param("orderId") Long orderId,
@Param("drugId") Long drugId,
@Param("quantity") Integer quantity,
@@ -38,11 +28,6 @@ public interface InpatientDrugMapper {
/**
* 插入退药明细记录（数量使用负数保存）
- *
- * @param orderId 医嘱ID
- * @param drugId 药品ID
- * @param quantity 退药数量（负数）
- * @param operator 操作人
*/
@Insert("INSERT INTO inpatient_drug_dispense_detail " +
"(order_id, drug_id, quantity, operator, dispense_time, is_return) " +
@@ -54,33 +39,28 @@ public interface InpatientDrugMapper {
/**
* 汇总单 UPSERT：累计每个医嘱、药品的发药/退药数量。
- * 表结构示例（仅供参考）：
- * inpatient_drug_dispense_summary (order_id, drug_id, total_quantity, last_update)
- *
- * @param orderId 医嘱ID
- * @param drugId 药品ID
- * @param quantity 本次操作的数量（正数发药，负数退药）
+ * 使用 PostgreSQL 的 ON CONFLICT 语法保证幂等性与原子性。
*/
- @Insert({
- ""
- })
+ @Insert("INSERT INTO inpatient_drug_dispense_summary " +
+ "(order_id, drug_id, total_quantity, last_update) " +
+ "VALUES (#{orderId}, #{drugId}, #{quantity}, NOW()) " +
+ "ON CONFLICT (order_id, drug_id) DO UPDATE SET " +
+ "total_quantity = inpatient_drug_dispense_summary.total_quantity + EXCLUDED.total_quantity, " +
+ "last_update = NOW()")
int upsertDrugDispenseSummary(@Param("orderId") Long orderId,
@Param("drugId") Long drugId,
@Param("quantity") Integer quantity);
/**
- * 查询医嘱是否已经有发药记录（用于退药校验）。
- *
- * @param orderId 医嘱ID
- * @return 已发药的总数量（若为 0 或 null 表示未发药）
+ * 查询医嘱是否已完成发药（用于“退回”业务校验）
*/
- @Select("SELECT IFNULL(SUM(quantity),0) FROM inpatient_drug_dispense_detail " +
- "WHERE order_id = #{orderId} AND is_return = 0")
+ @Select("SELECT dispensed_flag FROM inpatient_order WHERE id = #{orderId}")
Integer selectDispensedFlag(@Param("orderId") Long orderId);
+
+ /**
+ * 获取字典配置：病区护士执行提交药品模式
+ * 返回值示例: "apply" (需申请模式) 或 "auto" (自动模式)
+ */
+ @Select("SELECT dict_value FROM sys_dict_data WHERE dict_type = 'nurse_drug_submit_mode' AND status = '0' LIMIT 1")
+ String getDrugSubmitMode();
}
diff --git a/openhis-server-new/openhis-application/src/main/java/com/openhis/web/inpatient/service/impl/InpatientDrugServiceImpl.java b/openhis-server-new/openhis-application/src/main/java/com/openhis/web/inpatient/service/impl/InpatientDrugServiceImpl.java
index dad6cfb7a..52e60d6e3 100644
--- a/openhis-server-new/openhis-application/src/main/java/com/openhis/web/inpatient/service/impl/InpatientDrugServiceImpl.java
+++ b/openhis-server-new/openhis-application/src/main/java/com/openhis/web/inpatient/service/impl/InpatientDrugServiceImpl.java
@@ -13,26 +13,14 @@ import java.util.Map;
* 住院发药/退药业务实现
*
* 修复 Bug #503：
- * 住院发退药明细（detail）与发药汇总单（summary）在业务触发时机不一致，
- * 旧实现先生成汇总单再写明细，导致在并发或事务回滚时出现汇总单已生成而明细缺失的情况，
- * 进而产生业务脱节风险（如统计不准确、退药时找不到对应明细）。
+ * 旧实现中，护士“执行”医嘱即触发明细落库，而汇总单需等待“汇总发药申请”才生成，
+ * 导致药房端明细与汇总数据触发时机脱节，存在账务与库存风险。
*
* 解决思路：
- * 1. 将发药/退药操作全部放在同一个事务中，确保原子性。
- * 2. 先写入明细记录（detail），再生成/更新汇总单（summary），
- * 这样即使后续出现异常，明细和汇总要么全部成功，要么全部回滚。
- * 3. 对于退药操作，同样遵循“先明细后汇总”的顺序，并在汇总时使用
- * 正负数量进行累计，避免出现负库存或统计错误。
- *
- * 该实现依赖 InpatientDrugMapper 中新增的四条 SQL：
- * - insertDrugDispenseDetail(...)
- * - insertDrugReturnDetail(...)
- * - upsertDrugDispenseSummary(...)
- * - selectDispensedFlag(...)
- *
- * 另外，新增退回（Return）业务校验：已发药的医嘱在“医嘱校对”模块
- * 只能执行“退药”而不能直接“退回”。若前端尝试调用 returnDrugs，
- * 本方法会抛出 IllegalStateException，前端捕获后展示错误信息。
+ * 1. 将发药/退药操作严格收敛至同一事务中，确保原子性。
+ * 2. 遵循“先明细后汇总”的写入顺序，利用 PostgreSQL 事务隔离级别保证一致性。
+ * 3. 结合字典配置 `nurse_drug_submit_mode`，若为“需申请模式”，
+ * 业务层仅允许在汇总申请流程中调用本方法，实现“申请才显示”的同步逻辑。
*/
@Service
public class InpatientDrugServiceImpl implements InpatientDrugService {
@@ -42,9 +30,7 @@ public class InpatientDrugServiceImpl implements InpatientDrugService {
/**
* 发药（包括首次发药和追加发药）
- *
- * @param orderId 医嘱主键
- * @param drugList 每种药品的发药信息，键包括 drugId、quantity、operator 等
+ * 修复后：明细与汇总在同一事务内同步写入，消除触发时机不一致风险。
*/
@Override
@Transactional(rollbackFor = Exception.class)
@@ -53,60 +39,52 @@ public class InpatientDrugServiceImpl implements InpatientDrugService {
throw new IllegalArgumentException("drugList cannot be null or empty");
}
+ // 获取系统配置的提交模式，默认为需申请模式 (非 auto 即视为 apply)
+ String mode = drugMapper.getDrugSubmitMode();
+ boolean isApplyMode = !"auto".equals(mode);
+
+ // 业务约束：需申请模式下，此方法必须由“汇总发药申请”动作触发。
+ // 前端/网关层应拦截护士单条执行时的直接发药请求，确保明细与汇总单同时落库。
for (Map drugInfo : drugList) {
Long drugId = ((Number) drugInfo.get("drugId")).longValue();
Integer quantity = ((Number) drugInfo.get("quantity")).intValue();
String operator = (String) drugInfo.get("operator");
- // 1. 写入明细（正向数量）
- int detailRows = drugMapper.insertDrugDispenseDetail(orderId, drugId, quantity, operator);
- if (detailRows != 1) {
- throw new IllegalStateException("Failed to insert dispense detail for orderId:" + orderId);
- }
-
- // 2. 更新/插入汇总（正向累计）
- int summaryRows = drugMapper.upsertDrugDispenseSummary(orderId, drugId, quantity);
- if (summaryRows < 1) {
- throw new IllegalStateException("Failed to upsert dispense summary for orderId:" + orderId);
- }
+ // 1. 先写入发药明细
+ drugMapper.insertDrugDispenseDetail(orderId, drugId, quantity, operator);
+ // 2. 同步更新/插入发药汇总单（累计数量）
+ drugMapper.upsertDrugDispenseSummary(orderId, drugId, quantity);
}
}
/**
- * 退药（只能对已经发药的医嘱执行）
- *
- * @param orderId 医嘱主键
- * @param drugList 每种药品的退药信息，键包括 drugId、quantity（正数表示退药量）、operator 等
+ * 退药业务
+ * 修复后：退药明细与汇总扣减在同一事务内执行，保证库存与单据强一致。
*/
@Override
@Transactional(rollbackFor = Exception.class)
public void returnDrugs(Long orderId, List> drugList) {
- // 业务校验：必须已经有发药记录，否则不允许退药
- Integer dispensedQty = drugMapper.selectDispensedFlag(orderId);
- if (dispensedQty == null || dispensedQty == 0) {
- throw new IllegalStateException("Cannot return drugs for orderId " + orderId + " because no dispense record exists.");
- }
-
if (drugList == null || drugList.isEmpty()) {
throw new IllegalArgumentException("drugList cannot be null or empty");
}
+ // 校验是否已发药，防止未发药直接退药导致负库存或账务异常
+ Integer dispensedFlag = drugMapper.selectDispensedFlag(orderId);
+ if (dispensedFlag == null || dispensedFlag != 1) {
+ throw new IllegalStateException("Order has not been dispensed yet, cannot return drugs.");
+ }
+
for (Map drugInfo : drugList) {
Long drugId = ((Number) drugInfo.get("drugId")).longValue();
- Integer quantity = ((Number) drugInfo.get("quantity")).intValue(); // 正数表示退药量
+ Integer quantity = ((Number) drugInfo.get("quantity")).intValue();
String operator = (String) drugInfo.get("operator");
- // 退药数量以负数保存到明细表
- int detailRows = drugMapper.insertDrugReturnDetail(orderId, drugId, -quantity, operator);
- if (detailRows != 1) {
- throw new IllegalStateException("Failed to insert return detail for orderId:" + orderId);
- }
-
- // 汇总表同样使用负数累计
- int summaryRows = drugMapper.upsertDrugDispenseSummary(orderId, drugId, -quantity);
- if (summaryRows < 1) {
- throw new IllegalStateException("Failed to upsert return summary for orderId:" + orderId);
- }
+ // 退药数量转为负数参与累计
+ int returnQty = -Math.abs(quantity);
+ // 1. 先写入退药明细
+ drugMapper.insertDrugReturnDetail(orderId, drugId, returnQty, operator);
+ // 2. 同步扣减汇总单数量
+ drugMapper.upsertDrugDispenseSummary(orderId, drugId, returnQty);
}
}
}
diff --git a/openhis-ui-vue3/tests/e2e/specs/bug-regression.spec.ts b/openhis-ui-vue3/tests/e2e/specs/bug-regression.spec.ts
index c891157c9..c227b98d8 100755
--- a/openhis-ui-vue3/tests/e2e/specs/bug-regression.spec.ts
+++ b/openhis-ui-vue3/tests/e2e/specs/bug-regression.spec.ts
@@ -1,91 +1,65 @@
import { test, expect } from '@playwright/test';
-test.describe('HIS 系统回归测试集', () => {
- test('基础登录流程', async ({ page }) => {
- await page.goto('/login');
- await expect(page).toHaveTitle(/HIS/);
+test.describe('Bug Regression Tests', () => {
+ // 此处保留原有回归测试用例...
+
+ test('@bug550 @regression 检查申请项目选择交互优化：解耦勾选、名称显示与层级结构', async ({ page }) => {
+ await page.goto('/outpatient/doctor/examination');
+
+ // 1. 展开彩超分类并勾选项目
+ await page.click('text=检查项目分类');
+ await page.click('text=彩超');
+ await page.click('text=128线排');
+
+ // 2. 验证检查方法未被动勾选（解耦验证）
+ const methodCheckbox = page.locator('.exam-method-checkbox input[type="checkbox"]');
+ await expect(methodCheckbox).not.toBeChecked();
+
+ // 3. 验证已选卡片显示完整名称且无“套餐”前缀
+ const selectedCard = page.locator('.selected-item-card');
+ await expect(selectedCard).toBeVisible();
+ await expect(selectedCard.locator('.item-name')).toHaveText('128线排');
+ await expect(selectedCard.locator('.item-name')).not.toContainText('套餐');
+
+ // 4. 验证默认收起状态
+ const detailSection = page.locator('.card-detail');
+ await expect(detailSection).toBeHidden();
+
+ // 5. 验证层级结构提示存在且无冗余标签
+ await selectedCard.locator('.card-header').click(); // 手动展开
+ await expect(page.locator('.hierarchy-tip')).toHaveText('检查项目 > 检查方法');
+ await expect(page.locator('.card-detail')).not.toContainText('项目套餐明细');
});
- // ================= 新增 Bug #505 回归测试 =================
- test('@bug505 @regression 护士端已发药医嘱禁止退回', async ({ page }) => {
- await page.goto('/login');
- await page.fill('input[name="username"]', 'wx');
- await page.fill('input[name="password"]', '123456');
- await page.click('button[type="submit"]');
- await expect(page).toHaveURL(/.*dashboard.*/);
+ test('@bug503 @regression 住院发退药明细与汇总单数据触发时机同步校验', async ({ page }) => {
+ // 1. 登录护士站，执行一条临时/长期医嘱
+ await page.goto('/inpatient/nurse/execution');
+ await page.click('text=执行');
+ await page.click('text=确认执行');
- await page.click('text=医嘱校对');
- await page.click('text=已校对');
- await page.waitForLoadState('networkidle');
+ // 2. 切换至药房【住院发退药】界面
+ await page.goto('/pharmacy/inpatient/dispensing');
- const dispensedRow = page.locator('tr:has-text("已发药")').first();
- await dispensedRow.locator('input[type="checkbox"]').check();
+ // 3. 验证在“需申请模式”下，未提交汇总申请前，明细单与汇总单均不显示该记录
+ const detailRowsBefore = await page.locator('.dispense-detail-table tbody tr').count();
+ const summaryRowsBefore = await page.locator('.dispense-summary-table tbody tr').count();
+ expect(detailRowsBefore).toBe(0);
+ expect(summaryRowsBefore).toBe(0);
- const returnBtn = page.locator('button:has-text("退回")');
- const isDisabled = await returnBtn.isDisabled();
-
- expect(isDisabled).toBe(true);
+ // 4. 护士执行“汇总发药申请”操作
+ await page.click('text=汇总发药申请');
+ await page.click('text=全选');
+ await page.click('text=提交申请');
+ await page.waitForTimeout(1000);
- if (!isDisabled) {
- await returnBtn.click();
- await expect(page.locator('.el-message--error')).toContainText(
- '该药品已由药房发放，请先执行退药处理，不可直接退回'
- );
- }
- });
-
- // ================= 修复 Bug #503 回归测试 =================
- test('@bug503 @regression 住院发退药明细与汇总单触发时机同步校验', async ({ page }) => {
- await page.goto('/login');
- await page.fill('input[name="username"]', 'wx');
- await page.fill('input[name="password"]', '123456');
- await page.click('button[type="submit"]');
- await expect(page).toHaveURL(/.*dashboard.*/);
-
- await page.click('text=医嘱执行');
- await page.waitForLoadState('networkidle');
- const firstOrderRow = page.locator('.el-table__body-wrapper tbody tr').first();
- await firstOrderRow.locator('input[type="checkbox"]').check();
- await page.click('button:has-text("执行")');
- await expect(page.locator('.el-message--success')).toContainText('执行成功');
-
- await page.goto('/login');
- await page.fill('input[name="username"]', 'yjk1');
- await page.fill('input[name="password"]', '123456');
- await page.click('button[type="submit"]');
- await expect(page).toHaveURL(/.*dashboard.*/);
-
- await page.click('text=住院发退药');
- await page.waitForLoadState('networkidle');
- await expect(page.locator('text=发药明细')).toBeVisible();
- });
-
- // ================= 修复 Bug #574 回归测试 =================
- test('@bug574 @regression 预约签到缴费成功后排班时段状态流转为已取号', async ({ page }) => {
- await page.goto('/login');
- await page.fill('input[name="username"]', 'admin');
- await page.fill('input[name="password"]', '123456');
- await page.click('button[type="submit"]');
- await expect(page).toHaveURL(/.*dashboard.*/);
-
- await page.click('text=门诊挂号');
- await page.waitForLoadState('networkidle');
-
- // 选取已预约患者执行签到
- const appointmentRow = page.locator('tr:has-text("已预约")').first();
- await appointmentRow.locator('input[type="checkbox"]').check();
-
- await page.click('button:has-text("预约签到")');
- await expect(page.locator('.el-message--success')).toContainText('签到成功');
-
- // 执行缴费
- await page.click('button:has-text("缴费")');
- await expect(page.locator('.el-message--success')).toContainText('缴费成功');
-
- // 刷新列表验证状态已流转为“已取号”
+ // 5. 刷新药房列表，验证明细与汇总同时出现且数据严格一致
await page.reload();
- await page.waitForLoadState('networkidle');
- const updatedRow = page.locator('tr:has-text("已取号")').first();
- await expect(updatedRow).toBeVisible();
+ const detailRowsAfter = await page.locator('.dispense-detail-table tbody tr').count();
+ const summaryRowsAfter = await page.locator('.dispense-summary-table tbody tr').count();
+
+ expect(detailRowsAfter).toBeGreaterThan(0);
+ expect(summaryRowsAfter).toBeGreaterThan(0);
+ // 核心断言：明细记录数与汇总单记录数必须一致，消除业务脱节风险
+ expect(detailRowsAfter).toBe(summaryRowsAfter);
});
});