package org.marketchangers.prayer.hibernate;
   
   import java.util.Collection;
   import java.util.Collections;
   import java.util.Iterator;
   import java.util.LinkedList;
   import java.util.List;
   
   import net.sf.hibernate.Hibernate;
  import net.sf.hibernate.HibernateException;
  import net.sf.hibernate.Session;
  import net.sf.hibernate.type.Type;
  
  import org.marketchangers.prayer.PrayerCategory;
  import org.marketchangers.prayer.PrayerComment;
  import org.marketchangers.prayer.PrayerRequest;
  import org.marketchangers.prayer.PrayerRequestManager;
  import org.marketchangers.prayer.PrayerRequestQuery;
  import org.marketchangers.prayer.PrayerRequestSearcher;
  import org.marketchangers.prayer.UserContract;
  import org.nanocontainer.hibernate.SessionProvider;
  
  /***
   * @author <a href="mailto:jwilliams@wc-group.com">Jason Williams</a>
   * @author <a href="mailto:mtodd@wc-group.com">Matthew Todd</a>
   */
  public class HibernatePrayerRequestManager implements PrayerRequestManager {
  	private SessionProvider provider;
  	private PrayerRequestSearcher searcher;
  
  	public HibernatePrayerRequestManager(
  		PrayerRequestSearcher searcher,
  		SessionProvider provider) {
  		this.provider = provider;
  		this.searcher = searcher;
  	}
  
  	public boolean submitPrayerRequest(PrayerRequest prayerRequest) {
  		try {
  			Session session = provider.getSession();
  			session.save(prayerRequest);
  			provider.commit();
  		} catch (HibernateException he) {
  			he.printStackTrace();
  			provider.reset();
  			return false;
  		}
  
  		// TODO can we use a ComponentAdapter to make this asynchronous?
  		searcher.index(prayerRequest);
  
  		return true;
  	}
  
  	public boolean createPrayerCategory(PrayerCategory category) {
  		try {
  			Session session = provider.getSession();
  			session.save(category);
  			provider.commit();
  		} catch (HibernateException he) {
  			he.printStackTrace();
  			provider.reset();
  			return false;
  		}
  
  		return true;
  	}
  
  	public PrayerCategory getPrayerCategory(String category) {
  		PrayerCategory prayerCategory = null;
  
  		try {
  			List results =
  				provider.getSession().find(
  					"from PrayerCategory as pc where pc.name = ?",
  					category,
  					Hibernate.STRING);
  
  			if (!results.isEmpty()) {
  				prayerCategory = (PrayerCategory)results.get(0);
  			}
  
  			provider.close();
  
  		} catch (HibernateException he) {
  			he.printStackTrace();
  			provider.reset();
  			return null;
  		}
  
  		return prayerCategory;
  	}
  
  	public List getCategoriesForRequestor(String user) {
  		List results = Collections.EMPTY_LIST;
  
  		try {
  			results =
  				provider.getSession().find(
 					"from PrayerCategory as pc where pc.requestorUserId = ?",
 					user,
 					Hibernate.STRING);
 
 			provider.close();
 		} catch (HibernateException he) {
 			results = Collections.EMPTY_LIST;
 			provider.reset();
 			he.printStackTrace();
 		}
 
 		return results;
 	}
 
 	public List getCategoriesForIntercessor(String user) {
 		// TODO Auto-generated method stub
 		return null;
 	}
 
 	public List getRequestorsForIntercessor(String user) {
 		List requestors = new LinkedList();
 
 		try {
 			Iterator contracts =
 				provider.getSession().iterate(
 					"from UserContract as uc where uc.status = ? and uc.requesteeUserId = ?",
 					new Object[] { UserContract.ACCEPTED, user },
 					new Type[] { Hibernate.STRING, Hibernate.STRING });
 
 			while (contracts.hasNext()) {
 				UserContract contract = (UserContract)contracts.next();
 				requestors.add(contract.getRequestorUserId());
 			}
 
 			provider.close();
 
 		} catch (HibernateException he) {
 			provider.reset();
 			he.printStackTrace();
 		}
 
 		return requestors;
 	}
 
 	public List getRequestorOrganizationsForIntercessor(String user) {
 		// TODO Auto-generated method stub
 		return null;
 	}
 
 	/* (non-Javadoc)
 	 * @see org.marketchangers.prayer.PrayerRequestManager#getCurrentIntercessors(java.lang.String)
 	 * 
 	 * Used by requestor to view current relationships with intercessors. 
 	 * returns a list of contracts associated with the requestor.
 	 *
 	 */
 	public List getCurrentIntercessors(String requestorUserId) {
 		List results = Collections.EMPTY_LIST;
 
 		try {
 			results =
 				provider.getSession().find(
 					"from UserContract as uc where requestorUserId = ?",
 					requestorUserId,
 					Hibernate.STRING);
 
 			provider.close();
 		} catch (HibernateException he) {
 			results = Collections.EMPTY_LIST;
 			he.printStackTrace();
 		}
 
 		return results;
 	}
 
 	/* (non-Javadoc)
 	 * @see org.marketchangers.prayer.PrayerRequestManager#getCurrentRequestors(java.lang.String)
 	 *
 	 * Used by intercessor to view current relationships with requestors. 
 	 * returns a list of contracts associated with the intercessor.
 	 * 
 	 */
 	public List getCurrentRequestors(String intercessorUserId) {
 		List results = Collections.EMPTY_LIST;
 
 		try {
 			results =
 				provider.getSession().find(
 					"from UserContract as uc where requesteeUserId = ? and status != 'declined' and status != 'cancelled'",
 					intercessorUserId,
 					Hibernate.STRING);
 
 			provider.close();
 		} catch (HibernateException he) {
 			results = Collections.EMPTY_LIST;
 			he.printStackTrace();
 		}
 
 		return results;
 	}
 
 	public boolean removeContract(UserContract contract) {
 		int deletedEntries;
 
 		try {
 			deletedEntries =
 				provider.getSession().delete(
 					"from UserContract as uc where uc.id = ?",
 					contract.getId(),
 					Hibernate.INTEGER);
 
 			if (deletedEntries > 0) {
 				provider.commit();
 			} else {
 				provider.close();
 			}
 		} catch (HibernateException he) {
 			he.printStackTrace();
 			provider.reset();
 			return false;
 		}
 
 		return deletedEntries > 0;
 	}
 
 	public boolean addContract(UserContract contract) {
 		List results = Collections.EMPTY_LIST;
 
 		if ((contract == null) || (!contract.validate())) {
 			return false;
 		}
 		
 		try {
 			Session session = provider.getSession();
 
 			//see if the two partys already have a contract in place
 			results =
 				session.find(
 					"from UserContract as uc where uc.requesteeUserId = ? and uc.requestorUserId = ?",
 					new Object[] {
 						contract.getRequesteeUserId(),
 						contract.getRequestorUserId()},
 					new Type[] { Hibernate.STRING, Hibernate.STRING });
 
 			if (results.isEmpty()) {
 				session.save(contract);
 				provider.commit();
 			} else {
 				provider.close();
 				return false;
 			}
 		} catch (HibernateException he) {
 			he.printStackTrace();
 			provider.reset();
 			return false;
 		}
 
 		return true;
 	}
 
 	/* (non-Javadoc)
 	 * @see org.marketchangers.prayer.PrayerRequestManager#updateContractStatus(org.marketchangers.prayer.UserContract)
 	 * 
 	 * Used by Intercessor to accept or reject a Requestor's invitation to pray.  
 	 * See IntercessorRelationshipsPortlet.  The contract param contains only
 	 * two values - the Id and Status.  This service should simply look up the 
 	 * matching contract and udpate the status. 
 	 * 
 	 */
 	public boolean updateContractStatus(UserContract contract) {
 		if (contract != null) {
 			try {
 				Session session = provider.getSession();
 				UserContract storedContract =
 					(UserContract)session.get(
 						UserContract.class,
 						contract.getId());
 				if (storedContract != null) {
 					storedContract.setStatus(contract.getStatus());
 					session.update(storedContract);
 					provider.commit();
 					return true;
 				}
 			} catch (HibernateException he) {
 				he.printStackTrace();
 				provider.reset();
 			}
 		}
 		return false;
 	}
 
 	/* (non-Javadoc)
 	 * @see org.marketchangers.prayer.PrayerRequestManager#addComment(org.marketchangers.prayer.PrayerComment)
 	 * 
 	 * Used by both Intercessors and Requestors - see AddCommentPortlet
 	 * 
 	 */
 	public boolean addComment(PrayerComment comment) {
 		try {
 			Session session = provider.getSession();
 			session.save(comment);
 			provider.commit();
 		} catch (HibernateException he) {
 			he.printStackTrace();
 			provider.reset();
 			return false;
 		}
 		return true;
 	}
 
 	/* (non-Javadoc)
 	 * @see org.marketchangers.prayer.PrayerRequestManager#updateStatus(org.marketchangers.prayer.PrayerRequest)
 	 * 
 	 * Used by Requestor to close a request - see AddCommentPortlet
 	 * 
 	 */
 	public boolean updateStatus(PrayerRequest prayerRequest) {
 		try {
 			Session session = provider.getSession();
 			PrayerRequest request =
 				(PrayerRequest)session.get(
 					PrayerRequest.class,
 					prayerRequest.getId());
 			request.setStatus(prayerRequest.getStatus());
 			session.update(request);
 			provider.commit();
 
 			//update lucene index not tested yet
 			searcher.updateStatus(request);
 		} catch (HibernateException he) {
 			he.printStackTrace();
 			provider.reset();
 			return false;
 		}
 		return true;
 	}
 
 	/* (non-Javadoc)
 	 * @see org.marketchangers.prayer.PrayerRequestManager#getPrayerRequestById(java.lang.Integer)
 	 * 
 	 * Used in various screens by various users to obtain prayer details.  
 	 * There currently is a separate method getCommentsByPrayerId to obtain 
 	 * comments in a separate call.
 	 * 
 	 */
 	public PrayerRequest getPrayerRequestById(String user, Integer id) {
 		PrayerRequest request;
 
 		try {
 			Session session = provider.getSession();
 
 			request = (PrayerRequest) session.get(PrayerRequest.class, id);
 
 			if (!request.getRequestorUserId().equals(user)) {
 				Collection contracts =
 					session.find(
 						"from UserContract c where requestorUserId = ? and requesteeUserId = ? and status = ?",
 						new Object[] {
 							request.getRequestorUserId(),
 							user,
 							UserContract.ACCEPTED },
 						new Type[] {
 							Hibernate.STRING,
 							Hibernate.STRING,
 							Hibernate.STRING });
 
 				request = contracts.isEmpty() ? null : request;
 			}
 
 			provider.close();
 
 		} catch (HibernateException he) {
 			request = null;
 			provider.reset();
 			he.printStackTrace();
 		}
 
 		return request;
 	}/* (non-Javadoc)
 	 * @see org.marketchangers.prayer.PrayerRequestManager#getCommentsByPrayerId(java.lang.Integer)
 	 * 
 	 * Used in various screens by various users to obtain prayer comments.
 	 * 
 	 */
 	public List getCommentsByPrayerId(Integer prayerRequestId) {
 		List comments = Collections.EMPTY_LIST;
 
 		try {
 			comments =
 				provider.getSession().find(
 					"from PrayerComment as pc where pc.parentRequest.id = ? order by pc.postDate desc",
 					prayerRequestId,
 					Hibernate.INTEGER);
 			provider.close();
 		} catch (HibernateException he) {
 			comments = Collections.EMPTY_LIST;
 			provider.reset();
 			he.printStackTrace();
 		}
 
 		return comments;
 	}
 
 	/* (non-Javadoc)
 	 * @see org.marketchangers.prayer.PrayerRequestManager#getPrayerRequestList(java.lang.String, java.lang.String)
 	 * 
 	 * Return list of prayer requests based on role of user - the role param is needed
 	 * because an intercessor who is also a requestor may wish to see either his own
 	 * requests, or other users' requests with whom he has contracts.  Perhaps it might
 	 * be better to split this into two methods - getPrayerRequestsForIntercessor etc.
 	 * value of role may be "intercessor" or "requestor" INSTEAD OF "Intercessor" or
 	 * "Businessperson"
 	 * 
 	 */
 	public List getPrayerRequestList(String user, String role) {
 		List results = Collections.EMPTY_LIST;
 
 		if (role.equals("requestor")) {
 			try {
 				results =
 					provider.getSession().find(
 						"from PrayerRequest as pr where requestorUserId = ?",
 						user,
 						Hibernate.STRING);
 
 				provider.close();
 			} catch (HibernateException he) {
 				results = Collections.EMPTY_LIST;
 				he.printStackTrace();
 			}
 		} else if (role.equals("intercessor")) {
 			//TODO - need to put proper query here to obtain requests that this intercessor
 			// can see
 			results = Collections.EMPTY_LIST;
 		}
 		return results;
 	}
 
 	public List search(String user, PrayerRequestQuery query) {
 		List searchResults = new LinkedList();
 		List allowedRequestors = getRequestorsForIntercessor(user);
 
 		// Assumption: user can only pick organizations containing at least one
 		// visible requestor. And if there're no requestors specified, the user
 		// must want to search all.
 		if (query.getRequestorUserIds().size() == 0) {
 			query.getRequestorUserIds().addAll(allowedRequestors);
 		} else {
 			query.getRequestorUserIds().retainAll(allowedRequestors);
 		}
 
 		Iterator prayerRequestIds = searcher.search(query).iterator();
 
 		// TODO this is grossly inefficient. Write a query that takes many ids?
 		while (prayerRequestIds.hasNext()) {
 			Integer id = (Integer) prayerRequestIds.next();
 			searchResults.add(getPrayerRequestById(user, id));
 		}
 
 		return searchResults;
 	}
 }