From d8c1b8408ca24f3e02427c7885da8c87c90f16a0 Mon Sep 17 00:00:00 2001 From: eight <641137800@qq.com> Date: 星期二, 12 十一月 2024 19:43:48 +0800 Subject: [PATCH] update --- jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/devrent/DevRentServiceImpl.java | 218 +++++++++++++++++++++++++++++++++++++++++------------- 1 files changed, 166 insertions(+), 52 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 30f77c7..d1b9401 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 @@ -3,14 +3,17 @@ import cn.lihu.jh.framework.common.pojo.CommonResult; import cn.lihu.jh.framework.security.core.util.SecurityFrameworkUtils; import cn.lihu.jh.module.ecg.controller.admin.jobrecord.vo.JobRecordSaveReqVO; +import cn.lihu.jh.module.ecg.dal.dataobject.checktype.CheckTypeDO; import cn.lihu.jh.module.ecg.dal.dataobject.devmanage.DeviceDO; import cn.lihu.jh.module.ecg.dal.dataobject.jobrecord.JobRecordDO; +import cn.lihu.jh.module.ecg.dal.dataobject.queue.QueueDO; 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 cn.lihu.jh.module.ecg.service.queue.QueueServiceTxFunctions; import org.springframework.stereotype.Service; import org.springframework.validation.annotation.Validated; import org.springframework.transaction.annotation.Transactional; @@ -40,6 +43,9 @@ @Service @Validated public class DevRentServiceImpl implements DevRentService { + + @Resource + QueueServiceTxFunctions queueServiceTxFunctions; @Resource private DevRentMapper devRentMapper; @@ -75,7 +81,7 @@ 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()); + List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.FREE.getState()); if (devRentDOList.size() == 0) throw exception(DEV_INSTALL_NOT_APPOINTMENT); else if (devRentDOList.size() != 1) { @@ -98,6 +104,7 @@ jobRecordSaveReqVO.setJobType( DevRentStateEnum.ROUTINE_FINISH.getState() ); jobRecordSaveReqVO.setRemark(createReqVO.getRemark()); jobRecordSaveReqVO.setSummary(""); + jobRecordSaveReqVO.setCheckType( createReqVO.getCheckType() ); JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); jobRecordMapper.insert(jobRecord); @@ -117,8 +124,25 @@ } // 鏇存柊..闃熷垪鐘舵�� - queueMapper.updateBedQueueStatus(createReqVO.getRoomId(), createReqVO.getBedNo(), - QueueStatusEnum.ONSTAGE.getStatus(), QueueStatusEnum.FINISH.getStatus()); + //queueMapper.updateBedQueueStatus(createReqVO.getRoomId(), createReqVO.getBedNo(), + // QueueStatusEnum.ONSTAGE.getStatus(), QueueStatusEnum.FINISH.getStatus()); + + QueueDO firstOnStageQueueItem = queueMapper.getFirstItemByBedAndStatus(createReqVO.getRoomId(), + createReqVO.getBedNo(), QueueStatusEnum.ONSTAGE.getStatus()); + // QueueStatusEnum.ONSTAGE => QueueStatusEnum.FINISH + firstOnStageQueueItem.setStatus(QueueStatusEnum.FINISH.getStatus()); // 榛樿鐘舵�� 璁剧疆 + queueMapper.updateById( firstOnStageQueueItem ); + + // 妫�鏌ラ」鐩�.浜插拰鎬� 澶勭悊閫昏緫 + CheckTypeDO checkTypeDO = queueServiceTxFunctions.getCheckTypeItem( firstOnStageQueueItem.getBookCheckType() ); + if (checkTypeDO.getAffinityCheckTypes().length > 0) { + List<QueueDO> affinityAffinityWaitingItems = queueMapper.getCurPatGivenCheckTypesAndStatus(firstOnStageQueueItem.getPatId(), checkTypeDO.getAffinityCheckTypes(), QueueStatusEnum.AFFINITY_WAITING.getStatus()); + if (!affinityAffinityWaitingItems.isEmpty()) { + QueueDO tmpQueueDO = affinityAffinityWaitingItems.get(0); + tmpQueueDO.setStatus(QueueStatusEnum.ONSTAGE.getStatus()); + queueMapper.updateById(tmpQueueDO); + } + } return CommonResult.success(rent_id); } @@ -128,21 +152,20 @@ public CommonResult<Long> readyOperation(DevRentSaveReqVO createReqVO) { Long userId = SecurityFrameworkUtils.getLoginUserId(); String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); + Long rent_id = createReqVO.getId(); // 鏍囨敞璁惧 宸查鍙� - Integer ret = markDevRecieved(createReqVO.getDevId()); + Integer ret = markDevRecieved(createReqVO.getDevId(), rent_id); if (null == ret || 0 == ret) { throw exception(DEVICE_NOT_FREE); } - - 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()); + List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.FREE.getState()); if (devRentDOList.size() == 0) throw exception(DEV_INSTALL_NOT_APPOINTMENT); else if (devRentDOList.size() != 1) { @@ -165,6 +188,7 @@ jobRecordSaveReqVO.setJobType( DevRentStateEnum.READY.getState() ); jobRecordSaveReqVO.setRemark(createReqVO.getRemark()); jobRecordSaveReqVO.setSummary(""); + jobRecordSaveReqVO.setCheckType( createReqVO.getCheckType() ); JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); jobRecordMapper.insert(jobRecord); @@ -184,8 +208,39 @@ } // 鏇存柊..闃熷垪鐘舵�� - queueMapper.updateBedQueueStatus(createReqVO.getRoomId(), createReqVO.getBedNo(), - QueueStatusEnum.ONSTAGE.getStatus(), QueueStatusEnum.RECEIVED.getStatus()); + //queueMapper.updateBedQueueStatus(createReqVO.getRoomId(), createReqVO.getBedNo(), + // QueueStatusEnum.ONSTAGE.getStatus(), QueueStatusEnum.RECEIVED.getStatus()); + + QueueDO firstOnStageQueueItem = queueMapper.getFirstItemByBedAndStatus(createReqVO.getRoomId(), createReqVO.getBedNo(), QueueStatusEnum.ONSTAGE.getStatus()); + CheckTypeDO checkTypeDO = queueServiceTxFunctions.getCheckTypeItem( firstOnStageQueueItem.getBookCheckType() ); + + // QueueStatusEnum.ONSTAGE => QueueStatusEnum.RECEIVED + firstOnStageQueueItem.setStatus(QueueStatusEnum.RECEIVED.getStatus()); // 榛樿鐘舵�� 璁剧疆 + // 妫�鏌ラ」鐩�.浜插拰鎬� 澶勭悊閫昏緫 + if (checkTypeDO.getAffinityCheckTypes().length > 0) { + List<QueueDO> affinityInstallingItems = queueMapper.getCurPatGivenCheckTypesAndStatus(firstOnStageQueueItem.getPatId(), checkTypeDO.getAffinityCheckTypes(), QueueStatusEnum.INSTALLING.getStatus()); + if (!affinityInstallingItems.isEmpty()) { + firstOnStageQueueItem.setStatus(QueueStatusEnum.AFFINITY_RECEIVED.getStatus()); + } + } + queueMapper.updateById( firstOnStageQueueItem ); + + // 妫�鏌ラ」鐩�.浜插拰鎬� 澶勭悊閫昏緫 + if (checkTypeDO.getAffinityCheckTypes().length > 0) { + List<QueueDO> affinityReadyItems = queueMapper.getCurPatGivenCheckTypesAndStatus(firstOnStageQueueItem.getPatId(), checkTypeDO.getAffinityCheckTypes(), QueueStatusEnum.READY.getStatus()); + if (!affinityReadyItems.isEmpty()) { + QueueDO tmpQueueDO = affinityReadyItems.get(0); + tmpQueueDO.setStatus(QueueStatusEnum.ONSTAGE.getStatus()); + queueMapper.updateById(tmpQueueDO); + } else { + List<QueueDO> affinityAffinityWaitingItems = queueMapper.getCurPatGivenCheckTypesAndStatus(firstOnStageQueueItem.getPatId(), checkTypeDO.getAffinityCheckTypes(), QueueStatusEnum.AFFINITY_WAITING.getStatus()); + if (!affinityAffinityWaitingItems.isEmpty()) { + QueueDO tmpQueueDO = affinityAffinityWaitingItems.get(0); + tmpQueueDO.setStatus(QueueStatusEnum.ONSTAGE.getStatus()); + queueMapper.updateById(tmpQueueDO); + } + } + } return CommonResult.success(rent_id); } @@ -195,14 +250,19 @@ public CommonResult<Long> installOperation(DevRentSaveReqVO createReqVO) { Long userId = SecurityFrameworkUtils.getLoginUserId(); String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); + Long rent_id = createReqVO.getId(); + + // 瀵逛簬宸叉湁棰嗙敤锛屼絾鏄鏈烘椂浣跨敤鐨勪笉鏄凡棰嗙敤璁惧锛岄渶閲婃斁 婧愰鐢� 璁惧 + DevRentDO devRentDO = getDevRent(rent_id); + if ( null != devRentDO.getDevId() && !createReqVO.getDevId().equals(devRentDO.getDevId()) ) { + markDevFree( devRentDO.getDevId(), rent_id); + } // 璁剧疆璁惧 浣跨敤涓� - Integer ret = markDevInUse(createReqVO.getDevId()); + Integer ret = markDevInUse(createReqVO.getDevId(), rent_id); if (null == ret || 0 == ret) { throw exception(DEVICE_NOT_RECEIVED); } - - Long rent_id = createReqVO.getId(); // 妫�鏌� job_record 鐢ㄤ簬纭鏄惁鏄涓�娆″畨瑁呮搷浣� List<Integer> jobTypeList = new ArrayList<Integer>(); @@ -212,7 +272,7 @@ // 绗竴娆� 瀹夎鎿嶄綔 if (null == jobRecordDO) { - List<DevRentDO> devRentDOList = devRentMapper.selectByPatIdAndState(createReqVO.getPatId(), DevRentStateEnum.READY.getState()); + List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.READY.getState()); if (devRentDOList.size() == 0) throw exception(DEV_INSTALL_NOT_RECEIVED); else if (devRentDOList.size() != 1) { @@ -235,6 +295,7 @@ jobRecordSaveReqVO.setJobType( DevRentStateEnum.INSTALLED.getState() ); jobRecordSaveReqVO.setRemark(createReqVO.getRemark()); jobRecordSaveReqVO.setSummary(""); + jobRecordSaveReqVO.setCheckType( createReqVO.getCheckType() ); JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); jobRecordMapper.insert(jobRecord); @@ -253,8 +314,25 @@ } // 鏇存柊..闃熷垪鐘舵�� - queueMapper.updateBedQueueStatus(createReqVO.getRoomId(), createReqVO.getBedNo(), - QueueStatusEnum.INSTALLING.getStatus(), QueueStatusEnum.FINISH.getStatus()); + //queueMapper.updateBedQueueStatus(createReqVO.getRoomId(), createReqVO.getBedNo(), + // QueueStatusEnum.INSTALLING.getStatus(), QueueStatusEnum.FINISH.getStatus()); + + QueueDO firstInstallingQueueItem = queueMapper.getFirstItemByBedAndStatus(createReqVO.getRoomId(), + createReqVO.getBedNo(), QueueStatusEnum.INSTALLING.getStatus()); + // QueueStatusEnum.INSTALLING => QueueStatusEnum.FINISH + firstInstallingQueueItem.setStatus(QueueStatusEnum.FINISH.getStatus()); // 榛樿鐘舵�� 璁剧疆 + queueMapper.updateById( firstInstallingQueueItem ); + + // 妫�鏌ラ」鐩�.浜插拰鎬� 澶勭悊閫昏緫 + CheckTypeDO checkTypeDO = queueServiceTxFunctions.getCheckTypeItem( firstInstallingQueueItem.getBookCheckType() ); + if (checkTypeDO.getAffinityCheckTypes().length > 0) { + List<QueueDO> affinityAffinityReceivedItems = queueMapper.getCurPatGivenCheckTypesAndStatus(firstInstallingQueueItem.getPatId(), checkTypeDO.getAffinityCheckTypes(), QueueStatusEnum.AFFINITY_RECEIVED.getStatus()); + if (!affinityAffinityReceivedItems.isEmpty()) { + QueueDO tmpQueueDO = affinityAffinityReceivedItems.get(0); + tmpQueueDO.setStatus(QueueStatusEnum.INSTALLING.getStatus()); + queueMapper.updateById(tmpQueueDO); + } + } return CommonResult.success(rent_id); } @@ -264,12 +342,13 @@ 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 ); List<Integer> jobTypeList = new ArrayList<Integer>(); jobTypeList.add( DevRentStateEnum.DISMANTLED.getState()); @@ -286,6 +365,7 @@ jobRecordSaveReqVO.setJobType( DevRentStateEnum.DISMANTLED.getState() ); jobRecordSaveReqVO.setRemark( updateReqVO.getRemark() ); jobRecordSaveReqVO.setSummary( updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment() ); + jobRecordSaveReqVO.setCheckType( updateReqVO.getCheckType() ); JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); jobRecordMapper.insert(jobRecord); } else { @@ -324,6 +404,7 @@ jobRecordSaveReqVO.setJobType( DevRentStateEnum.DATAENTERED.getState() ); jobRecordSaveReqVO.setRemark( updateReqVO.getRemark() ); jobRecordSaveReqVO.setSummary( updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment() ); + jobRecordSaveReqVO.setCheckType( updateReqVO.getCheckType() ); JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); jobRecordMapper.insert(jobRecord); } else { @@ -355,7 +436,7 @@ 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()); + List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.FREE.getState()); if (devRentDOList.size() != 1) throw exception(ROUTINE_CHECK_EXIST); @@ -375,6 +456,7 @@ jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime()); jobRecordSaveReqVO.setRemark(createReqVO.getRemark()); jobRecordSaveReqVO.setSummary(""); + jobRecordSaveReqVO.setCheckType( createReqVO.getCheckType() ); JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); jobRecordMapper.insert(jobRecord); @@ -397,10 +479,11 @@ public CommonResult<Long> cancelReadyOperation(DevCancelReqVO cancelReqVO) { Long userId = SecurityFrameworkUtils.getLoginUserId(); String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); + Long rentId = cancelReqVO.getId(); // 鑻ヤ粠 瑁呮満 鏀逛负 鍙栨秷瑁呮満锛屾仮澶嶈澶囩姸鎬� if (null != cancelReqVO.getDevId()) { - resumeDevFree( cancelReqVO.getDevId() ); + markDevFree( cancelReqVO.getDevId(), rentId ); } DevRentSaveReqVO createReqVO = BeanUtils.toBean(cancelReqVO, DevRentSaveReqVO.class); @@ -414,7 +497,7 @@ 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()); + List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.FREE.getState()); if (devRentDOList.size() != 1) throw exception(DEV_INSTALL_EXIST); @@ -434,6 +517,7 @@ jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime()); jobRecordSaveReqVO.setRemark(createReqVO.getRemark()); jobRecordSaveReqVO.setSummary(""); + jobRecordSaveReqVO.setCheckType( createReqVO.getCheckType() ); JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); jobRecordMapper.insert(jobRecord); @@ -456,10 +540,11 @@ public CommonResult<Long> cancelInstallOperation(DevCancelReqVO cancelReqVO) { Long userId = SecurityFrameworkUtils.getLoginUserId(); String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); + Long rentId = cancelReqVO.getId(); // 鑻ヤ粠 瑁呮満 鏀逛负 鍙栨秷瑁呮満锛屾仮澶嶈澶囩姸鎬� if (null != cancelReqVO.getDevId()) { - resumeDevFree( cancelReqVO.getDevId() ); + markDevFree( cancelReqVO.getDevId(), rentId ); } DevRentSaveReqVO createReqVO = BeanUtils.toBean(cancelReqVO, DevRentSaveReqVO.class); @@ -473,7 +558,7 @@ 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()); + List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.READY.getState()); if (devRentDOList.size() != 1) throw exception(DEV_INSTALL_EXIST); @@ -493,6 +578,7 @@ jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime()); jobRecordSaveReqVO.setRemark(createReqVO.getRemark()); jobRecordSaveReqVO.setSummary(""); + jobRecordSaveReqVO.setCheckType( createReqVO.getCheckType() ); JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); jobRecordMapper.insert(jobRecord); @@ -512,17 +598,31 @@ @Override @Transactional(rollbackFor = Exception.class) - public CommonResult<Long> loseOperation(DevRentSaveReqVO updateReqVO) { - // 璁惧閬楀け鏃�, 鏍囨敞閬楀け - markDevLost( updateReqVO.getDevId(), updateReqVO.getReturnTime().toLocalDate() ); + public CommonResult<Long> dismantleExceptionOperation(DevRentSaveReqVO updateReqVO) { + DevStateEnum devStateEnum = null; + DevRentStateEnum devRentStateEnum = null; + if (updateReqVO.getState() == DevStateEnum.DAMAGED.getState()) { + devStateEnum = DevStateEnum.DAMAGED; + devRentStateEnum = DevRentStateEnum.DAMAGED; + } + else if (updateReqVO.getState() == DevStateEnum.LOST.getState()) { + devStateEnum = DevStateEnum.LOST; + devRentStateEnum = DevRentStateEnum.LOST; + } + else + throw exception(DEV_DISMANTLE_EXCEPTION); - updateReqVO.setState( DevRentStateEnum.LOST.getState() ); + // 璁惧閬楀け鏃�, 鏍囨敞閬楀け + markDevDismantleException( updateReqVO.getDevId(), updateReqVO.getId(), updateReqVO.getReturnTime().toLocalDate(), devStateEnum ); + + updateReqVO.setState( devRentStateEnum.getState() ); updateDevRent( updateReqVO ); Long userId = SecurityFrameworkUtils.getLoginUserId(); String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); List<Integer> jobTypeList = new ArrayList<Integer>(); + jobTypeList.add( DevRentStateEnum.DAMAGED.getState()); jobTypeList.add( DevRentStateEnum.LOST.getState()); JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(updateReqVO.getId(), userId, jobTypeList); if (null == jobRecordDO) { @@ -534,13 +634,14 @@ jobRecordSaveReqVO.setPatId( updateReqVO.getPatId() ); jobRecordSaveReqVO.setPatName( updateReqVO.getPatName() ); jobRecordSaveReqVO.setJobTime( updateReqVO.getReturnTime() ); - jobRecordSaveReqVO.setJobType( DevRentStateEnum.LOST.getState() ); + jobRecordSaveReqVO.setJobType( devRentStateEnum.getState() ); jobRecordSaveReqVO.setRemark( updateReqVO.getRemark() ); jobRecordSaveReqVO.setSummary( updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment() ); + jobRecordSaveReqVO.setCheckType( updateReqVO.getCheckType() ); JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); jobRecordMapper.insert(jobRecord); } else { - jobRecordDO.setJobType( DevRentStateEnum.LOST.getState() ); + jobRecordDO.setJobType( devRentStateEnum.getState() ); jobRecordDO.setJobTime( updateReqVO.getReturnTime() ); jobRecordDO.setRemark( updateReqVO.getRemark() ); jobRecordDO.setSummary( updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment() ); @@ -628,49 +729,62 @@ return devRentMapper.getRentByState(searchReqVO); } - private Integer markDevRecieved(String devId) { + // 鏍囪 璁惧宸茶棰嗗彇 + private Integer markDevRecieved(String devId, Long rentId) { // 璁惧鏍囨敞 宸查鍙� - DeviceDO deviveDO = deviceMapper.getDeviceByDevId(devId); - if (null != deviveDO && deviveDO.getState() == DevStateEnum.FREE.getState()) { - deviveDO.setState( DevStateEnum.RECEIVED.getState() ); - deviveDO.setStateDate( LocalDate.now() ); - return deviceMapper.updateById(deviveDO); + DeviceDO deviceDO = deviceMapper.getDeviceByDevId(devId); + if (null != deviceDO && DevStateEnum.FREE.isEqual(deviceDO.getState())) { + deviceDO.setState( DevStateEnum.RECEIVED.getState() ); + deviceDO.setRentId( rentId ); + deviceDO.setStateDate( LocalDate.now() ); + return deviceMapper.updateById(deviceDO); } return 0; } - private Integer markDevInUse(String devId) { - // 璁惧鏍囨敞 鍦ㄤ娇鐢� - DeviceDO deviveDO = deviceMapper.getDeviceByDevId(devId); - if (null != deviveDO && (deviveDO.getState() == DevStateEnum.RECEIVED.getState() || deviveDO.getState() == DevStateEnum.FREE.getState())) { - deviveDO.setState( DevStateEnum.INUSE.getState() ); - deviveDO.setStateDate( LocalDate.now() ); - return deviceMapper.updateById(deviveDO); + // 鏍囪 璁惧宸茶浣跨敤 + private Integer markDevInUse(String devId, Long rentId) { + DeviceDO deviceDO = deviceMapper.getDeviceByDevId(devId); + if (null == deviceDO) + return 0; + + if (DevStateEnum.RECEIVED.isEqual(deviceDO.getState()) && rentId.equals(deviceDO.getRentId())) { + deviceDO.setState( DevStateEnum.INUSE.getState() ); + deviceDO.setStateDate( LocalDate.now() ); + return deviceMapper.updateById(deviceDO); + } + + if (DevStateEnum.FREE.isEqual(deviceDO.getState())) { + deviceDO.setState( DevStateEnum.INUSE.getState() ); + deviceDO.setStateDate( LocalDate.now() ); + deviceDO.setRentId( rentId ); + return deviceMapper.updateById(deviceDO); } return 0; } - private Integer markDevLost(String devId, LocalDate localDate) { + 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.setStateDate( localDate ); - return deviceMapper.updateById(deviveDO); + DeviceDO deviceDO = deviceMapper.getDeviceByDevId(devId); + if (null != deviceDO && DevStateEnum.INUSE.isEqual(deviceDO.getState()) && rentId.equals(deviceDO.getRentId())) { + deviceDO.setState( devStateEnum.getState() ); + deviceDO.setStateDate( localDate ); + return deviceMapper.updateById(deviceDO); } return 0; } - private Integer resumeDevFree(String devId) { + private Integer markDevFree(String devId, Long rentId) { // 璁惧鏍囨敞閬楀け 鎭㈠涓虹┖闂� - DeviceDO deviveDO = deviceMapper.getDeviceByDevId( devId ); - if (null != deviveDO) { - deviveDO.setState( DevStateEnum.FREE.getState() ); - deviveDO.setStateDate( LocalDate.now() ); - return deviceMapper.updateById(deviveDO); + DeviceDO deviceDO = deviceMapper.getDeviceByDevId( devId ); + if (null != deviceDO && rentId.equals(deviceDO.getRentId())) { + deviceDO.setState( DevStateEnum.FREE.getState() ); + deviceDO.setStateDate( LocalDate.now() ); + deviceDO.setRentId(null); + return deviceMapper.updateById(deviceDO); } return 0; -- Gitblit v1.9.3