edm/jb/emailQueue.php

<?php
    require_once (__DIR__ . '/../config/config_db.php');
    require_once ('class.mysql.php');
    require_once (__DIR__ . '/../frame/common.php');
    
	date_default_timezone_set("PRC");
	set_time_limit(1800);
    $dbms = 'mysql';
    $host = 'localhost';
    $DB_Database = $dbName = $_ONU_CONFIG['_db_conf']['db_name'];
    $user = $_ONU_CONFIG['_db_conf']['user'];
    $pass = $_ONU_CONFIG['_db_conf']['pwd'];
    $db_charset = "utf8";
    
    $db = new Daopdo($host, $user, $pass, $dbName, $db_charset);

	$datetime = date("Y-m-d H:i:s", time());
    
    $sql['email_data'] = "SELECT `id`,`params_json` FROM `ly_email_data_tmp` WHERE `schedule_time` < '{$datetime}' ORDER BY `id` ASC LIMIT 1;";
	
    $email_data = $db->query($sql['email_data'], 'Row');
	if(empty($email_data)){
		exit(0);
	}else{
		$sql['delQueueHead'] = "DELETE FROM `ly_email_data_tmp` WHERE `id`='{$email_data['id']}';";
		$db->query($sql['delQueueHead']);
	}
	
	$params = unserialize($email_data['params_json']);
	$params['xsmtpapi'] = json_encode($params['xsmtpapi']);
	$uid = $params['uid'];
	unset($params['uid']);
	$post_url = 'http://api.sendcloud.net/apiv2/mail/send';
	//if($uid == 7 || $uid == 6) {
	//	$post_url = 'http://api2.sendcloud.net/api/mail/send';
	//}

	$result = make_curl($post_url, $params);
	
	$params['uid'] = $uid;
	$params['message'] = $result['message'];
	$params['time'] = time();
	$params['to']   = $params['xsmtpapi'];
	
	$sql['insert_log'] = 'INSERT INTO `ly_send_email1_log` (`to_user`,`subject`,`content`,`replay_to`,`time`,`message`,`uid`) VALUES ';
	$sql['insert_log'] .= "('{$params['to']}','{$params['subject']}','{$params['html']}','{$params['replyto']}','{$params['time']}','{$params['message']}','{$params['uid']}');";
	$insert_log = $db->query($sql['insert_log']);
?>