package fr.ifremer.quadrige2.synchro.intercept.referential;
   
   /*-
    * #%L
    * Quadrige2 Core :: Quadrige2 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.base.Joiner;
  import com.google.common.base.Splitter;
  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.quadrige2.core.config.Quadrige2Configuration;
  import fr.ifremer.quadrige2.synchro.meta.DatabaseColumns;
  import fr.ifremer.quadrige2.synchro.meta.referential.ReferentialSynchroTables;
  import fr.ifremer.quadrige2.synchro.service.SynchroDirection;
  import org.apache.commons.lang3.StringUtils;
  
  /**
   * 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 = Quadrige2Configuration.getInstance().getImportTranscribingItemTypeLbIncludes();
          StringBuilder protectedLabels = new StringBuilder();
          if (StringUtils.isNotBlank(transcribingTypeLbIncludes)) {
              protectedLabels.append('\'');
              Joiner.on("','").appendTo(protectedLabels, Splitter.on(',').split(transcribingTypeLbIncludes));
              protectedLabels.append('\'');
          }
  
          switch (e.queryName) {
              case count:
              case countFromUpdateDate:
              case select:
              case selectFromUpdateDate:
  
                  // Add restriction on transcribing item type
                  if (StringUtils.isNotBlank(protectedLabels.toString())) {
  
                      e.sql = 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))
                              .addWhere(SynchroQueryOperator.AND, String.format("tit.%s IN (%s)",
                                      DatabaseColumns.TRANSC_ITEM_TYPE_LB,
                                      protectedLabels.toString()))
                              .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 (StringUtils.isNotBlank(protectedLabels.toString())) {
  
                      // Add restriction on included ids
                     e.sql = "SELECT MIN(COALESCE(UPDATE_DT, TO_TIMESTAMP('1970-01-01', 'YYYY-MM-DD'))) FROM (\n" +
                             " SELECT TIT.TRANSC_ITEM_TYPE_ID, MAX(TI.UPDATE_DT) AS UPDATE_DT FROM TRANSCRIBING_ITEM_TYPE TIT\n" +
                             " LEFT OUTER JOIN TRANSCRIBING_ITEM TI ON TI.TRANSC_ITEM_TYPE_ID=TIT.TRANSC_ITEM_TYPE_ID\n" +
                             " WHERE TIT.TRANSC_ITEM_TYPE_LB IN (" + protectedLabels.toString() + ")\n" +
                             " GROUP BY TIT.TRANSC_ITEM_TYPE_ID\n" +
                             ")";
                 }
                 break;
 
             default:
                 break;
         }
     }
 }