package com.estate.expert.admin.service.impl;
|
|
import com.estate.expert.admin.domain.business.device.DeviceType;
|
import com.estate.expert.admin.domain.business.device.usage.DeviceUsage;
|
import com.estate.expert.admin.domain.business.device.usage.DeviceUsageDto;
|
import com.estate.expert.admin.domain.business.device.usage.DeviceUsageRepository;
|
import com.estate.expert.admin.domain.common.request.PageReq;
|
import com.estate.expert.admin.domain.common.response.PageResp;
|
import com.estate.expert.admin.domain.project.ProjectRepository;
|
import com.estate.expert.admin.domain.user.User;
|
import com.estate.expert.admin.enums.BizResultCode;
|
import com.estate.expert.admin.service.DeviceService;
|
import com.estate.expert.admin.service.DeviceUsageService;
|
import com.estate.expert.admin.service.common.CrudServiceBaseImpl;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.util.List;
|
import java.util.UUID;
|
|
/**
|
* 设备使用服务实现
|
*/
|
@Service
|
@Slf4j
|
public class DeviceUsageServiceImpl extends CrudServiceBaseImpl<DeviceUsage, DeviceUsageDto> implements DeviceUsageService {
|
|
@Resource
|
private DeviceUsageRepository repository;
|
|
@Resource
|
private DeviceService deviceService;
|
|
@Resource
|
private ProjectRepository projectRepository;
|
|
@Override
|
public PageResp<DeviceUsageDto> listUsages(Integer projectId, DeviceType deviceType, PageReq pageReq) {
|
var page = repository.list(projectId, deviceType, pageReq.toPageRequest());
|
return PageResp.of(page, toDto(page.getContent()));
|
}
|
|
@Override
|
public PageResp<DeviceUsageDto> history(Integer projectId, DeviceType deviceType, PageReq pageReq) {
|
var page = repository.history(projectId, deviceType, pageReq.toPageRequest());
|
return PageResp.of(page, toDto(page.getContent()));
|
}
|
|
@Override
|
public List<DeviceUsage> listUsages(Integer projectId, DeviceType deviceType) {
|
return repository.list(projectId, deviceType);
|
}
|
|
@Override
|
public void removeById(List<Integer> ids) {
|
var usages = repository.findAllById(ids);
|
usages.forEach(deviceUsage -> {
|
deviceUsage.setDisabled(true);
|
deviceUsage.setDeleted(true);
|
});
|
repository.saveAll(usages);
|
}
|
|
@Transactional
|
@Override
|
public DeviceUsage add(User user, DeviceUsage usage) {
|
var device = deviceService.get(usage.getDevice().getId());
|
BizResultCode.DEVICE_NOT_FOUND.check(device == null);
|
BizResultCode.DEVICE_IS_BUSY.check(device.isBusy());
|
|
var project = projectRepository.findById(usage.getProject().getId());
|
BizResultCode.BIZ_PROJECT_NOT_EXIST.check(project.isEmpty());
|
|
// 占用设备，防止其他项目使用
|
device.setBusy(true);
|
deviceService.save(device);
|
|
usage.setName(UUID.randomUUID().toString());
|
return super.add(user, usage);
|
}
|
|
@Override
|
protected void beforeDelete(DeviceUsage entity) {
|
var device = deviceService.get(entity.getDevice().getId());
|
BizResultCode.DEVICE_NOT_FOUND.check(device == null);
|
|
// 释放设备，可以被其他项目使用
|
device.setBusy(false);
|
deviceService.save(device);
|
}
|
}
|
