source: branches/dev/html/admin/mail/sendmail.php @ 13168

<?php
/*
 * Copyright(c) 2000-2007 LOCKON CO.,LTD. All Rights Reserved.
 *
 * http://www.lockon.co.jp/
 */
$include_dir = realpath(dirname( __FILE__));
require_once($include_dir."/../require.php");
$conn = new SC_DbConn();
$objSite = new SC_SiteInfo($conn);

if(MELMAGA_SEND != true) {
    exit;
}


if($_GET['mode'] == 'now') {
    //----¡¡Ì¤Á÷¿®¥Ç¡¼¥¿¤ò¼èÆÀ¤¹¤ë
    $time_data = $conn->getAll( "SELECT send_id FROM dtb_send_history  WHERE complete_count = 0 AND del_flg = 0 ORDER BY send_id ASC, start_date ASC" );
} else {
    
    // postgresql ¤È mysql ¤È¤ÇSQL¤ò¤ï¤±¤ë
    if (DB_TYPE == "pgsql") {
        $sql = "SELECT send_id FROM dtb_send_history  ";
        $sql.= "WHERE start_date  BETWEEN current_timestamp + '- 5 minutes' AND current_timestamp + '5 minutes' AND del_flg = 0 ORDER BY send_id ASC, start_date ASC";
    }else if (DB_TYPE == "mysql") {
        $sql = "SELECT send_id FROM dtb_send_history  ";
        $sql.= "WHERE start_date  BETWEEN date_add(now(),INTERVAL -5 minute) AND date_add(now(),INTERVAL 5 minute) AND del_flg = 0 ORDER BY send_id ASC, start_date ASC";
    }   
    //----¡¡30ʬËè¤ËCron¤¬Á÷¿®»þ´Ö¥Ç¡¼¥¿³Îǧ
    $time_data = $conn->getAll($sql);
}

$count = count($time_data);

if( $count > 0 ){
    print("start sending <br />\n");
} else {
    print("not found <br />\n");
    exit;
}

//---- ¥á¡¼¥ëÁ÷¿®
for( $i = 0; $i < count( $time_data ); $i++ ) {

    $sql = "SELECT * FROM dtb_send_customer WHERE send_id = ? AND (send_flag = 2 OR send_flag IS NULL)";
    $list_data[] = $conn->getAll( $sql, array( $time_data[$i]["send_id"] ) );
    
    $sql = "SELECT * FROM dtb_send_history WHERE send_id = ?";
    $mail_data[] = $conn->getAll( $sql, array(  $time_data[$i]["send_id"] ) );

}

//---- Á÷¿®·ë²Ì¥Õ¥é¥°ÍÑSQL
$sql_flag ="UPDATE dtb_send_customer SET send_flag = ? WHERE send_id = ? AND customer_id = ?";
$objMail = new GC_SendMail();

//----¡¡¥á¡¼¥ëÀ¸À®¤ÈÁ÷¿®
for( $i = 0; $i < count( $time_data ); $i++ ) {

    for( $j = 0; $j < count( $list_data[$i] ); $j ++ ) {

        $customerName = "";
        $mailBody = "";
        $sendFlag = "";

        //-- ¸ÜµÒ̾¤ÎÊÑ´¹
        $name = trim($list_data[$i][$j]["name"]);
        
        if ($name == "") {
            $name = "¤ªµÒ";
        }
        
        $customerName = htmlspecialchars($name);
        $subjectBody = ereg_replace( "{name}", $customerName , $mail_data[$i][0]["subject"] );
        $mailBody = ereg_replace( "{name}", $customerName ,  $mail_data[$i][0]["body"] );

        //-- ¥á¥ë¥Þ¥¬ÇÛ¿®¤ò¥Ö¥ì¥¤¥óÏ¢·È¤Ç¹Ô¤¦¾ì¹ç
        if(MELMAGA_MOBILE_SEND){
            
            print_r(MELMAGA_SENDING); 
            $sendResut = MELMAGA_SENDING( 
                                         $list_data[$i][$j]["email"]   //¡¡¸ÜµÒ°¸Àè 
                                        ,$subjectBody                  //¡¡Subject 
                                        ,$mailBody                     //¡¡¥á¡¼¥ëËÜʸ 
                                        ,$objSite->data["email03"]     //¡¡Á÷¿®¸µ¥á¡¼¥ë¥¢¥É¥ì¥¹ 
                                        ,$objSite->data["company_name"]//¡¡Á÷¿®¸µÌ¾ 
                                        ,$objSite->data["email03"]     //¡¡reply_to 
                                        ,$objSite->data["email04"]     //¡¡return_path 
                                        ,$objSite->data["email04"]     //¡¡errors_to
                                                                       );
            $mail_options = array(   
                        //¥Ö¥ì¥¤¥ó¤ÎSMTP¥µ¡¼¥Ð¡¼IP¥¢¥É¥ì¥¹ 
                              'host' => "127.0.1" 
                             ,'port' => "25"                  
                                          ); 
             
                    print_r($sendResut); 
                     
                    $decoder =& new Mail_mimeDecode($sendResut); 
                    //print_r($decoder); 
                    $parts = $decoder->getSendArray(); 
                    //print_r($parts); 
                    list($recipients, $header, $body) = $parts; 
                     
                    //$mailSend =& Mail::factory("SMTP", $mail_options); 
                    $mailSend =& Mail::factory("SMTP"); 
                    //print_r($mailSend); 
                    $mailSend->send($recipients, $header, $body); 
                    break;             
                 
        } else {
            //-- ¥Æ¥­¥¹¥È¥á¡¼¥ëÇÛ¿®¤Î¾ì¹ç
            if( $mail_data[$i][0]["mail_method"] == 2 ) {

                $sendResut = MAIL_SENDING(
                                         $list_data[$i][$j]["email"]                //¡¡¸ÜµÒ°¸Àè
                                        ,$subjectBody                               //¡¡Subject
                                        ,$mailBody                                  //¡¡¥á¡¼¥ëËÜʸ
                                        ,$objSite->data["email03"]                  //¡¡Á÷¿®¸µ¥á¡¼¥ë¥¢¥É¥ì¥¹
                                        ,$objSite->data["company_name"]             //¡¡Á÷¿®¸µÌ¾
                                        ,$objSite->data["email03"]                  //¡¡reply_to
                                        ,$objSite->data["email04"]                  //¡¡return_path
                                        ,$objSite->data["email04"]                  //¡¡errors_to
                                                                         );
                                                                         

            //--  HTML¥á¡¼¥ëÇÛ¿®¤Î¾ì¹ç  
            } elseif( $mail_data[$i][0]["mail_method"] == 1 || $mail_data[$i][0]["mail_method"] == 3) {
            
                $sendResut = HTML_MAIL_SENDING(
                                             $list_data[$i][$j]["email"]
                                            ,$subjectBody
                                            ,$mailBody
                                            ,$objSite->data["email03"]                  //¡¡Á÷¿®¸µ¥á¡¼¥ë¥¢¥É¥ì¥¹
                                            ,$objSite->data["company_name"]             //¡¡Á÷¿®¸µÌ¾
                                            ,$objSite->data["email03"]                  //¡¡reply_to
                                            ,$objSite->data["email04"]                  //¡¡return_path
                                            ,$objSite->data["email04"]                  //¡¡errors_to
                                                                     );
            }
        }
  
        //-- Á÷¿®´°Î»¤Ê¤é1¡¢¼ºÇԤʤé0¤ò¥á¡¼¥ëÁ÷¿®·ë²Ì¥Õ¥é¥°¤È¤·¤ÆDB¤ËÁÞÆþ
        if( ! $sendResut ){
             $sendFlag = "-1";
        } else {
            $sendFlag = "1";
            
            // ´°Î»¤ò1¤³Áý¤ä¤¹
            $sql = "UPDATE dtb_send_history SET complete_count = complete_count + 1 WHERE send_id = ?";
            $conn->query( $sql, array($mail_data[$i][0]["send_id"]) );
        }

        $conn->query( $sql_flag, array( $sendFlag, $mail_data[$i][0]["send_id"], $list_data[$i][$j]["customer_id"] ) );
        
        

    }

    //--- ¥á¡¼¥ëÁ´·ïÁ÷¿®´°Î»¸å¤Î½èÍý
    $completeSql = "UPDATE dtb_send_history SET end_date = now() WHERE send_id = ?";
    $conn->query( $completeSql, array( $time_data[$i]["send_id"] ) );

    //---¡¡Á÷¿®´°Î»¡¡Êó¹ð¥á¡¼¥ë
    $compData =  date("Yǯm·îdÆüH»þiʬ" . "  ²¼µ­¥á¡¼¥ë¤ÎÇÛ¿®¤¬´°Î»¤·¤Þ¤·¤¿¡£" );

    HTML_MAIL_SENDING(
                     $objSite->data["email03"]  
                    ,$compData
                    ,$mail_data[$i][0]["body"]
                    ,$objSite->data["email03"]                  //¡¡Á÷¿®¸µ¥á¡¼¥ë¥¢¥É¥ì¥¹
                    ,$objSite->data["company_name"]             //¡¡Á÷¿®¸µÌ¾
                    ,$objSite->data["email03"]                  //¡¡reply_to
                    ,$objSite->data["email04"]                  //¡¡return_path
                    ,$objSite->data["email04"]                  //¡¡errors_to
                 );
                 
    if ($_GET['mode'] = "now") {
        header("Location: " . URL_DIR . "admin/mail/history.php");
    }
    echo "complete\n";

}


//--- ¥á¥ë¥Þ¥¬ÇÛ¿®¡ÊBLAYNÏ¢·È¤Î¾ì¹ç¡Ë
function MELMAGA_SENDING( $to, $subject, $body, $fromaddress, $from_name, $reply_to, $return_path, $errors_to="", $bcc="", $cc ="" ) {


    $html_mail_obj = new GC_SendMail();  
    $html_mail_obj->setItemHtml( $to, $subject, $body, $fromaddress, $from_name, $reply_to, $return_path, $errors_to, $bcc, $cc );
    
    break;
}

//--- ¥Æ¥­¥¹¥È¥á¡¼¥ëÇÛ¿®
function MAIL_SENDING( $to, $subject, $body, $fromaddress, $from_name, $reply_to, $return_path, $errors_to="", $bcc="", $cc ="" ) {


    $mail_obj = new GC_SendMail();  
    $mail_obj->setItem( $to, $subject, $body, $fromaddress, $from_name, $reply_to, $return_path, $errors_to, $bcc, $cc );
        
    if( $mail_obj->sendMail() ) {
        return true;
    }
    
}

//--- HTML¥á¡¼¥ëÇÛ¿®
function HTML_MAIL_SENDING( $to, $subject, $body, $fromaddress, $from_name, $reply_to, $return_path, $errors_to="", $bcc="", $cc ="" ) {


    $html_mail_obj = new GC_SendMail();
    $html_mail_obj->setItemHtml( $to, $subject, $body, $fromaddress, $from_name, $reply_to, $return_path, $errors_to, $bcc, $cc );

            
    if( $html_mail_obj->sendHtmlMail() ) {
        return true;    
    }
    
}


?>