topicsaction.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.IOException;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.text.DateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashSet;
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.TopicsForm;

/** 
 * MyEclipse Struts
 * Creation date: 04-11-2008
 * 
 * XDoclet definition:
 * @struts.action path="/topics" name="topicsForm" parameter="method" scope="request"
 */
public class TopicsAction extends DispatchAction {
	/*
	 * Generated Methods
	 */

	/** 
	 * Method execute
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return ActionForward
	 */
	public ActionForward add(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		TopicsForm topicsForm = (TopicsForm) form;// TODO Auto-generated method stub
		TopicDAO dao=new TopicDAO();
		UserDAO udao=new UserDAO();
		
		HttpSession session=request.getSession();
		User user=(User)session.getAttribute("user");
		user.setTopics(new HashSet());
		
		String sid=request.getParameter("sid");
		Subject subject=null;
		Topic topic=new Topic();
		List list=(List)session.getAttribute("subject");
		Iterator it=list.iterator();
		while(it.hasNext()){
			Subject temp=(Subject)it.next();
			if(sid.equals(temp.getSid())){
				subject=temp;
				break;
			}
		}
		subject.setTopics(new HashSet());
		
		topic.setContent(topicsForm.getContent());
		topic.setTitle(topicsForm.getTopic());
		topic.setCreatedate(new Date());
		topic.setIflocked("1");
		topic.setLastmodiedtime(new Date());
		topic.setUid(user.getId());
		topic.setSubject(subject);
		topic.setTgrade("0");
		topic.setWriter(user.getUsername());
		topic.setUser(user);
		user.getTopics().add(topic);
		subject.getTopics().add(topic);
		dao.save(topic);
		user.setCount(user.getCount()+5);
		udao.update(user);
		SubjectDAO sdao=new SubjectDAO();
		List topics=sdao.queryById(sid,0);
		session.setAttribute("topic",topics);
		return mapping.findForward("eeeee");
	}
	
	public ActionForward showresp(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		String tid=request.getParameter("tid");
		HttpSession session=request.getSession();
		System.out.println(tid);
		ServletContext application=session.getServletContext();
		List users=(List)application.getAttribute("alluser");
		try {
			String tname=new String(request.getParameter("tname").getBytes("iso-8859-1"));
			session.setAttribute("temptname", tname);
			request.setAttribute("tname",tname);
		} catch (UnsupportedEncodingException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		String bankuai=(String)session.getAttribute("bankuaitemp");
		request.setAttribute("bankuai", bankuai);
		System.out.println(tid);
		TopicDAO dao=new TopicDAO();
		Topic t=dao.queryTopicByName(tid);
		Iterator it=users.iterator();
		Topic tempss;
		while(it.hasNext()){
			User temp=(User)it.next();
			if((temp.getUsername()).equals((t.getUser()).getUsername())){
				t.getUser().setStatus("2");
				tempss=t;
				break;
			}
		}
		ResponseDAO rdao=new ResponseDAO();
		List responses=rdao.queryById(tid,0);
		Iterator rit=responses.iterator();	
		while(rit.hasNext()){
			Response res=(Response)rit.next();
			Iterator it1=users.iterator();
			while(it1.hasNext()){
				User u=(User)it1.next();
				if(u.getUsername().equals(res.getUser().getUsername())){
					res.getUser().setStatus("2");
				}
			}
		}
		FenYe fenye=new FenYe();
		ResponseDAO sdao=new ResponseDAO();
		int itemcount=sdao.getCountItems(tid);			
		fenye.setCountitems(itemcount);
		fenye.setPageitems(5);
		fenye.setCountpage((fenye.getCountitems()+fenye.getPageitems()-1)/fenye.getPageitems());
		fenye.setNowpage(1);
		session.setAttribute("rfenye", fenye);	
		List tempresp=new ArrayList();
		Iterator its=tempresp.iterator();
		session.setAttribute("topicone", t);
		session.setAttribute("tid", tid);
		session.setAttribute("response", responses);
		return mapping.findForward("showresp");
	}
	
	public ActionForward pre(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		String tid=request.getParameter("tid");
		System.out.println(tid);	
		String sid=request.getParameter("sid");
		TopicDAO dao=new TopicDAO();
		List tids=dao.getAllTid(sid);
		String temp=tid;
		for(int i=0;i<tids.size();i++){
			if(tid.equals(tids.get(i))){
				if(i==0){
					temp=tid;
				}else{
					temp=(String)tids.get(i-1);
				}
				break;
			}
		}
		tid=temp;
		request.getSession().setAttribute("tid", tid);
		HttpSession session=request.getSession();
		String bankuai=(String)session.getAttribute("bankuaitemp");
		request.setAttribute("bankuai", bankuai);
		
		ServletContext application=session.getServletContext();
		List users=(List)application.getAttribute("alluser");
		Topic t=dao.queryTopicByName(tid);
		String tname=t.getTitle();
		session.setAttribute("temptname",tname);
		request.setAttribute("tname", tname);
		Iterator it=users.iterator();
		Topic tempss;
		while(it.hasNext()){
			User temp1=(User)it.next();
			if((temp1.getUsername()).equals((t.getUser()).getUsername())){
				t.getUser().setStatus("2");
				tempss=t;
				break;
			}
		}
		ResponseDAO rdao=new ResponseDAO();
		List responses=rdao.queryById(tid,0);
		Iterator rit=responses.iterator();
		while(rit.hasNext()){
			Response res=(Response)rit.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");
				}
			}
		}
		
		//分页设置
		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(1);
		
		List tempresp=new ArrayList();
		Iterator its=tempresp.iterator();
		session.setAttribute("topicone", t);
		session.setAttribute("response", responses);
		return mapping.findForward("showresp");
	}
	
	public ActionForward next(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		String tid=request.getParameter("tid");
		System.out.println(tid);
		TopicDAO dao=new TopicDAO();
		String sid=request.getParameter("sid");
		List tids=dao.getAllTid(sid);
		String temp=tid;
		for(int i=0;i<tids.size();i++){
			if(tid.equals(tids.get(i))){
				if(i==(tids.size()-1)){
					temp=tid;
				}else{
					temp=(String)tids.get(i+1);
				}
				break;
			}
		}
		tid=temp;
		request.getSession().setAttribute("tid", tid);
		HttpSession session=request.getSession();
		String bankuai=(String)session.getAttribute("bankuaitemp");
		request.setAttribute("bankuai", bankuai);
		ServletContext application=session.getServletContext();
		List users=(List)application.getAttribute("alluser");
		
		System.out.println(tid);
		Topic t=dao.queryTopicByName(tid);
		
		String tname=t.getTitle();
		session.setAttribute("temptname",tname);
		request.setAttribute("tname", tname);
		Iterator it=users.iterator();
		Topic tempss;
		while(it.hasNext()){
			User temp1=(User)it.next();
			if((temp1.getUsername()).equals((t.getUser()).getUsername())){
				t.getUser().setStatus("2");
				tempss=t;
				break;
			}
		}
		ResponseDAO rdao=new ResponseDAO();
		List responses=rdao.queryById(tid,0);
		Iterator rit=responses.iterator();
		
		while(rit.hasNext()){
			Response res=(Response)rit.next();
			Iterator it1=users.iterator();
			while(it1.hasNext()){
				User u=(User)it1.next();
				if(u.getUsername().equals(res.getUser().getUsername())){
					res.getUser().setStatus("2");
				}
			}
		}
		
		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(1);
		
		
		List tempresp=new ArrayList();
		Iterator its=tempresp.iterator();
		session.setAttribute("topicone", t);
		session.setAttribute("response", responses);
		return mapping.findForward("showresp");
	}
	
	public ActionForward jinghua(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		HttpSession session=request.getSession();
		TopicDAO dao=new TopicDAO();
		List list=dao.getJinghua();
		Iterator it=list.iterator();
		DateFormat df=DateFormat.getDateInstance();
		while(it.hasNext()){
			Topic t=(Topic)it.next();
			t.setCdate(df.format(t.getCreatedate()));
		}
		session.setAttribute("jinghua", list);
		return mapping.findForward("main");
	}
	
	public ActionForward fenye(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		HttpSession session=request.getSession();
		int nowpage=Integer.parseInt(request.getParameter("nowpage"));
		SubjectDAO sdao=new SubjectDAO();
		String sid=(String)session.getAttribute("sid");
		TopicDAO tdao=new TopicDAO();
		//得到总记录条数
		int count=tdao.getCountItems(sid);
		//实例化一个分页对象
		FenYe fenye=(FenYe)session.getAttribute("fenye");
		//给分页对象的各个属性赋值
		//总记录条数
		fenye.setCountitems(count);
		//总页数
		fenye.setCountpage((fenye.getCountitems()+fenye.getPageitems()-1)/fenye.getPageitems());
		//当前页数
		fenye.setNowpage(nowpage);
		
		List topics=sdao.queryById(sid, (nowpage-1)*10);
		session.setAttribute("topic", topics);
		
		return mapping.findForward("topics");
	}
	
	public ActionForward myitems(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		PrintWriter out=null;
		HttpSession session=request.getSession();
		TopicDAO tdao=new TopicDAO();
		String uid=request.getParameter("uid");
		
		List list=tdao.getUserItems(uid);
		//System.out.println(list.size()+"11111111000000000000022222222222222333333333333333");
		try {
			out= response.getWriter();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		response.setContentType("text/xml;charset=gb2312");
		response.setHeader("Cache-Control", "no-cachr");
		String xml="<response>";
		Iterator it=list.iterator();
		DateFormat df=DateFormat.getDateInstance();
		while(it.hasNext()){
			Topic topic=(Topic)it.next();
			xml+="<content>";
			xml+="<tid>"+topic.getTid()+"</tid>";
			xml+="<title>"+topic.getTitle()+"</title>";
			xml+="<cdate>"+df.format(topic.getCreatedate())+"</cdate>";
			xml+="<count>"+topic.getCount()+"</count>";
			xml+="</content>";
			System.out.println(topic.getTitle());
		}
		xml+="</response>";
		out.println(xml);
		out.close();
		
		System.out.println("+++++++--------HEHEHEHEHEHEHEHE");
		return mapping.findForward("mypage");
	}
	
	public ActionForward delete(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		String tid=request.getParameter("tid");
		TopicDAO dao=new TopicDAO();
		dao.delete(tid);
		TopicDAO tdao=new TopicDAO();
		String uid=request.getParameter("uid");
		PrintWriter out=null;
		List list=tdao.getUserItems(uid);
		System.out.println("11111111000000000000022222222222222333333333333333");
		try {
			out= response.getWriter();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		response.setContentType("text/xml;charset=gb2312");
		response.setHeader("Cache-Control", "no-cachr");
		String xml="<response>";
		Iterator it=list.iterator();
		DateFormat df=DateFormat.getDateInstance();
		while(it.hasNext()){
			Topic topic=(Topic)it.next();
			System.out.println(topic.getCreatedate());
			xml+="<content>";
			xml+="<tid>"+topic.getTid()+"</tid>";
			xml+="<title>"+topic.getTitle()+"</title>";
			xml+="<cdate>"+df.format(topic.getCreatedate())+"</cdate>";
			xml+="<count>"+topic.getCount()+"</count>";
			xml+="</content>";
			System.out.println(topic.getTitle());
		}
		xml+="</response>";
		out.println(xml);
		out.close();
		return mapping.findForward("mypage");
	}
	
	
}