From adb4da3c83649d550b8674feb1eb0926fbace30e Mon Sep 17 00:00:00 2001 From: eight <641137800@qq.com> Date: 星期一, 11 十一月 2024 13:45:12 +0800 Subject: [PATCH] 排队&抢人时 亲和检查项目处理 --- jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/appointment/AppointmentServiceImpl.java | 50 ++++++++++++++++++++++++++++++++++++++------------ 1 files changed, 38 insertions(+), 12 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 0621eed..a374f68 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 @@ -3,12 +3,14 @@ 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.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; @@ -114,29 +116,33 @@ } /** - * // TODO 灏氫笉鏀寔, 涓�浣嶆偅鑰呭綋澶╀袱绉嶆鏌ラ」鐩殑鎯呭喌 * @param patCode 缂栧彿 : !!! 涓嶄竴瀹氬氨鏄湰绯荤粺鐨� 鎮h�呯紪鍙�(patID), 鏍规簮鍦ㄤ簬 妫�鏌ュ崟鎵弿鍑烘潵鐨勭紪鍙� 涓嶄竴瀹氭槸 鏈郴缁熺殑 鎮h�呯紪鍙�(patID) * @return */ @Override - public AppointmentDO queryAndCreateAppointmentByPatId(String patCode) { + 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 && null != appointmentExtermal.getBookDate() && appointmentExtermal.getBookDate().isEqual(LocalDate.now())) { - // 鏌ュ埌褰撳ぉ鐨勯绾﹀悗锛屾煡璇B涓� 鏄惁宸茬粡瀛樺湪 - AppointmentDO appointmentDO = appointmentMapper.getCurrentByPatAndCheckType(appointmentExtermal.getPatId(), appointmentExtermal.getBookCheckType()); - if (null == appointmentDO) { - appointmentMapper.insert(appointmentExtermal); - return appointmentExtermal; - } - return appointmentDO; + if (null == appointmentExtermal ) + continue; + + // 浠嶥B鏌ュ埌棰勭害锛屾槸鍚﹀凡缁忓瓨鍦� + AppointmentDO appointmentDO = appointmentMapper.getByPatAndCheckTypeAndBookDate(appointmentExtermal.getPatId(), appointmentExtermal.getBookCheckType(), appointmentExtermal.getBookDate()); + if (null == appointmentDO) { + appointmentMapper.insert(appointmentExtermal); + } else { + appointmentExtermal.setId( appointmentDO.getId() ); // 纭繚 杩斿洖鍊间繚鎶� appointment id } } - List<AppointmentDO> appointmentDOList = appointmentMapper.getCurrentPatId( patCode ); - return 0 == appointmentDOList.size() ? null : appointmentDOList.get(0); + // 涓嶄粠DB鏌ヨ + //List<AppointmentDO> appointmentDOList = appointmentMapper.getCurrentPatId( patCode ); + //return 0 == appointmentDOList.size() ? null : appointmentDOList.get(0); + + return appointmentExtermalList; } @Override @@ -165,6 +171,8 @@ AppointmentExternal appointmentExternal = result.getRow().get( appointIndex ); AppointmentDO appointmentDO = BeanUtils.toBean(appointmentExternal, AppointmentDO.class); + appointmentDO.setApplyNo( appointmentExternal.getReqIdeApplyno() ); + appointmentDO.setPatSrc( getCorrespondingPatientSource(appointmentExternal.getAdmTypeCode()) ); appointmentDO.setPatId(appointmentExternal.getPatientID()); // 鍐呭涓� 韬唤璇佸彿 鎴� 闂ㄨ瘖浣忛櫌鍙� appointmentDO.setPatName(appointmentExternal.getPatName()); appointmentDO.setPatGender(Byte.valueOf(appointmentExternal.getPatgender())); @@ -204,6 +212,11 @@ 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); @@ -271,4 +284,17 @@ 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; + } } \ No newline at end of file -- Gitblit v1.9.3