| | |
| | | bladeRedis.setEx(getFileKey(),bfile.getName(), Duration.ofHours(2)); |
| | | |
| | | try(InputStream zipFileInputStream = ossTemplate.statFileStream(bfile.getName());) { |
| | | //InputStream zipFileInputStream = file.getInputStream();//test |
| | | list = parseProgramListFromZip(zipFileInputStream); |
| | | } |
| | | } catch (IOException e) { |
| | |
| | | String zipFileName = bladeRedis.get(filekey); |
| | | log.info("filekey={},文件名={}",filekey,zipFileName); |
| | | |
| | | //Map<Long,List<NcNode>> programPackageSubMap = new HashMap<>(); |
| | | |
| | | Map<Long,List<FlowProgramFile>> pkgIdFileMap = dealWithBackFile(zipFileName,acceptIdList); |
| | | |
| | | ///List<NcNode> newProgramPackageList = updateNodeDataByDNCBackData(pkgFileName,idList,programPackageSubMap); |
| | | //updateNodeDataByDNCBackData(pkgFileName,idList,programPackageSubMap); |
| | | /* |
| | | log.info("需要启动固化流程的程序包名数量:{}",newProgramPackageList.size()); |
| | | for(NcNode pkgNode :newProgramPackageList){ |
| | | exchange = new NcProgramExchange(); |
| | | exchange.setName(pkgNode.getName()); |
| | | exchange.setExchangeType(2);//回传 |
| | | exchange.setNcNodeId(pkgNode.getId()); |
| | | |
| | | this.save(exchange); |
| | | }*/ |
| | | //bladeRedis.del(filekey); |
| | | //this.ossTemplate.removeFile(zipFileName); |
| | | //log.info("删除oss文件:{}",zipFileName); |
| | | |
| | | //cureFlowService.startCure(newProgramPackageList,programPackageSubMap); |
| | | cureFlowService.startCureNew(pkgIdFileMap); |
| | | |
| | | } |