producenotedaohibernate.java

这是本人曾经在公司里用的,内部开发框架,基于struts+hibernate今天分享给大家

/**
 * 
 */
package cn.bway.foreigntrade.order.producenote.dao;

import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import org.hibernate.Criteria;
import org.hibernate.HibernateException;
import org.hibernate.criterion.Example;
import org.hibernate.criterion.Expression;
import org.hibernate.criterion.Order;



import cn.bway.common.BwayHibernateException;
import cn.bway.common.DataBaseUtils;
import cn.bway.common.Util;
import cn.bway.common.dao.BaseDAOHibernate;
import cn.bway.common.vo.PageListVO;
import cn.bway.common.vo.QueryVO;
import cn.bway.myoffice.merchant.model.Merchant;
import cn.bway.foreigntrade.order.producenote.model.Producenote;

/**
 * @author Kson
 * 
 */
public class ProducenoteDAOHibernate extends BaseDAOHibernate implements ProducenoteDAO {

	/*
	 * (non-Javadoc)
	 * 
	 * @see cn.bway.myoffice.merchant.dao.MerchantDAO#findAllMerchant(cn.bway.common.vo.QueryVO)
	 */
	public Object findAllProducenote(QueryVO qvo) throws BwayHibernateException {
		// TODO Auto-generated method stub
		PageListVO rvo = new PageListVO();
		rvo.setRealPage(qvo.getCurPage());
		rvo.setPageSize(qvo.getPageSize());
		ArrayList list = new ArrayList();
		Statement stmt = null;
		ResultSet rs = null;
		String sql = DataBaseUtils.getMySQLLimitString(
				"select * from merchant ", qvo.getCurPage() - 1, qvo
						.getPageSize());
		try {
			stmt = currentSession().connection().createStatement();
			rs = stmt.executeQuery(sql);
			Merchant p = null;
			while (rs.next()) {
				p = new Merchant();
				p.setId(String.valueOf(rs.getInt("id")));
				// p.setStorename(rs.getString("storename"));
				list.add(p);
			}
			rs = stmt.executeQuery("select count(*) from merchant");
			rs.next();
			rvo.setTotalItems(rs.getInt(1));
			rvo.setretVO(list);
		} catch (HibernateException he) {
			log.error(this.getClass().getName()
					+ ".findAllMerchant(QueryVO qvo)" + he);
			throw new BwayHibernateException(he.getMessage());
		} catch (Exception e) {
			log.error(this.getClass().getName()
					+ ".findAllMerchant(QueryVO qvo)" + e);
			throw new BwayHibernateException(e.getMessage());
		} finally {
			close(stmt, rs);
			closeSession();
		}
		return rvo;
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see cn.bway.myoffice.merchant.dao.MerchantDAO#findAllMerchant1(cn.bway.common.vo.QueryVO)
	 */
	public Object findAllProducenote1(QueryVO qvo) throws BwayHibernateException {
		// TODO Auto-generated method stub
		Producenote producenote= new Producenote();
		PageListVO rvo = new PageListVO();
		rvo.setRealPage(qvo.getCurPage());
		rvo.setPageSize(qvo.getPageSize());
		List list = null;
		session = currentSession();
		try {
			Criteria criteria = session.createCriteria(Producenote.class);
			rvo.setTotalItems(criteria.add(Example.create(producenote)).list().size());

			criteria.setFirstResult(qvo.getFirstItem());
			criteria.setMaxResults(qvo.getPageSize());

			list = criteria.add(Example.create(producenote))
					.addOrder(Order.asc("checks"))
					.addOrder(Order.desc("id")).list();

			rvo.setretVO(list);
		} catch (Exception ex) {
			ex.printStackTrace();
			log.error(this.getClass().getName() + ".updateObject(Object obj)"
					+ ex);
		} finally {
			closeSession();
		}
		return rvo;
	}

	public Object queryAllProducenote(QueryVO qvo) throws BwayHibernateException {Producenote producenote= new Producenote();
	PageListVO rvo = new PageListVO();
	rvo.setRealPage(qvo.getCurPage());
	rvo.setPageSize(qvo.getPageSize());
	List list = null;
	session = currentSession();
	 int start=0;
	 int end=0;
	 String startTime = "";
	 String endTime="";
	try {
		
		//鏌ヨ鏉′欢
		 Map map= Util.scatterMap(qvo.getScatterMap());
		
	
		 log.info(" ###################################  map objct:  "+map);
		 if(map.isEmpty()){
//			 luc
		 }else{
			 if(map.get("starttime") != null && !"".equals(map.get("starttime"))||
					 map.get("endtime") != null && !"".equals(map.get("endtime"))){
			 startTime = map.get("starttime").toString();
			 endTime = map.get("endtime").toString();
			 System.out.println("startTime是：++++"+startTime+"---------");
			 System.out.println("endTime是：++++"+endTime);
			 start=startTime.length();
			  end=endTime.length();

			 }
		 }
		
		 
		 Criteria criteria = session.createCriteria(Producenote.class);
//		 criteria.add(Expression.like("address", "%"+endTime+"%"));
//		 criteria.add(Expression.like("id", "%"+startTime+"%"));
		 if( start>3&&end>3	)
		 {
		 criteria.add(Expression.gt("requiretime",startTime));
		 criteria.add(Expression.lt("confirmtime",endTime));
		 System.out.println("两 个不为空");
		 System.out.println("strat是："+start + "___"+end);
	
		 }
		 else if( "".equals(endTime)|| endTime==null&&startTime!=null){
			 criteria.add(Expression.gt("requiretime",startTime));
			 System.out.println("endTime是空");
			 }
		 else if( "".equals(startTime)||startTime==null&& endTime!=null){
			 criteria.add(Expression.lt("confirmtime",endTime));
			 System.out.println("startTime是空");
			 }
		 else
		 {};
		rvo.setTotalItems(criteria.add(Example.create(producenote)).list().size());
//		criteria.add( Restricti)
		criteria.setFirstResult(qvo.getFirstItem());
		criteria.setMaxResults(qvo.getPageSize());
		list = criteria.add(Example.create(producenote)).addOrder(Order.desc("id"))
				.list();

		rvo.setretVO(list);
	} catch (Exception ex) {
		ex.printStackTrace();
		log.error(this.getClass().getName() + ".updateObject(Object obj)"
				+ ex);
	} finally {
		closeSession();
	}
	return rvo;
}
}