package fr.ifremer.quadrige2.core.service.data.survey;
   
   /*-
    * #%L
    * Quadrige2 Core :: Quadrige2 Server 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.Preconditions;
  import com.google.common.collect.Lists;
  import fr.ifremer.quadrige2.core.config.Quadrige2Configuration;
  import fr.ifremer.quadrige2.core.dao.data.survey.CampaignDao;
  import fr.ifremer.quadrige2.core.exception.BadUpdateDtException;
  import fr.ifremer.quadrige2.core.exception.DataLockedException;
  import fr.ifremer.quadrige2.core.exception.Exceptions;
  import fr.ifremer.quadrige2.core.vo.data.survey.CampaignVO;
  import org.apache.commons.collections4.CollectionUtils;
  import org.springframework.context.annotation.Lazy;
  import org.springframework.stereotype.Service;
  
  import javax.annotation.Resource;
  import java.util.List;
  
  /**
   * <p>
   * Campaign service impl class.
   * </p>
   * 
   */
  @Service("campaignService")
  @Lazy
  public class CampaignServiceImpl implements CampaignService {
  
  	@Resource
  	private CampaignDao campaignDao;
  
  	@Resource
  	protected Quadrige2Configuration config;
  
  	/** {@inheritDoc} */
  	@Override
  	public List<CampaignVO> save(List<CampaignVO> campaigns) {
  		List<CampaignVO> result = Lists.newArrayList();
  
  		if (CollectionUtils.isNotEmpty(campaigns)) {
  			for (CampaignVO source : campaigns) {
  				CampaignVO target = save(source);
  				result.add(target);
  			}
  		}
  
  		return result;
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	public CampaignVO save(CampaignVO source) {
  		Preconditions.checkNotNull(source);
  		Preconditions.checkNotNull(source.getQuserId());
  		Preconditions.checkNotNull(source.getRecDepId());
  		Preconditions.checkNotNull(source.getCampaignStartDt());
  		Preconditions.checkNotNull(source.getCampaignNm());
  
  		// Save campaign
  		try {
  			return campaignDao.save(source);
  		} catch (RuntimeException e) {
  			if (Exceptions.hasCause(e, BadUpdateDtException.class)) {
  				throw new BadUpdateDtException(Exceptions.getCause(e, BadUpdateDtException.class).getMessage(), e);
  			}
  			if (Exceptions.hasCause(e, DataLockedException.class)) {
  				throw new DataLockedException(Exceptions.getCause(e, DataLockedException.class).getMessage(), e);
  			}
  			throw e;
  		}
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	public CampaignVO getById(int campaignId) {
  		return (CampaignVO) campaignDao.get(CampaignDao.TRANSFORM_CAMPAIGNVO, campaignId);
  	}
 
 
 	/** {@inheritDoc}
 	 * @param campaignId*/
 	@Override
 	public boolean isCampaignUsedBySurvey(int campaignId) {
 		return campaignDao.countSurveyUsage(campaignId) > 0;
 	}
 
 	@Override
 	public void delete(List<Integer> campaignIds) {
 		if (CollectionUtils.isEmpty(campaignIds)) return;
 		campaignIds.forEach(campaignDao::remove);
 	}
 }