sendmsgservlet.java

oa办公系统

package cn.jx.ecjtu.oa.servlets.msg;

import java.io.IOException;
import java.io.PrintWriter;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

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

import cn.jx.ecjtu.oa.common.Constant;
import cn.jx.ecjtu.oa.ps.pojo.LoginUser;
import cn.jx.ecjtu.oa.ps.pojo.Message;
import cn.jx.ecjtu.oa.services.MessageService;
import cn.jx.ecjtu.oa.services.Result;
import cn.jx.ecjtu.oa.services.ServiceFactory;
import cn.jx.ecjtu.oa.services.UserInSession;
import cn.jx.ecjtu.oa.services.impl.MessageServiceImpl;

/**
 * FileName:${file_name},v 1.0 created in ${date} ${time}
 * Created by zxj&zhh&zy
 * Copyright (c) 2008 wanczy
 * All Rights Reserved.
 */
public class SendMsgServlet extends HttpServlet {

	/**
	 * Constructor of the object.
	 */
	public SendMsgServlet() {
		super();
	}

	/**
	 * Destruction of the servlet. <br>
	 */
	public void destroy() {
		super.destroy(); // Just puts "destroy" string in log
		// Put your code here
	}

	/**
	 * The doGet method of the servlet. <br>
	 *
	 * This method is called when a form has its tag value method equals to get.
	 * 
	 * @param request the request send by the client to the server
	 * @param response the response send by the server to the client
	 * @throws ServletException if an error occurred
	 * @throws IOException if an error occurred
	 */
	public void doGet(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {

		
		doPost(request,response);
	
	}

	/**
	 * The doPost method of the servlet. <br>
	 *
	 * This method is called when a form has its tag value method equals to post.
	 * 
	 * @param request the request send by the client to the server
	 * @param response the response send by the server to the client
	 * @throws ServletException if an error occurred
	 * @throws IOException if an error occurred
	 */
	public void doPost(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {
		HttpSession session=request.getSession();
		UserInSession user=(UserInSession)session.getAttribute(Constant.USER_IN_SESSION);
		if(user != null){//发送方
			String accId=request.getParameter("toId");//获取接收者用户的ID
			String content=request.getParameter("msg_info");//获得输入的短消息内容
			
            Timestamp sendtime=new Timestamp(System.currentTimeMillis());	
           
			if(accId==null ||"".equals(accId.trim())){//接收方空,不能发送
				request.getRequestDispatcher("../error.jsp").forward(request, response);
			}
			else{//发送生成的短消息
              // Message msg= new Message(1, 1, 1,  sendtime,  content, false,  "12", "21",  "21");             
				String [] accIds=accId.split(",");
				int length=accIds.length;
				int [] arrids=new int[length];
				for(int i=0;i<length;i++)
				{
					arrids[i]=Integer.parseInt(accIds[i]);
				}//
				if(msgService.sendMsg(1,user.getId(),content,"用户短信息", "image/user.gif","",arrids))
					{//发送成功
					//request.getRequestDispatcher("submit.jsp").forward(request, response);
					//request.setAttribute("toId", accId);
					request.getRequestDispatcher("submit.jsp").forward(request, response);
					}
				else{//发送失败
					request.getRequestDispatcher("../error.jsp").forward(request, response);
				}
					
				
			}
			
		}
	}
		
	
	
	private List<Integer> getAccIdList(String accId){
		String [] accIds=accId.split(",");
		List<Integer> ids=new ArrayList<Integer>();
		for(String id:accIds){
			ids.add(new Integer(id));
		}
		return ids;
	}

	/**
	 * Initialization of the servlet. <br>
	 *
	 * @throws ServletException if an error occure
	 */
	private MessageService msgService;
	public void init() throws ServletException {
		msgService=(MessageService)ServiceFactory.getService(MessageService.class);
	}

}