package com.fr.tx.common.dao.impl;

import java.util.List;

import com.fr.tx.common.dao.WarningSelectDao;
import com.fr.tx.common.dao.base.BaseDao;
import com.fr.tx.common.entity.WarningSelectEntity;
/**
 * 报警查询
 * @author lyf
 *
 */
public class WarningSelectDaoImpl extends BaseDao implements WarningSelectDao{

	@Override
	public List<WarningSelectEntity> search(WarningSelectEntity en) {
		List<WarningSelectEntity> result = null;
		try {
			makeSession();
			result = session.selectList("WarningSelect.search", en);
			if(result!=null){
				session.commit();
			}else{
				session.rollback();
			}
		} catch (Exception e) {
			// TODO: handle exception
			session.rollback();
			e.printStackTrace();
		}finally {
			close();
		}
        return result;
		
	}

	@Override
	public int getCount(WarningSelectEntity en) {
		int ret = 0;
		try {
			makeSession();
			ret = session.selectOne("WarningSelect.getCount", en);
			if(ret>0){
				session.commit();
			}else{
				session.rollback();
			}
		} catch (Exception e) {
			session.rollback();
			e.printStackTrace();
		} finally {
			close();
		}
        return ret;
		
	}

	@Override
	public WarningSelectEntity getDetailByPk(String pk) {
		
		List<WarningSelectEntity> result = null;
		try {
			makeSession();
			result = session.selectList("WarningSelect.getDetailByPk", pk);
			if(result!=null){
				session.commit();
			}else{
				session.rollback();
			}
		} catch (Exception e) {
			// TODO: handle exception
			session.rollback();
			e.printStackTrace();
		}finally {
			close();
		}
        return result.get(0);
	}

	@Override
	public int update(WarningSelectEntity en) {
		int ret = 0;
		try {
			makeSession();
			ret = session.update("WarningSelect.update", en);
			if(ret>0){
				session.commit();
			}else{
				session.rollback();
			}
		} catch (Exception e) {
			session.rollback();
			e.printStackTrace();
		} finally {
			close();
		}
        return ret;
		
	}

	@Override
	public int insert(WarningSelectEntity en) {
		int ret = 0;
		try {
			makeSession();
			ret = session.insert("WarningSelect.insert", en);
			if(ret>0){
				session.commit();
			}else{
				session.rollback();
			}
		} catch (Exception e) {
			session.rollback();
			e.printStackTrace();
		} finally {
			close();
		}
        return ret;
		
	}

	@Override
	public int delete(WarningSelectEntity en) {
		
		int ret = 0;
		try {
			makeSession();
			ret = session.update("WarningSelect.delete", en);
			if(ret>0){
				session.commit();
			}else{
				session.rollback();
			}
		} catch (Exception e) {
			session.rollback();
			e.printStackTrace();
		} finally {
			close();
		}
        return ret;
	}
	
	
	@Override
	public List<WarningSelectEntity> getLimitData(WarningSelectEntity en) {
		List<WarningSelectEntity> result = null;
		try {
			makeSession();
			result = session.selectList("WarningSelect.getLimitData", en);
			if(result!=null){
				session.commit();
			}else{
				session.rollback();
			}
		} catch (Exception e) {
			// TODO: handle exception
			session.rollback();
			e.printStackTrace();
		}finally {
			close();
		}
        return result;
		
	}

	@Override
	public int getTotalCount(WarningSelectEntity en) {
		int ret = 0;
		try {
			makeSession();
			ret = session.selectOne("WarningSelect.getTotalCount", en);
			if(ret>0){
				session.commit();
			}else{
				session.rollback();
			}
		} catch (Exception e) {
			session.rollback();
			e.printStackTrace();
		} finally {
			close();
		}
        return ret;
		
	}

}