qqeventprocessor.java

java写的qq代码实现qq的部分功能

/*
* LumaQQ - Java QQ Client
*
* Copyright (C) 2004 luma <[e-mail]>
*                    whg2001 <[e-mail]>
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
package edu.tsinghua.lumaqq.ui;

import java.util.ArrayList;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.eclipse.jface.dialogs.MessageDialog;
import org.eclipse.swt.widgets.Display;

import edu.tsinghua.lumaqq.IconHolder;
import edu.tsinghua.lumaqq.LumaQQ;
import edu.tsinghua.lumaqq.ModelUtils;
import edu.tsinghua.lumaqq.models.ClusterModel;
import edu.tsinghua.lumaqq.models.FriendModel;
import edu.tsinghua.lumaqq.models.GroupModel;
import edu.tsinghua.lumaqq.models.IQQNode;
import edu.tsinghua.lumaqq.qq.QQ;
import edu.tsinghua.lumaqq.qq.QQClient;
import edu.tsinghua.lumaqq.qq.Util;
import edu.tsinghua.lumaqq.qq.beans.ClusterInfo;
import edu.tsinghua.lumaqq.qq.beans.ContactInfo;
import edu.tsinghua.lumaqq.qq.beans.FriendOnlineEntry;
import edu.tsinghua.lumaqq.qq.beans.FriendStatus;
import edu.tsinghua.lumaqq.qq.beans.QQFriend;
import edu.tsinghua.lumaqq.qq.beans.QQUser;
import edu.tsinghua.lumaqq.qq.events.IQQListener;
import edu.tsinghua.lumaqq.qq.events.QQEvent;
import edu.tsinghua.lumaqq.qq.packets.in.ClusterCommandReplyPacket;
import edu.tsinghua.lumaqq.qq.packets.in.FriendChangeStatusPacket;
import edu.tsinghua.lumaqq.qq.packets.in.GetFriendOnlineReplyPacket;
import edu.tsinghua.lumaqq.qq.packets.in.GetUserInfoReplyPacket;
import edu.tsinghua.lumaqq.qq.packets.in.KeepAliveReplyPacket;
import edu.tsinghua.lumaqq.qq.packets.in.ReceiveIMPacket;
import edu.tsinghua.lumaqq.qq.packets.in.RequestKeyReplyPacket;
import edu.tsinghua.lumaqq.qq.packets.in.SystemNotificationPacket;
import edu.tsinghua.lumaqq.qq.packets.out.DeleteFriendPacket;
import edu.tsinghua.lumaqq.qq.packets.out.RequestKeyPacket;
import edu.tsinghua.lumaqq.ui.config.cluster.ClusterInfoWindow;
import edu.tsinghua.lumaqq.ui.config.user.UserInfoWindow;
import edu.tsinghua.lumaqq.ui.dialogs.LoginDialog;
import edu.tsinghua.lumaqq.ui.helper.MVCHelper;
import edu.tsinghua.lumaqq.ui.jobs.DownloadFriendRemarkJob;
import edu.tsinghua.lumaqq.ui.jobs.DownloadGroupJob;
import edu.tsinghua.lumaqq.ui.jobs.GetFriendListJob;
import edu.tsinghua.lumaqq.ui.jobs.JobExecutor;
import edu.tsinghua.lumaqq.ui.tool.HeadFactory;
import edu.tsinghua.lumaqq.ui.tool.ShellRegistry;
import edu.tsinghua.lumaqq.utils.OptionUtil;
import edu.tsinghua.swt.models.INode;

/**
 * QQ事件处理器
 * 
 * @author 马若劼 王华刚
 */
class QQEventProcessor implements IQQListener {
    // Log对象
    static Log log = LogFactory.getLog(QQEventProcessor.class);
    // 主窗口对象
	private MainShell main;
	
	private IconHolder icons;
	
	// 临时哈希表
	private Hashtable tempHash;
	
	// 登录重试次数，我这里处理最多重试6次
	// 如果第一次登录失败，则随机选择服务器重试3次
	// 如果依然失败，再随机选择服务器，并且强制使用tcp方式，再重试3次
	// 如果依然不行，报登录超时错误
	private int retryCount;
    
	/**
	 * 构造函数
	 */
	public QQEventProcessor(MainShell main) {
		this.main = main;
		tempHash = new Hashtable();
		icons = IconHolder.getInstance();
		retryCount = 0;
	}
	
	/**
	 * 重置变量状态
	 */
	public void clear() {
		main.getCurrentOnlines().clear();
		tempHash.clear();
		main.getTipHelper().setFirstTime(true);
	}
	
	/* (non-Javadoc)
	 * @see edu.tsinghua.lumaqq.qq.events.QQListener#qqEvent(edu.tsinghua.lumaqq.qq.events.QQEvent)
	 */
	public void qqEvent(QQEvent e) {
		switch(e.type) {
		    case QQEvent.QQ_GET_LOGIN_TOKEN_FAIL:
		        processLoginTimeout();
		    	break;
			case QQEvent.QQ_LOGIN_SUCCESS:
				processLoginSuccess();
				break;	
			case QQEvent.QQ_GET_FRIEND_ONLINE_SUCCESS:
				processGetFriendOnlineSuccess(e);
				break;
			case QQEvent.QQ_CHANGE_STATUS_SUCCESS:
				processChangeStatusSuccess();
				break;
			case QQEvent.QQ_CHANGE_STATUS_FAIL:
				processChangeStatusFail();
				break;
			case QQEvent.QQ_FRIEND_CHANGE_STATUS:
				processFriendChangeStatus(e);
				break;
			case QQEvent.QQ_RECEIVE_NORMAL_IM:
				processReceiveNormalIM(e);
				break;
			case QQEvent.QQ_RECEIVE_SMS:
			    processReceiveSMS(e);
				break;
		    case QQEvent.QQ_UNKNOWN_TYPE_IM:
		        processUnknownTypeIM(e);
		    	break;
			case QQEvent.QQ_REQUEST_SEND_FILE:
				processRequestSendFile(e);
				break;
			case QQEvent.QQ_KICKED_OUT_BY_SYSTEM:
				processKickedOutBySystem();
				break;
			case QQEvent.QQ_ADDED_BY_OTHERS:
			case QQEvent.QQ_REQUEST_ADD_ME:
			case QQEvent.QQ_REQUEST_ADD_OTHER_APPROVED:
			case QQEvent.QQ_REQUEST_ADD_OTHER_REJECTED:
				processReceiveSystemNotification(e);
				break;
			case QQEvent.QQ_LOGIN_PASSWORD_ERROR:
				processLoginPasswordError();
				break;
			case QQEvent.QQ_LOGIN_UNKNOWN_ERROR:
				processLoginUnknownError();
				break;
			case QQEvent.QQ_LOGIN_REDIRECT_NULL:
			    processLoginRedirectNull();
				break;
			case QQEvent.QQ_DELETE_FRIEND_SUCCESS:
			case QQEvent.QQ_DELETE_FRIEND_FAIL:
				processDeleteFriendSuccess(e);
				break;
			/*case QQEvent.QQ_DELETE_FRIEND_FAIL:
				processDeleteFriendFail(e);
				break;*/
			case QQEvent.QQ_KEEP_ALIVE_SUCCESS:
				processKeepAliveSuccess(e);
				break;
			case QQEvent.QQ_CREATE_CLUSTER_SUCCESS:
				processClusterCreateSuccess(e);
				break;
			case QQEvent.QQ_CREATE_TEMP_CLUSTER_SUCCESS:
			    processClusterCreateTempClusterSuccess(e);
				break;
			case QQEvent.QQ_GET_MEMBER_INFO_SUCCESS:
				processClusterGetMemberInfoSuccess(e);
				break;
			case QQEvent.QQ_GET_ONLINE_MEMBER_SUCCESS:
			    processClusterGetOnlineMemberSuccess(e);	
				break;
			case QQEvent.QQ_EXIT_CLUSTER_SUCCESS:
			case QQEvent.QQ_EXIT_TEMP_CLUSTER_SUCCESS:
				processClusterExitClusterSuccess(e);
				break;
			case QQEvent.QQ_RECEIVE_CLUSTER_IM:
			case QQEvent.QQ_RECEIVE_TEMP_CLUSTER_IM:
			case QQEvent.QQ_RECEIVE_UNKNOWN_CLUSTER_IM:
				processReceiveClusterIM(e);
				break;
			case QQEvent.QQ_I_AM_ADDED_TO_CLUSTER:
				processIAmAddedToCluster(e);
				break;
			case QQEvent.QQ_I_AM_REMOVED_FROM_CLUSTER:
				processIAmRemovedFromCluster(e);
				break;
			case QQEvent.QQ_REQUEST_JOIN_CLUSTER:
				processRequestJoinCluster(e);
				break;
			case QQEvent.QQ_REQUEST_JOIN_CLUSTER_APPROVED:
				processRequestJoinClusterApproved(e);
				break;
			case QQEvent.QQ_REQUEST_JOIN_CLUSTER_REJECTED:
				processRequestJoinClusterRejected(e);
				break;
			case QQEvent.QQ_OPERATION_TIMEOUT:
			    switch(e.operation) {
			        case QQ.QQ_CMD_LOGIN:
			        case QQ.QQ_CMD_REQUEST_LOGIN_TOKEN:
						processLoginTimeout();
			        	break;
			    }
				break;
			case QQEvent.QQ_CONNECTION_LOST:
				processLoginTimeout();
				break;
		    case QQEvent.QQ_PROXY_ERROR:
		        processProxyError(e);
		    	break;
		    case QQEvent.QQ_NETWORK_ERROR:
		        processNetworkError(e);
		    	break;
		    case QQEvent.QQ_REQUEST_KEY_SUCCESS:
		        processRequestKeySuccess(e);
		    	break;
		    case QQEvent.QQ_REQUEST_KEY_FAIL:
		        processRequestKeyFail(e);
		    	break;
			case QQEvent.QQ_GET_CLUSTER_INFO_SUCCESS:
				processClusterGetInfoSuccess(e);
				break;
			case QQEvent.QQ_GET_TEMP_CLUSTER_INFO_SUCCESS:
			    processClusterGetTempClusterInfoSuccess(e);
				break;
			case QQEvent.QQ_GET_CLUSTER_INFO_FAIL:
			case QQEvent.QQ_GET_MEMBER_INFO_FAIL:
			case QQEvent.QQ_GET_ONLINE_MEMBER_FAIL:
			case QQEvent.QQ_GET_TEMP_CLUSTER_INFO_FAIL:
			    processClusterCommandFail(e);
				break;
			case QQEvent.QQ_SEND_TEMP_CLUSTER_IM_FAIL:
			case QQEvent.QQ_SEND_CLUSTER_IM_EX_FAIL:
			    processSendClusterIMFail(e);
				break;
			case QQEvent.QQ_GET_USER_INFO_SUCCESS:
				processGetUserInfoSuccess(e);
				break;
		}
	}

    /**
     * 处理创建临时群成功事件
     * 
     * @param e
     */
    private void processClusterCreateTempClusterSuccess(QQEvent e) {
		final ClusterCommandReplyPacket packet = (ClusterCommandReplyPacket)e.getSource();
		main.getDisplay().syncExec(
			new Runnable() {
				public void run() {
				    main.getMVCHelper().addTempCluster(packet.type, packet.clusterId, packet.parentClusterId);
				}
			}
		);
    }

    /**
     * 处理重定向到0地址事件
     */
    private void processLoginRedirectNull() {
		main.getDisplay().syncExec(
			new Runnable() {
				public void run() {
				    // 自动随机更换其他服务器登录
				    main.logout();
				    main.checkLogin(true, false);
				}				
			}
		);
    }

    /**
     * 初始网络错误
     * 
     * @param e
     */
    private void processNetworkError(final QQEvent e) {
        if(main.getClient().getUser().getStatus() != QQ.QQ_FRIEND_STATUS_OFFLINE) {
	        main.getDisplay().syncExec(new Runnable() {
	            public void run() {
	                Exception ex = (Exception)e.getSource();
	                String msg = ex.getMessage();
	                main.getClient().getUser().setStatus(QQ.QQ_FRIEND_STATUS_OFFLINE);
	                main.logout();
	                MessageDialog.openError(main.getShell(), LumaQQ.getString("message.box.network.error.title"), msg);
	            }
	        });            
        }
    }

    /**
	 * 处理请求密钥失败事件
     * @param e
     */
    private void processRequestKeyFail(QQEvent e) {
        RequestKeyPacket packet = (RequestKeyPacket)e.getSource();
        main.getClient().requestKey(packet.getRequest());
    }

    /**
	 * 处理请求密钥成功事件
	 * 
     * @param e
     * 		QQEvent
     */
    private void processRequestKeySuccess(QQEvent e) {
        RequestKeyReplyPacket packet = (RequestKeyReplyPacket)e.getSource();
        QQUser me = main.getClient().getUser();
        if(packet.keyType == QQ.QQ_REQUEST_FILE_AGENT_KEY) {
	        me.setFileAgentKey(packet.key);
	        me.setFileAgentToken(packet.token);            
        } else if(packet.keyType == QQ.QQ_REQUEST_UNKNOWN_KEY) {
            me.setUnknownKey(packet.key);
            me.setUnknownToken(packet.token);
        }
    }

    /**
	 * 处理代理出错事件
	 * 
     * @param e
     * 			QQEvent
     */
    private void processProxyError(final QQEvent e) {
        if(main.getClient().getUser().getStatus() != QQ.QQ_FRIEND_STATUS_OFFLINE) {
	        main.getDisplay().syncExec(new Runnable() {
	            public void run() {
	                Exception ex = (Exception)e.getSource();
	                String msg = ex.getMessage();
	                main.getClient().getUser().setStatus(QQ.QQ_FRIEND_STATUS_OFFLINE);
	                main.logout();
	                MessageDialog.openError(main.getShell(), LumaQQ.getString("message.box.proxy.error.title"), msg);
	            }
	        });            
        }
    }

    /**
	 * 处理未知IM事件，这个目前用来自动拒绝TCP方式的文件传输，等到TCP实现时，不再需要
	 * 
     * @param e
     * 		QQEvent
     */
    private void processUnknownTypeIM(QQEvent e) {
        ReceiveIMPacket packet = (ReceiveIMPacket)e.getSource();
        if(packet.header.type == QQ.QQ_RECV_IM_FROM_FRIEND || packet.header.type == QQ.QQ_RECV_IM_FROM_STRANGER) {
            if(packet.normalHeader.type == QQ.QQ_IM_TCP_REQUEST)
                main.getClient().rejectSendFile(packet.normalHeader.sender, packet.normalHeader.sequence, false);
        }
    }

	/**
	 * 处理对方拒绝我加入群的事件
	 * 
	 * @param e
	 * 		QQEvent
	 */
	private void processRequestJoinClusterRejected(QQEvent e) {
		final ReceiveIMPacket packet = (ReceiveIMPacket)e.getSource();
		main.getDisplay().syncExec(
			new Runnable() {
				public void run() {
					main.getMessageHelper().putClusterNotification(packet);
				}				
			}
		);
	}

	/**
	 * 处理对方同意我加入群的事件
	 * 
	 * @param e
	 * 			QQEvent
	 */
	private void processRequestJoinClusterApproved(QQEvent e) {
		final ReceiveIMPacket packet = (ReceiveIMPacket)e.getSource();
		ClusterModel c = main.getMVCHelper().getClusterModel(packet.header.sender);
		if(c == null) {
			main.getDisplay().syncExec(
				new Runnable() {
					public void run() {
					    main.getMVCHelper().addCluster(packet.header.sender, false);
						main.getMessageHelper().putClusterNotification(packet);
					}				
				}
			);
		}
	}

	/**
	 * 处理别人申请加入群的事件
	 * 
	 * @param e
	 * 			QQEvent
	 */
	private void processRequestJoinCluster(QQEvent e) {
		final ReceiveIMPacket packet = (ReceiveIMPacket)e.getSource();
		ClusterModel c = main.getMVCHelper().getClusterModel(packet.header.sender);
		if(c != null) {
			main.getDisplay().syncExec(
				new Runnable() {
					public void run() {
					    main.getMessageHelper().putClusterNotification(packet);
					}				
				}
			);
		}
	}

	/**