salessessionfacadebean.java

EJB+Struts+Webservice实现的开放式基金管理系统

package com.fund.sales;

import javax.ejb.SessionBean;
import javax.ejb.SessionContext;
import javax.ejb.CreateException;
import com.fund.ServiceLocator;
import com.fund.ServiceLocatorException;
import java.util.List;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.Collection;
import javax.ejb.EJBException;

/**
 *
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2005</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class SalesSessionFacadeBean implements SessionBean {
    /**
     * serialVersionUID
     */
    private static final long serialVersionUID = 1L;
    /**
     * sessionContext
     */
    SessionContext sessionContext;
    /**
     * salesHome
     */
    private SalesHome salesHome;
    /**
     *
     * @throws CreateException e
     */
    public void ejbCreate() throws CreateException {
    }

    /**
     * ejbRemove
     */
    public void ejbRemove() {
    }

    /**
     * ejbActivate
     */
    public void ejbActivate() {
    }

    /**
     * ejbPassivate
     */
    public void ejbPassivate() {
    }

    /**
     * setSessionContext
     * @param sessionContext SessionContext
     */
    public void setSessionContext(SessionContext sessionContext) {
        this.sessionContext = sessionContext;
        try {
            findSalesHome();
        } catch (Exception e) {
            throw new EJBException(e.getMessage());
        }
    }

    /**
     *
     * @param salesDto SalesDto
     * @throws EJBException e
     */
    public void createSales(SalesDto salesDto) throws EJBException {
        if (salesDto == null) {
            return;
        }
        try {
            Sales sales = salesHome.create(salesDto.getSalesNo());
            setSalesFromSalesDto(sales, salesDto);
        } catch (Exception e) {
            throw new EJBException(e.getMessage());
        }
    }

    /**
     *
     * @param salesNo Integer
     * @throws EJBException e
     */
    public void removeSales(Integer salesNo) throws EJBException {
        try {
            salesHome.remove(salesNo);
        } catch (Exception e) {
            throw new EJBException(e.getMessage());
        }
    }

    /**
     *
     * @param salesDto SalesDto
     * @throws EJBException e
     */
    public void removeSales(SalesDto salesDto) throws EJBException {
        if (salesDto != null) {
            Integer salesNo = salesDto.getSalesNo();
            removeSales(salesNo);
        }
    }

    /**
     *
     * @param salesDto SalesDto
     * @throws EJBException e
     */
    public void updateSales(SalesDto salesDto) throws EJBException {
        if (salesDto != null) {
            Integer salesNo = salesDto.getSalesNo();
            try {
                Sales sales = salesHome.findByPrimaryKey(salesNo);
                setSalesFromSalesDto(sales, salesDto);
            } catch (Exception e) {
                throw new EJBException(e.getMessage());
            }
        }
    }

    /**
     *
     * @param salesDtos SalesDto[]
     * @throws EJBException e
     */
    public void updateSaless(SalesDto[] salesDtos) throws EJBException {
        if (salesDtos != null) {
            for (int i = 0; i < salesDtos.length; i++) {
                updateSales(salesDtos[i]);
            }
        }
    }

    /**
     *
     * @param salesNo Integer
     * @return SalesDto
     * @throws EJBException e
     */
    public SalesDto salesFindByPrimaryKey(Integer salesNo) throws EJBException {
        try {
            return assembleSalesDto(salesHome.findByPrimaryKey(salesNo));
        } catch (Exception e) {
            throw new EJBException(e.getMessage());
        }
    }

    /**
     *
     * @param username String
     * @param password String
     * @return SalesDto
     * @throws EJBException e
     */
    public SalesDto salesFindByLogin(String username, String password) throws
            EJBException {
        try {
            return assembleSalesDto(salesHome.findByLogin(username, password));
        } catch (Exception e) {
            throw new EJBException(e.getMessage());
        }
    }

    /**
     *
     * @param sales Sales
     * @param salesDto SalesDto
     */
    private void setSalesFromSalesDto(Sales sales, SalesDto salesDto) {
        sales.setUsername(salesDto.getUsername());
        sales.setPassword(salesDto.getPassword());
        sales.setRealname(salesDto.getRealname());
        sales.setSex(salesDto.getSex());
        sales.setCreatedDate(salesDto.getCreatedDate());
    }

    /**
     *
     * @throws EJBException e
     */
    private void findSalesHome() throws EJBException {
        String ENTITY_NAME = "java:comp/env/ejb/sales";
        if (salesHome == null) {
            try {
                ServiceLocator locator = ServiceLocator.getInstance();
                salesHome = (SalesHome) locator.getEjbLocalHome(ENTITY_NAME);
            } catch (ServiceLocatorException e) {
                throw new EJBException(e.getMessage());
            }
        }
    }

    /**
     *
     * @param sales Sales
     * @return SalesDto
     */
    private SalesDto assembleSalesDto(Sales sales) {
        return SalesDtoAssembler.createDto(sales);
    }

    /**
     *
     * @param saless Collection
     * @return SalesDto[]
     */
    private SalesDto[] assembleSalesDtos(Collection saless) {
        List list = new ArrayList();
        if (saless != null) {
            Iterator iterator = saless.iterator();
            while (iterator.hasNext()) {
                Sales sales = (Sales) iterator.next();
                list.add(assembleSalesDto(sales));
            }
        }
        SalesDto[] returnArray = new SalesDto[list.size()];
        return (SalesDto[]) list.toArray(returnArray);
    }
}