customermessageboardaction.java

基于struts的网上商店源码

/*
 * 作者:武律
 * 时间:2007年11月28日
 * 功能:消息中心功能处理
 */
package com.mole.struts.action;

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

import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;

import com.mole.struts.dao.DBConnector;
import com.mole.struts.form.CustomerMessageBoardForm;

/**
 * MyEclipse Struts Creation date: 11-28-2007
 * 
 * XDoclet definition:
 * 
 * @struts.action path="/customerMessageBoard" name="customerMessageBoardForm"
 *                input="/customerMessageBoard.jsp" scope="request"
 *                validate="true"
 */
public class CustomerMessageBoardAction extends Action {
	/*
	 * Generated Methods
	 */

	/**
	 * Method execute
	 * 
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return ActionForward
	 */
	public ActionForward execute(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		CustomerMessageBoardForm customerMessageBoardForm = (CustomerMessageBoardForm) form;

		DBConnector dao = new DBConnector();

		String owner = customerMessageBoardForm.getOwnerName();
		String deliver = customerMessageBoardForm.getDeliverName();
		String context = customerMessageBoardForm.getDeliverContext();
		// String deliverTime = customerMessageBoardForm.getDeliverTime();
		String mid = request.getParameter("mid");
		if (mid != null) {
			// 删除站内信
			String sql = "delete from CustomerMessageBoard where ID=" + mid;
			try {
				dao.executeUpdate(sql);
				HttpSession session = request.getSession();
				session.setAttribute("title", "成功信息");
				session.setAttribute("message", "删除成功！");
				session
						.setAttribute("returnUrl",
								"customerGetMessageBorder.do");
				return mapping.findForward("goMessage");
			} catch (Exception e) {
				e.printStackTrace();
				HttpSession session = request.getSession();
				session.setAttribute("title", "错误信息");
				session.setAttribute("message", "删除失败！");
				session
						.setAttribute("returnUrl",
								"customerGetMessageBorder.do");
				return mapping.findForward("goMessage");
			}
		} else if ("".equals(context)) {
			HttpSession session = request.getSession();
			session.setAttribute("title", "错误信息");
			session.setAttribute("message", "发表不成功,留言不能为空！");
			session.setAttribute("returnUrl", "customerGetMessageBorder.do");
			return mapping.findForward("goMessage");
		} else if ("".equals(deliver)) {
			HttpSession session = request.getSession();
			session.setAttribute("title", "错误信息");
			session.setAttribute("message", "发表不成功,请您先登录再发表留言！");
			session.setAttribute("returnUrl", "customerGetMessageBorder.do");
			return mapping.findForward("goMessage");
		} else if (!"".equals(owner) && !"".equals(deliver)) {
			// 发表站内信
			try {
				String sql = "insert into CustomerMessageBoard(Owner,Deliver,Context) values('"
						+ owner + "','" + deliver + "','" + context + "')";
				dao.executeUpdate(sql);
			} catch (Exception e) {
				e.printStackTrace();
				HttpSession session = request.getSession();
				session.setAttribute("title", "错误信息");
				session.setAttribute("message", "发表不成功！");
				session
						.setAttribute("returnUrl",
								"customerGetMessageBorder.do");
				return mapping.findForward("goMessage");
			}
		}
		HttpSession session = request.getSession();
		session.setAttribute("title", "成功信息");
		session.setAttribute("message", "发表成功！");
		session.setAttribute("returnUrl", "customerGetMessageBorder.do");
		return mapping.findForward("goMessage");
	}
}