// Generated by: hibernate/SpringHibernateDaoImpl.vsl in andromda-spring-cartridge.
   // license-header java merge-point
   /**
    * This is only generated once! It will never be overwritten.
    * You can (and have to!) safely modify it by hand.
    */
   package fr.ifremer.quadrige2.core.dao.data.survey;
   
   /*-
   * #%L
   * Quadrige2 Core :: Quadrige2 Server Core
   * %%
   * 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.Function;
  import com.google.common.base.Preconditions;
  import com.google.common.collect.Lists;
  import fr.ifremer.quadrige2.core.dao.administration.user.DepartmentImpl;
  import fr.ifremer.quadrige2.core.dao.administration.user.Quser;
  import fr.ifremer.quadrige2.core.dao.administration.user.QuserImpl;
  import fr.ifremer.quadrige2.core.dao.referential.monitoringLocation.PositionningSystemImpl;
  import fr.ifremer.quadrige2.core.dao.system.synchronization.DeletedItemHistoryExtendDao;
  import fr.ifremer.quadrige2.core.dao.technical.Daos;
  import fr.ifremer.quadrige2.core.dao.technical.Dates;
  import fr.ifremer.quadrige2.core.exception.BadUpdateDtException;
  import fr.ifremer.quadrige2.core.vo.data.survey.OccasionVO;
  import org.apache.commons.collections4.CollectionUtils;
  import org.apache.commons.lang3.ArrayUtils;
  import org.hibernate.SessionFactory;
  import org.nuiton.i18n.I18n;
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.context.annotation.Lazy;
  import org.springframework.stereotype.Repository;
  
  import javax.annotation.Nullable;
  import javax.annotation.Resource;
  import java.sql.Timestamp;
  import java.util.Collection;
  import java.util.List;
  import java.util.Objects;
  
  /**
   * @see Occasion
   */
  @Repository("occasionDao")
  @Lazy
  public class OccasionDaoImpl
          extends OccasionDaoBase {
      @Resource(name = "deletedItemHistoryDao")
      private DeletedItemHistoryExtendDao deletedItemHistoryDao;
  
      /**
       * Constructor used by Spring
       */
      @Autowired
      public OccasionDaoImpl(SessionFactory sessionFactory) {
          super();
          setSessionFactory(sessionFactory);
      }
  
      /**
       * {@inheritDoc}
       */
      @Override
      public void remove(Collection<Occasion> entities) {
          Preconditions.checkNotNull(entities);
          Preconditions.checkArgument(entities.size() > 0);
  
          for (Occasion entity : entities) {
              remove(entity);
          }
      }
  
      /**
       * {@inheritDoc}
       */
      @Override
      public void remove(Occasion entity) {
  
          // Remove link to moratoria
          if (CollectionUtils.isNotEmpty(entity.getMoratoria())) {
              entity.getMoratoria().clear();
          }
  
         // Remove link to Quser
         if (CollectionUtils.isNotEmpty(entity.getQusers())) {
             entity.getQusers().clear();
         }
 
         // Insert into DeleteItemHistory
         deletedItemHistoryDao.insertDeletedItem(OccasionImpl.class, entity);
 
         super.remove(entity);
     }
 
     /**
      * {@inheritDoc}
      */
     protected OccasionVO handleSave(OccasionVO source, Timestamp updateDt) {
         Preconditions.checkNotNull(source);
         Preconditions.checkNotNull(source.getCampaignId());
 
         // Load parent
         Campaign parent = get(CampaignImpl.class, source.getCampaignId());
 
         // Load entity
         Occasion entity = null;
         boolean isNew = false;
         if (source.getOccasId() != null) {
             entity = get(source.getOccasId());
         }
         if (entity == null) {
             entity = Occasion.Factory.newInstance();
             parent.addOccasions(entity);
             entity.setCampaign(parent);
             isNew = true;
         }
 
         // Check update_dt
         if (!isNew) {
             if (entity.getUpdateDt() != null) {
                 Timestamp serverUpdateDtNoMillisecond = Dates.resetMillisecond(entity.getUpdateDt());
                 if (source.getUpdateDt() == null) {
                     throw new BadUpdateDtException(I18n.t("quadrige2.dao.occasion.badUpdateDt", source.getOccasId(),
                             serverUpdateDtNoMillisecond,
                             "null"));
                 }
                 Timestamp sourceUpdateDtNoMillisecond = Dates.resetMillisecond(source.getUpdateDt());
                 if (!Objects.equals(sourceUpdateDtNoMillisecond, serverUpdateDtNoMillisecond)) {
                     throw new BadUpdateDtException(I18n.t("quadrige2.dao.occasion.badUpdateDt", source.getOccasId(), serverUpdateDtNoMillisecond,
                             sourceUpdateDtNoMillisecond));
                 }
             }
         }
 
         // update update_dt
         Timestamp newUpdateDt = updateDt;
         if (newUpdateDt == null) {
             newUpdateDt = getDatabaseCurrentTimestamp();
         }
         source.setUpdateDt(newUpdateDt);
 
         // VO -> Entity
         occasionVOToEntity(source, entity, true);
 
         // Save entity
         if (isNew) {
             Integer occasId = (Integer) getSession().save(entity);
             source.setOccasId(occasId);
         } else {
             getSession().update(entity);
         }
 
         return source;
     }
 
     /**
      * {@inheritDoc}
      */
     protected void handleRemoveByIds(Collection<Integer> occasIds) {
         for (Integer occasId : occasIds) {
             remove(occasId);
         }
     }
 
     /**
      * {@inheritDoc}
      */
     public void toOccasionVO(
             Occasion source,
             OccasionVO target) {
         // copy base attributes
         super.toOccasionVO(source, target);
 
         // copy recorder department
         target.setRecDepId(source.getRecorderDepartment() != null ? source.getRecorderDepartment().getDepId() : null);
 
         // copy pos system
         target.setPosSystemId(source.getPositionningSystem() != null ? source.getPositionningSystem().getPosSystemId() : null);
 
         // copy ship
         target.setShipId(source.getShip() != null ? source.getShip().getShipId() : null);
 
         // Resp qusers
         if (CollectionUtils.isEmpty(source.getQusers())) {
             target.setQuserIds(null);
         } else {
             List<Integer> quserIds = Lists.transform(Lists.newArrayList(source.getQusers()),
                     new Function<Quser, Integer>() {
                         @Nullable
                         @Override
                         public Integer apply(Quser source) {
                             return source.getQuserId();
                         }
                     });
             target.setQuserIds(quserIds.toArray(new Integer[quserIds.size()]));
         }
     }
 
     /**
      * Retrieves the entity object that is associated with the specified value object
      * from the object store. If no such entity object exists in the object store,
      * a new, blank entity is created
      */
     private Occasion loadOccasionFromOccasionVO(OccasionVO occasionVO) {
         Occasion occasion = null;
         if (occasionVO.getOccasId() != null) {
             occasion = this.get(occasionVO.getOccasId());
         }
         if (occasion == null) {
             occasion = Occasion.Factory.newInstance();
         }
         return occasion;
     }
 
     /**
      * {@inheritDoc}
      */
     public Occasion occasionVOToEntity(OccasionVO occasionVO) {
         Occasion entity = this.loadOccasionFromOccasionVO(occasionVO);
         this.occasionVOToEntity(occasionVO, entity, true);
         return entity;
     }
 
     /**
      * {@inheritDoc}
      */
     @Override
     public void occasionVOToEntity(
             OccasionVO source,
             Occasion target,
             boolean copyIfNull) {
         super.occasionVOToEntity(source, target, copyIfNull);
 
         // Campaign
         if (copyIfNull || source.getCampaignId() != null) {
             if (source.getCampaignId() == null) {
                 target.setCampaign(null);
             } else {
                 target.setCampaign(load(CampaignImpl.class, source.getCampaignId()));
             }
         }
 
         // Recorder department
         if (copyIfNull || source.getRecDepId() != null) {
             target.setRecorderDepartment(source.getRecDepId() != null ? load(DepartmentImpl.class, source.getRecDepId()) : null);
         }
 
         // Positionning system
         if (copyIfNull || source.getPosSystemId() != null) {
             target.setPositionningSystem(source.getPosSystemId() != null ? load(PositionningSystemImpl.class, source.getPosSystemId()) : null);
         }
 
         // Ship
         if (copyIfNull || source.getShipId() != null) {
             target.setShip(source.getShipId() != null ? load(ShipImpl.class, source.getShipId()) : null);
         }
 
         // Resp qusers
         if (copyIfNull || ArrayUtils.isNotEmpty(source.getQuserIds())) {
             if (ArrayUtils.isEmpty(source.getQuserIds())) {
                 target.getQusers().clear();
             } else {
                 Daos.replaceEntities(
                         target.getQusers(),
                         source.getQuserIds(),
                         quserId -> load(QuserImpl.class, quserId));
             }
         }
     }
 
     /* -- protected methods -- */
 
 }