messageajax.java

野蔷薇论坛源码 java 自己看看吧。 学习用

/* 
 * Created on 2007-5-2
 * Last modified on 2007-8-22
 * Powered by YeQiangWei.com
 */
package com.yeqiangwei.club.view.ajax;

import java.io.IOException;
import java.io.PrintWriter;
import java.util.List;

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

import org.apache.log4j.Logger;

import com.yeqiangwei.club.service.ServiceLocator;
import com.yeqiangwei.club.service.ServiceWrapper;
import com.yeqiangwei.club.service.message.MessageBlacklistService;
import com.yeqiangwei.club.service.message.MessageService;
import com.yeqiangwei.club.controller.form.MessageForm;
import com.yeqiangwei.club.controller.form.build.MessageBuild;
import com.yeqiangwei.club.exception.ClubException;
import com.yeqiangwei.util.ParamUtils;
import com.yeqiangwei.util.StringHelper;
import com.yeqiangwei.util.Validator;
import com.yeqiangwei.club.util.MessageUtils;

public class MessageAjax extends HttpServlet {
	
	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;
	
	private static final Logger logger = Logger.getLogger(MessageAjax.class);

	public void doGet(HttpServletRequest request,HttpServletResponse response)
		throws ServletException, IOException 
	{
		response.setContentType("text/HTML;charset=UTF-8"); 
		PrintWriter out = response.getWriter();
		out.close();
	}
	
	public void doPost(HttpServletRequest request,HttpServletResponse response)
		throws ServletException, IOException 
	{
		response.setContentType("text/HTML;charset=UTF-8"); 
		PrintWriter out = response.getWriter();
		String act = ParamUtils.getStringParameter(request,"act");
		if(act.equals("delblacklist")){
			StringBuffer sb = new StringBuffer("");
			List<Integer> ids = StringHelper.stringToIntegerList(ParamUtils.getStringParameter(request,"ids"),"|");
			int c;
			try {
				c = this.getMessageBlacklistService().delete(ids);
			} catch (ClubException e) {
				logger.error(e.toString());
				c = 0;
			}
			sb.append("{\"message\":\"");
			sb.append(MessageUtils.getMessage("success"));
			sb.append("\"");
			if(c>0&&!Validator.isEmpty(ids)){
				sb.append(",\"ids\":\"");
				for(int i=0; i<ids.size(); i++){
					sb.append(ids.get(i));
					if(i<ids.size()-1){
						sb.append(",");
					}
				}
				sb.append("\"");
			}
			sb.append("}");
			out.print(sb);
		}
		else if(act.equals("trash")){
			this.getMessageService().trashs(ParamUtils.getStringParameter(request,"ids"),true);
			out.print(MessageUtils.getMessage("success"));
		}
		else if(act.equals("untrash")){
			this.getMessageService().trashs(ParamUtils.getStringParameter(request,"ids"),false);
			out.print(MessageUtils.getMessage("success"));
		}
		else if(act.equals("deltake")){
			try {
				this.getMessageService().delete(ParamUtils.getStringParameter(request,"ids"),"deltake");
				out.print(MessageUtils.getMessage("success"));
			} catch (ClubException e) {
				out.print(e.toString());
			}
		}
		else if(act.equals("delsend")){
			try {
				this.getMessageService().delete(ParamUtils.getStringParameter(request,"ids"),"delsend");
				out.print(MessageUtils.getMessage("success"));
			} catch (ClubException e) {
				out.print(e.toString());
			}
			out.print(MessageUtils.getMessage("success"));
		}
		else if(act.equals("refuse")){
			try {
				this.getMessageService().refuse(ParamUtils.getStringParameter(request,"ids"));
				out.print(MessageUtils.getMessage("success"));
			} catch (ClubException e) {
				out.print(e.toString());
			}
		}
		else if(act.equals("remessage")){
			try {
				MessageForm messageForm = new MessageBuild(request).build();
				this.getMessageService().sends(messageForm);
				out.print(MessageUtils.getMessage("success"));
			} catch (ClubException e) {
				out.print(e.toString());
			}
		}
		else {
			logger.error("MessageAjax非法请求 IP"+request.getRemoteAddr());
		}
		out.close();
	}
	
	public MessageService getMessageService(){
		return ServiceWrapper.<MessageService>getSingletonInstance(ServiceLocator.MESSAGE);
	}

	public MessageBlacklistService getMessageBlacklistService(){
		return ServiceWrapper.<MessageBlacklistService>getSingletonInstance(ServiceLocator.MESSAGEBLACKLIST);
	}
}