messageoperation.java

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

/**
  * @(#)tarena.action.MessageOperation.java  2008-11-5  
  * 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-5 	小猪     		新建
  **/
package tarena.action;


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

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 tarena.dao.MessageDAO;
import tarena.dao.UserDAO;
import tarena.entity.Message;
import tarena.entity.User;
import tarena.form.MessageForm;
import tarena.global.CookieOperate;
import tarena.global.MessageOperate;
import tarena.global.PublicParameter;
import tarena.global.Transform;

 /**
 * 消息操作类。<br>
 * 收件箱、发件箱、草稿箱等。
 * 2008-11-5
 * @author		达内科技[Tarena Training Group]
 * @version	1.0
 * @since		JDK1.6(建议) 
 * @author		Administrator
 */
public class MessageOperation extends MappingDispatchAction {

	/**
	 * 撰写短消息
	 */
	public ActionForward usercppostpm(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		UserDAO udao = new UserDAO();
		Integer uid = Transform.StringToInteger(request.getParameter("uid"));
		User u = udao.findById(uid);
		
		request.setAttribute("uname", u.getUsername());
		return mapping.findForward("usercppostpm");
	}
	
	/**
	 * 发送短消息
	 */
	public ActionForward sendMessage(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		
		
		MessageForm msgform = (MessageForm)form;
		Message message = new Message();
		MessageDAO dao = new MessageDAO();
		
		String sendname = CookieOperate.FindCookie(PublicParameter.cookie_user, request.getCookies()).getValue();
		
		if(sendname == null || msgform.getReceivename() == null || msgform.getTitle() == null || msgform.getMsgContent() == null){
			MessageOperate.setAttribute(request, "错误", "参数错误", "请将信息填写完正!程序将跳转到上一页.", "");
			return mapping.findForward("message");
		}
		
		//判断消息类型
		byte type = (msgform.getMesstype()==null)?msgform.getTypevalue():msgform.getMesstype();
		
		message.setSendname(sendname);
		message.setReceivename(msgform.getReceivename());
		message.setTitle(msgform.getTitle());		
		message.setContent(msgform.getMsgContent());
		message.setSendtime(new Date());
		message.setIsread(false);
		message.setMesstype(type);
		//System.out.println("type:"+type+",typevalue："+msgform.getTypevalue()+",messtype:"+msgform.getMesstype());
		dao.save(message);
		
		return mapping.findForward("usercppostpm");
	}
	
	/**
	 * 收件箱
	 */
	public ActionForward usercpinbox(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		MessageDAO mdao = new MessageDAO();
		String receivename = CookieOperate.FindCookie(PublicParameter.cookie_user, request.getCookies()).getValue();
		List<Message> messages = mdao.findInBox(receivename, 10);
		int newMessage = mdao.countMessageInBox(receivename, true);
		int allMessage = mdao.countMessageInBox(receivename, false);
		
		request.setAttribute("messages", messages);
		request.setAttribute("newMessage",newMessage);
		request.setAttribute("allMessage",allMessage);
		
		
		return mapping.findForward("usercpinbox");
	}
	
	/**
	 * 发件箱
	 */
	public ActionForward usercpsentbox(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		
		MessageDAO mdao = new MessageDAO();
		String sendname = CookieOperate.FindCookie(PublicParameter.cookie_user, request.getCookies()).getValue();
		List<Message> messages = mdao.findSendMessage(sendname, MessageDAO.SENDBOX, 10);		
		int allMessage = mdao.countSendMessage(sendname, MessageDAO.SENDBOX);
		
		request.setAttribute("messages", messages);		
		request.setAttribute("allMessage",allMessage);
		
		return mapping.findForward("usercpsentbox");
	}
	
	/**
	 * 草稿箱
	 */
	public ActionForward usercpdraftbox(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		
		MessageDAO mdao = new MessageDAO();
		String sendname = CookieOperate.FindCookie(PublicParameter.cookie_user, request.getCookies()).getValue();
		List<Message> messages = mdao.findSendMessage(sendname, MessageDAO.DRAFTBOX, 10);		
		int allMessage = mdao.countSendMessage(sendname, MessageDAO.DRAFTBOX);
		
		request.setAttribute("messages", messages);		
		request.setAttribute("allMessage",allMessage);		
		
		return mapping.findForward("usercpdraftbox");
	}
	
	/**
	 * 删除短信息
	 */
	public ActionForward deleteMessage(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		
		MessageDAO mdao = new MessageDAO();
		
		String [] params = request.getParameterValues("pmitemid");
		List<Integer> mids = Transform.StringToInteger(params);
		List<Message> messages = mdao.findByIds(mids);
		mdao.delete(messages);			
		
		String goback = request.getParameter("goback");		
		if(goback==null){
			return mapping.findForward("usercp");
		}
		return mapping.findForward(goback);
	}
	
	/**
	 * 查看站内短信息
	 */
	public ActionForward usercpshowpm(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		
		Integer mid = Transform.StringToInteger(request.getParameter("mid"));
		if(mid.equals(-1)){
			
		}
		MessageDAO mdao = new MessageDAO();
		Message message = mdao.findById(mid);
		message.setIsread(true);
		mdao.saveOrUpdate(message);
		request.setAttribute("message",message);
		//request.setAttribute("gotoback",request.getAttribute(name));
		return mapping.findForward("usercpshowpm");
	}
}