package fr.ifremer.quadrige3.synchro.intercept.data;
   
   /*-
    * #%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.collect.ImmutableSet;
  import com.google.common.collect.Lists;
  import com.google.common.eventbus.Subscribe;
  import fr.ifremer.common.synchro.dao.SynchroTableDao;
  import fr.ifremer.common.synchro.intercept.SynchroInterceptorBase;
  import fr.ifremer.common.synchro.intercept.SynchroOperationRepository;
  import fr.ifremer.common.synchro.meta.event.LoadJoinEvent;
  import fr.ifremer.common.synchro.meta.event.LoadTableEvent;
  import fr.ifremer.quadrige3.core.dao.referential.ObjectTypeCode;
  import fr.ifremer.quadrige3.synchro.meta.DatabaseColumns;
  import fr.ifremer.quadrige3.synchro.meta.data.DataSynchroTables;
  import fr.ifremer.quadrige3.synchro.service.SynchroDirection;
  
  import java.sql.SQLException;
  import java.util.List;
  
  /**
   * <p>
   * SamplingOperationInterceptor class.
   * </p>
   * 
   */
  public class SamplingOperationInterceptor extends AbstractDataInterceptor {
  
  	private int columnSamplingOperationIdIndex = -1;
  
  	/**
  	 * <p>
  	 * Constructor for SamplingOperationInterceptor.
  	 * </p>
  	 */
  	public SamplingOperationInterceptor() {
  
  		super(DataSynchroTables.SAMPLING_OPERATION.name());
  		setEnableOnWrite(true);
  
  	}
  
  	@Override
  	public SynchroInterceptorBase clone() {
  		SamplingOperationInterceptor clone = (SamplingOperationInterceptor) super.clone();
  		clone.columnSamplingOperationIdIndex = this.columnSamplingOperationIdIndex;
  		return clone;
  	}
  
  	@Subscribe
  	public void handleLoadTable(LoadTableEvent e) {
  		columnSamplingOperationIdIndex = e.table.getSelectColumnIndex(DatabaseColumns.SAMPLING_OPER_ID.name());
  	}
  
  	/**
  	 * <p>
  	 * handleJoinLoad.
  	 * </p>
  	 * 
  	 * @param e
  	 *            a {@link fr.ifremer.common.synchro.meta.event.LoadJoinEvent} object.
  	 */
  	@Subscribe
  	public void handleJoinLoad(LoadJoinEvent e) {
  
  		if (!e.join.isValid()) {
  			return;
  		}
  
  		String targetTableName = e.join.getTargetTable().getName();
  		SynchroDirection direction = getConfig().getDirection();
  
  		// Server DB -> Temp DB
  		if (direction == SynchroDirection.IMPORT_SERVER2TEMP) {
  			// Disable join to Measurement (already processed in SurveyInterceptor)
  			if (DataSynchroTables.MEASUREMENT.name().equalsIgnoreCase(targetTableName)) {
  				e.join.setIsValid(false);
  			}
 
 			// Disable join to TaxonMeasurement (already processed in SurveyInterceptor)
 			if (DataSynchroTables.TAXON_MEASUREMENT.name().equalsIgnoreCase(targetTableName)) {
 				e.join.setIsValid(false);
 			}
 
 			// Disable join to TaxonMeasurement (already processed in SurveyInterceptor)
 			if (DataSynchroTables.MEASUREMENT_FILE.name().equalsIgnoreCase(targetTableName)) {
 				e.join.setIsValid(false);
 			}
 
 			// Disable join to Photo (already processed in SurveyInterceptor)
 			if (DataSynchroTables.PHOTO.name().equalsIgnoreCase(targetTableName)) {
 				e.join.setIsValid(false);
 			}
 		}
 	}
 
 	@Override
 	protected void doOnWrite(Object[] data, List<Object> pk, SynchroTableDao sourceDao, SynchroTableDao targetDao, SynchroOperationRepository buffer, boolean insert) throws SQLException {
 
 		// If root entity: no transformation
 		if (buffer == null) {
 			return;
 		}
 
 		Object samplingOperationId = data[columnSamplingOperationIdIndex];
 
 		if (samplingOperationId != null) {
 			buffer.addChildToUpdateFromManyColumns(DataSynchroTables.QUALIFICATION_HISTORY.name(),
 				ImmutableSet.of(DatabaseColumns.OBJECT_TYPE_CD.name(), DatabaseColumns.QUAL_HIST_ELEMENT_ID.name()),
 				Lists.newArrayList(ObjectTypeCode.SAMPLING_OPERATION.value(), Long.parseLong(samplingOperationId.toString())));
 		}
 	}
 
 	/* -- Internal methods -- */
 
 }