/*
 * JBoss, Home of Professional Open Source
 * Copyright 2005, JBoss Inc., and individual contributors as indicated
 * by the @authors tag. See the copyright.txt in the distribution for a
 * full listing of individual contributors.
 *
 * This is free software; you can redistribute it and/or modify it
 * under the terms of the GNU Lesser General Public License as
 * published by the Free Software Foundation; either version 2.1 of
 * the License, or (at your option) any later version.
 *
 * This software 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
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this software; if not, write to the Free
 * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
 * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
 */
package org.jbpm.pvm.internal.query;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import org.hibernate.Query;
import org.hibernate.Session;
import org.jbpm.api.Deployment;
import org.jbpm.api.ProcessDefinition;
import org.jbpm.api.ProcessDefinitionQuery;
import org.jbpm.pvm.internal.env.EnvironmentImpl;
import org.jbpm.pvm.internal.model.ProcessDefinitionImpl;
import org.jbpm.pvm.internal.repository.DeploymentImpl;
import org.jbpm.pvm.internal.repository.DeploymentProperty;
import org.jbpm.pvm.internal.session.RepositorySession;


/** returns partially initialized ProcessDefinitionImpl's that can only be exposed 
 * as {@link ProcessDefinition}.
 * 
 * To get the properly initialized {@link ProcessDefinitionImpl} objects,
 * use {@link RepositorySession#findProcessDefinitionById(String)} or 
 * {@link RepositorySession#findProcessDefinitionByKey(String)}
 * 
 * You can use the query query capabilities in this class to find the id 
 * and then use  {@link RepositorySession#findProcessDefinitionById(String)}
 * to get the properly initialized ProcessDefinitionImpl.
 * 
 * @author Tom Baeyens
 */
public class ProcessDefinitionQueryImpl extends AbstractQuery implements ProcessDefinitionQuery {
  
  private static final long serialVersionUID = 1L;

  protected String id;
  protected String key;
  protected String nameLike;
  protected String name;
  protected Boolean suspended;
  protected String deploymentId;
  
  public Object execute(Session session) {
    List<Map<String, Object>> propertyMaps = (List<Map<String, Object>>) super.execute(session);
    
    List<ProcessDefinition> processDefinitions = new ArrayList<ProcessDefinition>();
    for (Map<String, Object> properties: propertyMaps) {
      String deploymentId = properties.get("deploymentDbid").toString();
      String objectName = (String)properties.get("objectName");
      RepositorySession repositorySession = EnvironmentImpl.getFromCurrent(RepositorySession.class);
      ProcessDefinitionImpl processDefinition = (ProcessDefinitionImpl) repositorySession.getObject(deploymentId, objectName);
      processDefinitions.add(processDefinition);
    }
    
    return processDefinitions;
  }

  public String hql() {
  	StringBuilder hql = new StringBuilder();
    hql.append("select new map( idProperty.objectName as objectName, " +
    		                   "idProperty.deployment.dbid as deploymentDbid ) ");
    hql.append("from ");
    hql.append(DeploymentImpl.class.getName());
    hql.append(" as deployment, ");
    hql.append(DeploymentProperty.class.getName());
    hql.append(" as idProperty, ");
    hql.append(DeploymentProperty.class.getName());
    hql.append(" as keyProperty, ");
    hql.append(DeploymentProperty.class.getName());
    hql.append(" as versionProperty ");

    if (suspended!=null) {
      if (suspended) {
        appendWhereClause("deployment.state = '"+Deployment.STATE_SUSPENDED+"'", hql);
      } else {
        appendWhereClause("deployment.state != '"+Deployment.STATE_SUSPENDED+"'", hql);
      }
    }

    appendWhereClause("idProperty.key = '"+DeploymentImpl.KEY_PROCESS_DEFINITION_ID+"'", hql);
    appendWhereClause("idProperty.deployment = deployment ", hql);

    appendWhereClause("keyProperty.key = '"+DeploymentImpl.KEY_PROCESS_DEFINITION_KEY+"' ", hql);
    appendWhereClause("keyProperty.objectName = idProperty.objectName ", hql);
    appendWhereClause("keyProperty.deployment = deployment ", hql);

    appendWhereClause("versionProperty.key = '"+DeploymentImpl.KEY_PROCESS_DEFINITION_VERSION+"' ", hql);
    appendWhereClause("versionProperty.objectName = idProperty.objectName ", hql);
    appendWhereClause("versionProperty.deployment = deployment ", hql);

    if (id!=null) {
      appendWhereClause("idProperty.stringValue = '"+id+"'", hql);
    }

    if (nameLike!=null) {
      appendWhereClause("idProperty.objectName like '"+nameLike+"' ", hql);
    }

    if (name!=null) {
      appendWhereClause("idProperty.objectName = '"+name+"' ", hql);
    }

    if (key!=null) {
      appendWhereClause("keyProperty.stringValue = '"+key+"' ", hql);
    }
    
    if (deploymentId!=null) {
      appendWhereClause("idProperty.deployment.dbid = "+deploymentId+" ", hql);
    }
    
    appendOrderByClause(hql);

    return hql.toString();
  }
  
  protected void applyParameters(Query query) {
  }
  
  public List<ProcessDefinition> list() {
    return (List<ProcessDefinition>) untypedList();
  }
  
  public ProcessDefinition uniqueResult() {
    return (ProcessDefinition) untypedUniqueResult();
  }
  
  @Override
  public long count() {
    return list().size(); // TODO: change this to a real db count, as with the other query types
  }

  public ProcessDefinitionQuery processDefinitionId(String id) {
    this.id = id;
    return this;
  }

  public ProcessDefinitionQuery processDefinitionKey(String key) {
    this.key = key;
    return this;
  }
  
  public ProcessDefinitionQuery suspended() {
    this.suspended = true;
    return this;
  }

  public ProcessDefinitionQuery notSuspended() {
    this.suspended = false;
    return this;
  }

  public ProcessDefinitionQuery processDefinitionNameLike(String name) {
    this.nameLike = name;
    return this;
  }

  public ProcessDefinitionQuery processDefinitionName(String name) {
    this.name = name;
    return this;
  }

  public ProcessDefinitionQuery deploymentId(String deploymentId) {
    this.deploymentId = deploymentId;
    return this;
  } 

  public ProcessDefinitionQuery orderAsc(String property) {
    addOrderByClause(property+" asc");
    return this;
  }

  public ProcessDefinitionQuery orderDesc(String property) {
    addOrderByClause(property+" desc");
    return this;
  }

  public ProcessDefinitionQuery page(int firstResult, int maxResults) {
    this.page = new Page(firstResult, maxResults);
    return this;
  }
}