qqeventprocessor.java

lumaQQ的源文件

/*
* 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 static edu.tsinghua.lumaqq.resource.Messages.*;

import java.util.ArrayList;
import java.util.HashMap;
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.models.Cluster;
import edu.tsinghua.lumaqq.models.ClusterType;
import edu.tsinghua.lumaqq.models.Group;
import edu.tsinghua.lumaqq.models.ModelRegistry;
import edu.tsinghua.lumaqq.models.ModelUtils;
import edu.tsinghua.lumaqq.models.Organization;
import edu.tsinghua.lumaqq.models.Status;
import edu.tsinghua.lumaqq.models.User;
import edu.tsinghua.lumaqq.qq.QQ;
import edu.tsinghua.lumaqq.qq.QQPort;
import edu.tsinghua.lumaqq.qq.beans.CardStub;
import edu.tsinghua.lumaqq.qq.beans.ContactInfo;
import edu.tsinghua.lumaqq.qq.beans.FriendOnlineEntry;
import edu.tsinghua.lumaqq.qq.beans.Member;
import edu.tsinghua.lumaqq.qq.beans.QQFriend;
import edu.tsinghua.lumaqq.qq.beans.QQLive;
import edu.tsinghua.lumaqq.qq.beans.QQOrganization;
import edu.tsinghua.lumaqq.qq.beans.QQUser;
import edu.tsinghua.lumaqq.qq.beans.SMSReply;
import edu.tsinghua.lumaqq.qq.beans.SimpleClusterInfo;
import edu.tsinghua.lumaqq.qq.events.IQQListener;
import edu.tsinghua.lumaqq.qq.events.QQEvent;
import edu.tsinghua.lumaqq.qq.packets.ErrorPacket;
import edu.tsinghua.lumaqq.qq.packets.in.AddFriendExReplyPacket;
import edu.tsinghua.lumaqq.qq.packets.in.ClusterCommandReplyPacket;
import edu.tsinghua.lumaqq.qq.packets.in.FriendChangeStatusPacket;
import edu.tsinghua.lumaqq.qq.packets.in.GetOnlineOpReplyPacket;
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.SendSMSReplyPacket;
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.qq.packets.out.SendIMPacket;
import edu.tsinghua.lumaqq.ui.config.cluster.ClusterInfoWindow;
import edu.tsinghua.lumaqq.ui.config.user.UserInfoWindow;
import edu.tsinghua.lumaqq.ui.helper.CheckUpdateThread;
import edu.tsinghua.lumaqq.ui.helper.ShellRegistry;
import edu.tsinghua.lumaqq.ui.jobs.BackgroundJobExecutor;
import edu.tsinghua.lumaqq.ui.jobs.DownloadCustomHeadJob;
import edu.tsinghua.lumaqq.ui.jobs.DownloadFriendRemarkJob;
import edu.tsinghua.lumaqq.ui.jobs.DownloadGroupJob;
import edu.tsinghua.lumaqq.ui.jobs.DownloadSignatureJob;
import edu.tsinghua.lumaqq.ui.jobs.GetCustomHeadInfoJob;
import edu.tsinghua.lumaqq.ui.jobs.GetFriendLevelJob;
import edu.tsinghua.lumaqq.ui.jobs.GetFriendListJob;
import edu.tsinghua.lumaqq.ui.jobs.GetUserPropertyJob;
import edu.tsinghua.lumaqq.ui.jobs.IExecutor;
import edu.tsinghua.lumaqq.ui.jobs.IJob;

/**
 * QQ事件处理器
 * 
 * @author luma 王华刚
 */
class QQEventProcessor implements IQQListener {
    // Log对象
    static Log log = LogFactory.getLog(QQEventProcessor.class);
    // 主窗口对象
	private MainShell main;
	
	// 临时哈希表
	private Map<User, User> tempHash;
	
	// 登录重试次数，我这里处理最多重试6次
	// 如果第一次登录失败，则随机选择服务器重试3次
	// 如果依然失败，再随机选择服务器，并且强制使用tcp方式，再重试3次
	// 如果依然不行，报登录超时错误
	private int retryCount;
    
	/**
	 * 构造函数
	 */
	public QQEventProcessor(MainShell main) {
		this.main = main;
		tempHash = new HashMap<User, User>();
		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_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_ADDED_BY_OTHERS_EX:
			case QQEvent.QQ_REQUEST_ADD_ME:
			case QQEvent.QQ_REQUEST_ADD_ME_EX:
			case QQEvent.QQ_REQUEST_ADD_OTHER_APPROVED:
			case QQEvent.QQ_REQUEST_ADD_OTHER_REJECTED:
			case QQEvent.QQ_REQUEST_ADD_OTHER_APPROVED_AND_ADD:
				processReceiveSystemNotification(e);
				break;
			case QQEvent.QQ_LOGIN_FAIL:
				processLoginFail(e);
				break;
			case QQEvent.QQ_LOGIN_UNKNOWN_ERROR:
				processLoginUnknownError();
				break;
			case QQEvent.QQ_LOGIN_REDIRECT_NULL:
			    processLoginRedirectNull();
				break;
			case QQEvent.QQ_ADD_FRIEND_SUCCESS:
			case QQEvent.QQ_ADD_FRIEND_ALREADY:
				processAddFriendSuccess(e);
				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:
			case QQEvent.QQ_DISMISS_CLUSTER_SUCCESS:
				processClusterExitClusterSuccess(e);
				break;
			case QQEvent.QQ_RECEIVE_SMS:
				processReceiveSMS(e);
				break;
			case QQEvent.QQ_RECEIVE_DISK_NOTIFICATION:
				processReceiveDiskNotification(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_RECEIVE_TEMP_SESSION_IM:
				processReceiveTempSessionIM(e);
				break;
			case QQEvent.QQ_I_AM_ADDED_TO_CLUSTER:
				processIAmAddedToCluster(e);
				break;
			case QQEvent.QQ_ADMIN_ENTITLED:
				processAdminEntitled(e);
				break;
			case QQEvent.QQ_ADMIN_WITHDRAWED:
				processAdminWithdrawed(e);
				break;
			case QQEvent.QQ_SET_ROLE_SUCCESS:
				processSetRoleSuccess(e);
				break;
			case QQEvent.QQ_TRANSFER_ROLE_SUCCESS:
				processTransferRoleSuccess(e);
				break;
			case QQEvent.QQ_SET_ROLE_FAIL:
			case QQEvent.QQ_TRANSFER_ROLE_FAIL:
				processRoleOpFail(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_RUNTIME_ERROR:
		    	processRuntimeError(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_SEND_IM_SUCCESS:
				processSendIMSucess(e);
				break;
			case QQEvent.QQ_SMS_SENT:
				processSMSSent(e);
				break;
			case QQEvent.QQ_GET_USER_INFO_SUCCESS:
				processGetUserInfoSuccess(e);
				break;
			case QQEvent.QQ_SUB_CLUSTER_OP_SUCCESS:
				processClusterSubClusterOpSuccess(e);
				break;
			case QQEvent.QQ_UPDATE_ORGANIZATION_SUCCESS:
				processClusterUpdateOrganizationSuccess(e);
				break;
			case QQEvent.QQ_GET_CARD_BATCH_SUCCESS:
				processClusterGetCardBatchSuccess(e);
				break;
			case QQEvent.QQ_FRIEND_SIGNATURE_CHANGED:
				processFriendSignatureChanged(e);
				break;
			case QQEvent.QQ_FRIEND_PROPERTY_CHANGED:
				processFriendPropertyChanged(e);
				break;
			case QQEvent.QQ_FRIEND_CUSTOM_HEAD_CHANGED:
				processFriendCustomHeadChanged(e);
				break;
		}
	}

	/**
	 * 处理运行时错误
	 * 
	 * @param e
	 */
	private void processRuntimeError(final QQEvent e) {
		main.getDisplay().syncExec(new Runnable() {
			public void run() {
				main.handleRuntimeError(e);
			}				
		});	
	}

	/**
	 * 处理收到网络硬盘通知事件
	 * 
	 * @param e
	 */
	private void processReceiveDiskNotification(QQEvent e) {
		ReceiveIMPacket packet = (ReceiveIMPacket)e.getSource();
		final QQLive live = packet.qqlive;
		main.getDisplay().syncExec(new Runnable() {
			public void run() {
				DiskNotificationTipWindow win = new DiskNotificationTipWindow(main, live);
				win.open();
			}
		});
	}

	/**
	 * 处理好友自定义头像改变事件
	 * 
	 * @param e
	 */
	private void processFriendCustomHeadChanged(QQEvent e) {
		ReceiveIMPacket packet = (ReceiveIMPacket)e.getSource();
		main.getDiskJobQueue().addJob(new DownloadCustomHeadJob(packet.headChanges));
	}

	/**
	 * 处理好友属性改变事件
	 * 
	 * @param e
	 */
	private void processFriendPropertyChanged(QQEvent e) {
		ReceiveIMPacket packet = (ReceiveIMPacket)e.getSource();
		if(!packet.propertyChange.hasCustomHead()) {
			final User u = ModelRegistry.getUser(packet.propertyChange.qq);
			if(u == null)
				return;
			u.hasCustomHead = false;
			if(u.qq == main.getMyModel().qq)
				main.getMyModel().hasCustomHead = false;
			main.getDisplay().syncExec(new Runnable() {
				public void run() {
					main.getBlindHelper().refreshGroup(u.group);
				}
			});
		}
	}

	/**
	 * 处理手机短信发送事件
	 * 
	 * @param e
	 */
	private void processSMSSent(QQEvent e) {
		// 把发送成功的接收者添加到最近联系人中
		SendSMSReplyPacket packet = (SendSMSReplyPacket)e.getSource();
		for(SMSReply reply : packet.replies) {
			if(reply.replyCode == QQ.QQ_REPLY_SMS_OK) {
				if(reply.isQQ) {
					final User u = ModelRegistry.getUser(reply.qq);
					if(u != null) {
						main.getDisplay().syncExec(new Runnable() {
							public void run() {
								main.getBlindHelper().updateLatest(u);
							}
						});
						return;
					}
				}				
			}
		}
	}

	/**
	 * 处理普通消息发送成功事件
	 * 
	 * @param e
	 */
	private void processSendIMSucess(QQEvent e) {
		// 把接受者添加到最近联系人中
		SendIMPacket packet = (SendIMPacket)e.getSource();
		final User f = ModelRegistry.getUser(packet.getReceiver());
		if(f == null)
			return;
		main.getDisplay().syncExec(new Runnable() {
			public void run() {
				main.getBlindHelper().updateLatest(f);
			}
		});
	}

	/**
	 * 处理收到临时会话消息
	 * 
	 * @param e
	 */
	private void processReceiveTempSessionIM(QQEvent e) {
		final ReceiveIMPacket packet = (ReceiveIMPacket)e.getSource();
		main.getDisplay().syncExec(new Runnable() {
			public void run() {
			    main.getMessageHelper().putTempSessionIM(packet);
			}
		});
	}

	/**
	 * 处理收到短信
	 * 
	 * @param e
	 */
	private void processReceiveSMS(QQEvent e) {
		final ReceiveIMPacket packet = (ReceiveIMPacket)e.getSource();
		main.getDisplay().syncExec(new Runnable() {
			public void run() {
			    main.getMessageHelper().putSMS(packet);
			}
		});
	}