shipdaoimpl.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.ShipDao;
import jp.com.cost.pojo.Ship;
import jp.com.cost.xs.entity.XS3201ViewEntity1;

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

public class ShipDaoImpl extends HibernateDaoSupport implements ShipDao {
	Query query;
	Session session;

	/**
	 * 初始化事件，查询全部船期表信息
	 */
	public List findShipAll() {
		// TODO Auto-generated method stub

		String sql = "SELECT s.oid,s.shipname,s.line,s.startport,s.aimport,s.voytime,s.arrive  FROM ship as s WHERE s.delstate='"+ComTool.UDL+"'";
		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);
			XS3201ViewEntity1 a = new XS3201ViewEntity1();
			a.setOid((Integer) obj[0]);
			a.setShipName(obj[1].toString());
			a.setLine(obj[2].toString());
			a.setStaPort(obj[3].toString());
			a.setAimPort(obj[4].toString());
			a.setVoyTime(obj[5].toString());
			a.setArrive(obj[6].toString());
			list1.add(a);
		}
		session.close();
		return list1;
	}
	/**
	 *  根据航线　装箱量　集装箱量　起运港和目的港约束，进行多条件的船期表的高级查询
	 * @param line-航线
	 * @param boxCount-装箱量
	 * @param boxWeight-集装箱量
	 * @param startport-起运港
	 * @param aimPort-目的港
	 * @return
	 */
	public List findShipByCon(String line, String boxCount, String boxWeight,
			String startPort, String aimPort) {
		// TODO Auto-generated method stub
		StringBuffer sql = new StringBuffer();
		sql.append("SELECT	s.oid,s.shipname,s.line,s.startport,s.aimport,s.voytime,s.arrive  FROM ship as s WHERE s.delstate='"+ComTool.UDL+"'");
		if (null != line && line.trim().length() > 0) {
			sql.append(" AND s.line like '%");
			sql.append(line);
			sql.append("%'");
		}
		if (null != boxCount && boxCount.trim().length() > 0) {
			sql.append(" AND s.boxCount like '%");
			sql.append(boxCount);
			sql.append("%'");
		}
		if (null != boxWeight && boxWeight.trim().length() > 0) {
			sql.append(" AND s.boxWeight like '%");
			sql.append(boxWeight);
			sql.append("%'");
		}
		if (null != startPort && startPort.trim().length() > 0) {
			sql.append(" AND s.startPort like '%");
			sql.append(startPort);
			sql.append("%'");
		}
		if (null != aimPort && aimPort.trim().length() > 0) {
			sql.append(" AND s.aimPort like '%");
			sql.append(aimPort);
			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);
			XS3201ViewEntity1 a = new XS3201ViewEntity1();
			a.setOid((Integer) obj[0]);
			a.setShipName(obj[1].toString());
			a.setLine(obj[2].toString());
			a.setStaPort(obj[3].toString());
			a.setAimPort(obj[4].toString());
			a.setVoyTime(obj[5].toString());
			a.setArrive(obj[6].toString());
			list1.add(a);
		}
		session.close();
		return list1;
	}
	/**
	 * 根据条件查询船只信息
	 * @param startPort - 启运港
	 * @param aimPort - 目的港
	 * @return
	 */
	public List findByCon(String startPort, String aimPort) {
		StringBuffer sql = new StringBuffer();
		sql.append("SELECT	s.oid,s.shipname,s.line,s.startport,s.aimport,s.voytime,s.arrive  FROM ship as s WHERE s.delstate='"+ComTool.UDL+"'");		
		if (null != startPort && startPort.trim().length() > 0) {
			sql.append(" AND s.startPort like '%");
			sql.append(startPort);
			sql.append("%'");
		}
		if (null != aimPort && aimPort.trim().length() > 0) {
			sql.append(" AND s.aimPort like '%");
			sql.append(aimPort);
			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);
			XS3201ViewEntity1 a = new XS3201ViewEntity1();
			a.setOid((Integer) obj[0]);
			a.setShipName(obj[1].toString());
			a.setLine(obj[2].toString());
			a.setStaPort(obj[3].toString());
			a.setAimPort(obj[4].toString());
			a.setVoyTime(obj[5].toString());
			a.setArrive(obj[6].toString());
			list1.add(a);
		}
		session.close();
		return list1;
	}
	/**
	 * 根据编号查询一条船只记录的详细信息
	 * @param id
	 * @return
	 */
	public Ship findById(String id) {
		// TODO Auto-generated method stub
		List list = getHibernateTemplate().find("from Ship where oid="+id);
		Ship ship = (Ship)list.get(0);		 
		return ship;
	}
	/**
	 * 删除一条船只记录信息
	 * @param oid
	 * @return
	 */
	public boolean delete(String oid) {
		// TODO Auto-generated method stub
		boolean bln=false;
		try {
			Ship ship = findById(oid);
			ship.setDelstate(ComTool.DEL);
			getHibernateTemplate().saveOrUpdate(ship);
			Log.insert("ship", "delete");
 			bln = true;
		} catch (Exception e) {
			// TODO Auto-generated catch block			 
		}
		return bln;
	}
	/**
	 * 向SHIP插入一条船只信息
	 * @param ship
	 * @return
	 */
	public boolean insert(Ship ship) {
		// TODO Auto-generated method stub
		boolean bln=false;
		try {
			getHibernateTemplate().save(ship);
			Log.insert("ship", "insert");
		} catch (Exception e) {
						 
		}
		return bln;
	}
	/**
	 * 修改一条船只记录信息
	 * @param ship
	 * @return
	 */
	public boolean update(Ship ship) {
		// TODO Auto-generated method stub
		boolean bln=false;
		try {
			Ship s = findById(ship.getOid().toString());
			s.setAimport(ship.getAimport());
			s.setArrive(ship.getArrive());
			s.setBoxcount(ship.getBoxcount());
			s.setBoxid(ship.getBoxid());
			s.setBoxweight(ship.getBoxweight());
			s.setHavenstop(ship.getHavenstop());
			s.setLine(ship.getLine());
			s.setMytel(ship.getMytel());
			s.setShipcno(ship.getShipcno());
			s.setShipname(ship.getShipname());
			s.setShipnumber(ship.getShipnumber());
			s.setShipoener(ship.getShipoener());
			s.setStartport(ship.getStartport());
			s.setStop(ship.getStop());
			s.setTel(ship.getTel());
			s.setVoyno(ship.getVoyno());
			s.setVoytime(ship.getVoytime());
			System.out.println(s.getAimport()+"=="+s.getOid()+"=="+s.getHavenstop());
			getHibernateTemplate().saveOrUpdate(s);
			Log.insert("ship", "modify");
			bln = true;
		} catch (Exception e) {
			// TODO Auto-generated catch block		
			e.printStackTrace();
		}
		return bln;
	}
}