package cn.iocoder.yudao.module.mdm.service.item;
|
|
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
|
import cn.iocoder.yudao.module.mdm.controller.admin.item.vo.MdmItemTechnicalFileCreateReqVO;
|
import cn.iocoder.yudao.module.mdm.controller.admin.item.vo.MdmItemTechnicalFileRespVO;
|
import cn.iocoder.yudao.module.mdm.dal.dataobject.item.MdmItemTechnicalFileDO;
|
import cn.iocoder.yudao.module.mdm.dal.mysql.item.MdmItemTechnicalFileMapper;
|
import cn.iocoder.yudao.module.system.api.storage.StorageAttachmentApi;
|
import cn.iocoder.yudao.module.system.api.storage.dto.StorageBlobRespDTO;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.Collections;
|
import java.util.List;
|
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
import static cn.iocoder.yudao.module.mdm.enums.ErrorCodeConstants.MDM_ITEM_NOT_EXISTS;
|
|
@Service
|
public class MdmItemTechnicalFileServiceImpl implements MdmItemTechnicalFileService {
|
|
private static final String RECORD_TYPE = "mdm_item_technical_file";
|
|
private final MdmItemTechnicalFileMapper mapper;
|
private final MdmItemService itemService;
|
private final StorageAttachmentApi storageAttachmentApi;
|
|
public MdmItemTechnicalFileServiceImpl(MdmItemTechnicalFileMapper mapper,
|
MdmItemService itemService,
|
StorageAttachmentApi storageAttachmentApi) {
|
this.mapper = mapper;
|
this.itemService = itemService;
|
this.storageAttachmentApi = storageAttachmentApi;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Long createTechnicalFile(MdmItemTechnicalFileCreateReqVO reqVO) {
|
if (itemService.getItem(reqVO.getItemId()) == null) {
|
throw exception(MDM_ITEM_NOT_EXISTS);
|
}
|
int version = mapper.selectMaxVersionNo(reqVO.getItemId()) + 1;
|
// 记录 ID 必须与附件关系记录 ID 一致，因此先插入版本记录，再绑定附件。
|
MdmItemTechnicalFileDO file = new MdmItemTechnicalFileDO();
|
file.setItemId(reqVO.getItemId());
|
file.setStorageBlobId(reqVO.getBlobId());
|
file.setVersionNo(version);
|
mapper.insert(file);
|
storageAttachmentApi.bindAttachments("file", RECORD_TYPE, file.getId(),
|
Collections.singletonList(reqVO.getBlobId()));
|
return file.getId();
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void deleteTechnicalFile(Long itemId, Long id) {
|
MdmItemTechnicalFileDO file = mapper.selectById(id);
|
if (file == null || !java.util.Objects.equals(file.getItemId(), itemId)) {
|
throw new cn.iocoder.yudao.framework.common.exception.ServiceException(400, "技术文件不存在或不属于该物料");
|
}
|
// 只移除物料的当前文件记录。保留附件及文件本体，供已有工单快照使用。
|
mapper.deleteById(id);
|
}
|
|
@Override
|
public List<MdmItemTechnicalFileRespVO> getTechnicalFileList(Long itemId) {
|
return mapper.selectListByItemId(itemId).stream().map(file -> {
|
MdmItemTechnicalFileRespVO resp = BeanUtils.toBean(file, MdmItemTechnicalFileRespVO.class);
|
resp.setBlobId(file.getStorageBlobId());
|
List<StorageBlobRespDTO> blobs = storageAttachmentApi.listAttachments(RECORD_TYPE, file.getId());
|
if (blobs != null && !blobs.isEmpty()) {
|
StorageBlobRespDTO blob = blobs.get(0);
|
resp.setFileName(blob.getName());
|
resp.setPreviewURL(blob.getPreviewURL());
|
resp.setDownloadURL(blob.getDownloadURL());
|
}
|
return resp;
|
}).toList();
|
}
|
}
|
