import java.io.*;
import java.util.*;
import javax.swing.*;
import javax.mail.internet.*;
import javax.mail.*;

public class ProcessMessage implements Serializable
{
public void processMultipart(Multipart mp,MyMessage mymessage,Vector recieveVector)
{    
try{	
for(int i=0;i<mp.getCount();i++)
{String fileName=(mp.getBodyPart(i)).getFileName();
if(fileName==null)
processPart(mp.getBodyPart(i),mymessage,recieveVector);
else if(fileName!=null)
{
if(mymessage.getAttachment()==null)
mymessage.setAttachment("");
mymessage.setAttachment(mymessage.getAttachment()+getStr(fileName)+";");
File f=new File("附件",fileName);
FileOutputStream out=new FileOutputStream(f);
InputStream in=new BufferedInputStream((mp.getBodyPart(i)).getInputStream());
int b;
while((b=in.read())!=-1)
out.write(b);
out.flush();
out.close();
in.close();

}
}
}
catch(Exception e)
{JOptionPane.showMessageDialog(null,"Error:"+e.getMessage());
}
}
public void processPart(Part p,MyMessage mymessage,Vector recieveVector)
{
try{
String contentType=p.getContentType();
File f;
f=new File("郵件夾",recieveVector.size()+findEmailAddress(mymessage.getAddress())+".txt");
if(contentType.startsWith("text/plain"))
{
FileOutputStream out=new FileOutputStream(f);
InputStream in=new BufferedInputStream(p.getInputStream());
int b;
while((b=in.read())!=-1)
out.write(b);
out.flush();
out.close();
in.close();
mymessage.setContent("");
BufferedReader breader=new BufferedReader(new FileReader(f));
String str=breader.readLine();
while(str!=null)
{
mymessage.setContent(mymessage.getContent()+str+"\n");
str=breader.readLine();
}
breader.close();
mymessage.setIsHtml(false);
}
else if(contentType.startsWith("text/html")&&mymessage.getIsHtml())
{
FileOutputStream out=new FileOutputStream(f);
InputStream in=new BufferedInputStream(p.getInputStream());
int b;
while((b=in.read())!=-1)
out.write(b);
out.flush();
out.close();
in.close();
mymessage.setContent("");
BufferedReader breader=new BufferedReader(new FileReader(f));
String str=breader.readLine();
while(str!=null)
{
mymessage.setContent(mymessage.getContent()+str+"\n");
str=breader.readLine();
}
breader.close();
}

else if(contentType.startsWith("multipart"))
{Multipart mp=(Multipart)p.getContent();
processMultipart(mp,mymessage,recieveVector);
}
}
catch(Exception e)
{
JOptionPane.showMessageDialog(null,"Error:"+e.getMessage());
}
}
     
	public String getStr(String str) 
{ 
try { 
String temp_p=str; 
byte[] temp_t=temp_p.getBytes("ISO8859-1"); 
String temp=new String(temp_t); 
return temp; 
} 
catch(Exception e) 
{ return ""; } 
} 


     public String findEmailAddress(String str)
	{
	     try{
	     int foreindex=str.indexOf("<");
	     int backindex=str.indexOf("@");
	     if(foreindex!=-1&&backindex!=-1)
	     str=str.substring(foreindex+1,backindex);
	      return str;
	
	}
	     catch(Exception e)
	{ 
		return "";
	}
        }
        
}