From 3d10cfa8882afcfa28a7623b45232aef54fe033d Mon Sep 17 00:00:00 2001 From: eight <641137800@qq.com> Date: 星期五, 25 十月 2024 15:51:08 +0800 Subject: [PATCH] 设备表 增加 rent_id --- jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/devrent/DevRentServiceImpl.java | 495 +++++++++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 431 insertions(+), 64 deletions(-) diff --git a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/devrent/DevRentServiceImpl.java b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/devrent/DevRentServiceImpl.java index bbb01f7..a22dacf 100644 --- a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/devrent/DevRentServiceImpl.java +++ b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/devrent/DevRentServiceImpl.java @@ -7,14 +7,17 @@ import cn.lihu.jh.module.ecg.dal.dataobject.jobrecord.JobRecordDO; import cn.lihu.jh.module.ecg.dal.mysql.devmanage.DeviceMapper; import cn.lihu.jh.module.ecg.dal.mysql.jobrecord.JobRecordMapper; +import cn.lihu.jh.module.ecg.dal.mysql.queue.QueueMapper; import cn.lihu.jh.module.ecg.enums.DevRentStateEnum; import cn.lihu.jh.module.ecg.enums.DevStateEnum; +import cn.lihu.jh.module.ecg.enums.QueueStatusEnum; import org.springframework.stereotype.Service; import org.springframework.validation.annotation.Validated; import org.springframework.transaction.annotation.Transactional; import java.time.LocalDate; import java.time.LocalDateTime; +import java.util.ArrayList; import java.util.List; import cn.lihu.jh.module.ecg.controller.admin.devrent.vo.*; @@ -47,6 +50,9 @@ @Resource DeviceMapper deviceMapper; + @Resource + QueueMapper queueMapper; + @Override public CommonResult<Long> registerOperation(DevRentSaveReqVO createReqVO) { Long rent_id = createDevRent(createReqVO); @@ -54,22 +60,162 @@ } @Override - @Transactional - public CommonResult<Long> installOperation(DevRentSaveReqVO createReqVO) { + @Transactional(rollbackFor = Exception.class) + public CommonResult<Long> routineFinishOperation(RoutineFinishReqVO routineFinishReqVO) { + DevRentSaveReqVO createReqVO = BeanUtils.toBean(routineFinishReqVO, DevRentSaveReqVO.class); + Long userId = SecurityFrameworkUtils.getLoginUserId(); String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); - // 璁剧疆璁惧 浣跨敤涓� - Integer ret = markDevInUse(createReqVO.getDevId()); - if (null == ret || 0 == ret) { - return CommonResult.error(DEVICE_NOT_EXISTS); + // 鍚屾牱 鍦ㄩ绾︾‘瀹炴椂 灏辫繘鍏� [dev_rent] 琛ㄤ簡 + Long rent_id = createReqVO.getId(); + + List<Integer> jobTypeList = new ArrayList<Integer>(); + jobTypeList.add( DevRentStateEnum.ROUTINE_FINISH.getState()); + jobTypeList.add( DevRentStateEnum.ROUTINE_CANCELLED.getState()); + JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList); + if (null == jobRecordDO) { + List<DevRentDO> devRentDOList = devRentMapper.selectByPatIdAndState(createReqVO.getPatId(), DevRentStateEnum.FREE.getState()); + if (devRentDOList.size() == 0) + throw exception(DEV_INSTALL_NOT_APPOINTMENT); + else if (devRentDOList.size() != 1) { + throw exception(DEV_INSTALL_EXCEPTION); + } + + rent_id = devRentDOList.getFirst().getId(); + createReqVO.setId( rent_id ); + createReqVO.setState( DevRentStateEnum.ROUTINE_FINISH.getState() ); + updateDevRent( createReqVO ); + + JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO(); + jobRecordSaveReqVO.setRentId(rent_id); + jobRecordSaveReqVO.setDevId(createReqVO.getDevId()); + jobRecordSaveReqVO.setDocId(userId); + jobRecordSaveReqVO.setDocName(userNickname); + jobRecordSaveReqVO.setPatId(createReqVO.getPatId()); + jobRecordSaveReqVO.setPatName(createReqVO.getPatName()); + jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime()); + jobRecordSaveReqVO.setJobType( DevRentStateEnum.ROUTINE_FINISH.getState() ); + jobRecordSaveReqVO.setRemark(createReqVO.getRemark()); + jobRecordSaveReqVO.setSummary(""); + + JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); + jobRecordMapper.insert(jobRecord); + } else { + // 鎾ら攢 鏀惧純鎿嶄綔 + createReqVO.setState( DevRentStateEnum.ROUTINE_FINISH.getState() ); + + updateDevRent( createReqVO ); + + jobRecordDO.setDevId(createReqVO.getDevId()); + jobRecordDO.setJobType( DevRentStateEnum.ROUTINE_FINISH.getState() ); + jobRecordDO.setJobTime(createReqVO.getRentTime()); + jobRecordDO.setRemark(createReqVO.getRemark()); + jobRecordDO.setUpdater(String.valueOf(userId)); + jobRecordDO.setUpdateTime(LocalDateTime.now()); + jobRecordMapper.updateById(jobRecordDO); } + // 鏇存柊..闃熷垪鐘舵�� + queueMapper.updateBedQueueStatus(createReqVO.getRoomId(), createReqVO.getBedNo(), + QueueStatusEnum.ONSTAGE.getStatus(), QueueStatusEnum.FINISH.getStatus()); + + return CommonResult.success(rent_id); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public CommonResult<Long> readyOperation(DevRentSaveReqVO createReqVO) { + Long userId = SecurityFrameworkUtils.getLoginUserId(); + String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); Long rent_id = createReqVO.getId(); - if (null == rent_id) { + + // 鏍囨敞璁惧 宸查鍙� + Integer ret = markDevRecieved(createReqVO.getDevId(), rent_id); + if (null == ret || 0 == ret) { + throw exception(DEVICE_NOT_FREE); + } + + List<Integer> jobTypeList = new ArrayList<Integer>(); + jobTypeList.add( DevRentStateEnum.READY.getState()); + jobTypeList.add( DevRentStateEnum.READY_CANCELLED.getState()); + JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList); + if (null == jobRecordDO) { List<DevRentDO> devRentDOList = devRentMapper.selectByPatIdAndState(createReqVO.getPatId(), DevRentStateEnum.FREE.getState()); - if (devRentDOList.size() != 1) - return CommonResult.error(DEV_INSTALL_EXIST); + if (devRentDOList.size() == 0) + throw exception(DEV_INSTALL_NOT_APPOINTMENT); + else if (devRentDOList.size() != 1) { + throw exception(DEV_INSTALL_EXCEPTION); + } + + rent_id = devRentDOList.getFirst().getId(); + createReqVO.setId( rent_id ); + createReqVO.setState( DevRentStateEnum.READY.getState() ); + updateDevRent( createReqVO ); + + JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO(); + jobRecordSaveReqVO.setRentId(rent_id); + jobRecordSaveReqVO.setDevId(createReqVO.getDevId()); + jobRecordSaveReqVO.setDocId(userId); + jobRecordSaveReqVO.setDocName(userNickname); + jobRecordSaveReqVO.setPatId(createReqVO.getPatId()); + jobRecordSaveReqVO.setPatName(createReqVO.getPatName()); + jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime()); + jobRecordSaveReqVO.setJobType( DevRentStateEnum.READY.getState() ); + jobRecordSaveReqVO.setRemark(createReqVO.getRemark()); + jobRecordSaveReqVO.setSummary(""); + + JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); + jobRecordMapper.insert(jobRecord); + } else { + // 鎾ら攢 鏀惧純鎿嶄綔 + createReqVO.setState( DevRentStateEnum.READY.getState() ); + + updateDevRent( createReqVO ); + + jobRecordDO.setDevId(createReqVO.getDevId()); + jobRecordDO.setJobType( DevRentStateEnum.READY.getState() ); + jobRecordDO.setJobTime(createReqVO.getRentTime()); + jobRecordDO.setRemark(createReqVO.getRemark()); + jobRecordDO.setUpdater(String.valueOf(userId)); + jobRecordDO.setUpdateTime(LocalDateTime.now()); + jobRecordMapper.updateById(jobRecordDO); + } + + // 鏇存柊..闃熷垪鐘舵�� + queueMapper.updateBedQueueStatus(createReqVO.getRoomId(), createReqVO.getBedNo(), + QueueStatusEnum.ONSTAGE.getStatus(), QueueStatusEnum.RECEIVED.getStatus()); + + return CommonResult.success(rent_id); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public CommonResult<Long> installOperation(DevRentSaveReqVO createReqVO) { + Long userId = SecurityFrameworkUtils.getLoginUserId(); + String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); + Long rent_id = createReqVO.getId(); + + // 璁剧疆璁惧 浣跨敤涓� + Integer ret = markDevInUse(createReqVO.getDevId(), rent_id); + if (null == ret || 0 == ret) { + throw exception(DEVICE_NOT_RECEIVED); + } + + // 妫�鏌� job_record 鐢ㄤ簬纭鏄惁鏄涓�娆″畨瑁呮搷浣� + List<Integer> jobTypeList = new ArrayList<Integer>(); + jobTypeList.add( DevRentStateEnum.INSTALLED.getState()); + jobTypeList.add( DevRentStateEnum.INSTALL_CANCELLED.getState()); + JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList); + + // 绗竴娆� 瀹夎鎿嶄綔 + if (null == jobRecordDO) { + List<DevRentDO> devRentDOList = devRentMapper.selectByPatIdAndState(createReqVO.getPatId(), DevRentStateEnum.READY.getState()); + if (devRentDOList.size() == 0) + throw exception(DEV_INSTALL_NOT_RECEIVED); + else if (devRentDOList.size() != 1) { + throw exception(DEV_INSTALL_EXCEPTION); + } rent_id = devRentDOList.getFirst().getId(); createReqVO.setId( rent_id ); @@ -93,37 +239,41 @@ } else { // 鎾ら攢 鏀惧純鎿嶄綔 createReqVO.setState( DevRentStateEnum.INSTALLED.getState() ); - updateDevRent( createReqVO ); - JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId); - if (null != jobRecordDO) { - jobRecordDO.setDevId(createReqVO.getDevId()); - jobRecordDO.setJobType( DevRentStateEnum.INSTALLED.getState() ); - jobRecordDO.setJobTime(createReqVO.getRentTime()); - jobRecordDO.setRemark(createReqVO.getRemark()); - jobRecordDO.setUpdater(String.valueOf(userId)); - jobRecordDO.setUpdateTime(LocalDateTime.now()); - jobRecordMapper.updateById(jobRecordDO); - } + jobRecordDO.setDevId(createReqVO.getDevId()); + jobRecordDO.setJobType( DevRentStateEnum.INSTALLED.getState() ); + jobRecordDO.setJobTime(createReqVO.getRentTime()); + jobRecordDO.setRemark(createReqVO.getRemark()); + jobRecordDO.setUpdater(String.valueOf(userId)); + jobRecordDO.setUpdateTime(LocalDateTime.now()); + jobRecordMapper.updateById(jobRecordDO); } + + // 鏇存柊..闃熷垪鐘舵�� + queueMapper.updateBedQueueStatus(createReqVO.getRoomId(), createReqVO.getBedNo(), + QueueStatusEnum.INSTALLING.getStatus(), QueueStatusEnum.FINISH.getStatus()); + return CommonResult.success(rent_id); } @Override - @Transactional + @Transactional(rollbackFor = Exception.class) public Long dismantleOperation(DevRentSaveReqVO updateReqVO) { updateReqVO.setState( DevRentStateEnum.DISMANTLED.getState() ); updateDevRent( updateReqVO ); + Long rentId = updateReqVO.getId(); Long userId = SecurityFrameworkUtils.getLoginUserId(); String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); // 璁惧鎭㈠鍒扮┖闂� - resumeDevFree( updateReqVO.getDevId() ); + markDevFree( updateReqVO.getDevId(), rentId ); - JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(updateReqVO.getId(), userId); - if (jobRecordDO == null) { + List<Integer> jobTypeList = new ArrayList<Integer>(); + jobTypeList.add( DevRentStateEnum.DISMANTLED.getState()); + JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(updateReqVO.getId(), userId, jobTypeList); + if (null == jobRecordDO) { JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO(); jobRecordSaveReqVO.setRentId( updateReqVO.getId() ); jobRecordSaveReqVO.setDevId( updateReqVO.getDevId() ); @@ -150,30 +300,67 @@ } @Override - @Transactional - public CommonResult<Long> cancelOperation(DevCancelReqVO cancelReqVO) { + @Transactional(rollbackFor = Exception.class) + public Long dataEntryOperation(DevRentSaveReqVO updateReqVO) { + updateReqVO.setState( DevRentStateEnum.DATAENTERED.getState() ); + updateDevRent( updateReqVO ); + Long userId = SecurityFrameworkUtils.getLoginUserId(); String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); - // 鑻ヤ粠 瑁呮満 鏀逛负 鍙栨秷瑁呮満锛屾仮澶嶈澶囩姸鎬� - if (null != cancelReqVO.getDevId()) { - resumeDevFree( cancelReqVO.getDevId() ); + List<Integer> jobTypeList = new ArrayList<Integer>(); + jobTypeList.add( DevRentStateEnum.DATAENTERED.getState()); + JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(updateReqVO.getId(), userId, jobTypeList); + if (null == jobRecordDO) { + JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO(); + jobRecordSaveReqVO.setRentId( updateReqVO.getId() ); + jobRecordSaveReqVO.setDevId( updateReqVO.getDevId() ); + jobRecordSaveReqVO.setDocId( userId ); + jobRecordSaveReqVO.setDocName( userNickname ); + jobRecordSaveReqVO.setPatId( updateReqVO.getPatId() ); + jobRecordSaveReqVO.setPatName( updateReqVO.getPatName() ); + jobRecordSaveReqVO.setJobTime( updateReqVO.getEntryTime() ); + jobRecordSaveReqVO.setJobType( DevRentStateEnum.DATAENTERED.getState() ); + jobRecordSaveReqVO.setRemark( updateReqVO.getRemark() ); + jobRecordSaveReqVO.setSummary( updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment() ); + JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); + jobRecordMapper.insert(jobRecord); + } else { + jobRecordDO.setJobType( DevRentStateEnum.DATAENTERED.getState() ); + jobRecordDO.setJobTime( updateReqVO.getEntryTime() ); + jobRecordDO.setRemark( updateReqVO.getRemark() ); + jobRecordDO.setSummary( updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment() ); + jobRecordDO.setUpdater( String.valueOf(userId) ); + jobRecordMapper.updateById(jobRecordDO); } + return updateReqVO.getId(); + } + + // 甯歌妫�鏌� 鍙栨秷 + @Override + @Transactional(rollbackFor = Exception.class) + public CommonResult<Long> cancelRoutineOperation(DevCancelReqVO cancelReqVO) { + Long userId = SecurityFrameworkUtils.getLoginUserId(); + String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); DevRentSaveReqVO createReqVO = BeanUtils.toBean(cancelReqVO, DevRentSaveReqVO.class); createReqVO.setDevId(null); - createReqVO.setState( DevRentStateEnum.CANCELLED.getState() ); + createReqVO.setState( DevRentStateEnum.ROUTINE_CANCELLED.getState()); Long rent_id = createReqVO.getId(); - if (null == rent_id) { + List<Integer> jobTypeList = new ArrayList<Integer>(); + jobTypeList.add( DevRentStateEnum.ROUTINE_FINISH.getState()); + jobTypeList.add( DevRentStateEnum.ROUTINE_CANCELLED.getState()); + JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList); + if (null == jobRecordDO) { List<DevRentDO> devRentDOList = devRentMapper.selectByPatIdAndState(createReqVO.getPatId(), DevRentStateEnum.FREE.getState()); if (devRentDOList.size() != 1) - return CommonResult.error(DEV_INSTALL_EXIST); + throw exception(ROUTINE_CHECK_EXIST); rent_id = devRentDOList.getFirst().getId(); createReqVO.setId( rent_id ); - createReqVO.setState( DevRentStateEnum.CANCELLED.getState() ); + createReqVO.setState( DevRentStateEnum.ROUTINE_CANCELLED.getState() ); updateDevRent( createReqVO ); JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO(); @@ -183,7 +370,7 @@ jobRecordSaveReqVO.setDocName(userNickname); jobRecordSaveReqVO.setPatId(createReqVO.getPatId()); jobRecordSaveReqVO.setPatName(createReqVO.getPatName()); - jobRecordSaveReqVO.setJobType( DevRentStateEnum.CANCELLED.getState() ); + jobRecordSaveReqVO.setJobType( DevRentStateEnum.ROUTINE_CANCELLED.getState() ); jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime()); jobRecordSaveReqVO.setRemark(createReqVO.getRemark()); jobRecordSaveReqVO.setSummary(""); @@ -193,25 +380,150 @@ } else { updateDevRent( createReqVO ); - JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId); - if (null != jobRecordDO) { - jobRecordDO.setDevId(null); - jobRecordDO.setJobType( DevRentStateEnum.CANCELLED.getState() ); - jobRecordDO.setJobTime(createReqVO.getRentTime()); - jobRecordDO.setRemark(createReqVO.getRemark()); - jobRecordDO.setUpdater(String.valueOf(userId)); - jobRecordDO.setUpdateTime(LocalDateTime.now()); - jobRecordMapper.updateById(jobRecordDO); - } + jobRecordDO.setDevId(null); + jobRecordDO.setJobType(DevRentStateEnum.ROUTINE_CANCELLED.getState()); + jobRecordDO.setJobTime(createReqVO.getRentTime()); + jobRecordDO.setRemark(createReqVO.getRemark()); + jobRecordDO.setUpdater(String.valueOf(userId)); + jobRecordDO.setUpdateTime(LocalDateTime.now()); + jobRecordMapper.updateById(jobRecordDO); } return CommonResult.success(rent_id); } @Override - @Transactional - public CommonResult<Long> loseOperation(DevRentSaveReqVO updateReqVO) { + @Transactional(rollbackFor = Exception.class) + public CommonResult<Long> cancelReadyOperation(DevCancelReqVO cancelReqVO) { + Long userId = SecurityFrameworkUtils.getLoginUserId(); + String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); + Long rentId = cancelReqVO.getId(); + + // 鑻ヤ粠 瑁呮満 鏀逛负 鍙栨秷瑁呮満锛屾仮澶嶈澶囩姸鎬� + if (null != cancelReqVO.getDevId()) { + markDevFree( cancelReqVO.getDevId(), rentId ); + } + + DevRentSaveReqVO createReqVO = BeanUtils.toBean(cancelReqVO, DevRentSaveReqVO.class); + createReqVO.setDevId(null); + createReqVO.setState( DevRentStateEnum.READY_CANCELLED.getState()); + + Long rent_id = createReqVO.getId(); + + List<Integer> jobTypeList = new ArrayList<Integer>(); + jobTypeList.add( DevRentStateEnum.READY.getState()); + jobTypeList.add( DevRentStateEnum.READY_CANCELLED.getState()); + JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList); + if (null == jobRecordDO) { + List<DevRentDO> devRentDOList = devRentMapper.selectByPatIdAndState(createReqVO.getPatId(), DevRentStateEnum.FREE.getState()); + if (devRentDOList.size() != 1) + throw exception(DEV_INSTALL_EXIST); + + rent_id = devRentDOList.getFirst().getId(); + createReqVO.setId( rent_id ); + createReqVO.setState( DevRentStateEnum.READY_CANCELLED.getState() ); + updateDevRent( createReqVO ); + + JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO(); + jobRecordSaveReqVO.setRentId(rent_id); + jobRecordSaveReqVO.setDevId(null); + jobRecordSaveReqVO.setDocId(userId); + jobRecordSaveReqVO.setDocName(userNickname); + jobRecordSaveReqVO.setPatId(createReqVO.getPatId()); + jobRecordSaveReqVO.setPatName(createReqVO.getPatName()); + jobRecordSaveReqVO.setJobType( DevRentStateEnum.READY_CANCELLED.getState() ); + jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime()); + jobRecordSaveReqVO.setRemark(createReqVO.getRemark()); + jobRecordSaveReqVO.setSummary(""); + + JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); + jobRecordMapper.insert(jobRecord); + } else { + updateDevRent( createReqVO ); + + jobRecordDO.setDevId(null); + jobRecordDO.setJobType(DevRentStateEnum.READY_CANCELLED.getState()); + jobRecordDO.setJobTime(createReqVO.getRentTime()); + jobRecordDO.setRemark(createReqVO.getRemark()); + jobRecordDO.setUpdater(String.valueOf(userId)); + jobRecordDO.setUpdateTime(LocalDateTime.now()); + jobRecordMapper.updateById(jobRecordDO); + } + return CommonResult.success(rent_id); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public CommonResult<Long> cancelInstallOperation(DevCancelReqVO cancelReqVO) { + Long userId = SecurityFrameworkUtils.getLoginUserId(); + String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); + Long rentId = cancelReqVO.getId(); + + // 鑻ヤ粠 瑁呮満 鏀逛负 鍙栨秷瑁呮満锛屾仮澶嶈澶囩姸鎬� + if (null != cancelReqVO.getDevId()) { + markDevFree( cancelReqVO.getDevId(), rentId ); + } + + DevRentSaveReqVO createReqVO = BeanUtils.toBean(cancelReqVO, DevRentSaveReqVO.class); + createReqVO.setDevId(null); + createReqVO.setState( DevRentStateEnum.INSTALL_CANCELLED.getState() ); + + Long rent_id = createReqVO.getId(); + + List<Integer> jobTypeList = new ArrayList<Integer>(); + jobTypeList.add( DevRentStateEnum.INSTALLED.getState()); + jobTypeList.add( DevRentStateEnum.INSTALL_CANCELLED.getState()); + JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList); + if (null == jobRecordDO) { + List<DevRentDO> devRentDOList = devRentMapper.selectByPatIdAndState(createReqVO.getPatId(), DevRentStateEnum.READY.getState()); + if (devRentDOList.size() != 1) + throw exception(DEV_INSTALL_EXIST); + + rent_id = devRentDOList.getFirst().getId(); + createReqVO.setId( rent_id ); + createReqVO.setState( DevRentStateEnum.INSTALL_CANCELLED.getState() ); + updateDevRent( createReqVO ); + + JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO(); + jobRecordSaveReqVO.setRentId(rent_id); + jobRecordSaveReqVO.setDevId(null); + jobRecordSaveReqVO.setDocId(userId); + jobRecordSaveReqVO.setDocName(userNickname); + jobRecordSaveReqVO.setPatId(createReqVO.getPatId()); + jobRecordSaveReqVO.setPatName(createReqVO.getPatName()); + jobRecordSaveReqVO.setJobType( DevRentStateEnum.INSTALL_CANCELLED.getState() ); + jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime()); + jobRecordSaveReqVO.setRemark(createReqVO.getRemark()); + jobRecordSaveReqVO.setSummary(""); + + JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); + jobRecordMapper.insert(jobRecord); + } else { + updateDevRent( createReqVO ); + + jobRecordDO.setDevId(null); + jobRecordDO.setJobType( DevRentStateEnum.INSTALL_CANCELLED.getState() ); + jobRecordDO.setJobTime(createReqVO.getRentTime()); + jobRecordDO.setRemark(createReqVO.getRemark()); + jobRecordDO.setUpdater(String.valueOf(userId)); + jobRecordDO.setUpdateTime(LocalDateTime.now()); + jobRecordMapper.updateById(jobRecordDO); + } + return CommonResult.success(rent_id); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public CommonResult<Long> dismantleExceptionOperation(DevRentSaveReqVO updateReqVO) { + DevStateEnum devStateEnum = null; + if (updateReqVO.getState() == DevStateEnum.DAMAGED.getState()) + devStateEnum = DevStateEnum.DAMAGED; + else if (updateReqVO.getState() == DevStateEnum.LOST.getState()) + devStateEnum = DevStateEnum.LOST; + else + throw exception(DEV_DISMANTLE_EXCEPTION); + // 璁惧閬楀け鏃�, 鏍囨敞閬楀け - markDevLost( updateReqVO.getDevId(), updateReqVO.getReturnTime().toLocalDate() ); + markDevDismantleException( updateReqVO.getDevId(), updateReqVO.getId(), updateReqVO.getReturnTime().toLocalDate(), devStateEnum ); updateReqVO.setState( DevRentStateEnum.LOST.getState() ); updateDevRent( updateReqVO ); @@ -219,8 +531,10 @@ Long userId = SecurityFrameworkUtils.getLoginUserId(); String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); - JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(updateReqVO.getId(), userId); - if (jobRecordDO == null) { + List<Integer> jobTypeList = new ArrayList<Integer>(); + jobTypeList.add( DevRentStateEnum.LOST.getState()); + JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(updateReqVO.getId(), userId, jobTypeList); + if (null == jobRecordDO) { JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO(); jobRecordSaveReqVO.setRentId( updateReqVO.getId() ); jobRecordSaveReqVO.setDevId( updateReqVO.getDevId() ); @@ -249,8 +563,6 @@ @Override public Long createDevRent(DevRentSaveReqVO createReqVO) { - // - // 鎻掑叆 DevRentDO devRent = BeanUtils.toBean(createReqVO, DevRentDO.class); devRentMapper.insert(devRent); @@ -292,39 +604,94 @@ } @Override - public DevRentDO getDismantleRent(DevRentSearchReqVO searchReqVO) { - return devRentMapper.getDismantleRentByState(searchReqVO); + public DevRentDO getInstalledOrCancelledRent(DevRentSearchReqVO searchReqVO) { + List<Integer> stateList = new ArrayList<>(); + stateList.add( DevRentStateEnum.INSTALLED.getState() ); + stateList.add( DevRentStateEnum.INSTALL_CANCELLED.getState()); + searchReqVO.setStateList( stateList ); + return devRentMapper.getRentByState(searchReqVO); } - private Integer markDevInUse(String devId) { - // 璁惧鏍囨敞 鍦ㄤ娇鐢� + @Override + public DevRentDO getFreeRent(DevRentSearchReqVO searchReqVO) { + List<Integer> stateList = new ArrayList<>(); + stateList.add( DevRentStateEnum.FREE.getState() ); + searchReqVO.setStateList( stateList ); + return devRentMapper.getRentByState(searchReqVO); + } + + @Override + public DevRentDO getReadyOrCancelledRent(DevRentSearchReqVO searchReqVO) { + List<Integer> stateList = new ArrayList<>(); + stateList.add( DevRentStateEnum.READY.getState() ); + stateList.add( DevRentStateEnum.READY_CANCELLED.getState()); + searchReqVO.setStateList( stateList ); + return devRentMapper.getRentByState(searchReqVO); + } + + @Override + public DevRentDO getDismantledRent(DevRentSearchReqVO searchReqVO) { + List<Integer> stateList = new ArrayList<>(); + stateList.add( DevRentStateEnum.DISMANTLED.getState() ); + searchReqVO.setStateList( stateList ); + return devRentMapper.getRentByState(searchReqVO); + } + + // 鏍囪 璁惧宸茶棰嗗彇 + private Integer markDevRecieved(String devId, Long rentId) { + // 璁惧鏍囨敞 宸查鍙� DeviceDO deviveDO = deviceMapper.getDeviceByDevId(devId); - if (null != deviveDO) { - deviveDO.setState( DevStateEnum.INUSE.getState() ); + if (null != deviveDO && deviveDO.getState() == DevStateEnum.FREE.getState()) { + deviveDO.setState( DevStateEnum.RECEIVED.getState() ); + deviveDO.setRentId( rentId ); + deviveDO.setStateDate( LocalDate.now() ); return deviceMapper.updateById(deviveDO); } return 0; } - private Integer markDevLost(String devId, LocalDate localDate) { + // 鏍囪 璁惧宸茶浣跨敤 + private Integer markDevInUse(String devId, Long rentId) { + DeviceDO deviveDO = deviceMapper.getDeviceByDevId(devId); + if (null == deviveDO) + return 0; + + if (deviveDO.getState() == DevStateEnum.RECEIVED.getState() && deviveDO.getRentId() == rentId) { + deviveDO.setState( DevStateEnum.INUSE.getState() ); + deviveDO.setStateDate( LocalDate.now() ); + return deviceMapper.updateById(deviveDO); + } + + if (deviveDO.getState() == DevStateEnum.FREE.getState()) { + deviveDO.setState( DevStateEnum.INUSE.getState() ); + deviveDO.setStateDate( LocalDate.now() ); + deviveDO.setRentId( rentId ); + return deviceMapper.updateById(deviveDO); + } + + return 0; + } + + private Integer markDevDismantleException(String devId, Long rentId, LocalDate localDate, DevStateEnum devStateEnum) { // 璁惧鏍囨敞閬楀け DeviceDO deviveDO = deviceMapper.getDeviceByDevId(devId); - if (null != deviveDO) { - deviveDO.setState( DevStateEnum.LOST.getState() ); - deviveDO.setLoseDate( localDate ); // createReqVO.getReturnTime().toLocalDate() + if (null != deviveDO && deviveDO.getState() == DevStateEnum.INUSE.getState() && deviveDO.getRentId() == rentId) { + deviveDO.setState( devStateEnum.getState() ); + deviveDO.setStateDate( localDate ); return deviceMapper.updateById(deviveDO); } return 0; } - private Integer resumeDevFree(String devId) { + private Integer markDevFree(String devId, Long rentId) { // 璁惧鏍囨敞閬楀け 鎭㈠涓虹┖闂� DeviceDO deviveDO = deviceMapper.getDeviceByDevId( devId ); - if (null != deviveDO) { + if (null != deviveDO && deviveDO.getRentId() == rentId) { deviveDO.setState( DevStateEnum.FREE.getState() ); - deviveDO.setLoseDate( null ); + deviveDO.setStateDate( LocalDate.now() ); + deviveDO.setRentId(null); return deviceMapper.updateById(deviveDO); } -- Gitblit v1.9.3