/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package gov.hhs.fha.nhinc.common.connectionmanager.dao;

import gov.hhs.fha.nhinc.common.connectionmanager.model.AssigningAuthorityToHomeCommunityMapping;
import gov.hhs.fha.nhinc.common.connectionmanager.persistence.HibernateUtil;
import java.util.ArrayList;
import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.hibernate.Criteria;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import org.hibernate.criterion.Expression;

/**
 *
 * @author svalluripalli
 */
public class AssigningAuthorityHomeCommunityMappingDAO {

    private static Log log = LogFactory.getLog(AssigningAuthorityHomeCommunityMappingDAO.class);

    /**
     * This method retrieves and returns a AssigningAuthority for an Home Community...
     * @param homeCommunityId
     * @return String
     */
    public String getAssigningAuthority(String homeCommunityId) {
        log.debug("--Begin AssigningAuthorityHomeCommunityMappingDAO.getACommunityIdForAssigningAuthority() ---");
        Session sess = null;
        String assigningAuthId = "";
        if (homeCommunityId != null && !homeCommunityId.equals("")) {
            String sql = "select assigningauthorityid from assigningauthoritytohomecommunitymapping where homecommunityid = '" + homeCommunityId +"'";
            SessionFactory fact = HibernateUtil.getSessionFactory();
            try {
                sess = fact.openSession();                
                if (sess != null) {
                    Criteria criteria = sess.createCriteria(AssigningAuthorityToHomeCommunityMapping.class);
                    criteria.add(Expression.eq("homeCommunityId", homeCommunityId));
                    List<AssigningAuthorityToHomeCommunityMapping> l = criteria.list();
                    if (l != null && l.size() > 0) {
                        assigningAuthId = l.get(0).getAssigningAuthorityId();
                    }
                } else {
                    log.error("Unable create Hibernate Sessions");
                }
            } finally {
                if (sess != null) {
                    try {
                        sess.close();
                    } catch (Throwable t) {
                        log.error("Failed to close session: " + t.getMessage(), t);
                    }
                }
            }
        } else {
            log.error("Please provide a valid homeCommunityId");
            return null;
        }
        log.debug("--End AssigningAuthorityHomeCommunityMappingDAO.getACommunityIdForAssigningAuthority() ---");
        return assigningAuthId;
    }

    /**
     * returns List of Assigning Authorities for a given Home Community Id
     * @param homeCommId
     * @return List
     */
    public List<String> getAssigningAuthoritiesByHomeCommunity(String homeCommunityId)
    {
       log.debug("-- Begin AssigningAuthorityHomeCommunityMappingDAO.getAssigningAuthoritiesByHomeCommunity() ---");
        Session sess = null;
        List<String> listOfAAs = null;
        if (homeCommunityId != null && !homeCommunityId.equals("")) {
            //String sql = "select assigningauthorityid from assigningauthoritytohomecommunitymapping where homecommunityid = '" + homeCommunityId +"'";
            SessionFactory fact = HibernateUtil.getSessionFactory();
            try {
                sess = fact.openSession();                
                if (sess != null) {
                    Criteria criteria = sess.createCriteria(AssigningAuthorityToHomeCommunityMapping.class);
                    criteria.add(Expression.eq("homeCommunityId", homeCommunityId));
                    List<AssigningAuthorityToHomeCommunityMapping> l = criteria.list();
                    if(l != null && l.size() > 0)
                    {
                        listOfAAs = new ArrayList<String>();
                        int size = l.size();
                        String sAA = "";
                        for(int i = 0; i < size; i++)
                        {
                            sAA = l.get(i).getAssigningAuthorityId();
                            listOfAAs.add(sAA);
                        }
                    }
                } else {
                    log.error("Unable create Hibernate Sessions");
                }
            } finally {
                if (sess != null) {
                    try {
                        sess.close();
                    } catch (Throwable t) {
                        log.error("Failed to close session: " + t.getMessage(), t);
                    }
                }
            }
        } else {
            log.error("Please provide a valid homeCommunityId");
            return null;
        }
        log.debug("-- End AssigningAuthorityHomeCommunityMappingDAO.getAssigningAuthoritiesByHomeCommunity() ---");
        return listOfAAs;
    }
    
    /**
     * This method retrieves Home Community for an Assigning Authority...
     * @param assigningAuthority
     */
    public String getHomeCommunityId(String assigningAuthority) {
        log.debug("--Begin AssigningAuthorityHomeCommunityMappingDAO.getAllCommunityIdsForAllAssigningAuthorities() ---");
        String homeCommunity = "";
        if (assigningAuthority != null && !assigningAuthority.equals("")) {
            Session sess = null;
            String sql = "select homecommunityid from assigningauthoritytohomecommunitymapping where assigningauthorityid = '" + assigningAuthority + "'";
            SessionFactory fact = HibernateUtil.getSessionFactory();
            try {
                sess = fact.openSession();
                if (sess != null) {
                    Criteria criteria = sess.createCriteria(AssigningAuthorityToHomeCommunityMapping.class);
                    criteria.add(Expression.eq("assigningAuthorityId", assigningAuthority));
                    List<AssigningAuthorityToHomeCommunityMapping> l = criteria.list();
                    if (l != null && l.size() > 0) {
                        homeCommunity = l.get(0).getHomeCommunityId();
                    }
                } else {
                    log.error("Unable to create session");
                }
            } finally {
                if (sess != null) {
                    try {
                        sess.close();
                    } catch (Throwable t) {
                        log.error("Failed to close session: " + t.getMessage(), t);
                    }
                }
            }
        } else {
            log.error("Enter correct assigning authority");
        }
        log.debug("--End AssigningAuthorityHomeCommunityMappingDAO.getAllCommunityIdsForAllAssigningAuthorities() ---");
        return homeCommunity;
    }

    /**
     * This method stores Assigning Authority To Home Community Mapping...
     * @param homeCommunityId
     * @param assigningAuthority
     */
    public boolean storeMapping(String homeCommunityId, String assigningAuthority) {
        log.debug("--Begin AssigningAuthorityHomeCommunityMappingDAO.storeAssigningAuthorityAndHomeCommunity() ---");
        System.out.println("--Begin AssigningAuthorityHomeCommunityMappingDAO.storeAssigningAuthorityAndHomeCommunity() ---");
        boolean success = false;
        AssigningAuthorityToHomeCommunityMapping mappingInfo = null;
        Transaction trans = null;
        Session sess = null;
        if (homeCommunityId != null && !homeCommunityId.equals("") && assigningAuthority != null && !assigningAuthority.equals("")) {
            String sql = "select * from assigningauthoritytohomecommunitymapping where assigningauthorityid='" + assigningAuthority + "' and homecommunityid='" + homeCommunityId + "'";
            SessionFactory fact = HibernateUtil.getSessionFactory();
            try {
                sess = fact.openSession();
                if (sess != null) {
                    Criteria criteria = sess.createCriteria(AssigningAuthorityToHomeCommunityMapping.class);
                    criteria.add(Expression.eq("assigningAuthorityId", assigningAuthority));
                    criteria.add(Expression.eq("homeCommunityId", homeCommunityId));
                    List<AssigningAuthorityToHomeCommunityMapping> l = criteria.list();
                    if (l != null && l.size() > 0) {
                        log.info("Assigning Authority and Home Community pair already present in the repository");
                    } else {
                        mappingInfo = new AssigningAuthorityToHomeCommunityMapping();
                        mappingInfo.setAssigningAuthorityId(assigningAuthority);
                        mappingInfo.setHomeCommunityId(homeCommunityId);
                        trans = sess.beginTransaction();
                        sess.saveOrUpdate(mappingInfo);
                        success = true;
                    }
                } else {
                    log.error("Unable to create session information");
                }
            } finally {
                if (trans != null) {
                    try {
                        trans.commit();
                    } catch (Throwable t) {
                        log.error("Failed to commit transaction: " + t.getMessage(), t);
                    }
                }
                if (sess != null) {
                    try {
                        sess.close();
                    } catch (Throwable t) {
                        log.error("Failed to close session: " + t.getMessage(), t);
                    }
                }
            }
        } else {
            log.error("Invalid data entered, Enter Valid data to store");
        }
        log.debug("--End AssigningAuthorityHomeCommunityMappingDAO.storeAssigningAuthorityAndHomeCommunity() ---");
        System.out.println("--End AssigningAuthorityHomeCommunityMappingDAO.storeAssigningAuthorityAndHomeCommunity() ---");
        return success;
    }
}