gerrit.onap Code Review - sdc.git/blob

   1 package org.openecomp.core.tools.Commands;
   2
   3 import com.amdocs.zusammen.datatypes.SessionContext;
   4 import org.apache.commons.io.FileUtils;
   5 import org.openecomp.core.tools.Commands.exportdata.ElementHandler;
   6 import org.openecomp.core.tools.Commands.exportdata.ImportProperties;
   7 import org.openecomp.core.tools.Commands.exportdata.ItemHandler;
   8 import org.openecomp.core.tools.Commands.exportdata.VersionHandler;
   9 import org.openecomp.core.tools.util.ZipUtils;
  10 import org.openecomp.core.zusammen.impl.CassandraConnectionInitializer;
  11 import org.openecomp.sdc.logging.api.Logger;
  12 import org.openecomp.sdc.logging.api.LoggerFactory;
  13
  14 import java.io.File;
  15 import java.io.IOException;
  16 import java.nio.file.Files;
  17 import java.nio.file.Path;
  18 import java.nio.file.Paths;
  19 import java.time.LocalDateTime;
  20 import java.time.format.DateTimeFormatter;
  21
  22 import static java.nio.file.Files.createDirectories;
  23 public class ExportDataCommand {
  24     private static final Logger logger = LoggerFactory.getLogger(ExportDataCommand.class);
  25
  26     public static void exportData(SessionContext context, String filterItem) {
  27         try {
  28             ImportProperties.initParams();
  29             CassandraConnectionInitializer.setCassandraConnectionPropertiesToSystem();
  30             Path rootDir = Paths.get(ImportProperties.ROOT_DIRECTORY);
  31             initDir(rootDir);
  32             if (filterItem != null) {
  33                 filterItem = filterItem.replaceAll("\\r", "");
  34             }
  35             new ItemHandler().createItemsData(context, filterItem);
  36             new VersionHandler().loadVersions(filterItem);
  37             new ElementHandler().loadElements(filterItem);
  38             zipPath(rootDir,filterItem);
  39             FileUtils.forceDelete(rootDir.toFile());
  40         } catch (Exception ex) {
  41             logger.error(ex.getMessage(), ex);
  42             ex.printStackTrace();
  43         }
  44
  45     }
  46     private static void zipPath(Path rootDir,String filterItem ) throws Exception{
  47         LocalDateTime date = LocalDateTime.now();
  48         DateTimeFormatter formatter = DateTimeFormatter.ISO_LOCAL_DATE_TIME;
  49         String dateStr = date.format(formatter);
  50         String zipFile = System.getProperty("user.home")+ File.separatorChar+"onboarding_import"+ dateStr + ".zip";
  51         ZipUtils.createZip(zipFile, rootDir,filterItem);
  52     }
  53
  54
  55     public static void initDir(Path rootDir ) throws IOException{
  56         if (Files.exists(rootDir)) {
  57             FileUtils.forceDelete(rootDir.toFile());
  58         }
  59         createDirectories(rootDir);
  60     }
  61
  62 }