|
@@ -738,11 +738,11 @@ class AdvertAdminAction extends BaseAction{
|
|
|
return $result;
|
|
|
}
|
|
|
//插入待发送短信参数数据--牛信云
|
|
|
- public function add_sms_data_queue_new($data,$showtime,$datetime,$fid){
|
|
|
- $sql = 'INSERT INTO `ly_sms_data_tmp_new` (`params_json`,`sendtime`,`showtime`,`fid`) VALUES ';
|
|
|
+ public function add_sms_data_queue_new($data,$showtime,$datetime,$fid,$uid){
|
|
|
+ $sql = 'INSERT INTO `ly_sms_data_tmp_new` (`params_json`,`sendtime`,`showtime`,`fid`,`uid`) VALUES ';
|
|
|
foreach($data as $value){
|
|
|
$params_json = serialize($value);
|
|
|
- $sql .= "('{$params_json}','{$datetime}','{$showtime}','{$fid}'),";
|
|
|
+ $sql .= "('{$params_json}','{$datetime}','{$showtime}','{$fid}','{$uid}'),";
|
|
|
}
|
|
|
$sql = trim($sql, ',').';';
|
|
|
$result = $this->getDbEntity()->insert_sql($sql);
|
|
@@ -774,5 +774,36 @@ class AdvertAdminAction extends BaseAction{
|
|
|
$result = $this->getDbEntity()->execute_sql($sql);
|
|
|
return $result;
|
|
|
}
|
|
|
+ //添加短信回执记录
|
|
|
+ public function addDrLog($data){
|
|
|
+ $times=date('Y-m-d H:i:s');
|
|
|
+ $sql = "insert into ly_send_sms_log_dr(mobile,dr_id,group_dr_id,status,result,addtime) values
|
|
|
+ ('{$data['phone']}','{$data['messageid']}','{$data['group_dr_id']}','{$data['status']}','{$data['result']}','{$times}')";
|
|
|
+ $result = $this->getDbEntity()->execute_sql($sql);
|
|
|
+ return $result;
|
|
|
+ }
|
|
|
+
|
|
|
+ //根据$messageid 查询牛信云发送日志
|
|
|
+ public function select_smslog_new_query($where){
|
|
|
+ $sql = "select * from ly_send_sms_log_new $where LIMIT 1 ";
|
|
|
+
|
|
|
+ $result = $this->getDbEntity()->query($sql);
|
|
|
+ return $result;
|
|
|
+ }
|
|
|
+ //$uid 查询牛信云待发送日志
|
|
|
+ public function select_sms_data_tmp_new($where){
|
|
|
+ $sql = "select * from ly_sms_data_tmp_new $where ";
|
|
|
+ $result = $this->getDbEntity()->query($sql);
|
|
|
+ return $result;
|
|
|
+ }
|
|
|
+
|
|
|
+ //失败过高删除短信发送
|
|
|
+ public function delete_smslog_dr($uid,$fid,$count){
|
|
|
+ $sql1 = "DELETE FROM `ly_sms_data_tmp_new` WHERE `uid`='{$uid}' ";
|
|
|
+ $this->getDbEntity()->query($sql1);
|
|
|
+ $sql2 = "update ly_send_sms_log_count set status=1,nosend='{$count}' WHERE `log_id`='{$fid}'";
|
|
|
+ $this->getDbEntity()->query($sql2);
|
|
|
+ return true;
|
|
|
+ }
|
|
|
//end
|
|
|
}
|