From f14d9737da8bbe94e82427f2d0e727fd15c88f2e Mon Sep 17 00:00:00 2001 From: eight <641137800@qq.com> Date: 星期一, 23 九月 2024 11:44:35 +0800 Subject: [PATCH] update --- jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/devrent/DevRentServiceImpl.java | 163 +++++++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 154 insertions(+), 9 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 0fe1d44..b37420b 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 @@ -1,19 +1,21 @@ package cn.lihu.jh.module.ecg.service.devrent; +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.devmanage.DeviceDO; 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 org.springframework.stereotype.Service; import org.springframework.validation.annotation.Validated; import org.springframework.transaction.annotation.Transactional; import java.time.LocalDateTime; -import java.util.*; + import cn.lihu.jh.module.ecg.controller.admin.devrent.vo.*; import cn.lihu.jh.module.ecg.dal.dataobject.devrent.DevRentDO; 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.devrent.DevRentMapper; @@ -38,14 +40,30 @@ @Resource private JobRecordMapper jobRecordMapper; + @Resource + DeviceMapper deviceMapper; + @Override @Transactional - public Long installOperation(DevRentSaveReqVO createReqVO) { + public CommonResult<Long> installOperation(DevRentSaveReqVO createReqVO) { Long userId = SecurityFrameworkUtils.getLoginUserId(); String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); + // 妫�鏌ヨ澶囩紪鍙� + DeviceDO deviceDO = deviceMapper.getDeviceByDevId( createReqVO.getDevId() ); + if (null == deviceDO ) { + return CommonResult.error(DEVICE_NOT_EXISTS); + } + Long rent_id = createReqVO.getId(); if (null == rent_id) { + + // 鍒ゆ柇鏄惁宸茬粡鏈夎鏈鸿褰� + Integer recordNum = jobRecordMapper.getPatientJobNum(createReqVO.getPatId(), createReqVO.getRentTime(), 0); + if (null != recordNum && recordNum > 0) { + return CommonResult.error(DEV_INSTALL_EXIST); + } + rent_id = createDevRent(createReqVO); JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO(); @@ -63,10 +81,15 @@ JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); jobRecordMapper.insert(jobRecord); } else { + // 鎾ら攢 鏀惧純鎿嶄綔 + createReqVO.setCancelled(0); + updateDevRent( createReqVO ); JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdJobTypeDocId(rent_id, 0, userId); if (null != jobRecordDO) { + jobRecordDO.setCancelled( createReqVO.getCancelled() ); + jobRecordDO.setDevId(createReqVO.getDevId()); jobRecordDO.setJobTime(createReqVO.getRentTime()); jobRecordDO.setRemark(createReqVO.getRemark()); jobRecordDO.setUpdater(String.valueOf(userId)); @@ -74,12 +97,15 @@ jobRecordMapper.updateById(jobRecordDO); } } - return rent_id; + return CommonResult.success(rent_id); } @Override @Transactional public Long dismantleOperation(DevRentSaveReqVO updateReqVO) { + // 鍙栨秷閬楀け鏍囪 + updateReqVO.setLost(0); + updateDevRent( updateReqVO ); Long userId = SecurityFrameworkUtils.getLoginUserId(); @@ -101,6 +127,12 @@ JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); jobRecordMapper.insert(jobRecord); } else { + // 璁惧閬楀け鏃�, 闇�鎭㈠鍒版甯� + resumeDevLost( updateReqVO ); + + // 鍙栨秷閬楀け鏍囪 + jobRecordDO.setLost(0); + jobRecordDO.setJobTime( updateReqVO.getReturnTime() ); jobRecordDO.setRemark( updateReqVO.getRemark() ); jobRecordDO.setSummary( updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment() ); @@ -108,7 +140,100 @@ jobRecordDO.setUpdateTime( LocalDateTime.now() ); jobRecordMapper.updateById(jobRecordDO); } - return 0L; + return updateReqVO.getId(); + } + + @Override + @Transactional + public CommonResult<Long> cancelOperation(DevCancelReqVO cancelReqVO) { + DevRentSaveReqVO createReqVO = BeanUtils.toBean(cancelReqVO, DevRentSaveReqVO.class); + Long userId = SecurityFrameworkUtils.getLoginUserId(); + String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); + + createReqVO.setCancelled(1); + + Long rent_id = createReqVO.getId(); + if (null == rent_id) { + + // 鍒ゆ柇鏄惁宸茬粡鏈夋媶鏈鸿褰� + Integer recordNum = jobRecordMapper.getPatientJobNum(createReqVO.getPatId(), createReqVO.getRentTime(), 0); + if (null != recordNum && recordNum > 0) { + return CommonResult.error(DEV_INSTALL_EXIST); + } + + rent_id = createDevRent(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(0); + jobRecordSaveReqVO.setCancelled(1); + jobRecordSaveReqVO.setRemark(createReqVO.getRemark()); + jobRecordSaveReqVO.setSummary(""); + + JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); + jobRecordMapper.insert(jobRecord); + } else { + updateDevRent( createReqVO ); + + JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdJobTypeDocId(rent_id, 0, userId); + if (null != jobRecordDO) { + //jobRecordDO.setDevId(createReqVO.getDevId()); + jobRecordDO.setJobTime(createReqVO.getRentTime()); + jobRecordDO.setCancelled(1); + 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) { + updateReqVO.setLost(1); + updateDevRent( updateReqVO ); + + Long userId = SecurityFrameworkUtils.getLoginUserId(); + String userNickname = SecurityFrameworkUtils.getLoginUserNickname(); + + JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdJobTypeDocId(updateReqVO.getId(), 1, userId); + if (jobRecordDO == null) { + 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.getReturnTime() ); + jobRecordSaveReqVO.setJobType( 1 ); + jobRecordSaveReqVO.setLost( updateReqVO.getLost() ); + jobRecordSaveReqVO.setRemark( updateReqVO.getRemark() ); + jobRecordSaveReqVO.setSummary( updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment() ); + JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class); + jobRecordMapper.insert(jobRecord); + } else { + jobRecordDO.setLost( updateReqVO.getLost() ); + jobRecordDO.setJobTime( updateReqVO.getReturnTime() ); + jobRecordDO.setRemark( updateReqVO.getRemark() ); + jobRecordDO.setSummary( updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment() ); + jobRecordDO.setUpdater( String.valueOf(userId) ); + jobRecordDO.setUpdateTime( LocalDateTime.now() ); + jobRecordMapper.updateById(jobRecordDO); + } + + // 璁惧閬楀け鏃�, 鏍囨敞閬楀け + markDevLost( updateReqVO ); + + return CommonResult.success(updateReqVO.getId()); } @Override @@ -141,7 +266,7 @@ private void validateDevRentExists(Long id) { if (devRentMapper.selectById(id) == null) { - throw exception(DEV_RENT_NOT_EXISTS); + throw exception(DEV_INSTALL_NOT_EXISTS); } } @@ -156,8 +281,28 @@ } @Override - public DevRentDO getLatestRent(String devId) { - return devRentMapper.getLatestRent(devId); + public DevRentDO getLatestRent(DevRentSearchReqVO searchReqVO) { + return devRentMapper.getLatestRent(searchReqVO); } -} \ No newline at end of file + private void markDevLost(DevRentSaveReqVO createReqVO) { + // 璁惧鏍囨敞閬楀け + DeviceDO deviveDO = deviceMapper.getDeviceByDevId(createReqVO.getDevId()); + if (null != deviveDO) { + deviveDO.setLost(1); + deviveDO.setLoseDate( createReqVO.getReturnTime().toLocalDate() ); + deviceMapper.updateById(deviveDO); + } + } + + private void resumeDevLost(DevRentSaveReqVO createReqVO) { + // 璁惧鏍囨敞閬楀け 鎭㈠涓烘甯� + DeviceDO deviveDO = deviceMapper.getDeviceByDevId(createReqVO.getDevId()); + if (null != deviveDO) { + deviveDO.setLost(0); + deviveDO.setLoseDate( null ); + deviceMapper.updateById(deviveDO); + } + } + +} -- Gitblit v1.9.3