inboxoklistaction.java

功能是公安和学校的管理系统,用struts+hibernate+spring等匡架组成,在eclepse就能编译

package com.comingnet.action;

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

import com.comingnet.bean.UserInfor;
import com.comingnet.intercepter.UserSessionAware;
import com.db.DBUtils;
import com.db.page;
import com.opensymphony.xwork2.ActionSupport;

public class inboxOkListAction extends ActionSupport implements UserSessionAware{
	
	List inboxoklist=null;
	private String pageStr;                           //分页字符串
	private String pageno="1";                        //当前页
	private int pagecount=0;                          //总记录数
	private int rownum=15;                            //每页记录数
	private int pagerow=10;                           //显示多少页
	private UserInfor userSession=null;
	private String auid;
	private String auid_test;
	public String getAuid_test()
	{
		return auid_test;
	}
	public String getAuid() {
		return auid;
	}
	public void setAuid(String auid) {
		this.auid = auid;
	}

	public List getInboxoklist() {
		return inboxoklist;
	}
	public void setInboxoklist(List inboxoklist) {
		this.inboxoklist = inboxoklist;
	}
	public int getPagecount() {
		return pagecount;
	}
	public void setPagecount(int pagecount) {
		this.pagecount = pagecount;
	}
	public String getPageno() {
		return pageno;
	}
	public void setPageno(String pageno) {
		this.pageno = pageno;
	}
	public int getPagerow() {
		return pagerow;
	}
	public void setPagerow(int pagerow) {
		this.pagerow = pagerow;
	}
	public String getPageStr() {
		return pageStr;
	}
	public void setPageStr(String pageStr) {
		this.pageStr = pageStr;
	}
	public int getRownum() {
		return rownum;
	}
	public void setRownum(int rownum) {
		this.rownum = rownum;
	}
	public UserInfor getUserSession() {
		return userSession;
	}
	public void setUserSession(UserInfor userSession) {
		this.userSession = userSession;
	}
    
	public String execute()
	{
		UserInfor userinfor=getUserSession();
		int userid=userinfor.getUserid();
		String userclass=userinfor.getUserclass();
		
		
		String pageno1=getPageno(); //得到当前页
		if(pageno1==null)
			 pageno1="1";
		
		String flag;
		List newlist=new ArrayList();
		Connection conn=null;
		ResultSet rs=null;
		PreparedStatement stmt=null;
        try
        {
		  conn=DBUtils.getConnection();
		  String sqlStr="";
		  sqlStr="select count(*) from m_fwwz fw,m_fwsj sw where fw.fwid=sw.fwid and sjrid="+userid+" and sjrlb='"+userclass+"' and sjblzt='1'";
		  System.out.println(sqlStr);
		  stmt=conn.prepareStatement(sqlStr);
		  rs=stmt.executeQuery();
		  if(rs.next())
		  {
			 pagecount=rs.getInt(1);
		  }
		  setPagecount(pagecount);    //向前台传回总记录数
		  DBUtils.closeResultSet(rs);
		  DBUtils.closeStatement(stmt);
		
		  page page1=new page();
		  page1.setPageString(pagecount,rownum,Integer.parseInt(pageno1),pagerow,"auid="+getAuid());
		  String pageStr=page1.getPageString();
	      setPageStr(pageStr);                         //设置分页的字符串	
		 
	      int cupage=Integer.parseInt(pageno1)-1;
  	 
          sqlStr="select top "+rownum+" sjid,fwbt,fwfjrxm,CONVERT(varchar,fwfjsj,120) as fwfjsj,CONVERT(varchar,sjblsj,120) as sjblsj  from m_fwsj sw,m_fwwz fw  where sw.sjid not in (select top "+cupage*15+" sjid from m_fwsj  sw,m_fwwz fw  where  fw.fwid=sw.fwid and sjrid="+userid+" and sjrlb='"+userclass+"' and sjblzt='1'  order by  sjid) and fw.fwid=sw.fwid  and sjrid="+userid+" and sjrlb='"+userclass+"' and sjblzt='1'  order by sjid";
	      	
	      System.out.println(sqlStr);
	      stmt=conn.prepareStatement(sqlStr);
	      rs=stmt.executeQuery(); 

		  String name="";
		  String nameStr="user_xh";
		  int j=0;
		
		  HashMap row=null;
		  ResultSetMetaData rsmd=rs.getMetaData();
          int columnCount=rsmd.getColumnCount();	
          while(rs.next())
   	      {
              j++;
        	  row=new HashMap();
          	  for(int i=1;i<=columnCount;i++)
          	   {
                   name=rsmd.getColumnName(i);
                   row.put(nameStr,""+j);
                   row.put(name.toLowerCase(),rs.getString(i));
                }
          	newlist.add(row);
          }
          setInboxoklist(newlist);   //此处不能利用getList1(),get方法是获取从页面传过来的值
		  flag=SUCCESS;
	    }catch(Exception e)
	     {
		    System.out.println(e);
		    flag=ERROR;
         }finally
	     {
    	    DBUtils.closeResultSet(rs);
    	    DBUtils.closeStatement(stmt);
    	    DBUtils.closeConnection(conn);
	     }
         
         return flag;

    }

}