From f77fbfc8c07881f5239ce49b0dc78faaec3628b0 Mon Sep 17 00:00:00 2001
From: eight <641137800@qq.com>
Date: 星期二, 10 十二月 2024 12:09:24 +0800
Subject: [PATCH] Fix Bug: 无预约时间的在预约表会有多条记录
---
jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/appointment/AppointmentServiceImpl.java | 268 +++++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 257 insertions(+), 11 deletions(-)
diff --git a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/appointment/AppointmentServiceImpl.java b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/appointment/AppointmentServiceImpl.java
index c165a8a..525e33b 100644
--- a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/appointment/AppointmentServiceImpl.java
+++ b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/appointment/AppointmentServiceImpl.java
@@ -1,22 +1,45 @@
package cn.lihu.jh.module.ecg.service.appointment;
+import cn.lihu.jh.framework.common.util.date.DateUtils;
+import cn.lihu.jh.framework.common.util.date.LocalDateTimeUtils;
+import cn.lihu.jh.module.ecg.controller.admin.queue.vo.QueueSaveReqVO;
+import cn.lihu.jh.module.ecg.dal.dataobject.checktype.CheckTypeDO;
+import cn.lihu.jh.module.ecg.dal.dataobject.patient.PatDetails;
+import cn.lihu.jh.module.ecg.dal.dataobject.queue.QueueDO;
+import cn.lihu.jh.module.ecg.feign.RemoteDataService;
+import cn.lihu.jh.module.ecg.feign.RestApiReqBodyVo;
+import cn.lihu.jh.module.ecg.feign.RestApiResult;
+import cn.lihu.jh.module.ecg.feign.dto.AppointmentExternal;
+import cn.lihu.jh.module.ecg.service.config.EcgConfigService;
+import cn.lihu.jh.module.ecg.service.queue.QueueService;
+import cn.lihu.jh.module.ecg.service.queue.QueueServiceTxFunctions;
+import cn.lihu.jh.module.ecg.service.queuesequence.QueueSequenceService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.dao.DuplicateKeyException;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;
import cn.lihu.jh.module.ecg.controller.admin.appointment.vo.*;
import cn.lihu.jh.module.ecg.dal.dataobject.appointment.AppointmentDO;
import cn.lihu.jh.framework.common.pojo.PageResult;
-import cn.lihu.jh.framework.common.pojo.PageParam;
import cn.lihu.jh.framework.common.util.object.BeanUtils;
import cn.lihu.jh.module.ecg.dal.mysql.appointment.AppointmentMapper;
import javax.annotation.Resource;
+import javax.xml.crypto.Data;
+import java.time.LocalDate;
import java.time.LocalDateTime;
-import java.util.Date;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
import static cn.lihu.jh.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.lihu.jh.framework.common.pojo.CommonResult.error;
import static cn.lihu.jh.module.ecg.enums.ErrorCodeConstants.*;
/**
@@ -26,20 +49,37 @@
*/
@Service
@Validated
+@Slf4j
public class AppointmentServiceImpl implements AppointmentService {
+
+ @Resource
+ private EcgConfigService ecgConfigService;
+
+ @Resource
+ private RemoteDataService remoteDataService;
+
+ @Resource
+ private QueueSequenceService queueSequenceService;
+
+ @Resource
+ private QueueService queueService;
@Resource
private AppointmentMapper appointmentMapper;
@Override
- public Integer createAppointment(AppointmentSaveReqVO createReqVO) {
+ public Long createAppointment(AppointmentSaveReqVO createReqVO) {
// 鎻掑叆
AppointmentDO appointment = BeanUtils.toBean(createReqVO, AppointmentDO.class);
appointment.setBookTime( LocalDateTime.now() );
- appointment.setBookSrc( 0 );
- appointmentMapper.insert(appointment);
+ try {
+ appointmentMapper.insert(appointment);
+ } catch (DuplicateKeyException e) {
+ throw exception(APPOINTMENT_EXIST_TODAY);
+ }
+
// 杩斿洖
return appointment.getId();
}
@@ -54,27 +94,68 @@
}
@Override
- public void deleteAppointment(Integer id) {
+ public void deleteAppointment(Long id) {
// 鏍￠獙瀛樺湪
validateAppointmentExists(id);
// 鍒犻櫎
appointmentMapper.deleteById(id);
}
- private void validateAppointmentExists(Integer id) {
+ private void validateAppointmentExists(Long id) {
if (appointmentMapper.selectById(id) == null) {
throw exception(APPOINTMENT_NOT_EXISTS);
}
}
@Override
- public AppointmentDO getAppointment(Integer id) {
+ public AppointmentDO getAppointment(Long id) {
return appointmentMapper.selectById(id);
}
@Override
- public AppointmentDO getAppointmentByPatId(String patId) {
- return appointmentMapper.getByPatId( patId );
+ public AppointmentDO getCurAppointmentByPatIdAndCheckType(String patId, Integer checkType) {
+ AppointmentDO appointmentDO = appointmentMapper.getByPatAndCheckTypeAndBookDate( patId, checkType, LocalDate.now() );
+ return appointmentDO;
+ }
+
+ /**
+ * @param patCode 缂栧彿 : !!! 涓嶄竴瀹氬氨鏄湰绯荤粺鐨� 鎮ｈ�呯紪鍙�(patID), 鏍规簮鍦ㄤ簬 妫�鏌ュ崟鎵弿鍑烘潵鐨勭紪鍙� 涓嶄竴瀹氭槸 鏈郴缁熺殑 鎮ｈ�呯紪鍙�(patID)
+ * @return
+ */
+ @Override
+ public List<AppointmentDO> queryAndCreateAppointmentByPatId(String patCode) {
+ // 浠庡尰闄㈠钩鍙版煡璇�
+ List<AppointmentDO> appointmentExtermalList = getAppointmentExtermal( patCode );
+
+ for ( int appointmentIndex = 0; appointmentIndex < appointmentExtermalList.size(); appointmentIndex++ ) {
+ AppointmentDO appointmentExtermal = appointmentExtermalList.get(appointmentIndex);
+ if (null == appointmentExtermal )
+ continue;
+
+ // 浠嶥B鏌ヨ棰勭害锛屾槸鍚﹀凡缁忓瓨鍦�
+ AppointmentDO appointmentDO = appointmentMapper.getByEpisodeIdAndApplyNo(appointmentExtermal.getEpisodeId(), appointmentExtermal.getApplyNo());
+ if (null == appointmentDO) {
+ appointmentMapper.insert(appointmentExtermal);
+ } else {
+ appointmentExtermal.setId( appointmentDO.getId() ); // 纭繚 杩斿洖鍊煎寘鍚� appointment id
+ }
+ }
+
+ // 鏌ヨ[queue琛╙琛ュ厖 book_seq_num 鍒拌繑鍥炲�间腑
+ if (!appointmentExtermalList.isEmpty()) {
+ List<Long> appointIdlist = appointmentExtermalList.stream().map(appointmentDO -> appointmentDO.getId()).toList();
+ List<QueueDO> simpleQueueDOList = queueService.selectBookSeqNumByAppointIdList(appointIdlist);
+ if (!simpleQueueDOList.isEmpty()) {
+ Map<Long, Integer> mapAppointIdVsBookSeqNo = simpleQueueDOList.stream().collect(Collectors.toMap(QueueDO::getAppointId, QueueDO::getBookSeqNum));
+ appointmentExtermalList.forEach(appointmentExterma -> appointmentExterma.setBookSeqNum(mapAppointIdVsBookSeqNo.get(appointmentExterma.getId())));
+ }
+ }
+
+ // 涓嶄粠DB鏌ヨ
+ //List<AppointmentDO> appointmentDOList = appointmentMapper.getCurrentPatId( patCode );
+ //return 0 == appointmentDOList.size() ? null : appointmentDOList.get(0);
+
+ return appointmentExtermalList;
}
@Override
@@ -82,4 +163,169 @@
return appointmentMapper.selectPage(pageReqVO);
}
-}
\ No newline at end of file
+ @Override
+ public List<AppointmentDO> getAppointmentExtermal(String patId) {
+ List<AppointmentDO> curAppointDOList = new ArrayList<AppointmentDO>();
+
+ RestApiReqBodyVo reqBodyVo = new RestApiReqBodyVo();
+ if (18 == patId.length()) {
+ reqBodyVo.setSfzh( patId );
+ } else {
+ reqBodyVo.setMzzyh(patId);
+ }
+
+ // QueryRisReportList queryEcgRequest
+ RestApiResult<AppointmentExternal> result = remoteDataService.httpApi("queryEcgRequest", "ECG", "ECG", reqBodyVo);
+ if (0 == result.getRow().size()) {
+ return curAppointDOList;
+ }
+
+ for (int appointIndex=0; appointIndex < result.getRow().size(); appointIndex++ ) {
+ AppointmentExternal appointmentExternal = result.getRow().get( appointIndex );
+
+ AppointmentDO appointmentDO = BeanUtils.toBean(appointmentExternal, AppointmentDO.class);
+ appointmentDO.setApplyNo( appointmentExternal.getReqIdeApplyno() );
+ appointmentDO.setEpisodeId( appointmentExternal.getEpisodeID() );
+ appointmentDO.setPatSrc( getCorrespondingPatientSource(appointmentExternal.getAdmTypeCode()) );
+ appointmentDO.setPatId(appointmentExternal.getPatientID()); // 鍐呭涓� 韬唤璇佸彿 鎴� 闂ㄨ瘖浣忛櫌鍙�
+ appointmentDO.setPatName(appointmentExternal.getPatName());
+ appointmentDO.setPatGender(Byte.valueOf(appointmentExternal.getPatgender()));
+ appointmentDO.setPatBirthday(DateUtils.ofUTC(appointmentExternal.getEncPatBirthDate()).toLocalDate());
+ appointmentDO.setPatIdentityId(appointmentExternal.getIdentityID());
+ appointmentDO.setPatAddr(appointmentExternal.getAddress());
+ appointmentDO.setPatDeptCode(appointmentExternal.getPatLocDeptCode());
+ appointmentDO.setPatDeptDesc(appointmentExternal.getPatLocDeptDesc());
+ appointmentDO.setPatWardCode(appointmentExternal.getPatLocWardCode());
+ appointmentDO.setPatWardDesc(appointmentExternal.getPatLocWardDesc());
+ appointmentDO.setPatMobile(appointmentExternal.getPhone());
+ appointmentDO.setPatBedNo(appointmentExternal.getEnBedno());
+ appointmentDO.setBookCheckType(getCorrespondingCheckType(appointmentExternal.getPlanDefItemList().getPlanDefItem().getPlanDefItemcode()));
+ appointmentDO.setBookTime(DateUtils.ofUTC(appointmentExternal.getReqAuthoredOn())); // 寮�鍗曟椂闂�
+ appointmentDO.setBookSrc( 0 );
+
+ // 鍏夊紑鍗曠殑鎯呭喌锛屾病鏈夐绾︽椂闂�
+ if (null != appointmentExternal.getReqExtBooktime() ) {
+ appointmentDO.setBookDate(DateUtils.ofUTC(appointmentExternal.getReqExtBooktime()).toLocalDate());
+ LocalDateTime bookStartTime = DateUtils.ofUTC(appointmentExternal.getReqExtBooktime());
+ LocalDateTime bookEndTime = bookStartTime.plusMinutes( ecgConfigService.getTimeslotLength());
+ appointmentDO.setBookTimeslot((bookStartTime.getHour() * 100 + bookStartTime.getMinute()) * 10000 + bookEndTime.getHour() * 100 + bookEndTime.getMinute());
+ }
+
+ appointmentDO.setPaid( 0 );
+
+ curAppointDOList.add( appointmentDO );
+ }
+
+ return curAppointDOList;
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public Integer appoitmentConfirm(AppointmentConfirmReqVO confirmReqVO) {
+ AppointmentDO appointment = getAppointment(confirmReqVO.getId());
+ if (null == appointment)
+ throw exception(PATIENT_NOT_EXISTS);
+
+ // 鎵嬪姩棰勭害锛岀洿鎺ヨ缃绾︽棩鏈熶负褰撳ぉ
+ if (confirmReqVO.getIsVip() == 1) {
+ appointment.setBookDate( LocalDate.now() );
+ }
+
+ if ( !DateUtils.isToday(appointment.getBookDate()) )
+ throw exception( APPOINTMENT_NOT_TODAY);
+
+
+ Integer newSeqNo = null;
+ if (confirmReqVO.getIsVip() == 0) {
+ newSeqNo = queueSequenceService.distributeSeqNo(confirmReqVO.getBookCheckType(), confirmReqVO.getBookTimeslot());
+ } else {
+ newSeqNo = queueSequenceService.distributeVipSeqNo(confirmReqVO.getBookCheckType(), confirmReqVO.getBookTimeslot());
+ }
+
+ try {
+ QueueSaveReqVO queueSaveReqVO = new QueueSaveReqVO();
+ queueSaveReqVO.setApplyNo( appointment.getApplyNo() );
+ queueSaveReqVO.setEpisodeId( appointment.getEpisodeId() );
+ queueSaveReqVO.setAppointId(appointment.getId());
+ queueSaveReqVO.setPatId(appointment.getPatId());
+ queueSaveReqVO.setPatName(appointment.getPatName());
+ queueSaveReqVO.setPatGender(appointment.getPatGender());
+ queueSaveReqVO.setBookDate(appointment.getBookDate());
+ queueSaveReqVO.setBookTimeslot( confirmReqVO.getBookTimeslot() ); /*appointment.getBookTimeslot()*/
+ queueSaveReqVO.setBookCheckType(appointment.getBookCheckType());
+ queueSaveReqVO.setBookSeqNum( newSeqNo );
+ queueSaveReqVO.setIsVip( confirmReqVO.getIsVip() );
+ queueSaveReqVO.setPassed((byte) 0);
+ queueSaveReqVO.setExpired((byte) 0);
+ queueSaveReqVO.setPatDetails( getPatDetails(appointment) );
+ queueService.queue(queueSaveReqVO);
+ } catch (DuplicateKeyException duplicateKeyException) {
+ throw exception(APPOINTMENT_HAVE_QUEUED);
+ }
+
+ return newSeqNo;
+ }
+
+ private Integer getCorrespondingCheckType(String strPlanDefItemcode) {
+ if (strPlanDefItemcode.equals("691133607"))
+ return 100;
+ else if (strPlanDefItemcode.equals("201605"))
+ return 200;
+ else if (strPlanDefItemcode.equals("200327"))
+ return 300;
+ else if (strPlanDefItemcode.equals("201652"))
+ return 400;
+ else if (strPlanDefItemcode.equals("502490914"))
+ return 500;
+ else if (strPlanDefItemcode.equals("419562119"))
+ return 600;
+ else if (strPlanDefItemcode.equals("201604"))
+ return 700;
+ else if (strPlanDefItemcode.equals("1202042"))
+ return 800;
+ else if (strPlanDefItemcode.equals("1202058"))
+ return 900;
+ else if (strPlanDefItemcode.equals("1202065"))
+ return 1000;
+ else if (strPlanDefItemcode.equals("559542128"))
+ return 1100;
+ else if (strPlanDefItemcode.equals("590244511"))
+ return 1200;
+ else if (strPlanDefItemcode.equals("666454217"))
+ return 1300;
+ else if (strPlanDefItemcode.equals("720791490"))
+ return 1400;
+ else if (strPlanDefItemcode.equals("720792077"))
+ return 1500;
+
+ return 100;
+ }
+
+ private Integer getCorrespondingPatientSource(String admTypeCode) {
+ if (admTypeCode.equals("AMB"))
+ return 1;
+ else if (admTypeCode.equals("EMER"))
+ return 2;
+ else if (admTypeCode.equals("IMP"))
+ return 3;
+ else if (admTypeCode.equals("PHY"))
+ return 4;
+
+ return 0;
+ }
+
+ private PatDetails getPatDetails(AppointmentDO appointment) {
+ PatDetails patDetails = new PatDetails();
+ patDetails.setId( appointment.getPatId() );
+ patDetails.setName( appointment.getPatName() );
+ patDetails.setMobile( appointment.getPatMobile() );
+ patDetails.setDeptCode( appointment.getPatDeptCode() );
+ patDetails.setDeptDesc( appointment.getPatDeptDesc() );
+ patDetails.setWardCode( appointment.getPatWardCode() );
+ patDetails.setWardDesc( appointment.getPatWardDesc() );
+ patDetails.setBedNo( appointment.getPatBedNo() );
+ patDetails.setSource( appointment.getPatSrc() );
+ return patDetails;
+ }
+}
+
--
Gitblit v1.9.3