Platon Technologies
not logged in Login Registration
EnglishSlovak
open source software development celebrating 10 years of open source development! Saturday, October 17, 2026
[BACK] [TXT][DIR] Up to [Platon] / mylist / backend / sender

Diff for mylist/backend/sender/sender.php between version 1.4 and 1.5

version 1.4, 2005/04/10 19:42:54 version 1.5, 2005/04/12 20:25:57
Line 1 
Line 1 
 <?  <?php
   
 // $Platon: mylist/backend/sender/sender.php,v 1.2 2005/03/25 23:32:45 nepto Exp $  // $Platon: mylist/backend/sender/sender.php,v 1.4 2005/04/10 19:42:54 majo Exp $
   
 require_once "../../mylist.config.php";  require_once '../../mylist.config.php';
   
 class CSender {  class CSender
   {
   
         function send()          function send() /* {{{ */
         {          {
                 global $dbh;                  global $dbh;
   
                 $sql  = "SELECT queue_message_id, recipient FROM mylist_queue ";                  $sql  = "SELECT queue_message_id, recipient FROM mylist_queue ";
                 $sql .= "WHERE dt_sent IS NULL ";                  $sql .= "WHERE dt_sent IS NULL ";
                 $sql .= "ORDER BY queue_message_id";                  $sql .= "ORDER BY queue_message_id";
   
                 $res =& $dbh->query($sql);                  $res =& $dbh->query($sql);
                 if (PEAR::isError($res))                  if (PEAR::isError($res))
                         die($res->getMessage());                          die($res->getMessage());
   
                 $last_queue_message_id = "";                  $last_queue_message_id = "";
   
                 while ($res->fetchInto($row))                  while ($res->fetchInto($row))
                 {                  {
   
                         if ($row["queue_message_id"] != $last_queue_message_id )                        {                          if ($row["queue_message_id"] != $last_queue_message_id )                        {
                                 $sql  = "SELECT message_header, message_body FROM mylist_queue_messages WHERE id = ".$row["queue_message_id"];                                  $sql  = "SELECT message_header, message_body FROM mylist_queue_messages WHERE id = ".$row["queue_message_id"];
   
                                 $res2 =& $dbh->query($sql);                                  $res2 =& $dbh->query($sql);
                                 if (PEAR::isError($res2))                                  if (PEAR::isError($res2))
                                         die($res2->getMessage());                                          die($res2->getMessage());
   
                                 $res2->fetchInto($row2);                                  $res2->fetchInto($row2);
                         }                          }
   
                         $last_queue_message_id = $row["$queue_message_id"];                          $last_queue_message_id = $row["$queue_message_id"];
   
                         // subjekt spravy neni v struktre tabulky mylist_queue_messages, ale je zbytocne ho tam nateraz doplnat, kedze sa funkcia mail() aj tak nebude pouzivat a bude nahradena inou funkciou                          // subjekt spravy neni v struktre tabulky mylist_queue_messages, ale je zbytocne ho tam nateraz doplnat, kedze sa funkcia mail() aj tak nebude pouzivat a bude nahradena inou funkciou
                         if (@$ret_mail = mail($row["recipient"], 'Test PhpMyList', $row2["message_body"], $row2["message_header"]))                          if (@$ret_mail = mail($row["recipient"], 'Test PhpMyList', $row2["message_body"], $row2["message_header"]))
                         {                          {
Line 45  class CSender {
Line 46  class CSender {
                                 $sql .= "' AND ";                                  $sql .= "' AND ";
                                 $sql .= "recipient LIKE ";                                  $sql .= "recipient LIKE ";
                                 $sql .= "'".$row["recipient"]."'";                                  $sql .= "'".$row["recipient"]."'";
   
                                 $res3 =& $dbh->query($sql);                                  $res3 =& $dbh->query($sql);
                                 if (PEAR::isError($res3))                                  if (PEAR::isError($res3))
                                         die($res3->getMessage());                                          die($res3->getMessage());
   
                                 echo "posielam spravu s queue id '".$row["queue_message_id"]."' na adresu '".$row["recipient"]."'\n";                                  echo "posielam spravu s queue id '".$row["queue_message_id"]."' na adresu '".$row["recipient"]."'\n";
                         }                          }
   
   
                 }                  }
           } /* }}} */
   
         }  
 }  }
   
   /* Modeline for ViM {{{
    * vim: set ts=4:
    * vim600: fdm=marker fdl=0 fdc=0:
    * }}} */
   
 ?>  ?>
Legend:
Removed from v.1.4  
changed lines
  Added in v.1.5
Platon Group <platon@platon.org> http://platon.org/
Copyright © 2002-2006 Platon Group
Site powered by Metafox CMS 		Go to Top