accountdaoimpl.java

一个完整的物流系统

package jp.com.cost.dao.impl;

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

import jp.com.cost.common.Log;
import jp.com.cost.dao.AccountDao;
import jp.com.cost.login.web.form.EditPassForm;
import jp.com.cost.pojo.Account;
import jp.com.cost.xt.entity.XT6101ViewEntity1;
import jp.com.cost.xt.web.form.XT6102Form;
import jp.com.cost.xt.web.form.XT6103Form;

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

public class AccountDaoImpl extends HibernateDaoSupport implements AccountDao {
	Query query;
	Session session;

	/**
	 * 查询出所有帐户信息
	 */
	public List findAllAccount() {
		// TODO Auto-generated method stub
		String SQL = "select id,aid,aname,aconnet,adept,aduty,aaddr,aremark from account";
		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);
			XT6101ViewEntity1 xt = new XT6101ViewEntity1();
			xt.setId((Integer) obj[0]);
			xt.setAid(obj[1].toString());
			xt.setAname(obj[2].toString());
			xt.setAconnet(obj[3].toString());
			xt.setAdept(obj[4].toString());
			xt.setAduty(obj[5].toString());
			xt.setAaddr(obj[6].toString());
			xt.setAremark(obj[7].toString());
			list1.add(xt);
		}
		session.close();
		return list1;
	}

	/**
	 * 向ACCOUNT表里添加新帐户信息
	 */
	public boolean addAccount(XT6102Form form) {
		// TODO Auto-generated method stub
		boolean bln = false;
		String SQL = "insert into account(aid,apass,aname,aconnet,adept,aduty,aaddr,aremark) values ('"
				+ form.getAid()
				+ "','"
				+ form.getApass()
				+ "','"
				+ form.getAname()
				+ "','"
				+ form.getAconnet()
				+ "','"
				+ form.getAdept()
				+ "','"
				+ form.getAduty()
				+ "','"
				+ form.getAaddr() + "','" + form.getAremark() + "')";
		try {
			session = getHibernateTemplate().getSessionFactory().openSession();
			query = session.createSQLQuery(SQL);
			query.executeUpdate();
			bln = true;
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		Log.insert("account", "insert");
		session.close();
		return bln;
	}

	/**
	 * 根据帐户的ID删除数据库里ACCOUNT表相应记录
	 */
	public boolean deleteAccount(int id) {
		// TODO Auto-generated method stub
		boolean bln = false;
		String SQL = "delete from account where id =" + id;
		try {
			session = getHibernateTemplate().getSessionFactory().openSession();
			query = session.createSQLQuery(SQL);
			query.executeUpdate();
			Log.insert("account", "delete");
			session.close();
			bln = true;
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return bln;
	}

	/**
	 * 根据帐户的帐号查询出相应的帐户ID
	 */
	public Account findAccountID(XT6102Form form) {
		// TODO Auto-generated method stub
		String SQL = "select id,aid,apass,aname,aconnet,adept,aduty,aaddr,aremark from account where aid="
				+ "'" + form.getAid() + "'";
		session = getHibernateTemplate().getSessionFactory().openSession();
		query = session.createSQLQuery(SQL);
		List<Object> list = query.list();
		Object[] obj = (Object[]) list.get(0);
		Account a = new Account();
		a.setId((Integer) obj[0]);
		a.setAid(obj[1].toString());
		a.setApass(obj[2].toString());
		a.setAname(obj[3].toString());
		a.setAconnet(obj[4].toString());
		a.setAdept(obj[5].toString());
		a.setAduty(obj[6].toString());
		a.setAaddr(obj[7].toString());
		a.setAremark(obj[8].toString());
		session.close();
		return a;
	}

	/**
	 * 修改相应的帐户信息
	 */
	public boolean updateAccount(XT6103Form form) {
		// TODO Auto-generated method stub
		boolean bb = false;
		try {
			String SQL = "select id,aid,apass,aname,aconnet,adept,aduty,aaddr,aremark from account where id="
					+ "'" + form.getId() + "'";
			session = getHibernateTemplate().getSessionFactory().openSession();
			query = session.createSQLQuery(SQL);
			List<Object> list = query.list();
			Object[] obj = (Object[]) list.get(0);
			Account a = new Account();
			a.setId((Integer) obj[0]);
			a.setAid(form.getAid().toString());
			a.setApass(obj[2].toString());
			a.setAname(form.getAname().toString());
			a.setAconnet(form.getAconnet().toString());
			a.setAdept(form.getAdept().toString());
			a.setAduty(form.getAduty().toString());
			a.setAaddr(form.getAaddr().toString());
			a.setAremark(form.getAremark().toString());
			getHibernateTemplate().saveOrUpdate(a);
			Log.insert("account", "modify");
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return bb;
	}

	/**
	 * 根据帐户流水号查询出相应的帐户信息
	 */
	public XT6103Form findByID(int id) {
		// TODO Auto-generated method stub
		String SQL = "select id,aid,aname,aconnet,adept,aduty,aaddr,aremark from account where id="
				+ id;
		session = getHibernateTemplate().getSessionFactory().openSession();
		query = session.createSQLQuery(SQL);
		List<Object> list = query.list();
		Object[] obj = (Object[]) list.get(0);
		XT6103Form form = new XT6103Form();
		form.setId((Integer) obj[0]);
		form.setAid(obj[1].toString());
		form.setAname(obj[2].toString());
		form.setAconnet(obj[3].toString());
		form.setAdept(obj[4].toString());
		form.setAduty(obj[5].toString());
		form.setAaddr(obj[6].toString());
		form.setAremark(obj[7].toString());
		session.close();
		return form;
	}

	/**
	 * 根据aid从account表里查询出相应的帐户信息
	 */
	public List findByAid(String aid) {
		// TODO Auto-generated method stub
		List list = null;
		try {
			String SQL = "select id,aid,aname,aconnet,adept,aduty,aaddr,aremark from account where 1=1 ";
			if (null != aid && aid.trim().length() > 0) {
				SQL = SQL + " and aid like '%" + aid + "%'";
			}
			session = getHibernateTemplate().getSessionFactory().openSession();
			query = session.createSQLQuery(SQL);
			List<Object> list1 = query.list();
			List list2 = new ArrayList();
			for (int i = 0; i < list1.size(); i++) {
				Object[] obj = (Object[]) list1.get(i);
				XT6101ViewEntity1 xt = new XT6101ViewEntity1();
				xt.setId((Integer) obj[0]);
				xt.setAid(obj[1].toString());
				xt.setAname(obj[2].toString());
				xt.setAconnet(obj[3].toString());
				xt.setAdept(obj[4].toString());
				xt.setAduty(obj[5].toString());
				xt.setAaddr(obj[6].toString());
				xt.setAremark(obj[7].toString());
				list2.add(xt);
			}
			list = list2;
			session.close();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return list;
	}

	public Account login(String aid, String apass) {
		// TODO Auto-generated method stub
		String sql = "select id,aid,aname,aconnet,adept,aduty,aaddr,aremark from account where aid='"
				+ aid + "' and apass='" + apass + "'";
		//List list = getHibernateTemplate().find(sql);
		session = getHibernateTemplate().getSessionFactory().openSession();
		query = session.createSQLQuery(sql);
		List<Object> list = query.list();
			Object[] obj = (Object[]) list.get(0);
			Account account = new Account();
			account.setId((Integer)obj[0]);
			account.setAid(obj[1].toString());
			account.setAname(obj[2].toString());
			account.setAconnet(obj[3].toString());
			account.setAdept(obj[4].toString());
			account.setAduty(obj[5].toString());
			account.setAaddr(obj[6].toString());
			account.setAremark(obj[7].toString());
		session.close();
		return account;
	}

	public boolean updatepass(EditPassForm form) {
		// TODO Auto-generated method stub
		boolean bln = false;
		String SQL = "update account SET apass='" + form.getNewpass1()
				+ "' where aid ='" + form.getAid() + "' and apass ='"
				+ form.getOldpass() + "'";
		try {
			session = getHibernateTemplate().getSessionFactory().openSession();
			query = session.createSQLQuery(SQL);
			query.executeUpdate();
			session.close();
			bln = true;
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

		return bln;
	}

	public List findAid(String aid) {
		// TODO Auto-generated method stub
		List list = null;
		try {
			String SQL = "select id,aid,aname,aconnet,adept,aduty,aaddr,aremark from account where aid='" + aid + "'";

			session = getHibernateTemplate().getSessionFactory().openSession();
			query = session.createSQLQuery(SQL);
			List<Object> list1 = query.list();
			List list2 = new ArrayList();
			for (int i = 0; i < list1.size(); i++) {
				Object[] obj = (Object[]) list1.get(i);
				XT6101ViewEntity1 xt = new XT6101ViewEntity1();
				xt.setId((Integer) obj[0]);
				xt.setAid(obj[1].toString());
				xt.setAname(obj[2].toString());
				xt.setAconnet(obj[3].toString());
				xt.setAdept(obj[4].toString());
				xt.setAduty(obj[5].toString());
				xt.setAaddr(obj[6].toString());
				xt.setAremark(obj[7].toString());
				list2.add(xt);
			}
			list = list2;
			session.close();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return list;
	}

}