sendaction.java

JSP+AJAX开发的聊天室(毕业设计)

package org.yeeku.action;

import com.opensymphony.xwork2.ActionContext;
import java.util.*;
import org.yeeku.action.base.BaseAction;

import java.sql.*;
import java.util.Vector;
import org.apache.struts2.ServletActionContext;
import org.yeeku.service.ChatMessage;
import javax.servlet.ServletContext;
import org.yeeku.dao.DaoManager;
public class SendAction extends BaseAction
  {     
        private String messagemethod;
	private String toname;
	private String content;
        
        @Override
	public String execute() throws Exception
	 {
           Map session = ActionContext.getContext().getSession();
           String UserName=(String)session.get("username");              
           ServletContext M_application=ServletActionContext.getServletContext();
           if(messagemethod.equals("personal"))
            { 
              String checkname="与"+toname+"*聊天";
              List checkuser=(List)M_application.getAttribute(UserName);
              String firstuser=(String)checkuser.get(0);
              if(firstuser.equals(checkname))
               {
                 String msg=UserName+"说:"+content; 
                 ChatMessage addmessage= new ChatMessage();
                 addmessage.addToPersonalChat(UserName,msg,M_application);
                 addmessage.addToPersonalChat(toname,msg,M_application);
                 
               }
               else
               {
                 if(!(firstuser.equals("请等待对方回复") || firstuser.equals("请发送消息")))
                   {
                    int i=firstuser.indexOf("*");
                    String clearname=firstuser.substring(1,i);
                    List  checkuser1;
                    checkuser1=new ArrayList();
                    checkuser1.add("请发送消息");
                    M_application.setAttribute(clearname,checkuser1);
                    } 
                 List  checkuser2;
                 checkuser2=new ArrayList();
                 checkuser2.add(checkname);
                 M_application.setAttribute(UserName,checkuser2);
                 List  checkuser3;
                 checkuser3=new ArrayList();
                 checkname="请等待对方回复";
                 checkuser3.add(checkname);
                 M_application.setAttribute(toname,checkuser3);
                 String msg=UserName+"说:"+content; 
                 ChatMessage addmessage= new ChatMessage();
                 addmessage.addToPersonalChat(UserName,msg,M_application);
                 addmessage.addToPersonalChat(toname,msg,M_application);
                 
                  
               }
                 
             }
            else
             {
               if(M_application.getAttribute(toname)!=null)
                 {
                       String msg=UserName+"对"+toname+"说:"+content;  
                       ChatMessage addmessage= new ChatMessage();
                       addmessage.addToChatmsg(msg,M_application);
                 }
             }
          java.util.Date date=new java.util.Date();
          String datetime=new Timestamp(date.getTime()).toString();
          String title=" ";
          DaoManager.begin();       
          boolean messagesend=mgr.addMessage(UserName,toname,content,title,datetime);
          DaoManager.commit();
          if(messagesend)
            {
               return SUCCESS;
            }
          else
           {
               addActionError("消息发送出错");
           }
          return "failure";
        }
       public void setMessagemethod(String messagemethod)
	{
		this.messagemethod=messagemethod;
	}
	public String getMessagemethod()
	{
		 return this.messagemethod;
	}
       public void setContent(String content)
	{
		this.content = content;
	}
	public String getContent()
	{
		 return this.content;
	}
	public void setToname(String toname)
	{
		this.toname = toname;
	}
	public String getToname()
	{
		 return this.toname;
	}
        
}