/*

  * Copyright 2007-2009 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.kim.impl.group;

 import org.apache.commons.lang.StringUtils;

 import org.apache.log4j.Logger;

 import org.kuali.rice.core.api.CoreApiServiceLocator;

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

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

 import org.kuali.rice.kim.api.identity.principal.Principal;

 import org.kuali.rice.kim.api.services.KimApiServiceLocator;

 import org.kuali.rice.kim.api.type.KimType;

 import org.kuali.rice.kim.api.type.KimTypeInfoService;

 import org.kuali.rice.kim.bo.types.dto.AttributeDefinitionMap;

 import org.kuali.rice.kim.service.KIMServiceLocatorWeb;

 import org.kuali.rice.kim.service.support.KimTypeService;

 import org.kuali.rice.kim.util.KIMPropertyConstants;

 import org.kuali.rice.kim.util.KimConstants;

 import org.kuali.rice.krad.datadictionary.AttributeDefinition;

 import org.kuali.rice.krad.datadictionary.BusinessObjectEntry;

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

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

 import javax.persistence.EntityManager;

 import javax.persistence.PersistenceContext;

 import java.sql.Timestamp;

 import java.util.List;

 import java.util.Map;

 /**

  * This is a description of what this class does - shyu don't forget to fill this in. 

  * 

  * @author Kuali Rice Team (rice.collab@kuali.org)

  *

  */

 public class GroupDaoJpa implements GroupDao {

     private static final Logger LOG = Logger.getLogger(GroupDaoJpa.class);

     @PersistenceContext(unitName="kim-unit")

     private EntityManager entityManager;

     private KimTypeInfoService kimTypeInfoService;

     public List<GroupBo> getGroups(Map<String,String> fieldValues) {

         Criteria crit = new Criteria(GroupBo.class.getName());

         BusinessObjectEntry boEntry = KRADServiceLocatorWeb.getDataDictionaryService().getDataDictionary().getBusinessObjectEntry("org.kuali.rice.kim.impl.group.GroupBo");

         List lookupNames = boEntry.getLookupDefinition().getLookupFieldNames();

         String kimTypeId = null;

         for (Map.Entry<String,String> entry : fieldValues.entrySet()) {

                 if (entry.getKey().equals("kimTypeId")) {

                         kimTypeId=entry.getValue();

                         break;

                 }

         }

         AttributeDefinitionMap definitions = null;

         for (Map.Entry<String, String> entry : fieldValues.entrySet()) {

                 if (StringUtils.isNotBlank(entry.getValue())) {

                         if (entry.getKey().contains(".")) {

                         Criteria subCrit = new Criteria(GroupAttributeBo.class.getName());

                                 String value = entry.getValue().replace('*', '%');

                     // obey the DD forceUppercase attribute and allow the OR operator

                     // subCrit.addLike("attributeValue",value);

                     String[] values = StringUtils.split(value, KRADConstants.OR_LOGICAL_OPERATOR);

                     boolean valuesCriterionAdded = false;

                     if (values.length > 0) {

                         if (definitions == null) {

                             KimType kimTypeInfo = getKimTypeInfoService().getKimType(kimTypeId);

                             KimTypeService kimTypeService = KIMServiceLocatorWeb.getKimTypeService(kimTypeInfo);

                             definitions = kimTypeService.getAttributeDefinitions(kimTypeId);

                         }

                         AttributeDefinition definition = definitions.getByAttributeName(entry.getKey().substring(0, entry.getKey().indexOf('.')));

                         Criteria valuesCrit = new Criteria(GroupAttributeBo.class.getName());

                         for (int i = 0; i < values.length; i++) {

                             String subValue = values[i];

                             if (StringUtils.isNotBlank(subValue)) {

                                 Criteria valueCrit = new Criteria(GroupAttributeBo.class.getName());

                                 // null means uppercase it, so do !Boolean.FALSE.equals

                                 if (!Boolean.FALSE.equals(definition.getForceUppercase())) {

                                     valueCrit.like("UPPER(__JPA_ALIAS[[0]]__.value)", subValue.toUpperCase());

                                 }

                                 else {

                                     valueCrit.like("value", subValue);

                                 }

                                 valuesCriterionAdded = true;

                                 valuesCrit.or(valueCrit);

                             }

                         }

                         subCrit.and(valuesCrit);

                         subCrit.eq("id", entry.getKey().substring(entry.getKey().indexOf(".") + 1, entry.getKey().length()));

                         subCrit.eq("kimTypeId", kimTypeId);

                         subCrit.eq(KIMPropertyConstants.Group.GROUP_ID, crit.getAlias() + "." + KIMPropertyConstants.Group.GROUP_ID);

                         //List<GroupAttributeBo> attributes = new QueryByCriteria(entityManager, crit).toQuery().getResultList();

                         if (valuesCriterionAdded) {

                             crit.exists(subCrit);

                         }

                     }

                         } else {

                                 if (lookupNames.contains(entry.getKey())) {

                                     String value = entry.getValue().replace('*', '%');

                         String[] values = StringUtils.split(value, KRADConstants.OR_LOGICAL_OPERATOR);

                         Criteria valuesCrit = new Criteria(GroupBo.class.getName());

                         for (int i = 0; i < values.length; i++) {

                             String subValue = values[i];

                             if (StringUtils.isNotBlank(subValue)) {

                                 Criteria valueCrit = new Criteria(GroupBo.class.getName());

                                 // null means uppercase it, so do !Boolean.FALSE.equals

                                 if (KimConstants.UniqueKeyConstants.GROUP_NAME.equals(entry.getKey())) {

                                     valueCrit.like("UPPER(__JPA_ALIAS[[0]]__.name)", subValue.toUpperCase());

                                 }

                                 else {

                                     valueCrit.like(entry.getKey(), subValue);

                                 }

                                 valuesCrit.or(valueCrit);

                             }

                         }

                         crit.and(valuesCrit);

                                 } else {

                                         if (entry.getKey().equals(KIMPropertyConstants.Person.PRINCIPAL_NAME)) {

                                                 // KULRICE-4248: Retrieve Principal using the Identity Management Service

                                                 Criteria memberSubCrit = new Criteria(GroupMemberBo.class.getName());

                                                 memberSubCrit.eq(KIMPropertyConstants.GroupMember.GROUP_ID, crit.getAlias() +"."+ KIMPropertyConstants.Group.GROUP_ID);

                                                 // Get the passed-in Principal Name

                                                 String principalName = entry.getValue();

                                                 // Search for the Principal using the Identity Management service

                                                 LOG.debug("Searching on Principal Name: " + entry.getValue());

                                                 Principal principalInfo = KimApiServiceLocator.getIdentityManagementService().getPrincipalByPrincipalName(principalName);

                                                 // If a Principal is returned, plug in the Principal ID as the Member ID

                                                 if (principalInfo != null)

                                                 {

                                                         LOG.debug("Retrieved Principal: " + principalInfo.getPrincipalName());

                                                         String principalId = principalInfo.getPrincipalId();

                                                         LOG.debug("Plugging in Principal ID: " + principalId + "as Member ID");

                                                         memberSubCrit.like(KIMPropertyConstants.GroupMember.MEMBER_ID, principalId);

                                            // KULRICE-4232: Only return groups that the principal is an active member of.

                                            Timestamp now = CoreApiServiceLocator.getDateTimeService().getCurrentTimestamp();

                                            Criteria afterActiveFromSubCrit = new Criteria(GroupMemberBo.class.getName());

                                            afterActiveFromSubCrit.lte(KIMPropertyConstants.GroupMember.ACTIVE_FROM_DATE, now);

                                     Criteria nullActiveFromSubCrit = new Criteria(GroupMemberBo.class.getName());

                                     nullActiveFromSubCrit.isNull(KIMPropertyConstants.GroupMember.ACTIVE_FROM_DATE);

                                     Criteria ActiveMemberSubCrit1 = new Criteria(GroupMemberBo.class.getName());

                                 ActiveMemberSubCrit1.or(afterActiveFromSubCrit);

                                     ActiveMemberSubCrit1.or(nullActiveFromSubCrit);

                                            Criteria afterActiveToSubCrit = new Criteria(GroupMemberBo.class.getName());

                                 afterActiveToSubCrit.gte(KIMPropertyConstants.GroupMember.ACTIVE_TO_DATE, now);

                                     Criteria nullActiveToSubCrit = new Criteria(GroupMemberBo.class.getName());

                                     nullActiveToSubCrit.isNull(KIMPropertyConstants.GroupMember.ACTIVE_TO_DATE);

                                     Criteria ActiveMemberSubCrit2 = new Criteria(GroupMemberBo.class.getName());

                                     ActiveMemberSubCrit2.or(afterActiveToSubCrit);

                                     ActiveMemberSubCrit2.or(nullActiveToSubCrit);

                                     memberSubCrit.and(ActiveMemberSubCrit1);

                                     memberSubCrit.and(ActiveMemberSubCrit2);

                                                 }

                                                 // Otherwise, plug in a blank string as the Member ID

                                                 else

                                 {

                                                         LOG.debug("No Principal ID, plugging in blank string as Member ID");

                                                         memberSubCrit.like(KIMPropertyConstants.GroupMember.MEMBER_ID, "");

                                 }

                                                 /*

                                 Criteria subCrit = new Criteria();

                                         String principalName = entry.getValue().replace('*', '%');

                                         subCrit.addLike(KIMPropertyConstants.Person.PRINCIPAL_NAME, principalName );

                                 subCrit.addEqualToField(KIMPropertyConstants.Person.PRINCIPAL_ID, Criteria.PARENT_QUERY_PREFIX + "memberId");

                                         ReportQueryByCriteria subQuery = QueryFactory.newReportQuery(KimPrincipalImpl.class, subCrit);

                                 Criteria memberSubCrit = new Criteria();

                                 memberSubCrit.addEqualToField(KIMPropertyConstants.Group.GROUP_ID, Criteria.PARENT_QUERY_PREFIX + KIMPropertyConstants.Group.GROUP_ID);

                                 memberSubCrit.addExists(subQuery);

                                 */

                                         //ReportQueryByCriteria memberSubQuery = QueryFactory.newReportQuery(GroupMemberBo.class, memberSubCrit);

                                         crit.exists(memberSubCrit);

                                         }

                                 }

                         }

                 }

         }

         List<GroupBo> groups = new QueryByCriteria(entityManager, crit).toQuery().getResultList();

         //Query q = QueryFactory.newQuery(GroupBo.class, crit);

         return groups;

     }

     public EntityManager getEntityManager() {

         return this.entityManager;

     }

     public void setEntityManager(EntityManager entityManager) {

         this.entityManager = entityManager;

     }

     protected KimTypeInfoService getKimTypeInfoService() {

             if (kimTypeInfoService == null) {

                     kimTypeInfoService = KimApiServiceLocator.getKimTypeInfoService();

             }

             return kimTypeInfoService;

     }

 }