Subversion Repositories SmartDukaan

Rev

Rev 4537 | Rev 14882 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
3339 mandeep.dh 1 
/**
2 
 *
3 
 */
4 
package in.shop2020.util;
5 
 
6 
import in.shop2020.model.v1.user.UserContextException;
7 
 
8 
import java.text.ParseException;
9 
import java.util.Properties;
10 
 
4513 anupam.sin 11 
import javax.mail.Flags;
3339 mandeep.dh 12 
import javax.mail.Folder;
13 
import javax.mail.Message;
14 
import javax.mail.MessagingException;
15 
import javax.mail.NoSuchProviderException;
16 
import javax.mail.Session;
17 
import javax.mail.Store;
4513 anupam.sin 18 
import javax.mail.search.FlagTerm;
3339 mandeep.dh 19 
 
20 
import org.apache.commons.logging.Log;
21 
import org.apache.commons.logging.LogFactory;
22 
import org.apache.thrift.TException;
23 
 
24 
/**
25 
 * @author mandeep
26 
 *
27 
 */
28 
public class EmailReader {
4513 anupam.sin 29 
    private static final String PROCESSED_FLAG = "processed";
30 
 
3339 mandeep.dh 31 
    private static final Log log = LogFactory.getLog(EmailReader.class);
32 
 
33 
    Store                    store;
34 
 
35 
    private EmailReader(String username, String password) {
36 
        Properties props = System.getProperties();
37 
        props.setProperty("mail.store.protocol", "imaps");
38 
        try {
39 
            Session session = Session.getDefaultInstance(props, null);
40 
            store = session.getStore("imaps");
41 
            store.connect("imap.gmail.com", username, password);
42 
        } catch (NoSuchProviderException e) {
43 
            log.error("Error getting store", e);
44 
        } catch (MessagingException e) {
45 
            log.error("Error while connecting", e);
46 
        }
47 
    }
48 
 
49 
    public Folder getInboxFolder() throws MessagingException {
50 
        return store.getFolder("inbox");
51 
    }
52 
 
53 
    /**
54 
     * @param args
55 
     * @throws MessagingException
56 
     * @throws ParseException
57 
     * @throws TException
58 
     * @throws UserContextException
59 
     */
60 
    public static void main(String[] args) throws MessagingException,
61 
            ParseException, TException, UserContextException {
4513 anupam.sin 62 
        EmailReader helpEmailReader = new EmailReader("help@shop2020.in", "5h0p2o2o");
63 
        Folder inbox = helpEmailReader.getInboxFolder();
64 
        inbox.open(Folder.READ_WRITE);
3339 mandeep.dh 65 
        CRMEmailProcessor crmEmailProcessor = new CRMEmailProcessor();
3368 mandeep.dh 66 
 
4513 anupam.sin 67 
        for (Message message : inbox.search(new FlagTerm(new Flags(PROCESSED_FLAG), false)))
3339 mandeep.dh 68 
        {
7297 anupam.sin 69 
            boolean isRead = false;
3339 mandeep.dh 70 
            try {
4513 anupam.sin 71 
                log.info("Processing Email from : " + message.getFrom() + "with subject: " + message.getSubject());
7297 anupam.sin 72 
                isRead = message.getFlags().contains(Flags.Flag.SEEN);
3373 mandeep.dh 73 
                crmEmailProcessor.processEmail(message);
4513 anupam.sin 74 
                Flags flags = new Flags(PROCESSED_FLAG);
75 
                message.setFlags(flags, true);
4536 anupam.sin 76 
                message.setFlag(Flags.Flag.SEEN, isRead);
4513 anupam.sin 77 
            } catch (Exception e) {
3339 mandeep.dh 78 
                log.error("Could not process message: " + message, e);
7297 anupam.sin 79 
                Flags flags = new Flags(PROCESSED_FLAG);
80 
                message.setFlags(flags, true);
81 
                message.setFlag(Flags.Flag.SEEN, true);
3339 mandeep.dh 82 
            }
83 
        }
4523 anupam.sin 84 
        log.info("No message left to process, closing Inbox");
4513 anupam.sin 85 
        inbox.close(false);
86 
        helpEmailReader.store.close();
3339 mandeep.dh 87 
    }
4523 anupam.sin 88 
}