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.base.Joiner;
  import com.google.common.collect.Sets;
  import com.google.common.eventbus.Subscribe;
  import fr.ifremer.common.synchro.intercept.SynchroInterceptorBase;
  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.dao.ObjectTypes;
  import fr.ifremer.quadrige3.synchro.meta.DatabaseColumns;
  import fr.ifremer.quadrige3.synchro.meta.referential.ReferentialSynchroTables;
  import fr.ifremer.quadrige3.synchro.meta.system.RuleSynchroTables;
  import fr.ifremer.quadrige3.synchro.service.referential.ReferentialSynchroDatabaseConfiguration;
  import org.apache.commons.collections4.CollectionUtils;
  
  import java.util.LinkedHashSet;
  import java.util.Set;
  
  /**
   * Import DELETED_ITEM_HISTORY rows, limited to referential tables
   * 
   * @author Benoit Lavenier <benoit.lavenier@e-is.pro>
   * @since 1.0
   */
  public class DeletedItemHistoryInterceptor extends AbstractReferentialInterceptor {
  
  	private String whereClauseOnTableIncludes = null;
  
  	/**
  	 * <p>
  	 * Constructor for DeletedItemHistoryInterceptor.
  	 * </p>
  	 */
  	public DeletedItemHistoryInterceptor() {
  		super(ReferentialSynchroTables.DELETED_ITEM_HISTORY.name());
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	protected void init(ReferentialSynchroDatabaseConfiguration config) {
  		super.init(config);
  		whereClauseOnTableIncludes = createWhereClauseOnTableIncludes();
  
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	public SynchroInterceptorBase clone() {
  		DeletedItemHistoryInterceptor newBean = (DeletedItemHistoryInterceptor) super.clone();
  		newBean.whereClauseOnTableIncludes = this.whereClauseOnTableIncludes;
  		return newBean;
  	}
  
  	/**
  	 * <p>
  	 * handleQuery.
  	 * </p>
  	 * 
  	 * @param e
  	 *            a {@link fr.ifremer.common.synchro.meta.event.CreateQueryEvent} object.
  	 */
  	@Subscribe
  	public void handleQuery(CreateQueryEvent e) {
  		switch (e.queryName) {
  		case count:
  		case countFromUpdateDate:
  		case selectMaxUpdateDate:
  			e.sql = SynchroQueryBuilder.newBuilder(e.sql)
  					.addWhere(SynchroQueryOperator.AND, whereClauseOnTableIncludes)
  					.build();
  			break;
  		case select:
  		case selectFromUpdateDate:
  			e.sql = SynchroQueryBuilder.newBuilder(e.sql)
  					.addWhere(SynchroQueryOperator.AND, whereClauseOnTableIncludes)
 					// Keep original delete order (e.g. to import taxon deletion - mantis 28389)
 					.addOrderByColumn("t." + DatabaseColumns.UPDATE_DT.name(), true/* ASC */)
 					.build();
 			break;
 
 		default:
 			break;
 		}
 	}
 
 	private String createWhereClauseOnTableIncludes() {
 		Set<String> tableToIncludes = new LinkedHashSet<>(ReferentialSynchroTables.getImportTablesIncludes());
 		tableToIncludes.addAll(RuleSynchroTables.tableNames());
 
 		// Should return no lines :
 		// - if no tables to import
 		// - if status filter enable (see mantis #26399)
 		if (CollectionUtils.isEmpty(tableToIncludes)
 				|| hasStatusCodesIncludes()) {
 			return "1=2";
 		}
 
 		Set<String> allObjectTypes = Sets.newHashSet();
 		for (String tableName : tableToIncludes) {
 			Set<String> objectTypes = ObjectTypes.getObjectTypeFromTableName(tableName);
 			if (CollectionUtils.isNotEmpty(objectTypes)) {
 				allObjectTypes.addAll(objectTypes);
 			}
 			else {
 				// By default, add the table name itself (i.e. PERSON_SESSION_VESSEL)
 				allObjectTypes.add(tableName);
 			}
 		}
 		return String.format("%s IN ('%s')",
 				DatabaseColumns.OBJECT_TYPE_CD.name(),
 				Joiner.on("','").join(allObjectTypes));
 	}
 
 }