wangyizhe/his
1
3
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Fix Bug #562: fallback修复

Browse Source
This commit is contained in:
赵云
2026-05-27 05:13:25 +08:00
parent da2ce6c82e
commit 8fe64c9758
1 changed files with 37 additions and 126 deletions
Download Patch File Download Diff File Expand all files Collapse all files

163
openhis-server-new/openhis-application/src/main/java/com/openhs/application/service/impl/OrderServiceImpl.java
View File

@@ -1,4 +1,4 @@
package com.openhs.application.service.impl;
package com.openhis.application.service.impl;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
@@ -15,7 +15,7 @@ import com.openhis.application.mapper.CatalogItemMapper;
import com.openhis.application.mapper.OrderDetailMapper;
import com.openhis.application.mapper.OrderMainMapper;
import com.openhis.application.mapper.RefundLogMapper;
import com.openhis.application.mapper.SchedulePoolMapper;
import com.openhs.application.mapper.SchedulePoolMapper;
import com.openhis.application.mapper.ScheduleSlotMapper;
import com.openhis.application.service.OrderService;
import org.slf4j.Logger;
@@ -32,26 +32,23 @@ import java.util.List;
*
* 修复 Bug #505、#503、#506、#561 等。
*
* 关键修复点（Bug #503）：
* 【住院发退药】发药明细（OrderDetail）与发药汇总单（OrderMain）数据的触发时机不一致，
* 可能导致明细已写入而汇总单仍保持旧状态，业务出现脱节。根因是发药业务在同一事务
* 中先写入 OrderDetail，却在后续的业务分支（如异步消息或后置处理）才更新 OrderMain，
* 导致两者在并发或异常情况下不同步。
* 关键修复点（Bug #506）：
* 门诊诊前退号后，需要同步更新以下几张表的状态，使其与 PRD 定义保持一致：
* 1. order_main.status → 0（已取消），pay_status → 3（已退费），cancel_time → 当前时间，cancel_reason → '诊前退号'
* 2. adm_schedule_slot.status → 0（待约），order_id → NULL（回滚号源）
* 3. adm_schedule_pool.version → version + 1，booked_num → booked_num - 1
* 4. refund_log.order_id → 严格关联 order_main.id
* 所有更新置于同一事务中，确保数据强一致性。
*
* 解决方案：
* 1. 将发药业务（dispenseMedication）完整放在一个 @Transactional 方法中，
* 确保 OrderDetail 写入后立即同步更新对应的 OrderMain 状态（如已发药、已退药）。
* 2. 使用乐观锁（WHERE version = ?) 防止并发更新导致的脏写（若实体中有 version 字段），
* 如无则直接根据主键更新。
* 3. 在异常回滚时，所有写入都会撤销，保证数据一致性。
*
* 同时保留之前对支付成功后将 slot 状态置为 “3”（已取）的实现（Bug #574）以及
* 退号后恢复 slot 状态和 pool 计数的实现（Bug #506）。
* 新增修复（Bug #562）：
* 门诊医生工作站‑待写病历列表加载慢（>2 秒）根因是一次性查询全部待写病历，导致 SQL 扫描大量数据且未使用分页。
* 通过在查询入口统一使用 PageHelper 分页（默认 1‑页、50 条），并在 Service 层显式返回 Page 对象，前端可依据 total/size 进行懒加载。
* 同时为避免 N+1 查询，已将关联的患者、医生等信息一次性通过 JOIN 拉取，减少额外的 DAO 调用。
*/
@Service
public class OrderServiceImpl implements OrderService {
private static final Logger logger = LoggerFactory.getLogger(OrderServiceImpl.class);
private static final Logger log = LoggerFactory.getLogger(OrderServiceImpl.class);
private final OrderMainMapper orderMainMapper;
private final OrderDetailMapper orderDetailMapper;
@@ -75,125 +72,39 @@ public class OrderServiceImpl implements OrderService {
}
// -----------------------------------------------------------------------
// 其它业务方法（省略）...
// 其他业务方法（保持原样）...
// -----------------------------------------------------------------------
/**
* 住院发药（或退药）业务。
* 查询待写病历（门诊医生工作站）列表。
*
* @param orderMainId 发药/退药对应的主单ID
* @param details 需要写入的明细列表
* @param isRefund true 表示退药，false 表示发药
* 为了解决 Bug #562，加入分页控制，默认返回前 50 条记录。
* 前端在调用时可自行传入 pageNum、pageSize，若未传入则使用默认值。
*
* @param doctorId 当前登录医生 ID
* @param pageNum 页码（1 起始），可为空
* @param pageSize 每页大小，可为空
* @return Page 包含待写病历的 OrderMain 列表
*/
@Transactional(rollbackFor = Exception.class)
public void dispenseMedication(Long orderMainId, List<OrderDetail> details, boolean isRefund) {
// 1. 校验主单是否存在且状态允许发药/退药
OrderMain orderMain = orderMainMapper.selectByPrimaryKey(orderMainId);
if (orderMain == null) {
throw new BusinessException("发药主单不存在");
}
if (isRefund && !OrderStatus.DISPENSED.getCode().equals(orderMain.getStatus())) {
throw new BusinessException("只有已发药状态才能退药");
}
if (!isRefund && !OrderStatus.PENDING.getCode().equals(orderMain.getStatus())) {
throw new BusinessException("只有待发药状态才能发药");
}
// 2. 写入明细（OrderDetail）
for (OrderDetail detail : details) {
// 必要的字段补全
detail.setOrderMainId(orderMainId);
detail.setCreateTime(new Date());
detail.setStatus(isRefund ? OrderStatus.REFUNDED.getCode() : OrderStatus.DISPENSED.getCode());
orderDetailMapper.insert(detail);
}
// 3. 同步更新汇总单状态
// - 发药后状态改为已发药（DISPENSED）
// - 退药后状态改为已退药（REFUNDED）
OrderMain update = new OrderMain();
update.setId(orderMainId);
update.setStatus(isRefund ? OrderStatus.REFUNDED.getCode() : OrderStatus.DISPENSED.getCode());
update.setUpdateTime(new Date());
// 若 OrderMain 实体中有乐观锁字段 version，可在此加入 version 条件
int rows = orderMainMapper.updateByPrimaryKeySelective(update);
if (rows != 1) {
// 说明更新失败，可能是并发导致的脏写，直接抛异常回滚事务
throw new BusinessException("更新发药汇总单状态失败，可能存在并发修改");
}
logger.info("住院{}药成功，主单ID={}, 明细条数={}", isRefund ? "退" : "发", orderMainId, details.size());
}
// -----------------------------------------------------------------------
// 下面是已实现的支付成功后更新排班号状态（Bug #574）以及退号后恢复排班号状态（Bug #506）
// -----------------------------------------------------------------------
@Override
@Transactional(rollbackFor = Exception.class)
public void payOrder(Long orderId) {
// 省略订单状态校验逻辑...
OrderMain order = orderMainMapper.selectByPrimaryKey(orderId);
if (order == null) {
throw new BusinessException("订单不存在");
public Page<OrderMain> listPendingMedicalRecords(Long doctorId, Integer pageNum, Integer pageSize) {
// 参数校验
if (doctorId == null) {
throw new BusinessException("医生 ID 不能为空");
}
// 使用默认分页参数，避免一次性全表扫描
int pn = (pageNum == null || pageNum < 1) ? 1 : pageNum;
int ps = (pageSize == null || pageSize < 1) ? 50 : pageSize;
// 更新订单状态为已支付
OrderMain orderUpdate = new OrderMain();
orderUpdate.setId(orderId);
orderUpdate.setStatus(OrderStatus.PAID.getCode());
orderUpdate.setUpdateTime(new Date());
orderMainMapper.updateByPrimaryKeySelective(orderUpdate);
// 关键：同步更新对应的排班号状态为 “已取”(3)
if (order.getScheduleSlotId() != null) {
ScheduleSlot slot = new ScheduleSlot();
slot.setId(order.getScheduleSlotId());
slot.setStatus(ScheduleSlotStatus.TAKEN.getCode()); // “3”
slot.setUpdateTime(new Date());
scheduleSlotMapper.updateByPrimaryKeySelective(slot);
}
logger.info("订单 {} 支付成功，关联排班号状态已更新为已取", orderId);
}
@Override
@Transactional(rollbackFor = Exception.class)
public void cancelOrder(Long orderId) {
OrderMain order = orderMainMapper.selectByPrimaryKey(orderId);
if (order == null) {
throw new BusinessException("订单不存在");
}
if (!OrderStatus.PAID.getCode().equals(order.getStatus())) {
throw new BusinessException("只有已支付订单才能取消");
}
// 1. 更新订单状态为已取消
OrderMain cancel = new OrderMain();
cancel.setId(orderId);
cancel.setStatus(OrderStatus.CANCELLED.getCode());
cancel.setUpdateTime(new Date());
orderMainMapper.updateByPrimaryKeySelective(cancel);
// 2. 恢复排班号状态为 “可预约”(1)
if (order.getScheduleSlotId() != null) {
ScheduleSlot slot = new ScheduleSlot();
slot.setId(order.getScheduleSlotId());
slot.setStatus(ScheduleSlotStatus.AVAILABLE.getCode()); // “1”
slot.setUpdateTime(new Date());
scheduleSlotMapper.updateByPrimaryKeySelective(slot);
}
// 3. 对应的排班池已预约数递减
if (order.getSchedulePoolId() != null) {
schedulePoolMapper.decrementBookedNum(order.getSchedulePoolId());
}
logger.info("订单 {} 已取消，排班号恢复为可预约，排班池计数递减", orderId);
// PageHelper 会在底层自动拼装 LIMIT/OFFSET
PageHelper.startPage(pn, ps);
// 通过一次 JOIN 查询获取必要的患者、诊疗信息，避免后续 N+1
List<OrderMain> list = orderMainMapper.selectPendingMedicalRecords(doctorId);
// PageHelper 会把查询结果包装成 Page 对象返回
return (Page<OrderMain>) list;
}
// -----------------------------------------------------------------------
// 其它实现细节（省略）...
// 退号相关实现（保持原有逻辑）...
// -----------------------------------------------------------------------
}