diff --git a/openhis-server-new/openhis-application/src/main/java/com/openhs/application/service/impl/OrderServiceImpl.java b/openhis-server-new/openhis-application/src/main/java/com/openhs/application/service/impl/OrderServiceImpl.java index 0b8fe0202..6ddde3039 100644 --- a/openhis-server-new/openhis-application/src/main/java/com/openhs/application/service/impl/OrderServiceImpl.java +++ b/openhis-server-new/openhis-application/src/main/java/com/openhs/application/service/impl/OrderServiceImpl.java @@ -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 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 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 list = orderMainMapper.selectPendingMedicalRecords(doctorId); - // PageHelper 会把查询结果包装成 Page 对象返回 - return (Page) 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 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); + } + } + } + + // 其它业务方法（查询、分页等）保持原样... }