edm/jb/smsQueue.php

<?php
/***
 * User: jun_hy
 * Date: 2022/7/6
 * Time: 16:11
 */
require_once (__DIR__ . '/../config/config_db.php');
require_once('class.mysql.php');
require_once (__DIR__ . '/../frame/common.php');
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";
$times =time();
$db = new Daopdo($host, $user, $pass, $dbName, $db_charset);
$sql['email_data'] = "SELECT `id`,`params_json` FROM `ly_sms_data_tmp_new` where  sendtime<='{$times}' 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_sms_data_tmp_new` WHERE `id`='{$email_data['id']}';";
    $db->query($sql['delQueueHead']);
}
$params = unserialize($email_data['params_json']);
$uid = $params['uid'];
$phone=serialize($params['phone']);
$params['phone'] = implode(',', $params['phone']);
unset($params['uid']);
//$params= http_build_query($params);
$post_url = 'http://api2.nxcloud.com/api/sms/mtsend';
$result = make_curl($post_url, $params);
$params['status'] = $result['code'];
$params['remarks'] = $result['messageid'];
$sql['insert_log'] = 'INSERT INTO `ly_send_sms_log_new` (`mobile`,`template_body`,`from_name`,`uid`,`status`,`remarks`) VALUES ';
$sql['insert_log'] .= "('{$phone}','{$params['content']}','{$params['source_address']}','{$uid}','{$params['status']}','{$params['remarks']}');";
$insert_log = $db->query($sql['insert_log']);