private
static final long serialVersionUID = 1L;
protected
void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
nodeid="";
node="0";
currentnodeid=0;
url=request.getRequestURL().toString();
HttpSession ses=request.getSession();
MailUserData mud=(MailUserData)ses.getAttribute("mud");
ServletOutputStream out=response.getOutputStream();
response.setContentType("text/html;charset=GB2312");
int
msgid=-1,partid=-1;//msgdi：邮件编号；partid：MultiPart Message中part的编号。
String
partname=null; //图片或附件的文件名
String
nodepara=null;//节点编号，如1-2-1-0, 他以便层层剥入
if
(request.getParameter("msgid")!=null)
msgid=Integer.parseInt(request.getParameter("msgid"));
msgidStr="msgid="+msgid;
if
(request.getParameter("partid")!=null)
partid=Integer.parseInt(request.getParameter("partid"));
if
(request.getParameter("partname")!=null)
partname=new String(request.getParameter("partname").getBytes("ISO-8859-1"),"GB2312");
if
(request.getParameter("node")!=null)
nodepara=request.getParameter("node");
System.out.println(nodepara);
if
(partname!=null){
try
{
displayPart(partname,response,out);
} catch (MessagingException e) {
} catch (IOException e) {
}
return;
}
if
(mud==null){
Login login=new Login("imap","mail.server.com",-1,"user","password");
login.login();
if
(login.getResult()==1){
HttpSession session = request.getSession();
session.setMaxInactiveInterval(3600);
session.setAttribute("mud",login.getMud());
}
mud=(MailUserData)ses.getAttribute("mud");
}
if
(mud==null){
out.print("<error>Login First(No Session)</error>");
} else{
try
{
Store store=mud.getStore();
Folder
folder=store.getFolder("INBOX");
folder.open(Folder.READ_ONLY);
Message m=folder.getMessage(msgid);
if
(nodepara==null){
messageHtml="";
attachment="";
recipients=getAllgetRecipients(m);
out.print(displayMessage(request,m,partid));
} else{
displayPart(m,nodepara,response,out);
}
} catch (MessagingException e) {
} catch (IOException e) {
} catch (Exception e) {
}
}
}
protected
void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
}
String
stdUrl="";
String
url="";
String
msgidStr="";
String
messageHtml="";
String
attachment="";
String
recipients="";
String
nodeid="";
int
currentnodeid=0;
String
node="";
HashMap<String,Part> imgs=new HashMap<String,Part>();
public
String displayMessage(HttpServletRequest request,Part p,int partid) throws Exception{
if
(currentnodeid==1&&!node.endsWith("0")){
nodeid=nodeid.substring(0,(nodeid.length()-2));
}
node=nodeid+currentnodeid;
System.out.println(node);
if
(p.isMimeType("multipart/*")){
nodeid+=currentnodeid+"-";
Multipart mp=(Multipart) p.getContent();
int
cnt=mp.getCount();
String
mpct=mp.getContentType().toLowerCase();
for
(int i=0;
i<cnt;
i++){
if
(mpct.startsWith("multipart/alternative")&&mp.getBodyPart(i).getContentType().toLowerCase().startsWith("text/plain"))continue;
currentnodeid=i;
displayMessage(request,mp.getBodyPart(i),i);
}
}
if
(p.isMimeType("text/plain")||p.isMimeType("text/html")){
if
(messageHtml=="") {
messageHtml=(String)p.getContent();
} else {
messageHtml=messageHtml+"<HR/>"+(String)p.getContent();
}
} else if (p.isMimeType("message/rfc822")) {
} else{
if
(node.length()>2) node=node.substring(2);
System.out.println(node);
String
disposition=p.getDisposition();
if
(disposition!=null&&disposition.equalsIgnoreCase(Part.ATTACHMENT)){
String
filename=getFileName(p);
attachment+=","+"<a href='"+url+"/"+filename+"?"+msgidStr+"&node="+node+"'>"+filename+"</a>";
} else{
if
(getCid(p)!=null) {
imgs.put(getFileName(p),p);
String
uri=url+"?"+msgidStr+"&node="+node;
String
t=messageHtml.substring(messageHtml.indexOf(getCid(p))-1);
if
(!(t.startsWith("\"")||t.startsWith("\'"))){
}
messageHtml=messageHtml.replace(getCid(p),uri);
}
}
}
return
messageHtml+"attachhncwx="+attachment+recipients;
}
public
void displayPart(Message m,String node,HttpServletResponse response,ServletOutputStream out)
throws MessagingException, IOException{
Part part = getPart(m,node);
String
sct = part.getContentType();
response.setContentType(sct);
outPut(part,out);
}
private
Part getPart(Part m, String nodes) throws NumberFormatException, MessagingException, IOException {
if
(node==null)return m;
String
node=nodes.substring(0,1);
System.out.println(nodes+" : "+node);
int
nid=Integer.parseInt(node);
if
(m.getContent()==null)System.out.print("no content");
Part p=((Multipart)m.getContent()).getBodyPart(nid);
if
(nodes.length()>2)nodes=nodes.substring(2);
else
{
if
(nodes.length()==1)nodes="";
}
if
(nodes.length()>0)p=getPart(p,nodes);
return
p;
}
public
void displayPart(String partname,HttpServletResponse response, ServletOutputStream out) throws MessagingException, IOException{
Part part=imgs.get(partname);
String
ct=part.getContentType();
if
(ct!=null) response.setContentType(ct);
InputStream in=part.getInputStream();
ByteArrayOutputStream bos=new ByteArrayOutputStream();
byte
[] buffer=new byte[8192];
int
count=0;
while
((count=in.read(buffer))>=0) bos.write(buffer,0,count);
in
.close();
try{
out.write(bos.toByteArray());
out.flush();
} catch(Exception e){
}
out.close();
}
public
void displayPart(Message m,int partid,HttpServletResponse response, ServletOutputStream out) throws MessagingException, IOException{
Multipart mp = (Multipart)m.getContent();
Part part = mp.getBodyPart(partid);
String
sct = part.getContentType();
response.setContentType(sct);
if
(sct == null) {
out.println("invalid part");
return;
}
InputStream in=part.getInputStream();
ByteArrayOutputStream bos=new ByteArrayOutputStream();
byte
[] buffer=new byte[8192];
int
count=0;
while
((count=in.read(buffer))>=0) bos.write(buffer,0,count);
in
.close();
try{
out.write(bos.toByteArray());
out.flush();
} catch(Exception e){
}
out.close();
}
private
String getFileName(Part p) throws MessagingException, UnsupportedEncodingException{
String
filename=p.getFileName();
if
(filename==null)return null;
filename=new String(filename.getBytes("ISO-8859-1"),"GB2312");
int
indexStart=filename.toUpperCase().indexOf("=?GB");
if
(indexStart>-1){
filename=filename.substring(0,indexStart)+MimeUtility.decodeText(filename.substring(indexStart));
}
return
filename;
}
private
String getCid(Part p) throws MessagingException{
String
cidraw=null,cid=null;
String
[] headers=p.getHeader("Content-id");
if
(headers!=null && headers.length>0) {
} else{
}
if
(cidraw.startsWith("<")&&cidraw.endsWith(">")) {
cid="cid:"+cidraw.substring(1,cidraw.length()-1);
} else {
}
return
cid;
}
private
String getAllgetRecipients(Message m) throws Exception{
return
"mailaddrTo=" +getRecipients(m,"TO")
+"mailaddrCc="+getRecipients(m,"CC")
+"mailaddrBcc="+getRecipients(m,"BCC");
}
private
String getRecipients(Message m,String type) throws Exception {
StringBuffer mailaddr = new StringBuffer("");
String
addtype = type.toUpperCase();
InternetAddress[] address = null;
if
(addtype.equals("TO")) {
address = (InternetAddress[]) m.getRecipients(Message.RecipientType.TO);
} else if (addtype.equals("CC")) {
address = (InternetAddress[]) m.getRecipients(Message.RecipientType.CC);
} else {
address = (InternetAddress[]) m.getRecipients(Message.RecipientType.BCC);
}
if
(address != null) {
for
(int i = 0;
i < address.length;
i++) {
String
email = address[i].getAddress();
if
(email == null)
email = "";
else
{
email = MimeUtility.decodeText(email);
}
String
personal = address[i].getPersonal();
if
(personal == null)
personal = "";
else
{
personal = MimeUtility.decodeText(personal);
}
mailaddr.append("\""+personal+"\" ");
mailaddr.append("<");
mailaddr.append(email);
mailaddr.append(">");
mailaddr.append(",");
}
}
if
(mailaddr.length()>0)mailaddr.deleteCharAt(mailaddr.length()-1);
return
mailaddr.toString();
}
private
void outPut(Part part,ServletOutputStream out) throws IOException, MessagingException{
InputStream in=part.getInputStream();
ByteArrayOutputStream bos=new ByteArrayOutputStream();
byte
[] buffer=new byte[8192];
int
count=0;
while
((count=in.read(buffer))>=0) bos.write(buffer,0,count);
in
.close();
try{
out.write(bos.toByteArray());
out.flush();
} catch(Exception e){
}
out.close();
}