package fr.ifremer.quadrige3.synchro.intercept.referential;
   
   /*-
    * #%L
    * Quadrige3 Core :: Quadrige3 Synchro Core
    * $Id:$
    * $HeadURL:$
    * %%
    * Copyright (C) 2017 Ifremer
   * %%
   * This program is free software: you can redistribute it and/or modify
   * it under the terms of the GNU Affero 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 Affero General Public License
   * along with this program.  If not, see <http://www.gnu.org/licenses/>.
   * #L%
   */
  
  import com.google.common.eventbus.Subscribe;
  import fr.ifremer.common.synchro.meta.event.CreateQueryEvent;
  import fr.ifremer.common.synchro.query.SynchroQueryBuilder;
  import fr.ifremer.common.synchro.query.SynchroQueryOperator;
  import fr.ifremer.quadrige3.core.config.QuadrigeConfiguration;
  import fr.ifremer.quadrige3.core.dao.technical.Beans;
  import fr.ifremer.quadrige3.core.dao.technical.Daos;
  import fr.ifremer.quadrige3.synchro.meta.DatabaseColumns;
  import fr.ifremer.quadrige3.synchro.meta.referential.ReferentialSynchroTables;
  import fr.ifremer.quadrige3.synchro.service.SynchroDirection;
  import org.apache.commons.lang3.StringUtils;
  
  import java.util.ArrayList;
  import java.util.List;
  
  /**
   * Interceptor use to limit imported transcribing items, filter on transcribing item type
   */
  public class TranscribingItemInterceptor extends AbstractReferentialInterceptor {
  
      /**
       * <p>
       * Constructor for TranscribingItemInterceptor.
       * </p>
       */
      public TranscribingItemInterceptor() {
          super(ReferentialSynchroTables.TRANSCRIBING_ITEM.name(),
              SynchroDirection.IMPORT_SERVER2TEMP);
      }
  
      /**
       * <p>
       * handleCreateQuery.
       * </p>
       *
       * @param e a {@link fr.ifremer.common.synchro.meta.event.CreateQueryEvent} object.
       */
      @Subscribe
      public void handleCreateQuery(CreateQueryEvent e) {
  
          String transcribingTypeLbIncludes = QuadrigeConfiguration.getInstance().getImportTranscribingItemTypeLbIncludes();
          List<String> protectedLabels = new ArrayList<>();
          List<String> unprotectedLabels = new ArrayList<>();
          if (StringUtils.isNotBlank(transcribingTypeLbIncludes)) {
  
              // get all labels and find (un)protected labels
              List<String> labels = Beans.split(transcribingTypeLbIncludes, ",");
              labels.forEach(label -> {
                  if (label.contains("%"))
                      unprotectedLabels.add(label);
                  else
                      protectedLabels.add(label);
              });
  
          }
  
          switch (e.queryName) {
              case count:
              case countFromUpdateDate:
              case select:
              case selectFromUpdateDate:
  
                  // Add restriction on transcribing item type
                  if (!protectedLabels.isEmpty() || !unprotectedLabels.isEmpty()) {
                      SynchroQueryBuilder queryBuilder = SynchroQueryBuilder.newBuilder(e.sql)
                          .addJoin(String.format("INNER JOIN %s tit ON t.%s = tit.%s",
                              ReferentialSynchroTables.TRANSCRIBING_ITEM_TYPE,
                              DatabaseColumns.TRANSC_ITEM_TYPE_ID,
                              DatabaseColumns.TRANSC_ITEM_TYPE_ID));
                      StringBuilder whereClauseBuilder = new StringBuilder("1=2"); // starting with a disjunction
                      if (!protectedLabels.isEmpty()) {
                          whereClauseBuilder.append(
                              String.format(" OR tit.%s IN (%s)", DatabaseColumns.TRANSC_ITEM_TYPE_LB, Daos.getInStatementFromStringCollection(protectedLabels))
                          );
                     }
                     if (!unprotectedLabels.isEmpty()) {
                         unprotectedLabels.forEach(s -> whereClauseBuilder.append(
                                 String.format(" OR tit.%s LIKE '%s'", DatabaseColumns.TRANSC_ITEM_TYPE_LB, s)
                             )
                         );
                     }
                     queryBuilder.addWhere(SynchroQueryOperator.AND, String.format("(%s)", whereClauseBuilder));
                     e.sql = queryBuilder.build();
                 }
                 break;
 
             case selectMaxUpdateDate:
 
                 // Add specific query to determine the max update date.
                 // It return the min update date against the max update date of each type, or 1970-01-01 if an item has not
                 // been found
                 if (!protectedLabels.isEmpty() || !unprotectedLabels.isEmpty()) {
 
                     // Add restriction on included ids
                     StringBuilder query = new StringBuilder();
                     query.append("SELECT MIN(COALESCE(UPDATE_DT, TO_TIMESTAMP('1970-01-01', 'YYYY-MM-DD'))) FROM (");
                     query.append(" SELECT TIT.TRANSC_ITEM_TYPE_ID, MAX(TI.UPDATE_DT) AS UPDATE_DT FROM TRANSCRIBING_ITEM_TYPE TIT");
                     query.append(" LEFT OUTER JOIN TRANSCRIBING_ITEM TI ON TI.TRANSC_ITEM_TYPE_ID=TIT.TRANSC_ITEM_TYPE_ID");
                     query.append(" WHERE 1=2");
                     if (!protectedLabels.isEmpty()) {
                         query.append(" OR TIT.TRANSC_ITEM_TYPE_LB IN (").append(Daos.getInStatementFromStringCollection(protectedLabels)).append(")");
                     }
                     if (!unprotectedLabels.isEmpty()) {
                         unprotectedLabels.forEach(s -> query.append(" OR TIT.TRANSC_ITEM_TYPE_LB LIKE '").append(s).append("'"));
                     }
                     query.append(" GROUP BY TIT.TRANSC_ITEM_TYPE_ID");
                     query.append(")");
                     e.sql = query.toString();
                 }
                 break;
 
             default:
                 break;
         }
     }
 }