基于JavaWeb实现洋酒销售平台的设计与实现（二）

package cn.itbaizhan.shop.adminuser.action;
import org.apache.struts2.ServletActionContext;
import cn.itbaizhan.shop.adminuser.service.AdminUserService;
import cn.itbaizhan.shop.adminuser.vo.AdminUser;
import com.opensymphony.xwork2.ActionSupport;
import com.opensymphony.xwork2.ModelDriven;
public class AdminUserAction extends ActionSupport implements
    ModelDriven<AdminUser> {
  // 模型驱动使用的对象
  private AdminUser adminUser = new AdminUser();
  public AdminUser getModel() {
    return adminUser;
  }
  // 注入AdminUserService
  private AdminUserService adminUserService;
  public void setAdminUserService(AdminUserService adminUserService) {
    this.adminUserService = adminUserService;
  }
  // 后台登录的执行的方法
  public String login() {
    // 调用service方法完成登录
    AdminUser existAdminUser = adminUserService.login(adminUser);
    // 判断
    if (existAdminUser == null) {
      // 用户名或密码错误
      this.addActionError("用户名或密码错误!");
      return "loginFail";
    } else {
      // 登录成功:
      ServletActionContext.getRequest().getSession()
          .setAttribute("existAdminUser", existAdminUser);
      return "loginSuccess";
    }
  }
}

package cn.itbaizhan.shop.cart.action;
import org.apache.struts2.ServletActionContext;
import cn.itbaizhan.shop.cart.vo.Cart;
import cn.itbaizhan.shop.cart.vo.CartItem;
import cn.itbaizhan.shop.product.service.ProductService;
import cn.itbaizhan.shop.product.vo.Product;
import com.opensymphony.xwork2.ActionSupport;
/**
 * 购物车Action
 */
public class CartAction extends ActionSupport {
  // 接收pid
  private Integer pid;
  // 接收数量count
  private Integer count;
  // 注入商品的Service
  private ProductService productService;
  public void setProductService(ProductService productService) {
    this.productService = productService;
  }
  public void setPid(Integer pid) {
    this.pid = pid;
  }
  public void setCount(Integer count) {
    this.count = count;
  }
  // 将购物项添加到购物车:执行的方法
  public String addCart() {
    // 封装一个CartItem对象.
    CartItem cartItem = new CartItem();
    // 设置数量:
    cartItem.setCount(count);
    // 根据pid进行查询商品:
    Product product = productService.findByPid(pid);
    // 设置商品:
    cartItem.setProduct(product);
    // 将购物项添加到购物车.
    // 购物车应该存在session中.
    Cart cart = getCart();
    cart.addCart(cartItem);
    return "addCart";
  }
  // 清空购物车的执行的方法:
  public String clearCart(){
    // 获得购物车对象.
    Cart cart = getCart();
    // 调用购物车中清空方法.
    cart.clearCart();
    return "clearCart";
  }
  // 从购物车中移除购物项的方法:
  public String removeCart(){
    // 获得购物车对象
    Cart cart = getCart();
    // 调用购物车中移除的方法:
    cart.removeCart(pid);
    // 返回页面:
    return "removeCart";
  }
  // 我的购物车:执行的方法
  public String myCart(){
    return "myCart";
  }
  /**
   * 获得购物车的方法:从session中获得购物车.
   * @return
   */
  private Cart getCart() {
    Cart cart = (Cart) ServletActionContext.getRequest().getSession()
        .getAttribute("cart");
    if (cart == null) {
      cart = new Cart();
      ServletActionContext.getRequest().getSession()
          .setAttribute("cart", cart);
    }
    return cart;
  }
}

package cn.itbaizhan.shop.order.action;
import java.io.IOException;
import java.util.Date;
import org.apache.struts2.ServletActionContext;
import cn.itbaizhan.shop.cart.vo.Cart;
import cn.itbaizhan.shop.cart.vo.CartItem;
import cn.itbaizhan.shop.order.service.OrderService;
import cn.itbaizhan.shop.order.vo.Order;
import cn.itbaizhan.shop.order.vo.OrderItem;
import cn.itbaizhan.shop.user.vo.User;
import cn.itbaizhan.shop.utils.PageBean;
import cn.itbaizhan.shop.utils.PaymentUtil;
import com.opensymphony.xwork2.ActionContext;
import com.opensymphony.xwork2.ActionSupport;
import com.opensymphony.xwork2.ModelDriven;
/**
 * 订单Action类
 */
public class OrderAction extends ActionSupport implements ModelDriven<Order> {
  // 模型驱动使用的对象
  private Order order = new Order();
  public Order getModel() {
    return order;
  }
  // 接收支付通道编码:
  private String pd_FrpId;
  public void setPd_FrpId(String pd_FrpId) {
    this.pd_FrpId = pd_FrpId;
  }
  // 接收付款成功后的参数:
  private String r3_Amt;
  private String r6_Order;
  public void setR3_Amt(String r3_Amt) {
    this.r3_Amt = r3_Amt;
  }
  public void setR6_Order(String r6_Order) {
    this.r6_Order = r6_Order;
  }
  // 接收page
  private Integer page;
  public void setPage(Integer page) {
    this.page = page;
  }
  // 注入OrderService
  private OrderService orderService;
  public void setOrderService(OrderService orderService) {
    this.orderService = orderService;
  }
  // 生成订单的执行的方法:
  public String saveOrder() {
    // 调用Service完成数据库插入的操作:
    // Order order = new Order();
    // 设置订单的总金额:订单的总金额应该是购物车中总金额:
    // 购物车在session中,从session总获得购物车信息.
    Cart cart = (Cart) ServletActionContext.getRequest().getSession()
        .getAttribute("cart");
    if (cart == null) {
      this.addActionMessage("亲!您还没有购物!");
      return "msg";
    }
    order.setTotal(cart.getTotal());
    // 设置订单的状态
    order.setState(2); // 1:未付款.
    // 设置订单时间
    order.setOrdertime(new Date());
    // 设置订单关联的客户:
    User existUser = (User) ServletActionContext.getRequest().getSession()
        .getAttribute("existUser");
    if (existUser == null) {
      this.addActionMessage("亲!您还没有登录!");
      return "msg";
    }
    order.setUser(existUser);
    // 设置订单项集合:
    for (CartItem cartItem : cart.getCartItems()) {
      // 订单项的信息从购物项获得的.
      OrderItem orderItem = new OrderItem();
      orderItem.setCount(cartItem.getCount());
      orderItem.setSubtotal(cartItem.getSubtotal());
      orderItem.setProduct(cartItem.getProduct());
      orderItem.setOrder(order);
      order.getOrderItems().add(orderItem);
    }
    orderService.save(order);
    // 清空购物车:
    cart.clearCart();
    // 页面需要回显订单信息:
    // 使用模型驱动了 所有可以不使用值栈保存了
    // ActionContext.getContext().getValueStack().set("order", order);
    return "saveOrder";
  }
  // 查询我的订单:
  public String findByUid() {
    // 获得用户的id.
    User existUser = (User) ServletActionContext.getRequest().getSession()
        .getAttribute("existUser");
    // 获得用户的id
    Integer uid = existUser.getUid();
    // 根据用户的id查询订单:
    PageBean<Order> pageBean = orderService.findByUid(uid, page);
    // 将PageBean数据带到页面上.
    ActionContext.getContext().getValueStack().set("pageBean", pageBean);
    return "findByUid";
  }
  // 根据订单id查询订单:
  public String findByOid() {
    order = orderService.findByOid(order.getOid());
    return "findByOid";
  }
  // 为订单付款:
  public String payOrder() throws IOException {
    // 1.修改数据:
    Order currOrder = orderService.findByOid(order.getOid());
    currOrder.setAddr(order.getAddr());
    currOrder.setName(order.getName());
    currOrder.setPhone(order.getPhone());
    // 修改订单
    orderService.update(currOrder);
    this.addActionMessage("亲!提交成功!");
    return "msg";
  }
  // 付款成功后跳转回来的路径:
  public String callBack(){
    // 修改订单的状态:
    Order currOrder = orderService.findByOid(Integer.parseInt(r6_Order));
    // 修改订单状态为2:已经付款:
    currOrder.setState(2);
    orderService.update(currOrder);
    this.addActionMessage("支付成功!订单编号为: "+r6_Order +" 付款金额为: "+r3_Amt);
    return "msg";
  }
  // 修改订单的状态:
  public String updateState(){
    Order currOrder = orderService.findByOid(order.getOid());
    currOrder.setState(4);
    orderService.update(currOrder);
    return "updateStateSuccess";
  }
}