reqmessage.java

一个小型的BBS系统

package com.servlet;

import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Date;
import java.util.Vector;

import bean.check.CheckMessage;
import bean.dbwrite.DBFormWrite;
import bean.dbwrite.DBWrite;
import bean.readdb.*;

import javax.servlet.RequestDispatcher;
import javax.servlet.ServletConfig;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
/**
 * Servlet implementation class for Servlet: ReqMessage
 *
 */
 public class ReqMessage extends javax.servlet.http.HttpServlet implements javax.servlet.Servlet {
   static final long serialVersionUID = 1L;
   
    /* (non-Java-doc)
	 * @see javax.servlet.http.HttpServlet#HttpServlet()
	 */
	public ReqMessage() {
		super();
	}   	
	
	/* (non-Java-doc)
	 * @see javax.servlet.http.HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
	 */
	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		// TODO Auto-generated method stub
		String url;
		ServletContext sc = getServletContext();
		String action = (String)request.getParameter("action");
		
		if(action.equals("sendmessage")){
			DBRead dbr = new DBRead();
			String ID_author = new String(request.getParameter("ID").getBytes("iso-8859-1"),"GB2312");
			String ID = dbr.DBReader_id(ID_author);//查出ID
			String title = new String(request.getParameter("retitle").getBytes("iso-8859-1"),"GB2312");
			String content =  new String(request.getParameter("recontent").getBytes("iso-8859-1"),"GB2312");
			Date date = new Date();
			String time = date.toLocaleString();
			String whosendid = new String(request.getParameter("whosend").getBytes("iso-8859-1"),"GB2312");
			String whosend = dbr.DBReader_author(whosendid);//获取昵称 
			CheckMessage cm =new CheckMessage();
			int num = cm.CheckNumOfMessage(ID);
			num +=1;
			int number = cm.CheckNumOfMessage();
			number+=1;
			DBWrite dbw = new DBWrite();
			dbw.WriteMessage(ID, title, content, time, whosend, num,number);//写入数据库
			
			url="/messagesucessful.jsp?userid="+whosendid;
			RequestDispatcher rd = sc.getRequestDispatcher(url);
			rd.forward(request, response);
		}
		else if(action.equals("sendto")){
			String whosendid = (String)request.getParameter("whosend");
			String author = new String(request.getParameter("author").getBytes("iso-8859-1"),"GB2312");
			DBRead dbr = new DBRead();
			String ID= dbr.DBReader_id(author);
			String whosend = dbr.DBReader_author(whosendid);
			
			request.setAttribute("whosend", whosend);
			request.setAttribute("ID", ID);
			request.setAttribute("author", author);
			
			url="/sendto.jsp";
			RequestDispatcher rd = sc.getRequestDispatcher(url);
			rd.forward(request, response);
		}
		else if(action.equals("sendthemessage")){
			String ID = (String)request.getParameter("ID");
			String title = new String(request.getParameter("title").getBytes("iso-8859-1"),"GB2312");
			
			String content =  new String(request.getParameter("content").getBytes("iso-8859-1"),"GB2312");
			Date date = new Date();
			String time = date.toLocaleString();
			String whosend = new String(request.getParameter("whosend").getBytes("iso-8859-1"),"GB2312");
			CheckMessage cm =new CheckMessage();
			int num = cm.CheckNumOfMessage(ID);
			num +=1;
			int number = cm.CheckNumOfMessage();
			number+=1;
			DBWrite dbw = new DBWrite();
			dbw.WriteMessage(ID, title, content, time, whosend, num,number);//写入数据库
			
			DBRead dbr = new DBRead();
			String userid = dbr.DBReader_id(whosend);
			url="/messagesucessful.jsp?userid="+userid;
			RequestDispatcher rd = sc.getRequestDispatcher(url);
			rd.forward(request, response);
		}
		else if(action.equals("sendthismessage")){
			String author = new String(request.getParameter("author").getBytes("iso-8859-1"),"GB2312");
			DBRead dbr = new DBRead();
			String ID= dbr.DBReader_id(author);
			String title = new String(request.getParameter("title").getBytes("iso-8859-1"),"GB2312");
			
			String content =  new String(request.getParameter("content").getBytes("iso-8859-1"),"GB2312");
			Date date = new Date();
			String time = date.toLocaleString();
			String whosend = new String(request.getParameter("whosend").getBytes("iso-8859-1"),"GB2312");
			CheckMessage cm =new CheckMessage();
			int num = cm.CheckNumOfMessage(ID);
			num +=1;
			int number = cm.CheckNumOfMessage();
			number+=1;
			DBWrite dbw = new DBWrite();
			dbw.WriteMessage(ID, title, content, time, whosend, num,number);//写入数据库
			
			
			String userid = dbr.DBReader_id(whosend);
			url="/messagesucessful.jsp?userid="+userid;
			RequestDispatcher rd = sc.getRequestDispatcher(url);
			rd.forward(request, response);
		}
		else if(action.equals("sendall")){
			Vector user = new Vector();
			DBRead dbr = new DBRead();
			user = dbr.DBReader_UserIDOnly();
			String title = new String(request.getParameter("title").getBytes("iso-8859-1"),"GB2312");
			String content =  new String(request.getParameter("content").getBytes("iso-8859-1"),"GB2312");
			Date date = new Date();
			String time = date.toLocaleString();
			HttpSession session =request.getSession();
			String whosend = (String)session.getAttribute("author");
			String userid = (String)session.getAttribute("name");
			int size = user.size();
			System.out.println("获取到总用户数:"+size);
			
			int number =0;
			if(size!=0){
				CheckMessage cm =new CheckMessage();
				DBWrite dbw = new DBWrite();
				for(int i=0; i<size; i++){
					String ID = (String)user.elementAt(i);
					
					int num = cm.CheckNumOfMessage(ID);
					num +=1;
					if(number==0)
						number = cm.CheckNumOfMessage();
					
					number+=1;
					
					dbw.WriteMessage(ID, title, content, time, whosend, num,number);//写入数据库
				}
			}
			url="/messagesucessful.jsp?userid="+userid;
			RequestDispatcher rd = sc.getRequestDispatcher(url);
			rd.forward(request, response);
		}
	}  	
	
	/* (non-Java-doc)
	 * @see javax.servlet.http.HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
	 */
	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		// TODO Auto-generated method stub
	}   	  	    
}