package com.smartor.statemachine.handler.impl; import com.ruoyi.common.utils.StringUtils; import com.smartor.domain.PatMedInhosp; import com.smartor.service.IPatMedInhospService; import com.smartor.statemachine.handler.InhospStateHandler; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.List; /** * 出院状态处理器 * * @author smartor */ @Slf4j @Component public class DischargeHandler implements InhospStateHandler { @Autowired private IPatMedInhospService patMedInhospService; @Override public boolean handle(PatMedInhosp patMedInhosp) { log.info("【DischargeHandler】处理出院逻辑,serialnum={}, orgid={}", patMedInhosp.getSerialnum(), patMedInhosp.getOrgid()); PatMedInhosp query = new PatMedInhosp(); query.setPatno(StringUtils.trim(patMedInhosp.getPatno())); query.setSerialnum(StringUtils.trim(patMedInhosp.getSerialnum())); query.setOrgid(StringUtils.trim(patMedInhosp.getOrgid())); // 1. 先检查是否已存在出院记录 query.setInhospstate("1"); List dischargedRecords = patMedInhospService.selectPatMedInhosp(query); if (CollectionUtils.isNotEmpty(dischargedRecords)) { log.warn("【DischargeHandler】出院记录已存在,跳过,serialnum={}, orgid={}", patMedInhosp.getSerialnum(), patMedInhosp.getOrgid()); return false; } // 2. 检查是否存在入院记录(正常流程:必须先入院才能出院) query.setInhospstate("0"); List inHospitalRecords = patMedInhospService.selectPatMedInhosp(query); if (CollectionUtils.isNotEmpty(inHospitalRecords)) { // 存在入院记录,执行状态更新为出院 try { patMedInhosp.setInhospstate("1"); patMedInhosp.setInhospid(inHospitalRecords.get(0).getInhospid()); int updateCount = patMedInhospService.updatePatMedInhosp(patMedInhosp); log.info("【DischargeHandler】更新入院记录为出院状态,serialnum={}, updateCount={}", patMedInhosp.getSerialnum(), updateCount); return updateCount > 0; } catch (Exception e) { log.error("【DischargeHandler】更新入院记录失败:serialnum={}, orgid={}, 错误:{}", patMedInhosp.getSerialnum(), patMedInhosp.getOrgid(), e.getMessage(), e); return false; } } // 3. 检查是否存在预入院记录(异常流程:从预入院直接出院,可能是取消入院) query.setInhospstate("3"); List preAdmissionRecords = patMedInhospService.selectPatMedInhosp(query); if (CollectionUtils.isNotEmpty(preAdmissionRecords)) { log.warn("【DischargeHandler】存在预入院记录但未入院,不允许直接出院,serialnum={}, orgid={}", patMedInhosp.getSerialnum(), patMedInhosp.getOrgid()); // 根据业务需求决定是否允许从预入院直接出院,这里暂时不允许 return false; } // 4. 不存在任何记录,异常情况:不应该没有入院记录就出院 log.warn("【DischargeHandler】无入院记录,不允许直接插入出院记录,serialnum={}, orgid={}", patMedInhosp.getSerialnum(), patMedInhosp.getOrgid()); // 如果业务允许直接插入出院记录(如数据修复场景),可以取消注释以下代码 /* try { patMedInhosp.setInhospstate("1"); patMedInhospService.insertPatMedInhosp(patMedInhosp); log.info("【DischargeHandler】成功插入出院记录(无入院记录),serialnum={}", patMedInhosp.getSerialnum()); return true; } catch (org.springframework.dao.DuplicateKeyException e) { log.warn("【DischargeHandler】出院记录已存在(并发插入),跳过:serialnum={}, orgid={}", patMedInhosp.getSerialnum(), patMedInhosp.getOrgid()); return false; } catch (Exception e) { log.error("【DischargeHandler】插入出院记录失败:serialnum={}, orgid={}, 错误:{}", patMedInhosp.getSerialnum(), patMedInhosp.getOrgid(), e.getMessage(), e); return false; } */ return false; } @Override public String getStateCode() { return "1"; } }