package fr.ifremer.quadrige3.core.dao.administration.user;
   
   /*-
    * #%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.base.Joiner;
  import com.google.common.collect.Maps;
  import fr.ifremer.quadrige3.core.dao.referential.StatusCode;
  import fr.ifremer.quadrige3.core.dao.technical.Assert;
  import fr.ifremer.quadrige3.core.dao.technical.jdbc.OptionalDataSourceJdbcDaoSupport;
  import fr.ifremer.quadrige3.core.exception.QuadrigeTechnicalException;
  import fr.ifremer.quadrige3.core.vo.administration.user.DepartmentVO;
  import org.apache.commons.io.IOUtils;
  import org.springframework.beans.factory.InitializingBean;
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.context.annotation.Lazy;
  import org.springframework.stereotype.Repository;
  
  import javax.annotation.Resource;
  import javax.sql.DataSource;
  import java.io.IOException;
  import java.io.InputStream;
  import java.sql.ResultSet;
  import java.sql.SQLException;
  import java.util.Date;
  import java.util.List;
  import java.util.Map;
  import java.util.Properties;
  
  /**
   * <p>
   * DepartmentJdbcDaoImpl class.
   * </p>
   * 
   * @see fr.ifremer.quadrige3.core.dao.administration.user.Quser
   */
  @Repository("departmentJdbcDao")
  @Lazy
  public class DepartmentJdbcDaoImpl
  		extends OptionalDataSourceJdbcDaoSupport
  		implements DepartmentJdbcDao, InitializingBean {
  
  	private final static String QUERIES_FILE_PATH = "queries.jdbc.xml";
  
  	@Resource(name = "queriesJdbcProperties")
  	private Properties queriesJdbcProperties;
  
  	protected Properties connectionProperties;
  
  	/**
  	 * Constructor used by Spring
  	 * 
  	 * @param dataSource
  	 *            a {@link javax.sql.DataSource} object.
  	 */
  	@Autowired
  	public DepartmentJdbcDaoImpl(DataSource dataSource) {
  		super(dataSource);
  	}
  
  	/**
  	 * Constructor without Spring (e.g. for synchro)
  	 */
  	public DepartmentJdbcDaoImpl() {
  		this((Properties) null);
  	}
  
  	/**
  	 * Constructor without Spring (e.g. for synchro)
  	 * 
  	 * @param connectionProperties
  	 *            a {@link java.util.Properties} object.
  	 */
  	public DepartmentJdbcDaoImpl(Properties connectionProperties) {
  		super();
  		this.connectionProperties = connectionProperties;
  
  		// Load properties
  		Properties properties = new Properties();
 		InputStream is = null;
 		try {
 			is = getClass().getClassLoader().getResourceAsStream(QUERIES_FILE_PATH);
 			properties.loadFromXML(is);
 
 			this.queriesJdbcProperties = properties;
 		} catch (IOException e) {
 			throw new QuadrigeTechnicalException(
 					String.format("Unable to read file [%s] from classpath", QUERIES_FILE_PATH),
 					e);
 		} finally {
 			IOUtils.closeQuietly(is);
 		}
 
 		// Check all queries
 		checkAllQueriesExists();
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public void afterPropertiesSet() {
 		checkAllQueriesExists();
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public DepartmentVO getDepartmentById(int depId) {
 		return getDepartmentById(connectionProperties, depId);
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public DepartmentVO getDepartmentById(Properties connectionProperties, int depId) {
 		// Find the user, by id
 		String sql = queriesJdbcProperties.getProperty("departmentById");
 
 		Map<String, Object> paramMap = Maps.newHashMap();
 		paramMap.put("depId", depId);
 
 		return query(connectionProperties, sql, paramMap, this::toDepartmentVO);
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public List<DepartmentVO> getDepartmentsByIds(List<Integer> ids) {
 		return getDepartmentsByIds(connectionProperties, ids);
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public List<DepartmentVO> getDepartmentsByIds(Properties connectionProperties, List<Integer> ids) {
 		// Find the user, by id
 		String sql = queriesJdbcProperties.getProperty("departmentsByIds");
 		sql = sql.replace(":ids", Joiner.on(',').skipNulls().join(ids));
 
 		Map<String, Object> paramMap = Maps.newHashMap();
 
 		return query(connectionProperties, sql, paramMap, (rs, rowNum) -> toDepartmentVO(rs));
 	}
 
 	@Override
 	public List<Integer> getInheritedRecorderDepartmentIdsFrom(int departmentId, Date date) {
 		String sql = queriesJdbcProperties.getProperty("inheritedDepartmentIdsByDepartmentIdFrom");
 
 		Map<String, Object> paramMap = Maps.newHashMap();
 		paramMap.put("departmentId", departmentId);
 		paramMap.put("date", new java.sql.Date(date.getTime()));
 		paramMap.put("statusCd", StatusCode.ENABLE.getValue());
 
 		return query(connectionProperties, sql, paramMap, (resultSet, i) -> resultSet.getInt(1));
 	}
 
 	/* -- Internal methods -- */
 
 	/**
 	 * <p>
 	 * toDepartmentVO.
 	 * </p>
 	 * 
 	 * @param source
 	 *            a {@link java.sql.ResultSet} object.
 	 * @return a {@link fr.ifremer.quadrige3.core.vo.administration.user.DepartmentVO} object.
 	 * @throws java.sql.SQLException
 	 *             if any.
 	 */
 	protected DepartmentVO toDepartmentVO(ResultSet source) throws SQLException {
 		DepartmentVO target = new DepartmentVO();
 		int col = 0;
 		target.setDepId(safeGetInteger(source, ++col));
 		target.setDepCd(source.getString(++col));
 		target.setDepNm(source.getString(++col));
 		target.setDepEMail(source.getString(++col));
 		target.setDepAddress(source.getString(++col));
 		target.setDepPhone(source.getString(++col));
 		target.setDepLdapPresent(source.getString(++col));
 		target.setDepCreationDt(source.getDate(++col));
 		target.setUpdateDt(source.getTimestamp(++col));
 		target.setParentDepartmentId(source.getInt(++col));
 		target.setStatusCd(source.getString(++col));
 
 		return target;
 	}
 
 	/**
 	 * <p>
 	 * checkAllQueriesExists.
 	 * </p>
 	 */
 	protected void checkAllQueriesExists() {
 		checkQueryExists("departmentById");
 	}
 
 	/**
 	 * <p>
 	 * checkQueryExists.
 	 * </p>
 	 * 
 	 * @param queryName
 	 *            a {@link java.lang.String} object.
 	 */
 	protected void checkQueryExists(String queryName) {
 		Assert.notBlank(queriesJdbcProperties.getProperty(queryName),
 				"Property with name [%s] not exists on JDBC queries file");
 	}
 }