customergroupindexaction.java

基于struts的网上商店源码

/*
 * 作者:李斌
 * 时间:2007年12月04日
 * 功能:创建用户群
 */
package com.mole.struts.action;

import java.util.ArrayList;

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

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;

/**
 * MyEclipse Struts Creation date: 12-04-2007 Creator: Li Bin XDoclet
 * definition:
 * 
 * @struts.action input="/customerGroupIndex.jsp" validate="true"
 * @struts.action-forward name="goIndex" path="/customerBlogIndex.jsp"
 */
public class CustomerGroupIndexAction 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) {
		// TODO Auto-generated method stub
		DBConnector dbc = new DBConnector();
		String action = request.getParameter("action");
		String groupID = request.getParameter("groupID");
		String user = String.valueOf(request.getSession().getAttribute("user"));
		String sql;
		// 群相关操作
		if (null != user) {
			// 加入群
			if (null != action && action.equals("join")) {
				sql = "insert into [CustomerGroupMember]([ID],[GroupID]) values(?,?)";
				try {
					dbc.executeUpdate(sql, user, groupID);
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
			// 退出群
			if (null != action && action.equals("exit")) {
				sql = "delete from [CustomerGroupMember] where [ID]=" + user
						+ " and [GroupID]=" + groupID;
				try {
					dbc.executeQuery(sql);
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
			// 解散群
			if (null != action && action.equals("disband")) {
				try {
					dbc.executeStoredProcedure("sp_DisbandGroup(?)", groupID);
				} catch (Exception e) {
					e.printStackTrace();
				}
				return new ActionForward("/customer.do");
			}
			// 判断是否已经加入此群
			ArrayList<Object[]> joined = null;
			sql = "select [IsHost] from [CustomerGroupMember] where [GroupID]="
					+ groupID + " and [ID]=" + user;
			try {
				joined = dbc.executeQuery(sql);
			} catch (Exception e) {
				e.printStackTrace();
			}
			request.setAttribute("Joined", joined);
		}
		// 获取群信息
		ArrayList<Object[]> list = null;
		sql = "select a.[ID],a.[Name],a.[KeyWord],a.[Description],a.[GroupImage],a.[GroupMemberNum],a.[HostName] from [v_CustomerGroupDetail] a where a.[ID]="
				+ groupID;
		try {
			list = dbc.executeQuery(sql);
		} catch (Exception e) {
			e.printStackTrace();
		}
		request.setAttribute("GroupDetail", list);
		// 获取群公告
		// 获取群日志
		ArrayList<Object[]> blogList = null;
		sql = "select top 5 a.[ID],a.[Title],a.[NickName],convert(varchar(20),a.[IssueTime],120),a.[Revert] from [v_CustomerGroupBlogList] a where a.[GroupID]="
				+ groupID + " order by a.[ID] DESC";
		try {
			blogList = dbc.executeQuery(sql);
		} catch (Exception e) {
			e.printStackTrace();
		}
		request.setAttribute("GroupBlogList", blogList);
		// 获取群成员
		ArrayList<Object[]> memberList = null;
		sql = "select top 10 a.[ID],a.[NickName] from [Customer] a,[CustomerGroupMember] b where a.[ID]=b.[ID] and b.[GroupID]="
				+ groupID + " order by b.[JoinDate] DESC";
		try {
			memberList = dbc.executeQuery(sql);
		} catch (Exception e) {
			e.printStackTrace();
		}
		request.setAttribute("User", user);
		request.setAttribute("GroupMember", memberList);
		return mapping.findForward("goIndex");
	}
}