package fr.ifremer.quadrige2.synchro.service.data;
   
   /*-
    * #%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.collect.Multimap;
  import fr.ifremer.common.synchro.service.SynchroContext;
  import fr.ifremer.quadrige2.synchro.service.SynchroDirection;
  import fr.ifremer.quadrige2.synchro.vo.SynchroDateOperatorVO;
  
  import java.io.File;
  import java.util.Date;
  import java.util.Map;
  import java.util.Set;
  
  /**
   * <p>
   * DataSynchroContext class.
   * </p>
   * 
   */
  public class DataSynchroContext extends SynchroContext {
  
  	private Integer userId;
  
  	private SynchroDirection direction;
  
  	protected Date dataStartDate;
  
  	protected Date dataEndDate;
  
  	/**
  	 * Optional date operator handling dataStartDate and/or dataEndDate
  	 */
  	protected SynchroDateOperatorVO dateOperator;
  
  	/**
  	 * Need to filter on 'dirty' synchronization status ?
  	 */
  	protected boolean dirtyOnly;
  
  	/**
  	 * Need to process deletion ?
  	 */
  	protected boolean enableDelete = true;
  
  	/**
  	 * Need to process insert/update ?
  	 */
  	protected boolean enableInsertOrUpdate = true;
  
  	/**
  	 * Map of table/PK to includes. Use to limit import on some data (e.g. after a revert on data)
  	 */
  	protected Multimap<String, String> pkIncludes;
  
  	/**
  	 * List of program codes
  	 */
  	protected Set<String> programCodes;
  
  	/**
  	 * Could an edited row (synchronizationStatus <> SYNC) be override silently ?
  	 * <p/>
  	 * Default is <code>false</code>. Set to <code>true</code> to avoid rejected rows, when importing by Pk (with a
  	 * pkIncludes) (See class ImportEditedRowInterceptor for usage)
  	 */
  	protected boolean forceEditedRowOverride = false;
  
  	/**
  	 * A file to write all changes (see ChangeLogInterceptor)
  	 */
  	protected File changeLogFile;
  
  	/**
  	 * If true, force data to be duplicate when imported from a file
  	 */
  	protected boolean forceDuplication = false;
  
 	/**
 	 * Use to transcribing column values at write time
 	 */
 	protected Map<String, Map<String, Map<String, Object>>> remapValues;
 
 	/**
 	 * <p>
 	 * Constructor for DataSynchroContext.
 	 * </p>
 	 */
 	public DataSynchroContext() {
 		super();
 		this.userId = null;
 		this.direction = null;
 	}
 
 	/**
 	 * <p>
 	 * Constructor for DataSynchroContext.
 	 * </p>
 	 * 
 	 * @param otherBean
 	 *            a {@link fr.ifremer.quadrige2.synchro.service.data.DataSynchroContext} object.
 	 */
 	public DataSynchroContext(DataSynchroContext otherBean) {
 		copy(otherBean);
 	}
 
 	/**
 	 * <p>
 	 * Constructor for DataSynchroContext.
 	 * </p>
 	 * 
 	 * @param direction
 	 *            a {@link fr.ifremer.quadrige2.synchro.service.SynchroDirection} object.
 	 * @param userId
 	 *            a {@link java.lang.Integer} object.
 	 */
 	public DataSynchroContext(SynchroDirection direction, Integer userId) {
 		super();
 		this.userId = userId;
 		this.direction = direction;
 	}
 
 	/**
 	 * <p>
 	 * Constructor for DataSynchroContext.
 	 * </p>
 	 * 
 	 * @param delegate
 	 *            a {@link fr.ifremer.common.synchro.service.SynchroContext} object.
 	 * @param direction
 	 *            a {@link fr.ifremer.quadrige2.synchro.service.SynchroDirection} object.
 	 * @param userId
 	 *            a {@link java.lang.Integer} object.
 	 */
 	public DataSynchroContext(SynchroContext delegate, SynchroDirection direction, Integer userId) {
 		super(delegate);
 		this.userId = userId;
 		this.direction = direction;
 	}
 
 	/**
 	 * <p>
 	 * Constructor for DataSynchroContext.
 	 * </p>
 	 * 
 	 * @param delegate
 	 *            a {@link fr.ifremer.common.synchro.service.SynchroContext} object.
 	 * @param direction
 	 *            a {@link fr.ifremer.quadrige2.synchro.service.SynchroDirection} object.
 	 * @param userId
 	 *            a {@link java.lang.Integer} object.
 	 * @param sessionId
 	 *            a {@link java.lang.Integer} object.
 	 */
 	public DataSynchroContext(SynchroContext delegate, SynchroDirection direction, Integer userId, Integer sessionId) {
 		super(delegate);
 		this.userId = userId;
 		this.direction = direction;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>userId</code>.
 	 * </p>
 	 * 
 	 * @return a {@link java.lang.Integer} object.
 	 */
 	public Integer getUserId() {
 		return userId;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>userId</code>.
 	 * </p>
 	 * 
 	 * @param userId
 	 *            a {@link java.lang.Integer} object.
 	 */
 	public void setUserId(Integer userId) {
 		this.userId = userId;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>direction</code>.
 	 * </p>
 	 * 
 	 * @return a {@link fr.ifremer.quadrige2.synchro.service.SynchroDirection} object.
 	 */
 	public SynchroDirection getDirection() {
 		return direction;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>direction</code>.
 	 * </p>
 	 * 
 	 * @param direction
 	 *            a {@link fr.ifremer.quadrige2.synchro.service.SynchroDirection} object.
 	 */
 	public void setDirection(SynchroDirection direction) {
 		this.direction = direction;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>dataStartDate</code>.
 	 * </p>
 	 * 
 	 * @return a {@link java.util.Date} object.
 	 */
 	public Date getDataStartDate() {
 		return dataStartDate;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>dataStartDate</code>.
 	 * </p>
 	 * 
 	 * @param dataStartDate
 	 *            a {@link java.util.Date} object.
 	 */
 	public void setDataStartDate(Date dataStartDate) {
 		this.dataStartDate = dataStartDate;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>dataEndDate</code>.
 	 * </p>
 	 * 
 	 * @return a {@link java.util.Date} object.
 	 */
 	public Date getDataEndDate() {
 		return dataEndDate;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>dataEndDate</code>.
 	 * </p>
 	 * 
 	 * @param dataEndDate
 	 *            a {@link java.util.Date} object.
 	 */
 	public void setDataEndDate(Date dataEndDate) {
 		this.dataEndDate = dataEndDate;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>pkIncludes</code>.
 	 * </p>
 	 * 
 	 * @param pkIncludes
 	 *            a {@link com.google.common.collect.Multimap} object.
 	 */
 	public void setPkIncludes(Multimap<String, String> pkIncludes) {
 		this.pkIncludes = pkIncludes;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>pkIncludes</code>.
 	 * </p>
 	 * 
 	 * @return a {@link com.google.common.collect.Multimap} object.
 	 */
 	public Multimap<String, String> getPkIncludes() {
 		return this.pkIncludes;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>programCodes</code>.
 	 * </p>
 	 * 
 	 * @return a {@link java.util.Set} object.
 	 */
 	public Set<String> getProgramCodes() {
 		return programCodes;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>programCodes</code>.
 	 * </p>
 	 * 
 	 * @param programCodes
 	 *            a {@link java.util.Set} object.
 	 */
 	public void setProgramCodes(Set<String> programCodes) {
 		this.programCodes = programCodes;
 	}
 
 	/**
 	 * <p>
 	 * isEnableDelete.
 	 * </p>
 	 * 
 	 * @return a boolean.
 	 */
 	public boolean isEnableDelete() {
 		return enableDelete;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>enableDelete</code>.
 	 * </p>
 	 * 
 	 * @param enableDelete
 	 *            a boolean.
 	 */
 	public void setEnableDelete(boolean enableDelete) {
 		this.enableDelete = enableDelete;
 	}
 
 	/**
 	 * <p>
 	 * isEnableInsertOrUpdate.
 	 * </p>
 	 * 
 	 * @return a boolean.
 	 */
 	public boolean isEnableInsertOrUpdate() {
 		return enableInsertOrUpdate;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>enableInsertOrUpdate</code>.
 	 * </p>
 	 * 
 	 * @param enableInsertOrUpdate
 	 *            a boolean.
 	 */
 	public void setEnableInsertOrUpdate(boolean enableInsertOrUpdate) {
 		this.enableInsertOrUpdate = enableInsertOrUpdate;
 	}
 
 	/**
 	 * <p>
 	 * isForceEditedRowOverride.
 	 * </p>
 	 * 
 	 * @return a boolean.
 	 */
 	public boolean isForceEditedRowOverride() {
 		return forceEditedRowOverride;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>forceEditedRowOverride</code>.
 	 * </p>
 	 * 
 	 * @param forceEditedRowOverride
 	 *            a boolean.
 	 */
 	public void setForceEditedRowOverride(boolean forceEditedRowOverride) {
 		this.forceEditedRowOverride = forceEditedRowOverride;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>changeLogFile</code>.
 	 * </p>
 	 * 
 	 * @return a {@link java.io.File} object.
 	 */
 	public File getChangeLogFile() {
 		return changeLogFile;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>changeLogFile</code>.
 	 * </p>
 	 * 
 	 * @param changeLogFile
 	 *            a {@link java.io.File} object.
 	 */
 	public void setChangeLogFile(File changeLogFile) {
 		this.changeLogFile = changeLogFile;
 	}
 
 	/**
 	 * <p>
 	 * isForceDuplication.
 	 * </p>
 	 * 
 	 * @return a boolean.
 	 */
 	public boolean isForceDuplication() {
 		return forceDuplication;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>forceDuplication</code>.
 	 * </p>
 	 * 
 	 * @param forceDuplication
 	 *            a boolean.
 	 */
 	public void setForceDuplication(boolean forceDuplication) {
 		this.forceDuplication = forceDuplication;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>remapValues</code>.
 	 * </p>
 	 * 
 	 * @return a {@link java.util.Map} object.
 	 */
 	public Map<String, Map<String, Map<String, Object>>> getRemapValues() {
 		return remapValues;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>remapValues</code>.
 	 * </p>
 	 * 
 	 * @param remapValues
 	 *            a {@link java.util.Map} object.
 	 */
 	public void setRemapValues(Map<String, Map<String, Map<String, Object>>> remapValues) {
 		this.remapValues = remapValues;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>dateOperator</code>.
 	 * </p>
 	 * 
 	 * @return a {@link fr.ifremer.quadrige2.synchro.vo.SynchroDateOperatorVO} object.
 	 */
 	public SynchroDateOperatorVO getDateOperator() {
 		return dateOperator;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>dateOperator</code>.
 	 * </p>
 	 * 
 	 * @param dateOperator
 	 *            a {@link fr.ifremer.quadrige2.synchro.vo.SynchroDateOperatorVO} object.
 	 */
 	public void setDateOperator(SynchroDateOperatorVO dateOperator) {
 		this.dateOperator = dateOperator;
 	}
 
 	/**
 	 * <p>
 	 * isDirtyOnly.
 	 * </p>
 	 * 
 	 * @return a boolean.
 	 */
 	public boolean isDirtyOnly() {
 		return dirtyOnly;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>dirtyOnly</code>.
 	 * </p>
 	 * 
 	 * @param dirtyOnly
 	 *            a boolean.
 	 */
 	public void setDirtyOnly(boolean dirtyOnly) {
 		this.dirtyOnly = dirtyOnly;
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public void copy(SynchroContext otherBean) {
 		super.copy(otherBean);
 
 		// Change database configuration class
 		if (otherBean.getTarget() != null) {
 			setTarget(new DataSynchroDatabaseConfiguration(this, otherBean.getTarget()));
 		}
 		if (otherBean.getSource() != null) {
 			setSource(new DataSynchroDatabaseConfiguration(this, otherBean.getSource()));
 		}
 
 		if (otherBean instanceof DataSynchroContext) {
 			this.userId = ((DataSynchroContext) otherBean).userId;
 			this.direction = ((DataSynchroContext) otherBean).direction;
 			this.dataStartDate = ((DataSynchroContext) otherBean).dataStartDate;
 			this.dataEndDate = ((DataSynchroContext) otherBean).dataEndDate;
 			this.dateOperator = ((DataSynchroContext) otherBean).dateOperator;
 			this.dirtyOnly = ((DataSynchroContext) otherBean).dirtyOnly;
 			this.pkIncludes = ((DataSynchroContext) otherBean).pkIncludes;
 			this.programCodes = ((DataSynchroContext) otherBean).programCodes;
 			this.enableDelete = ((DataSynchroContext) otherBean).enableDelete;
 			this.enableInsertOrUpdate = ((DataSynchroContext) otherBean).enableInsertOrUpdate;
 			this.forceEditedRowOverride = ((DataSynchroContext) otherBean).forceEditedRowOverride;
 			this.forceDuplication = ((DataSynchroContext) otherBean).forceDuplication;
 			this.remapValues = ((DataSynchroContext) otherBean).remapValues;
 			this.changeLogFile = ((DataSynchroContext) otherBean).changeLogFile;
 		}
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public String toString() {
 		StringBuilder sb = new StringBuilder(super.toString());
 		sb.append("\n        direction: ").append(getDirection());
 		sb.append("\n          user id: ").append(getUserId());
 		sb.append("\n    enable insert: ").append(isEnableInsertOrUpdate());
 		sb.append("\n    enable delete: ").append(isEnableDelete());
 		sb.append("\n  override dirty")
 				.append("\n    rows silently: ").append(forceEditedRowOverride);
 		sb.append("\n force duplicates: ").append(forceDuplication);
 		sb.append("\n  only dirty data: ").append(dirtyOnly);
 
 		if (getDataStartDate() != null) {
 			sb.append("\n   start date: ").append(getDataStartDate());
 			sb.append("\n     end date: ").append(getDataEndDate());
 			if (getDateOperator() != null) {
 				sb.append("\n     operator: ").append(getDateOperator());
 			}
 		}
 		if (getProgramCodes() != null) {
 			sb.append("\n     programs: ").append(programCodes == null ? "all" : programCodes.toString());
 		}
 		if (getPkIncludes() != null) {
 			sb.append("\n  PK includes: ").append(getPkIncludes().toString());
 		}
 
 		return sb.toString();
 	}
 
 }