|
package org.springblade.mdm.program.service;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import lombok.AllArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.flowable.engine.HistoryService;
|
import org.flowable.engine.ProcessEngine;
|
import org.springblade.core.log.exception.ServiceException;
|
import org.springblade.core.mp.base.BizServiceImpl;
|
import org.springblade.core.mp.support.Condition;
|
import org.springblade.core.oss.OssTemplate;
|
import org.springblade.core.oss.model.BladeFile;
|
import org.springblade.core.tool.utils.FileUtil;
|
import org.springblade.mdm.flow.entity.FlowProgramFile;
|
import org.springblade.mdm.flow.service.FlowBusinessService;
|
import org.springblade.mdm.program.entity.DncBackFile;
|
import org.springblade.mdm.program.entity.NcNode;
|
import org.springblade.mdm.program.entity.NcNodeHis;
|
import org.springblade.mdm.program.mapper.DncBackFileMapper;
|
import org.springblade.mdm.program.vo.DncBackFileQueryVO;
|
import org.springblade.mdm.program.vo.DncBackFileVO;
|
import org.springblade.mdm.program.vo.DncSendBackFile;
|
import org.springblade.mdm.utils.FileContentUtil;
|
import org.springblade.mdm.utils.ZipTextFileContentUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.io.ByteArrayInputStream;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.nio.file.Files;
|
import java.nio.file.Path;
|
import java.nio.file.StandardOpenOption;
|
import java.util.ArrayList;
|
import java.util.Enumeration;
|
import java.util.List;
|
import java.util.Optional;
|
import java.util.zip.ZipEntry;
|
|
/**
|
* DNC回传文件处理服务
|
*
|
* @author yangys
|
*/
|
@Slf4j
|
@Service
|
@AllArgsConstructor
|
public class DncBackFileService extends BizServiceImpl<DncBackFileMapper, DncBackFile> {
|
private final NcNodeService ncNodeService;
|
private final NcNodeHisService nodeHisService;
|
private final OssTemplate ossTemplate;
|
private final HistoryService historyService;
|
private final FlowBusinessService businessService;
|
public IPage<DncBackFileVO> pageQuery(DncBackFileQueryVO query) {
|
IPage<DncBackFileVO> page= this.baseMapper.pageQuery(Condition.getPage(query),query);
|
page.getRecords().forEach(item->{
|
item.setProcessExecuted(isProcessExecuted(item.getProcessInstanceId()));
|
});
|
return page;
|
}
|
|
/**
|
* 检查流程实例是否被执行过（通过历史记录）
|
*/
|
public boolean isProcessExecuted(String processInstanceId) {
|
if(StringUtils.isBlank(processInstanceId)){
|
//空流程实例id，说明节点已经没有了
|
return true;
|
}
|
// 检查是否有历史任务记录
|
long taskCount = historyService.createHistoricTaskInstanceQuery()
|
.processInstanceId(processInstanceId)
|
.count();
|
|
//多于一个任务被处理，说明至少流转到第二个节点了
|
return taskCount > 1;
|
}
|
|
/**
|
* 取消流程
|
* @param id 回传记录id
|
*/
|
@Transactional
|
public void cancelProcess(long id) {
|
DncBackFile backFIle = this.getById(id);
|
NcNode packageNode = ncNodeService.getById(backFIle.getNcNodeId());
|
//多于一个任务被处理，说明至少流转到第二个节点了
|
if(isProcessExecuted(packageNode.getProcessInstanceId())){
|
throw new ServiceException("流程已经开始处理，不可取消");
|
}
|
businessService.deleteProcessInstance(packageNode.getProcessInstanceId());
|
this.baseMapper.deleteById(id);
|
}
|
|
/**
|
* 获取回传记录的文件列表
|
* @param id 回传记录id
|
* @return
|
*/
|
public List<DncSendBackFile> filesById(long id) throws IOException {
|
List<DncSendBackFile> fileList = new ArrayList<>();
|
|
DncBackFile backFIle = this.getById(id);
|
|
InputStream inputStream = this.ossTemplate.statFileStream(backFIle.getOssName());
|
Path tempZipFile = createTempFile(inputStream);
|
NcNodeHis packageNode = nodeHisService.getById(backFIle.getNcNodeId());
|
//String targetFolder = packageNode.getName()+"-"+packageNode.getProcessEdition()+"/";
|
String targetFolder = packageNode.getName()+"/";
|
ZipEntry entry;
|
try (java.util.zip.ZipFile zipFile = new java.util.zip.ZipFile(tempZipFile.toFile())) {
|
Enumeration<? extends ZipEntry> entries = zipFile.entries();
|
while(entries.hasMoreElements()) {
|
entry = entries.nextElement();
|
|
if(!entry.isDirectory() && entry.getName().startsWith(targetFolder)){
|
//这里面之前时入库的文件
|
DncSendBackFile file = new DncSendBackFile();
|
file.setName(entry.getName().substring(targetFolder.length()));
|
file.setEntryName(entry.getName());
|
|
fileList.add(file);
|
}
|
}
|
}
|
return fileList;
|
}
|
|
|
Path createTempFile(InputStream inputStream) throws IOException {
|
byte[] zipData = FileUtil.copyToByteArray(inputStream);
|
Path tempFile = Files.createTempFile("tempzip"+System.currentTimeMillis(), ".zip");
|
// 写入字节数据到临时文件
|
Files.write(tempFile, zipData, StandardOpenOption.WRITE);
|
|
return tempFile;
|
}
|
/**
|
* 从文件夹名解析出程序包名和和工序版次
|
* @param folderName 文件夹名
|
* @return 结构数据
|
*/
|
PackageAndProcessEdition parseProgramPackageFromFolderName(String folderName){
|
int index = StringUtils.lastIndexOf(folderName,'-');
|
String processEditon = "";
|
String temp;
|
String packageName = "";
|
if(index != -1){
|
processEditon = folderName.substring(index+1);
|
packageName = folderName.substring(0,index);
|
}
|
|
PackageAndProcessEdition result = new PackageAndProcessEdition();;
|
result.setProgramPackageName(packageName);
|
result.setProcessEdition(processEditon);
|
return result;
|
}
|
|
/**
|
* 获取历史记录中的文件内容
|
* @param id 回传历史记录id
|
* @param entryName 压缩包文件路径
|
* @return
|
*/
|
public String getEntryFileContent(long id, String entryName) throws IOException {
|
DncBackFile backFIle = this.getById(id);
|
|
return ZipTextFileContentUtil.getTextContent(this.ossTemplate.statFileStream(backFIle.getOssName()),entryName);
|
}
|
}
|
