package fr.ifremer.tutti.service.genericformat.importactions;
   
   /*
    * #%L
    * Tutti :: Service
    * $Id:$
    * $HeadURL:$
    * %%
    * Copyright (C) 2012 - 2015 Ifremer
   * %%
   * This program is free software: you can redistribute it and/or modify
   * it under the terms of the GNU General Public License as
   * published by the Free Software Foundation, either version 3 of the
   * License, or (at your option) any later version.
   * 
   * This program is distributed in the hope that it will be useful,
   * but WITHOUT ANY WARRANTY; without even the implied warranty of
   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   * GNU General Public License for more details.
   * 
   * You should have received a copy of the GNU General Public
   * License along with this program.  If not, see
   * <http://www.gnu.org/licenses/gpl-3.0.html>.
   * #L%
   */
  
  import fr.ifremer.tutti.persistence.entities.referential.Species;
  import fr.ifremer.tutti.service.genericformat.GenericFormatContextSupport;
  import fr.ifremer.tutti.service.genericformat.GenericFormatReferentialSpeciesImportResult;
  import fr.ifremer.tutti.service.genericformat.GenericformatImportPersistenceHelper;
  import fr.ifremer.tutti.service.referential.ReferentialImportRequest;
  import fr.ifremer.tutti.service.referential.ReferentialImportResult;
  import fr.ifremer.tutti.service.referential.consumer.CsvConsumerForTemporarySpecies;
  import fr.ifremer.tutti.service.referential.csv.SpeciesRow;
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  import org.nuiton.csv.ImportRow;
  import org.nuiton.csv.ImportRuntimeException;
  import org.nuiton.jaxx.application.ApplicationTechnicalException;
  
  import java.io.IOException;
  import java.util.Map;
  import java.util.TreeMap;
  
  import static org.nuiton.i18n.I18n.t;
  
  /**
   * Created on 3/3/15.
   *
   * @author Tony Chemit - chemit@codelutin.com
   * @since 3.14
   */
  public class ImportReferentialSpeciesAction extends ImportActionSupport {
  
      /** Logger. */
      private static final Log log = LogFactory.getLog(ImportReferentialSpeciesAction.class);
  
      private final GenericformatImportPersistenceHelper persistenceHelper;
  
      public ImportReferentialSpeciesAction(GenericFormatContextSupport importContext, GenericformatImportPersistenceHelper persistenceHelper) {
          super(importContext);
          this.persistenceHelper = persistenceHelper;
      }
  
      @Override
      protected boolean canExecute() {
          return importContext.getReferentialTemporarySpeciesFileResult().isFound();
      }
  
      @Override
      protected void skipExecute() {
  
          if (log.isInfoEnabled()) {
              log.info("Skip import temporary species (no file found).");
          }
          importContext.increments(t("tutti.service.genericFormat.skip.import.temporarySpecies"));
  
      }
  
      @Override
      protected void doExecute() {
  
          importContext.increments(t("tutti.service.genericFormat.import.temporarySpecies"));
  
          if (log.isInfoEnabled()) {
              log.info("Import temporary species.");
          }
  
          ReferentialImportRequest<Species, Integer> referentialImportRequest = persistenceHelper.createSpeciesImportRequest();
  
          Map<Integer, Integer> referenceTaxonIdById = new TreeMap<>();
  
          GenericFormatReferentialSpeciesImportResult importFileResult = importContext.getReferentialTemporarySpeciesFileResult();
          try (CsvConsumerForTemporarySpecies consumer = importContext.loadTemporarySpecies(false)) {
              for (ImportRow<SpeciesRow> row : consumer) {
                  consumer.checkRowForGenericFormatImport(row, referentialImportRequest);
                  referenceTaxonIdById.put(row.getBean().getIdAsInt(), row.getBean().getReferenceTaxonId());
              }
  
             importFileResult.flushErrors(consumer);
 
         } catch (IOException e) {
             throw new ApplicationTechnicalException("Could not close species.csv file", e);
         } catch (ImportRuntimeException e) {
 
             importFileResult.addGlobalError(e.getMessage());
 
         }
 
         if (importFileResult.isValid()) {
 
             ReferentialImportResult<Species> referentialImportResult = persistenceHelper.importSpecies(referentialImportRequest);
             importFileResult.flushResult(referentialImportRequest, referentialImportResult);
 
             // On ajoute aussi le dictionnaire de taxons référents obsolètes
             importFileResult.flushObsoleteReferenceTaxonIds(persistenceHelper.getAllObsoleteReferentTaxons());
 
             importFileResult.flushReferenceTaxonIds(referenceTaxonIdById);
 
             if (log.isInfoEnabled()) {
                 log.info("Temporary species import result: " + importFileResult.getReport());
             }
 
         } else {
 
             if (log.isWarnEnabled()) {
                 log.warn("Do not import temporary species (the incoming file is not valid)");
             }
 
         }
 
 
     }
 }