牛信云定时发送

application/lib/data/adminAction.php

@@ -677,11 +677,11 @@ class AdvertAdminAction extends BaseAction{
             return $result;
         }
         //插入待发送短信参数数据--牛信云
-        public function add_sms_data_queue_new($data){
-            $sql = 'INSERT INTO `ly_sms_data_tmp_new` (`params_json`) VALUES ';
+        public function add_sms_data_queue_new($data,$showtime,$datetime){
+            $sql = 'INSERT INTO `ly_sms_data_tmp_new` (`params_json`,`sendtime`,`showtime`) VALUES ';
             foreach($data as $value){
                 $params_json = serialize($value);
-                $sql .= "('{$params_json}'),";
+                $sql .= "('{$params_json}','{$datetime}','{$showtime}'),";
             }
             $sql = trim($sql, ',').';';
             $result = $this->getDbEntity()->insert_sql($sql);

application/module/ctrl/Send_sms_adminAction.class.php

@@ -164,7 +164,7 @@ class Send_sms_adminAction extends Action
                 $params_arr[] = $params;
             }
             if($uid==7||$uid==1||$uid==6){
-                $result = $admin->add_sms_data_queue_new($params_arr);
+                $result = $admin->add_sms_data_queue_new($params_arr,$showtime,$datetime);
             }else{
                 $result = $admin->add_sms_data_queue($params_arr,$showtime,$datetime);
             }

jb/smsQueue.php

@@ -14,8 +14,10 @@ $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` ORDER BY `id` ASC LIMIT 1;';
+$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);