sellwaitaction.java

交易撮合系统是一套买卖信息沟通的平台

package struts.userplatformaction;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;

import struts.page.QueryPageBean;
import conn.DBConnection;
import domain.Offers;
import domain.Users;

public class SellWaitAction extends Action{
    public ActionForward execute(ActionMapping mapping,ActionForm form,HttpServletRequest request,HttpServletResponse response){
    	
    	Connection conn = DBConnection.getConn();
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		
		List<Offers> olist = new ArrayList<Offers>();
		Offers off = null;
		Users u = (Users)request.getSession().getAttribute("user");
    	String email = u.getEmail();
		
		String sql = "SELECT count(*) FROM webpk.offers o WHERE o.email='"+email+"' AND o.trade=1 AND o.state='发贴中'";
		int page;
    	int pageSize = 2;
    	QueryPageBean qpb = new QueryPageBean();
		int totalRow = qpb.getRowNumber(sql);
    	int totalPage = qpb.getTotalPage(sql,pageSize);
    	String page0 = request.getParameter("Page");
    	if(page0 != null && page0 != ""){
    		page = Integer.parseInt(page0);
    	}else{
    		page = 1;
    	}
    	
    	if(page < 0){
    		page = 1;
    	}
    	if(page > totalPage){
    		page = totalPage;
    	}
    	
		String ssql = "SELECT p.title productstitle,o.amount,o.price,o.post_time,o.end_time,o.state  FROM webpk.products p inner join webpk.offers o WHERE o.trade=1 AND o.state='发贴中' AND o.email=? AND p.productsid=o.productsid limit ?,?";
		int start = (page-1)*pageSize;
		try{
			pstmt = conn.prepareStatement(ssql);
			pstmt.setString(1, email);
			pstmt.setInt(2, start);
    		pstmt.setInt(3, pageSize);
			rs = pstmt.executeQuery();
			
			while(rs.next()){
				off = new Offers();
				off.setAmount(rs.getInt("amount"));			
				
				off.setEnd_time(rs.getDate("end_time"));				
				off.setPost_time(rs.getDate("post_time"));
				off.setPrice(rs.getDouble("price"));				
				
				
				off.setState(rs.getString("state"));
				off.setProductstitle(rs.getString("productstitle"));
				olist.add(off);
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			DBConnection.closeConn();
		}
		request.setAttribute("totalRecord", totalRow);		
		request.setAttribute("totalPage", totalPage); 
		request.setAttribute("whichpage", page);
    	
    	request.setAttribute("offer", olist);
    	return mapping.findForward("sellwait");
    }
}