Subversion Repositories SmartDukaan

Rev

Rev 4523 | Rev 4537 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 4523 Rev 4536
Line 3... Line 3...
3
 */
3
 */
4
package in.shop2020.util;
4
package in.shop2020.util;
5
 
5
 
6
import in.shop2020.model.v1.user.UserContextException;
6
import in.shop2020.model.v1.user.UserContextException;
7
 
7
 
8
import java.io.IOException;
-
 
9
import java.text.ParseException;
8
import java.text.ParseException;
10
import java.util.Date;
-
 
11
import java.util.Properties;
9
import java.util.Properties;
12
 
10
 
13
import javax.mail.Flags;
11
import javax.mail.Flags;
14
import javax.mail.Flags.Flag;
-
 
15
import javax.mail.Folder;
12
import javax.mail.Folder;
16
import javax.mail.Message;
13
import javax.mail.Message;
17
import javax.mail.MessagingException;
14
import javax.mail.MessagingException;
18
import javax.mail.NoSuchProviderException;
15
import javax.mail.NoSuchProviderException;
19
import javax.mail.Session;
16
import javax.mail.Session;
20
import javax.mail.Store;
17
import javax.mail.Store;
21
import javax.mail.search.ComparisonTerm;
-
 
22
import javax.mail.search.FlagTerm;
18
import javax.mail.search.FlagTerm;
23
import javax.mail.search.ReceivedDateTerm;
-
 
24
 
19
 
25
import org.apache.commons.logging.Log;
20
import org.apache.commons.logging.Log;
26
import org.apache.commons.logging.LogFactory;
21
import org.apache.commons.logging.LogFactory;
27
import org.apache.thrift.TException;
22
import org.apache.thrift.TException;
28
 
23
 
Line 71... Line 66...
71
 
66
 
72
        for (Message message : inbox.search(new FlagTerm(new Flags(PROCESSED_FLAG), false)))
67
        for (Message message : inbox.search(new FlagTerm(new Flags(PROCESSED_FLAG), false)))
73
        {
68
        {
74
            try {
69
            try {
75
                log.info("Processing Email from : " + message.getFrom() + "with subject: " + message.getSubject());
70
                log.info("Processing Email from : " + message.getFrom() + "with subject: " + message.getSubject());
-
 
71
                boolean isRead = false;
-
 
72
                if (message.getFlags().contains(Flags.Flag.SEEN)) {
-
 
73
                    isRead = true;
-
 
74
                }
76
                crmEmailProcessor.processEmail(message);
75
                crmEmailProcessor.processEmail(message);
77
                Flags flags = new Flags(PROCESSED_FLAG);
76
                Flags flags = new Flags(PROCESSED_FLAG);
78
                message.setFlags(flags, true);
77
                message.setFlags(flags, true);
79
                if (message.getFlags().contains(Flags.Flag.SEEN)) {
-
 
80
                    message.setFlag(Flags.Flag.SEEN, true);
78
                message.setFlag(Flags.Flag.SEEN, isRead);
81
                } else {
-
 
82
                    message.setFlag(Flags.Flag.SEEN, false);
-
 
83
                }
-
 
84
            } catch (Exception e) {
79
            } catch (Exception e) {
85
                log.error("Could not process message: " + message, e);
80
                log.error("Could not process message: " + message, e);
86
            }
81
            }
87
        }
82
        }
88
        log.info("No message left to process, closing Inbox");
83
        log.info("No message left to process, closing Inbox");