当当网实现源码超好dangdang_struts2_jdbc

package com.yan.bo; import java.io.Serializable; import java.io.UnsupportedEncodingException; import java.util.ArrayList; import java.util.Arrays; import java.util.HashMap; import java.util.Iterator; import java.util.List; import org.apache.log4j.Logger; import com.yan.domain.Product; import com.yan.exception.DaoException; import com.yan.service.IProductSer; import com.yan.service.impl.ProductSerImpl; public class Cart implements Serializable { private static final long serialVersionUID = 1L; private transient IProductSer ips=new ProductSerImpl(); private static Logger logger = Logger.getLogger(Cart.class); private Integer userId; // CartItem.product.id private HashMap<Integer, CartItem> items; /** * 初始化购物车 * @param user */ public Cart(Integer userId) { this.userId = userId; items = new HashMap<Integer, CartItem>(); } /** * 获取UserId, 方便页面调用 * @return */ public Integer getUserId() { return userId; } /** *增加一个条目 * @param product * @return */ public boolean addItem(Integer productId) throws DaoException { logger.debug(productId); if (!items.containsKey(productId)) {//购物车没有的才能购买 Product product = ips.findProductById(productId); logger.debug(productId); CartItem item = new CartItem(); item.setProduct(product); item.setDrop(false);// item.setNumber(1);//设置数量为1 items.put(product.getId(), item); return true; } return false; } /** * 更改数量 * @param productId * @param num * @return */ public boolean updateNum(Integer productId, int num) { if (items.containsKey(productId)) {//有才能更改 if (num <= 0) { return this.drop(productId); } CartItem item = items.get(productId); item.setNumber(num);// return true; } return false; } /** * * @param productId * @return */ public boolean drop(Integer productId) { if (items.containsKey(productId)) { CartItem item = items.get(productId); item.setDrop(true); return true; } return false; } /** * * @param productId * @return */ public boolean recovery(Integer productId) { if (items.containsKey(productId)) { CartItem item = items.get(productId); item.setDrop(false); return true; } return false; } /** * */ public void clear() { items.clear(); } /** * 把购物车的信息转换为字符串，用于Cookie存儲 * * @return * @throws UnsupportedEncodingException */ public String serialize() { StringBuilder buffer = new StringBuilder(); buffer.append(userId).append("@"); if (items.isEmpty()) { buffer.append("0"); } else { Iterator<Integer> it = items.keySet().iterator(); while (it.hasNext()) { Integer productId = it.next(); logger.debug(productId); int num = items.get(productId).getNumber(); boolean drop = items.get(productId).isDrop(); buffer.append(productId + "," + num + "," + drop); buffer.append(";"); } } if (buffer.length() > 0) buffer.deleteCharAt(buffer.length() - 1);//去掉最后一个; logger.debug(buffer); return buffer.toString(); } /** * * @param content * @throws DaoException * @throws UnsupportedEncodingException */ public void load(String content) { this.items.clear();//清空后，放cookie的 String userId = content.substring(0, content.indexOf("@")); if (userId != null && Integer.parseInt(userId) == this.userId) {//怕同一台电脑， //同时被两个人用 content = content.substring(content.indexOf("@") + 1);//截取@后的内容 if (content == null || "0".equals(content))//防止空指针异常 return;//没有条目，返回空 if (content != null && content.length() > 0) { String[] itemsArry = content.split(";"); for (int i = 0; i < itemsArry.length; i++) { String[] itemArry = itemsArry[i].split(","); logger.debug(Arrays.toString(itemArry));//随时记录日志 Integer id = Integer.valueOf(itemArry[0]); int number = Integer.parseInt(itemArry[1]); boolean drop = Boolean.parseBoolean(itemArry[2]); Product product = ips.findProductById(id); CartItem item = new CartItem(); item.setProduct(product); item.setNumber(number); item.setDrop(drop); items.put(product.getId(), item); logger.debug(items); } } } } /** * * @return */ public boolean isEmpty() { return items.isEmpty(); } /** * 返回所有没有被标记为删除的 list列表 * @return */ public List<CartItem> getItems() { List<CartItem> list = new ArrayList<CartItem>(); Iterator<Integer> it = items.keySet().iterator(); while (it.hasNext()) { CartItem item = items.get(it.next()); logger.debug(item); logger.debug(item.getProduct()); logger.debug(item.getProduct().getFixedprice()); if (!item.isDrop()) { list.add(item); } } return list; } /** * 返回所有被标记为删除的list列表 * @return */ public List<CartItem> getDropItems() { List<CartItem> list = new ArrayList<CartItem>(); Iterator<Integer> it = items.keySet().iterator(); while (it.hasNext()) { CartItem item = items.get(it.next()); if (item.isDrop()) { list.add(item); } } return list; } /** * 返回市场总价格 * @return */ public double getTotalPrice() { double totalPrice = 0; Iterator<Integer> it = items.keySet().iterator(); while (it.hasNext()) { CartItem item = items.get(it.next()); if (!item.isDrop()) { totalPrice += item.getProduct().getFixedprice() * item.getNumber(); System.out.println(totalPrice+"............."+item.getProduct().getFixedprice()); } } return totalPrice; } /** * 返回dangdang市场价 * @return */ public double getDangPrice() { double dangPrice = 0; Iterator<Integer> it = items.keySet().iterator(); while (it.hasNext()) { CartItem item = items.get(it.next()); if (!item.isDrop()) { dangPrice += item.getProduct().getDangprice() * item.getNumber(); } } return dangPrice; } }