openaccountbean.java

EJB的网上银行系统,非常具有参考价值

package bankonlinesystem.openaccount.ejb.session;

import javax.ejb.SessionBean;
import javax.ejb.SessionContext;
import javax.ejb.CreateException;
import bankonlinesystem.openaccount.dto.*;
import javax.naming.Context;
import javax.naming.InitialContext;
import bankonlinesystem.openaccount.ejb.entity.*;
import bankonlinesystem.openaccount.ejb.entity.AccountHome;
import bankonlinesystem.openaccount.ejb.entity.Account;
import bankonlinesystem.openaccount.controller.*;
import bankonlinesystem.common.util.ContextUtil;
import java.math.BigDecimal;
import bankonlinesystem.common.util.*;
import java.util.ArrayList;
import java.util.Iterator;

public class OpenAccountBean implements SessionBean {
    SessionContext sessionContext;
    public void ejbCreate() throws CreateException {
    }

    public void ejbRemove() {
    }

    public void ejbActivate() {
    }

    public void ejbPassivate() {
    }


    public void setSessionContext(SessionContext sessionContext) {
        this.sessionContext = sessionContext;
    }

//注册
    public void register(AccountDto account) {
        try {
            //通过上下文，去取实体Bean操作
            Context context = new InitialContext();
            AccountHome home = (AccountHome) context.lookup("Account");
            home.create(account);
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

//登录
    public int login(String user, String password) {
        try {
            Context context = new InitialContext();
            AccountHome home = (AccountHome) context.lookup("Account");
            Account account = home.findByPrimaryKey(user);
            //帐号不存在
            if (account == null) {
                return 1;
            }
            //密码不正确
            if (!account.getPassword().equals(password)) {
                return 2;
            }
        } catch (Exception ex) {
            return 3;
        }
        System.out.println("4");
        return 4;
    }

//更新javaBean的数据封装
    public AccountDto getAccount(String user) {
        System.out.println("进入1--更新javaBean的数据封装");
        AccountDto accountDto = new AccountDto();
        try {
            Context context = new InitialContext();
            AccountHome accountHome = (AccountHome) context.lookup("Account");
            Account account = accountHome.findByPrimaryKey(user);
            accountDto.setID(account.getId());
            accountDto.setName(account.getName());
            accountDto.setPassword(account.getPassword());
            accountDto.setIdentityCard(account.getIdentityCard());
            accountDto.setOpenBank(account.getOpenBank());
            accountDto.setBalance(account.getBalance());
            accountDto.setOpenDate(account.getOpenDate());
            accountDto.setStatus(account.getStatus());
            return accountDto;
        } catch (Exception ex) {
            return null;
        }
    }

//交易信息-存款》取款
    public void modifyMondy(String id, String operator, BigDecimal money) {
        try {
            Context context = new InitialContext();
            AccountHome accountHome = (AccountHome) context.lookup("Account");
            Account account = accountHome.findByPrimaryKey(id);
            if (operator.equals("存款")) {
                account.setBalance(account.getBalance().add(money));
            }

            if (operator.equals("取款")) {
                //取余额与输入的金额比较
                if (account.getBalance().compareTo(money) >= 0) {
                    account.setBalance(account.getBalance().subtract(money));
                } else {
                    throw new Exception("余额不足...不能进行操作");
                }
            }
            //封装数据
            RecordDto recordDto = new RecordDto();
            recordDto.setID(id);
            recordDto.setRecordID(RandomAccount.accountId());
            recordDto.setIsDeposit(operator);
            recordDto.setMoney(money);
            recordDto.setRecordDate(getDate.getNowTime());
            //调用实体Bean的操作
            RecordHome recordHome = (RecordHome) context.lookup("Record");
            Record record = recordHome.create(recordDto);
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

//修改密码
    public void changPassword(String id, String password) {
        try {
            Context context = new InitialContext();
            AccountHome accountHome = (AccountHome) context.lookup("Account");
            Account account = accountHome.findByPrimaryKey(id);
            account.setPassword(password);
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

//得到所有交易信息集合
    public ArrayList getAllRecordByID(String id) {
        ArrayList list = new ArrayList();
        try {
            Context context = new InitialContext();
            RecordHome recordHome = (RecordHome) context.lookup("Record");
            Iterator iterator = recordHome.findGetAllRecordByID(id).iterator();
            while (iterator.hasNext()) {
                Record record = (Record) iterator.next();
                RecordDto recordDto = new RecordDto();
                recordDto.setID(record.getId());
                recordDto.setRecordID(record.getRecordID());
                recordDto.setIsDeposit(record.getIsDeposit());
                recordDto.setMoney(record.getMoney());
                recordDto.setRecordDate(getDate.getNowTime());
                list.add(recordDto);
            }
        } catch (Exception ex) {
            ex.printStackTrace();
            return null;
        }
        return list;
    }
}