bookdaoimpl.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.BookDao;
import jp.com.cost.dc.entity.DC2101ViewEntity1;
import jp.com.cost.dc.entity.DC2201ViewEntity1;
import jp.com.cost.dc.entity.DC2301ViewEntity1;
import jp.com.cost.dc.web.form.DC2203Form;
import jp.com.cost.pojo.Book;
import jp.com.cost.pojo.Ship;
import jp.com.cost.sw.entity.SW4101ViewEntity1List;
import jp.com.cost.sw.entity.SW4201ViewEntity1List;
import jp.com.cost.wt.entity.WT1301ViewEntity1;
import jp.com.cost.xs.entity.XS3201ViewEntity1;

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

public class BookDaoImpl extends HibernateDaoSupport implements BookDao{
	Query query;
	Session session;
	/**
	 * 初始化信息:查询已申请的客户委托书
	 * @return
	 */
	
	public List findDCWTAll() {
		// TODO Auto-generated method stub

		String sql = "select id,sendperon,receperson,type,size,weight,lister from book as b where  b.state='"+ComTool.WSQ+"'"
				+ " and b.delstate='" + ComTool.UDL + "'";
		session = getHibernateTemplate().getSessionFactory()
				.openSession();
		query = session.createSQLQuery(sql);
		List<Object> list = query.list();
		List bookList = new ArrayList();
		for (int i = 0; i < list.size(); i++) {
			Object[] obj = (Object[]) list.get(i);
			DC2101ViewEntity1 dc2101 = new DC2101ViewEntity1();
			dc2101.setId((Integer) obj[0]);
			dc2101.setSendperon(obj[1].toString());
			dc2101.setReceperson(obj[2].toString());
			dc2101.setType(obj[3].toString());
			dc2101.setSize(Double.parseDouble(obj[4].toString()));
			dc2101.setWeight(Double.parseDouble(obj[5].toString()));
			dc2101.setLister(obj[6].toString());
			bookList.add(dc2101);
		}
		session.close();
		return bookList;
	}

	/**
	 * 根据编号查询未申请订舱已缴费的客户委托书的信息
	 */
	public List findDCWTByCon(String id) {
		String sql = "select id,sendperon,receperson,type,size,weight,lister from book where delstate='" + ComTool.UDL+ "' "+ " and state='"+ComTool.WSQ+"'";
		if(null!=id  && id.trim().length()>0){
			sql=sql+" and id like '%"+id+"%'";
			System.out.println(sql);
		}
		session = getHibernateTemplate().getSessionFactory()
				.openSession();
		query = session.createSQLQuery(sql);
		List<Object> list = query.list();
		List bookList = new ArrayList();
		for (int i = 0; i < list.size(); i++) {
			Object[] obj = (Object[]) list.get(i);
			DC2101ViewEntity1 dc2101 = new DC2101ViewEntity1();
			dc2101.setId((Integer) obj[0]);
			dc2101.setSendperon(obj[1].toString());
			dc2101.setReceperson(obj[2].toString());
			dc2101.setType(obj[3].toString());
			dc2101.setSize(Double.parseDouble(obj[4].toString()));
			dc2101.setWeight(Double.parseDouble(obj[5].toString()));
			dc2101.setLister(obj[6].toString());
			bookList.add(dc2101);
		}
		session.close();
		return bookList;
	}

	/**
	 * 根据编号查询一条记录的详细信息
	 */
	public Book findDCWTById(String id) {
		List list = getHibernateTemplate().find("from Book where id=" + id);
		Book book = (Book) list.get(0);
		return book;
	}

	/**
	 * 根据编号跳转到生成订舱申请页面显示相应信息
	 */

	public Book findDCWTUpdate(String id) {
		List list = getHibernateTemplate().find("from Book where id=" + id);
		Book book = (Book) list.get(0);
		return book;
	}
	/**
	 * 补全订舱申请的相应信息
	 */
	public boolean findDCSQUpdate(Book book) {
		boolean bln = false;
		try{
 			Book b = findDCWTById(book.getId().toString());
			b.setShipcno(book.getShipcno());
			b.setShipcname(book.getShipcname());
			b.setShipname(book.getShipname());
			b.setVoyno(book.getVoyno());
			b.setVoytime(book.getVoytime());
			b.setState(ComTool.YSQ);
			getHibernateTemplate().saveOrUpdate(b);
			Log.insert("book", "modifyDCSQ");
 			bln = true;
		}	
		catch(Exception e){
			e.printStackTrace();
		}
		return bln;		
	}
	/**
	 * 初始化信息:查询已申请的客户委托书
	 * @return
	 */
	public List findSCDCAll() {
		String sql="SELECT id,sendperon,receperson,type,size,weight,lister FROM book where delstate='"+ComTool.UDL+"' and state='"+ComTool.YSQ+"'";
		//System.out.println(sql);
		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++){
  	//		System.out.println("dddddddddd");
 			Object[] obj = (Object[])list.get(i);
 			DC2201ViewEntity1 a = new DC2201ViewEntity1();
 			a.setId((Integer)obj[0]);
 			a.setSendPerson(obj[1].toString());
 			a.setRecePerson(obj[2].toString());
 			a.setType(obj[3].toString());
 			a.setSize(Double.parseDouble(obj[4].toString()));
 			a.setWeight(Double.parseDouble(obj[5].toString()));
 			a.setReceLister(obj[6].toString());
 			//System.out.println(a.getId()+"++++++");
 			list1.add(a); 		 
 		}
 		session.close();
		return list1;
	}

	/**
	 * 根据编号查询客户委托书
	 * @param id -客户委托书编号
	 * @return
	 */
	public List findSCDCByCon(String id) {
		StringBuffer sql = new StringBuffer();
		sql.append("SELECT id,sendperon,receperson,type,size,weight,lister FROM book where delstate='"+ComTool.UDL+"' and state='"+ComTool.YSQ+"'");
		if (null != id && id.trim().length() > 0) {
			sql.append(" AND id like '%");
			sql.append(id);
			sql.append("%'");
		}
	
	//	System.out.println(sql);
   		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);
			DC2201ViewEntity1 a = new DC2201ViewEntity1();
			a.setId((Integer)obj[0]);
 			a.setSendPerson(obj[1].toString());
 			a.setRecePerson(obj[2].toString());
 			a.setType(obj[3].toString());
 			a.setSize(Double.parseDouble(obj[4].toString()));
 			a.setWeight(Double.parseDouble(obj[5].toString()));
 			a.setReceLister(obj[6].toString());
			list1.add(a);
		}
		session.close();
		return list1;
	}
	/**
	 * 查询一条记录的详细信息
	 * @param id-点击的该条记录的id
	 * @return
	 */

	/**
	 * 将需要修改的数据显示到页面上
	 * @param id-需要修改的客户委托书编号
	 * @return
	 */
	public Book findSCDCUpdate(String id) {

		List list = getHibernateTemplate().find("from Book where id="+id);
		Book book = (Book)list.get(0);		 
		return book;
	}
	/**
	 * 修改客户委托书生成订舱委托书
	 * @param book-客户委托书所对应的POJO
	 * @return
	 */
	public boolean updateSCDC(String id,DC2203Form dc2203Form) {
		boolean bln=false;
		try {
			Book b = findSCDCById(id);
			b.setBoxid(dc2203Form.getBoxid());
			b.setBoxweight(dc2203Form.getBoxweight());
			b.setStartport(dc2203Form.getStartport());
			b.setAimport(dc2203Form.getAimport());
			b.setDealcost(dc2203Form.getPayrate());
			b.setState(ComTool.DJH);
			getHibernateTemplate().saveOrUpdate(b);
			Log.insert("book", "modifySCDC");
			bln = true;
		} catch (Exception e) {
			// TODO Auto-generated catch block		
			e.printStackTrace();
		}
		return bln;
	}
	/**
	 * 初始化信息:查询已申请的客户委托书
	 * @return
	 */
	public List findGLDCAll() {
		String sql="SELECT id,sendperon,receperson,type,size,weight,lister FROM book where delstate='"+ComTool.UDL+"' and state='"+ComTool.YTG+"' or state='"+ComTool.WTG+"'";
		//System.out.println(sql);
		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++){
  	//		System.out.println("dddddddddd");
 			Object[] obj = (Object[])list.get(i);
 			DC2301ViewEntity1 a = new DC2301ViewEntity1();
 			a.setId((Integer)obj[0]);
 			a.setSendPerson(obj[1].toString());
 			a.setRecePerson(obj[2].toString());
 			a.setType(obj[3].toString());
 			a.setSize(Double.parseDouble(obj[4].toString()));
 			a.setWeight(Double.parseDouble(obj[5].toString()));
 			a.setReceLister(obj[6].toString());
 	//		System.out.println(a.getId()+"++++++");
 			list1.add(a); 		 
 		}
 		session.close();
		return list1;
	}
	/**
	 * 根据编号和状态查询客户委托书
	 * @param id-客户委托书编号
	 * @param state-客户委托书状态
	 * @return
	 */

	public List findGLDCByCon(String id, String state) {
		StringBuffer sql = new StringBuffer();
		sql.append("SELECT id,sendperon,receperson,type,size,weight,lister FROM book where delstate='"+ComTool.UDL+"'");
		if (null != id && id.trim().length() > 0) {
			sql.append(" AND id like '%");
			sql.append(id);
			sql.append("%'");
		}
		 if(null!=state && state.trim().length()>0){
			if(state.equals(ComTool.QXZ)){
//				sql.append(" and state='"+ComTool.YTG+"' or state='"+ComTool.WTG+"'");
				sql.append(" and state in ('"+ComTool.YTG+"','"+ComTool.WTG+"')");

			}
			else
				sql.append(" AND state='"+state+"'");
				
		}
//		if(null==state)sql.append(" and state='"+ComTool.YTG+"' or state='"+ComTool.WTG+"'");
	
//		System.out.println(sql);
   		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);
			DC2201ViewEntity1 a = new DC2201ViewEntity1();
			a.setId((Integer)obj[0]);
 			a.setSendPerson(obj[1].toString());
 			a.setRecePerson(obj[2].toString());
 			a.setType(obj[3].toString());
 			a.setSize(Double.parseDouble(obj[4].toString()));
 			a.setWeight(Double.parseDouble(obj[5].toString()));
 			a.setReceLister(obj[6].toString());
			list1.add(a);
		}
		session.close();
		return list1;
	}

	/**
	 * 查询某条记录的详细信息
	 */
	public Book findGLDCById(String id) {
//		System.out.println("AAA");
		List list = getHibernateTemplate().find("from Book where id="+id);
//		System.out.println("from Book where id="+id);
		Book book = (Book)list.get(0);		 
		return book;
	}

	/**
	 * 重新订舱或者发送客户
	 */
	public boolean updateGLDC(String id,String deallister) {
		boolean bln=false;
		try {
			Book b = findSCDCById(id);	
			if(b.getState().equals(ComTool.WTG)){
			b.setState(ComTool.WSQ);
			}
			if(b.getState().equals(ComTool.YTG)){
				b.setState(ComTool.YWC);
				b.setDeallister(deallister);
			}
			getHibernateTemplate().saveOrUpdate(b);
			Log.insert("book", "modifyGLDC");
			bln = true;
		} catch (Exception e) {
			// TODO Auto-generated catch block		
			e.printStackTrace();
		}
		return bln;
	}
	public List findWTGLAll() {
		// TODO Auto-generated method stub
		String sql = "select id,sendperon,receperson,type,weight,receplace,deliplace from book where delstate='1'";
		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);
			WT1301ViewEntity1 a = new WT1301ViewEntity1();
			a.setId((Integer) obj[0]);
			a.setSendperon(obj[1].toString());
			a.setReceperson(obj[2].toString());
			a.setType(obj[3].toString());
			a.setWeight(obj[4].toString());