searchmessageaction.java

Eclipse RCP下编写的工作管理软件代码

package net.sf.pim.mail.reader;

import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.List;

import javax.mail.Folder;
import javax.mail.Message;
import javax.mail.MessagingException;

import jp.gr.java_conf.roadster.net.pop.MessageIndex;

import net.sf.pim.mail.MailPlugin;
import net.sf.pim.mail.MailUtil;

import org.eclipse.jface.action.IAction;
import org.eclipse.jface.dialogs.Dialog;
import org.eclipse.jface.dialogs.InputDialog;
import org.eclipse.jface.viewers.ISelection;
import org.eclipse.swt.custom.BusyIndicator;
import org.eclipse.ui.IWorkbenchWindow;
import org.eclipse.ui.IWorkbenchWindowActionDelegate;

/**
 * 查找邮件
 * @author levin
 */
public class SearchMessageAction implements IWorkbenchWindowActionDelegate {

	private IWorkbenchWindow window;

	public void dispose() {

	}

	public void init(IWorkbenchWindow window) {
		this.window=window;
	}

	public void run(IAction action) {
		final InputDialog input=new InputDialog(window.getShell(),"搜索邮件","请输入关键词","",null);
		if(input.open() == Dialog.OK && input.getValue() != null){
			final String key=input.getValue();
			BusyIndicator.showWhile(window.getShell().getDisplay(), new Runnable() {
				public void run(){
					try {
						List<Message> hit=new ArrayList<Message>();
						SearchFolder searchFolder=new SearchFolder(MailPlugin.getDefault().getStore(),hit);
						MessageIndex.setCacheContent(false);
						for(Folder folder:MailPlugin.getDefault().getStore().getDefaultFolder().list()){
							if(!folder.isOpen())
								folder.open(Folder.READ_ONLY);
							Message[] messages=folder.getMessages();
							for(Message msg:messages){
								if(match(msg,key))
									hit.add(msg);
							}
						}
						MessageIndex.setCacheContent(true);
						FolderViewer fv=(FolderViewer) window. getActivePage().findView(FolderViewer.ID);
						fv.showFolder(searchFolder);
					} catch (MessagingException e) {
						e.printStackTrace();
					}
				}
			});
		}
	}

	public void selectionChanged(IAction action, ISelection selection) {

	}

	//邮件中是否包含关键词
	private static boolean match(Message message,String key) throws MessagingException{
		//对关键词进行解析
		String prefix=null;
		if(key.indexOf(':') != -1){
			prefix=key.substring(0, key.indexOf(':'));
			if(";head;from;to;cc;subject;body;".indexOf(";"+prefix+";")!= -1)
				key=key.substring(prefix.length()+1);
			else
				prefix=null;
		}
		
		if(prefix != null){
			if(prefix.equals("head"))
				return matchFrom(message, key) || matchTo(message, key) || matchCc(message, key) || matchSubject(message, key);
			String methodName="match"+prefix.substring(0,1).toUpperCase()+prefix.substring(1);
			try {
				Method method = SearchMessageAction.class.getDeclaredMethod(methodName, Message.class,String.class);
				method.setAccessible(true);
				return (Boolean) method.invoke(null, message,key);
			} catch (Exception e) {
				throw new MessagingException("search error",e);
			}
		}
		return matchFrom(message, key) || matchTo(message, key) || matchCc(message, key) || matchSubject(message, key) || matchBody(message, key);
	}

	
	//一组搜索邮件的方法
	private static boolean matchBody(Message message, String key) {
		return MailUtil.dumpBodyText(message).indexOf(key) != -1;
	}

	private static boolean matchSubject(Message message, String key)
			throws MessagingException {
		return message.getSubject().indexOf(key) != -1;
	}

	private static boolean matchCc(Message message, String key)
			throws MessagingException {
		return MailUtil.getAddress(message.getRecipients(Message.RecipientType.CC)).indexOf(key) != -1;
	}

	private static boolean matchTo(Message message, String key)
			throws MessagingException {
		return MailUtil.getAddress(message.getRecipients(Message.RecipientType.TO)).indexOf(key) != -1;
	}

	private static boolean matchFrom(Message message, String key)
			throws MessagingException {
		return MailUtil.getAddress(message.getFrom()).indexOf(key) != -1;
	}
}