saledao.java

java开发购物车+网上书城

package com.xaccp.aj3q8073.dao;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

import com.xaccp.aj3q8073.db.DBManager;
import com.xaccp.aj3q8073.db.RowMapper;
import com.xaccp.aj3q8073.vo.OrderDetailVo;
import com.xaccp.aj3q8073.vo.OrderInfoVo;

public class SaleDao {
	DBManager db = new DBManager();

	/**
	 * 查询待发货的订单
	 * 
	 * @return
	 */
	public List findWaitOkOrder() {
		String sql = "select orderId,orderTime,custmorName,orderState from orderInfo where orderState=?";
		Object[] obj = new Object[] { 1 };
		List list = db.queryForList(sql, obj, new OrderMapper());
		return list;
	}

	/**
	 * 查询待付款的订单
	 * 
	 * @return
	 */
	public List findWaitPayOrder() {
		String sql = "select orderId,orderTime,custmorName,orderState from orderInfo where orderState=?";
		Object[] obj = new Object[] { 2 };
		List list = db.queryForList(sql, obj, new OrderMapper());
		return list;
	}

	/**
	 * 查询已取消的订单
	 * 
	 * @return
	 */
	public List findCancleOrder() {
		String sql = "select orderId,orderTime,custmorName,orderState from orderInfo where orderState=?";
		Object[] obj = new Object[] { 3 };
		List list = db.queryForList(sql, obj, new OrderMapper());
		return list;
	}

	/**
	 * 查询已成功的订单
	 * 
	 * @return
	 */
	public List findHistoryOrder() {
		String sql = "select orderId,orderTime,custmorName,orderState from orderInfo where orderState=?";
		Object[] obj = new Object[] { 4 };
		List list = db.queryForList(sql, obj, new OrderMapper());
		return list;
	}

	/**
	 * 查找订单详情
	 * 
	 * @param id
	 * @return
	 */
	public List findOrderDetail(String id) {
		String sql = "select b.bookName,b.bookPrice,b.bookDiscount,o.bookCount,o.orderId from orderList as o inner join  bookinfo as b on b.bookId=o.bookId where orderId=?";
		Object[] obj = new Object[] { id };
		List list = db.queryForList(sql, obj, new OrderDetailMapper());
		return list;
	}

	/**
	 * 查找订单用户
	 * 
	 * @param id
	 * @return
	 */
	public Object findOrderUser(String id) {
		String sql = "select r.custmorName,r.custmorAddress,r.custmorEmail,r.custmorPostman,r.custmorTel,r.sendStyle,r.payStyle,u.userName from orderinfo as r inner join userinfo as u on u.userId=r.userId where r.orderId=?";
		Object[] obj = new Object[] { id };
		Object jt = db.queryForObject(sql, obj, new OrderUserMapper());
		return jt;
	}
	
	/**
	 * 根据输入信息查询订单信息
	 * @param condition
	 * @return
	 */
	public List findOrderByInfo(String condition){
		String sql="select orderId,orderTime,custmorName,orderState from orderInfo where orderId like ? or custmorName like ? ";
		Object[] obj = new Object[] {"%"+condition+"%","%"+condition+"%" };
		List list=db.queryForList(sql, obj, new OrderMapper());
		return list;
	}
	
	/**
	 * 更新为发货
	 * @param id
	 */
	public void sendGoods(String id){
		String sql="update orderInfo set orderState=? where orderId=?";
		Object[] obj=new Object[]{2,id};
		db.executeUpdate(sql, obj);
	}

	/**
	 * 更新为取消
	 * @param id
	 */
	public void cancleGoods(String id){
		String sql="update orderInfo set orderState=? where orderId=?";
		Object[] obj=new Object[]{3,id};
		db.executeUpdate(sql, obj);
	}

	/**
	 * 更新为等待发货
	 * @param id
	 */
	public void renew(String id){
		String sql="update orderInfo set orderState=? where orderId=?";
		Object[] obj=new Object[]{1,id};
		db.executeUpdate(sql, obj);
	}
	
	/**
	 * 更新为历史订单
	 * @param id
	 */
	public void succeed(String id){
		String sql="update orderInfo set orderState=? where orderId=?";
		Object[] obj=new Object[]{4,id};
		db.executeUpdate(sql, obj);
	}
	class OrderUserMapper implements RowMapper {

		public Object rowMapper(ResultSet rt) throws SQLException {
			OrderDetailVo vo = new OrderDetailVo();
			vo.setCustmorName(rt.getString("custmorName"));
			vo.setCustmorAddress(rt.getString("custmorAddress"));
			vo.setCustmorEmail(rt.getString("custmorEmail"));
			vo.setCustmorPostman(rt.getString("custmorPostman"));
			vo.setCustmorTel(rt.getString("custmorTel"));
			vo.setSendStyle(rt.getString("sendStyle"));
			vo.setPayStyle(rt.getString("payStyle"));
			vo.setUserName(rt.getString("userName"));
			return vo;
		}

	}

	class OrderDetailMapper implements RowMapper {

		public Object rowMapper(ResultSet rt) throws SQLException {
			OrderDetailVo vo = new OrderDetailVo();
			vo.setOrderId(rt.getString("orderId"));
			vo.setBookName(rt.getString("bookName"));
			vo.setBookPrice(rt.getDouble("bookPrice"));
			vo.setBookDiscount(rt.getDouble("bookDiscount"));
			vo.setBookCount(rt.getInt("bookCount"));
			return vo;
		}

	}

	class OrderMapper implements RowMapper {

		public Object rowMapper(ResultSet rt) throws SQLException {
			OrderInfoVo vo = new OrderInfoVo();
			vo.setOrderId(rt.getInt("orderId"));
			vo.setOrderTime(rt.getString("orderTime"));
			vo.setCustmorName(rt.getString("custmorName"));
			vo.setOrderState(rt.getInt("orderState"));
			return vo;
		}

	}
}