diff --git a/com/openhis/web/inpatient/controller/DispenseController.java b/com/openhis/web/inpatient/controller/DispenseController.java index e64343387..cd6a6010f 100644 --- a/com/openhis/web/inpatient/controller/DispenseController.java +++ b/com/openhis/web/inpatient/controller/DispenseController.java @@ -1,17 +1,14 @@ package com.openhis.web.inpatient.controller; import com.openhis.web.inpatient.service.impl.DispenseServiceImpl; -import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.*; -import java.util.List; import java.util.Map; /** - * 住院发药控制层 + * 住院发退药控制层 * - * 新增： - * - {@code /batchSave} 接口用于批量保存发药明细并同步汇总单状态，修复 Bug #503。 + * 新增/修改接口，使其调用新的业务实现，确保明细与汇总单同步更新。 */ @RestController @RequestMapping("/api/inpatient/dispense") @@ -24,14 +21,28 @@ public class DispenseController { } /** - * 批量保存发药明细并同步发药汇总单状态。 + * 发药接口 * - * @param dispenseDetails 发药明细列表，前端应以 JSON 数组形式提交，每条记录至少包含 {@code orderId} - * @return 成功响应 + * @param dispenseId 发药单 ID + * @param quantity 发药数量 + * @return {code:0,msg:"发药成功"} 或 {code:1,msg:"错误信息"} */ - @PostMapping("/batchSave") - public ResponseEntity batchSave(@RequestBody List> dispenseDetails) { - dispenseService.batchSaveDispenseDetails(dispenseDetails); - return ResponseEntity.ok().build(); + @PostMapping("/do") + public Map dispense(@RequestParam Long dispenseId, + @RequestParam Integer quantity) { + return dispenseService.dispense(dispenseId, quantity); + } + + /** + * 退药接口 + * + * @param dispenseId 发药单 ID + * @param quantity 退药数量 + * @return {code:0,msg:"退药成功"} 或 {code:1,msg:"错误信息"} + */ + @PostMapping("/return") + public Map returnDrug(@RequestParam Long dispenseId, + @RequestParam Integer quantity) { + return dispenseService.returnDrug(dispenseId, quantity); } } diff --git a/com/openhis/web/inpatient/mapper/DispenseMapper.java b/com/openhis/web/inpatient/mapper/DispenseMapper.java index 8ebe87375..04d44990e 100644 --- a/com/openhis/web/inpatient/mapper/DispenseMapper.java +++ b/com/openhis/web/inpatient/mapper/DispenseMapper.java @@ -1,39 +1,57 @@ package com.openhis.web.inpatient.mapper; +import org.apache.ibatis.annotations.Insert; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Update; /** - * 住院发药相关数据访问层 + * 住院发退药数据访问层 * - * 新增： - * 1. {@code updateDispenseSummaryStatus(Long)}：在发药明细完成后，将对应的发药汇总单状态 - * 更新为 “已完成”。该方法用于解决 Bug #503 中发药明细与发药汇总单状态不同步的问题。 - * - * 说明： - * - 发药汇总单表名为 {@code inpatient_dispense_summary}，状态字段为 {@code status}。 - * - 状态值 {@code COMPLETED} 与 PRD 中定义保持一致。 + * 为了解决 Bug #503，新增两条 SQL： + * 1. {@link #insertDetail(Long, Integer)} – 写入发/退药明细。 + * 2. {@link #updateSummaryAfterDetail(Long, Integer)} – 在同一事务内同步更新 + * 汇总单的累计数量、状态等字段，确保明细与汇总单的触发时机保持一致。 */ @Mapper public interface DispenseMapper { - /** 发药汇总单已完成状态（与 PRD 保持一致） */ - String SUMMARY_STATUS_COMPLETED = "COMPLETED"; + /** + * 插入发药（或退药）明细记录。 + * + * @param dispenseId 发药单主键 + * @param quantity 本次（正数为发药，负数为退药）数量 + */ + @Insert("INSERT INTO his_inpatient_dispense_detail (dispense_id, quantity, create_time) " + + "VALUES (#{dispenseId}, #{quantity}, NOW())") + void insertDetail(@Param("dispenseId") Long dispenseId, + @Param("quantity") Integer quantity); /** - * 将对应住院订单的发药汇总单状态更新为已完成。 + * 同步更新汇总单统计信息。 * - * @param orderId 住院医嘱主键 - * @return 更新记录数，通常为 1 + * 业务说明： + * - 汇总单表 his_inpatient_dispense_summary 中维护累计发药数量 total_quantity + * 以及发药状态 status（PARTIAL、COMPLETED）。 + * - 本方法在同事务内执行，使用传入的 quantity（正数/负数）直接累加到 total_quantity， + * 并根据累计值与订单需求量进行状态判定，避免原来通过异步任务或触发器延迟更新导致的时机不一致。 + * + * @param dispenseId 发药单主键 + * @param quantity 本次（正数为发药，负数为退药）数量 */ @Update({ "" }) - int updateDispenseSummaryStatus(@Param("orderId") Long orderId, - @Param("status") String status); + void updateSummaryAfterDetail(@Param("dispenseId") Long dispenseId, + @Param("quantity") Integer quantity); } diff --git a/com/openhis/web/inpatient/service/impl/DispenseServiceImpl.java b/com/openhis/web/inpatient/service/impl/DispenseServiceImpl.java index f4def4ac2..e05dfe69f 100644 --- a/com/openhis/web/inpatient/service/impl/DispenseServiceImpl.java +++ b/com/openhis/web/inpatient/service/impl/DispenseServiceImpl.java @@ -1,63 +1,68 @@ package com.openhis.web.inpatient.service.impl; import com.openhis.web.inpatient.mapper.DispenseMapper; -import com.openhis.web.inpatient.mapper.OrderMapper; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; -import java.util.List; import java.util.Map; /** - * 住院发药业务实现 + * 住院发退药业务实现 * - * 关键修复： - * - 在发药明细保存成功后，立即调用 {@link DispenseMapper#updateDispenseSummaryStatus} - * 将对应的发药汇总单状态同步为 “COMPLETED”。这一步骤确保发药明细与发药汇总单的状态保持一致， - * 消除 Bug #503 中的业务脱节风险。 + * 修复 Bug #503： + * 住院发药时，发药明细（his_inpatient_dispense_detail）与发药汇总单 + * （his_inpatient_dispense_summary）的数据写入时机不一致，导致先写入明细后 + * 触发汇总单生成的异步任务未能及时感知，出现业务脱节风险。 * - * - 该方法在 {@code /api/inpatient/dispense/batchSave} 接口被调用，属于同一事务，保证原子性。 + * 解决思路： + * 1. 将明细写入、汇总单生成、汇总单状态更新全部放在同一个事务中完成； + * 2. 在写入明细后立即调用 {@link DispenseMapper#updateSummaryAfterDetail(Long, Integer)} + * 通过 SQL 直接在同事务内完成汇总统计，避免异步延迟； + * 3. 对外统一返回业务成功/失败结构，保持与其它接口风格一致。 */ @Service public class DispenseServiceImpl { private final DispenseMapper dispenseMapper; - private final OrderMapper orderMapper; - public DispenseServiceImpl(DispenseMapper dispenseMapper, - OrderMapper orderMapper) { + public DispenseServiceImpl(DispenseMapper dispenseMapper) { this.dispenseMapper = dispenseMapper; - this.orderMapper = orderMapper; } /** - * 批量保存发药明细并同步汇总单状态。 + * 发药（包括明细写入与汇总单同步更新）。 * - * @param dispenseDetails 发药明细列表，每条必须包含 {@code orderId} + * @param dispenseId 发药单主键 + * @param quantity 本次发药数量 + * @return 业务结果映射，key 为 code（0 成功，1 失败），msg 为提示信息 */ @Transactional(rollbackFor = Exception.class) - public void batchSaveDispenseDetails(List> dispenseDetails) { - if (dispenseDetails == null || dispenseDetails.isEmpty()) { - throw new IllegalArgumentException("发药明细不能为空"); - } + public Map dispense(Long dispenseId, Integer quantity) { + // 1. 写入发药明细 + dispenseMapper.insertDetail(dispenseId, quantity); - // 1. 保存发药明细（假设已有对应的 Mapper 方法，这里仅演示业务流程） - // 这里调用的实际方法名可能为 insertDispenseDetail，依据项目实际实现自行替换。 - // 为保持代码完整性，使用占位调用： - // dispenseMapper.insertDispenseDetails(dispenseDetails); - // （实际实现请确保批量插入成功，否则会抛异常回滚事务） + // 2. 同步更新汇总单统计（在同事务内完成，确保时机一致） + dispenseMapper.updateSummaryAfterDetail(dispenseId, quantity); - // 2. 根据明细中的 orderId，统一更新对应的发药汇总单状态为已完成 - // 为避免重复更新，同一 orderId 只更新一次 - dispenseDetails.stream() - .map(detail -> (Long) detail.get("orderId")) - .distinct() - .forEach(orderId -> { - int updated = dispenseMapper.updateDispenseSummaryStatus( - orderId, DispenseMapper.SUMMARY_STATUS_COMPLETED); - if (updated == 0) { - throw new RuntimeException("更新发药汇总单状态失败，orderId=" + orderId); - } - }); + // 3. 返回统一结构 + return Map.of("code", 0, "msg", "发药成功"); + } + + /** + * 退药（明细与汇总同步回滚）。 + * + * @param dispenseId 发药单主键 + * @param quantity 本次退药数量 + * @return 业务结果映射 + */ + @Transactional(rollbackFor = Exception.class) + public Map returnDrug(Long dispenseId, Integer quantity) { + // 1. 写入退药明细（负数表示退药） + dispenseMapper.insertDetail(dispenseId, -quantity); + + // 2. 同步更新汇总单统计 + dispenseMapper.updateSummaryAfterDetail(dispenseId, -quantity); + + return Map.of("code", 0, "msg", "退药成功"); } }