588 lines
21 KiB
PHP
Executable File
588 lines
21 KiB
PHP
Executable File
<?php
|
||
/**
|
||
* NiuShop商城系统 - 团队十年电商经验汇集巨献!
|
||
* =========================================================
|
||
* Copy right 2019-2029 杭州牛之云科技有限公司, 保留所有权利。
|
||
* ----------------------------------------------
|
||
* 官方网址: https://www.niushop.com
|
||
*/
|
||
|
||
namespace addon\niusms\model;
|
||
|
||
use addon\niusms\model\Config as ConfigModel;
|
||
use app\model\BaseModel;
|
||
use think\facade\Db;
|
||
|
||
/**
|
||
* 牛云短信
|
||
*/
|
||
class Sms extends BaseModel
|
||
{
|
||
private $api = "https://www.niushop.com/api";
|
||
|
||
// 审核状态（0 未审核，1 待审核，2 审核通过， 3 审核不通过）
|
||
private $audit_status = [
|
||
'未审核',
|
||
'待审核',
|
||
'审核通过',
|
||
'审核不通过'
|
||
];
|
||
|
||
private $error_msg = [
|
||
4000 => '短信余额不足',
|
||
4001 => '用户名错误',
|
||
4002 => '密码不能为空',
|
||
4004 => '手机号码错误',
|
||
4006 => 'IP鉴权错误',
|
||
4007 => '短信账号被禁用',
|
||
4008 => '时间戳格式错误，请检查服务器时区设置是否正确',
|
||
4009 => '密码错误',
|
||
4013 => '定时时间错误',
|
||
4014 => '模板错误',
|
||
4015 => '扩展号错误',
|
||
4019 => '用户类型错误',
|
||
4023 => '签名错误',
|
||
4025 => '模板变量内容为空',
|
||
4026 => '手机号码数最大2000个',
|
||
4027 => '模板变量内容最大200组',
|
||
4029 => '请使用post请求',
|
||
4030 => 'Content-Type请使用application/json',
|
||
9998 => 'JSON解析错误',
|
||
9999 => '非法请求',
|
||
401 => '接口未授权',
|
||
];
|
||
|
||
public function getAuditStatus()
|
||
{
|
||
return $this->audit_status;
|
||
}
|
||
|
||
/**
|
||
* 查询短信签名报备状态
|
||
* @param $site_id
|
||
* @param $app_module
|
||
* @return array|mixed
|
||
*/
|
||
public function querySignature($site_id, $app_module)
|
||
{
|
||
$config_model = new ConfigModel();
|
||
$sms_config = $config_model->getSmsConfig($site_id, $app_module)[ 'data' ][ 'value' ];
|
||
$tKey = time();
|
||
$data = [
|
||
'username' => $sms_config[ 'username' ],
|
||
'password' => md5(md5($sms_config[ 'password' ]) . $tKey),
|
||
'tKey' => $tKey,
|
||
'sign' => input('signature', $sms_config[ 'signature' ]),//短信签名
|
||
];
|
||
$url = 'https://api.mix2.zthysms.com/sms/v1/sign/query';
|
||
$res = $this->sendSms($url, $data);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 创建子账号
|
||
* @param $data
|
||
* @return array|mixed
|
||
*/
|
||
public function createChildAccount($data, $site_id, $app_module)
|
||
{
|
||
$url = $this->api . '/sms/createChildAccountNew';
|
||
$res = $this->httpPost($url, $data);
|
||
if ($res[ 'code' ] == 0) {
|
||
$config_model = new ConfigModel();
|
||
$data[ 'signature' ] = "";
|
||
$config_model->setSmsConfig($data, 1, $site_id, $app_module);
|
||
}
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 账号登录
|
||
* @param $data
|
||
* @param $site_id
|
||
* @param $app_module
|
||
* @return array|mixed
|
||
*/
|
||
public function loginAccount($data, $site_id, $app_module)
|
||
{
|
||
$url = $this->api . '/sms/loginAccount';
|
||
$res = $this->httpPost($url, $data);
|
||
if ($res[ 'code' ] == 0 && !empty($res[ 'data' ])) {
|
||
$config_model = new ConfigModel();
|
||
$res[ 'data' ][ 'password' ] = $data[ 'password' ];
|
||
$config_model->setSmsConfig($res[ 'data' ], 1, $site_id, $app_module);
|
||
|
||
// 清空短信模板配置信息
|
||
model('sms_template')->update([ 'tem_id' => 0, 'status' => 0, 'audit_status' => 0 ], [ [ 'site_id', '=', $site_id ] ]);
|
||
|
||
// 刷新模板id
|
||
$this->getSmsTemplatePageList($site_id, [], 1, 0, 'template_id desc', 'template_id,tem_id,template_name,audit_status,status');
|
||
|
||
}
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 重置密码
|
||
* @param $data
|
||
* @return mixed
|
||
*/
|
||
public function resetPassword($data)
|
||
{
|
||
$url = $this->api . '/sms/resetPassword';
|
||
$res = $this->httpPost($url, $data);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 获取动态数字码
|
||
* @return mixed
|
||
*/
|
||
public function captcha()
|
||
{
|
||
$url = $this->api . '/captcha/captcha';
|
||
$res = $this->httpPost($url, []);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 获取手机验证码
|
||
* @param $data
|
||
* @return mixed
|
||
*/
|
||
public function mobileCode($data)
|
||
{
|
||
$url = $this->api . '/sms/mobileCode';
|
||
$res = $this->httpPost($url, $data);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 子账号添加短信签名
|
||
* @param $data
|
||
* @param $site_id
|
||
* @param $app_module
|
||
* @return array|mixed
|
||
*/
|
||
public function addChildSignature($data, $site_id, $app_module)
|
||
{
|
||
$url = $this->api . '/sms/addChildSignature';
|
||
$res = $this->httpPost($url, $data);
|
||
// if ($res[ 'code' ] == 0) {
|
||
// $config_model = new ConfigModel();
|
||
// $sms_config = $config_model->getSmsConfig($site_id, $app_module);
|
||
// $sms_config = $sms_config[ 'data' ][ 'value' ];
|
||
// if (!empty($sms_config)) {
|
||
// $save_data = $sms_config;
|
||
// } else {
|
||
// $save_data = $data;
|
||
// }
|
||
// $save_data[ 'signature' ] = "【" . $data[ 'signature' ] . "】";
|
||
// $config_model->setSmsConfig($save_data, 1, $site_id, $app_module);
|
||
// }
|
||
if(!empty($res['data']['failList'])){
|
||
return $this->error($res['data']['failList'][0], $res['data']['failList'][0]['msg']);
|
||
}
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 子账号删除短信签名
|
||
* @param $data
|
||
* @param $site_id
|
||
* @param $app_module
|
||
* @return array|mixed
|
||
*/
|
||
public function deleteChildSignature($data, $site_id, $app_module)
|
||
{
|
||
$url = $this->api . '/sms/deleteChildSignature';
|
||
$res = $this->httpPost($url, $data);
|
||
if(!empty($res['data']['failList'])){
|
||
return $this->error($res['data']['failList'][0], $res['data']['failList'][0]['msg']);
|
||
}
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 查询子账号信息
|
||
*/
|
||
public function getChildAccountInfo($data)
|
||
{
|
||
$url = $this->api . '/sms/getChildAccountInfo';
|
||
$res = $this->httpPost($url, $data);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 获取签名列表
|
||
* @param $data
|
||
* @return mixed
|
||
*/
|
||
public function getChildSignatureList($data)
|
||
{
|
||
$url = $this->api . '/sms/getChildSignatureList';
|
||
$res = $this->httpPost($url, $data);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 获取短信套餐包
|
||
* @return mixed
|
||
*/
|
||
public function getSmsPackageList()
|
||
{
|
||
$url = $this->api . '/sms/getSmsPackageList';
|
||
$res = $this->httpPost($url, '');
|
||
return $res;
|
||
}
|
||
|
||
/******************************************** 短信模板 start ********************************************************************/
|
||
|
||
/**
|
||
* 设置短信模板开启
|
||
* @param $template_id
|
||
* @param $status
|
||
* @param $sms_config
|
||
* @param $site_id
|
||
* @param $app_module
|
||
* @return array|mixed
|
||
*/
|
||
public function enableTemplate($template_id, $status, $sms_config, $site_id, $app_module)
|
||
{
|
||
//获取模板信息
|
||
$template_info = model('sms_template')->getInfo([ [ 'template_id', '=', $template_id ] ]);
|
||
if (empty($template_info)) {
|
||
return $this->error('', '模板不存在');
|
||
}
|
||
|
||
if (empty($sms_config)) {
|
||
return $this->error('', '账号不存在，请先注册牛云短信账号');
|
||
}
|
||
|
||
model('sms_template')->startTrans();
|
||
try {
|
||
|
||
$signature_status = $this->querySignature($site_id, $app_module);
|
||
if ($signature_status[ 'auditResult' ] != 2) {
|
||
model('sms_template')->rollback();
|
||
return $this->error('', $signature_status[ 'msg' ]);
|
||
}
|
||
|
||
if ($template_info[ 'tem_id' ] == 0 || $template_info['audit_status'] == 3) {
|
||
|
||
$data = [
|
||
'username' => $sms_config[ 'username' ],
|
||
'signature' => $sms_config[ 'signature' ],
|
||
'template_name' => $template_info[ 'template_name' ],
|
||
'template_type' => $template_info[ 'template_type' ],
|
||
'template_content' => $template_info[ 'template_content' ],
|
||
'param_json' => $template_info[ 'param_json' ],
|
||
'tem_id' => $template_info['tem_id'],
|
||
];
|
||
$url = $this->api . '/sms/addChildSmsTemplate';
|
||
$res = $this->httpPost($url, $data);
|
||
if ($res[ 'code' ] < 0) {
|
||
model('sms_template')->rollback();
|
||
return $res;
|
||
}
|
||
|
||
//修改状态
|
||
$template_data = [
|
||
'tem_id' => $res[ 'data' ][ 'temId' ],
|
||
'status' => $status,
|
||
'audit_status' => 1,
|
||
'update_time' => time()
|
||
];
|
||
|
||
} else {
|
||
//修改状态
|
||
$template_data = [
|
||
'status' => $status,
|
||
'update_time' => time()
|
||
];
|
||
}
|
||
model('sms_template')->update($template_data, [ [ 'template_id', '=', $template_id ] ]);
|
||
|
||
//判断message信息是否存在
|
||
$message_info = model('message')->getInfo([ [ 'keywords', '=', $template_info[ 'keywords' ] ] ]);
|
||
if ($message_info) {
|
||
$message_data = [
|
||
'sms_is_open' => $status
|
||
];
|
||
model('message')->update($message_data, [ [ 'keywords', '=', $template_info[ 'keywords' ] ] ]);
|
||
} else {
|
||
$message_data = [
|
||
'site_id' => 1,
|
||
'keywords' => $template_info[ 'keywords' ],
|
||
'sms_is_open' => $status
|
||
];
|
||
model('message')->add($message_data);
|
||
}
|
||
|
||
model('sms_template')->commit();
|
||
return $this->success();
|
||
} catch (\Exception $e) {
|
||
model('sms_template')->rollback();
|
||
return $this->error('', $e->getMessage());
|
||
}
|
||
|
||
}
|
||
|
||
/**
|
||
* 设置短信模板关闭
|
||
* @param $template_ids
|
||
* @param $status
|
||
* @param $sms_config
|
||
* @return array|mixed
|
||
*/
|
||
public function disableTemplate($template_ids, $status, $sms_config)
|
||
{
|
||
//获取模板信息
|
||
$template_list = model('sms_template')->getList([ [ 'template_id', 'in', $template_ids ] ]);
|
||
if (empty($template_list)) {
|
||
return $this->error('', '模板不存在');
|
||
}
|
||
|
||
if (empty($sms_config)) {
|
||
return $this->error('', '账号不存在，请先注册牛云短信账号');
|
||
}
|
||
|
||
model('sms_template')->startTrans();
|
||
try {
|
||
|
||
//修改状态
|
||
$template_data = [
|
||
'status' => $status,
|
||
'update_time' => time()
|
||
];
|
||
|
||
model('sms_template')->update($template_data, [ [ 'template_id', 'in', $template_ids ] ]);
|
||
|
||
foreach ($template_list as $k => $v) {
|
||
//判断message信息是否存在
|
||
$message_info = model('message')->getInfo([ [ 'keywords', '=', $v[ 'keywords' ] ] ]);
|
||
if ($message_info) {
|
||
$message_data = [
|
||
'sms_is_open' => $status
|
||
];
|
||
model('message')->update($message_data, [ [ 'keywords', '=', $v[ 'keywords' ] ] ]);
|
||
} else {
|
||
$message_data = [
|
||
'site_id' => 1,
|
||
'keywords' => $v[ 'keywords' ],
|
||
'sms_is_open' => $status
|
||
];
|
||
model('message')->add($message_data);
|
||
}
|
||
}
|
||
|
||
model('sms_template')->commit();
|
||
return $this->success();
|
||
} catch (\Exception $e) {
|
||
model('sms_template')->rollback();
|
||
return $this->error('', $e->getMessage());
|
||
}
|
||
|
||
}
|
||
|
||
/**
|
||
* 修改审核状态
|
||
* @param $audit_status
|
||
* @param $template_id
|
||
* @return array
|
||
*/
|
||
public function modifyAuditStatus($audit_status, $template_id)
|
||
{
|
||
$res = model('sms_template')->update([ 'audit_status' => $audit_status ], [ [ 'template_id', '=', $template_id ] ]);
|
||
return $this->success($res);
|
||
}
|
||
|
||
/**
|
||
* 查询短信模板审核状态
|
||
* @param $data
|
||
* @return array|mixed
|
||
*/
|
||
public function queryTemplate($data)
|
||
{
|
||
$url = 'https://api.mix2.zthysms.com/sms/v2/template/query';
|
||
$res = $this->sendSms($url, $data);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 获取短信模板分页列表
|
||
* @param $site_id
|
||
* @param array $condition
|
||
* @param int $page
|
||
* @param int $page_size
|
||
* @param string $order
|
||
* @param string $field
|
||
* @return array
|
||
*/
|
||
public function getSmsTemplatePageList($site_id, $condition = [], $page = 1, $page_size = PAGE_LIST_ROWS, $order = 'template_id desc', $field = '*')
|
||
{
|
||
$res = model('sms_template')->pageList($condition, $field, $order, $page, $page_size);
|
||
|
||
$config_model = new ConfigModel();
|
||
$sms_config = $config_model->getSmsConfig($site_id, 'shop')[ 'data' ][ 'value' ];
|
||
|
||
$url = $this->api . '/sms/getChildSmsTemplateList';
|
||
$sms_template_list = $this->httpPost($url, [ 'username' => $sms_config[ 'username' ] ]);
|
||
$sms_template_list = $sms_template_list[ 'data' ];
|
||
$sms_template_list = array_column($sms_template_list, null, 'temName');
|
||
|
||
// 修改模板id、审核状态
|
||
$update_data_arr = [];
|
||
foreach ($res[ 'list' ] as $k => $v) {
|
||
$sms_template_info = $sms_template_list[$v['template_name']] ?? null;
|
||
$update_data = [
|
||
'status' => 0,
|
||
'audit_status' => 0,
|
||
'tem_id' => 0,
|
||
];
|
||
if($sms_template_info){
|
||
$update_data['status'] = $v['status'];
|
||
$update_data['audit_status'] = $sms_template_info['auditResult'];
|
||
$update_data['tem_id'] = $sms_template_info['temId'];
|
||
}
|
||
$res['list'][$k] = array_merge($v, $update_data);
|
||
$update_data_arr[$v['template_id']] = $update_data;
|
||
}
|
||
|
||
//批量修改数据
|
||
$status_sql = [];
|
||
$audit_status_sql = [];
|
||
$tem_id_sql = [];
|
||
foreach($update_data_arr as $template_id=>$update_data){
|
||
$status_sql[] = "WHEN template_id = {$template_id} THEN {$update_data['status']}";
|
||
$audit_status_sql[] = "WHEN template_id = {$template_id} THEN {$update_data['audit_status']}";
|
||
$tem_id_sql[] = "WHEN template_id = {$template_id} THEN {$update_data['tem_id']}";
|
||
}
|
||
model('sms_template')->update([
|
||
'status' => Db::raw("CASE ". join(' ', $status_sql) ." END"),
|
||
'audit_status' => Db::raw("CASE ". join(' ', $audit_status_sql) ." END"),
|
||
'tem_id' => Db::raw("CASE ". join(' ', $tem_id_sql) ." END"),
|
||
], [[ 'template_id', 'in', array_keys($update_data_arr)]]);
|
||
|
||
return $this->success($res);
|
||
}
|
||
|
||
/**
|
||
* 发送短信
|
||
* @param $params
|
||
* @return array
|
||
*/
|
||
public function send($params)
|
||
{
|
||
$config_model = new ConfigModel();
|
||
$sms_config = $config_model->getSmsConfig($params[ 'site_id' ], 'shop')[ 'data' ];
|
||
if ($sms_config[ 'is_use' ]) {
|
||
$config = $sms_config[ 'value' ];
|
||
if (empty($config)) return $this->error([], "牛云短信尚未配置");
|
||
|
||
$sms_info = $params[ "message_info" ][ "sms_json_array" ];//消息类型模板 短信模板信息
|
||
if (empty($sms_info)) return $this->error([], "消息模板尚未配置");
|
||
if ($sms_info[ 'audit_status' ] != 2) return $this->error([], "消息模板尚未审核通过");
|
||
|
||
$time = time();
|
||
$data = [
|
||
'username' => $config[ 'username' ],
|
||
'password' => md5(md5($config[ 'password' ]) . $time),
|
||
'signature' => $config[ 'signature' ],
|
||
'tKey' => $time,
|
||
'tpId' => $sms_info[ 'tem_id' ],
|
||
'records' => [
|
||
'mobile' => $params[ 'sms_account' ],
|
||
'tpContent' => $params[ 'var_parse' ]
|
||
]
|
||
];
|
||
$result = $this->sendSms('https://api.mix2.zthysms.com/v2/sendSmsTp', $data);
|
||
if ($result[ 'code' ] == 200) {
|
||
return $this->success([ "addon" => "niusms", "addon_name" => "牛云短信", "content" => $sms_info[ "template_content" ] ]);
|
||
} else {
|
||
return $this->error([], $result[ 'msg' ]);
|
||
}
|
||
}
|
||
}
|
||
|
||
/******************************************** 短信模板 end ********************************************************************/
|
||
|
||
/**
|
||
* 数据请求
|
||
* @param $url
|
||
* @param $data
|
||
* @return mixed
|
||
*/
|
||
public function httpPost($url, $data)
|
||
{
|
||
// 模拟提交数据函数
|
||
$curl = curl_init(); // 启动一个CURL会话
|
||
curl_setopt($curl, CURLOPT_URL, $url); // 要访问的地址
|
||
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false); // 对认证证书来源的检查
|
||
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false); // 从证书中检查SSL加密算法是否存在
|
||
curl_setopt($curl, CURLOPT_USERAGENT, $_SERVER[ 'HTTP_USER_AGENT' ]); // 模拟用户使用的浏览器
|
||
curl_setopt($curl, CURLOPT_POST, true); // 发送一个常规的Post请求
|
||
|
||
curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($data)); // Post提交的数据包
|
||
curl_setopt($curl, CURLOPT_TIMEOUT, 30); // 设置超时限制防止死循环
|
||
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); // 获取的信息以文件流的形式返回
|
||
curl_setopt($curl, CURLOPT_HEADER, false); //开启header
|
||
curl_setopt($curl, CURLOPT_HTTPHEADER, array (
|
||
'Content-Type: application/json; charset=utf-8',
|
||
)); //类型为json
|
||
$result = curl_exec($curl); // 执行操作
|
||
if (curl_errno($curl)) {
|
||
return $this->error('', '系统错误，请联系平台进行处理');
|
||
}
|
||
curl_close($curl); // 关键CURL会话
|
||
$return = json_decode($result, true); // 返回数据
|
||
//dd($return);
|
||
if (!empty($return)) {
|
||
if ($return[ 'code' ] < 0) {
|
||
return $this->error($return[ 'code' ], $return[ 'message' ]);
|
||
} else {
|
||
return $this->success($return[ 'data' ]);
|
||
}
|
||
} else {
|
||
return $result;
|
||
}
|
||
}
|
||
|
||
public function sendSms($url, $data)
|
||
{
|
||
// 模拟提交数据函数
|
||
$curl = curl_init(); // 启动一个CURL会话
|
||
curl_setopt($curl, CURLOPT_URL, $url); // 要访问的地址
|
||
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false); // 对认证证书来源的检查
|
||
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false); // 从证书中检查SSL加密算法是否存在
|
||
curl_setopt($curl, CURLOPT_USERAGENT, $_SERVER[ 'HTTP_USER_AGENT' ]); // 模拟用户使用的浏览器
|
||
curl_setopt($curl, CURLOPT_POST, true); // 发送一个常规的Post请求
|
||
|
||
curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($data)); // Post提交的数据包
|
||
curl_setopt($curl, CURLOPT_TIMEOUT, 30); // 设置超时限制防止死循环
|
||
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); // 获取的信息以文件流的形式返回
|
||
curl_setopt($curl, CURLOPT_HEADER, false); //开启header
|
||
curl_setopt($curl, CURLOPT_HTTPHEADER, array (
|
||
'Content-Type: application/json; charset=utf-8',
|
||
)); //类型为json
|
||
$result = curl_exec($curl); // 执行操作
|
||
if (curl_errno($curl)) {
|
||
return $this->error('', '系统错误，请联系平台进行处理');
|
||
}
|
||
curl_close($curl); // 关键CURL会话
|
||
$res = json_decode($result, true); // 返回数据
|
||
if(isset($res['code']) && $res['code'] != 200 && isset($this->error_msg[$res['code']])){
|
||
$res['msg'] = $this->error_msg[$res['code']];
|
||
}
|
||
return $res;
|
||
}
|
||
|
||
public function updateNiusmsTel($mobiles, $username)
|
||
{
|
||
$url = $this->api . '/sms/updateMemberNiusmsTel';
|
||
$res = $this->httpPost($url, [ 'mobiles' => $mobiles, "username" => $username ]);
|
||
return $res;
|
||
}
|
||
|
||
}
|