<?php
|
|
class mobliemsg_model extends model{
|
|
/*
|
* 获取配置列表
|
* $whereData 查询条件
|
* $data 自定义处理数组
|
*/
|
|
function getList($whereData,$data=array()){
|
$ListNew = array();
|
$List = $this -> select_all('moblie_msg',$whereData);
|
|
if(!empty( $List )){
|
$cuid = array();
|
$uid = array();
|
foreach ($List as $k => $v) {
|
if($v['cuid'] && $v['cuid']>0){
|
$cuid[] = $v['cuid'];
|
}
|
if($v['uid'] && $v['uid']>0){
|
$uid[] = $v['uid'];
|
}
|
}
|
$alluids = array_merge($cuid,$uid);
|
$alluids = array_unique($alluids);
|
|
require_once ('userinfo.model.php');
|
$userinfoM = new userinfo_model($this->db, $this->def);
|
|
$namelists = $userinfoM -> getUserList(array('uid'=>array('in',pylode(',',$alluids))));
|
|
foreach($namelists as $nk=>$nv){
|
$names[$nv['uid']] = $nv['name'];
|
}
|
|
foreach($List as $lk => $lv){
|
|
$List[$lk]['fname'] = $lv['cuid'] ? $names[$lv['cuid']] : '系统';
|
|
if($lv['uid']>0){
|
|
$List[$lk]['sname'] = $names[$lv['uid']];
|
|
}elseif($lv['uid']<0){
|
|
$List[$lk]['sname'] = '管理员';
|
|
}else{
|
|
$List[$lk]['sname'] = '';
|
|
}
|
}
|
|
$ListNew['list'] = $List;
|
}
|
|
return $ListNew;
|
}
|
|
function delMoblieMsg($whereData,$data){
|
|
if($data['type']=='one'){//单个删除
|
|
$limit = 'limit 1';
|
|
}
|
|
if($data['type']=='all'){//多个删除
|
|
$limit = '';
|
|
}
|
|
if($data['norecycle'] == '1'){ // 数据库清理，不插入回收站
|
|
$result = $this -> delete_all('moblie_msg',$whereData,$limit,'','1');
|
}else{
|
|
$result = $this -> delete_all('moblie_msg',$whereData,$limit);
|
}
|
|
return $result;
|
|
}
|
/*
|
* 获取单条数据moblie_msg
|
* $whereData 查询条件
|
* $data 自定义处理数组
|
*/
|
|
function getInfo($whereData,$data=array()){
|
|
$data['field'] = empty($data['field']) ? '*' : $data['field'];
|
|
$List = $this -> select_once('moblie_msg',$whereData,$data['field']);
|
|
if(is_array($List)&&$List){
|
|
if(date('Y-m-d',$List['ctime'])==date('Y-m-d'))
|
{
|
$List['disabled']='1';
|
}
|
}
|
|
return $List;
|
}
|
|
|
function getNum($whereData){
|
|
$num = $this -> select_num('moblie_msg',$whereData);
|
|
return $num;
|
}
|
//短信失败重发
|
function repeat($id){
|
|
if(is_array($id)){
|
$where['id'] = array('in',pylode(',',$id));
|
}else{
|
$where['id'] = (int)$id;
|
}
|
$where['state'] = array('<>','0');
|
|
//查询失败短信
|
$repeatMsg = $this -> select_all('moblie_msg',$where);
|
|
|
if(!empty($repeatMsg)){
|
|
|
include_once ('notice.model.php');
|
|
$noticeM = new notice_model($this->db, $this->def);
|
|
//发送短信
|
$row = array(
|
|
'appsecret' => $this->config['sy_msg_appsecret'],
|
'appkey' => $this->config['sy_msg_appkey']
|
);
|
|
foreach($repeatMsg as $key=>$value){
|
|
$row['phone'] = $value['moblie'];
|
$row['content'] = $value['content'];
|
|
$return = $noticeM -> postSMS('msgsend',$row);
|
|
if(trim($return['code']) == '200'){
|
$successid[] = $value['id'];
|
|
}else{
|
$nosuccessid[] = $value['id'];
|
$codeMsg = $return['code']." ";
|
}
|
}
|
if(!empty($successid)){
|
|
$this -> update_once('moblie_msg', array('state'=>'0'),array('id'=> array('in',implode(',',$successid))));
|
|
}
|
$msg = '本次短信重发成功：'.count($successid).'条';
|
if(!empty($nosuccessid) && isset($codeMsg)){
|
$msg .=',失败：'.count($nosuccessid).'条,错误码：'.$codeMsg;
|
}
|
}else{
|
$msg = '没有需要重发的短信！';
|
}
|
|
|
return $msg;
|
}
|
|
}
|
