topicoperation.java

基于struts+hibernate的电子商务网站。可运行。数据库mysql

/**
  * @(#)tarena.action.TopicOperation.java  2008-11-4  
  * Copy Right Information	: Tarena
  * Project					: xindou
  * JDK version used		: jdk1.6.4
  * Comments				: 主题操作类。
  * Version					: 1.0
  * Sr	Date		Modified By		Why & What is modified
  * 1.	2008-11-4 	小猪     		新建
  **/
package tarena.action;

import java.util.Date;
import java.util.List;
import java.util.Vector;

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

import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.actions.MappingDispatchAction;
import org.hibernate.Session;

import tarena.dao.HibernateSessionFactory;
import tarena.dao.PostDAO;
import tarena.dao.SectionDAO;
import tarena.dao.TopicDAO;
import tarena.dao.UserDAO;
import tarena.dao.pages.CForumDAO;
import tarena.data.AbractSection;
import tarena.data.AdvancedPagination;

import tarena.data.SearchTopic;
import tarena.data.SectionSecondAndThird;
import tarena.entity.Post;

import tarena.entity.Topic;
import tarena.entity.User;
import tarena.form.PostForm;
import tarena.form.SearchForm;
import tarena.global.CookieOperate;
import tarena.global.MessageOperate;
import tarena.global.PublicParameter;
import tarena.global.Transform;

 /**
 * 主题操作类。<br>
 * 添加主题、回复主题、删除主题、加亮主题等。
 * 2008-11-4
 * @author		达内科技[Tarena Training Group]
 * @version	1.0
 * @since		JDK1.6(建议) 
 */
public class TopicOperation extends MappingDispatchAction {

	/**
	 * 平板方式浏览主题
	 */
	public ActionForward cTopic(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		//此处记得保存rootid
		TopicDAO tdao = new TopicDAO();
		CForumDAO  cfdao = new CForumDAO();
		SectionDAO sdao = new SectionDAO();
		System.out.println("getAttribute:"+request.getAttribute("tid"));
		System.out.println("getParameter:"+request.getParameter("tid"));
		Integer tid = Transform.StringToInteger(request.getParameter("tid")==null?request.getAttribute("tid").toString():request.getParameter("tid"));
		Integer sid = Transform.StringToInteger(request.getParameter("sid"));
				
		Topic topic = null;
		Integer total = cfdao.countPost(tid);
		Integer current = Transform.StringToInteger(request.getParameter("page"));
		String url = request.getRequestURI()+"?"+request.getQueryString();
//		System.out.println(total+","+current+","+url);
		AdvancedPagination ap = new AdvancedPagination(total,10,current,10,url);
		
		if(request.getAttribute("maxpage")!=null){
			ap.setCurrent(ap.getTotalPage());
		}
		
		List<Post> posts = cfdao.listPosts((ap.getCurrent()-1)*ap.getEvery(), ap.getEvery(), tid,false);
		try {
			topic = tdao.findById(tid);
//			System.out.println(tid+","+topic);
		} catch (RuntimeException e) {}
		if(topic == null) MessageOperate.wrongparam(request, response);
		
		request.setAttribute("pagination", ap);
		request.setAttribute("posts", posts);
		request.setAttribute("topic", topic);	
		request.setAttribute("ocategorys", getOcategorys(sid));
		request.setAttribute("address", "<a href='default.htm'>首页</a>&nbsp;> &nbsp;<span id='aTabCategory'>"+topic.getSection().getSectionname()+"</span>");
		return mapping.findForward("ctopic");
	}
	
	/**
	 * 树形方式浏览主题
	 */
	public ActionForward cTree(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
				
		TopicDAO tdao = new TopicDAO();
		CForumDAO  cfdao = new CForumDAO();
		PostDAO  pdao = new PostDAO();
		
		Integer tid = Transform.StringToInteger(request.getParameter("tid"));
		Integer pid = Transform.StringToInteger(request.getParameter("pid"));
		Integer sid = Transform.StringToInteger(request.getParameter("sid"));
		
		Topic topic = null;
		Integer total = cfdao.countPost(tid);
		Integer current = Transform.StringToInteger(request.getParameter("page"));
		String url = request.getRequestURI()+"?"+request.getQueryString();
		AdvancedPagination ap = new AdvancedPagination(total,10,current,10,url);
		
		if(request.getAttribute("maxpage")!=null){
			ap.setCurrent(ap.getTotalPage());
		}
		
//		List<Post> posts = cfdao.listPosts((ap.getCurrent()-1)*ap.getEvery(), ap.getEvery(), tid,false);
		try {
			topic = tdao.findById(tid);
//			System.out.println(tid+","+topic);
		} catch (RuntimeException e) {}
		if(topic == null) MessageOperate.wrongparam(request, response);
		
		
		System.out.println(topic.getPosts().size());
		
		List<Post> posts = cfdao.listPosts((ap.getCurrent()-1)*ap.getEvery(), ap.getEvery(), tid,false);
		
		request.setAttribute("pagination", ap);
		request.setAttribute("post", pdao.findById(pid));		
		request.setAttribute("topic", topic);
		request.setAttribute("posts", posts);
		request.setAttribute("ocategorys", getOcategorys(sid));
		request.setAttribute("address", "<a href='default.htm'>首页</a>&nbsp;> &nbsp;<span id='aTabCategory'>"+topic.getSection().getSectionname()+"</span>");
		return mapping.findForward("ctree");
	}
	
	/**
	 * 发布主题
	 */
	public ActionForward cPostTopic(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		
//		TopicDAO tdao = new TopicDAO();
//		PostDAO pdao = new PostDAO();
		SectionDAO sdao = new SectionDAO();
		Integer sid = Transform.StringToInteger(request.getParameter("sid"));
		User user = null;
		try {
			user = new UserDAO().findUserByUsername(CookieOperate.FindCookie(PublicParameter.cookie_user, request.getCookies()).getValue());
		} catch (RuntimeException e) {
			MessageOperate.notLogin(request, response);
		}

		//如果表单数据为空，只显示相关数据，否则,将表单中的数据插入到数据库
		if(form!=null&&((PostForm)form).getMessage()!=null){
			Topic topic = new Topic();
			Post post = new Post();
			
//			Integer sid = Transform.StringToInteger(request.getParameter("sid"));
			
			PostForm formbean = (PostForm)form;
			
			topic.setTitle(formbean.getTitle());
			topic.setSection(sdao.findById(sid));		
			topic.setPublisher(user.getUsername());	
			
			post.setTitle(formbean.getTitle());
			post.setContent((user.getUsesign()||formbean.getUsesign())?(formbean.getMessage()+"<br/>"+user.getSignature()):formbean.getMessage());
			post.setForbidegerweb(formbean.getForbidegerweb());
			post.setForbidesmile(formbean.getForbidesmile());
			post.setForbideurl(formbean.getForbideurl());
			post.setUsesign(formbean.getUsesign());
			post.setFloor(1);
			post.setTopic(topic);
			post.setUser(user);
			post.setSendtime(new Date());
			Session session = HibernateSessionFactory.getSession();
			//tdao.save(topic);
//			System.out.println("postContent:--------"+post.getContent());
			session.beginTransaction();
			session.save(topic);
			session.save(post);
			session.getTransaction().commit();	
			request.setAttribute("maxpage", true);
			request.setAttribute("tid", topic.getId());
			return mapping.findForward("ctopic");
		}
		request.setAttribute("uname", user.getUsername());
		request.setAttribute("ocategorys", getOcategorys(sid));
		
		
		return mapping.findForward("cposttopic");
		
	}
	
	/**
	 * 回复帖子
	 */
	public ActionForward cPostReply(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		//如果表单数据为空，只显示相关数据，否则,将表单中的数据插入到数据库
		Integer tid = Transform.StringToInteger(request.getParameter("tid"));
		Integer sid = Transform.StringToInteger(request.getParameter("sid"));
		CForumDAO cfdao = new CForumDAO();
		TopicDAO tdao = new TopicDAO();
		Topic topic = tdao.findById(tid);

		if(form!=null&&((PostForm)form).getMessage()!=null){
			PostForm formbean = (PostForm)form;
			Post post = new Post();
			User user = null;
			try {
				user = new UserDAO().findUserByUsername(CookieOperate.FindCookie(PublicParameter.cookie_user, request.getCookies()).getValue());
			} catch (RuntimeException e) {
				MessageOperate.notLogin(request, response);
			}
			
			post.setTitle(formbean.getTitle());
			post.setContent((user.getUsesign()||formbean.getUsesign())?(formbean.getMessage()+"<br/>"+user.getSignature()):formbean.getMessage());
			post.setForbidegerweb(formbean.getForbidegerweb());
			post.setForbidesmile(formbean.getForbidesmile());
			post.setForbideurl(formbean.getForbideurl());			
			post.setUsesign(formbean.getUsesign());
//			System.out.println(tdao+","+tid+","+post+"");
			post.setFloor(tdao.countFloors(tid)+1);
			post.setTopic(topic);
			post.setUser(user);
			post.setSendtime(new Date());
			Session session = HibernateSessionFactory.getSession();
			session.beginTransaction();
			session.save(post);
			session.flush();
			session.getTransaction().commit();	
			
//			System.out.println(post.getForbideurl());
//			System.out.println(post.getForbidesmile());
//			System.out.println(post.getForbidegerweb());
//			System.out.println(post.getUsesign());
			
			request.setAttribute("maxpage", true);
			return mapping.findForward("ctopic");
		}
		User user = null;
		try {
			user = new UserDAO().findUserByUsername(CookieOperate.FindCookie(PublicParameter.cookie_user, request.getCookies()).getValue());
		} catch (RuntimeException e) {
			MessageOperate.notLogin(request, response);
		}
		
		
		//最后5条回复
		List<Post> posts = cfdao.listPosts(0, 5, tid,true);
		
		request.setAttribute("topic", topic);
		request.setAttribute("user", user);
		request.setAttribute("posts", posts);
		request.setAttribute("ocategorys", getOcategorys(sid));
		
		return mapping.findForward("cpostreply");
	}
	
	/**
	 * 查询主题
	 */
	public ActionForward search(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		//此处记得保存rootid
//		byte keywordtype = Transform.stringToByte(request.getParameter(PublicParameter.PARAM_SEARCH_KEYWORD_TYPE));
//		String author = request.getParameter(PublicParameter.PARAM_SEARCH_KEYWORD_AUTHOR);
//		String digest = request.getParameter(PublicParameter.PARAM_SEARCH_KEYWORD_DIGEST);
//		String title = request.getParameter(PublicParameter.PARAM_SEARCH_KEYWORD_TITLE);
		
	
		
		//============================================
//		//参数中包含作者信息
//		if((keywordtype&PublicParameter.SEARCH_KEYWORD_TYPE_AUTHOR)!=0){
//			if(author == null){
//				
//			}
//			
//		}
//		//参数中包含是否是精华贴
//		if((keywordtype&PublicParameter.SEARCH_KEYWORD_TYPE_DIGEST)!=0){
//			if(digest == null){
//				
//			}
//		}
//		//参数中包含标题信息
//		if((keywordtype&PublicParameter.SEARCH_KEYWORD_TYPE_TITLE)!=0){
//			if(title == null){
//				
//			}
//		}
		
		CForumDAO cfdao = new CForumDAO();

		//设置参数对象
//		SearchCondition sc = new SearchCondition();
//		sc.setAuthor(author);
//		sc.setDigest(digest==null?null:new Boolean(digest));
//		sc.setTitle(title);
		SearchForm sf = (SearchForm)form;
		
		//分页
		Integer total = cfdao.countAbstractTopics(sf);
		Integer current = Transform.StringToInteger(request.getParameter("page"));
		String url = request.getRequestURI()+"?"+request.getQueryString();
		AdvancedPagination ap = new AdvancedPagination(total,10,current,10,url);
		
		List<SearchTopic> st = cfdao.listAbstractTopics(sf, (ap.getCurrent()-1)*ap.getEvery(), ap.getEvery());
//		System.out.println(sf.getAuthor()+","+sf.getDigest()+","+sf.getTitle());
//		System.out.println(total+","+(ap.getCurrent()-1)*ap.getEvery()+","+ap.getEvery()+","+st.size());
		request.setAttribute("topics", st);
		request.setAttribute("pagination", ap);
		return mapping.findForward("search");
	}
	
	/**
	 * 模糊查询主题
	 */
	public ActionForward query(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		//此处记得保存rootid
		
		return mapping.findForward("query");
	}
	
	private List<SectionSecondAndThird> getOcategorys(Integer sid){		
		SectionDAO sdao = new SectionDAO();
		List<AbractSection> secondSectioin = sdao.listSecondCategory(new Integer(sid));
		List<SectionSecondAndThird> ocategorys = new Vector<SectionSecondAndThird>();
		//2级分类和3级分类
		if(secondSectioin!=null){
			for(AbractSection c:secondSectioin){				
				ocategorys.add(new SectionSecondAndThird(c,sdao.listHotThirdCategory(c.getId())));
			}			
		}
		return ocategorys;
	}
}