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 cn.lihu.jh.module.ecg.enums.DevRentStateEnum;
|
import cn.lihu.jh.module.ecg.enums.DevStateEnum;
|
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.List;
|
|
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.util.object.BeanUtils;
|
|
import cn.lihu.jh.module.ecg.dal.mysql.devrent.DevRentMapper;
|
|
import javax.annotation.Resource;
|
|
import static cn.lihu.jh.framework.common.exception.util.ServiceExceptionUtil.exception;
|
import static cn.lihu.jh.module.ecg.enums.ErrorCodeConstants.*;
|
|
/**
|
* 装机拆机 Service 实现类
|
*
|
* @author 芋道源码
|
*/
|
@Service
|
@Validated
|
public class DevRentServiceImpl implements DevRentService {
|
|
@Resource
|
private DevRentMapper devRentMapper;
|
|
@Resource
|
private JobRecordMapper jobRecordMapper;
|
|
@Resource
|
DeviceMapper deviceMapper;
|
|
@Override
|
public CommonResult<Long> registerOperation(DevRentSaveReqVO createReqVO) {
|
Long rent_id = createDevRent(createReqVO);
|
return CommonResult.success(rent_id);
|
}
|
|
@Override
|
public CommonResult<Long> readyOperation(DevRentSaveReqVO createReqVO) {
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
String userNickname = SecurityFrameworkUtils.getLoginUserNickname();
|
|
// 标注设备 已领取
|
Integer ret = markDevRecieved(createReqVO.getDevId());
|
if (null == ret || 0 == ret) {
|
return CommonResult.error(DEVICE_NOT_EXISTS);
|
}
|
|
Long rent_id = createReqVO.getId();
|
if (null == rent_id) {
|
List<DevRentDO> devRentDOList = devRentMapper.selectByPatIdAndState(createReqVO.getPatId(), DevRentStateEnum.FREE.getState());
|
if (devRentDOList.size() == 0)
|
return CommonResult.error(DEV_INSTALL_NOT_APPOINTMENT);
|
else if (devRentDOList.size() != 1) {
|
return CommonResult.error(DEV_INSTALL_EXCEPTION);
|
}
|
|
rent_id = devRentDOList.getFirst().getId();
|
createReqVO.setId( rent_id );
|
createReqVO.setState( DevRentStateEnum.RECEIVED.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.RECEIVED.getState() );
|
jobRecordSaveReqVO.setRemark(createReqVO.getRemark());
|
jobRecordSaveReqVO.setSummary("");
|
|
JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class);
|
jobRecordMapper.insert(jobRecord);
|
} else {
|
// 撤销 放弃操作
|
createReqVO.setState( DevRentStateEnum.RECEIVED.getState() );
|
|
updateDevRent( createReqVO );
|
|
JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId);
|
if (null != jobRecordDO) {
|
jobRecordDO.setDevId(createReqVO.getDevId());
|
jobRecordDO.setJobType( DevRentStateEnum.RECEIVED.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> installOperation(DevRentSaveReqVO createReqVO) {
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
String userNickname = SecurityFrameworkUtils.getLoginUserNickname();
|
|
// 设置设备 使用中
|
Integer ret = markDevInUse(createReqVO.getDevId());
|
if (null == ret || 0 == ret) {
|
return CommonResult.error(DEVICE_NOT_EXISTS);
|
}
|
|
Long rent_id = createReqVO.getId();
|
if (null == rent_id) {
|
List<DevRentDO> devRentDOList = devRentMapper.selectByPatIdAndState(createReqVO.getPatId(), DevRentStateEnum.RECEIVED.getState());
|
if (devRentDOList.size() == 0)
|
return CommonResult.error(DEV_INSTALL_NOT_RECEIVED);
|
else if (devRentDOList.size() != 1) {
|
return CommonResult.error(DEV_INSTALL_EXCEPTION);
|
}
|
|
rent_id = devRentDOList.getFirst().getId();
|
createReqVO.setId( rent_id );
|
createReqVO.setState( DevRentStateEnum.INSTALLED.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.INSTALLED.getState() );
|
jobRecordSaveReqVO.setRemark(createReqVO.getRemark());
|
jobRecordSaveReqVO.setSummary("");
|
|
JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class);
|
jobRecordMapper.insert(jobRecord);
|
} 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);
|
}
|
}
|
return CommonResult.success(rent_id);
|
}
|
|
@Override
|
@Transactional
|
public Long dismantleOperation(DevRentSaveReqVO updateReqVO) {
|
updateReqVO.setState( DevRentStateEnum.DISMANTLED.getState() );
|
updateDevRent( updateReqVO );
|
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
String userNickname = SecurityFrameworkUtils.getLoginUserNickname();
|
|
// 设备恢复到空闲
|
resumeDevFree( updateReqVO.getDevId() );
|
|
JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(updateReqVO.getId(), 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( DevRentStateEnum.DISMANTLED.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.DISMANTLED.getState() );
|
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);
|
}
|
return updateReqVO.getId();
|
}
|
|
@Override
|
@Transactional
|
public CommonResult<Long> cancelOperation(DevCancelReqVO cancelReqVO) {
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
String userNickname = SecurityFrameworkUtils.getLoginUserNickname();
|
|
// 若从 装机 改为 取消装机，恢复设备状态
|
if (null != cancelReqVO.getDevId()) {
|
resumeDevFree( cancelReqVO.getDevId() );
|
}
|
|
DevRentSaveReqVO createReqVO = BeanUtils.toBean(cancelReqVO, DevRentSaveReqVO.class);
|
createReqVO.setDevId(null);
|
createReqVO.setState( DevRentStateEnum.CANCELLED.getState() );
|
|
Long rent_id = createReqVO.getId();
|
if (null == rent_id) {
|
|
List<DevRentDO> devRentDOList = devRentMapper.selectByPatIdAndState(createReqVO.getPatId(), DevRentStateEnum.FREE.getState());
|
if (devRentDOList.size() != 1)
|
return CommonResult.error(DEV_INSTALL_EXIST);
|
|
rent_id = devRentDOList.getFirst().getId();
|
createReqVO.setId( rent_id );
|
createReqVO.setState( DevRentStateEnum.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.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 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);
|
}
|
}
|
return CommonResult.success(rent_id);
|
}
|
|
@Override
|
@Transactional
|
public CommonResult<Long> loseOperation(DevRentSaveReqVO updateReqVO) {
|
// 设备遗失时, 标注遗失
|
markDevLost( updateReqVO.getDevId(), updateReqVO.getReturnTime().toLocalDate() );
|
|
updateReqVO.setState( DevRentStateEnum.LOST.getState() );
|
updateDevRent( updateReqVO );
|
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
String userNickname = SecurityFrameworkUtils.getLoginUserNickname();
|
|
JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(updateReqVO.getId(), 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( DevRentStateEnum.LOST.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.LOST.getState() );
|
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);
|
}
|
|
return CommonResult.success(updateReqVO.getId());
|
}
|
|
@Override
|
public Long createDevRent(DevRentSaveReqVO createReqVO) {
|
//
|
|
// 插入
|
DevRentDO devRent = BeanUtils.toBean(createReqVO, DevRentDO.class);
|
devRentMapper.insert(devRent);
|
// 返回
|
return devRent.getId();
|
}
|
|
@Override
|
public void updateDevRent(DevRentSaveReqVO updateReqVO) {
|
// 校验存在
|
validateDevRentExists(updateReqVO.getId());
|
// 更新
|
DevRentDO updateObj = BeanUtils.toBean(updateReqVO, DevRentDO.class);
|
devRentMapper.updateById(updateObj);
|
}
|
|
@Override
|
public void deleteDevRent(Long id) {
|
// 校验存在
|
validateDevRentExists(id);
|
// 删除
|
devRentMapper.deleteById(id);
|
}
|
|
private void validateDevRentExists(Long id) {
|
if (devRentMapper.selectById(id) == null) {
|
throw exception(DEV_INSTALL_NOT_EXISTS);
|
}
|
}
|
|
@Override
|
public DevRentDO getDevRent(Long id) {
|
return devRentMapper.selectById(id);
|
}
|
|
@Override
|
public PageResult<DevRentDO> getDevRentPage(DevRentPageReqVO pageReqVO) {
|
return devRentMapper.selectPage(pageReqVO);
|
}
|
|
@Override
|
public DevRentDO getDismantleRent(DevRentSearchReqVO searchReqVO) {
|
return devRentMapper.getDismantleRentByState(searchReqVO);
|
}
|
|
private Integer markDevRecieved(String devId) {
|
// 设备标注 已领取
|
DeviceDO deviveDO = deviceMapper.getDeviceByDevId(devId);
|
if (null != deviveDO) {
|
deviveDO.setState( DevStateEnum.RECEIVED.getState() );
|
return deviceMapper.updateById(deviveDO);
|
}
|
|
return 0;
|
}
|
|
private Integer markDevInUse(String devId) {
|
// 设备标注 在使用
|
DeviceDO deviveDO = deviceMapper.getDeviceByDevId(devId);
|
if (null != deviveDO) {
|
deviveDO.setState( DevStateEnum.INUSE.getState() );
|
return deviceMapper.updateById(deviveDO);
|
}
|
|
return 0;
|
}
|
|
private Integer markDevLost(String devId, LocalDate localDate) {
|
// 设备标注遗失
|
DeviceDO deviveDO = deviceMapper.getDeviceByDevId(devId);
|
if (null != deviveDO) {
|
deviveDO.setState( DevStateEnum.LOST.getState() );
|
deviveDO.setLoseDate( localDate ); // createReqVO.getReturnTime().toLocalDate()
|
return deviceMapper.updateById(deviveDO);
|
}
|
|
return 0;
|
}
|
|
private Integer resumeDevFree(String devId) {
|
// 设备标注遗失 恢复为空闲
|
DeviceDO deviveDO = deviceMapper.getDeviceByDevId( devId );
|
if (null != deviveDO) {
|
deviveDO.setState( DevStateEnum.FREE.getState() );
|
deviveDO.setLoseDate( null );
|
return deviceMapper.updateById(deviveDO);
|
}
|
|
return 0;
|
}
|
|
}
|
