Spring2.0宝典-SSH网上拍卖系统

package org.yeeku.service; import org.apache.log4j.Logger; import java.util.List; import java.util.ArrayList; import java.util.Iterator; import java.util.Date; import java.util.Calendar; import org.yeeku.business.*; import org.yeeku.dao.*; import org.yeeku.model.*; import org.yeeku.exception.AuctionException; import org.springframework.mail.MailException; import org.springframework.mail.MailSender; import org.springframework.mail.SimpleMailMessage; /** * @author yeeku.H.lee kongyeeku@163.com * @version 1.0 * <br>Copyright (C), 2005-2008, yeeku.H.Lee * <br>This program is protected by copyright laws. * <br>Program Name: * <br>Date: */ public class AuctionManagerImpl implements AuctionManager { static Logger log = Logger.getLogger(AuctionManagerImpl.class.getName()); private AuctionUserDao userDao; private BidDao bidDao; private ItemDao itemDao; private KindDao kindDao; private StateDao stateDao; private MailSender mailSender; private SimpleMailMessage message; public void setUserDao(AuctionUserDao userDao) { this.userDao = userDao; } public void setBidDao(BidDao bidDao) { this.bidDao = bidDao; } public void setItemDao(ItemDao itemDao) { this.itemDao = itemDao; } public void setKindDao(KindDao kindDao) { this.kindDao = kindDao; } public void setStateDao(StateDao stateDao) { this.stateDao = stateDao; } public void setMailSender(MailSender mailSender) { this.mailSender = mailSender; } public void setMessage(SimpleMailMessage message) { this.message = message; } /** * 根据赢取者查询物品 * @param winerId 赢取者id * @return 赢取者获得的全部物品 */ public List getItemByWiner(int winerId) throws AuctionException { try { List result = new ArrayList(); List items = itemDao.findItemByWiner(new Integer(winerId)); for (Iterator it = items.iterator() ; it.hasNext() ; ) { Item item = (Item)it.next(); ItemBean ib = new ItemBean(); initItem(ib,item); result.add(ib); } return result; } catch (Exception e) { log.debug(e.getMessage()); throw new AuctionException("底层业务异常,请重新试"); } } /** * 查询全部流拍的物品 * @return 全部流拍物品 */ public List getFailItems() throws AuctionException { try { List result = new ArrayList(); List items = itemDao.findItemByState(new Integer(3)); for (Iterator it = items.iterator() ; it.hasNext() ; ) { Item item = (Item)it.next(); ItemBean ib = new ItemBean(); initItem(ib,item); result.add(ib); } return result; } catch (Exception e) { log.debug(e.getMessage()); throw new AuctionException("底层业务异常,请重新试"); } } /** * 查询用户的全部出价 * @param userId 需查询的用户id * @return 用户的全部出价 */ public List getBidByUser(int userId) throws AuctionException { try { List l = bidDao.findByUser(new Integer(userId)); List result = new ArrayList(); for ( int i = 0 ; i < l.size() ; i++ ) { Bid bid = (Bid)l.get(i); BidBean bb = new BidBean(); initBid(bb, bid); result.add(bb); } return result; } catch (Exception e) { log.debug(e.getMessage()); throw new AuctionException("底层业务异常,请重新试"); } } /** * 根据用户名，密码验证登陆是否成功 * @param username 登陆所输入的用户名 * @param pass 登陆的密码 * @return 全部流拍物品 */ public Integer validLogin(String username , String pass) throws AuctionException { try { return userDao.findUserByNameAndPass(username , pass); } catch (Exception e) { log.debug(e.getMessage()); throw new AuctionException("底层业务异常,请重新试"); } } /** * 根据用户id查找目前仍在拍卖中的物品 * @param userId 用户id * @return 当前用户所有的全部物品。 */ public List getItemsByOwner(int userId) throws AuctionException { try { List result = new ArrayList(); List items = itemDao.findItemByOwner(new Integer(userId)); for (Iterator it = items.iterator() ; it.hasNext() ; ) { Item item = (Item)it.next(); ItemBean ib = new ItemBean(); initItem(ib,item); result.add(ib); } return result; } catch (Exception e) { log.debug(e.getMessage()); throw new AuctionException("底层业务异常,请重新试"); } } /** * 查询全部状态 * @return 获得全部种类 */ public List getAllKind() throws AuctionException { try { return kindDao.findAll(); } catch (Exception e) { log.debug(e.getMessage()); throw new AuctionException("底层业务异常,请重新试"); } } /** * 添加物品 * @param name 物品名称 * @param desc 物品描述 * @param remark 物品备注 * @param avail 有效天数 * @param kind 物品种类 */ public void addItem(String name , String desc , String remark , double initPrice , int avail , int kind , int userId) throws AuctionException { try { Kind k = kindDao.get(new Integer(kind)); AuctionUser owner = userDao.get(new Integer(userId)); Item item = new Item(); item.setItemName(name); item.setItemDesc(desc); item.setItemPic(remark); item.setAddtime(new Date()); Calendar c = Calendar.getInstance(); c.add(Calendar.DATE , avail); item.setEndtime(c.getTime()); item.setInitPrice(new Double(initPrice)); item.setMaxPrice(new Double(initPrice)); item.setItemState(stateDao.get(new Integer(1))); item.setKind(k); item.setOwner(owner); itemDao.save(item); } catch (Exception e) { log.debug(e.getMessage()); throw new AuctionException("底层业务异常,请重新试"); } } /** * 添加种类 * @param name 种类名称 * @param desc 种类描述 */ public void addKind(String name , String desc ) throws AuctionException { try { Kind k = new Kind(); k.setKindName(name); k.setKindDesc(desc); kindDao.save(k); } catch (Exception e) { log.debug(e.getMessage()); throw new AuctionException("底层业务异常,请重新试"); } } /** * 根据产品分类，获取当前拍卖的全部商品 * @param kindId 种类id; * @return 该类的全部产品 */ public List getItemsByKind(int kindId) throws AuctionException { try { List result = new ArrayList(); List items = itemDao.findItemByKind(new Integer(kindId)); for (Iterator it = items.iterator() ; it.hasNext() ; ) { Item item = (Item)it.next(); ItemBean ib = new ItemBean();