| | |
| | | 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.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.queue.QueueService; |
| | | 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.List; |
| | | |
| | | 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.*; |
| | | |
| | | /** |
| | |
| | | public class AppointmentServiceImpl implements AppointmentService { |
| | | |
| | | @Resource |
| | | private RemoteDataService remoteDataService; |
| | | |
| | | @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((byte)0); |
| | | appointment.setBookSrc( 1 ); |
| | | |
| | | appointmentMapper.insert(appointment); |
| | | try { |
| | | appointmentMapper.insert(appointment); |
| | | } catch (DuplicateKeyException e) { |
| | | throw exception(APPOINTMENT_EXIST_TODAY); |
| | | } |
| | | |
| | | // 返回 |
| | | return appointment.getId(); |
| | | } |
| | |
| | | } |
| | | |
| | | @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); |
| | | } |
| | | |
| | | // TODO 尚不支持, 一位患者当天两种检查项目的情况 |
| | | @Override |
| | | public AppointmentDO getCurAppointmentByPatId(String patId) { |
| | | List<AppointmentDO> appointmentDOList = appointmentMapper.getCurrentPatId( patId ); |
| | | return 0 == appointmentDOList.size() ? null : appointmentDOList.get(0); |
| | | } |
| | | |
| | | /** |
| | | * // TODO 尚不支持, 一位患者当天两种检查项目的情况 |
| | | * @param patCode 编号 : !!! 不一定就是本系统的 患者编号(patID), 根源在于 检查单扫描出来的编号 不一定是 本系统的 患者编号(patID) |
| | | * @return |
| | | */ |
| | | @Override |
| | | public 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())) { |
| | | // 查到当天的预约后,查询DB中 是否已经存在 |
| | | AppointmentDO appointmentDO = appointmentMapper.getCurrentByPatAndCheckType(appointmentExtermal.getPatId(), appointmentExtermal.getBookCheckType()); |
| | | if (null == appointmentDO) { |
| | | appointmentMapper.insert(appointmentExtermal); |
| | | return appointmentExtermal; |
| | | } |
| | | return appointmentDO; |
| | | } |
| | | } |
| | | |
| | | List<AppointmentDO> appointmentDOList = appointmentMapper.getCurrentPatId( patCode ); |
| | | return 0 == appointmentDOList.size() ? null : appointmentDOList.get(0); |
| | | } |
| | | |
| | | @Override |
| | |
| | | return appointmentMapper.selectPage(pageReqVO); |
| | | } |
| | | |
| | | @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.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.setBookId(appointmentExternal.getReqIdeApplyno()); |
| | | appointmentDO.setBookCheckType(getCorrespondingCheckType(appointmentExternal.getPlanDefItemList().getPlanDefItem().getPlanDefItemcode())); |
| | | appointmentDO.setBookTime(DateUtils.ofUTC(appointmentExternal.getReqAuthoredOn())); // 开单时间 |
| | | |
| | | // 光开单的情况,没有预约时间 |
| | | if (null != appointmentExternal.getReqExtBooktime() ) { |
| | | appointmentDO.setBookDate(DateUtils.ofUTC(appointmentExternal.getReqExtBooktime()).toLocalDate()); |
| | | 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); |
| | | appointmentDO.setPaid(1); |
| | | |
| | | curAppointDOList.add( appointmentDO ); |
| | | } |
| | | |
| | | return curAppointDOList; |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public String 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); |
| | | |
| | | try { |
| | | QueueSaveReqVO queueSaveReqVO = new QueueSaveReqVO(); |
| | | queueSaveReqVO.setPatId(appointment.getPatId()); |
| | | queueSaveReqVO.setPatName(appointment.getPatName()); |
| | | queueSaveReqVO.setPatGender(appointment.getPatGender()); |
| | | queueSaveReqVO.setBookDate(appointment.getBookDate()); |
| | | queueSaveReqVO.setBookTimeslot(appointment.getBookTimeslot()); |
| | | queueSaveReqVO.setBookCheckType(appointment.getBookCheckType()); |
| | | queueSaveReqVO.setPassed((byte) 0); |
| | | queueSaveReqVO.setExpired((byte) 0); |
| | | queueSaveReqVO.setPatDetails( appointment.getPatDeptDesc() + "-" + appointment.getPatWardDesc() + "-" + appointment.getPatBedNo()); |
| | | queueService.queue(queueSaveReqVO); |
| | | } catch (DuplicateKeyException duplicateKeyException) { |
| | | throw exception(APPOINTMENT_HAVE_QUEUED); |
| | | } |
| | | |
| | | return "确认成功"; |
| | | } |
| | | |
| | | 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; |
| | | } |
| | | } |