397 lines
11 KiB
PHP
397 lines
11 KiB
PHP
|
<?php
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* ECSHOP 短信模块 之 模型（类库）
|
|||
|
|
* ============================================================================
|
|||
|
|
* 版权所有 2005-2010 上海商派网络科技有限公司，并保留所有权利。
|
|||
|
|
* 网站地址: http://www.ecshop.com；
|
|||
|
|
* ----------------------------------------------------------------------------
|
|||
|
|
* 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和
|
|||
|
|
* 使用；不允许对程序代码以任何形式任何目的的再发布。
|
|||
|
|
* ============================================================================
|
|||
|
|
* $Author: douqinghua $
|
|||
|
|
* $Id: cls_sms.php 17155 2010-05-06 06:29:05Z douqinghua $
|
|||
|
|
*/
|
|||
|
|
|
|||
|
|
if (!defined('IN_ECS'))
|
|||
|
|
{
|
|||
|
|
die('Hacking attempt');
|
|||
|
|
}
|
|||
|
|
define('SOURCE_TOKEN', '814d4852d74f5914b41695ee7fa8508c');
|
|||
|
|
define('SOURCE_ID', '863180');
|
|||
|
|
require_once(ROOT_PATH . 'includes/cls_transport.php');
|
|||
|
|
require_once(ROOT_PATH . 'includes/shopex_json.php');
|
|||
|
|
|
|||
|
|
/* 短信模块主类 */
|
|||
|
|
class sms
|
|||
|
|
{
|
|||
|
|
/**
|
|||
|
|
* 存放提供远程服务的URL。
|
|||
|
|
*
|
|||
|
|
* @access private
|
|||
|
|
* @var array $api_urls
|
|||
|
|
*/
|
|||
|
|
var $api_urls = array(
|
|||
|
|
'info' => 'http://api.sms.shopex.cn',
|
|||
|
|
'send' => 'http://api.sms.shopex.cn',
|
|||
|
|
'servertime' => 'http://webapi.sms.shopex.cn'
|
|||
|
|
|
|||
|
|
);
|
|||
|
|
/**
|
|||
|
|
* 存放MYSQL对象
|
|||
|
|
*
|
|||
|
|
* @access private
|
|||
|
|
* @var object $db
|
|||
|
|
*/
|
|||
|
|
var $db = null;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 存放ECS对象
|
|||
|
|
*
|
|||
|
|
* @access private
|
|||
|
|
* @var object $ecs
|
|||
|
|
*/
|
|||
|
|
var $ecs = null;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 存放transport对象
|
|||
|
|
*
|
|||
|
|
* @access private
|
|||
|
|
* @var object $t
|
|||
|
|
*/
|
|||
|
|
var $t = null;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 存放程序执行过程中的错误信息，这样做的一个好处是：程序可以支持多语言。
|
|||
|
|
* 程序在执行相关的操作时，error_no值将被改变，可能被赋为空或大等0的数字.
|
|||
|
|
* 为空或0表示动作成功；大于0的数字表示动作失败，该数字代表错误号。
|
|||
|
|
*
|
|||
|
|
* @access public
|
|||
|
|
* @var array $errors
|
|||
|
|
*/
|
|||
|
|
var $errors = array('api_errors' => array('error_no' => -1, 'error_msg' => ''),
|
|||
|
|
'server_errors' => array('error_no' => -1, 'error_msg' => ''));
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 构造函数
|
|||
|
|
*
|
|||
|
|
* @access public
|
|||
|
|
* @return void
|
|||
|
|
*/
|
|||
|
|
function __construct()
|
|||
|
|
{
|
|||
|
|
$this->sms();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 构造函数
|
|||
|
|
*
|
|||
|
|
* @access public
|
|||
|
|
* @return void
|
|||
|
|
*/
|
|||
|
|
function sms()
|
|||
|
|
{
|
|||
|
|
/* 由于要包含init.php，所以这两个对象一定是存在的，因此直接赋值 */
|
|||
|
|
$this->db = $GLOBALS['db'];
|
|||
|
|
$this->ecs = $GLOBALS['ecs'];
|
|||
|
|
|
|||
|
|
/* 此处最好不要从$GLOBALS数组里引用，防止出错 */
|
|||
|
|
$this->t = new transport(-1, -1, -1, false);
|
|||
|
|
$this->json = new Services_JSON;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/* 发送短消息
|
|||
|
|
*
|
|||
|
|
* @access public
|
|||
|
|
* @param string $phone 要发送到哪些个手机号码，传的值是一个数组
|
|||
|
|
* @param string $msg 发送的消息内容
|
|||
|
|
*/
|
|||
|
|
function send($phones,$msg,$send_date = '', $send_num = 1,$sms_type='',$version='1.0')
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
/* 检查发送信息的合法性 */
|
|||
|
|
$contents=$this->get_contents($phones, $msg);
|
|||
|
|
if(!$contents)
|
|||
|
|
{
|
|||
|
|
$this->errors['server_errors']['error_no'] = 3;//发送的信息有误
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$login_info = $this->getSmsInfo();
|
|||
|
|
if (!$login_info)
|
|||
|
|
{
|
|||
|
|
$this->errors['server_errors']['error_no'] = 5;//无效的身份信息
|
|||
|
|
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
if($login_info['info']['account_info']['active']!='1')
|
|||
|
|
{
|
|||
|
|
$this->errors['server_errors']['error_no'] = 11;//短信功能没有激活
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
/* 获取API URL */
|
|||
|
|
$sms_url = $this->get_url('send');
|
|||
|
|
|
|||
|
|
if (!$sms_url)
|
|||
|
|
{
|
|||
|
|
$this->errors['server_errors']['error_no'] = 6;//URL不对
|
|||
|
|
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$send_str['contents']= $this->json->encode($contents);
|
|||
|
|
$send_str['certi_app']='sms.send';
|
|||
|
|
$send_str['entId']=$GLOBALS['_CFG']['ent_id'];
|
|||
|
|
$send_str['entPwd']=$GLOBALS['_CFG']['ent_ac'];
|
|||
|
|
$send_str['license']=$GLOBALS['_CFG']['certificate_id'];
|
|||
|
|
$send_str['source']=SOURCE_ID;
|
|||
|
|
$send_str['sendType'] = 'notice';
|
|||
|
|
$send_str['use_backlist'] = '1';
|
|||
|
|
$send_str['version'] = $version;
|
|||
|
|
$send_str['format']='json';
|
|||
|
|
$send_str['timestamp'] = $this->getTime();
|
|||
|
|
$send_str['certi_ac']=$this->make_shopex_ac($send_str,SOURCE_TOKEN);
|
|||
|
|
$sms_url= $this->get_url('send');
|
|||
|
|
/* 发送HTTP请求 */
|
|||
|
|
$response = $this->t->request($sms_url, $send_str,'POST');
|
|||
|
|
$result = $this->json->decode($response['body'], true);
|
|||
|
|
|
|||
|
|
if($result['res'] == 'succ')
|
|||
|
|
{
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
elseif($result['res'] == 'fail')
|
|||
|
|
{
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 检测启用短信服务需要的信息
|
|||
|
|
*
|
|||
|
|
* @access private
|
|||
|
|
* @param string $email 邮箱
|
|||
|
|
* @param string $password 密码
|
|||
|
|
* @return boolean 如果启用信息格式合法就返回true，否则返回false。
|
|||
|
|
*/
|
|||
|
|
function check_enable_info($email, $password)
|
|||
|
|
{
|
|||
|
|
if (empty($email) || empty($password))
|
|||
|
|
{
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//查询是否已有通行证
|
|||
|
|
function has_registered()
|
|||
|
|
{
|
|||
|
|
$sql = 'SELECT `value`
|
|||
|
|
FROM ' . $this->ecs->table('shop_config') . "
|
|||
|
|
WHERE `code` = 'ent_id'";
|
|||
|
|
|
|||
|
|
$result = $this->db->getOne($sql);
|
|||
|
|
|
|||
|
|
if (empty($result))
|
|||
|
|
{
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
function get_site_info()
|
|||
|
|
{
|
|||
|
|
/* 获得当前处于会话状态的管理员的邮箱 */
|
|||
|
|
$email = $this->get_admin_email();
|
|||
|
|
$email = $email ? $email : '';
|
|||
|
|
/* 获得当前网店的域名 */
|
|||
|
|
$domain = $this->ecs->get_domain();
|
|||
|
|
$domain = $domain ? $domain : '';
|
|||
|
|
/* 赋给smarty模板 */
|
|||
|
|
$sms_site_info['email'] = $email;
|
|||
|
|
$sms_site_info['domain'] = $domain;
|
|||
|
|
|
|||
|
|
return $sms_site_info;
|
|||
|
|
}
|
|||
|
|
function get_site_url()
|
|||
|
|
{
|
|||
|
|
$url = $this->ecs->url();
|
|||
|
|
$url = $url ? $url : '';
|
|||
|
|
return $url;
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* 获得当前处于会话状态的管理员的邮箱
|
|||
|
|
*
|
|||
|
|
* @access private
|
|||
|
|
* @return string or boolean 成功返回管理员的邮箱，否则返回false。
|
|||
|
|
*/
|
|||
|
|
function get_admin_email()
|
|||
|
|
{
|
|||
|
|
$sql = 'SELECT `email` FROM ' . $this->ecs->table('admin_user') . " WHERE `user_id` = '" . $_SESSION['admin_id'] . "'";
|
|||
|
|
$email = $this->db->getOne($sql);
|
|||
|
|
|
|||
|
|
if (empty($email))
|
|||
|
|
{
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return $email;
|
|||
|
|
}
|
|||
|
|
//用户短信账户信息获取
|
|||
|
|
function getSmsInfo($certi_app='sms.info',$version='1.0', $format='json'){
|
|||
|
|
$send_str['certi_app'] = $certi_app;
|
|||
|
|
$send_str['entId'] = $GLOBALS['_CFG']['ent_id'];
|
|||
|
|
$send_str['entPwd'] = $GLOBALS['_CFG']['ent_ac'];
|
|||
|
|
$send_str['source'] = SOURCE_ID;
|
|||
|
|
$send_str['version'] = $version;
|
|||
|
|
$send_str['format'] = $format;
|
|||
|
|
$send_str['timestamp'] = $this->getTime();
|
|||
|
|
$send_str['certi_ac'] = $this->make_shopex_ac($send_str,SOURCE_TOKEN);
|
|||
|
|
$sms_url = $this->get_url('info');
|
|||
|
|
$response = $this->t->request($sms_url, $send_str,'POST');
|
|||
|
|
$result = $this->json->decode($response['body'],true);
|
|||
|
|
if($result['res'] == 'succ')
|
|||
|
|
{
|
|||
|
|
return $result;
|
|||
|
|
}
|
|||
|
|
elseif($result['res'] == 'fail')
|
|||
|
|
{
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//检查手机号和发送的内容并生成生成短信队列
|
|||
|
|
function get_contents($phones,$msg)
|
|||
|
|
{
|
|||
|
|
if (empty($phones) || empty($msg))
|
|||
|
|
{
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
$phone_key=0;
|
|||
|
|
|
|||
|
|
$phones=explode(',',$phones);
|
|||
|
|
foreach($phones as $key => $value)
|
|||
|
|
{
|
|||
|
|
if($i<200)
|
|||
|
|
{
|
|||
|
|
$i++;
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
$i=0;
|
|||
|
|
$phone_key++;
|
|||
|
|
}
|
|||
|
|
if($this->is_moblie($value))
|
|||
|
|
{
|
|||
|
|
$phone[$phone_key][]=$value;
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
$i--;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if(!empty($phone))
|
|||
|
|
{
|
|||
|
|
foreach($phone as $phone_key => $val)
|
|||
|
|
{
|
|||
|
|
if (EC_CHARSET != 'utf-8')
|
|||
|
|
{
|
|||
|
|
$phone_array[$phone_key]['phones']=implode(',',$val);
|
|||
|
|
$phone_array[$phone_key]['content']=iconv('gb2312','utf-8',$msg);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
$phone_array[$phone_key]['phones']=implode(',',$val);
|
|||
|
|
$phone_array[$phone_key]['content']=$msg;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
return $phone_array;
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//获得服务器时间
|
|||
|
|
function getTime(){
|
|||
|
|
$Tsend_str['certi_app'] = 'sms.servertime';
|
|||
|
|
$Tsend_str['version'] = '1.0' ;
|
|||
|
|
$Tsend_str['format'] = 'json' ;
|
|||
|
|
$Tsend_str['certi_ac'] = $this->make_shopex_ac($Tsend_str,'SMS_TIME');
|
|||
|
|
$sms_url = $this->get_url('servertime');
|
|||
|
|
$response = $this->t->request($sms_url, $Tsend_str,'POST');
|
|||
|
|
|
|||
|
|
$result = $this->json->decode($response['body'], true);
|
|||
|
|
return $result['info'];
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* 返回指定键名的URL
|
|||
|
|
*
|
|||
|
|
* @access public
|
|||
|
|
* @param string $key URL的名字，即数组的键名
|
|||
|
|
* @return string or boolean 如果由形参指定的键名对应的URL值存在就返回该URL，否则返回false。
|
|||
|
|
*/
|
|||
|
|
function get_url($key)
|
|||
|
|
{
|
|||
|
|
$url = $this->api_urls[$key];
|
|||
|
|
|
|||
|
|
if (empty($url))
|
|||
|
|
{
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return $url;
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* 检测手机号码是否正确
|
|||
|
|
*
|
|||
|
|
*/
|
|||
|
|
function is_moblie($moblie)
|
|||
|
|
{
|
|||
|
|
return preg_match("/^0?1((3|8)[0-9]|5[0-35-9]|4[57])\d{8}$/", $moblie);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//加密算法
|
|||
|
|
function make_shopex_ac($temp_arr,$token)
|
|||
|
|
{
|
|||
|
|
ksort($temp_arr);
|
|||
|
|
$str = '';
|
|||
|
|
foreach($temp_arr as $key=>$value)
|
|||
|
|
{
|
|||
|
|
if($key!=' certi_ac')
|
|||
|
|
{
|
|||
|
|
$str.= $value;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return strtolower(md5($str.strtolower(md5($token))));
|
|||
|
|
}
|
|||
|
|
function base_encode($str)
|
|||
|
|
{
|
|||
|
|
$str = base64_encode($str);
|
|||
|
|
return strtr($str, $this->pattern());
|
|||
|
|
}
|
|||
|
|
function pattern()
|
|||
|
|
{
|
|||
|
|
return array(
|
|||
|
|
'+'=>'_1_',
|
|||
|
|
'/'=>'_2_',
|
|||
|
|
'='=>'_3_',
|
|||
|
|
);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
?>
|