基于struts的个人网上银行系统

package cn.com.tarena.weibing.bank.biz; import java.util.Date; import java.util.List; import org.hibernate.Transaction; import cn.com.tarena.weibing.bank.common.util.HibernateUtil; import cn.com.tarena.weibing.bank.dao.IAccountDao; import cn.com.tarena.weibing.bank.dao.ICustomerDao; import cn.com.tarena.weibing.bank.dao.IRecordDao; import cn.com.tarena.weibing.bank.dao.factory.DAOFactory; import cn.com.tarena.weibing.bank.dao.impl.AccountDaoImpl; import cn.com.tarena.weibing.bank.dao.impl.CustomerDaoImpl; import cn.com.tarena.weibing.bank.dao.impl.RecordDaoImpl; import cn.com.tarena.weibing.bank.exception.OnlineBankException; import cn.com.tarena.weibing.bank.pojo.Account; import cn.com.tarena.weibing.bank.pojo.Record; public class AccountManager { ICustomerDao dao1 = (CustomerDaoImpl)DAOFactory.getDAO(ICustomerDao.class.getName()); IAccountDao dao2 = (AccountDaoImpl)DAOFactory.getDAO(IAccountDao.class.getName()); IRecordDao dao3 = (RecordDaoImpl)DAOFactory.getDAO(IRecordDao.class.getName()); /** * 从数据库中查询所有的帐户,并返回一个List集合 * @return List<Account> * @throws OnlineBankException */ public List<Account> getAllAccounts() throws OnlineBankException { List<Account> list = null; Transaction tran = null; try { //开始一个事务 tran = HibernateUtil.getCurrentSession().beginTransaction(); //执行事务 list = dao2.findAllAccounts(); //提交事务 tran.commit(); } catch (OnlineBankException e) { //如果出现异常,就撤消事务 if( tran != null) tran.rollback(); e.printStackTrace(); }finally{ //不管事务执行成功与否,最后都要关闭Session //HibernateUtil.getCurrentSession().close(); } return list; } /** * 通过帐号num从数据库中加载一个Customer对象 * @param num * @return Account * @throws OnlineBankException */ public Account getAccountByNum(String num) throws OnlineBankException { Account act = null; Transaction tran = null; try { //开始一个事务 tran = HibernateUtil.getCurrentSession().beginTransaction(); //执行事务 act = dao2.loadAccount(num); //提交事务 tran.commit(); } catch (OnlineBankException e) { //如果出现异常,就撤消事务 if( tran != null) tran.rollback(); e.printStackTrace(); }finally{ //不管事务执行成功与否,最后都要关闭Session //HibernateUtil.getCurrentSession().close(); } return act; } /** * 在帐号为num的帐户上存款amount * @param num * @param amount * @return String * @throws OnlineBankException */ public String deposite(String num, double amount) throws OnlineBankException { Account act = null; Transaction tran = null; String str = null; try { //开始一个事务 tran = HibernateUtil.getCurrentSession().beginTransaction(); //执行事务 act=dao2.loadAccount(num); //返回一个帐户对象 if(act == null) { str = "对不起你,你输入的帐号不存在!"; return str; } act.deposite(amount); //调用该对象的取款方法 dao2.saveAccount(act); //更新保存帐户 str = "存款操作已成功!目前你的帐户余额为:"+act.getBalance(); /** 操作记录的保存 */ Date date=new Date(); Record record = new Record(act,act.getCustomer(),"存款",date.toString(),amount); dao3.saveRecord(record); //提交事务 tran.commit(); } catch (OnlineBankException e) { //如果出现异常,就撤消事务 if( tran != null) tran.rollback(); e.printStackTrace(); }finally{ //不管事务执行成功与否,最后都要关闭Session //HibernateUtil.getCurrentSession().close(); } return str; } /** * 在帐号为num的帐户上取款amount * @param num * @param amount * @return String * @throws OnlineBankException */ public String withdraw(String num, double amount) throws OnlineBankException { Account act = null; Transaction tran = null; String str = null; try { //开始一个事务 tran = HibernateUtil.getCurrentSession().beginTransaction(); //执行事务 act=dao2.loadAccount(num); //返回一个帐户对象 if(act == null) { str = "对不起你,你输入的帐号不存在!"; }else if(act.getBalance() >= amount) { act.withdraw(amount); //调用该对象的取款方法 dao2.saveAccount(act); //更新保存帐户 /** 操作记录的保存 */ Date date=new Date(); Record record = new Record(act,act.getCustomer(),"取款",date.toString(),amount); dao3.saveRecord(record); str = "取款操作已成功!目前你的帐户余额为:"+act.getBalance(); }else { str = "对不起,你的帐户余额不足!"; } //提交事务 tran.commit(); } catch (OnlineBankException e) { //如果出现异常,就撤消事务 if( tran != null) tran.rollback(); e.printStackTrace(); }finally{ //不管事务执行成功与否,最后都要关闭Session //HibernateUtil.getCurrentSession().close(); } return str; } /** * 查询帐户余额 * @param num * @return String * @throws OnlineBankException */ public String getBalance(String num) throws OnlineBankException { Account act = null; Transaction tran = null; String str = null; try { //开始一个事务 tran = HibernateUtil.getCurrentSession().beginTransaction(); //执行事务 act=dao2.loadAccount(num); //返回一个帐户对象 if(act == null) { str = "对不起你,你输入的帐号不存在!"; return str; } str = "目前你的帐户余额为:"+act.getBalance(); //提交事务 tran.commit(); } catch (OnlineBankException e) { //如果出现异常,就撤消事务 if( tran != null) tran.rollback(); e.printStackTrace(); }finally{ //不管事务执行成功与否,最后都要关闭Session //HibernateUtil.getCurrentSession().close(); } return str; } /** * 转帐 * @param FromNum * @param ToNum * @param amount * @return String * @throws OnlineBankException */ public String transfer(String FromNum, String ToNum, double amount) throws OnlineBankException { Account act1 = null; Account act2 = null; Transaction tran = null; String str = null; try { //开始一个事务 tran = HibernateUtil.getCurrentSession().beginTransaction(); //执行事务 act1=dao2.loadAccount(FromNum); //返回一个帐户对象 act2=dao2.loadAccount(ToNum); //返回一个帐户对象 if(act1 == null) { str = "对不起你,你输入的第一个帐号不存在!"; return str; } if(act2 == null) { str = "对不起你,你输入的第二个帐号不存在!"; return str; } if(act1.getBalance() < amount) { str = "对不起你,你的帐号余额不足,不允许进行转帐操作!"; return str; } act1.withdraw(amount);//调用该对象的取款方法 act2.deposite(amount);//调用该对象的存款方法 dao2.saveAccount(act1);//更新保存帐户 dao2.saveAccount(act2);//更新保存帐户 str = "恭喜你,转帐操作成功!"; /** 操作记录的保存 */ Date date=new Date(); Record record1 = new Record(act1,act1.getCustomer(),"取款",date.toString(),amount); Record record2 = new Record(act2,act2.getCustomer(),"存款",date.toString(),amount); dao3.saveRecord(record1);