manageaction.java

商品购物车的管理程序

package shopping;

import javax.servlet.http.*;
import java.sql.*;
import java.util.Vector;

public class manageAction {
	private Statement statement;
	private connectionDB connectiondb=new connectionDB();

    public manageAction()
    {
    	try{
      	  statement=connectiondb.setDBConnection();
      	}catch(Exception e)
      	{
      		System.out.println("connection db is error");
      	}
    }
    /**
     * 计算新商品的ID
     * @ID="P"+系统时间 年月日时分秒
     */
	public String getProductId()
	{
		String product_id="";
		product_id="P"+connectiondb.getSystemTime("yyMMddkkmmss");
		return product_id;
	}

	public void insertProduct(String op_flag,HttpServletRequest request)
                                                         throws Exception{
    	 String product_id=this.getProductId();
         request.setCharacterEncoding("GBK");
    	 String m_product_id=request.getParameter("id");
		 String product_name=request.getParameter("name");
    	 String product_desc=request.getParameter("desc");
    	 String product_price=request.getParameter("price");

    	 String sql="";
    	 if(op_flag.equals("add"))
    	 {
        	 sql="insert into products  values ('"+product_id+"',"+
             "'"+product_name+"','"+product_desc+"',"+
             "'"+product_price+"')";
    	 }
    	 else if(op_flag.equals("modify"))
    	 {
    		sql = "update  products set name='"+product_name+"',"+
    		      " snote='"+product_desc+"' ,"+
    		      " price="+product_price+" "+
    		      " where productid='" + m_product_id + "'";

    	 }
    	 System.out.println("before sql "+sql);
    	 String sql1="select * from products";

         try{
             statement.execute(sql);
             System.out.println("sql==> " + sql);
             System.out.println("sql==> " + sql1);
         	 statement.execute(sql1);
          }catch(Exception e)
          {
       	     System.out.println("insert products is error ");
          }
     }
	public void deleteProduct(String jsp_product_id)
    {
   	 String product_id=jsp_product_id;
   	 String sql = "delete from products where productid='" + product_id + "'";

   	 System.out.println("before sql "+sql);
   	 String sql1="select * from products";

        try{
        	System.out.println("sql==> " + sql);
        	statement.execute(sql);
        	System.out.println("sql==> " + sql1);
        	statement.execute(sql1);
         }catch(Exception e)
         {
      	     System.out.println("delete products is error ");
         }
    }
    /**
     * 按查询条件获得订单信息
     */
    public Vector getOrderInfo(String order_status) throws Exception {

    	order_status=(order_status==null)? "0":order_status.trim();
    	String condition="";
    	if(order_status.length()>0)
    		condition=" and orderstatus ="+order_status+"";
    	else
    		condition=" and orderstatus = 0 ";
    	Vector v_results=new Vector();
        v_results.clear();
        String sql="select distinct orderid,name,orderTime,orderstatus,ordercount,a.userid "+
                    " from orders a,users b "+
                    " where a.userid=b.userid ";
        sql+=condition;
        System.out.println(sql);
        ResultSet results=statement.executeQuery(sql);
		   while(results.next())
		   {
			   String resultsArray[]=new String[5];
			   for(int i=0;i<resultsArray.length;i++)
			   {
				   String getDBItem=results.getString(i+1);
				   getDBItem = (getDBItem==null ? "" : getDBItem.trim());
				   resultsArray[i]=getDBItem;
			   }
			   v_results.addElement(resultsArray);
		   }
		   results.close();
		   return v_results;
    }
    /**
     * 按查询条件获得订单信息
     */
	public void modifyOrderInfo(String order_id,String order_status)
    {

	 order_id=(order_id==null)?"":order_id.trim();
	 order_status=(order_status==null)?"":order_status.trim();

   	 String sql="";
   		sql = "update  orders set orderstatus="+order_status+" "+
   		      " where orderid='" + order_id + "'";

   	 System.out.println("before sql "+sql);
   	 String sql1="select * from orders";

        try{
            statement.execute(sql);
            System.out.println("sql==> " + sql);
            System.out.println("sql==> " + sql1);
            statement.execute(sql1);
         }catch(Exception e)
         {
      	     System.out.println("update orders is error ");
         }
    }
    /**
     * 按查询条件获得统计信息
     */
    public Vector getStatisticInfo(String begin_time,String end_time) throws Exception {

    	begin_time=(begin_time==null)? "":begin_time.trim();
    	end_time=(end_time==null)? "":end_time.trim();
    	String condition=" where 1=1";

        if(begin_time.length()>1)
            condition+=" and orderTime >= # "+begin_time+"# ";
        if(end_time.length()>1)
            condition+=" and orderTime <= # "+end_time+"# ";

    	Vector v_results=new Vector();
        v_results.clear();
        String sql="select a.productid,name,quantity,quantity*price "+
                   "from orderitem a,products b " +
                   "where a.productid=b.productid "+
                   " and a.orderid in "+
                   " (select orderid from orders  ) ";
        System.out.println(sql);
        ResultSet results=statement.executeQuery(sql);
        while(results.next())
	{
		 String resultsArray[]=new String[4];
		 for(int i=0;i<resultsArray.length;i++)
		 {
			 String getDBItem=results.getString(i+1);
			 getDBItem = (getDBItem==null ? "" : getDBItem.trim());
			 resultsArray[i]=getDBItem;
		 }
		v_results.addElement(resultsArray);
	 }
	results.close();
	return v_results;
    }
}