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