From 784c60d5baad7edceab2f1668ed9116e5b5e5e89 Mon Sep 17 00:00:00 2001
From: eight <641137800@qq.com>
Date: 星期四, 31 十月 2024 16:22:50 +0800
Subject: [PATCH] update

---
 jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/appointment/AppointmentServiceImpl.java |   73 ++++++++++++++++++++++--------------
 1 files changed, 45 insertions(+), 28 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 3f0de3d..7ce9921 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,8 +1,8 @@
 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.enums.QueueStatusEnum;
 import cn.lihu.jh.module.ecg.feign.RemoteDataService;
 import cn.lihu.jh.module.ecg.feign.RestApiReqBodyVo;
 import cn.lihu.jh.module.ecg.feign.RestApiResult;
@@ -16,19 +16,18 @@
 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 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.framework.common.pojo.CommonResult.success;
 import static cn.lihu.jh.module.ecg.enums.ErrorCodeConstants.*;
 
 /**
@@ -50,14 +49,19 @@
     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( 1 );
 
-        appointmentMapper.insert(appointment);
+        try {
+            appointmentMapper.insert(appointment);
+        } catch (DuplicateKeyException e) {
+            throw exception(APPOINTMENT_EXIST_TODAY);
+        }
+
         // 杩斿洖
         return appointment.getId();
     }
@@ -72,27 +76,46 @@
     }
 
     @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 getCurAppointmentByPatId(String patId) {
+        AppointmentDO appointmentDO = appointmentMapper.getCurrentPatId( patId );
+        return appointmentDO;
+    }
+
+    @Override
+    public AppointmentDO queryAndCreateAppointmentByPatId(String patId) {
+        // 鍏堜粠鍖婚櫌骞冲彴鏌ヨ
+        AppointmentDO appointmentExtermal = getAppointmentExtermal( patId );
+        if (null != appointmentExtermal && null != appointmentExtermal.getBookDate() && appointmentExtermal.getBookDate().isEqual(LocalDate.now()) ) {
+            // 鏌ュ埌褰撳ぉ鐨勯绾﹀悗锛屾煡璇B涓� 鏄惁宸茬粡瀛樺湪
+            AppointmentDO appointmentDO = appointmentMapper.getCurrentPatId( patId );
+            if (null == appointmentDO ) {
+                appointmentExtermal.setBookSrc(0);
+                appointmentMapper.insert( appointmentExtermal );
+                return appointmentExtermal;
+            }
+            return appointmentDO;
+        }
+
+        return appointmentMapper.getCurrentPatId( patId );
     }
 
     @Override
@@ -101,23 +124,24 @@
     }
 
     @Override
-    public AppointmentDO getAppointmentExtermal(String mzzyh) {
+    public AppointmentDO getAppointmentExtermal(String patId) {
         RestApiReqBodyVo reqBodyVo = new RestApiReqBodyVo();
-        //reqBodyVo.setSfzh(confirmReqVO.getPatId());
-        reqBodyVo.setMzzyh( mzzyh );
+        reqBodyVo.setSfzh("");
+        reqBodyVo.setMzzyh( patId );
 
         // QueryRisReportList   queryEcgRequest
         RestApiResult<AppointmentExternal> result = remoteDataService.httpApi("queryEcgRequest", "ECG", "ECG", reqBodyVo);
-        result.getCode();
+        if (0 == result.getRow().size()) {
+            return null;
+        }
 
         AppointmentExternal appointmentExternal = result.getRow().get(0);
-
         AppointmentDO appointmentDO = BeanUtils.toBean( appointmentExternal, AppointmentDO.class );
 
         appointmentDO.setPatId( appointmentExternal.getPatientID() ); // 鍐呭涓� 韬唤璇佸彿 鎴� 闂ㄨ瘖浣忛櫌鍙�
         appointmentDO.setPatName( appointmentExternal.getPatName() );
         appointmentDO.setPatGender( Byte.valueOf(appointmentExternal.getPatgender()) );
-        appointmentDO.setPatBirthday( appointmentExternal.getEncPatBirthDate() );
+        appointmentDO.setPatBirthday( DateUtils.ofUTC(appointmentExternal.getEncPatBirthDate()).toLocalDate() );
         appointmentDO.setPatIdentityId( appointmentExternal.getIdentityID() );
         appointmentDO.setPatAddr( appointmentExternal.getAddress() );
         appointmentDO.setPatDeptCode( appointmentExternal.getPatLocDeptCode() );
@@ -127,10 +151,10 @@
         appointmentDO.setPatMobile( appointmentExternal.getPhone() );
         appointmentDO.setPatBedNo( appointmentExternal.getEnBedno() );
         appointmentDO.setBookId( appointmentExternal.getReqIdeApplyno() );
-        appointmentDO.setBookDate( appointmentExternal.getReqExtBooktime().toLocalDate() );
+        appointmentDO.setBookDate( DateUtils.ofUTC( appointmentExternal.getReqExtBooktime() ).toLocalDate() );
         appointmentDO.setBookCheckType( getCorrespondingCheckType(appointmentExternal.getPlanDefItemList().getPlanDefItem().getPlanDefItemcode()) );
-        appointmentDO.setBookTime( appointmentExternal.getReqAuthoredOn() );
-        LocalDateTime bookStartTime = appointmentExternal.getReqExtBooktime();
+        appointmentDO.setBookTime( DateUtils.ofUTC( appointmentExternal.getReqAuthoredOn() ) );
+        LocalDateTime bookStartTime = DateUtils.ofUTC( appointmentExternal.getReqExtBooktime() );
         LocalDateTime bookEndTime = bookStartTime.plusMinutes(30);
         appointmentDO.setBookTimeslot( (bookStartTime.getHour()*100 + bookStartTime.getMinute())*10000 + bookEndTime.getHour()*100 + bookEndTime.getMinute() );
         appointmentDO.setBookSrc( 0 );
@@ -141,19 +165,12 @@
     @Override
     @Transactional(rollbackFor = Exception.class)
     public String appoitmentConfirm(AppointmentConfirmReqVO confirmReqVO) {
-        AppointmentDO appointment = getAppointmentExtermal(confirmReqVO.getMzzyh());
-        if (null == appointment ) {
-            //浠庨绾﹁〃鍙栨暟鎹紝鍚庣画瀵规帴鏁版嵁骞冲彴鏌ラ绾︽暟鎹�
-            appointment = getAppointment(confirmReqVO.getId());
-        }
-
+        AppointmentDO appointment = getAppointment(confirmReqVO.getId());
         if (null == appointment)
             throw exception(PATIENT_NOT_EXISTS);
 
         if ( !DateUtils.isToday(appointment.getBookDate()) )
             throw exception( APPOINTMENT_NOT_TODAY);
-
-        appointmentMapper.insert(appointment);
 
         try {
             QueueSaveReqVO queueSaveReqVO = new QueueSaveReqVO();

--
Gitblit v1.9.3