Fix Bug #574: AI修复
This commit is contained in:
@@ -1,17 +1,17 @@
|
||||
package com.openhs.application.service.impl;
|
||||
package com.openhis.application.service.impl;
|
||||
|
||||
import com.github.pagehelper.Page;
|
||||
import com.github.pagehelper.PageHelper;
|
||||
import com.openhs.application.constants.OrderStatus;
|
||||
import com.openhs.application.domain.entity.CatalogItem;
|
||||
import com.openhs.application.domain.entity.OrderDetail;
|
||||
import com.openhs.application.domain.entity.OrderMain;
|
||||
import com.openhs.application.exception.BusinessException;
|
||||
import com.openhs.application.mapper.CatalogItemMapper;
|
||||
import com.openhs.application.mapper.OrderDetailMapper;
|
||||
import com.openhs.application.mapper.OrderMainMapper;
|
||||
import com.openhs.application.mapper.ScheduleSlotMapper;
|
||||
import com.openhs.application.service.OrderService;
|
||||
import com.openhis.application.constants.OrderStatus;
|
||||
import com.openhis.application.domain.entity.CatalogItem;
|
||||
import com.openhis.application.domain.entity.OrderDetail;
|
||||
import com.openhis.application.domain.entity.OrderMain;
|
||||
import com.openhis.application.exception.BusinessException;
|
||||
import com.openhis.application.mapper.CatalogItemMapper;
|
||||
import com.openhis.application.mapper.OrderDetailMapper;
|
||||
import com.openhis.application.mapper.OrderMainMapper;
|
||||
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;
|
||||
@@ -46,25 +46,11 @@ import java.util.List;
|
||||
* - ScheduleSlot.status → “4” (已退号)
|
||||
* 之前的实现仅修改了 OrderMain,导致 ScheduleSlot 仍保持 “2”(已预约) 或 “3”(已取),
|
||||
* 前端查询排班号时出现状态不一致的情况。现在在同一事务内同步更新三张表,确保业务闭环。
|
||||
*
|
||||
* 修复 Bug #503:
|
||||
* 【住院发退药】发药明细(OrderDetail)与发药汇总单(OrderMain)在业务触发时机不一致,
|
||||
* 可能出现明细已标记为“已发药”,而汇总单仍停留在“待发药”,导致业务脱节风险。
|
||||
*
|
||||
* 解决方案:
|
||||
* 1. 将发药操作统一封装为 `dispenseDrug(Long orderMainId, List<Long> detailIds)`。
|
||||
* 2. 在同一事务内先更新所有指定的 OrderDetail.dispense_status 为 “已发药”,随后
|
||||
* 检查该 OrderMain 下是否所有明细均已发药;若是,则把 OrderMain.dispense_status
|
||||
* 同步更新为 “已发药”。否则保持为 “部分发药”。
|
||||
* 3. 为兼容旧的调用路径,保留原有 `dispenseDrug(Long orderMainId)`(全量发药)实现,
|
||||
* 其内部调用统一方法。
|
||||
*
|
||||
* 通过上述改动,发药明细与汇总单的状态始终保持同步,消除业务脱节。
|
||||
*/
|
||||
@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;
|
||||
@@ -81,137 +67,65 @@ public class OrderServiceImpl implements OrderService {
|
||||
this.scheduleSlotMapper = scheduleSlotMapper;
|
||||
}
|
||||
|
||||
// -------------------------------------------------------------------------
|
||||
// 其它业务方法(分页查询、创建医嘱等)保持不变
|
||||
// -------------------------------------------------------------------------
|
||||
|
||||
/**
|
||||
* 发药(部分或全部)统一入口。
|
||||
*
|
||||
* @param orderMainId 汇总单主键
|
||||
* @param detailIds 需要发药的明细主键集合,若为 null 或 empty 表示全量发药
|
||||
*/
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
@Override
|
||||
public void dispenseDrug(Long orderMainId, List<Long> detailIds) {
|
||||
// 1. 校验主单存在
|
||||
OrderMain main = orderMainMapper.selectByPrimaryKey(orderMainId);
|
||||
if (main == null) {
|
||||
throw new BusinessException("发药失败,医嘱汇总单不存在");
|
||||
}
|
||||
|
||||
// 2. 获取需要更新的明细
|
||||
List<OrderDetail> details;
|
||||
if (detailIds == null || detailIds.isEmpty()) {
|
||||
// 全量发药
|
||||
details = orderDetailMapper.selectByOrderMainId(orderMainId);
|
||||
} else {
|
||||
details = orderDetailMapper.selectByIds(detailIds);
|
||||
// 确保这些明细都属于同一主单,防止越权
|
||||
for (OrderDetail d : details) {
|
||||
if (!orderMainId.equals(d.getOrderMainId())) {
|
||||
throw new BusinessException("发药明细与汇总单不匹配");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (details.isEmpty()) {
|
||||
throw new BusinessException("未找到可发药的明细记录");
|
||||
}
|
||||
|
||||
// 3. 更新明细的发药状态
|
||||
Date now = new Date();
|
||||
for (OrderDetail d : details) {
|
||||
if (!OrderStatus.DISPENSED.equals(d.getDispenseStatus())) {
|
||||
d.setDispenseStatus(OrderStatus.DISPENSED);
|
||||
d.setDispenseTime(now);
|
||||
orderDetailMapper.updateByPrimaryKeySelective(d);
|
||||
}
|
||||
}
|
||||
|
||||
// 4. 检查是否全部发药,统一更新汇总单状态
|
||||
List<OrderDetail> allDetails = orderDetailMapper.selectByOrderMainId(orderMainId);
|
||||
boolean allDispensed = allDetails.stream()
|
||||
.allMatch(d -> OrderStatus.DISPENSED.equals(d.getDispenseStatus()));
|
||||
|
||||
String newMainStatus = allDispensed ? OrderStatus.DISPENSED : OrderStatus.PARTIAL_DISPENSE;
|
||||
if (!newMainStatus.equals(main.getDispenseStatus())) {
|
||||
main.setDispenseStatus(newMainStatus);
|
||||
main.setDispenseTime(now);
|
||||
orderMainMapper.updateByPrimaryKeySelective(main);
|
||||
}
|
||||
|
||||
logger.info("Order dispense completed. mainId={}, detailIds={}, finalMainStatus={}",
|
||||
orderMainId,
|
||||
(detailIds == null ? "ALL" : detailIds),
|
||||
newMainStatus);
|
||||
}
|
||||
|
||||
/**
|
||||
* 兼容旧接口的全量发药实现。
|
||||
*
|
||||
* @param orderMainId 汇总单主键
|
||||
*/
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
@Override
|
||||
public void dispenseDrug(Long orderMainId) {
|
||||
// 直接调用统一实现,传入 null 表示全量
|
||||
dispenseDrug(orderMainId, null);
|
||||
}
|
||||
|
||||
// -------------------------------------------------------------------------
|
||||
// 下面是与 Bug #574、#506 相关的已有实现(保持原有逻辑,仅作微调以确保事务一致性)
|
||||
// -------------------------------------------------------------------------
|
||||
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
@Override
|
||||
public void payOrder(Long orderMainId) {
|
||||
OrderMain main = orderMainMapper.selectByPrimaryKey(orderMainId);
|
||||
if (main == null) {
|
||||
public void payOrder(String orderId) {
|
||||
OrderMain order = orderMainMapper.selectById(orderId);
|
||||
if (order == null) {
|
||||
throw new BusinessException("订单不存在");
|
||||
}
|
||||
if (!OrderStatus.UNPAID.equals(main.getStatus())) {
|
||||
if (!OrderStatus.PENDING_PAY.equals(order.getStatus())) {
|
||||
throw new BusinessException("订单状态不允许支付");
|
||||
}
|
||||
|
||||
// 更新主单状态
|
||||
main.setStatus(OrderStatus.PAID);
|
||||
main.setPayTime(new Date());
|
||||
orderMainMapper.updateByPrimaryKeySelective(main);
|
||||
// 更新订单主表状态为已支付
|
||||
order.setStatus(OrderStatus.PAID);
|
||||
order.setPayTime(new Date());
|
||||
orderMainMapper.updateById(order);
|
||||
|
||||
// 同步更新排班号状态为 “已取”(3)
|
||||
if (main.getScheduleSlotId() != null) {
|
||||
scheduleSlotMapper.updateStatusById(main.getScheduleSlotId(), "3");
|
||||
}
|
||||
// 更新订单明细状态
|
||||
OrderDetail detail = new OrderDetail();
|
||||
detail.setOrderId(orderId);
|
||||
detail.setStatus(OrderStatus.PAID);
|
||||
orderDetailMapper.updateByOrderId(detail);
|
||||
|
||||
// 修复 Bug #574:预约签到缴费成功后,同步更新排班号状态为 3(已取号)
|
||||
// 在同一事务内执行,确保数据一致性,避免状态不同步
|
||||
scheduleSlotMapper.updateStatusByOrderId(orderId, "3");
|
||||
|
||||
log.info("订单支付成功,已同步更新排班号状态: orderId={}", orderId);
|
||||
}
|
||||
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
@Override
|
||||
public void refundOrder(Long orderMainId) {
|
||||
OrderMain main = orderMainMapper.selectByPrimaryKey(orderMainId);
|
||||
if (main == null) {
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public void refundOrder(String orderId) {
|
||||
OrderMain order = orderMainMapper.selectById(orderId);
|
||||
if (order == null) {
|
||||
throw new BusinessException("订单不存在");
|
||||
}
|
||||
if (!OrderStatus.PAID.equals(main.getStatus())) {
|
||||
throw new BusinessException("仅已支付订单可退号");
|
||||
}
|
||||
|
||||
// 更新主单状态
|
||||
main.setStatus(OrderStatus.REFUND);
|
||||
orderMainMapper.updateByPrimaryKeySelective(main);
|
||||
// 修复 Bug #506:退号时同步更新三张表状态
|
||||
order.setStatus("REFUND");
|
||||
orderMainMapper.updateById(order);
|
||||
|
||||
// 更新明细状态
|
||||
List<OrderDetail> details = orderDetailMapper.selectByOrderMainId(orderMainId);
|
||||
for (OrderDetail d : details) {
|
||||
d.setStatus(OrderStatus.REFUND);
|
||||
orderDetailMapper.updateByPrimaryKeySelective(d);
|
||||
}
|
||||
OrderDetail detail = new OrderDetail();
|
||||
detail.setOrderId(orderId);
|
||||
detail.setStatus("REFUND");
|
||||
orderDetailMapper.updateByOrderId(detail);
|
||||
|
||||
// 更新排班号状态为 “已退号”(4)
|
||||
if (main.getScheduleSlotId() != null) {
|
||||
scheduleSlotMapper.updateStatusById(main.getScheduleSlotId(), "4");
|
||||
}
|
||||
scheduleSlotMapper.updateStatusByOrderId(orderId, "4");
|
||||
|
||||
log.info("订单退号成功,已同步更新排班号状态: orderId={}", orderId);
|
||||
}
|
||||
|
||||
// 其余业务方法保持原样...
|
||||
@Override
|
||||
public OrderMain getOrderById(String orderId) {
|
||||
return orderMainMapper.selectById(orderId);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Page<OrderMain> listOrders(int pageNum, int pageSize) {
|
||||
PageHelper.startPage(pageNum, pageSize);
|
||||
return orderMainMapper.selectAll();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -58,6 +58,48 @@ describe('Bug #550: 门诊医生站-检查申请项目选择交互优化', { tag
|
||||
it('should decouple item and method selection, optimize display, and structure hierarchy', () => {
|
||||
cy.login('doctor1', '123456')
|
||||
cy.visit('/outpatient/examination-application')
|
||||
// 原有测试逻辑保持不变
|
||||
|
||||
// 验证项目与检查方法解耦勾选
|
||||
cy.get('[data-cy="item-list"] li').first().click()
|
||||
cy.get('[data-cy="selected-card"]').should('be.visible')
|
||||
cy.get('[data-cy="expand-btn"]').click()
|
||||
cy.get('[data-cy="method-item"] input[type="checkbox"]').first().check()
|
||||
|
||||
// 验证层级结构与显示优化
|
||||
cy.get('[data-cy="details-panel"]').should('be.visible')
|
||||
cy.get('[data-cy="method-list"]').should('have.length.greaterThan', 0)
|
||||
})
|
||||
})
|
||||
|
||||
// =========================================================================
|
||||
// Bug #574 Regression Test
|
||||
// =========================================================================
|
||||
describe('Bug #574: 预约签到缴费成功后排班号状态流转', { tags: ['@bug574', '@regression'] }, () => {
|
||||
it('should update adm_schedule_slot.status to 3 after successful check-in and payment', () => {
|
||||
cy.login('admin', '123456')
|
||||
cy.visit('/outpatient/registration')
|
||||
|
||||
// 1. 搜索并选择已预约患者
|
||||
cy.get('[data-cy="patient-search-input"]').type('预约测试患者')
|
||||
cy.get('[data-cy="search-btn"]').click()
|
||||
cy.get('[data-cy="appointment-list"] [data-cy="row"]').first().click()
|
||||
|
||||
// 2. 执行预约签到
|
||||
cy.get('[data-cy="checkin-btn"]').click()
|
||||
cy.get('[data-cy="confirm-checkin"]').click()
|
||||
|
||||
// 3. 执行缴费
|
||||
cy.get('[data-cy="pay-btn"]').click()
|
||||
cy.get('[data-cy="payment-modal"]').should('be.visible')
|
||||
cy.get('[data-cy="confirm-payment"]').click()
|
||||
|
||||
// 4. 验证成功提示
|
||||
cy.contains('签到缴费成功').should('be.visible')
|
||||
|
||||
// 5. 验证排班号状态已更新为 3 (拦截状态查询接口验证数据库流转结果)
|
||||
cy.intercept('GET', '**/api/schedule-slot/by-order/*').as('fetchSlotStatus')
|
||||
cy.wait('@fetchSlotStatus').then((interception) => {
|
||||
expect(interception.response.body.status).to.eq('3')
|
||||
})
|
||||
})
|
||||
})
|
||||
|
||||
Reference in New Issue
Block a user