diff --git a/src/main/java/com/docus/server/AppRunBootstrap.java b/src/main/java/com/docus/server/AppRunBootstrap.java index 76613b9..87ab35c 100644 --- a/src/main/java/com/docus/server/AppRunBootstrap.java +++ b/src/main/java/com/docus/server/AppRunBootstrap.java @@ -1,6 +1,8 @@ package com.docus.server; +import com.docus.infrastructure.core.utils.SpringUtil; +import com.docus.server.message.dao.TrInpatientOutpatientDao; import lombok.extern.slf4j.Slf4j; import org.mybatis.spring.annotation.MapperScan; import org.springframework.boot.SpringApplication; diff --git a/src/main/java/com/docus/server/message/busservice/impl/SdBusinessServiceImpl.java b/src/main/java/com/docus/server/message/busservice/impl/SdBusinessServiceImpl.java index a8c9dc7..7077c72 100644 --- a/src/main/java/com/docus/server/message/busservice/impl/SdBusinessServiceImpl.java +++ b/src/main/java/com/docus/server/message/busservice/impl/SdBusinessServiceImpl.java @@ -120,6 +120,9 @@ public class SdBusinessServiceImpl implements SdBusinessService { @Override @Transactional(rollbackFor = Exception.class) public void trInpatientOutPatient(String patientId) { + if (trInpatientOutpatientDao.exists(patientId)){ + return; + } String sdRyIndex = tBasicMapper.getSdRyIndex(patientId); if (Func.isBlank(sdRyIndex)) { log.warn("patientId:{} 没有患者索引!", patientId); diff --git a/src/main/java/com/docus/server/message/dao/TrInpatientOutpatientDao.java b/src/main/java/com/docus/server/message/dao/TrInpatientOutpatientDao.java index 79c0f89..39e6fa8 100644 --- a/src/main/java/com/docus/server/message/dao/TrInpatientOutpatientDao.java +++ b/src/main/java/com/docus/server/message/dao/TrInpatientOutpatientDao.java @@ -20,4 +20,10 @@ public interface TrInpatientOutpatientDao extends IBaseDao wrapper = new LambdaQueryWrapper<>(); + wrapper.eq(TrInpatientOutpatient::getPatientId, inpatientId); + wrapper.last(" LIMIT 1"); + return baseMapper.selectCount(wrapper)>1; + } }