From 2cf602ee9ade83b0f7865c9242edf43598673aa1 Mon Sep 17 00:00:00 2001 From: eight <641137800@qq.com> Date: 星期四, 07 十一月 2024 18:08:03 +0800 Subject: [PATCH] update --- jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/appointment/AppointmentServiceImpl.java | 40 ++++++++++++++++++++++++++++++++-------- 1 files changed, 32 insertions(+), 8 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 4be3618..0621eed 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 @@ -7,7 +7,10 @@ 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.queuesequence.QueueSequenceService; +import lombok.extern.slf4j.Slf4j; import org.springframework.dao.DuplicateKeyException; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -39,10 +42,17 @@ */ @Service @Validated +@Slf4j public class AppointmentServiceImpl implements AppointmentService { @Resource + private EcgConfigService ecgConfigService; + + @Resource private RemoteDataService remoteDataService; + + @Resource + private QueueSequenceService queueSequenceService; @Resource private QueueService queueService; @@ -103,16 +113,20 @@ return 0 == appointmentDOList.size() ? null : appointmentDOList.get(0); } - // TODO 灏氫笉鏀寔, 涓�浣嶆偅鑰呭綋澶╀袱绉嶆鏌ラ」鐩殑鎯呭喌 + /** + * // TODO 灏氫笉鏀寔, 涓�浣嶆偅鑰呭綋澶╀袱绉嶆鏌ラ」鐩殑鎯呭喌 + * @param patCode 缂栧彿 : !!! 涓嶄竴瀹氬氨鏄湰绯荤粺鐨� 鎮h�呯紪鍙�(patID), 鏍规簮鍦ㄤ簬 妫�鏌ュ崟鎵弿鍑烘潵鐨勭紪鍙� 涓嶄竴瀹氭槸 鏈郴缁熺殑 鎮h�呯紪鍙�(patID) + * @return + */ @Override - public AppointmentDO queryAndCreateAppointmentByPatId(String patId) { + public AppointmentDO queryAndCreateAppointmentByPatId(String patCode) { // 鍏堜粠鍖婚櫌骞冲彴鏌ヨ - List<AppointmentDO> appointmentExtermalList = getAppointmentExtermal( patId ); + List<AppointmentDO> appointmentExtermalList = getAppointmentExtermal( patCode ); for ( int appointmentIndex = 0; appointmentIndex < appointmentExtermalList.size(); appointmentIndex++ ) { AppointmentDO appointmentExtermal = appointmentExtermalList.get(appointmentIndex); if (null != appointmentExtermal && null != appointmentExtermal.getBookDate() && appointmentExtermal.getBookDate().isEqual(LocalDate.now())) { // 鏌ュ埌褰撳ぉ鐨勯绾﹀悗锛屾煡璇B涓� 鏄惁宸茬粡瀛樺湪 - AppointmentDO appointmentDO = appointmentMapper.getCurrentByPatAndCheckType(patId, appointmentExtermal.getBookCheckType()); + AppointmentDO appointmentDO = appointmentMapper.getCurrentByPatAndCheckType(appointmentExtermal.getPatId(), appointmentExtermal.getBookCheckType()); if (null == appointmentDO) { appointmentMapper.insert(appointmentExtermal); return appointmentExtermal; @@ -121,7 +135,7 @@ } } - List<AppointmentDO> appointmentDOList = appointmentMapper.getCurrentPatId( patId ); + List<AppointmentDO> appointmentDOList = appointmentMapper.getCurrentPatId( patCode ); return 0 == appointmentDOList.size() ? null : appointmentDOList.get(0); } @@ -171,7 +185,7 @@ if (null != appointmentExternal.getReqExtBooktime() ) { appointmentDO.setBookDate(DateUtils.ofUTC(appointmentExternal.getReqExtBooktime()).toLocalDate()); LocalDateTime bookStartTime = DateUtils.ofUTC(appointmentExternal.getReqExtBooktime()); - LocalDateTime bookEndTime = bookStartTime.plusMinutes(30); + LocalDateTime bookEndTime = bookStartTime.plusMinutes( ecgConfigService.getTimeslotLength()); appointmentDO.setBookTimeslot((bookStartTime.getHour() * 100 + bookStartTime.getMinute()) * 10000 + bookEndTime.getHour() * 100 + bookEndTime.getMinute()); } @@ -186,13 +200,21 @@ @Override @Transactional(rollbackFor = Exception.class) - public String appoitmentConfirm(AppointmentConfirmReqVO confirmReqVO) { + public Integer appoitmentConfirm(AppointmentConfirmReqVO confirmReqVO) { AppointmentDO appointment = getAppointment(confirmReqVO.getId()); if (null == appointment) throw exception(PATIENT_NOT_EXISTS); 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(); @@ -202,6 +224,8 @@ queueSaveReqVO.setBookDate(appointment.getBookDate()); queueSaveReqVO.setBookTimeslot(appointment.getBookTimeslot()); queueSaveReqVO.setBookCheckType(appointment.getBookCheckType()); + queueSaveReqVO.setBookSeqNum( newSeqNo ); + queueSaveReqVO.setIsVip( confirmReqVO.getIsVip() ); queueSaveReqVO.setPassed((byte) 0); queueSaveReqVO.setExpired((byte) 0); queueSaveReqVO.setPatDetails( appointment.getPatDeptDesc() + "-" + appointment.getPatWardDesc() + "-" + appointment.getPatBedNo()); @@ -210,7 +234,7 @@ throw exception(APPOINTMENT_HAVE_QUEUED); } - return "纭鎴愬姛"; + return newSeqNo; } private Integer getCorrespondingCheckType(String strPlanDefItemcode) { -- Gitblit v1.9.3