cartbean.java

j2ee框架下的mvc模式的一个网上销售系统

package com.qrsx.buyflowers.beans;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Collection;



public class CartBean extends DBConnection{
	
	private PreparedStatement ptst;
	private OrderDetail orderDetail;
	private ResultSet rs=null;
	private Collection collection=null;

	public CartBean() throws ClassNotFoundException, SQLException {
		super();
		collection=new ArrayList();
		// TODO Auto-generated constructor stub
	}

	
	
	
	
	//增加购买商品
	public void addItem(String item){
		collection.add(item);
	}
	
	//删除已选商品
	public void removeItem(String item){
		collection.remove(item);
	}
	
	//获取商品
	public Collection getItems(){
		return collection;
	}
	
	//生成订单
	public OrdersClass genOrder(String usersName,float ordersPrice){
		String result=null;
		OrdersClass orders=null;
		collection=new ArrayList();
		String sql="insert into orders(usersName,ordersPrice) values(?,?);";
		try {
			ptst=con.prepareStatement(sql);
			ptst.setString(1, usersName);
			ptst.setFloat(2, ordersPrice);
			ptst.executeUpdate();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		String s="select * from orders where usersName =? and ordersPrice=?";
		try {
			ptst=con.prepareStatement(s);
			ptst.setString(1, usersName);
			ptst.setFloat(2, ordersPrice);
			rs=ptst.executeQuery();
			while(rs.next()){
				orders=new OrdersClass();
				orders.setOrdersId(rs.getString("ordersId"));
				orders.setOrdersDatetime(rs.getString("ordersDatetime"));
				orders.setUsersName(rs.getString("usersName"));
				orders.setOrdersPrice(Float.parseFloat(rs.getString("ordersPrice")));
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return orders;
	}
	
	
	//生成订单明细
	public void genOrderDetail( String ordersId,String goodsName,String goodsPrice,String goodsCount){
		String sql="insert into ordersDetails(ordersId,goodsName,goodsPrice,goodsCount) values(?,?,?,?)";
		 ArrayList collection = new ArrayList();;
		try {
			ptst=con.prepareStatement(sql);
			ptst.setString(1, ordersId);
			ptst.setString(2,goodsName);
			ptst.setString(3, goodsPrice);
			ptst.setString(4, goodsCount);
			ptst.executeUpdate();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		
	}
	
	//获取历史记录
	public Collection getOrderHistory(String usersName){
		
		
		String sql="select *  from orders where usesName=?";
		try {
			
			ptst=con.prepareStatement(sql);
			ptst.setString(1, usersName);
			rs=ptst.executeQuery();
			while(rs.next()){
				orderDetail=new OrderDetail();
				orderDetail.setGoodsCount(Integer.parseInt(rs.getString("goodsCount")));
				orderDetail.setGoodsName(rs.getString("goodsName"));
				orderDetail.setGoodsPrice(rs.getString("goodsPrice"));
				orderDetail.setOrdersId(rs.getString("ordersId"));
				collection.add(orderDetail);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	     
		return collection;
	}
}