S45723751 # Matchd / Talentology - No Plan [Enhancement] #Ingest not working - URGENT

cmsWebApp/src/performa/utils/PerformaEmailFetcher.java

@@ -229,6 +229,7 @@ public class PerformaEmailFetcher implements Runnable, InitialisationParticipant
         LogMgr.log(LOG, LogLevel.PROCESSING2 , "processMessage called");
         
         String  tmpFromAdress   =   null;
+        String  tmpFromPerson   =   null;
         String  tmpReplyTo      =   null;
         String  tmpFirstName    =   null;
         String  tmpLastName     =   null;
@@ -265,14 +266,25 @@ public class PerformaEmailFetcher implements Runnable, InitialisationParticipant
             tmpSubject      =   message.getSubject();
             tmpSentDate     =   message.getReceivedDate();
             tmpMessageID    =   ((MimeMessage)message).getMessageID();
+            tmpMessageBody  =   EmailFetcher.getText(message, new ArrayList());
 
             if(message.getReplyTo() != null && message.getReplyTo().length > 0)
             {
                 tmpReplyTo      =   ((InternetAddress) message.getReplyTo()[0]).getAddress();
-                String  name    =   ((InternetAddress) message.getReplyTo()[0]).getPersonal();
+                tmpFromPerson   =   ((InternetAddress) message.getReplyTo()[0]).getPersonal(); 
+                
+                if(tmpReplyTo != null && tmpReplyTo.equals("noreply@jobapplications.seek.com.au"))
+                {
+                    tmpFromPerson   =    getApplicantName(tmpFromPerson);
+                    
+                    Document    document        =   Jsoup.parse(tmpMessageBody);
+                    Element     atag            =   document.select("a[title*=" + tmpFromPerson + "]").first();
 
-                tmpFirstName    =   getFirstName(name);
-                tmpLastName     =   getLastName(name);
+                    tmpReplyTo      =   atag.text();
+                }
+                
+                tmpFirstName    =   formatName(getFirstName(tmpFromPerson));
+                tmpLastName     =   formatName(getLastName(tmpFromPerson));
             }
             
             LogMgr.log(LOG, LogLevel.PROCESSING2 , "Mail Subject:" + tmpSubject, " Address:", tmpFromAdress, " MessageId:", tmpMessageID);
@@ -300,7 +312,6 @@ public class PerformaEmailFetcher implements Runnable, InitialisationParticipant
             
             tmpEmailText    =   EmailFetcher.getText(message, new ArrayList<>());
             tmpContents     =   getAttachments(message);
-            tmpMessageBody  =   EmailFetcher.getText(message, new ArrayList());
         }
         catch (MessagingException | IOException ex)
         {
@@ -351,7 +362,7 @@ public class PerformaEmailFetcher implements Runnable, InitialisationParticipant
                                     // handle seek email
                                     if(replyTo == null || replyTo.isEmpty())
                                     {
-                                        // might have to check email body if reply to is not set
+                                        // email body is checked - retriving a tag with title="Email applicant name"
                                         return;
                                     }
 
@@ -543,6 +554,11 @@ public class PerformaEmailFetcher implements Runnable, InitialisationParticipant
         return ((name.split("\\w+").length > 1) &&  (name.lastIndexOf(' ') > 0 )) ? name.substring(name.lastIndexOf(" ")+1) : "";
     }
     
+    private static String formatName(String name)
+    {
+        return name.length() > 1 ? name.substring(0,1).toUpperCase() + name.substring(1).toLowerCase() : name;
+    }
+    
     public static String getJobIdentifierFromEmail(String strReceipient)
     {
         int index = strReceipient.indexOf('@');
@@ -550,6 +566,11 @@ public class PerformaEmailFetcher implements Runnable, InitialisationParticipant
         return strReceipient.substring(0, index).replace("job", "");
     }
     
+    public static String getApplicantName(String strPerson)
+    {
+        return strPerson.replace("via SEEK", "").trim();
+    }
+    
     private static List<FileBinaryContent> getAttachments(Message message) throws IOException, MessagingException
     {
         List<FileBinaryContent> contents    =   new ArrayList<>();