guestdaoimpl.java

一个完整的物流系统

package jp.com.cost.dao.impl;

import java.util.ArrayList;
import java.util.List;

import jp.com.cost.common.ComTool;
import jp.com.cost.common.Log;
import jp.com.cost.dao.GuestDao;
import jp.com.cost.dao.ShareDao;
import jp.com.cost.pojo.Guest;

import jp.com.cost.tj.entity.SW5301ViewEntity1;
import jp.com.cost.xs.entity.XS3101ViewEntity1;


import org.hibernate.Query;
import org.hibernate.Session;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

public class GuestDaoImpl extends HibernateDaoSupport implements GuestDao {
	
	Query query;
	Session session;
	/**
	 * 根据业务等级和商务等级约束进行统计
	 * @param pgrade-业务等级
	 * @param bgrade-商务等级
	 * @return
	 */
	public List findByCon(String pgrade, String bgrade) {
		// TODO Auto-generated method stub
		StringBuffer sql = new StringBuffer();
		sql.append("SELECT oid,uname,sort,area,email,tel,pgrade,bgrade FROM guest WHERE delstate='"+ComTool.UDL+"'");
		if (null != pgrade && pgrade.trim().length() > 0) {
			sql.append(" AND pgrade =");
			sql.append(pgrade);
			sql.append("");
		}
		if (null != bgrade && bgrade.trim().length() > 0) {
			sql.append(" AND bgrade = ");
			sql.append(bgrade);
			sql.append("");
		}
		session = getHibernateTemplate().getSessionFactory()
				.openSession();
		query = session.createSQLQuery(sql.toString());
		List<Object> list = query.list();
		List list1 = new ArrayList();
		for (int i = 0; i < list.size(); i++) {
			Object[] obj = (Object[]) list.get(i);
			SW5301ViewEntity1 a = new SW5301ViewEntity1();
			a.setOid((Integer) obj[0]);
			a.setUname(obj[1].toString());
			a.setSort(obj[2].toString());
            a.setArea(obj[3].toString());
            a.setEmail(obj[4].toString());
            a.setTel(obj[5].toString());
            a.setPgrade((Integer)obj[6]);
            a.setBgrade((Integer)obj[7]);
			list1.add(a);
		}
		session.close();
		return list1;
	}
	
	/**
	 * 根据查询登陆人员信息显示归属此人员的所有客户信息
	 * @param pnumber
	 * @return
	 */
	public List findAll(String pnumber) {
		// TODO Auto-generated method stub
		String sql = "SELECT oid,uname,tel,sort FROM guest  WHERE delstate='"+ComTool.UDL+"' and pnumber="+pnumber;
 		session = getHibernateTemplate().getSessionFactory()
				.openSession();
		query = session.createSQLQuery(sql);
		List<Object> list = query.list();
		List list1 = new ArrayList();
		for (int i = 0; i < list.size(); i++) {
			Object[] obj = (Object[]) list.get(i);
			XS3101ViewEntity1 a = new XS3101ViewEntity1();
			a.setOid((Integer) obj[0]);
			a.setUname(obj[1].toString());
			a.setTel(obj[2].toString());
			a.setSort(obj[3].toString());		
			list1.add(a);
		}
		session.close();
		return list1;
	}
	/**
	 * 根据输入条件查询合作伙伴信息
	 * @param oid-公司ID
	 * @param uname-公司名称
	 * @param pnumber
	 * @return
	 */
	public List findByCon(String oid, String uname,String pnumber) {
		// TODO Auto-generated method stub
 		StringBuffer sql = new StringBuffer();
		sql.append("SELECT oid,uname,tel,sort  FROM guest WHERE delstate='"+ComTool.UDL+"'");
		sql.append(" and pnumber="+pnumber);
		if (null != oid && oid.trim().length() > 0) {
			sql.append(" AND oid like '%");
			sql.append(oid);
			sql.append("%'");
		}
		if (null != uname && uname.trim().length() > 0) {
			sql.append(" AND uname like '%");
			sql.append(uname);
			sql.append("%'");
		}
       session = getHibernateTemplate().getSessionFactory()
				.openSession();
		query = session.createSQLQuery(sql.toString());
		List<Object> list = query.list();
		List list1 = new ArrayList();
		for (int i = 0; i < list.size(); i++) {
			Object[] obj = (Object[]) list.get(i);
			XS3101ViewEntity1 a = new XS3101ViewEntity1();
			a.setOid((Integer) obj[0]);
			a.setUname(obj[1].toString());
			a.setTel(obj[2].toString());
			a.setSort(obj[3].toString());		
			list1.add(a);
		}
		session.close();
		return list1;
	}
	/**
	 * 删除一条合作伙伴信息
	 * @param oid
	 * @return
	 */
	public boolean delete(String oid) {
		// TODO Auto-generated method stub
		boolean bln=false;
		try {
			Guest guest = findDetail(oid);
			guest.setDelstate(ComTool.DEL);
			getHibernateTemplate().saveOrUpdate(guest);
			Log.insert("guest", "delete");
 			bln = true;
		} catch (Exception e) {
			// TODO Auto-generated catch block			 
		}
		return bln;
	}
	/**
	 * 查询合作伙伴详细信息
	 * @param oid
	 * @return
	 */
	public Guest findDetail(String oid) {
		// TODO Auto-generated method stub
		List list = getHibernateTemplate().find("from Guest where oid="+oid);
		Guest guest = (Guest)list.get(0);		 
		return guest;
	}
	/**
	 * 插入新的合作伙伴信息
	 * @param guest
	 * @return
	 */
	public boolean insert(Guest guest) {
		// TODO Auto-generated method stub
		boolean bln=false;
		try {
			getHibernateTemplate().save(guest);
			Log.insert("guest", "insert");
		} catch (Exception e) {
			// TODO Auto-generated catch block			 
		}
		return bln;
	}
	/**
	 * 修改合作伙伴信息
	 */
	public boolean update(Guest guest) {
		boolean bln=false;
 		try {
			Guest g = findDetail(guest.getOid().toString());
			g.setUname(guest.getUname());
			g.setTel(guest.getTel());
			g.setSort(guest.getSort());
			g.setArea(guest.getArea());
			g.setAddress(guest.getAddress());
			g.setEmail(guest.getEmail());
			g.setBusiness(guest.getBusiness());
			g.setPoeration(guest.getPoeration());
			g.setPgrade(guest.getPgrade());
			g.setBgrade(guest.getBgrade());
			getHibernateTemplate().saveOrUpdate(g);
			Log.insert("guest", "modify");
			bln = true;
		} catch (Exception e) {
			// TODO Auto-generated catch block		
			e.printStackTrace();
		}
		return bln;
	}
	/**
	 * 调用共享表内数据
	 * @param number
	 * @return
	 */
	public Guest shareGuest(String number) {
		ShareDao shareDao=new ShareDaoImpl();
		shareDao.showShared(number);
		shareDao.showNotShared(number);		
		return null;
	}



	}