package fr.ifremer.quadrige3.core.dao.data.samplingoperation;
   
   /*-
    * #%L
    * Quadrige3 Core :: Quadrige3 Client 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.ImmutableList;
  import fr.ifremer.quadrige3.core.dao.technical.Assert;
  import fr.ifremer.quadrige3.core.dao.technical.Daos;
  import org.apache.commons.collections4.CollectionUtils;
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  import org.hibernate.SessionFactory;
  import org.hibernate.type.StringType;
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.context.annotation.Lazy;
  import org.springframework.stereotype.Repository;
  
  import java.util.List;
  
  /**
   * <p>
   * SamplingOperationDaoImpl class.
   * </p>
   * 
   * @see fr.ifremer.quadrige3.core.dao.data.samplingoperation.SamplingOperation
   */
  @Repository("samplingOperationDao")
  @Lazy
  public class SamplingOperationDaoImpl
  		extends SamplingOperationDaoBase
  		implements SamplingOperationExtendDao
  {
  	/**
  	 * Logger.
  	 */
  	private static final Log log = LogFactory.getLog(SamplingOperationDaoImpl.class);
  
  	/**
  	 * Constructor used by Spring
  	 * 
  	 * @param sessionFactory
  	 *            a {@link org.hibernate.SessionFactory} object.
  	 */
  	@Autowired
  	public SamplingOperationDaoImpl(SessionFactory sessionFactory) {
  		super();
  		setSessionFactory(sessionFactory);
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	public int updateHasMeasFlagBySurveyId(int surveyId) {
  		return updateHasMeasFlagBySurveyIds(ImmutableList.of(surveyId));
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	public int updateHasMeasFlagBySurveyIds(List<Integer> surveyIds) {
  		Assert.notEmpty(surveyIds);
  
  		if (log.isDebugEnabled()) {
  			log.debug(String.format("Updating HAS_MEAS flag o sampling operation, for parent surveys: %s", surveyIds.toString()));
  		}
  		int rowCount = 0;
  
  		// get get sampling operation WITH meas
  		List<Integer> samplingOperIdsWithMeas = queryListTyped("samplingOperIdsWithMeasBySurveyIds",
  				"surveyIds", null, surveyIds);
  		boolean hasSamplingOperIdsWithMeas = CollectionUtils.isNotEmpty(samplingOperIdsWithMeas);
  
  		// get sampling operation WITHOUT meas
  		List<Integer> samplingOperIdsNoMeas = queryListTyped("samplingOperIdsBySurveyIdsNotInIds",
  				"surveyIds", null, surveyIds,
  				"excludedSamplingOperIds", null, hasSamplingOperIdsWithMeas ? samplingOperIdsWithMeas : ImmutableList.of(-99999999));
  
  		// Update get sampling operation WITH meas
  		if (hasSamplingOperIdsWithMeas) {
  			rowCount += queryUpdate("updateSamplingOperHasMeas",
  					"samplingOperHasMeas", StringType.INSTANCE, Daos.convertToString(true),
 					"samplingOperIds", null, samplingOperIdsWithMeas);
 		}
 
 		// Update get sampling operation WITHOUT meas
 		if (CollectionUtils.isNotEmpty(samplingOperIdsNoMeas)) {
 			rowCount += queryUpdate("updateSamplingOperHasMeas",
 					"samplingOperHasMeas", StringType.INSTANCE, Daos.convertToString(false),
 					"samplingOperIds", null, samplingOperIdsNoMeas);
 		}
 
 		return rowCount;
 	}
 }