emailworker.java

Sequoia ERP是一个真正的企业级开源ERP解决方案。它提供的模块包括：电子商务应用(e-commerce), POS系统(point of sales),知识管理,存货与仓库管理

package org.ofbiz.content.email;

import java.util.List;
import java.util.Map;
import java.util.HashMap;
import java.io.ByteArrayOutputStream;
import java.io.ByteArrayInputStream;
import java.io.InputStream;
import java.io.IOException;

import javax.mail.internet.MimeMessage;
import javax.mail.internet.InternetAddress;
import javax.mail.MessagingException;
import javax.mail.Multipart;
import javax.mail.Part;

import org.ofbiz.entity.GenericDelegator;
import org.ofbiz.entity.GenericValue;
import org.ofbiz.entity.GenericEntityException;
import org.ofbiz.base.util.UtilMisc;
import org.ofbiz.base.util.UtilValidate;
import org.ofbiz.base.util.Base64;
import org.ofbiz.base.util.Debug;
import org.ofbiz.service.LocalDispatcher;
import org.ofbiz.service.GenericServiceException;
import org.ofbiz.entity.util.ByteWrapper;

public class EmailWorker {

    public final static String module = EmailWorker.class.getName();

    public String getForwardedField(MimeMessage message) {
    	
    	String fieldValue = null;
    	
    	return fieldValue;
    }
    
    /**
     * Takes a message and store all its attachments as Content associated with a CommunicationEvent
     * using the attachment's file name as the name of the content
     * 
     * @param message 
     * @param communicationEventId
     * @param bodyContentIndex identifies the index value of the multi-part message which is the main body, so it is not created as an attachment
     * @param dispatcher
     * @param userLogin
     * @return
     * @throws MessagingException
     * @throws IOException
     * @throws GenericServiceException
     */
    public static int addAttachmentsToCommEvent(MimeMessage message, String communicationEventId, int bodyContentIndex, LocalDispatcher dispatcher, GenericValue userLogin) 
    	throws MessagingException, IOException, GenericServiceException {
    	int attachmentCount =0;
    	Map commEventMap = new HashMap();
    	commEventMap.put("communicationEventId", communicationEventId);
    	commEventMap.put("contentTypeId", "DOCUMENT");
		commEventMap.put("mimeTypeId", "text/html");
		commEventMap.put("userLogin", userLogin);
		Map result = null;
		ByteArrayOutputStream baos = new ByteArrayOutputStream();
    	
		Multipart multipart = (Multipart)message.getContent();
		int multipartCount = multipart.getCount();
		for (int i=0; i < multipartCount; i++) {
			Part part = multipart.getBodyPart(i);
			String thisContentTypeRaw = part.getContentType();
            
            int idx2 = thisContentTypeRaw.indexOf(";");
            String thisContentType = thisContentTypeRaw.substring(0, idx2);
            
            String disposition = part.getDisposition();
			
			// The first test should not pass, because if it exists, it should be the bodyContentIndex part
			if (((disposition == null) && (i == 0) && (i != bodyContentIndex)  && thisContentType.startsWith("text")) 
               || ((disposition != null)
					 && (disposition.equals(Part.ATTACHMENT) || disposition.equals(Part.INLINE))
				     && (i != bodyContentIndex)) )
		    {
		        commEventMap.put("contentName", part.getFileName());
        		commEventMap.put("drMimeTypeId", thisContentType);
        		if (thisContentType.startsWith("text")) {
                    
                    String content = (String)part.getContent();
                    
                    commEventMap.put("drDataResourceTypeId", "ELECTRONIC_TEXT");
        			commEventMap.put("textData", content);
        		} else {
                    
                    InputStream is = part.getInputStream();
        			int c;
        			while ((c = is.read()) > -1) {
        				baos.write(c);
        			}
        			
    				ByteWrapper imageData = new ByteWrapper(baos.toByteArray());
    				int len = imageData.getLength();
    				if (Debug.infoOn()) Debug.logInfo("imageData length: " + len, module);
    				commEventMap.put("imageData", imageData);
    				commEventMap.put("drDataResourceTypeId", "IMAGE_OBJECT");
            		commEventMap.put("_imageData_contentType", thisContentType);
        		}
        		result = dispatcher.runSync("createCommContentDataResource", commEventMap);
    			attachmentCount++;
		    }
		}

    	return attachmentCount;
    }
}