searchwizard.java

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

/*
* 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 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.IconHolder;
import edu.tsinghua.lumaqq.LumaQQ;
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.QQEvent;
import edu.tsinghua.lumaqq.qq.events.IQQListener;
import edu.tsinghua.lumaqq.qq.packets.Packet;
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.AddFriendPacket;
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.ui.MainShell;


/**
 * 搜索的wizard
 * 
 * @author luma
 */
public class SearchWizard extends Wizard implements INewWizard, IQQListener {
    // 页名称
    public static final String SEARCH_WHAT = "1";
    public static final String HOW_TO_SEARCH_USER = "2";
    public static final String HOW_TO_SEARCH_CLUSTER = "3";
    public static final String SEARCH_USER_ACCURATE = "4";
    public static final String SEARCH_USER_ADVANCED = "5";
    public static final String SEARCH_USER_RESULT = "6";
    public static final String SEARCH_CLUSTER_RESULT = "7";
    public static final String ADD = "8";
    
    private MainShell main;
    private SearchResult userResult;
    private SearchResult clusterResult;
    private char expected;
    private boolean end;
    private boolean operating;
    private Object selectedModel;
    private boolean enterResultPage;
    
    protected static final int ONLINE = 0;
    protected static final int ACCURATE = 1;
    protected static final int ADVANCED = 2;
    protected static final int DEMO_CLUSTER = 3;
    protected static final int BY_CLUSTER_ID = 4;
    private int searchMode;
    
    // 首先显示哪一页
    private String startPage;

    public SearchWizard() {
        startPage = SEARCH_WHAT;
    }
    
    /* (non-Javadoc)
     * @see org.eclipse.jface.wizard.IWizard#getStartingPage()
     */
    public IWizardPage getStartingPage() {
        return getPage(startPage);
    }
    
    /* (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(SEARCH_WHAT));
        addPage(new HowToSearchUserWizardPage(HOW_TO_SEARCH_USER));
        addPage(new HowToSearchClusterWizardPage(HOW_TO_SEARCH_CLUSTER));
        addPage(new SearchUserAccurateWizardPage(SEARCH_USER_ACCURATE));
        addPage(new SearchUserAdvancedWizardPage(SEARCH_USER_ADVANCED));
        addPage(new SearchUserResultWizardPage(SEARCH_USER_RESULT, userResult));
        addPage(new SearchClusterResultWizardPage(SEARCH_CLUSTER_RESULT, clusterResult));
        addPage(new AddFriendClusterWizardPage(ADD));
        
        getShell().setImage(IconHolder.getInstance().getImage(IconHolder.icoSearch));
        hookListener();
        end = false;
        operating = false;
        enterResultPage = true;
    }
    
    /* (non-Javadoc)
     * @see org.eclipse.jface.wizard.IWizard#getNextPage(org.eclipse.jface.wizard.IWizardPage)
     */
    public IWizardPage getNextPage(IWizardPage page) {
        String name = page.getName();
        if(SEARCH_WHAT.equals(name)) {
            SearchWhatWizardPage swwp = (SearchWhatWizardPage)page;
            switch(swwp.getSearchWhat()) {
                case SearchWhatWizardPage.USER:
                    return getPage(HOW_TO_SEARCH_USER);
                case SearchWhatWizardPage.CLUSTER:
                    return getPage(HOW_TO_SEARCH_CLUSTER);
                default:
                    return null;
            }
        } else if(HOW_TO_SEARCH_USER.equals(name)) {
            HowToSearchUserWizardPage htsuwp = (HowToSearchUserWizardPage)page;     
            switch(htsuwp.getSearchMethod()) {
                case HowToSearchUserWizardPage.ONLINE:
                    return getPage(SEARCH_USER_RESULT);
                case HowToSearchUserWizardPage.ACCURATE:
                    return getPage(SEARCH_USER_ACCURATE);
                case HowToSearchUserWizardPage.ADVANCED:
                    return getPage(SEARCH_USER_ADVANCED);
                default:
                    return null;
            }
        } else if(HOW_TO_SEARCH_CLUSTER.equals(name)) {
            return getPage(SEARCH_CLUSTER_RESULT);
        } else if(SEARCH_USER_ACCURATE.equals(name)) {
            return getPage(SEARCH_USER_RESULT);
        } else if(SEARCH_USER_ADVANCED.equals(name)) {
            return getPage(SEARCH_USER_RESULT);
        } else if(SEARCH_USER_RESULT.equals(name)) {
            return getPage(ADD);
        } else if(SEARCH_CLUSTER_RESULT.equals(name)) {
            return getPage(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 main
     */
    public void init(MainShell main) {
        this.main = main;
        setWindowTitle(LumaQQ.getString("search.title"));       
        setDefaultPageImageDescriptor(IconHolder.getInstance().getImageDescriptor(IconHolder.icoSearchWizard));
    }
    
    /**
     * @return
     * 		MainShell
     */
    public MainShell getMainShell() {
        return main;
    }

    /* (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:
				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:
				processAddFriendAuthSendSuccess(e);
				break;
			case QQEvent.QQ_ADD_FRIEND_AUTH_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);
		        }
		}
    }    
    
	/**
	 * 初始对方禁止添加好友事件
	 * 
     * @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(AddFriendClusterWizardPage.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(AddFriendClusterWizardPage.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(AddFriendClusterWizardPage.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(AddFriendClusterWizardPage.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(AddFriendClusterWizardPage.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(AddFriendClusterWizardPage.JOIN_TIMEOUT);
				}				
			}
		);
	}
    
	/**
	 * 处理加入群成功事件
	 * @param e
	 */
	private void processJoinClusterSuccess(QQEvent e) {
		ClusterCommandReplyPacket packet = (ClusterCommandReplyPacket)e.getSource();
		if(expected != packet.getSequence())
		    return;
		
		final int id = getSelectedModelId();
		if(id == packet.clusterId) {
			main.getDisplay().asyncExec(
				new Runnable() {
					public void run() {
					    operating = false;
					    expected = 0;
					    setAddPageStatus(AddFriendClusterWizardPage.JOIN_FINISHED);
						main.getMVCHelper().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(AddFriendClusterWizardPage.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(AddFriendClusterWizardPage.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(AddFriendClusterWizardPage.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() {
				    operating = false;
				    expected = 0;
				    setAddPageStatus(AddFriendClusterWizardPage.ADD_DENY);
				}				
			}
		);
	}
    
	/**
	 * 处理添加好友成功事件
	 * 
	 * @param e
	 */
	private void processAddFriendSuccess(QQEvent e) {
		AddFriendPacket packet = (AddFriendPacket)e.getSource();
		if(expected != packet.getSequence())
		    return;
		final int id = getSelectedModelId();
		if(id == packet.getTo()) {
			main.getDisplay().asyncExec(
				new Runnable() {
					public void run() {
					    operating = false;
					    expected = 0;
					    setAddPageStatus(AddFriendClusterWizardPage.ADD_FINISHED);
						main.getMVCHelper().addFriendViewPart(id);
					}					
				}
			);
		}
	}