responseaction.java

bbs论坛 采用java的Web开发strtus、hibernate

/*
 * Generated by MyEclipse Struts
 * Template path: templates/java/JavaClass.vtl
 */
package com.wish.bbs.struts.action;

import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.Date;
import java.util.Iterator;
import java.util.List;

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

import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.actions.DispatchAction;

import com.wish.bbs.dao.ResponseDAO;
import com.wish.bbs.dao.SubjectDAO;
import com.wish.bbs.dao.TopicDAO;
import com.wish.bbs.dao.UserDAO;
import com.wish.bbs.fenye.FenYe;
import com.wish.bbs.pojo.Response;
import com.wish.bbs.pojo.Subject;
import com.wish.bbs.pojo.Topic;
import com.wish.bbs.pojo.User;
import com.wish.bbs.struts.form.ResponseForm;


public class ResponseAction extends DispatchAction {

	public ActionForward add(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		ResponseForm responseForm = (ResponseForm) form;
		HttpSession session=request.getSession();
		String yanzheng=(String)session.getAttribute("rand");
		if(yanzheng.equals(responseForm.getYanzheng())){
			ServletContext application=session.getServletContext();
			List users=(List)application.getAttribute("alluser");
			UserDAO udao=new UserDAO();
			String sid=(String)session.getAttribute("sid");
			System.out.println("sid==="+sid);
			
			List subjects=(List)session.getAttribute("subject");
			System.out.println(subjects.size());
			Iterator sit=subjects.iterator();

			
			TopicDAO tdao=new TopicDAO();
			User user=(User)session.getAttribute("user");
			Topic topic=(Topic)session.getAttribute("topicone");
			String tid=request.getParameter("tid");
			Topic ttemp=tdao.queryTopicByName(tid);
			ttemp.setCount(ttemp.getCount()+1);
			Subject subject=ttemp.getSubject();
			System.out.println(ttemp.getCount()+"    0000000000000000000000");
			User user2=ttemp.getUser();
			//topic.setUser(user2);
			//topic.setSubject(subject);
			ResponseDAO dao=new ResponseDAO();
			Response resp=new Response();
			resp.setContent(responseForm.getContent());
			resp.setCreatedate(new Date());
			resp.setLastmodified(new Date());
			resp.setTopic(ttemp);
			resp.setUser(user);
			resp.setWriter(user.getUsername());
			
			dao.save(resp);
			System.out.println(ttemp.getCount()+"     11111111111111111111111111111111");
			
			user.setCount(user.getCount()+2);
			udao.update(user);
			List responses=dao.queryById(tid,0);
			Iterator it2=responses.iterator();
			
			while(it2.hasNext()){
				Response res=(Response)it2.next();
				Iterator it1=users.iterator();
				while(it1.hasNext()){
					User u=(User)it1.next();
					if(u.getUsername().equals(res.getUser().getUsername())){
						
						res.getUser().setStatus("2");
						System.out.println(res.getUser().getStatus()+"status");
					}
				}
			}
			
			Iterator uit=users.iterator();
			Topic ttemp1=tdao.queryTopicByName(tid);
			Iterator it=users.iterator();
			while(it.hasNext()){
				User temp=(User)it.next();
				if((temp.getUsername()).equals((ttemp1.getUser()).getUsername())){
					ttemp1.getUser().setStatus("2");
					break;
				}
			}
			session.setAttribute("topicone", ttemp1);
			List resuser=new ArrayList();
			Iterator it3=responses.iterator();
			while(it3.hasNext()){
				Response temp=(Response)it3.next();
				resuser.add(temp.getUser());
			}
			session.setAttribute("response", responses);
			session.setAttribute("resuser", resuser);
		}

		return mapping.findForward("showresp");
	}
	
	public ActionForward fenye(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		HttpSession session=request.getSession();
		String bankuai=(String)session.getAttribute("bankuaitemp");
		request.setAttribute("bankuai", bankuai);
		String tname=(String)session.getAttribute("temptname");
		request.setAttribute("tname", tname);
		ServletContext application=session.getServletContext();
		List users=(List)application.getAttribute("alluser");
		int nowpage=Integer.parseInt(request.getParameter("nowpage"));
		SubjectDAO sdao=new SubjectDAO();
		String tid=(String)session.getAttribute("tid");
		ResponseDAO rdao=new ResponseDAO();
		int count=rdao.getCountItems(tid);
		FenYe fenye=(FenYe)session.getAttribute("rfenye");
		fenye.setCountitems(count);
		fenye.setCountpage((fenye.getCountitems()+fenye.getPageitems()-1)/fenye.getPageitems());
		fenye.setNowpage(nowpage);
		System.out.println(3);
		session.setAttribute("rpage", fenye.getNowpage());
		System.out.println(4);
		session.setAttribute("rcountpage", fenye.getCountpage());
		System.out.println(5);
		List topics=rdao.queryById(tid, (nowpage-1)*5);
		Iterator it2=topics.iterator();
		while(it2.hasNext()){
			Response res=(Response)it2.next();
			Iterator it1=users.iterator();
			while(it1.hasNext()){
				User u=(User)it1.next();
				if(u.getUsername().equals(res.getUser().getUsername())){
					
					res.getUser().setStatus("2");
					System.out.println(res.getUser().getStatus()+"status");
				}
			}
		}
		Iterator it=topics.iterator();
		session.setAttribute("response", topics);
		return mapping.findForward("showresp");
	}
}