/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package com.bestray.healthcarecommonutil.daoimpl;

import com.bestray.healthcarecommonutil.exception.DataAccessException;
import com.bestray.healthcarecommonutil.vo.TPatient;
import com.bestray.healthcarecommonutil.dao.PatientDao;
import com.bestray.healthcarecommonutil.vo.DuplicatePatient;
import com.bestray.healthcarecommonutil.vo.TInpatentAdmission;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import org.hibernate.Hibernate;
import org.hibernate.Query;
import org.hibernate.SQLQuery;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.exception.ConstraintViolationException;
import org.hibernate.transform.AliasToBeanResultTransformer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.orm.hibernate3.HibernateOptimisticLockingFailureException;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;

// TODO: Auto-generated Javadoc
/**
 * The Class PatientDaoImpl.
 *
 * @author User1
 */
@Repository
public class PatientDaoImpl extends HibernateDaoSupport implements PatientDao{
    
    private SimpleDateFormat sdf = new SimpleDateFormat("dd-MM-YYYY");
    @Autowired
    public void init(SessionFactory sessionfactory) {
        setSessionFactory(sessionfactory);
    }
    
    /* (non-Javadoc)
     * @see com.bestray.healthcareemr.Dao.PatientDao#savePatientRegistration(com.bestray.healthcareemr.Vo.TPatient)
     */
    @Override
    public void savePatientRegistration(TPatient patient)throws DataAccessException,ConstraintViolationException,HibernateOptimisticLockingFailureException {
        try{
            getHibernateTemplate().saveOrUpdate(patient);
        }catch(ConstraintViolationException | HibernateOptimisticLockingFailureException  e){
            throw e;
        }
        catch(Exception e){
           throw new DataAccessException();
        }
    }
    
    @Override
    public void savePatientAdmission(TInpatentAdmission admission) throws DataAccessException, ConstraintViolationException, HibernateOptimisticLockingFailureException {
        try{
            System.out.println("########### "+admission.getIpdNo()+"    "+admission.getPatientDisease()+"   "+admission.getPatientNote());
            getHibernateTemplate().saveOrUpdate(admission);
        }catch(ConstraintViolationException | HibernateOptimisticLockingFailureException  e){
            throw e;
        }
        catch(Exception e){
           throw new DataAccessException();
        }
    }

    /* (non-Javadoc)
     * @see com.bestray.healthcareemr.Dao.PatientDao#getPatientDetails(java.lang.Long)
     */
    @Override
    public TPatient getPatientDetails(Long ID)throws DataAccessException {
        try{
            return getHibernateTemplate().get(TPatient.class, ID);
        }catch(Exception e){
            throw new DataAccessException();
        }
    }

    /* (non-Javadoc)
     * @see com.bestray.healthcareemr.Dao.PatientDao#findAllPatientrecords()
     */
    @Override
    public List<TPatient> findAllPatientrecords() throws DataAccessException {
        try{
            return getHibernateTemplate().findByNamedQuery("findAllPatientrecords");
        }catch(Exception e){
            throw new DataAccessException();
        }
    }

    /* (non-Javadoc)
     * @see com.bestray.healthcareemr.Dao.PatientDao#findPatientWise(java.lang.String)
     */
    @Override
    public List<TPatient> findPatientWise(String searchCriteria) throws DataAccessException {
        try{
            Query query=getHibernateTemplate().getSessionFactory().openSession().createQuery(searchCriteria);
            List<TPatient> patientList = query.list();
            return patientList;
        }catch(Exception e){
            throw new DataAccessException();
        }
    }
    
    /* (non-Javadoc)
     * @see com.bestray.healthcareemr.Dao.PatientDao#getIdToInsert()
     */
    @Transactional(readOnly=true)
    @Override
    public String getIdToInsert() throws DataAccessException {
        try{
            List<TPatient> patientIds = getHibernateTemplate().findByNamedQuery("findMaxId");
            if(patientIds.isEmpty()){
                String date = sdf.format(new Date());
                date = date.substring(0,2)+date.substring(3,5)+date.substring(6);
                return date+"1685";
                //return "A0999";
            }else{
                return (patientIds.get(0)).getPatientId();
            }
        }catch(Exception e){
            throw new DataAccessException();
        }
    }
    @Override
    public boolean isDuplicatePatient(TPatient patient)throws DataAccessException {
        try{
            List<TPatient> patientList = getHibernateTemplate().findByNamedQuery("findDuplicatePatientNameWise",patient.getPatientFName(),patient.getPatientMName(),patient.getPatientLName(),patient.getPatientGender());
            if(!patientList.isEmpty()){
                return true;
            }else{
                return false;
            }
        }catch(Exception e){
            throw new DataAccessException();
        }
    }

    @Override
    public List<DuplicatePatient> findDuplicatePatientDetails() throws DataAccessException {
         try{
            SQLQuery query = getHibernateTemplate().getSessionFactory().openSession().createSQLQuery("select patient_f_name as fname,patient_m_name as mname,patient_l_name as lname,patient_gender as gender,count(*) as duplicateNo from t_patient WHERE patient_status = 'ACTIVE' group by patient_f_name,patient_m_name,patient_l_name,patient_gender having count(*)>1 order by 5 desc ;");
            query.addScalar("fname", Hibernate.STRING).addScalar("mname", Hibernate.STRING).addScalar("lname", Hibernate.STRING).addScalar("gender", Hibernate.STRING).addScalar("duplicateNo", Hibernate.INTEGER); 
            query.setResultTransformer(new AliasToBeanResultTransformer(DuplicatePatient.class));
            return query.list();
        }catch(Exception e){
            throw new DataAccessException();
        }
    }

    @Override
    public List<TPatient> findDuplicateRecordsByPatient(DuplicatePatient patient) throws DataAccessException {
        try{
             return getHibernateTemplate().findByNamedQuery("findDuplicatePatientNameWise",patient.getFname(),patient.getMname(),patient.getLname(),patient.getGender());
        }catch(Exception e){
            throw new DataAccessException();
        }
    }

    @Override
    public void changePatientStatus(String patientids) throws DataAccessException {
        try{
            Session session = getHibernateTemplate().getSessionFactory().openSession();
            Query query = session.getNamedQuery("updatePatient");
            query.setString(0,patientids);
            query.executeUpdate();
        }catch(Exception e){
            throw new DataAccessException();
        }
    }

    @Override
    public Long getIdAfterPatientSave(TPatient patient) throws DataAccessException {
        try{
             return (Long)getHibernateTemplate().save(patient);
        }catch(Exception e){
           throw new DataAccessException();
        }
    }
    
    @Override
    public List<TPatient> getPatientByPatientId(String patientID) throws DataAccessException {
        try{
            return getHibernateTemplate().findByNamedQuery("findPatientIdList", patientID);
        }catch(Exception e){
            throw new DataAccessException();
        }
    }

    
}