山寨版--当当网源程序

package org.whatisjava.dang.action; import java.util.Date; import java.util.HashSet; import java.util.List; import java.util.Set; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpSession; import org.apache.commons.beanutils.BeanUtils; import org.apache.struts.action.ActionForm; import org.apache.struts.action.ActionForward; import org.apache.struts.action.ActionMapping; import org.apache.struts.actions.MappingDispatchAction; import org.whatisjava.dang.domain.Address; import org.whatisjava.dang.domain.Item; import org.whatisjava.dang.domain.Order; import org.whatisjava.dang.domain.SendWay; import org.whatisjava.dang.domain.User; import org.whatisjava.dang.form.AddressForm; import org.whatisjava.dang.po.CartItem; import org.whatisjava.dang.service.OrderService; import org.whatisjava.dang.util.Constants; public class OrderAction extends MappingDispatchAction { private OrderService os = new OrderService(); /** * 显示订单地址页面 */ public ActionForward showAddress(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception { HttpSession session = request.getSession(); User user = (User) session.getAttribute(Constants.SID_USER); String addressId = request.getParameter("addressId"); Address addr = new Address(); if ("".equals(addressId)) { addr = os.findAllAddress(user.getId()).get(0); } else { addr = os.findById_Address(Integer.parseInt(addressId)); } List<SendWay> sendWays = os.findAllSendWay(); request.setAttribute("sendWays", sendWays); List<Address> addresses = os.findAllAddress(user.getId()); request.setAttribute("addresses", addresses); request.setAttribute("addr", addr); return mapping.findForward("success"); } /** * 显示详细订单条目页面 */ public ActionForward showItems(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception { return mapping.findForward("success"); } /** * 显示生成订单页面 */ public ActionForward showOrder(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception { return mapping.findForward("success"); } /** * 添加送货地址信息 */ public ActionForward addAddress(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception { HttpSession session = request.getSession(); User user = (User) session.getAttribute(Constants.SID_USER); String addressId = request.getParameter("addressId"); Address add_def = os.findByUserId_Default(user.getId()); AddressForm af = (AddressForm) form; Address add = new Address(); Integer sendWayId = af.getSendWayId(); SendWay sendWay = os.findById_SendWay(sendWayId); BeanUtils.copyProperties(add, af); if ("".equals(addressId)) { // 新的发货地址 if (af.isIs_default()) { // 设置为默认地址 if (os.findAllAddress(user.getId()).size() == 0) { // 原来还没有存地址 add.setIs_default(true); os.addAddress(add); } else { // 原始已经有地址，将此次输入的地址设置为默认地址，放在第一个位置上，将原始的默认地址重新添加进入 Address add1 = os.findById_Address(add_def.getId()); add.setId(add_def.getId()); os.updateAddress(add); add1.setId(null); add1.setIs_default(false); os.addAddress(add1); } } else { // 没有设置为默认地址，直接添加 os.addAddress(add); } } else { // 更新地址信息 if (af.isIs_default()) { // 要设置为默认地址 if (Integer.parseInt(addressId) == add_def.getId()) { // 直接更新 add.setId(add_def.getId()); add.setIs_default(true); os.updateAddress(add); } else { Address add1 = os.findById_Address(add_def.getId()); add.setId(add_def.getId()); os.updateAddress(add); add1.setId(Integer.parseInt(addressId)); add1.setIs_default(false); os.updateAddress(add1); } } else { if (Integer.parseInt(addressId) == add_def.getId()) { // 直接更新 add.setId(add_def.getId()); add.setIs_default(true); os.updateAddress(add); } else { add.setId(Integer.parseInt(addressId)); os.updateAddress(add); } } } request.setAttribute("user", user); session.setAttribute("Address", add); session.setAttribute("sendWay", sendWay); return mapping.findForward("success"); } /** * 确认订单条目信息 */ public ActionForward addItems(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception { return mapping.findForward("success"); } /** * 生成订单 */ public ActionForward madeOrder(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception { HttpSession session = request.getSession(); User user = (User) session.getAttribute(Constants.SID_USER); Address addr = (Address) session.getAttribute("Address"); SendWay sendway = (SendWay) session.getAttribute("sendWay"); List<CartItem> cartItems = (List<CartItem>) session.getAttribute("buys"); Order order = new Order(); order.setAddress(addr); Double dangdangprice = (Double) session.getAttribute("dangdangprice"); order.setOrder_price(dangdangprice); order.setOrder_time(new Date().getTime()); order.setSendWay(sendway); order.setTotal_price(dangdangprice + sendway.getSend_fee()); order.setUser(user); /** * 应考虑回滚，事务一起提交一起失败的问题，批量提交,订单和条目必须一起成功一起失败 */ os.saveOrder(order); this.madeItems(cartItems,order.getId()); request.setAttribute("orderId", order.getId()); request.setAttribute("allPrice", order.getTotal_price()); return mapping.findForward("success"); } /** * 生成订单条目 */ private void madeItems(List<CartItem> cartItems, Integer oid) { /** * 应考虑回滚，事务一起提交一起失败的问题，批量提交 */ Set<Item> items = new HashSet<Item>(); for (int i = 0; i < cartItems.size(); i++) { CartItem citem = cartItems.get(i); Item item = new Item(oid, citem.getProduct().getId(), citem .getProduct().getDang_price(), citem.getNum(), citem .getProduct().getDang_price() * citem.getNum()); items.add(item); } os.saveItems(items); } }