/**

  * Copyright 2005-2011 The Kuali Foundation

  *

  * Licensed under the Educational Community License, Version 2.0 (the "License");

  * you may not use this file except in compliance with the License.

  * You may obtain a copy of the License at

  *

  * http://www.opensource.org/licenses/ecl2.php

  *

  * Unless required by applicable law or agreed to in writing, software

  * distributed under the License is distributed on an "AS IS" BASIS,

  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

  * See the License for the specific language governing permissions and

  * limitations under the License.

  */

 package org.kuali.rice.krad.dao.impl;

 import java.util.ArrayList;

 import java.util.Collection;

 import java.util.Iterator;

 import java.util.List;

 import java.util.Map;

 import javax.persistence.EntityManager;

 import javax.persistence.EntityNotFoundException;

 import javax.persistence.PersistenceContext;

 import javax.persistence.PersistenceException;

 import org.hibernate.FlushMode;

 import org.hibernate.Session;

 import org.hibernate.ejb.HibernateEntityManager;

 import org.hibernate.proxy.HibernateProxy;

 import org.kuali.rice.core.framework.persistence.jpa.OrmUtils;

 import org.kuali.rice.core.framework.persistence.jpa.criteria.Criteria;

 import org.kuali.rice.core.framework.persistence.jpa.criteria.QueryByCriteria;

 import org.kuali.rice.core.framework.persistence.jpa.criteria.QueryByCriteria.QueryByCriteriaType;

 import org.kuali.rice.core.framework.persistence.jpa.metadata.MetadataManager;

 import org.kuali.rice.krad.bo.BusinessObject;

 import org.kuali.rice.krad.bo.PersistableBusinessObject;

 import org.kuali.rice.krad.bo.PersistableBusinessObjectExtension;

 import org.kuali.rice.krad.dao.BusinessObjectDao;

 import org.kuali.rice.krad.service.PersistenceStructureService;

 import org.kuali.rice.krad.util.KRADPropertyConstants;

 import org.kuali.rice.krad.util.OjbCollectionHelper;

 import org.springframework.dao.DataAccessException;

 /**

  * This class is the JPA implementation of the BusinessObjectDao interface.

  */

 @SuppressWarnings("unchecked")

 public class BusinessObjectDaoJpa implements BusinessObjectDao {

         @PersistenceContext

         private EntityManager entityManager;

         private PersistenceStructureService persistenceStructureService;

         private OjbCollectionHelper ojbCollectionHelper;

         public BusinessObjectDaoJpa(EntityManager entityManager, PersistenceStructureService persistenceStructureService) {

                 this.entityManager = entityManager;

                 this.persistenceStructureService = persistenceStructureService;

         }

         /**

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#findBySinglePrimaryKey(java.lang.Class, java.lang.Object)

          */

         public <T extends BusinessObject> T findBySinglePrimaryKey(Class<T> clazz, Object primaryKey) {

                 return (T) entityManager.find(clazz, primaryKey);

         }

         /**

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#findByPrimaryKey(java.lang.Class,

          *      java.util.Map)

          */

         public <T extends BusinessObject> T findByPrimaryKey(Class<T> clazz, Map<String, ?> primaryKeys) { 

                 if (primaryKeys == null || primaryKeys.isEmpty()) {

                         return null;

                 }

                 T bo = null;

                 try {

                         bo = (T) new QueryByCriteria(entityManager, buildJpaCriteria(clazz, primaryKeys)).toQuery().getSingleResult();

                 } catch (PersistenceException e) {}

                 return bo;

         }

         /**

          * Retrieves an object, based on its PK object

          * 

          * @param clazz the class of the object to retrieve

          * @param pkObject the value of the primary key

          * @return the retrieved PersistableBusinessObject

          */

         public <T extends BusinessObject> T findByPrimaryKeyUsingKeyObject(Class<T> clazz, Object pkObject) { 

                 if (pkObject == null) {

                         return null;

                 }

                 T bo = null;

                 try {

                         bo = (T) entityManager.find(clazz, pkObject);

                 } catch (PersistenceException e) {}

                 return bo;

         }

         /**

          * Retrieves all of the records for a given class name.

          * 

          * @param clazz -

          *            the name of the object being used, either KualiCodeBase or a

          *            subclass

          * @return Collection

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#findAll(java.lang.Class)

          */

         public <T extends BusinessObject> Collection<T> findAll(Class<T> clazz) {

                 return (Collection<T>) new QueryByCriteria(entityManager, new Criteria(clazz.getName())).toQuery().getResultList();

         }

         /**

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#findAllOrderBy(java.lang.Class,

          *      java.lang.String, boolean)

          */

         public <T extends BusinessObject> Collection<T> findAllOrderBy(Class<T> clazz, String sortField, boolean sortAscending) {

                 Criteria criteria = new Criteria(clazz.getName());

                 criteria.orderBy(sortField, sortAscending);

                 return new QueryByCriteria(entityManager, criteria).toQuery().getResultList();

         }

         /**

          * This is the default impl that comes with Kuali - uses OJB.

          * 

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#findMatching(java.lang.Class,

          *      java.util.Map)

          */

         public <T extends BusinessObject> Collection<T> findMatching(Class<T> clazz, Map<String, ?> fieldValues) {

                 return (Collection<T>)new QueryByCriteria(entityManager, buildJpaCriteria(clazz, fieldValues)).toQuery().getResultList();

         }

         /**

          * Uses the passed query to form a Rice QueryByCriteria, which then translates to a JPA query and retrieves results

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#findMatching(org.kuali.rice.core.framework.persistence.jpa.criteria.Criteria)

          */

         public <T extends BusinessObject> Collection<T> findMatching(Criteria criteria) {

                 return (List<T>)new QueryByCriteria(entityManager, criteria).toQuery().getResultList();

         }

         /**

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#findAllActive(java.lang.Class)

          */

         public <T extends BusinessObject> Collection<T> findAllActive(Class<T> clazz) {

                 return (Collection<T>)new QueryByCriteria(entityManager, buildActiveJpaCriteria(clazz)).toQuery().getResultList();

         }

         /**

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#findAllActive(java.lang.Class)

          */

         public <T extends BusinessObject> Collection<T> findAllInactive(Class<T> clazz) {

                 return (Collection<T>)new QueryByCriteria(entityManager, buildInactiveJpaCriteria(clazz)).toQuery().getResultList();

         }

         /**

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#findAllActiveOrderBy(java.lang.Class,

          *      java.lang.String, boolean)

          */

         public <T extends BusinessObject> Collection<T> findAllActiveOrderBy(Class<T> clazz, String sortField, boolean sortAscending) {

                 Criteria criteria = buildActiveJpaCriteria(clazz);

                 criteria.orderBy(sortField, sortAscending);

                 return (Collection<T>)new QueryByCriteria(entityManager, criteria).toQuery().getResultList();

         }

         /**

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#findMatchingActive(java.lang.Class,

          *      java.util.Map)

          */

         public <T extends BusinessObject> Collection<T> findMatchingActive(Class<T> clazz, Map<String, ?> fieldValues) {

                 Criteria criteria = buildJpaCriteria(clazz, fieldValues);

                 criteria.and(buildActiveJpaCriteria(clazz));

                 return (Collection<T>)new QueryByCriteria(entityManager, criteria).toQuery().getResultList();

         }

         /**

          * This is the default impl that comes with Kuali - uses OJB.

          * 

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#countMatching(java.lang.Class,

          *      java.util.Map)

          */

         public int countMatching(Class clazz, Map<String, ?> fieldValues) {

                 return ((Long) new QueryByCriteria(entityManager, buildJpaCriteria(clazz, fieldValues)).toCountQuery().getSingleResult()).intValue();

         }

         /**

          * This is the default impl that comes with Kuali - uses OJB.

          * 

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#countMatching(java.lang.Class,

          *      java.util.Map, java.util.Map)

          */

         public int countMatching(Class clazz, Map<String, ?> positiveFieldValues, Map<String, ?> negativeFieldValues) {

                 Criteria criteria = buildJpaCriteria(clazz, positiveFieldValues);

                 criteria.and(buildNegativeJpaCriteria(clazz, negativeFieldValues));

                 return ((Long) new QueryByCriteria(entityManager, criteria).toCountQuery().getSingleResult()).intValue();

         }

         /**

          * This is the default impl that comes with Kuali - uses OJB.

          * 

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#findMatching(java.lang.Class,

          *      java.util.Map)

          */

         public <T extends BusinessObject> Collection<T> findMatchingOrderBy(Class<T> clazz, Map<String, ?> fieldValues, String sortField, boolean sortAscending) {

                 Criteria criteria = buildJpaCriteria(clazz, fieldValues);

                 criteria.orderBy(sortField, sortAscending);

                 return (Collection<T>)new QueryByCriteria(entityManager, criteria).toQuery().getResultList();

         }

         /**

          * Saves a business object.

          * 

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#save(org.kuali.rice.krad.bo.PersistableBusinessObject)

          */

         public PersistableBusinessObject save(PersistableBusinessObject bo) throws DataAccessException {

                 /* KC determined this is not needed for JPA

                 // if collections exist on the BO, create a copy and use to process the

                 // collections to ensure

                 // that removed elements are deleted from the database

                 Set<String> boCollections = getPersistenceStructureService().listCollectionObjectTypes(bo.getClass()).keySet();

                 PersistableBusinessObject savedBo = null;

                 if (!boCollections.isEmpty()) {

                         // refresh bo to get db copy of collections

                         savedBo = (PersistableBusinessObject) ObjectUtils.deepCopy(bo);

                         for (String boCollection : boCollections) {

                                 if (getPersistenceStructureService().isCollectionUpdatable(savedBo.getClass(), boCollection)) {

                                         savedBo.refreshReferenceObject(boCollection);

                                 }

                         }

                 }

                 */

                 if (entityManager.contains(bo) && ((HibernateEntityManager)entityManager).getSession().isReadOnly(bo)) {

                         ((HibernateEntityManager)entityManager).getSession().setReadOnly(bo, false); // are we read only?  turn that off...

                 }

                 return reattachAndSave(bo);

         }

         /**

          * Saves a business object.

          * 

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#save(org.kuali.rice.krad.bo.PersistableBusinessObject)

          */

         public List<? extends PersistableBusinessObject> save(List businessObjects) throws DataAccessException {

                 List<PersistableBusinessObject> savedBOs = new ArrayList<PersistableBusinessObject>();

                 for (Iterator i = businessObjects.iterator(); i.hasNext();) {

                         Object bo = i.next();

                         final PersistableBusinessObject savedBusinessObject = reattachAndSave((PersistableBusinessObject) bo);

                         savedBOs.add(savedBusinessObject);

                 }

                 return savedBOs;

         }

         /**

          * Deletes the business object passed in.

          * 

          * @param bo

          * @throws DataAccessException

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#delete(org.kuali.rice.krad.bo.PersistableBusinessObject)

          */

         public void delete(PersistableBusinessObject bo) {

                 final PersistableBusinessObject realPBO = materialize(bo);

                 if (realPBO != null) {

                         if (realPBO.getExtension() != null) {

                                 delete(realPBO.getExtension());

                         }

                         if (entityManager.contains(realPBO)) {

                                 entityManager.remove(realPBO);

                         } else {

                                 final PersistableBusinessObject foundBO = (PersistableBusinessObject)entityManager.find(realPBO.getClass(), MetadataManager.getEntityPrimaryKeyObject(realPBO));

                                 if (foundBO != null) {

                                         entityManager.remove(foundBO);

                                 }

                         }

                 }

         }

         /**

          * If the object is a proxy, materializes it

          * 

          * @param bo the business object, which may be a sneaky proxy

          * @return the materialized non-proxied business object

          */

         protected PersistableBusinessObject materialize(PersistableBusinessObject bo) {

                 try {

                         if (bo instanceof HibernateProxy) {

                                 return (PersistableBusinessObject)((HibernateProxy)bo).getHibernateLazyInitializer().getImplementation();

                         }

                         return bo;

                 } catch (EntityNotFoundException enfe) {

                         return null;  // could not find the entity - just return null

                 }

         }

         /**

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#delete(java.util.List)

          */

         public void delete(List<? extends PersistableBusinessObject> boList) {

                 for (PersistableBusinessObject bo : boList) {

                         delete(bo);

                 }

         }

         /**

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#deleteMatching(java.lang.Class,

          *      java.util.Map)

          */

         public void deleteMatching(Class clazz, Map<String, ?> fieldValues) {

                 // Rice JPA MetadataManager

                 new QueryByCriteria(entityManager, buildJpaCriteria(clazz, fieldValues), QueryByCriteriaType.DELETE).toQuery().executeUpdate();

         }

         /**

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#retrieve(org.kuali.rice.krad.bo.PersistableBusinessObject)

          */

         public PersistableBusinessObject retrieve(PersistableBusinessObject object) {

                 PersistableBusinessObject pbo = null;

                 Object pkObject = MetadataManager.getEntityPrimaryKeyObject(object);

                 if (pkObject != null) {

                         pbo = (PersistableBusinessObject) entityManager.find(object.getClass(), pkObject);

                         if (pbo != null && pbo.getExtension() != null) {

                                 pbo.setExtension((PersistableBusinessObjectExtension) entityManager.find(pbo.getExtension().getClass(), MetadataManager.getPersistableBusinessObjectPrimaryKeyObjectWithValuesForExtension(pbo, pbo.getExtension())));

                         }

                 }

                 return pbo;

         }

         private Criteria buildJpaCriteria(Class clazz, Map<String, ?> fieldValues) {

                 Criteria criteria = new Criteria(clazz.getName());

                 for (Iterator i = fieldValues.entrySet().iterator(); i.hasNext();) {

                         Map.Entry<String, ?> e = (Map.Entry<String, ?>) i.next();

                         String key = e.getKey();

                         Object value = e.getValue();

                         String alias = "";

                         String[] keySplit = key.split("\\.");

                         if (keySplit.length > 1) {

                                 alias = keySplit[keySplit.length-2];

                                 String variableKey = keySplit[keySplit.length-1];

                                 for (int j = 0; j < keySplit.length - 1; j++)  {

                                         if (criteria.getAliasIndex(keySplit[j]) == -1) {

                                             criteria.join(keySplit[j], keySplit[j], false, true);

                                     }

                                 }

                                 key = "__JPA_ALIAS[['" + alias + "']]__." + variableKey;

                         }

                         if (value == null) {

                                 continue;

                         } else if (value instanceof Collection) {

                                 criteria.in(key, (Collection)value);

                         } else {

                                 criteria.eq(key, value);

                         }

                 }

                 return criteria;

         }

         private Criteria buildActiveJpaCriteria(Class clazz) {

                 Criteria criteria = new Criteria(clazz.getName());

                 criteria.eq(KRADPropertyConstants.ACTIVE, true);

                 return criteria;

         }

         private Criteria buildInactiveJpaCriteria(Class clazz) {

                 Criteria criteria = new Criteria(clazz.getName());

                 criteria.eq(KRADPropertyConstants.ACTIVE, false);

                 return criteria;

         }

         private Criteria buildNegativeJpaCriteria(Class clazz, Map negativeFieldValues) {

                 Criteria criteria = new Criteria(clazz.getName());

                 for (Iterator i = negativeFieldValues.entrySet().iterator(); i.hasNext();) {

                         Map.Entry e = (Map.Entry) i.next();

                         String key = (String) e.getKey();

                         Object value = e.getValue();

                         if (value instanceof Collection) {

                                 criteria.notIn(key, (List) value);

                         } else {

                                 criteria.ne(key, value);

                         }

                 }

                 return criteria;

         }

         /**

          * @see org.kuali.rice.krad.dao.BusinessObjectDao#manageReadOnly(org.kuali.rice.krad.bo.PersistableBusinessObject)

          */

         public PersistableBusinessObject manageReadOnly(PersistableBusinessObject bo) {

                 Session session = ((HibernateEntityManager)entityManager).getSession();

                 FlushMode currentFlushMode = session.getFlushMode();

                 session.setFlushMode(FlushMode.MANUAL); // make sure the merge doesn't flush what we're trying to make read only

                 PersistableBusinessObject managedBO = entityManager.merge(bo);

                 session.setReadOnly(managedBO, true);

                 session.setFlushMode(currentFlushMode);

                 return managedBO;

         }

         /**

          * Gets the persistenceStructureService attribute.

          * 

          * @return Returns the persistenceStructureService.

          */

         protected PersistenceStructureService getPersistenceStructureService() {

                 return persistenceStructureService;

         }

         /**

          * Sets the persistenceStructureService attribute value.

          * 

          * @param persistenceStructureService

          *            The persistenceStructureService to set.

          */

         public void setPersistenceStructureService(PersistenceStructureService persistenceStructureService) {

                 this.persistenceStructureService = persistenceStructureService;

         }

         private PersistableBusinessObject reattachAndSave(PersistableBusinessObject bo) {

                 PersistableBusinessObject attachedBo = findByPrimaryKey(bo.getClass(), MetadataManager.getEntityPrimaryKeyValuePairs(bo));

                 PersistableBusinessObject newBo = attachedBo;

                 if (attachedBo == null) {

                         newBo = entityManager.merge(bo);

                         if (bo.getExtension() != null) {

                                 entityManager.merge(bo.getExtension());

                         }

                 } else {

                         /*if (bo.getExtension() != null) {

                                 PersistableBusinessObject attachedBoe = findByPrimaryKey(bo.getExtension().getClass(), MetadataManager.getEntityPrimaryKeyValuePairs(bo.getExtension()));

                                 OrmUtils.reattach(bo.getExtension(),attachedBoe);

                                 attachedBo.setExtension((PersistableBusinessObjectExtension) attachedBoe);

                                 entityManager.merge(attachedBoe);

                         }*/

                         OrmUtils.reattach(bo, attachedBo);

                         newBo = entityManager.merge(attachedBo);

                 }

                 return newBo;

         }

     /**

      * @return the entityManager

      */

     public EntityManager getEntityManager() {

         return this.entityManager;

     }

     /**

      * @param entityManager the entityManager to set

      */

     public void setEntityManager(EntityManager entityManager) {

         this.entityManager = entityManager;

     }

 }