adminqueryassociatorsaction.java

基于struts的网上商店源码

/*
 * 作者：张建
 * 功能：管理员查询会员
 * 时间： 11-21-2007
 */
package com.mole.struts.action;

import java.util.ArrayList;
import java.util.Hashtable;

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.bean.CustomerInfoBean;
import com.mole.struts.bean.Page;
import com.mole.struts.dao.AdminQueryAssociatorsDAO;
import com.mole.struts.dao.DBConnector;
import com.mole.struts.form.AdminQueryAssociatorsForm;

public class AdminQueryAssociatorsAction extends Action {
	private Hashtable<String, CustomerInfoBean> hash;
	private AdminQueryAssociatorsDAO dao = new AdminQueryAssociatorsDAO();

	public ActionForward execute(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		AdminQueryAssociatorsForm adminQueryAssociatorsForm = (AdminQueryAssociatorsForm) form;

		String action = request.getParameter("action");
		String loginName = request.getParameter("loginName");

		String cusName = adminQueryAssociatorsForm.getCusName() == "" ? null
				: adminQueryAssociatorsForm.getCusName();
		String merName = adminQueryAssociatorsForm.getMerName() == "" ? null
				: adminQueryAssociatorsForm.getMerName();
		String message = adminQueryAssociatorsForm.getMessageContent();
		String senderID = adminQueryAssociatorsForm.getSenderID();
		String receiverID = adminQueryAssociatorsForm.getReceiverID();
		String title = adminQueryAssociatorsForm.getTitle();

		Page page = new Page();
		int pageSize = (request.getParameter("pageSizeSelect") == null ? 5
				: Integer.parseInt(request.getParameter("pageSizeSelect")));
		int currentPage = (request.getParameter("page") == null ? 1 : Integer
				.parseInt(request.getParameter("page")));
		if (cusName == null && merName == null) {
			cusName = "all";
		}
		try {
			if ("search".equals(action)) // 会员信息
			{
				if ("all".equals(cusName)) {
					int count = dao.getAllRecordPageInfo(pageSize);
					page.setPageSize(pageSize);
					page.setRecordCount(count);
					page.setPageCount((count + pageSize - 1) / pageSize);
					page.setCurrentPage(currentPage);
					hash = new Hashtable<String, CustomerInfoBean>();
					try {
						hash = dao.queryAllAssociators(page.getCurrentPage());
					} catch (Exception e) {
						e.printStackTrace();
						HttpSession session = request.getSession();
						session.setAttribute("title", "错误信息");
						session.setAttribute("message", "查询失败，请再试一遍！");
						session.setAttribute("returnUrl",
								"adminQueryAssociators.do?action=search");
						return mapping.findForward("goMessage");
					}
					request.setAttribute("CustomerInfoBean", hash.elements());
					request.setAttribute("Page", page);
					return mapping.findForward("goAdminQueryAssociators");
				} else {
					int count = dao.getPageInfo(cusName, merName, pageSize);
					page.setPageSize(pageSize);
					page.setRecordCount(count);
					page.setPageCount((count + pageSize - 1) / pageSize);
					page.setCurrentPage(currentPage);
					hash = new Hashtable<String, CustomerInfoBean>();
					try {
						hash = dao.queryAssociators(cusName, merName, page
								.getCurrentPage());
					} catch (Exception e) {
						e.printStackTrace();
						HttpSession session = request.getSession();
						session.setAttribute("title", "错误信息");
						session.setAttribute("message", "查询失败，请再试一遍！");
						session.setAttribute("returnUrl",
								"adminQueryAssociators.do?action=search");
						return mapping.findForward("goMessage");
					}
					request.setAttribute("CustomerInfoBean", hash.elements());
					request.setAttribute("Page", page);
					return mapping.findForward("goAdminQueryAssociators");
				}
			} else if ("send".equals(action)) // 给会员发送消息
			{
				DBConnector dbdao = new DBConnector();
				String updateSql = "";
				String[] idArray = receiverID.split(" ");
				for (int i = 0; i < idArray.length; i++) {
					System.out.println(idArray[i]);
					updateSql = "insert into [MessageCenter](SenderID,ReceiverID,SenderType,ReceiverType,Title,Message,State) values('"
							+ senderID
							+ "','"
							+ idArray[i]
							+ "','Administrator','Customer','"
							+ title
							+ "','"
							+ message + "','0')";
					dbdao.executeUpdate(updateSql);
				}
				HttpSession session = request.getSession();
				session.setAttribute("title", "成功信息");
				session.setAttribute("message", "发送成功！");
				session.setAttribute("returnUrl",
						"adminQueryAssociators.do?action=search");
				return mapping.findForward("goMessage");
			} else if ("detail".equals(action)) // 查询详细信息
			{
				DBConnector dbdao = new DBConnector();
				String selectSql = "select LoginName,State,Nickname,Name,Gender,Email,Telephone,Cellphone,Address,Company,FaceImage,FaceWidth,FaceHeight,CreateDate,LastLogin,Interest,Description from [Customer] where LoginName='"
						+ loginName + "'";
				ArrayList<Object[]> al = dbdao.executeQuery(selectSql);
				Object[] result = al.get(0);
				request.setAttribute("detail", result);
				return mapping.findForward("goAdminQueryAssociatorDetail");
			} else if ("remove".equals(action)) // 删除会员
			{
				DBConnector dbdao = new DBConnector();
				String updateSql = "update [Customer] set [State]='1' where LoginName='"
						+ loginName + "'";
				dbdao.executeUpdate(updateSql);
				HttpSession session = request.getSession();
				session.setAttribute("title", "成功信息");
				session.setAttribute("message", "删除成功！");
				session.setAttribute("returnUrl",
						"adminQueryAssociators.do?action=search");
				return mapping.findForward("goMessage");
			}
		} catch (Exception e) {
			e.printStackTrace();
			HttpSession session = request.getSession();
			session.setAttribute("title", "错误信息");
			session.setAttribute("message", "打开页面错误，请再试一次！");
			session.setAttribute("returnUrl",
					"adminQueryAssociators.do?action=search");
			return mapping.findForward("goMessage");
		}
		return null;
	}
}