| 11890 |
kshitij.so |
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 |
|
|
|
11 |
import javax.mail.Flags;
|
|
|
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;
|
|
|
18 |
import javax.mail.search.FlagTerm;
|
|
|
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 BulkOrderEmailReader {
|
|
|
29 |
private static final String PROCESSED_FLAG = "processed";
|
|
|
30 |
|
|
|
31 |
private static final Log log = LogFactory.getLog(EmailReader.class);
|
|
|
32 |
|
|
|
33 |
Store store;
|
|
|
34 |
|
|
|
35 |
private BulkOrderEmailReader(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 {
|
|
|
62 |
BulkOrderEmailReader helpEmailReader = new BulkOrderEmailReader("bulkdeals@shop2020.in", "saholicbulk");
|
|
|
63 |
Folder inbox = helpEmailReader.getInboxFolder();
|
|
|
64 |
inbox.open(Folder.READ_WRITE);
|
|
|
65 |
CRMEmailProcessor crmEmailProcessor = new CRMEmailProcessor();
|
|
|
66 |
crmEmailProcessor.setEmailType("BulkEmail");
|
|
|
67 |
for (Message message : inbox.search(new FlagTerm(new Flags(PROCESSED_FLAG), false)))
|
|
|
68 |
{
|
|
|
69 |
boolean isRead = false;
|
|
|
70 |
try {
|
|
|
71 |
log.info("Processing Email from : " + message.getFrom() + "with subject: " + message.getSubject());
|
|
|
72 |
System.out.println("Processing Email from : " + message.getFrom() + "with subject: " + message.getSubject());
|
|
|
73 |
isRead = message.getFlags().contains(Flags.Flag.SEEN);
|
|
|
74 |
crmEmailProcessor.processEmail(message);
|
|
|
75 |
Flags flags = new Flags(PROCESSED_FLAG);
|
|
|
76 |
message.setFlags(flags, true);
|
|
|
77 |
message.setFlag(Flags.Flag.SEEN, isRead);
|
|
|
78 |
} catch (Exception e) {
|
|
|
79 |
System.out.println("Could not process message: " + message);
|
|
|
80 |
log.error("Could not process message: " + message, e);
|
|
|
81 |
Flags flags = new Flags(PROCESSED_FLAG);
|
|
|
82 |
message.setFlags(flags, true);
|
|
|
83 |
message.setFlag(Flags.Flag.SEEN, true);
|
|
|
84 |
}
|
|
|
85 |
}
|
|
|
86 |
log.info("No message left to process, closing Inbox");
|
|
|
87 |
inbox.close(false);
|
|
|
88 |
helpEmailReader.store.close();
|
|
|
89 |
}
|
|
|
90 |
}
|