queryalldo.java

一个bbs论坛系统

package com.lovo.servlet;

import java.io.IOException;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import javax.servlet.RequestDispatcher;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import com.lovo.bo.BlockBO;
import com.lovo.factory.BOFactory;
import com.lovo.po.AreaPO;
import com.lovo.po.BlockPO;
import com.lovo.po.PublishPO;
import com.lovo.po.UserPO;
import com.lovo.util.Page;

public class QueryAllDO extends HttpServlet {
	protected void doGet(HttpServletRequest request,
			HttpServletResponse response) throws ServletException, IOException {
		this.doPost(request, response);
	}

	protected void doPost(HttpServletRequest request,
			HttpServletResponse response) throws ServletException, IOException {
		request.setCharacterEncoding("utf-8");
		response.setContentType("text/html;charset=utf-8");
		response.setCharacterEncoding("utf-8");

		RequestDispatcher rd = null;
		ServletContext application = this.getServletContext();
		HttpSession session = request.getSession(true);
		Boolean isLogSuc = (Boolean) session.getAttribute("isLogSuc");

		if (isLogSuc != null) {
			rd = request.getRequestDispatcher("web/jsp/homeindex.jsp");
		} else {
			rd = request.getRequestDispatcher("web/login.jsp");
		}
		
		if(isLogSuc == null) {
			UserPO user = new UserPO();
			user.setName("visitor");
			session.setAttribute("user", user);
		}
		this.TheNewestPublish(session);
		this.theWealthUser(session);
		this.allArea(session);
		this.newFiveReg(session);
		this.onLine(session, application);
		this.onLineReg(session, application);
		
		// 最新精华帖
		try {
			PublishPO theNewestDigestPublish = BOFactory.getPublishBOInstance().queryByDigestdate();
			if(theNewestDigestPublish == null) {
				theNewestDigestPublish = new PublishPO();
				theNewestDigestPublish.setTitle("暂时没有精华贴");
			}
			session.setAttribute("theNewestDigestPublish", theNewestDigestPublish);
		} catch (SQLException e) {
			e.printStackTrace();
			session.setAttribute("errorInfo", "查找最新精华贴出错");
			response.sendRedirect("web/error.jsp");
			return;
		}
		// 最新推荐贴
		
		try {
			PublishPO theNewestRecommendPublish = BOFactory.getPublishBOInstance().queryByRecomendate();
			if(theNewestRecommendPublish == null) {
				theNewestRecommendPublish = new PublishPO();
				theNewestRecommendPublish.setTitle("暂时没有推荐贴");
			}
			session.setAttribute("theNewestRecommendPublish", theNewestRecommendPublish);
		} catch (SQLException e) {
			e.printStackTrace();
			session.setAttribute("errorInfo", "查找最新推荐贴出错");
			response.sendRedirect("web/error.jsp");
			return;
		}

		rd.forward(request, response);
	}

	public void newFiveReg(HttpSession session) {
		// 最近注册的五位会员
		List<UserPO> newRegUserList = BOFactory.getUserBOInstance()
				.queryUserByRegisterTime();
		List<UserPO> newestFiveRegUserList = new ArrayList<UserPO>();
		if (newRegUserList.size() < 5) {
			for (int i = 0; i < newRegUserList.size(); i++) {
				newestFiveRegUserList.add(newRegUserList.get(i));
			}
		} else {
			for (int i = 0; i <= 4; i++) {
				newestFiveRegUserList.add(newRegUserList.get(i));
			}
		}
		session.setAttribute("fiveNewReg", newestFiveRegUserList);
	}

	public void theWealthUser(HttpSession session) {
		// 最富有的五位会员
		Page page = new Page();
		page.setCurrPage(1);
		List<UserPO> wealthUserList = BOFactory.getUserBOInstance()
				.queryUserByWealth(page);
		List<UserPO> fiveWealthList = new ArrayList<UserPO>();
		if (wealthUserList.size() < 5) {
			for (int i = 0; i < wealthUserList.size(); i++) {
				fiveWealthList.add(wealthUserList.get(i));
			}
		} else {
			for (int i = 0; i <= 4; i++) {
				fiveWealthList.add(wealthUserList.get(i));
			}
		}
		session.setAttribute("fiveWealth", fiveWealthList);
	}

	public void TheNewestPublish(HttpSession session) {
		// 最新的五个帖子
		List<PublishPO> newPubList = BOFactory.getPublishBOInstance()
				.queryByPublishDate();
		List<PublishPO> newFivePubList = new ArrayList<PublishPO>();
		if (newPubList.size() < 5) {
			for (int i = 0; i < newPubList.size(); i++) {
				newFivePubList.add(newPubList.get(i));
			}
		} else {
			for (int i = 0; i <= 4; i++) {
				newFivePubList.add(newPubList.get(i));
			}
		}
		session.setAttribute("newFivePubList", newFivePubList);
		// 最新的帖子
		PublishPO theNewestPublish = new PublishPO();
		if (newPubList.size() == 0) {
			theNewestPublish.setTitle("暂时没有新帖");
		} else {
			theNewestPublish = newPubList.get(0);
		}
		session.setAttribute("theNewestPublish", theNewestPublish);
	}

	public void allArea(HttpSession session) {
		// 所有的区域 //所有区域下的版块
		List<AreaPO> allAreaList = BOFactory.getAreaBOInstance().queryArea();
		BlockBO blockBO = BOFactory.getBlockBOInstance();
		for (int i = 0; i < allAreaList.size(); i++) {
			AreaPO area = allAreaList.get(i);
			List<BlockPO> blockList = blockBO.queryBlockByArea(area.getId());
			area.setBlockList(blockList);
			List<UserPO> areaAdminList = BOFactory.getUserBOInstance().queryAreaAdmin(area.getId());
			area.setAreaAdminList(areaAdminList);
		}

		session.setAttribute("allAreaList", allAreaList);
	}
	
	public void onLine(HttpSession session, ServletContext application) {
		int onLineNum = 0;
		int onLineNumApp = 0;//存在application里的session的个数
		int onLineNumSes = 0;//session的个数
		Integer onLineApp = (Integer) application.getAttribute("onLineNum");
		if(onLineApp == null) {
			onLineNum = ((Integer) session.getAttribute("onLineNum")).intValue();
		} else {
			onLineNumSes = ((Integer) session.getAttribute("onLineNum")).intValue();
			onLineNumApp = ((Integer) application.getAttribute("onLineNum")).intValue();
			if(onLineNumSes > onLineNumApp) {
				onLineNum = onLineNumSes;
			} else {
				onLineNum = onLineNumApp;
			}
		}
		application.setAttribute("onLineNum", onLineNum);
	}
	
	public void onLineReg(HttpSession session, ServletContext application) {
//		 在线人数多少是注册用户
		List<UserPO> userRegList = (List)application.getAttribute("userRegList");
		if(userRegList == null) {
			userRegList = new ArrayList<UserPO>();
		}
		UserPO userReg = (UserPO) session.getAttribute("user");
		
		boolean isAdd = ((Boolean)session.getAttribute("isAdd")).booleanValue();
		if (!userReg.getName().	equals("visitor") &&!isAdd ) {
			userRegList.add(userReg);
			isAdd = true;
			session.setAttribute("isAdd", isAdd);
		}
		application.setAttribute("userRegList", userRegList);
		int regNum = userRegList.size();
		session.setAttribute("regNum", regNum);
	}
}