inboxlistaction.java

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

package com.comingnet.action;
import java.util.*;

import com.opensymphony.xwork2.ActionSupport;
import com.db.DBUtils;
import java.sql.*;

import com.db.page;
import com.comingnet.bean.UserInfor;
import com.comingnet.intercepter.UserSessionAware;
public class inboxListAction extends ActionSupport implements UserSessionAware{
	List inboxllist=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_test;
	
	public String getAuid_test()
	{
		return auid_test;  
	}
	public List getInboxllist() {
		return inboxllist; 
	}

	public void setInboxllist(List inboxllist) {
		this.inboxllist = inboxllist;
	}

	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="";
			if(userclass.equals("1"))
			   sqlStr="select count(*) from m_fwwz where fwid not in (select fwid from m_fwsj) and fwsjid_js like '%,"+1+",%'";
			else
			   sqlStr="select count(*) from m_fwwz where fwid not in (select fwid from m_fwsj) and fwsjid_xs like '%,"+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_test());
			String pageStr=page1.getPageString();
		    setPageStr(pageStr);                         //设置分页的字符串	
			 
		    int cupage=Integer.parseInt(pageno1)-1;
		    if(userclass.equals("1"))
		    	sqlStr="select top "+rownum+" fwid,fwbt,fwsjid_js,fwsjxm_js,fwfjrid,fwfjrxm,CONVERT(varchar,fwfjsj,120) as fwfjsj from m_fwwz where fwid not in (select fwid from m_fwsj) and fwsjid_js like '%,"+userid+",%' and (fwid not in (select top "+cupage*15+" fwid  from  m_fwwz  where fwsjid_js like '%,"+userid+",%'  order by  fwid DESC))";
		    else
		    	sqlStr="select top "+rownum+" fwid,fwbt,fwsjid_js,fwsjxm_js,fwfjrid,fwfjrxm,CONVERT(varchar,fwfjsj,120) as fwfjsj from m_fwwz where fwid not in (select fwid from m_fwsj) and fwsjid_js like '%,"+userid+",%' and (fwid not in (select top "+cupage*15+" fwid  from  m_fwwz  where fwsjid_xs like '%,"+userid+",%'  order by  fwid DESC))";	
		    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);
	         }
	        setInboxllist(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;

	}

}