/** * BladeX Commercial License Agreement * Copyright (c) 2018-2099, https://bladex.cn. All rights reserved. *

* Use of this software is governed by the Commercial License Agreement * obtained after purchasing a license from BladeX. *

* 1. This software is for development use only under a valid license * from BladeX. *

* 2. Redistribution of this software's source code to any third party * without a commercial license is strictly prohibited. *

* 3. Licensees may copyright their own code but cannot use segments * from this software for such purposes. Copyright of this software * remains with BladeX. *

* Using this software signifies agreement to this License, and the software * must not be used for illegal purposes. *

* THIS SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY. The author is * not liable for any claims arising from secondary or illegal development. *

* Author: Chill Zhuang (bladejava@qq.com) */ package org.springblade.mdm.program.service; import com.fasterxml.jackson.databind.ObjectMapper; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.commons.compress.archivers.zip.ZipArchiveEntry; import org.apache.commons.compress.archivers.zip.ZipArchiveInputStream; import org.apache.commons.compress.archivers.zip.ZipFile; import org.apache.commons.compress.utils.IOUtils; import org.apache.commons.compress.utils.SeekableInMemoryByteChannel; import org.flowable.engine.*; import org.springblade.core.tool.utils.DateUtil; import org.springblade.core.tool.utils.FileUtil; import org.springblade.core.tool.utils.Func; import org.springblade.mdm.flow.service.CureFlowService; import org.springblade.mdm.program.entity.NcProgram; import org.springblade.mdm.program.entity.NcProgramExchange; import org.springblade.mdm.program.mapper.NcProgramExchangeMapper; import org.springblade.mdm.program.vo.DncSendBackData; import org.springframework.stereotype.Service; import org.springframework.web.multipart.MultipartFile; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.IOException; import java.io.InputStream; import java.util.ArrayList; import java.util.Enumeration; import java.util.List; /** * 工作流服务实现类 * * @author Chill */ @Slf4j @Service @AllArgsConstructor public class DncSendBackService { //private final RepositoryService repositoryService; //private final RuntimeService runtimeService; //private final HistoryService historyService; //private final ProcessEngine processEngine; private final NcProgramService ncProgramService; private final CureFlowService cureFlowService; private final NcProgramExchangeMapper ncProgramExchangeMapper; /** * 入库回传文件,并启动固化流程 * @param ids * @return */ public void dncFileAccept(String ids) { List idList = Func.toLongList(ids); NcProgramExchange exchange; NcProgram program; for (Long id : idList) { exchange = ncProgramExchangeMapper.selectById(id); exchange.setStatus(2);//已入库状态 program = ncProgramService.getLastNcProgram(exchange.getName()); //如果是已经固化的则不需要启动流程 //启动固化流程 if(program.getIsCured() !=1) {//未固化的程序,启动固化流程 cureFlowService.start(program.getId()); } } } }