E-Mails via PHP auslesen und in Datenbank speichern

Diese Seite verwendet Cookies. Durch die Nutzung unserer Seite erklären Sie sich damit einverstanden, dass wir Cookies setzen. Weitere Informationen

  • E-Mails via PHP auslesen und in Datenbank speichern

    Hallo,

    gerne würde ich meine E-Mails abrufen und in der Datenbank speichern.
    Soweit klappt dies auch. Anhänge, HTML Mails und Textmails funktionieren soweit.

    Hin und wieder kommt es aber vor das er den Text falsch wiedergibt bzw. falsch codiert. Dann sieht er so aus

    die zust=3DC3=3DA4ndigen Moderatoren sind sicherlich im Urlaub....Mit freundlichen Gr=3DC3=3DBC=3DC3=3D9Fen
    Die Rechnungen können Sie innerhalb Ihres Kundeninterface unter dem Pu==3Dnkt Rechnungsübersicht einsehen.=3D0A=3D0A

    F=3DC3=3DBCr meine Webseite damals hab ich einen Server von strato gemietet=. Ic=3Dh muss sagen, sie waren recht gut bez=3DC3=3DBCglich Schnelligkeit, Service=etc=3D


    Dies betrifft übrigens nicht nur Sonderzeichen. Leider schreibt er auch hin und wieder Teile des Headers in die Datenbank.

    --b2_90afbf4a3f4986efa19e4202d7aed1e7
    Content-Type: text/plain; charset=3Dutf-8
    Content-Transfer-Encoding: quoted-printable

    =3D0A=3D0A=3D0A =3D0A=3D0A
    ​Hallo Frau/Herr Christian xxxx,=3D0A=3D0Aleider haben wir


    Und hier mein Script

    PHP-Quellcode

    1. <?php
    2. define('ACP', true);
    3. define('ACP_PATH', './');
    4. define('PATH', '../');
    5. define('EXT', substr(strrchr(__FILE__, '.'), 1));
    6. // Einbinden der Initialisierungsdatei
    7. include (ACP_PATH . 'init/init.php');
    8. include (ACP_PATH . 'class/ticket_class.php');
    10. $Ticket = new Ticket;
    12. $mbox = imap_open( "{imap.domain.de:143/novalidate-cert}INBOX" , 'info@domain.de' , '!secret%' );
    14. $message = array();
    15. $message["attachment"]["type"][0] = "text";
    16. $message["attachment"]["type"][1] = "multipart";
    17. $message["attachment"]["type"][2] = "message";
    18. $message["attachment"]["type"][3] = "application";
    19. $message["attachment"]["type"][4] = "audio";
    20. $message["attachment"]["type"][5] = "image";
    21. $message["attachment"]["type"][6] = "video";
    22. $message["attachment"]["type"][7] = "other";
    24. function get_decode_value($message, $encoding) {
    25. switch($encoding) {
    26. case 0:
    27. case 1:
    28. $message = imap_8bit($message);
    29. break;
    30. case 2:
    31. $message = imap_binary($message);
    32. break;
    33. case 3:
    34. case 5:
    35. $message = imap_base64($message);
    36. break;
    37. case 4:
    38. $message = imap_qprint($message);
    39. break;
    40. }
    41. return $message;
    42. }
    44. function fix_text($str)
    45. {
    46. $subject = '';
    47. $subject_array = imap_mime_header_decode($str);
    49. foreach ($subject_array AS $obj) {
    50. $subject .= rtrim($obj->text, "\t");
    51. }
    53. return $subject;
    54. }
    56. $att = '';
    58. for ($jk = 1; $jk <= imap_num_msg($mbox); ++$jk) {
    60. print_r($structure = imap_fetchstructure($mbox, $jk));
    62. /* retrieve message timestamp */
    63. $header = imap_headerinfo($mbox, $jk);
    64. $timestamp = $header->udate;
    66. // Ticket in Datenbank eintragen
    67. $ticket_array = array();
    68. $ticket_array['name'] = $header->from[0]->personal;
    69. $ticket_array['email'] = $header->from[0]->mailbox.'@'.$header->from[0]->host;
    70. $ticket_array['status'] = 1;
    71. $ticket_array['date'] = $header->udate;
    72. $ticket_array['subject'] = fix_text($header->Subject);
    74. $ticket_array['priority'] = '3';
    76. // Prüfen ob Anhang
    77. if(isset($structure->parts)) {
    78. $parts = $structure->parts;
    79. $fpos=2;
    81. for($i = 1; $i < count($parts); $i++) {
    82. $message['pid'][$i] = ($i);
    83. $part = $parts[$i];
    85. if(isset($part->disposition) == "INLINE") {
    87. $message["type"][$i] = $message["attachment"]["type"][$part->type] . "/" . strtolower($part->subtype);
    88. $message["subtype"][$i] = strtolower($part->subtype);
    90. $ext = $part->subtype;
    91. $params = $part->dparameters;
    92. $filename = $part->dparameters[0]->value;
    93. $body="";$data="";
    95. $body = imap_fetchbody($mbox, $jk, $fpos);
    96. $inhalt1 = get_decode_value($body, $part->type);
    98. //Schreibe Anhänge in Datei
    99. $fp = fopen('file/'.$part->dparameters[0]->value, 'w+');
    100. fwrite ($fp, $inhalt1);
    101. fclose($fp);
    103. $att .= $part->dparameters[0]->value.';';
    104. $ticket_array['attachment'] = $att;
    105. $fpos++;
    107. }
    108. }
    110. }
    112. // prüfen ob Ticket ID im header ist
    113. if (preg_match('/[A-Z]{3,}-[0-9]{3,}-[0-9]{3,}/', $header->subject)) {
    114. // Rückgabe der Ticket-ID
    115. preg_match('/[A-Z]{3,}-[0-9]{3,}-[0-9]{3,}/', $header->subject, $match);
    116. $ticket_id = $match[0];
    117. $varse = "'".$ticket_id."'";
    119. // Status wieder auf Offen setzen
    120. $status_update = array();
    121. $status_update['status'] = 1;
    123. $sql = 'UPDATE ' . TICKETS . ' SET ' . $db->sql_build_array('UPDATE', $status_update) . ' WHERE ticket_id_parrent IS NULL AND ticket_id = ' . (string) $varse;
    124. $db->sql_query($sql);
    126. // Ticket zuordnung
    127. $sql = "SELECT * FROM " . TICKETS . " WHERE ticket_id = '" . $ticket_id ."' AND ticket_id_parrent IS NULL";
    128. $result = $db->sql_query($sql);
    129. $row = $db->sql_fetchrow($result);
    131. $ticket_array['ticket_id_parrent'] = $row['id'];
    132. $ticket_array['ticket_id'] = $ticket_id;
    134. } else {
    135. $ticket_array['ticket_id'] = $Ticket->randomTicket();
    136. }
    138. $messages = imap_fetchbody($mbox, $jk, "1");
    140. if($structure->encoding == 0) {
    141. $messages = imap_8bit($messages);
    142. } else if($structure->encoding == 1) {
    143. $messages =$messages;
    144. } else if($structure->encoding == 2) {
    145. $messages = imap_binary($messages);
    146. } else if($structure->encoding == 3) {
    147. $messages = imap_base64($messages);
    148. } else if($structure->encoding == 4) {
    149. $messages = imap_qprint($messages);
    150. } else if($structure->encoding == 5) {
    151. $messages = imap_base64($messages);
    152. } else {
    153. $messages = imap_qprint($messages);
    154. }
    156. $ticket_array['message'] = $messages;
    157. $sql = 'INSERT INTO ' . TICKETS. ' ' . $db->sql_build_array('INSERT', $ticket_array);
    158. $db->sql_query($sql);
    160. #imap_delete($mbox,$jk);
    162. }
    164. #imap_expunge($mbox);
    165. imap_close($mbox);
    167. ?>
    Alles anzeigen

  • Kein Problem, ich habe eh auf die code.google.com/p/php-imap/ gewechselt.
    Da kann ich allerdings irgendwie nicht den E-Mail Text in der Datenbank speichern

    $ticket_array['message'] = $mail;


    PHP-Quellcode

    1. $mails = array();
    3. $mails = $mailbox->searchMailbox('All') ;
    5. foreach ($mails as $key => $mailId) {
    6. $mail = $mailbox->getMail($mailId);
    8. // Ticket in Datenbank eintragen
    9. $ticket_array = array();
    10. $ticket_array['message'] = $mail;
    11. $ticket_array['name'] = $mail->fromName;
    12. $ticket_array['email'] = $mail->fromAddress;
    13. $ticket_array['status'] = 1;
    14. $ticket_array['date'] = $mail->date;
    15. $ticket_array['subject'] = $mail->subject;
    17. $ticket_array['priority'] = '3';
    18. $list = $mail->getAttachments();
    19. $filePath_CorpMail = "";
    20. foreach ($list as $key => $value) {
    21. if (preg_match("#.txt#",$value->name))
    22. $filePath_CorpMail = $value->filePath;
    23. $ticket_array['attachment'] = $value->filePath;
    24. }
    26. // prüfen ob Ticket ID im header ist
    27. if (preg_match('/[A-Z]{3,}-[0-9]{3,}-[0-9]{3,}/', $mail->subject)) {
    28. // Rückgabe der Ticket-ID
    29. preg_match('/[A-Z]{3,}-[0-9]{3,}-[0-9]{3,}/', $mail->subject, $match);
    30. $ticket_id = $match[0];
    31. $varse = "'".$ticket_id."'";
    33. // Status wieder auf Offen setzen
    34. $status_update = array();
    35. $status_update['status'] = 1;
    37. $sql = 'UPDATE ' . TICKETS . ' SET ' . $db->sql_build_array('UPDATE', $status_update) . ' WHERE ticket_id_parrent IS NULL AND ticket_id = ' . (string) $varse;
    38. $db->sql_query($sql);
    40. // Ticket zuordnung
    41. $sql = "SELECT * FROM " . TICKETS . " WHERE ticket_id = '" . $ticket_id ."' AND ticket_id_parrent IS NULL";
    42. $result = $db->sql_query($sql);
    43. $row = $db->sql_fetchrow($result);
    45. $ticket_array['ticket_id_parrent'] = $row['id'];
    46. $ticket_array['ticket_id'] = $ticket_id;
    48. } else {
    49. $ticket_array['ticket_id'] = $Ticket->randomTicket();
    50. }
    52. $sql = 'INSERT INTO ' . TICKETS. ' ' . $db->sql_build_array('INSERT', $ticket_array);
    53. $db->sql_query($sql);
    55. }
    Alles anzeigen

  • Hallo,

    ich kann den Beitrag nicht Editieren, daher nun mein Lösungsweg.

    Ich habe die eigentliche Klasse um wenige Zeilen erweitert.

    PHP-Quellcode

    1. public $text; <<
    2. elseif($partStructure->type == 0 && $data) {
    3. if(strtolower($partStructure->subtype) == 'plain') {
    4. $mail->textPlain .= nl2br(utf8_decode($data));
    5. $mail->text = $mail->textPlain;<<
    6. }
    7. else {
    8. $mail->textHtml .= $data;
    9. $mail->text = $mail->textHtml;<<
    10. }
    11. }
    12. elseif($partStructure->type == 2 && $data) {
    13. $mail->textPlain .= nl2br(trim($data));
    14. $mail->text = $mail->textPlain;<<
    15. }
    Alles anzeigen


    Und kann den Inhalt nun mit

    PHP-Quellcode

    1. $ticket_array['message'] = $mailbox->getMail($mailId)->text;


    in der Datenbank Speicher.

    Problem was jetzt allerdings ist, bei mehr als 2 Bilder oder 2 Anhänge in der E-Mail versagt das Script. Die E-Mails werden einfach nicht mehr abgearbeitet. Habe ich nur 1 Anhang oder 1 Bild in der E-Mail klappt dies ohne Probleme. Wo liegt der Fehler?

    PHP-Quellcode

    1. $mailbox = new ImapMailbox('{imap.domain.de:143/novalidate-cert}INBOX', GMAIL_EMAIL, GMAIL_PASSWORD, ATTACHMENTS_DIR, 'utf-8');
    2. $mails = array();
    4. $mails = $mailbox->searchMailbox('NEW') ;
    6. foreach ($mails as $key => $mailId) {
    7. $mail = $mailbox->getMail($mailId);
    9. // Ticket in Datenbank eintragen
    10. $ticket_array = array();
    11. $ticket_array['message'] = $mailbox->getMail($mailId)->text;
    12. $ticket_array['name'] = $mail->fromName;
    13. $ticket_array['email'] = $mail->fromAddress;
    14. $ticket_array['status'] = 1;
    15. $ticket_array['date'] = $mail->date;
    16. $ticket_array['subject'] = $mail->subject;
    18. $ticket_array['priority'] = '3';
    19. $list = $mail->getAttachments();
    20. $filePath_CorpMail = "";
    21. foreach ($list as $key => $value) {
    22. if (preg_match("#.txt#",$value->name))
    23. $filePath_CorpMail = $value->filePath;
    24. $ticket_array['attachment'] = $value->filePath;
    25. }
    27. // prüfen ob Ticket ID im header ist
    28. if (preg_match('/[A-Z]{3,}-[0-9]{3,}-[0-9]{3,}/', $mail->subject)) {
    29. // Rückgabe der Ticket-ID
    30. preg_match('/[A-Z]{3,}-[0-9]{3,}-[0-9]{3,}/', $mail->subject, $match);
    31. $ticket_id = $match[0];
    32. $varse = "'".$ticket_id."'";
    34. // Status wieder auf Offen setzen
    35. $status_update = array();
    36. $status_update['status'] = 1;
    38. $sql = 'UPDATE ' . TICKETS . ' SET ' . $db->sql_build_array('UPDATE', $status_update) . ' WHERE ticket_id_parrent IS NULL AND ticket_id = ' . (string) $varse;
    39. $db->sql_query($sql);
    41. // Ticket zuordnung
    42. $sql = "SELECT * FROM " . TICKETS . " WHERE ticket_id = '" . $ticket_id ."' AND ticket_id_parrent IS NULL";
    43. $result = $db->sql_query($sql);
    44. $row = $db->sql_fetchrow($result);
    46. $ticket_array['ticket_id_parrent'] = $row['id'];
    47. $ticket_array['ticket_id'] = $ticket_id;
    49. } else {
    50. $ticket_array['ticket_id'] = $Ticket->randomTicket();
    51. }
    53. $sql = 'INSERT INTO ' . TICKETS. ' ' . $db->sql_build_array('INSERT', $ticket_array);
    54. $db->sql_query($sql);
    56. }
    Alles anzeigen

  • Ich habe mal diesen alten Thread ausgegraben weil ich es schon seit längerer Zeit gelöst habe und ich dies nicht vorenthalten will.
    Evtl. kann dies ja einer brauchen.

    Es püft ob im Betreff eine Ticket ID alla GZH-478-457 vorhanden ist. Wenn ja wird dies als Antwort auf ein vorhandenen Ticket gespeichert. Wenn nicht als neues Ticket gehandelt.

    Gleichzeitig werden bei mehr als 1 Anhang alle in der Datenbank gespeichert, getrennt mit ;

    PHP-Quellcode

    1. // IMAP must be enabled in Google Mail Settings
    2. define('GMAIL_EMAIL', 'info@fffffff.de');
    3. define('GMAIL_PASSWORD', '!fffffff%');
    4. define('ATTACHMENTS_DIR', dirname(__FILE__) . '/file');
    6. $mailbox = new ImapMailbox('{imap.ffffffff.de:143/novalidate-cert}INBOX', GMAIL_EMAIL, GMAIL_PASSWORD, ATTACHMENTS_DIR, 'utf-8');
    7. $mails = array();
    9. $mails = $mailbox->searchMailbox('ALL') ;
    11. foreach ($mails as $key => $mailId) {
    12. $mail = $mailbox->getMail($mailId);
    14. // Ticket in Datenbank eintragen
    15. $ticket_array = array();
    16. $ticket_array['message'] = $mailbox->getMail($mailId)->text;
    17. $ticket_array['name'] = $mail->fromName;
    18. $ticket_array['email'] = $mail->fromAddress;
    19. $ticket_array['status'] = 1;
    20. $ticket_array['date'] = $mail->date;
    21. $ticket_array['subject'] = $mail->subject;
    23. $ticket_array['priority'] = '3';
    25. $att = '';
    26. foreach($mail->getAttachments() as $attachment) {
    27. echo $attachment->filePath;
    29. $att .= $attachment->filePath.';';
    31. }
    32. $ticket_array['attachment'] = $att;
    34. // prüfen ob Ticket ID im header ist
    35. if (preg_match('/[A-Z]{3,}-[0-9]{3,}-[0-9]{3,}/', $mail->subject)) {
    36. // Rückgabe der Ticket-ID
    37. preg_match('/[A-Z]{3,}-[0-9]{3,}-[0-9]{3,}/', $mail->subject, $match);
    38. $ticket_id = $match[0];
    39. $varse = "'".$ticket_id."'";
    41. // Status wieder auf Offen setzen
    42. $status_update = array();
    43. $status_update['status'] = 1;
    45. $sql = 'UPDATE ' . TICKETS . ' SET ' . $db->sql_build_array('UPDATE', $status_update) . ' WHERE ticket_id_parrent IS NULL AND ticket_id = ' . (string) $varse;
    46. $db->sql_query($sql);
    48. // Ticket zuordnung
    49. $sql = "SELECT * FROM " . TICKETS . " WHERE ticket_id = '" . $ticket_id ."' AND ticket_id_parrent IS NULL";
    50. $result = $db->sql_query($sql);
    51. $row = $db->sql_fetchrow($result);
    53. $ticket_array['ticket_id_parrent'] = $row['id'];
    54. $ticket_array['ticket_id'] = $ticket_id;
    56. } else {
    57. $ticket_array['ticket_id'] = $Ticket->randomTicket();
    58. }
    60. $sql = 'INSERT INTO ' . TICKETS. ' ' . $db->sql_build_array('INSERT', $ticket_array);
    61. $db->sql_query($sql);
    63. }
    Alles anzeigen