Jsp电子商务之七 订单篇2

从View页面，点击超链接查询订单,进入到控制器OrderlistServlet

package com.cart.web;

import java.io.IOException;
import java.util.*;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import com.cart.entity.*;
import com.cart.service.OrderService;

public class OrderlistServlet extends HttpServlet {
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
//从View来获取查询订单;
OrderService orderService=new OrderService();
Map<Order,ArrayList<Book>> map=(Map<Order,ArrayList<Book>>)orderService.getOrders(null, null);
HttpSession session=req.getSession();
session.setAttribute("map",map); //将订单map存放到session中；
//Iterator it=map.entrySet().iterator();
//System.out.println(map.entrySet().size());//长度为2是对的；
//下面如何获取订单对象和对应的图书详情信息呢;
//后台测试代码
// Order key;
// ArrayList<Book> value;
// while(it.hasNext()){
// Map.Entry<Order,ArrayList<Book>>entry=(Map.Entry<Order,ArrayList<Book>>)it.next();
// key=entry.getKey();
// value=entry.getValue();
//
// System.out.println("订单"+key.getId());
// System.out.println("书名\t\t价格\t数量\t总价");
// for(Book book:value){
// System.out.println(book.getBookname()+"/"+book.getImage()+"/"+book.getPrice()+"/"+book.getCount()+"/"+key.getTotal());
// }
// System.out.println();
// }
resp.sendRedirect("orderlist.jsp");
}
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
this.doGet(req, resp);
}
}
OrderService

package com.cart.service;

import java.sql.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;

import com.cart.dao.*;
import com.cart.dao.impl.*;
import com.cart.entity.Book;
import com.cart.entity.Order;
import com.cart.entity.Userinfo;
import com.cart.util.DaoFactory;
import com.cart.util.PageControler;

public class OrderService {
//1.定义属性：对dao进行操作;
OrderDao orderDao=new OrderDaoImpl();
CartDao cartDao=new CartDaoImpl();
//2.对订单,进行增删该查
public void delCartAndSaveOrder(String sbid,Userinfo user,Order order){
//使用事务操作，业务层可以这样操作，对不同的dao操作；
Connection con=null;
PreparedStatement pstmt=null;
try{
StringBuilder sbSql=new StringBuilder();
sbSql.append("delete from cartitem where uid=? and bid in(");
sbSql.append(sbid);
sbSql.append(")");
String sql=sbSql.toString();

con=DaoFactory.getConnection();
pstmt=con.prepareStatement(sql);
con.setAutoCommit(false);//设置自动提交事务，为false
orderDao.insertOrder(order);//调用杀入订单方法；，同时删除原来的购物车数据方法；
Object[] params={user.getId()};
DaoFactory.setParams(pstmt, params);
DaoFactory.executeUpdate(sql, params);

System.out.println(sbSql);

con.commit();

}catch(Exception e){
e.printStackTrace();
}finally{
DaoFactory.closeAll(null, pstmt, con);
}
}
public int insertOrder(Order order){
//ct.deletecartItem(uid, bid);
return orderDao.insertOrder(order);
}
public int updateOrder(int id){
return orderDao.updateOrder(id);
}
public int deleteOrder(int id){
return orderDao.deleteOrder(id);
}

public Order findOrderById(int id){
return orderDao.findOrderById(id);
}
public Map <Order,ArrayList<Book>> getOrders(String sql, PageControler pager) {//获取多条订单并带有详情
Connection con = null;
Map <Order,ArrayList<Book>> rtn = new HashMap <Order,ArrayList<Book>>();
try {
con = DaoFactory.getConnection();
OrderDao orderDao = new OrderDaoImpl();
rtn = orderDao.getOrders(sql, pager);
} catch (SQLException e) {
e.printStackTrace();
} finally {
DaoFactory.closeAll(null, null, con);
}
return rtn;
}
}

OrderDao的实现类
package com.cart.dao.impl;

import java.sql.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.cart.dao.OrderDao;
import com.cart.entity.Book;
import com.cart.entity.Order;
import com.cart.util.DaoFactory;
import com.cart.util.PageControler;

public class OrderDaoImpl implements OrderDao{
PreparedStatement pstmt=null;
Connection con=null;

public int deleteOrder(int id) {
return 0;
}

public Order findOrderById(int id) {
return null;
}

public int insertOrder(Order order) {
//将你所获得的订单数据，插入到数据库；
int result=-1;
try {
String sql="insert orders(userid,createtime,total,address,phone,status)values(?,?,?,?,?,?)";
con=DaoFactory.getConnection();
pstmt=con.prepareStatement(sql);
Object[] params={order.getUserid(),order.getCreatetime(),order.getTotal(),order.getShipaddress(),order.getContactphone(),order.getStatus()};
DaoFactory.setParams(pstmt, params);

result=pstmt.executeUpdate();

} catch (SQLException e) {
e.printStackTrace();
}finally{
DaoFactory.closeAll(null, pstmt, con);
}
return result;
}

public int updateOrder(int id) {
return 0;
}
、、//参数用于以后代码扩展
public Map<Order, ArrayList<Book>> getOrders(String sqlCon,
PageControler pager) throws SQLException {
List<Order> rtn = new ArrayList<Order>(); //可能会存在1个客户有多个订单，对吧;
//String sql="select O.*,OD.* from orders O inner join orderdetails OD on O.id=OD.oid";
String sql="select O.id,o.createtime,o.total,od.count,od.transprice,b.bookname,b.price,b.image" +
" from orders o inner join orderdetails od on od.oid=o.id inner join book b on b.id=od.bid";
//新的三表连接，取得book的值；
con=DaoFactory.getConnection();
pstmt=con.prepareStatement(sql);
ResultSet rs=pstmt.executeQuery();//执行结果放rs结果集;
Map<Order,ArrayList<Book>> map=new HashMap<Order,ArrayList<Book>>();

Order order=new Order();//订单对象,用于接收客户的多个订单项；
while(rs.next()){
int id=rs.getInt("id");//记录上次的一个id;6,如果和现在的id一致，则视为一个order
//直接继续，添加书本;

if(id!=order.getId()){
order.setId(rs.getInt("id"));
order.setCreatetime(rs.getDate("createtime"));
order.setTotal(rs.getDouble("total"));
}

//这个可以做好，不同订单，对应不同商品即1:1关系；不适合1：M关系；
//到此为止，已经获得了，订单的关键要素点，下面需要获得相应的订单，对应的商品详情了;
Book book=new Book();
book.setCount(rs.getInt("count"));
book.setPrice(rs.getFloat("transprice"));
book.setImage(rs.getString("image"));
book.setBookname(rs.getString("bookname"));

//设置图书表，然后添加到ArrayList里面;
if(map.get(order)==null){
ArrayList list=new ArrayList();
list.add(book);
map.put(order, list);
}else{
//应该在order不为空的情况下判断，是否重复;
ArrayList list=map.get(order);
list.add(book);
map.put(order, list);
}
}
DaoFactory.closeAll(rs, pstmt, con);
return map;
}

}
针对出现多个商品进入到一个订单的问题，已经给予解决了，其中的业务代码还可以继续修改，要继续等待哦。
OrderDaoImpl
public Map<Order, ArrayList<ShoppingItem>> getOrders(String condition,
PageControler pager) throws SQLException {
shoppingService ss = new shoppingService();
List<Order> rtn = new ArrayList<Order>(); //可能会存在1个客户有多个订单
String sql="select o.id,o.submittime,o.totalprice,b.bid,b.point,b.stock,di.bcount,b.bookname,b.b_price from d_order o inner join d_items di on di.orderId=o.id inner join d_books b on b.bid=di.bid";
//新的三表连接，取得book的值；
con=DaoFactory.getConnection();
pstmt=con.prepareStatement(sql);
ResultSet rs=pstmt.executeQuery();//执行结果放rs结果集;
Map<Order,ArrayList<ShoppingItem>> map=new HashMap<Order,ArrayList<ShoppingItem>>();

Order order=null;//订单对象,用于接收客户的多个订单项；
while(rs.next()){
if(order==null){
order=new Order(); //1.第一次，正常；
order.setId(rs.getInt("id"));
order.setSubmittime(rs.getString("submittime"));
order.setTotalprice(rs.getString("totalprice"));
ShoppingItem si = ss.declareShoppingItem(rs);
ArrayList list=new ArrayList();
list.add(si);
map.put(order, list);
}else{
if(order.getId()!=rs.getInt("id")){
order=new Order();
order.setId(rs.getInt("id"));
order.setSubmittime(rs.getString("submittime"));
order.setTotalprice(rs.getString("totalprice"));
ShoppingItem si = ss.declareShoppingItem(rs);
ArrayList list=new ArrayList();
list.add(si);
map.put(order, list);
}else{//证明是同一个订单;
ShoppingItem si = ss.declareShoppingItem(rs);
ArrayList list=map.get(order);
list.add(si);
map.put(order, list);
}
}
}
DaoFactory.closeAll(rs, pstmt, con);
return map;
}