purchase.java

jsp mysql 实现网上购物系统

package com.mybusiness.web;

import java.sql.*;
import java.util.Vector;
import com.mybusiness.util.*;
import javax.servlet.http.*;
import com.mybusiness.web.ware.ware;
import com.mybusiness.web.ware.indentlist;
import com.mybusiness.web.ware.indent;

/**
 *       设置订单类
 */

public class purchase extends DataBase {
	private javax.servlet.http.HttpServletRequest request; //建立页面请求
	private HttpSession session;				//页面的session;
	private boolean sqlflag = true ;			//对接收到的数据是否正确
	private Vector purchaselist;				//显示商品列表向量数组
	private Vector my_indent;						//订购单列表
	private Vector my_indent1;
	private Vector indent_list;						//订单清单列表
	private int warenumber=0;						//定购总数量
	private float all_price=0;						//定购总价钱
	private boolean isEmpty=false;					//库中的商品数量是否够购买的数
	private int leaveware=0;						//库存数量
	private String IndentNo = "";					//用户订单号
	private boolean isLogin = true;					//用户是否登录！
	private int page = 1;					//显示的页码
	private int pageSize=15;				//每页显示的订单数
	private int pageCount =0;				//页面总数
	private long recordCount =0;			//查询的记录总数


	
	public purchase() throws Exception{
		super();
	}

	public Vector getPurchaselist() {
		return purchaselist;                    //得到商品列表向量数组
	}

	public Vector getIndent_list() {
		return indent_list;                    //得到清单列表
	}

	public Vector getMy_indent() {
		return my_indent;                        //得到订购单列表
	}
	public Vector getMy_indent1() {
		return my_indent;
	}

	public boolean getSqlflag() {
		return sqlflag;
	}

	public void setIsEmpty(boolean flag){
		isEmpty = flag;
	}
	public boolean getIsEmpty() {
		return isEmpty;
	}

	public void setLeaveware(int bknum) {
		leaveware = bknum;
	}
	public int getLeaveware() {
		return leaveware;
	}
	
	public void setIndentNo(String newIndentNo) {
		IndentNo = newIndentNo;
	}

	public String getIndentNo() {
		return IndentNo;
	}

	public void setIsLogin(boolean flag){
		isLogin = flag;
	}
	public boolean getIsLogin() {
		return isLogin;
	}

	public int getPage() {				//显示的页码
		return page;
	}
	public void setPage(int newpage) {
		page = newpage;
	}

	public int getPageSize(){			//每页显示的图书数
		return pageSize;
	}
	public void setPageSize(int newpsize) {
		pageSize = newpsize;
	}

	public int getPageCount() {				//页面总数
		return pageCount;
	}
	public void setPageCount(int newpcount) {
		pageCount = newpcount;
	}

	public long getRecordCount() {
		return recordCount;
	}
	public void setRecordCount(long newrcount) {
		recordCount= newrcount;
	}

	public String getGbk( String str) {                 //转化为汉字
		try
		{
			return new String(str.getBytes("ISO8859-1"));
		}
		catch (Exception e)
		{
			return str;
		}
	}
	
//查询商品数据库语句
	public String getSql() {
		sqlStr = "select id,classname from my_ware order by id";  
		return sqlStr;
	}

	public boolean addnew(HttpServletRequest newrequest){   //添加新的商品
		request = newrequest;
		String ID = request.getParameter("wareid");
		String Amount = request.getParameter("amount");
		long wareid = 0;
		int amount = 0;
		try
		{
			wareid = Long.parseLong(ID);
			amount = Integer.parseInt(Amount);
		}
		catch (Exception e)
		{
			return false;
		}
		if (amount<1) return false;
		session = request.getSession(false);
		if (session == null)
		{
			return false;
		}
		purchaselist = (Vector)session.getAttribute("shopcar");
		sqlStr = "select leav_number from My_ware where id=" + wareid;
		try
		{
			rs = stmt.executeQuery(sqlStr);
			if (rs.next())
			{
				if (amount > rs.getInt(1))
				{
					leaveware = rs.getInt(1);
					isEmpty = true;
					return false;
				}
			}
			rs.close();
		}
		catch (SQLException e)
		{
			return false;
		}

		indentlist iList = new indentlist();
		iList.setwareNo(wareid);
		iList.setAmount(amount);
		boolean match = false;		//是否购买过该图书
		if (purchaselist==null)  //第一次购买
		{
			purchaselist = new Vector();
			purchaselist.addElement(iList);
		}
		
		else { // 不是第一次购买 				
			for (int i=0; i< purchaselist.size(); i++) { 
				indentlist itList= (indentlist) purchaselist.elementAt(i); 
				if ( iList.getwareNo() == itList.getwareNo() ) { 
					itList.setAmount(itList.getAmount() + iList.getAmount()); 
					purchaselist.setElementAt(itList,i); 
					match = true; 
					break;
				} //if name matches结束 				
			} // for循环结束 
			if (!match) 
				purchaselist.addElement(iList); 
		}
		session.setAttribute("shopcar", purchaselist); 
		return true;
		
	}

	public boolean modiShoper(HttpServletRequest newrequest) {  //修改购物车
		request = newrequest;
		String ID = request.getParameter("wareid");
		String Amount = request.getParameter("amount");
		long wareid = 0;
		int amount = 0;
		try
		{
			wareid = Long.parseLong(ID);
			amount = Integer.parseInt(Amount);
		}
		catch (Exception e)
		{
			return false;
		}
		if (amount<1) return false;
		session = request.getSession(false);
		if (session == null)
		{
			return false;
		}
		purchaselist = (Vector)session.getAttribute("shopcar");
		if (purchaselist==null)
		{
			return false;
		}
		sqlStr = "select leav_number from My_ware where id=" + wareid;
		try
		{
			rs = stmt.executeQuery(sqlStr);          //查询剩余数
			if (rs.next())
			{
				if (amount > rs.getInt(1))
				{
					leaveware = rs.getInt(1);
					isEmpty = true;
					return false;
				}
			}
			rs.close();
		}
		catch (SQLException e)
		{
			return false;
		}
		for (int i=0; i< purchaselist.size(); i++) { 
			indentlist itList= (indentlist) purchaselist.elementAt(i); 
			if ( wareid == itList.getwareNo() ) { 
				itList.setAmount(amount); 
				purchaselist.setElementAt(itList,i); 
				break;
			} //if name matches结束 				
		} // for循环结束 
		return true;
	}



	public boolean delShoper(HttpServletRequest newrequest) {   //删除商品
		request = newrequest;
		String ID = request.getParameter("wareid");
		long wareid = 0;
		try
		{
			wareid = Long.parseLong(ID);
		}
		catch (Exception e)
		{
			return false;
		}
		session = request.getSession(false);
		if (session == null)
		{
			return false;
		}
		purchaselist = (Vector)session.getAttribute("shopcar");
		if (purchaselist==null)
		{
			return false;
		}

		for (int i=0; i< purchaselist.size(); i++) { 
			indentlist itList= (indentlist) purchaselist.elementAt(i); 
			if ( wareid == itList.getwareNo() ) { 
				purchaselist.removeElementAt(i); 
				break;
			} //if name matches结束 				
		} // for循环结束 
		return true;
	}

	public boolean payout(HttpServletRequest newrequest) throws Exception {  //提交购物单
		request = newrequest;
		session = request.getSession(false);
		if (session == null)
		{
			return false;
		}
		purchaselist = (Vector)session.getAttribute("shopcar");
		//String Userid = (String) session.getAttribute("userid");  //取得用户ID号
		String Userid = (String) request.getParameter("userid");
		long userid=0;
		if (Userid==null || Userid.equals(""))     //userid 传不过来??????????
		{
			isLogin = false;
			return false;
		}else {
			try
			{
				userid = Long.parseLong(Userid);
			}
			catch (NumberFormatException e)
			{
				return false;
			}
		}
		return true;

		/*if (purchaselist==null || purchaselist.size()<0)
		{
			return true;                                   /////wrong
		}
		String Content = request.getParameter("content");
		if (Content==null)
		{
			Content="";
		}
		Content = getGbk(Content);
		String IP = request.getRemoteAddr();
		String TotalPrice = request.getParameter("totalprice");

		sqlStr = "select max(id) from My_indent";
		rs = stmt.executeQuery(sqlStr);
		if (rs.next())
		{
			IndentNo = "HYD" + userid + "" + rs.getString(1);
		} else {
			IndentNo =  "HYD" + userid + "0";
		}
		rs.close();

		sqlStr = "insert into My_indent (IndentNo,UserId,SubmitTime,ConsignmentTime,TotalPrice,content,IPAddress,IsPayoff,IsSales) values ('";
		sqlStr = sqlStr + IndentNo + "','";
		sqlStr = sqlStr + userid + "',now(),now()+7,'";
		sqlStr = sqlStr + TotalPrice + "','";
		sqlStr = sqlStr + Content + "','";
		sqlStr = sqlStr + IP + "',1,1)";
		try
		{
			stmt.execute(sqlStr);
			sqlStr= "select max(id) from My_indent where UserId = " + userid;
			rs = stmt.executeQuery(sqlStr);
			long indentid = 0;
			while (rs.next())
			{
				indentid = rs.getLong(1);
			}
			rs.close();
			for (int i=0; i<purchaselist.size() ;i++ )
			{
				indentlist iList = (indentlist) purchaselist.elementAt(i);
				sqlStr = "insert into My_indentlist (IndentNo,wareNo,Amount) values (";
				sqlStr = sqlStr + indentid + ",'";
				sqlStr = sqlStr + iList.getwareNo() + "','";
				sqlStr = sqlStr + iList.getAmount() + "')";
				stmt.execute(sqlStr);
				sqlStr = "update My_ware set leav_number=leav_number - " + iList.getAmount() + " where id = " + iList.getwareNo();
				stmt.execute(sqlStr);
			}
			return true;
		}
		catch (SQLException e)
		{
			return false;
		}*/
				
	}

	public boolean getIndent(long userid) {   //得到购物单
		sqlStr = "select * from My_indent where userid = '" +userid+ "' order by id desc";
		try
		{
			rs = stmt.executeQuery(sqlStr);
			my_indent = new Vector();
			int flag=0;
			  while (rs.next())
			 {
				flag=1;
				indent ind = new indent();
				ind.setId(rs.getLong("Id"));
				ind.setIndentNo(rs.getString("IndentNo"));
				ind.setUserId(rs.getLong("UserId"));
				ind.setSubmitTime(rs.getString("SubmitTime"));
				ind.setConsignmentTime(rs.getString("ConsignmentTime"));
				ind.setTotalPrice(rs.getFloat("TotalPrice"));
				ind.setContent(rs.getString("content"));
				ind.setIPAddress(rs.getString("IPAddress"));
				if (rs.getInt("IsPayoff")==1)
					ind.setIsPayoff(false);
				else 
					ind.setIsPayoff(true);
				if (rs.getInt("IsSales")==1)
					ind.setIsSales(false);
				else
					ind.setIsSales(true);
				my_indent.addElement(ind);
			 }
			  rs.close();
			 if(flag==0)
				 return  false;
			 else
		         return true;			
		}
		catch (SQLException e)
		{
			return false;
		}		
	}

	public boolean getOneIndent(long iid) {    //得到一类的商品的列表
		sqlStr = "select * from My_indent where id = '" +iid+ "' order by id desc";
		try
		{
			rs = stmt.executeQuery(sqlStr);
			my_indent = new Vector();
			while (rs.next())
			{
				indent ind = new indent();
				ind.setId(rs.getLong("Id"));
				ind.setIndentNo(rs.getString("IndentNo"));
				ind.setUserId(rs.getLong("UserId"));
				ind.setSubmitTime(rs.getString("SubmitTime"));
				ind.setConsignmentTime(rs.getString("ConsignmentTime"));
				ind.setTotalPrice(rs.getFloat("TotalPrice"));
				ind.setContent(rs.getString("content"));
				ind.setIPAddress(rs.getString("IPAddress"));
				if (rs.getInt("IsPayoff")==1)
					ind.setIsPayoff(false);
				else 
					ind.setIsPayoff(true);
				if (rs.getInt("IsSales")==1)
					ind.setIsSales(false);
				else
					ind.setIsSales(true);
				my_indent.addElement(ind);
			}
			rs.close();
			return true;			
		}
		catch (SQLException e)
		{
			return false;
		}		
	}

	public boolean getIndent() {             //得到订单
		sqlStr = "select count(*) from My_indent";    //取出记录数
		int rscount = pageSize;
		try
		{
			ResultSet rs1 = stmt.executeQuery(sqlStr);
			if (rs1.next()) recordCount = rs1.getInt(1);				
			rs1.close();
		}
		catch (SQLException e)
		{
			return false;
		}
		//设定有多少pageCount
		if (recordCount < 1)
            pageCount = 0;
        else
            pageCount = (int)(recordCount - 1) / pageSize + 1;
		//检查查看的页面数是否在范围内
		if (page < 1)  
            page = 1;
        else if (page > pageCount)
            page = pageCount;
		
		rscount = (int) recordCount % pageSize;	 // 最后一页记录数        

		//sql为倒序取值
		sqlStr = "select * from My_indent ";
		if (page == 1)
		{
			sqlStr = sqlStr + " order by Id desc";
		}else {
			sqlStr = sqlStr + " where Id not in ( select  Id from My_indent order by Id ) and Id in " +
			"(select Id from My_indent order by Id ) " + " order by Id desc";
		}

		try
		{
			rs = stmt.executeQuery(sqlStr);
			my_indent = new Vector();
			while (rs.next())
			{
				indent ind = new indent();
				ind.setId(rs.getLong("Id"));
				ind.setIndentNo(rs.getString("IndentNo"));
				ind.setUserId(rs.getLong("UserId"));
				ind.setSubmitTime(rs.getString("SubmitTime"));
				ind.setConsignmentTime(rs.getString("ConsignmentTime"));
				ind.setTotalPrice(rs.getFloat("TotalPrice"));
				ind.setContent(rs.getString("content"));
				ind.setIPAddress(rs.getString("IPAddress"));
				if (rs.getInt("IsPayoff")==1)
					ind.setIsPayoff(false);
				else 
					ind.setIsPayoff(true);
				if (rs.getInt("IsSales")==1)
					ind.setIsSales(false);
				else
					ind.setIsSales(true);
				my_indent.addElement(ind);
			}
			rs.close();
			return true;			
		}
		catch (SQLException e)
		{
			System.out.println(e);
			return false;
		}		
	}
	
	public boolean getIndentList(long nid) {   //查询商品类别表
		sqlStr = "select * from my_indentlist where IndentNo = '" + nid + "'";
		try
		{	
			rs = stmt.executeQuery(sqlStr);
			indent_list = new Vector();
			while (rs.next())
			{				
				indentlist identlist = new indentlist();
				identlist.setId(rs.getLong("Id"));
				identlist.setIndentNo(rs.getLong("IndentNo"));
				identlist.setwareNo(rs.getLong("wareNo"));
				identlist.setAmount(rs.getInt("Amount"));
				indent_list.addElement(identlist);
			}
			rs.close();
			return true;
		}
		catch (SQLException e)
		{
			return false;
		}		
	}

	public boolean update(HttpServletRequest res) {  //更新商品
		request = res;
		int payoff = 1;
		int sales = 1;
		long indentid =0;
		try
		{
			payoff = Integer.parseInt(request.getParameter("payoff"));
			sales = Integer.parseInt(request.getParameter("sales"));
			indentid = Long.parseLong(request.getParameter("indentid"));
			sqlStr = "update My_indent set IsPayoff = '" + payoff + "',IsSales='"+ sales +"' where id =" + indentid;
			stmt.execute(sqlStr);
			return true;
		}
		catch (Exception e)
		{
			return false;
		}		
	}

	public boolean delete(long id) {    //删除订单
		try
		{
			sqlStr = "delete from My_indentlist where indentNo =" + id;
			stmt.execute(sqlStr);
			sqlStr = "delete from My_indent where id= " + id ;
			stmt.execute(sqlStr);
			return true;
		}
		catch (SQLException e)
		{
			return false;
		}
	}

};