searchwizard.java

lumaQQ的源文件

/*
* LumaQQ - Java QQ Client
*
* Copyright (C) 2004 luma <[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.wizard.search;

import static edu.tsinghua.lumaqq.resource.Messages.*;
import static edu.tsinghua.lumaqq.ui.wizard.search.SearchWizardModel.*;

import java.util.List;

import org.eclipse.jface.dialogs.MessageDialog;
import org.eclipse.jface.viewers.IStructuredSelection;
import org.eclipse.jface.wizard.IWizardPage;
import org.eclipse.jface.wizard.Wizard;
import org.eclipse.ui.INewWizard;
import org.eclipse.ui.IWorkbench;

import edu.tsinghua.lumaqq.qq.QQ;
import edu.tsinghua.lumaqq.qq.beans.AdvancedUserInfo;
import edu.tsinghua.lumaqq.qq.beans.ClusterInfo;
import edu.tsinghua.lumaqq.qq.beans.UserInfo;
import edu.tsinghua.lumaqq.qq.events.IQQListener;
import edu.tsinghua.lumaqq.qq.events.QQEvent;
import edu.tsinghua.lumaqq.qq.packets.Packet;
import edu.tsinghua.lumaqq.qq.packets.in.AddFriendExReplyPacket;
import edu.tsinghua.lumaqq.qq.packets.in.AdvancedSearchUserReplyPacket;
import edu.tsinghua.lumaqq.qq.packets.in.ClusterCommandReplyPacket;
import edu.tsinghua.lumaqq.qq.packets.in.SearchUserReplyPacket;
import edu.tsinghua.lumaqq.qq.packets.out.AdvancedSearchUserPacket;
import edu.tsinghua.lumaqq.qq.packets.out.ClusterCommandPacket;
import edu.tsinghua.lumaqq.qq.packets.out.SearchUserPacket;
import edu.tsinghua.lumaqq.resource.Resources;
import edu.tsinghua.lumaqq.ui.MainShell;
import edu.tsinghua.lumaqq.ui.wizard.IModelBasedWizard;


/**
 * 搜索的wizard
 * 
 * @author luma
 */
public class SearchWizard extends Wizard implements IModelBasedWizard, INewWizard, IQQListener {    
    private MainShell main;
    private SearchResult userResult;
    private SearchResult clusterResult;
    private char expected;
    private boolean end;
    private boolean operating;
    private SearchWizardModel model;
    
    private int preNextFlag;
    
    private static final int PRE_NEXT_NONE = 0;
    private static final int PRE_NEXT_SEARCH_CLUSTER_BY_CATEGORY = 1;

    public SearchWizard() {
    	model = new SearchWizardModel();
    }
    
    /* (non-Javadoc)
     * @see org.eclipse.jface.wizard.IWizard#getStartingPage()
     */
    public IWizardPage getStartingPage() {
        return getPage(model.getStartingPage());
    }
    
    /* (non-Javadoc)
     * @see org.eclipse.jface.wizard.IWizard#performFinish()
     */
    public boolean performFinish() {
        unhookListener();
        main.getShellRegistry().deregisterSearchWizard();
        return true;
    }
    
    /* (non-Javadoc)
     * @see org.eclipse.jface.wizard.IWizard#addPages()
     */
    public void addPages() {
        userResult = new SearchResult();
        clusterResult = new SearchResult();
        addPage(new SearchWhatWizardPage(PAGE_SEARCH_WHAT));
        addPage(new HowToSearchUserWizardPage(PAGE_HOW_TO_SEARCH_USER));
        addPage(new HowToSearchClusterWizardPage(main, PAGE_HOW_TO_SEARCH_CLUSTER));
        addPage(new SearchUserAccurateWizardPage(PAGE_SEARCH_USER_ACCURATE));
        addPage(new SearchUserAdvancedWizardPage(PAGE_SEARCH_USER_ADVANCED));
        addPage(new SearchUserResultWizardPage(PAGE_SEARCH_USER_RESULT, userResult));
        addPage(new SearchClusterResultWizardPage(PAGE_SEARCH_CLUSTER_RESULT, clusterResult));
        addPage(new AddFriendClusterWizardPage(PAGE_ADD));
        
        getShell().setImage(Resources.getInstance().getImage(Resources.icoSearch));
        hookListener();
        end = false;
        operating = false;
        preNextFlag = PRE_NEXT_NONE;
    }
    
    /* (non-Javadoc)
     * @see org.eclipse.jface.wizard.IWizard#getNextPage(org.eclipse.jface.wizard.IWizardPage)
     */
    public IWizardPage getNextPage(IWizardPage page) {
    	preNextFlag = PRE_NEXT_NONE;
        String name = page.getName();
        if(PAGE_SEARCH_WHAT.equals(name)) {
            switch(model.getSearchWhat()) {
                case SearchWizardModel.USER:
                    return getPage(PAGE_HOW_TO_SEARCH_USER);
                case SearchWizardModel.CLUSTER:
                    return getPage(PAGE_HOW_TO_SEARCH_CLUSTER);
                default:
                    return null;
            }
        } else if(PAGE_HOW_TO_SEARCH_USER.equals(name)) {   
            switch(model.getUserSearchMode()) {
                case ONLINE:
                    return getPage(PAGE_SEARCH_USER_RESULT);
                case ACCURATE:
                    return getPage(PAGE_SEARCH_USER_ACCURATE);
                case ADVANCED:
                    return getPage(PAGE_SEARCH_USER_ADVANCED);
                default:
                    return null;
            }
        } else if(PAGE_HOW_TO_SEARCH_CLUSTER.equals(name)) {
        	switch(model.getClusterSearchMode()) {
        		case BY_CATEGORY:      
        			preNextFlag = PRE_NEXT_SEARCH_CLUSTER_BY_CATEGORY;
        			return page;
        		default:
        			return getPage(PAGE_SEARCH_CLUSTER_RESULT);
        	}
        } else if(PAGE_SEARCH_USER_ACCURATE.equals(name)) {
            return getPage(PAGE_SEARCH_USER_RESULT);
        } else if(PAGE_SEARCH_USER_ADVANCED.equals(name)) {
            return getPage(PAGE_SEARCH_USER_RESULT);
        } else if(PAGE_SEARCH_USER_RESULT.equals(name)) {
            return getPage(PAGE_ADD);
        } else if(PAGE_SEARCH_CLUSTER_RESULT.equals(name)) {
            return getPage(PAGE_ADD);
        } else
            return null;
    }

    /* (non-Javadoc)
     * @see org.eclipse.ui.IWorkbenchWizard#init(org.eclipse.ui.IWorkbench, org.eclipse.jface.viewers.IStructuredSelection)
     */
    public void init(IWorkbench workbench, IStructuredSelection selection) {
    }
    
    /**
     * 初始化，传递MainShell引用
     * 
     * @param m
     */
    public void init(MainShell m) {
        this.main = m;
        setWindowTitle(search_title);       
        setDefaultPageImageDescriptor(Resources.getInstance().getImageDescriptor(Resources.icoSearchWizard));
    }    
    
    public MainShell getMainShell() {
        return main;
    }
    
    /* (non-Javadoc)
     * @see edu.tsinghua.lumaqq.ui.wizard.IModelBasedWizard#preNext()
     */
    public void preNext() {
    	switch(preNextFlag) {
    		case PRE_NEXT_SEARCH_CLUSTER_BY_CATEGORY:
    			getMainShell().getShellLauncher().searchCluster(model.getCategoryId());
    			break;
    	}
    }

    /* (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_SEARCH_USER_SUCCESS:
				processSearchUserSuccess(e);
				break;		
			case QQEvent.QQ_SEARCH_USER_END:
				processSearchUserEnd(e);
				break;
			case QQEvent.QQ_ADVANCED_SEARCH_USER_SUCCESS:
			    processAdvancedSearchUserSuccess(e);
				break;
		    case QQEvent.QQ_ADVANCED_SEARCH_USER_END:
		        processAdvancedSearchUserEnd(e);
		    	break;
			case QQEvent.QQ_SEARCH_CLUSTER_SUCCESS:
				processSearchClusterSuccess(e);
				break;
			case QQEvent.QQ_SEARCH_CLUSTER_FAIL:
				processSearchClusterFail(e);
				break;
			case QQEvent.QQ_ADD_FRIEND_SUCCESS:
			case QQEvent.QQ_ADD_FRIEND_ALREADY:
				processAddFriendSuccess(e);
				break;
			case QQEvent.QQ_ADD_FRIEND_FAIL:
				processAddFriendFail(e);
				break;
		    case QQEvent.QQ_ADD_FRIEND_DENY:
		        processAddFriendDeny(e);
		    	break;
			case QQEvent.QQ_ADD_FRIEND_NEED_AUTH:
				processAddFriendNeedAuth(e);
				break;
			case QQEvent.QQ_ADD_FRIEND_AUTH_SEND_SUCCESS:
			case QQEvent.QQ_AUTHORIZE_SEND_SUCCESS:
				processAddFriendAuthSendSuccess(e);
				break;
			case QQEvent.QQ_ADD_FRIEND_AUTH_SEND_FAIL:
			case QQEvent.QQ_AUTHORIZE_SEND_FAIL:
				processAddFriendAuthSendFail(e);
				break;
			case QQEvent.QQ_JOIN_CLUSTER_SUCCESS:
				processJoinClusterSuccess(e);
				break;
			case QQEvent.QQ_JOIN_CLUSTER_FAIL:
				processJoinClusterFail(e);
				break;
			case QQEvent.QQ_JOIN_CLUSTER_DENIED:
			    processJoinClusterDenied(e);
				break;
			case QQEvent.QQ_JOIN_CLUSTER_NEED_AUTH:
				processJoinClusterNeedAuth(e);
				break;
			case QQEvent.QQ_JOIN_CLUSTER_AUTH_SEND_FAIL:
				processJoinClusterAuthSendFail(e);
				break;
			case QQEvent.QQ_JOIN_CLUSTER_AUTH_SEND_SUCCESS:
			    processJoinClusterAuthSendSuccess(e);
				break;
		    case QQEvent.QQ_OPERATION_TIMEOUT:
		        switch(e.operation) {
		            case QQ.QQ_CMD_SEARCH_USER:
		                processSearchUserTimeout(e);
		            	break;
		            case QQ.QQ_CMD_ADVANCED_SEARCH:
		                processAdvancedSearchUserTimeout(e);
		            	break;
					case QQ.QQ_CMD_CLUSTER_CMD:
						processClusterCommandTimeout(e);
						break;
					case QQ.QQ_CMD_ADD_FRIEND_AUTH:
						processAddFriendAuthSendFail(e);
						break;
					case QQ.QQ_CMD_ADD_FRIEND_EX:
						processAddFriendExTimeout(e);
						break;
		        }
		}
    }    
    
	/**
	 * 处理添加好友超时事件
	 * 
	 * @param e
	 */
	private void processAddFriendExTimeout(QQEvent e) {
	    Packet packet = (Packet)e.getSource();
	    if(expected != packet.getSequence())
	        return;
		main.getDisplay().asyncExec(
			new Runnable() {
				public void run() {
				    operating = false;
				    expected = 0;
				    setAddPageStatus(ADD_TIMEOUT);
				}				
			}
		);
	}

	/**
	 * 初始对方禁止添加好友事件
	 * 
     * @param e
     */
    private void processAddFriendDeny(QQEvent e) {
	    Packet packet = (Packet)e.getSource();
	    if(expected != packet.getSequence())
	        return;
		main.getDisplay().syncExec(
			new Runnable() {
				public void run() {
				    operating = false;
				    expected = 0;
				    setAddPageStatus(ADD_DENY);
				}				
			}
		);
    }

    /**
	 * 处理认证消息发送失败事件
	 */
	private void processJoinClusterAuthSendFail(QQEvent e) {
	    Packet packet = (Packet)e.getSource();
	    if(expected != packet.getSequence())
	        return;
		main.getDisplay().syncExec(
			new Runnable() {
				public void run() {
				    operating = false;
				    expected = 0;
				    setAddPageStatus(AUTH_TIMEOUT);
				}				
			}
		);
	}
    
	/**
	 * 处理认证消息发送成功事件
	 */
	private void processJoinClusterAuthSendSuccess(QQEvent e) {
	    Packet packet = (Packet)e.getSource();
	    if(expected != packet.getSequence())
	        return;
		main.getDisplay().syncExec(
			new Runnable() {
				public void run() {
				    operating = false;
				    expected = 0;
				    setAddPageStatus(AUTH_SENT);
				}				
			}
		);	
	}
	
    /**
     * 处理加入群需要认证事件
     */
    private void processJoinClusterNeedAuth(QQEvent e) {
	    Packet packet = (Packet)e.getSource();
	    if(expected != packet.getSequence())
	        return;
    	main.getDisplay().syncExec(
    		new Runnable() {
    			public void run() {
				    operating = false;
				    expected = 0;
				    setAddPageStatus(AUTH_INPUTING);
    			}				
    		}
    	);
    }
    
	/**
     * 处理禁止加入群事件
     */
    private void processJoinClusterDenied(QQEvent e) {
	    Packet packet = (Packet)e.getSource();
	    if(expected != packet.getSequence())
	        return;
		main.getDisplay().syncExec(
			new Runnable() {
				public void run() {
				    operating = false;
				    expected = 0;
				    setAddPageStatus(JOIN_DENY);
				}				
			}
		);
    }
    
    /**
	 * 初始加入群失败事件
	 */
	private void processJoinClusterFail(QQEvent e) {
	    Packet packet = (Packet)e.getSource();
	    if(expected != packet.getSequence())
	        return;
		main.getDisplay().syncExec(
			new Runnable() {
				public void run() {
				    operating = false;
				    expected = 0;
				    setAddPageStatus(JOIN_TIMEOUT);
				}				
			}
		);
	}
    
	/**
	 * 处理加入群成功事件
	 * @param e
	 */
	private void processJoinClusterSuccess(QQEvent e) {
		ClusterCommandReplyPacket packet = (ClusterCommandReplyPacket)e.getSource();
		if(expected != packet.getSequence())
		    return;
		
		final int id = model.getSelectedModelId();
		if(id == packet.clusterId) {
			main.getDisplay().asyncExec(
				new Runnable() {
					public void run() {
					    operating = false;
					    expected = 0;
					    setAddPageStatus(JOIN_FINISHED);
						main.getBlindHelper().addCluster(id, false);
					}					
				}
			);
		}
	}
    
	/**
	 * 处理认证信息发送失败事件
	 */
	private void processAddFriendAuthSendFail(QQEvent e) {
	    Packet packet = (Packet)e.getSource();
	    if(expected != packet.getSequence())
	        return;
		main.getDisplay().syncExec(
			new Runnable() {
				public void run() {
				    operating = false;
				    expected = 0;
				    setAddPageStatus(AUTH_TIMEOUT);
				}				
			}
		);
	}
    
	/**
	 * 处理验证发送成功事件
	 */
	private void processAddFriendAuthSendSuccess(QQEvent e) {
	    Packet packet = (Packet)e.getSource();
	    if(expected != packet.getSequence())
	        return;
		main.getDisplay().syncExec(
			new Runnable() {
				public void run() {
				    operating = false;
				    expected = 0;
				    setAddPageStatus(AUTH_SENT);
				}				
			}
		);		
	}
    
	/**
	 * 处理添加好友需要验证事件
	 */
	private void processAddFriendNeedAuth(QQEvent e) {
	    Packet packet = (Packet)e.getSource();
	    if(expected != packet.getSequence())
	        return;
		main.getDisplay().syncExec(
			new Runnable() {
				public void run() {
				    operating = false;
				    expected = 0;
				    setAddPageStatus(AUTH_INPUTING);
				}				
			}
		);
	}
	
	/**
	 * 处理添加好友失败事件
	 */
	private void processAddFriendFail(QQEvent e) {
	    Packet packet = (Packet)e.getSource();
	    if(expected != packet.getSequence())
	        return;
		main.getDisplay().syncExec(
			new Runnable() {
				public void run() {