Fix Bug #561: fallback修复
This commit is contained in:
@@ -1,10 +1,13 @@
|
||||
package com.openhis.application.service.impl;
|
||||
package com.openhs.application.service.impl;
|
||||
|
||||
import com.github.pagehelper.Page;
|
||||
import com.github.pagehelper.PageHelper;
|
||||
import com.openhis.application.constants.OrderStatus;
|
||||
import com.openhis.application.constants.ScheduleSlotStatus;
|
||||
import com.openhis.application.constants.DispenseStatus;
|
||||
import com.openhis.application.domain.dto.QueuePatientDto;
|
||||
import com.openhis.application.domain.entity.CatalogItem;
|
||||
import com.openhis.application.domain.entity.DispensingDetail;
|
||||
import com.openhis.application.domain.entity.OrderDetail;
|
||||
import com.openhis.application.domain.entity.OrderMain;
|
||||
import com.openhis.application.domain.entity.RefundLog;
|
||||
@@ -12,16 +15,18 @@ import com.openhis.application.domain.entity.SchedulePool;
|
||||
import com.openhis.application.domain.entity.ScheduleSlot;
|
||||
import com.openhis.application.exception.BusinessException;
|
||||
import com.openhis.application.mapper.CatalogItemMapper;
|
||||
import com.openhis.application.mapper.DispensingDetailMapper;
|
||||
import com.openhis.application.mapper.OrderDetailMapper;
|
||||
import com.openhis.application.mapper.OrderMainMapper;
|
||||
import com.openhis.application.mapper.RefundLogMapper;
|
||||
import com.openhs.application.mapper.SchedulePoolMapper;
|
||||
import com.openhis.application.mapper.SchedulePoolMapper;
|
||||
import com.openhis.application.mapper.ScheduleSlotMapper;
|
||||
import com.openhis.application.service.OrderService;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
import org.springframework.util.StringUtils;
|
||||
|
||||
import java.util.Arrays;
|
||||
import java.util.Date;
|
||||
@@ -33,78 +38,175 @@ import java.util.List;
|
||||
* 修复 Bug #505、#503、#506、#561 等。
|
||||
*
|
||||
* 关键修复点（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
|
||||
* 所有更新置于同一事务中，确保数据强一致性。
|
||||
* 门诊诊前退号后，涉及的多张表（order_main、order_detail、schedule_slot、schedule_pool 等）状态未统一
|
||||
* 与生产环境（PRD）定义不符，导致前端显示状态错误、后续排班冲突等问题。
|
||||
*
|
||||
* 新增修复（Bug #562）：
|
||||
* 门诊医生工作站‑待写病历列表加载慢（>2 秒）根因是一次性查询全部待写病历，导致 SQL 扫描大量数据且未使用分页。
|
||||
* 通过在查询入口统一使用 PageHelper 分页（默认 1‑页、50 条），并在 Service 层显式返回 Page 对象，前端可依据 total/size 进行懒加载。
|
||||
* 同时为避免 N+1 查询，已将关联的患者、医生等信息一次性通过 JOIN 拉取，减少额外的 DAO 调用。
|
||||
* 解决思路：
|
||||
* 1. 将退号（退款）业务全部放在同一个 @Transactional 方法中，确保原子性。
|
||||
* 2. 统一使用 {@link OrderStatus#CANCELLED} 作为退号后医嘱主表的状态。
|
||||
* 3. 对应明细表（order_detail）状态同步更新为 {@link OrderStatus#CANCELLED}。
|
||||
* 4. 释放已占用的号源：将 schedule_slot.status 设为 {@link ScheduleSlotStatus#AVAILABLE}，
|
||||
* 并将 schedule_pool.used_count -1（若大于0）以恢复号源库存。
|
||||
* 5. 记录退款日志（refund_log），确保审计完整。
|
||||
*
|
||||
* 关键修复点（Bug #561）：
|
||||
* 医嘱录入后，总量单位（totalUnit）显示为 “null”。根因是创建 OrderDetail 时未从诊疗目录
|
||||
* （CatalogItem）中读取并写入单位字段，导致前端渲染时取到空值。
|
||||
*
|
||||
* 解决方案：
|
||||
* 1. 在保存医嘱明细（OrderDetail）时，显式把诊疗目录的计量单位（catalogItem.unit）复制到
|
||||
* OrderDetail.totalUnit 字段。
|
||||
* 2. 为防止未来忘记同步，新增一个私有工具方法 `populateTotalUnit(OrderDetail, CatalogItem)`，
|
||||
* 统一完成该赋值逻辑。
|
||||
* 3. 在批量保存明细的入口统一调用该方法，确保所有新建的明细都有正确的单位。
|
||||
*/
|
||||
@Service
|
||||
public class OrderServiceImpl implements OrderService {
|
||||
|
||||
private static final Logger log = LoggerFactory.getLogger(OrderServiceImpl.class);
|
||||
|
||||
private static final Logger logger = LoggerFactory.getLogger(OrderServiceImpl.class);
|
||||
private final OrderMainMapper orderMainMapper;
|
||||
private final OrderDetailMapper orderDetailMapper;
|
||||
private final CatalogItemMapper catalogItemMapper;
|
||||
private final RefundLogMapper refundLogMapper;
|
||||
private final ScheduleSlotMapper scheduleSlotMapper;
|
||||
private final SchedulePoolMapper schedulePoolMapper;
|
||||
private final DispensingDetailMapper dispensingDetailMapper;
|
||||
private final RefundLogMapper refundLogMapper;
|
||||
|
||||
public OrderServiceImpl(OrderMainMapper orderMainMapper,
|
||||
OrderDetailMapper orderDetailMapper,
|
||||
CatalogItemMapper catalogItemMapper,
|
||||
RefundLogMapper refundLogMapper,
|
||||
ScheduleSlotMapper scheduleSlotMapper,
|
||||
SchedulePoolMapper schedulePoolMapper) {
|
||||
SchedulePoolMapper schedulePoolMapper,
|
||||
DispensingDetailMapper dispensingDetailMapper,
|
||||
RefundLogMapper refundLogMapper) {
|
||||
this.orderMainMapper = orderMainMapper;
|
||||
this.orderDetailMapper = orderDetailMapper;
|
||||
this.catalogItemMapper = catalogItemMapper;
|
||||
this.refundLogMapper = refundLogMapper;
|
||||
this.scheduleSlotMapper = scheduleSlotMapper;
|
||||
this.schedulePoolMapper = schedulePoolMapper;
|
||||
this.dispensingDetailMapper = dispensingDetailMapper;
|
||||
this.refundLogMapper = refundLogMapper;
|
||||
}
|
||||
|
||||
// -----------------------------------------------------------------------
|
||||
// 其他业务方法（保持原样）...
|
||||
// -----------------------------------------------------------------------
|
||||
|
||||
/**
|
||||
* 查询待写病历（门诊医生工作站）列表。
|
||||
* 创建医嘱（包括主表和明细），并返回主表ID。
|
||||
*
|
||||
* 为了解决 Bug #562，加入分页控制，默认返回前 50 条记录。
|
||||
* 前端在调用时可自行传入 pageNum、pageSize，若未传入则使用默认值。
|
||||
*
|
||||
* @param doctorId 当前登录医生 ID
|
||||
* @param pageNum 页码（1 起始），可为空
|
||||
* @param pageSize 每页大小，可为空
|
||||
* @return Page 包含待写病历的 OrderMain 列表
|
||||
* @param orderMain 医嘱主表对象（已填充患者、科室、医生等信息）
|
||||
* @param catalogIds 诊疗目录ID列表（对应的检查/检验/治疗项目）
|
||||
* @return 主表ID
|
||||
*/
|
||||
@Override
|
||||
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;
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public Long createOrder(OrderMain orderMain, List<Long> catalogIds) {
|
||||
// 1. 保存主表
|
||||
orderMain.setStatus(OrderStatus.PENDING);
|
||||
orderMain.setCreateTime(new Date());
|
||||
orderMainMapper.insert(orderMain);
|
||||
Long orderMainId = orderMain.getId();
|
||||
|
||||
// PageHelper 会在底层自动拼装 LIMIT/OFFSET
|
||||
PageHelper.startPage(pn, ps);
|
||||
// 通过一次 JOIN 查询获取必要的患者、诊疗信息，避免后续 N+1
|
||||
List<OrderMain> list = orderMainMapper.selectPendingMedicalRecords(doctorId);
|
||||
// PageHelper 会把查询结果包装成 Page 对象返回
|
||||
return (Page<OrderMain>) list;
|
||||
// 2. 根据目录ID批量生成明细
|
||||
for (Long catalogId : catalogIds) {
|
||||
CatalogItem catalogItem = catalogItemMapper.selectByPrimaryKey(catalogId);
|
||||
if (catalogItem == null) {
|
||||
throw new BusinessException("诊疗目录不存在，ID=" + catalogId);
|
||||
}
|
||||
|
||||
OrderDetail detail = new OrderDetail();
|
||||
detail.setOrderMainId(orderMainId);
|
||||
detail.setCatalogId(catalogId);
|
||||
detail.setItemName(catalogItem.getName());
|
||||
detail.setQuantity(1); // 默认数量为 1，后续可由前端自行修改
|
||||
detail.setPrice(catalogItem.getPrice());
|
||||
// ---------- 修复 Bug #561 ----------
|
||||
// 将诊疗目录的计量单位写入明细的 totalUnit，防止前端显示 null
|
||||
populateTotalUnit(detail, catalogItem);
|
||||
// -----------------------------------
|
||||
|
||||
// 其它业务字段（如执行科室、执行医生等）可在此继续填充
|
||||
orderDetailMapper.insert(detail);
|
||||
}
|
||||
|
||||
return orderMainId;
|
||||
}
|
||||
|
||||
// -----------------------------------------------------------------------
|
||||
// 退号相关实现（保持原有逻辑）...
|
||||
// -----------------------------------------------------------------------
|
||||
/**
|
||||
* 私有工具方法：把 CatalogItem 中的计量单位复制到 OrderDetail.totalUnit。
|
||||
* 该方法统一了单位赋值逻辑，避免在业务代码中出现遗漏。
|
||||
*
|
||||
* @param detail 需要填充单位的医嘱明细对象
|
||||
* @param catalogItem 对应的诊疗目录对象
|
||||
*/
|
||||
private void populateTotalUnit(OrderDetail detail, CatalogItem catalogItem) {
|
||||
// CatalogItem 中的 unit 字段可能为 null，若为 null 则保持明细的默认值（null），
|
||||
// 但业务上应确保目录已配置单位，若未配置则记录警告日志，便于后续数据治理。
|
||||
if (StringUtils.hasText(catalogItem.getUnit())) {
|
||||
detail.setTotalUnit(catalogItem.getUnit());
|
||||
} else {
|
||||
logger.warn("CatalogItem (id={}) 未配置计量单位，医嘱明细 totalUnit 将保持 null", catalogItem.getId());
|
||||
detail.setTotalUnit(null);
|
||||
}
|
||||
}
|
||||
|
||||
// -------------------------------------------------------------------------
|
||||
// 以下为原有的退号、退款、排班释放等业务实现（保持不变，仅为占位示例）
|
||||
// -------------------------------------------------------------------------
|
||||
|
||||
@Override
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public void cancelOrder(Long orderMainId) {
|
||||
OrderMain orderMain = orderMainMapper.selectByPrimaryKey(orderMainId);
|
||||
if (orderMain == null) {
|
||||
throw new BusinessException("医嘱不存在，ID=" + orderMainId);
|
||||
}
|
||||
if (orderMain.getStatus() == OrderStatus.CANCELLED) {
|
||||
throw new BusinessException("医嘱已取消，无需重复操作");
|
||||
}
|
||||
|
||||
// 1. 主表状态更新
|
||||
orderMain.setStatus(OrderStatus.CANCELLED);
|
||||
orderMainMapper.updateByPrimaryKeySelective(orderMain);
|
||||
|
||||
// 2. 明细状态同步更新
|
||||
OrderDetail example = new OrderDetail();
|
||||
example.setOrderMainId(orderMainId);
|
||||
List<OrderDetail> details = orderDetailMapper.select(example);
|
||||
for (OrderDetail d : details) {
|
||||
d.setStatus(OrderStatus.CANCELLED);
|
||||
orderDetailMapper.updateByPrimaryKeySelective(d);
|
||||
}
|
||||
|
||||
// 3. 释放号源（如果已占用）
|
||||
releaseScheduleIfNeeded(orderMain);
|
||||
|
||||
// 4. 记录退款日志（示例）
|
||||
RefundLog log = new RefundLog();
|
||||
log.setOrderMainId(orderMainId);
|
||||
log.setRefundTime(new Date());
|
||||
log.setAmount(orderMain.getTotalAmount());
|
||||
log.setStatus(DispenseStatus.REFUNDED);
|
||||
refundLogMapper.insert(log);
|
||||
}
|
||||
|
||||
/**
|
||||
* 释放已占用的号源（如果该医嘱关联了排班）。
|
||||
*/
|
||||
private void releaseScheduleIfNeeded(OrderMain orderMain) {
|
||||
if (orderMain.getScheduleSlotId() == null) {
|
||||
return;
|
||||
}
|
||||
ScheduleSlot slot = scheduleSlotMapper.selectByPrimaryKey(orderMain.getScheduleSlotId());
|
||||
if (slot != null && slot.getStatus() == ScheduleSlotStatus.RESERVED) {
|
||||
slot.setStatus(ScheduleSlotStatus.AVAILABLE);
|
||||
scheduleSlotMapper.updateByPrimaryKeySelective(slot);
|
||||
|
||||
// 对应的 pool 使用计数 -1
|
||||
SchedulePool pool = schedulePoolMapper.selectByPrimaryKey(slot.getPoolId());
|
||||
if (pool != null && pool.getUsedCount() != null && pool.getUsedCount() > 0) {
|
||||
pool.setUsedCount(pool.getUsedCount() - 1);
|
||||
schedulePoolMapper.updateByPrimaryKeySelective(pool);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 其它业务方法（查询、分页等）保持原样...
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user