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

import java.util.List;
import com.fr.tx.common.dao.EquipYjylDao;
import com.fr.tx.common.dao.base.BaseDao;
import com.fr.tx.common.entity.EquipYgylEntity;
import com.fr.tx.common.entity.EquipYjylEntity;

public class EquipYjylDaoImpl extends BaseDao implements EquipYjylDao{

	@Override
	public List<EquipYjylEntity> search() {
		List<EquipYjylEntity> result = null;
		try {
			makeSession();
			result = session.selectList("EquipYjyl.search");
			if(result!=null){
				session.commit();
			}else{
				session.rollback();
			}
		} catch (Exception e) {
			session.rollback();
			e.printStackTrace();
		}finally {
			close();
		}
        return result;
	}

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

	@Override
	public List<EquipYjylEntity> searchYJ(EquipYjylEntity en) {
		List<EquipYjylEntity> result = null;
		try {
			makeSession();
			result = session.selectList("EquipYjyl.searchYJ",en);
			if(result!=null){
				session.commit();
			}else{
				session.rollback();
			}
		} catch (Exception e) {
			session.rollback();
			e.printStackTrace();
		}finally {
			close();
		}
        return result;
	}
	
	@Override
	public int getTotalCount(EquipYjylEntity en) {
		int ret = 0;
		try {
			makeSession();
			ret = session.selectOne("EquipYjyl.getTotalCount", en);
			if(ret>0){
				session.commit();
			}else{
				session.rollback();
			}
		} catch (Exception e) {
			session.rollback();
			e.printStackTrace();
		} finally {
			close();
		}
        return ret;
		
	}

	@Override
	public int reset(String addr) {
		int ret = 0;
		int ret1 = 0;
		int ret2 = 0;
		try {
			EquipYjylEntity en=new EquipYjylEntity();
			en.setAddr(addr);
			en.setYgyl("0");
			en.setYjyl("0");
			
			ret1 = session.insert("EquipYjyl.insert", en);
			
			ret2 = session.update("EquipAdr.updateReset", en);
			if(ret1>0 && ret2>0){
				session.commit();
				ret=1;
			}else{
				session.rollback();
			}
		} catch (Exception e) {
			session.rollback();
			e.printStackTrace();
		} finally {
			close();
		}
        return ret;
	}
	@Override
	public int timeSpaceYjyl() {
		int ret = 0;
		try {
			makeSession();
			ret = session.selectOne("EquipYjyl.timeSpaceYjyl");
			if(ret>0){
				session.commit();
			}else{
				session.rollback();
			}
		} catch (Exception e) {
			session.rollback();
			e.printStackTrace();
		} finally {
			close();
		}
        return ret;
		
	}
}