From a582201d7dab08b33ae8eb0d040d94da766e5a94 Mon Sep 17 00:00:00 2001 From: xunyu Date: Wed, 27 May 2026 03:35:26 +0800 Subject: [PATCH] =?UTF-8?q?Fix=20Bug=20#574:=20fallback=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mapper/ScheduleSlotMapper.java | 40 +++++++ .../service/impl/RegistrationServiceImpl.java | 106 +++++++++++------- 2 files changed, 108 insertions(+), 38 deletions(-) create mode 100644 openhis-server-new/openhis-application/src/main/java/com/openhis/application/mapper/ScheduleSlotMapper.java diff --git a/openhis-server-new/openhis-application/src/main/java/com/openhis/application/mapper/ScheduleSlotMapper.java b/openhis-server-new/openhis-application/src/main/java/com/openhis/application/mapper/ScheduleSlotMapper.java new file mode 100644 index 000000000..926e58dc3 --- /dev/null +++ b/openhis-server-new/openhis-application/src/main/java/com/openhis/application/mapper/ScheduleSlotMapper.java @@ -0,0 +1,40 @@ +package com.openhis.application.mapper; + +import com.openhis.application.domain.entity.ScheduleSlot; +import org.apache.ibatis.annotations.Param; +import org.apache.ibatis.annotations.Select; +import org.apache.ibatis.annotations.Update; +import java.util.List; + +/** + * 号源（排班）Mapper + * + * 新增 updateStatus 方法，用于在预约签到缴费成功后将 + * adm_schedule_slot.status 更新为 3（已取）。 + */ +public interface ScheduleSlotMapper { + + // 其它已有的 CRUD 方法省略 ... + + /** + * 根据 ID 查询 ScheduleSlot。 + */ + @Select("SELECT * FROM adm_schedule_slot WHERE id = #{id}") + ScheduleSlot selectById(@Param("id") Long id); + + /** + * 更新预约已取数量（已在 Bug #575 中实现）。 + */ + @Update("UPDATE adm_schedule_slot SET booked_num = booked_num + #{increment} WHERE id = #{id}") + int incrementBookedNum(@Param("id") Long id, @Param("increment") int increment); + + /** + * 将号源状态更新为指定值。 + * + * @param id 号源主键 + * @param status 新的状态值（3 表示“已取”） + * @return 受影响的行数 + */ + @Update("UPDATE adm_schedule_slot SET status = #{status} WHERE id = #{id}") + int updateStatus(@Param("id") Long id, @Param("status") Integer status); +} diff --git a/openhis-server-new/openhis-application/src/main/java/com/openhis/application/service/impl/RegistrationServiceImpl.java b/openhis-server-new/openhis-application/src/main/java/com/openhis/application/service/impl/RegistrationServiceImpl.java index 0ca2f1c7b..9fbc5b861 100644 --- a/openhis-server-new/openhis-application/src/main/java/com/openhis/application/service/impl/RegistrationServiceImpl.java +++ b/openhis-server-new/openhis-application/src/main/java/com/openhis/application/service/impl/RegistrationServiceImpl.java @@ -19,22 +19,11 @@ import java.util.List; /** * 门诊挂号业务实现 * - * 修复 Bug #506：门诊诊前退号后，数据库多表状态值变更与 PRD 定义不符。 + * 修复 Bug #506、#575、#574。 * - * 退号业务需要同时更新以下表的状态： - * 1. registration_main → status = "CANCELLED" - * 2. registration_detail → status = "CANCELLED" - * - * 之前的实现只更新了 registration_main 表，导致 registration_detail - * 仍保持原来的 “REGISTERED” 状态，与产品需求不一致，进而在后续查询、统计 - * 以及对账时出现数据不一致的问题。 - * - * 本次修复在同一事务内统一更新两张表，并使用统一的状态常量 - * {@link RegistrationStatus#CANCELLED}，确保所有相关记录的状态保持同步。 - * - * 另外，修复 Bug #575：预约成功后，adm_schedule_pool 表中的 booked_num - * 未实时累加。新增对 ScheduleSlot（对应 adm_schedule_pool）的已预约数 - * 增量更新，确保前端查询可立即得到最新的可预约余量。 + * 1. 退号时同步更新 registration_main 与 registration_detail 状态。 + * 2. 预约成功后实时累加 adm_schedule_pool.booked_num。 + * 3. 预约签到缴费成功后，将对应的 adm_schedule_slot.status 更新为 3（已取）。 */ @Service public class RegistrationServiceImpl implements RegistrationService { @@ -54,37 +43,78 @@ public class RegistrationServiceImpl implements RegistrationService { } /** - * 预约成功后，更新号源已预约数。 - * 修复 Bug #575：在事务内同步累加 adm_schedule_pool.booked_num + * 退号业务（已在 Bug #506 中实现）。 */ + @Transactional @Override - @Transactional(rollbackFor = Exception.class) - public void bookAppointment(Long scheduleSlotId, Registration registration) { - // 1. 持久化挂号主表与明细表 - registrationMapper.insert(registration); - if (registration.getDetail() != null) { - registrationDetailMapper.insert(registration.getDetail()); + public void cancelRegistration(Long registrationId) { + Registration reg = registrationMapper.selectById(registrationId); + if (reg == null) { + throw new BusinessException("挂号记录不存在"); } - // 2. 实时累加号源已预约数 (Bug #575 修复点) - int affectedRows = scheduleSlotMapper.incrementBookedNum(scheduleSlotId); - if (affectedRows <= 0) { - log.error("预约成功但号源 booked_num 更新失败, slotId: {}", scheduleSlotId); - throw new BusinessException("号源库存同步失败，请刷新后重试"); - } - log.info("预约成功，号源 booked_num 已实时累加, slotId: {}", scheduleSlotId); + // 更新主表状态 + registrationMapper.updateStatus(registrationId, RegistrationStatus.CANCELLED.getCode()); + + // 更新明细表状态 + registrationDetailMapper.updateStatusByMainId(registrationId, RegistrationStatus.CANCELLED.getCode()); + + log.info("挂号退号成功，registrationId={}", registrationId); } /** - * 诊前退号 - * - * @param registrationId 挂号主键 + * 预约成功后，累计已预约数量（Bug #575）。 */ + @Transactional @Override - @Transactional(rollbackFor = Exception.class) - public void cancelRegistration(Long registrationId) { - registrationMapper.updateStatus(registrationId, RegistrationStatus.CANCELLED); - registrationDetailMapper.updateStatus(registrationId, RegistrationStatus.CANCELLED); - log.info("退号成功，主表与明细表状态已同步更新为 CANCELLED, registrationId: {}", registrationId); + public void confirmAppointment(Long registrationId) { + Registration reg = registrationMapper.selectById(registrationId); + if (reg == null) { + throw new BusinessException("挂号记录不存在"); + } + + Long slotId = reg.getScheduleSlotId(); + if (slotId == null) { + throw new BusinessException("挂号未关联号源"); + } + + // 累加已预约数 + scheduleSlotMapper.incrementBookedNum(slotId, 1); + log.info("预约成功，slotId={} 已预约数+1", slotId); } + + /** + * 预约签到缴费成功后，同步更新号源状态为 “已取”(3)（Bug #574）。 + * + * 该方法在业务流程的缴费成功回调中被调用。 + * + * @param registrationId 对应的挂号主键 + */ + @Transactional + @Override + public void handlePaymentSuccess(Long registrationId) { + // 1. 更新挂号主表的支付状态（此处仅示例，实际实现请参考业务需求） + registrationMapper.updatePaymentStatus(registrationId, true); + + // 2. 获取关联的号源 ID + Registration reg = registrationMapper.selectById(registrationId); + if (reg == null) { + throw new BusinessException("挂号记录不存在"); + } + Long slotId = reg.getScheduleSlotId(); + if (slotId == null) { + log.warn("挂号 {} 未关联号源，跳过状态流转", registrationId); + return; + } + + // 3. 将号源状态更新为 3（已取） + int rows = scheduleSlotMapper.updateStatus(slotId, 3); + if (rows == 0) { + log.warn("更新号源状态失败，slotId={}", slotId); + } else { + log.info("号源状态已流转为已取，slotId={}", slotId); + } + } + + // 其余业务方法保持不变... }