| | |
|---|
| | | List<DncSendBackData> parseDncZipFromByteArray(InputStream inputStream) throws IOException { |
|---|
| | | List<DncSendBackData> list = new ArrayList<>(); |
|---|
| | | Path tempZipFile = createTempFile(inputStream); |
|---|
| | | //Map<String,String> fileMd5Map = new HashMap<>(); |
|---|
| | | Map<String,DncSendBackData> fileDataMap = new HashMap<>(); |
|---|
| | | |
|---|
| | | try (ZipFile zipFile = new ZipFile(tempZipFile.toFile())) { |
|---|
| | | |
|---|
| | | ZipEntry entry; |
|---|
| | |
|---|
| | | List<Long> idList = Func.toLongList(ids); |
|---|
| | | // |
|---|
| | | NcProgramExchange exchange; |
|---|
| | | String pkgFileName = bladeRedis.get(getFileKey()); |
|---|
| | | String filekey = getFileKey(); |
|---|
| | | String pkgFileName = bladeRedis.get(filekey); |
|---|
| | | log.info("filekey={},文件名={}",filekey,pkgFileName); |
|---|
| | | |
|---|
| | | Map<Long,List<NcNode>> programPackageSubMap = new HashMap<>(); |
|---|
| | | List<NcNode> newProgramPckageList = updateNodeDataByDNCBackData(pkgFileName,idList,programPackageSubMap); |
|---|
| | | |
|---|
| | | log.info("需要启动固化流程的程序包名数量:{}",newProgramPckageList.size()); |
|---|
| | | for(NcNode pkgNode :newProgramPckageList){ |
|---|
| | | exchange = new NcProgramExchange(); |
|---|
| | | exchange.setName(pkgNode.getName()); |
|---|
| | |
|---|
| | | |
|---|
| | | this.save(exchange); |
|---|
| | | } |
|---|
| | | bladeRedis.del(filekey); |
|---|
| | | this.ossTemplate.removeFile(pkgFileName); |
|---|
| | | log.info("删除oss文件:{}",pkgFileName); |
|---|
| | | |
|---|
| | | cureFlowService.startCure(newProgramPckageList,programPackageSubMap); |
|---|
| | | } |
|---|
| | |
|---|
| | | List<String> dirList = entryNameList.stream().filter(s -> s.endsWith("/")).toList(); |
|---|
| | | for(String dir : dirList){ |
|---|
| | | String programPackageName = StringUtils.removeEnd(dir,"/"); |
|---|
| | | |
|---|
| | | NcNode oriProgramPkg = this.ncNodeService.getLastEditionProgramPackage(programPackageName); |
|---|
| | | if(oriProgramPkg == null){ |
|---|
| | | log.warn("未发现匹配的程序包名{}",programPackageName); |
|---|
| | |
|---|
| | | |
|---|
| | | if(!programPackageIdList.contains(oriProgramPkg.getId())){ |
|---|
| | | //不在勾选的范围内 |
|---|
| | | log.info("{}不在勾选范围内",programPackageName); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | NcNode newProgramPkg = new NcNode(); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | return newProgramPackageNodeList; |
|---|
| | | } |
|---|
| | | |
|---|
