blackteay/ThinkAdmin
1
0
Fork 0
mirror of https://gitee.com/zoujingli/ThinkAdmin.git synced 2025-04-06 03:58:04 +08:00
Code Issues Projects Releases Wiki Activity

[调整]移除library改service

Browse Source
This commit is contained in:
邹景立 2017-03-23 12:40:51 +08:00
parent 290fe74069
commit 692d0d0d16
24 changed files with 680 additions and 4695 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
application/admin/controller/Auth.php
View File

@ -16,8 +16,8 @@ namespace app\admin\controller;
use app\admin\model\Node;
use controller\BasicAdmin;
use library\Data;
use library\Tools;
use service\DataService;
use service\ToolsService;
use think\Db;
/**
@ -59,7 +59,7 @@ class Auth extends BasicAdmin {
unset($nodes[$key]);
}
}
$this->success('获取节点成功！', '', $this->_filterNodes($this->_filterNodes(Tools::arr2tree($nodes, 'node', 'pnode', '_sub_'))));
$this->success('获取节点成功！', '', $this->_filterNodes($this->_filterNodes(ToolsService::arr2tree($nodes, 'node', 'pnode', '_sub_'))));
break;
case 'save':
$data = [];
@ -106,7 +106,7 @@ class Auth extends BasicAdmin {
* 权限禁用
*/
public function forbid() {
if (Data::update($this->table)) {
if (DataService::update($this->table)) {
$this->success("权限禁用成功！", '');
} else {
$this->error("权限禁用失败，请稍候再试！");
@ -117,7 +117,7 @@ class Auth extends BasicAdmin {
* 权限恢复
*/
public function resume() {
if (Data::update($this->table)) {
if (DataService::update($this->table)) {
$this->success("权限启用成功！", '');
} else {
$this->error("权限启用失败，请稍候再试！");
@ -128,7 +128,7 @@ class Auth extends BasicAdmin {
* 权限删除
*/
public function del() {
if (Data::update($this->table)) {
if (DataService::update($this->table)) {
$this->success("权限删除成功！", '');
} else {
$this->error("权限删除失败，请稍候再试！");

4
application/admin/controller/Config.php
View File

@ -15,7 +15,7 @@
namespace app\admin\controller;
use controller\BasicAdmin;
use library\Data;
use service\DataService;
/**
* 后台参数配置控制器
@ -47,7 +47,7 @@ class Config extends BasicAdmin {
} else {
$data = $this->request->post();
foreach ($data as $key => $vo) {
Data::save($this->table, ['name' => $key, 'value' => $vo], 'name');
DataService::save($this->table, ['name' => $key, 'value' => $vo], 'name');
}
$this->success('数据修改成功！', '');
}

8
application/admin/controller/Index.php
View File

@ -16,8 +16,8 @@ namespace app\admin\controller;
use app\admin\model\Node;
use controller\BasicAdmin;
use library\Data;
use library\Tools;
use service\DataService;
use service\ToolsService;
use think\Db;
use think\View;
@ -37,7 +37,7 @@ class Index extends BasicAdmin {
public function index() {
Node::applyAuthNode();
$list = Db::name('SystemMenu')->field('title,id,pid,url,icon')->order('sort asc,id asc')->where('status', '1')->select();
$menus = $this->_filter_menu(Tools::arr2tree($list));
$menus = $this->_filter_menu(ToolsService::arr2tree($list));
$this->assign('title', '后台管理');
$this->assign('menus', $menus);
return view();
@ -109,7 +109,7 @@ class Index extends BasicAdmin {
if (md5($data['oldpassword']) !== $user['password']) {
$this->error('旧密码验证失败，请重新输入！');
}
if (Data::save('SystemUser', ['id' => session('user.id'), 'password' => md5($data['password'])])) {
if (DataService::save('SystemUser', ['id' => session('user.id'), 'password' => md5($data['password'])])) {
$this->success('密码修改成功，下次请使用新密码登录！', '');
} else {
$this->error('密码修改失败，请稍候再试！');

16
application/admin/controller/Menu.php
View File

@ -16,8 +16,8 @@ namespace app\admin\controller;
use app\admin\model\Node;
use controller\BasicAdmin;
use library\Data;
use library\Tools;
use service\DataService;
use service\ToolsService;
use think\Db;
/**
@ -51,9 +51,9 @@ class Menu extends BasicAdmin {
protected function _index_data_filter(&$data) {
foreach ($data as &$vo) {
($vo['url'] !== '#') && ($vo['url'] = url($vo['url']));
$vo['ids'] = join(',', Tools::getArrSubIds($data, $vo['id']));
$vo['ids'] = join(',', ToolsService::getArrSubIds($data, $vo['id']));
}
$data = Tools::arr2table($data);
$data = ToolsService::arr2table($data);
}
/**
@ -82,7 +82,7 @@ class Menu extends BasicAdmin {
// 上级菜单处理
$_menus = Db::name($this->table)->where('status', '1')->order('sort desc,id desc')->select();
$_menus[] = ['title' => '顶级菜单', 'id' => '0', 'pid' => '-1'];
$menus = Tools::arr2table($_menus);
$menus = ToolsService::arr2table($_menus);
foreach ($menus as $key => &$menu) {
if (substr_count($menu['path'], '-') > 3) {
unset($menus[$key]);
@ -112,7 +112,7 @@ class Menu extends BasicAdmin {
*/
public function del() {
$this->error('别再删我菜单了...');
if (Data::update($this->table)) {
if (DataService::update($this->table)) {
$this->success("菜单删除成功！", '');
} else {
$this->error("菜单删除失败，请稍候再试！");
@ -124,7 +124,7 @@ class Menu extends BasicAdmin {
*/
public function forbid() {
$this->error('请不要禁用菜单...');
if (Data::update($this->table)) {
if (DataService::update($this->table)) {
$this->success("菜单禁用成功！", '');
} else {
$this->error("菜单禁用失败，请稍候再试！");
@ -135,7 +135,7 @@ class Menu extends BasicAdmin {
* 菜单禁用
*/
public function resume() {
if (Data::update($this->table)) {
if (DataService::update($this->table)) {
$this->success("菜单启用成功！", '');
} else {
$this->error("菜单启用失败，请稍候再试！");

8
application/admin/controller/Node.php
View File

@ -16,8 +16,8 @@ namespace app\admin\controller;
use app\admin\model\Node as NodeModel;
use controller\BasicAdmin;
use library\Data;
use library\Tools;
use service\DataService;
use service\ToolsService;
/**
* 系统功能节点管理
@ -45,7 +45,7 @@ class Node extends BasicAdmin {
];
$this->assign('alert', $alert);
$this->assign('title', '系统节点管理');
$this->assign('nodes', Tools::arr2table(NodeModel::get(), 'node', 'pnode'));
$this->assign('nodes', ToolsService::arr2table(NodeModel::get(), 'node', 'pnode'));
return view();
}
@ -59,7 +59,7 @@ class Node extends BasicAdmin {
$nameattr = explode('.', $post['name']);
$field = array_shift($nameattr);
$data = ['node' => join(',', $nameattr), $field => $post['value']];
Data::save($this->table, $data, 'node');
DataService::save($this->table, $data, 'node');
$this->success('参数保存成功！', '');
}
} else {

10
application/admin/controller/User.php
View File

@ -15,7 +15,7 @@
namespace app\admin\controller;
use controller\BasicAdmin;
use library\Data;
use service\DataService;
use think\Db;
/**
@ -79,7 +79,7 @@ class User extends BasicAdmin {
if ($data['password'] !== $data['repassword']) {
$this->error('两次输入的密码不一致！');
}
if (Data::save($this->table, ['id' => $data['id'], 'password' => md5($data['password'])], 'id')) {
if (DataService::save($this->table, ['id' => $data['id'], 'password' => md5($data['password'])], 'id')) {
$this->success('密码修改成功，下次请使用新密码登录！', '');
} else {
$this->error('密码修改失败，请稍候再试！');
@ -113,7 +113,7 @@ class User extends BasicAdmin {
if (in_array('10000', explode(',', $this->request->post('id')))) {
$this->error('系统超级账号禁止删除！');
}
if (Data::update($this->table)) {
if (DataService::update($this->table)) {
$this->success("用户删除成功！", '');
} else {
$this->error("用户删除失败，请稍候再试！");
@ -127,7 +127,7 @@ class User extends BasicAdmin {
if (in_array('10000', explode(',', $this->request->post('id')))) {
$this->error('系统超级账号禁止操作！');
}
if (Data::update($this->table)) {
if (DataService::update($this->table)) {
$this->success("用户禁用成功！", '');
} else {
$this->error("用户禁用失败，请稍候再试！");
@ -138,7 +138,7 @@ class User extends BasicAdmin {
* 用户禁用
*/
public function resume() {
if (Data::update($this->table)) {
if (DataService::update($this->table)) {
$this->success("用户启用成功！", '');
} else {
$this->error("用户启用失败，请稍候再试！");

6
extend/controller/BasicAdmin.php
View File

@ -14,10 +14,10 @@
namespace controller;
use library\Data;
use service\DataService;
use think\Controller;
use think\Db;
use think\db\Query;
use think\Db;
/**
* 后台权限基础控制器
@ -158,7 +158,7 @@ class BasicAdmin extends Controller {
if ($this->request->isPost()) { // Save Options
$vo = array_merge(input('post.'), $data);
$this->_callback('_form_filter', $vo);
$result = Data::save($db, $vo, $pk, $where);
$result = DataService::save($db, $vo, $pk, $where);
if (false !== $this->_callback('_form_result', $result)) {
$result !== false ? $this->success('恭喜，保存成功哦！', '') : $this->error('保存失败，请稍候再试！');
}

4
extend/controller/BasicApi.php
View File

@ -2,7 +2,7 @@
namespace controller;
use library\Tools;
use service\ToolsService;
use think\Cache;
use think\Request;
use think\Response;
@ -31,7 +31,7 @@ class BasicApi {
*/
public function __construct(Request $request = null) {
// CORS 跨域 Options 检测响应
Tools::corsOptionsHandler();
ToolsService::corsOptionsHandler();
// 获取当前 Request 对象
$this->request = is_null($request) ? Request::instance() : $request;
// 安全方法请求过滤

1
extend/controller/BasicWechat.php
View File

@ -14,7 +14,6 @@
namespace controller;
use service\FansService;
use think\Controller;
class BasicWechat extends Controller {

106
extend/library/Csv.php
View File

@ -1,106 +0,0 @@
<?php
// +----------------------------------------------------------------------
// | Think.Admin
// +----------------------------------------------------------------------
// | 版权所有 2016~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/Think.Admin
// +----------------------------------------------------------------------
namespace library;
/**
* Cvs 导出工具
*
* 流输出操作，支持输出大文件
* @author Anyon <zoujingli@qq.com>
* @date 2016-05-12 09:50
*/
class Csv {
/**
* 输出对象
* @var string
*/
protected $output;
/**
* 输出行数
* @var int
*/
protected $_row_nums = 0;
/**
* 构造函数
* @param string $downname 下载的文件名
* @param string $filename 输出文件流名
*/
public function __construct($downname = 'export.csv', $filename = 'php://output') {
if ($filename === 'php://output') {
header("Content-type:text/csv");
header("Content-Disposition:attachment;filename=" . $downname);
header('Cache-Control:must-revalidate,post-check=0,pre-check=0');
header('Expires:0');
header('Pragma:public');
}
$this->output = fopen($filename, 'w');
}
/**
* 增加数据列
* @param array $data
*/
public function add_list($data) {
foreach ($data as $row) {
is_array($row) && $this->add_row($row);
}
}
/**
* 增加一行记录
* @param array $row
* @return Csv
*/
public function add_row($row) {
$this->_row_nums++;
if ($this->_row_nums % 1000 === 0) {
ob_flush();
flush();
}
fputcsv($this->output, $this->_convert_gbk($row));
return $this;
}
/**
* 整行数据转为GBK编码
* @param string $row
* @return string
*/
protected function _convert_gbk($row) {
foreach ($row as &$value) {
$value = mb_convert_encoding($value, 'gbk', 'utf-8');
}
return $row;
}
/**
* 关闭输出对象
*/
public function close() {
!empty($this->output) && fclose($this->output);
$this->output = null;
}
/**
* 魔术方法，销毁对象
*/
public function __destruct() {
$this->close();
}
}

106
extend/library/Express.php
View File

@ -1,106 +0,0 @@
<?php
// +----------------------------------------------------------------------
// | Think.Admin
// +----------------------------------------------------------------------
// | 版权所有 2016~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/Think.Admin
// +----------------------------------------------------------------------
namespace library;
/**
* 快递查询接口
* @class Express
* @brief Line的协议接口
*/
class Express {
const APPID = '1232779';
const APPKEY = 'ac45f461-8c1a-4518-87b1-bb8e835a2f9d';
const APIURI = 'http://api.kdniao.com/Ebusiness/EbusinessOrderHandle.aspx';
/**
* @brief 获取物流轨迹线路
* @param $ShipperCode string 物流公司代号
* @param $LogisticCode string 物流单号
* @return string array 轨迹数据
*/
public static function line($ShipperCode, $LogisticCode) {
$sendData = json_encode(array('ShipperCode' => $ShipperCode, 'LogisticCode' => $LogisticCode), JSON_UNESCAPED_UNICODE);
$data = array(
'RequestData' => $sendData,
'EBusinessID' => self::APPID,
'RequestType' => '1002',
'DataType' => 2,
'DataSign' => base64_encode(md5($sendData . self::APPKEY)),
);
$result = Http::post(self::APIURI, $data);
$resultJson = json_decode($result, true);
if (!$resultJson) {
die(var_export($result));
}
return self::response($resultJson);
}
/**
* 处理返回数据统一数据格式
* @param $result 结果处理
* @return array 通用的结果集 array('result' => 'success或者fail','data' => array( array('time' => '时间','info' => '地点'),......),'reason' => '失败原因')
*/
public static function response($result) {
$status = "fail";
$data = array();
$message = "此单号无跟踪记录";
if (isset($result['Message'])) {
$message = $result['Message'];
} else if (isset($result['Reason'])) {
$message = $result['Reason'];
}
if (isset($result['Traces']) && $result['Traces']) {
foreach ($result['Traces'] as $key => $val) {
$data[$key]['time'] = $val['AcceptTime'];
$data[$key]['info'] = $val['AcceptStation'];
}
$status = "success";
$message = '此订单号有' . count($data) . '条跟踪记录';
}
return array('result' => $status, 'data' => $data, 'message' => $message);
}
/**
* CURL模拟提交数据
* @param $url string 提交的url
* @param $data array 要发送的数据
* @return mixed 返回的数据
*/
private static function curl_post($url, $data) {
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, self::_encode_data($data));
return curl_exec($ch);
}
/**
* 进行数据的string字符串编码
* @param type $datas
* @return type
*/
private static function _encode_data($datas) {
$temps = array();
foreach ($datas as $key => $value) {
$temps[] = sprintf('%s=%s', $key, $value);
}
return join('&', $temps);
}
}

396
extend/library/Ip2Region.php
View File

@ -1,396 +0,0 @@
<?php
// +----------------------------------------------------------------------
// | Think.Admin
// +----------------------------------------------------------------------
// | 版权所有 2016~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/Think.Admin
// +----------------------------------------------------------------------
namespace library;
/**
* ip2region php seacher client class
*
* @author chenxin<chenxin619315@gmail.com>
* @date 2015-10-29
*/
defined('INDEX_BLOCK_LENGTH') or define('INDEX_BLOCK_LENGTH', 12);
defined('TOTAL_HEADER_LENGTH') or define('TOTAL_HEADER_LENGTH', 4096);
class Ip2Region {
/**
* db file handler
*/
private $dbFileHandler = NULL;
/**
* header block info
*/
private $HeaderSip = NULL;
private $HeaderPtr = NULL;
private $headerLen = 0;
/**
* super block index info
*/
private $firstIndexPtr = 0;
private $lastIndexPtr = 0;
private $totalBlocks = 0;
/**
* for memory mode only
* the original db binary string
*/
private $dbBinStr = NULL;
private $dbFile = NULL;
/**
* construct method
*
* @param ip2regionFile
*/
public function __construct($ip2regionFile = null) {
if (is_null($ip2regionFile)) {
$this->dbFile = __DIR__ . '/resource/ip2region.db';
} else {
$this->dbFile = $ip2regionFile;
}
}
/**
* 静态查询
* @staticvar type $self
* @param string $ip
* @param string $method
* @return string
*/
public static function query($ip, $method = 'btreeSearch') {
static $self = null;
if (empty($self)) {
$self = new Ip2Region();
}
$ret = $self->$method($ip);
return $ret['region'];
}
/**
* all the db binary string will be loaded into memory
* then search the memory only and this will a lot faster than disk base search
* @param $ip
* @return array|null
*/
public function memorySearch($ip) {
//check and load the binary string for the first time
if ($this->dbBinStr == NULL) {
$this->dbBinStr = file_get_contents($this->dbFile);
if ($this->dbBinStr == false) {
throw new Exception("Fail to open the db file {$this->dbFile}");
}
$this->firstIndexPtr = self::getLong($this->dbBinStr, 0);
$this->lastIndexPtr = self::getLong($this->dbBinStr, 4);
$this->totalBlocks = ($this->lastIndexPtr - $this->firstIndexPtr) / INDEX_BLOCK_LENGTH + 1;
}
if (is_string($ip))
$ip = self::safeIp2long($ip);
//binary search to define the data
$l = 0;
$h = $this->totalBlocks;
$dataPtr = 0;
while ($l <= $h) {
$m = (($l + $h) >> 1);
$p = $this->firstIndexPtr + $m * INDEX_BLOCK_LENGTH;
$sip = self::getLong($this->dbBinStr, $p);
if ($ip < $sip) {
$h = $m - 1;
} else {
$eip = self::getLong($this->dbBinStr, $p + 4);
if ($ip > $eip) {
$l = $m + 1;
} else {
$dataPtr = self::getLong($this->dbBinStr, $p + 8);
break;
}
}
}
//not matched just stop it here
if ($dataPtr == 0)
return NULL;
//get the data
$dataLen = (($dataPtr >> 24) & 0xFF);
$dataPtr = ($dataPtr & 0x00FFFFFF);
return array(
'city_id' => self::getLong($this->dbBinStr, $dataPtr),
'region' => substr($this->dbBinStr, $dataPtr + 4, $dataLen - 4)
);
}
/**
* get the data block throught the specifield ip address or long ip numeric with binary search algorithm
*
* @param ip
* @return mixed Array or NULL for any error
*/
public function binarySearch($ip) {
//check and conver the ip address
if (is_string($ip))
$ip = self::safeIp2long($ip);
if ($this->totalBlocks == 0) {
//check and open the original db file
if ($this->dbFileHandler == NULL) {
$this->dbFileHandler = fopen($this->dbFile, 'r');
if ($this->dbFileHandler == false) {
throw new Exception("Fail to open the db file {$this->dbFile}");
}
}
fseek($this->dbFileHandler, 0);
$superBlock = fread($this->dbFileHandler, 8);
$this->firstIndexPtr = self::getLong($superBlock, 0);
$this->lastIndexPtr = self::getLong($superBlock, 4);
$this->totalBlocks = ($this->lastIndexPtr - $this->firstIndexPtr) / INDEX_BLOCK_LENGTH + 1;
}
//binary search to define the data
$l = 0;
$h = $this->totalBlocks;
$dataPtr = 0;
while ($l <= $h) {
$m = (($l + $h) >> 1);
$p = $m * INDEX_BLOCK_LENGTH;
fseek($this->dbFileHandler, $this->firstIndexPtr + $p);
$buffer = fread($this->dbFileHandler, INDEX_BLOCK_LENGTH);
$sip = self::getLong($buffer, 0);
if ($ip < $sip) {
$h = $m - 1;
} else {
$eip = self::getLong($buffer, 4);
if ($ip > $eip) {
$l = $m + 1;
} else {
$dataPtr = self::getLong($buffer, 8);
break;
}
}
}
//not matched just stop it here
if ($dataPtr == 0)
return NULL;
//get the data
$dataLen = (($dataPtr >> 24) & 0xFF);
$dataPtr = ($dataPtr & 0x00FFFFFF);
fseek($this->dbFileHandler, $dataPtr);
$data = fread($this->dbFileHandler, $dataLen);
return array(
'city_id' => self::getLong($data, 0),
'region' => substr($data, 4)
);
}
/**
* get the data block associated with the specifield ip with b-tree search algorithm
* @Note: not thread safe
*
* @param ip
* @return Mixed Array for NULL for any error
*/
public function btreeSearch($ip) {
if (is_string($ip))
$ip = self::safeIp2long($ip);
//check and load the header
if ($this->HeaderSip == NULL) {
//check and open the original db file
if ($this->dbFileHandler == NULL) {
$this->dbFileHandler = fopen($this->dbFile, 'r');
if ($this->dbFileHandler == false) {
throw new Exception("Fail to open the db file {$this->dbFile}");
}
}
fseek($this->dbFileHandler, 8);
$buffer = fread($this->dbFileHandler, TOTAL_HEADER_LENGTH);
//fill the header
$idx = 0;
$this->HeaderSip = array();
$this->HeaderPtr = array();
for ($i = 0; $i < TOTAL_HEADER_LENGTH; $i += 8) {
$startIp = self::getLong($buffer, $i);
$dataPtr = self::getLong($buffer, $i + 4);
if ($dataPtr == 0)
break;
$this->HeaderSip[] = $startIp;
$this->HeaderPtr[] = $dataPtr;
$idx++;
}
$this->headerLen = $idx;
}
//1. define the index block with the binary search
$l = 0;
$h = $this->headerLen;
$sptr = 0;
$eptr = 0;
while ($l <= $h) {
$m = (($l + $h) >> 1);
//perfetc matched, just return it
if ($ip == $this->HeaderSip[$m]) {
if ($m > 0) {
$sptr = $this->HeaderPtr[$m - 1];
$eptr = $this->HeaderPtr[$m];
} else {
$sptr = $this->HeaderPtr[$m];
$eptr = $this->HeaderPtr[$m + 1];
}
break;
}
//less then the middle value
if ($ip < $this->HeaderSip[$m]) {
if ($m == 0) {
$sptr = $this->HeaderPtr[$m];
$eptr = $this->HeaderPtr[$m + 1];
break;
} else if ($ip > $this->HeaderSip[$m - 1]) {
$sptr = $this->HeaderPtr[$m - 1];
$eptr = $this->HeaderPtr[$m];
break;
}
$h = $m - 1;
} else {
if ($m == $this->headerLen - 1) {
$sptr = $this->HeaderPtr[$m - 1];
$eptr = $this->HeaderPtr[$m];
break;
} else if ($ip <= $this->HeaderSip[$m + 1]) {
$sptr = $this->HeaderPtr[$m];
$eptr = $this->HeaderPtr[$m + 1];
break;
}
$l = $m + 1;
}
}
//match nothing just stop it
if ($sptr == 0)
return NULL;
//2. search the index blocks to define the data
$blockLen = $eptr - $sptr;
fseek($this->dbFileHandler, $sptr);
$index = fread($this->dbFileHandler, $blockLen + INDEX_BLOCK_LENGTH);
$dataptr = 0;
$l = 0;
$h = $blockLen / INDEX_BLOCK_LENGTH;
while ($l <= $h) {
$m = (($l + $h) >> 1);
$p = (int) ($m * INDEX_BLOCK_LENGTH);
$sip = self::getLong($index, $p);
if ($ip < $sip) {
$h = $m - 1;
} else {
$eip = self::getLong($index, $p + 4);
if ($ip > $eip) {
$l = $m + 1;
} else {
$dataptr = self::getLong($index, $p + 8);
break;
}
}
}
//not matched
if ($dataptr == 0) {
return NULL;
}
//3. get the data
$dataLen = (($dataptr >> 24) & 0xFF);
$dataPtr = ($dataptr & 0x00FFFFFF);
fseek($this->dbFileHandler, $dataPtr);
$data = fread($this->dbFileHandler, $dataLen);
return array(
'city_id' => self::getLong($data, 0),
'region' => substr($data, 4)
);
}
/**
* safe self::safeIp2long function
*
* @param ip
* */
public static function safeIp2long($ip) {
$ip = ip2long($ip);
// convert signed int to unsigned int if on 32 bit operating system
if ($ip < 0 && PHP_INT_SIZE == 4) {
$ip = sprintf("%u", $ip);
}
return $ip;
}
/**
* read a long from a byte buffer
*
* @param b
* @param offset
*/
public static function getLong($b, $offset) {
$val = (
(ord($b[$offset++])) |
(ord($b[$offset++]) << 8) |
(ord($b[$offset++]) << 16) |
(ord($b[$offset]) << 24)
);
// convert signed int to unsigned int if on 32 bit operating system
if ($val < 0 && PHP_INT_SIZE == 4) {
$val = sprintf("%u", $val);
}
return $val;
}
/**
* destruct method, resource destroy
*/
public function __destruct() {
if ($this->dbFileHandler != NULL) {
fclose($this->dbFileHandler);
}
$this->dbBinStr = NULL;
$this->HeaderSip = NULL;
$this->HeaderPtr = NULL;
}
}

90
extend/library/News.php
View File

@ -1,90 +0,0 @@
<?php
// +----------------------------------------------------------------------
// | Think.Admin
// +----------------------------------------------------------------------
// | 版权所有 2016~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/Think.Admin
// +----------------------------------------------------------------------
namespace library;
use think\Db;
use think\Log;
/**
* 微信图文处理器
*
* @author Anyon <zoujingli@qq.com>
* @date 2016/03/15 17:28
*/
class News {
/**
* 通过图文ID读取图文信息
* @param int $id 本地图文ID
* @param array $where 额外的查询条件
* @return array
*/
static public function get($id, $where = []) {
$data = Db::table('wechat_news')->where('id', $id)->where($where)->find();
$article_ids = explode(',', $data['article_id']);
$articles = Db::table('wechat_news_article')->where('id', 'in', $article_ids)->select();
$data['articles'] = array();
foreach ($article_ids as $article_id) {
foreach ($articles as $article) {
if (intval($article['id']) === intval($article_id)) {
unset($article['create_by'], $article['create_at']);
$data['articles'][] = $article;
}
}
}
unset($articles);
return $data;
}
/**
* 上传图片永久素材
* @param string $appid 公众号APPID
* @param string $local_url 文件URL地址
* @param string $type 文件类型
* @param bool $is_video 是否为视频文件
* @param array $video_info 视频信息
* @return string|null
*/
static public function uploadMedia($appid, $local_url = '', $type = 'image', $is_video = false, $video_info = array()) {
# 检测文件上否已经上传过了
$md5 = md5($local_url);
$wechat = &load_wechat('media', $appid);
$map = ['md5' => $md5, 'appid' => $wechat->appid];
if (($result = Db::table('wechat_news_media')->where($map)->find()) && !empty($result)) {
return $result['media_id'];
}
# 下载临时文件到本地
$filename = ROOT_PATH . 'public/static/upload/wechat/' . join('/', str_split($md5, 16)) . '.' . pathinfo($local_url, PATHINFO_EXTENSION);
if (!file_exists($filename) || !is_file($filename)) {
!is_dir(dirname($filename)) && mkdir(dirname($filename), 0755, TRUE);
file_put_contents($filename, file_get_contents($local_url));
}
# 上传图片素材
$result = $wechat->uploadForeverMedia(array('media' => "@{$filename}"), $type, $is_video, $video_info);
unlink($filename);
if (FALSE !== $result) {
$data = ['appid' => $wechat->appid, 'md5' => $md5, 'type' => $type];
$data['media_id'] = $result['media_id'];
isset($result['url']) && $data['media_url'] = $result['url'];
$data['local_url'] = $local_url;
if (false !== Db::table('wechat_news_media')->insert($data)) {
return $data['media_id'];
}
}
Log::error("素材上传失败，请稍后再试！{$wechat->errMsg}[{$wechat->errCode}]");
return NULL;
}
}

3251
extend/library/QRcode.php
View File

File diff suppressed because it is too large Load Diff

91
extend/library/Sms.php
View File

@ -1,91 +0,0 @@
<?php
// +----------------------------------------------------------------------
// | Think.Admin
// +----------------------------------------------------------------------
// | 版权所有 2016~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/Think.Admin
// +----------------------------------------------------------------------
namespace library;
use think\Db;
use think\Log;
/**
* 助通短信接口（旧版API）
*
* @package library
* @author Anyon <zoujingli@qq.com>
* @date 2016/11/15 10:01
*/
class Sms {
/**
* 接口URI地址
* @var string
*/
protected $uri = 'http://www.ztsms.cn:8800/sendSms.do';
/**
* 短信内容
* @var string
*/
protected $content;
/**
* 发送短信
* @param string $mobile
* @return bool
*/
public function send($mobile) {
$data = $this->createPack($mobile, $this->content);
$result = Http::get($this->uri, $data);
$data['status'] = $result;
$data['create_by'] = get_user_id();
Db::table('system_sms_history')->insert($data);
list($status, $msg) = explode(',', "{$result},-1");
if ($status === '1') {
return TRUE;
}
Log::error("给[{$mobile}]短信发送失败，{$msg}");
return FALSE;
}
/**
* 内容模板数据解析
* @param string $tpl 短信模板内容
* @param array $data 短信模板值
* @return $this
*/
public function render($tpl, $data) {
$content = !sysconf($tpl) ? $tpl : sysconf($tpl);
foreach ($data as $key => $value) {
$content = str_replace("{{$key}}", $value, $content);
}
$this->content = $content;
return $this;
}
/**
* 创建短信接口数据
* @param string $mobile
* @param string $content
* @return array
*/
protected function createPack($mobile, $content) {
$data = array();
$data['username'] = sysconf('sms_username');
$data['password'] = md5(sysconf('sms_password'));
$data['mobile'] = $mobile;
$data['content'] = $content;
$data['productid'] = sysconf('sms_product');
return $data;
}
}

BIN
extend/library/resource/ip2region.db
View File

Binary file not shown.

33
extend/library/Data.php → extend/service/DataService.php
View File

@ -7,23 +7,24 @@
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// | 开源协议 ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/Think.Admin
// +----------------------------------------------------------------------
namespace library;
namespace service;
use think\Db;
use think\db\Query;
/**
* 数据工具库类
*
* 基础数据服务
* Class DataService
* @package service
* @author Anyon <zoujingli@qq.com>
* @date 2016/10/21 19:04
* @date 2017/03/22 15:32
*/
class Data {
class DataService {
/**
* 删除指定序号
@ -31,7 +32,7 @@ class Data {
* @param string $type
* @return bool
*/
static public function deleteSequence($sequence, $type = 'SYSTEM') {
public static function deleteSequence($sequence, $type = 'SYSTEM') {
$data = ['sequence' => $sequence, 'type' => strtoupper($type)];
return Db::name('SystemSequence')->where($data)->delete();
}
@ -42,7 +43,7 @@ class Data {
* @param string $type 序号顾类型
* @return string
*/
static public function createSequence($length = 10, $type = 'SYSTEM') {
public static function createSequence($length = 10, $type = 'SYSTEM') {
$times = 0;
while ($times++ < 10) {
$sequence = '';
@ -60,13 +61,13 @@ class Data {
/**
* 数据增量保存
* @param Query|string $db 数据查询对象
* @param \think\db\Query|string $db 数据查询对象
* @param array $data 需要保存或更新的数据
* @param string $upkey 条件主键限制
* @param array $where 其它的where条件
* @return bool
*/
static public function save($db, $data, $upkey = 'id', $where = []) {
public static function save($db, $data, $upkey = 'id', $where = []) {
if (is_string($db)) {
$db = Db::name($db);
}
@ -83,13 +84,13 @@ class Data {
/**
* 应用 where 条件
* @param Query $db 数据查询对象
* @param \think\db\Query|string $db 数据查询对象
* @param array $data 需要保存或更新的数据
* @param string $upkey 条件主键限制
* @param array $where 其它的where条件
* @return Query
* @return \think\db\Query
*/
static protected function _apply_save_where(&$db, $data, $upkey, $where) {
protected static function _apply_save_where(&$db, $data, $upkey, $where) {
foreach (is_string($upkey) ? explode(',', $upkey) : $upkey as $v) {
if (is_string($v) && array_key_exists($v, $data)) {
$db->where($v, $data[$v]);
@ -102,11 +103,11 @@ class Data {
/**
* 更新数据表内容
* @param Query|string $db
* @param \think\db\Query|string $db 数据查询对象
* @param array $where 额外查询条件
* @return bool|null
*/
static public function update(&$db, $where = []) {
public static function update(&$db, $where = []) {
if (is_string($db)) {
$db = Db::name($db);
}

217
extend/service/ExpressService.php
View File

@ -1,109 +1,108 @@
<?php
// +----------------------------------------------------------------------
// | Think.Admin
// +----------------------------------------------------------------------
// | 版权所有 2016~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/Think.Admin
// +----------------------------------------------------------------------
namespace service;
use library\Http;
/**
* 快递查询接口
*
* @author Anyon <zoujingli@qq.com>
* @date 2016/11/28 17:13
*/
class ExpressService {
const APPID = '1232779';
const APPKEY = 'ac45f461-8c1a-4518-87b1-bb8e835a2f9d';
const APIURI = 'http://api.kdniao.com/Ebusiness/EbusinessOrderHandle.aspx';
/**
* @brief 获取物流轨迹线路
* @param $ShipperCode string 物流公司代号
* @param $LogisticCode string 物流单号
* @return string array 轨迹数据
*/
public static function line($ShipperCode, $LogisticCode) {
$sendData = json_encode(array('ShipperCode' => $ShipperCode, 'LogisticCode' => $LogisticCode), JSON_UNESCAPED_UNICODE);
$data = array(
'RequestData' => $sendData,
'EBusinessID' => self::APPID,
'RequestType' => '1002',
'DataType' => 2,
'DataSign' => base64_encode(md5($sendData . self::APPKEY)),
);
$result = Http::post(self::APIURI, $data);
$resultJson = json_decode($result, true);
if (!$resultJson) {
die(var_export($result));
}
return self::response($resultJson);
}
/**
* 处理返回数据统一数据格式
* @param $result 结果处理
* @return array 通用的结果集 array('result' => 'success或者fail','data' => array( array('time' => '时间','info' => '地点'),......),'reason' => '失败原因')
*/
public static function response($result) {
$status = "fail";
$data = array();
$message = "此单号无跟踪记录";
if (isset($result['Message'])) {
$message = $result['Message'];
} else if (isset($result['Reason'])) {
$message = $result['Reason'];
}
if (isset($result['Traces']) && $result['Traces']) {
foreach ($result['Traces'] as $key => $val) {
$data[$key]['time'] = $val['AcceptTime'];
$data[$key]['info'] = $val['AcceptStation'];
}
$status = "success";
$message = '此订单号有' . count($data) . '条跟踪记录';
}
return array('result' => $status, 'data' => $data, 'message' => $message);
}
/**
* CURL模拟提交数据
* @param $url string 提交的url
* @param $data array 要发送的数据
* @return mixed 返回的数据
*/
private static function curl_post($url, $data) {
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, self::_encode_data($data));
return curl_exec($ch);
}
/**
* 进行数据的string字符串编码
* @param type $datas
* @return type
*/
private static function _encode_data($datas) {
$temps = array();
foreach ($datas as $key => $value) {
$temps[] = sprintf('%s=%s', $key, $value);
}
return join('&', $temps);
}
}
<?php
// +----------------------------------------------------------------------
// | Think.Admin
// +----------------------------------------------------------------------
// | 版权所有 2016~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/Think.Admin
// +----------------------------------------------------------------------
namespace service;
/**
* 物流查询服务
* Class ExpressService
* @package service
* @author Anyon <zoujingli@qq.com>
* @date 2017/03/15 15:17
*/
class ExpressService {
const APPID = '1232779';
const APPKEY = 'ac45f461-8c1a-4518-87b1-bb8e835a2f9d';
const APIURI = 'http://api.kdniao.com/Ebusiness/EbusinessOrderHandle.aspx';
/**
* @brief 获取物流轨迹线路
* @param $ShipperCode string 物流公司代号
* @param $LogisticCode string 物流单号
* @return string array 轨迹数据
*/
public static function line($ShipperCode, $LogisticCode) {
$sendData = json_encode(array('ShipperCode' => $ShipperCode, 'LogisticCode' => $LogisticCode), JSON_UNESCAPED_UNICODE);
$data = array(
'RequestData' => $sendData,
'EBusinessID' => self::APPID,
'RequestType' => '1002',
'DataType' => 2,
'DataSign' => base64_encode(md5($sendData . self::APPKEY)),
);
$result = HttpService::post(self::APIURI, $data);
$resultJson = json_decode($result, true);
if (!$resultJson) {
die(var_export($result));
}
return self::response($resultJson);
}
/**
* 处理返回数据统一数据格式
* @param $result 结果处理
* @return array 通用的结果集 array('result' => 'success或者fail','data' => array( array('time' => '时间','info' => '地点'),......),'reason' => '失败原因')
*/
public static function response($result) {
$status = "fail";
$data = array();
$message = "此单号无跟踪记录";
if (isset($result['Message'])) {
$message = $result['Message'];
} else if (isset($result['Reason'])) {
$message = $result['Reason'];
}
if (isset($result['Traces']) && $result['Traces']) {
foreach ($result['Traces'] as $key => $val) {
$data[$key]['time'] = $val['AcceptTime'];
$data[$key]['info'] = $val['AcceptStation'];
}
$status = "success";
$message = '此订单号有' . count($data) . '条跟踪记录';
}
return array('result' => $status, 'data' => $data, 'message' => $message);
}
/**
* CURL模拟提交数据
* @param $url string 提交的url
* @param $data array 要发送的数据
* @return mixed 返回的数据
*/
private static function curl_post($url, $data) {
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, self::_encode_data($data));
return curl_exec($ch);
}
/**
* 进行数据的string字符串编码
* @param type $datas
* @return type
*/
private static function _encode_data($datas) {
$temps = array();
foreach ($datas as $key => $value) {
$temps[] = sprintf('%s=%s', $key, $value);
}
return join('&', $temps);
}
}

187
extend/service/FansService.php
View File

@ -1,187 +0,0 @@
<?php
// +----------------------------------------------------------------------
// | Think.Admin
// +----------------------------------------------------------------------
// | 版权所有 2016~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/Think.Admin
// +----------------------------------------------------------------------
namespace service;
use library\Data;
use think\Cache;
use think\Db;
use think\Log;
/**
* 微信粉丝数据服务
*
* @author Anyon <zoujingli@qq.com>
* @date 2016/10/24 17:01
*/
class FansService {
/**
* 从微信服务器获取所有标签
* @param $appid
* @return bool
*/
static public function syncTags($appid) {
$wechat = &load_wechat("User", $appid);
if (($result = $wechat->getTags()) !== FALSE) {
$tags = $result['tags'];
foreach ($tags as &$tag) {
$tag['appid'] = $appid;
}
Db::table('wechat_fans_tags')->where('appid', $appid)->delete();
foreach (array_chunk($tags, 100) as $list) {
Db::table('wechat_fans_tags')->insertAll($list);
}
return true;
}
return true;
}
/**
* 同步粉丝的标签
* @param string $appid
* @param string $openid
* @return bool
*/
static public function syncFansTags($appid, $openid) {
$wechat = &load_wechat('User', $appid);
$tagsid = $wechat->getUserTags($openid);
if ($tagsid === false || !is_array($tagsid)) {
return false;
}
return Data::save('wechat_fans', ['appid' => $appid, 'openid' => $openid, 'tagid_list' => join(',', $tagsid)], 'openid', ['appid' => $appid]);
}
/**
* 保存/更新粉丝信息
* @param array $userInfo
* @param string $appid
* @return bool
*/
static public function set($userInfo, $appid = '') {
if (!empty($userInfo['subscribe_time'])) {
$userInfo['subscribe_at'] = date('Y-m-d H:i:s', $userInfo['subscribe_time']);
}
if (!empty($userInfo['tagid_list']) && is_array($userInfo['tagid_list'])) {
$userInfo['tagid_list'] = join(',', $userInfo['tagid_list']);
}
$userInfo['appid'] = $appid;
return Data::save('wechat_fans', $userInfo, 'openid');
}
/**
* 读取粉丝信息
* @param string $openid
* @return array|false
*/
static public function get($openid) {
return Db::table('wechat_fans')->where('openid', $openid)->find();
}
/**
* 同步获取粉丝列表
* @param string $appid
* @param string $next_openid
* @return bool
*/
static public function sync($appid, $next_openid = '') {
$wechat = &load_wechat('User', $appid);
$result = $wechat->getUserList($next_openid);
if ($result === FALSE || empty($result['data']['openid'])) {
Log::record("获取粉丝列表失败，{$wechat->errMsg} [{$wechat->errCode}]", Log::ERROR);
return FALSE;
}
foreach ($result['data']['openid'] as $openid) {
if (FALSE === ($userInfo = $wechat->getUserInfo($openid))) {
Log::record("获取用户[{$openid}]信息失败，$wechat->errMsg", Log::ERROR);
return FALSE;
}
if (FALSE === self::set($userInfo, $wechat->appid)) {
Log::record('更新粉丝信息更新失败！', Log::ERROR);
return FALSE;
}
if ($result['next_openid'] === $openid) {
unset($result['next_openid']);
}
}
return !empty($result['next_openid']) ? self::sync($appid, $result['next_openid']) : TRUE;
}
/**
* 同步获取黑名单信息
* @param string $appid
* @param string $next_openid
* @return bool
*/
static public function syncBlacklist($appid, $next_openid = '') {
$wechat = &load_wechat('User');
$result = $wechat->getBacklist($next_openid);
if ($result === FALSE || (empty($result['data']['openid']))) {
if (empty($result['total'])) {
return TRUE;
}
Log::record("获取粉丝黑名单列表失败，{$wechat->errMsg} [{$wechat->errCode}]", Log::ERROR);
return FALSE;
}
foreach ($result['data']['openid'] as $openid) {
if (FALSE === ($userInfo = $wechat->getUserInfo($openid))) {
Log::record("获取用户[{$openid}]信息失败，$wechat->errMsg", Log::ERROR);
return FALSE;
}
$userInfo['is_back'] = '1';
if (FALSE === self::set($userInfo)) {
Log::record('更新粉丝信息更新失败！', Log::ERROR);
return FALSE;
}
if ($result['next_openid'] === $openid) {
unset($result['next_openid']);
}
}
return !empty($result['next_openid']) ? self::sync_blacklist($appid, $result['next_openid']) : TRUE;
}
/**
* 读取七天的统计数据
* @param string $appid
* @param int $day
* @return array
*/
static public function getTotal($appid, $day = 7) {
$result = Cache::get(($cachekey = "wechat_token_{$appid}"));
if (!empty($result)) {
return $result;
}
$extends = &load_wechat('Extends', $appid);
// 统计总数
$data['cumulate'] = (array) $extends->getDatacube('user', 'cumulate', date('Y-m-d', strtotime("-{$day} day")), date('Y-m-d', strtotime('-1 day')));
// 统计增量数
$data['summary'] = (array) $extends->getDatacube('user', 'summary', date('Y-m-d', strtotime("-{$day} day")), date('Y-m-d', strtotime('-1 day')));
// 统计消息数
$data['upstreammsg'] = (array) $extends->getDatacube('upstreammsg', 'summary', date('Y-m-d', strtotime("-{$day} day")), date('Y-m-d', strtotime('-1 day')));
$temp = array();
for ($i = 1; $i <= $day; $i++) {
$temp[date('Y-m-d', strtotime("-{$i} day"))] = [];
}
foreach ($data as $vo) {
foreach ($vo as $v) {
isset($v['ref_date']) && ($temp[$v['ref_date']] = array_merge($temp[$v['ref_date']], $v));
}
}
ksort($temp);
Cache::set($cachekey, $temp, 600);
return $temp;
}
}

4
extend/service/FileService.php
View File

@ -155,9 +155,10 @@ class FileService {
!is_dir(dirname($filepath)) && mkdir(dirname($filepath), '0755', true);
if (file_put_contents($filepath, $bodycontent)) {
return [
'file' => $filepath,
'hash' => md5_file($filepath),
'key' => "upload/{$filename}",
'url' => pathinfo(request()->baseFile(true), PATHINFO_DIRNAME) . '/upload/' . $filename
'url' => pathinfo(request()->baseFile(true), PATHINFO_DIRNAME) . '/upload/' . $filename,
];
}
} catch (Exception $err) {
@ -181,6 +182,7 @@ class FileService {
Log::error('七牛云文件上传失败, ' . var_export($err, true));
return null;
}
$result['file'] = $filename;
$result['url'] = self::getBaseUriQiniu() . $filename;
return $result;
}

273
extend/library/Http.php → extend/service/HttpService.php
View File

@ -1,136 +1,137 @@
<?php
// +----------------------------------------------------------------------
// | Think.Admin
// +----------------------------------------------------------------------
// | 版权所有 2016~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/Think.Admin
// +----------------------------------------------------------------------
namespace library;
use CURLFile;
/**
* HTTP模拟请求
*
* @package library
* @author Anyon <zoujingli@qq.com>
* @date 2016/11/15 09:53
*/
class Http {
/**
* HTTP GET 请求
* @param string $url 请求的URL地址
* @param array $data GET参数
* @param int $second 设置超时时间（默认30秒）
* @param array $header 请求Header信息
* @return bool|string
*/
static public function get($url, $data = array(), $second = 30, $header = []) {
if (!empty($data)) {
$url .= (stripos($url, '?') === FALSE ? '?' : '&');
$url .= (is_array($data) ? http_build_query($data) : $data);
}
$curl = curl_init();
curl_setopt($curl, CURLOPT_TIMEOUT, $second);
curl_setopt($curl, CURLOPT_URL, $url);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
if (!empty($header)) {
curl_setopt($curl, CURLOPT_HTTPHEADER, $header);
}
self::_set_ssl($curl, $url);
$content = curl_exec($curl);
$status = curl_getinfo($curl);
curl_close($curl);
if (intval($status["http_code"]) == 200) {
return $content;
} else {
return false;
}
}
/**
* 设置SSL参数
* @param $curl
* @param string $url
*/
static private function _set_ssl(&$curl, $url) {
if (stripos($url, "https") === 0) {
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE);
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE);
curl_setopt($curl, CURLOPT_SSLVERSION, 1);
}
}
/**
* POST 请求（支持文件上传）
* @param string $url HTTP请求URL地址
* @param array|string $data POST提交的数据
* @param int $second 请求超时时间
* @param array $header 请求Header信息
* @return bool|string
*/
static public function post($url, $data = [], $second = 30, $header = []) {
self::_set_upload($data);
$curl = curl_init();
curl_setopt($curl, CURLOPT_TIMEOUT, $second);
curl_setopt($curl, CURLOPT_URL, $url);
curl_setopt($curl, CURLOPT_HEADER, FALSE);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, TRUE);
curl_setopt($curl, CURLOPT_POST, TRUE);
curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
if (!empty($header)) {
curl_setopt($curl, CURLOPT_HTTPHEADER, $header);
}
self::_set_ssl($curl, $url);
$content = curl_exec($curl);
$status = curl_getinfo($curl);
curl_close($curl);
if (intval($status["http_code"]) == 200) {
return $content;
} else {
return false;
}
}
/**
* 设置POST文件上传兼容
* @param array $data
* @return string
*/
static private function _set_upload(&$data) {
if (is_array($data)) {
foreach ($data as &$value) {
if (!is_string($value) || stripos($value, '@') !== 0) {
continue;
}
$filename = realpath(trim($value, '@'));
$filemime = self::_get_file_mimes($filename);
$value = class_exists('CURLFile', FALSE) ? new CURLFile($filename, $filemime) : "{$value};type={$filemime}";
}
}
}
/**
* 文件上传MIMS设置
* @param $file
* @return string
*/
static private function _get_file_mimes($file) {
$mimes = require(__DIR__ . DS . 'resource' . DS . 'mines.php');
$ext = strtolower(pathinfo($file, PATHINFO_EXTENSION));
if (isset($mimes[$ext])) {
return is_array($mimes[$ext]) ? $mimes[$ext][0] : $mimes[$ext];
} else {
return 'application/octet-stream';
}
}
}
<?php
// +----------------------------------------------------------------------
// | Think.Admin
// +----------------------------------------------------------------------
// | 版权所有 2016~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/Think.Admin
// +----------------------------------------------------------------------
namespace service;
use think\Config;
/**
* HTTP请求服务
* Class HttpService
* @package service
* @author Anyon <zoujingli@qq.com>
* @date 2017/03/22 15:32
*/
class HttpService {
/**
* HTTP GET 请求
* @param string $url 请求的URL地址
* @param array $data GET参数
* @param int $second 设置超时时间（默认30秒）
* @param array $header 请求Header信息
* @return bool|string
*/
public static function get($url, $data = array(), $second = 30, $header = []) {
if (!empty($data)) {
$url .= (stripos($url, '?') === FALSE ? '?' : '&');
$url .= (is_array($data) ? http_build_query($data) : $data);
}
$curl = curl_init();
curl_setopt($curl, CURLOPT_TIMEOUT, $second);
curl_setopt($curl, CURLOPT_URL, $url);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
if (!empty($header)) {
curl_setopt($curl, CURLOPT_HTTPHEADER, $header);
}
self::_setSsl($curl, $url);
$content = curl_exec($curl);
$status = curl_getinfo($curl);
curl_close($curl);
if (intval($status["http_code"]) == 200) {
return $content;
} else {
return false;
}
}
/**
* POST 请求（支持文件上传）
* @param string $url HTTP请求URL地址
* @param array|string $data POST提交的数据
* @param int $second 请求超时时间
* @param array $header 请求Header信息
* @return bool|string
*/
static public function post($url, $data = [], $second = 30, $header = []) {
self::_setUploadFile($data);
$curl = curl_init();
curl_setopt($curl, CURLOPT_TIMEOUT, $second);
curl_setopt($curl, CURLOPT_URL, $url);
curl_setopt($curl, CURLOPT_HEADER, FALSE);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, TRUE);
curl_setopt($curl, CURLOPT_POST, TRUE);
curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
if (!empty($header)) {
curl_setopt($curl, CURLOPT_HTTPHEADER, $header);
}
self::_setSsl($curl, $url);
$content = curl_exec($curl);
$status = curl_getinfo($curl);
curl_close($curl);
if (intval($status["http_code"]) == 200) {
return $content;
} else {
return false;
}
}
/**
* 设置SSL参数
* @param $curl
* @param string $url
*/
private static function _setSsl(&$curl, $url) {
if (stripos($url, "https") === 0) {
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE);
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE);
curl_setopt($curl, CURLOPT_SSLVERSION, 1);
}
}
/**
* 设置POST文件上传兼容
* @param array $data
* @return string
*/
private static function _setUploadFile(&$data) {
if (is_array($data)) {
foreach ($data as &$value) {
if (!is_string($value) || stripos($value, '@') !== 0) {
continue;
}
$filename = realpath(trim($value, '@'));
$filemime = self::_getFileMine($filename);
$value = class_exists('CURLFile', FALSE) ? new CURLFile($filename, $filemime) : "{$value};type={$filemime}";
}
}
}
/**
* 文件上传MIMS设置
* @param $filename
* @return string
*/
private static function _getFileMine($filename) {
$mimes = Config::get('mines');
$ext = strtolower(pathinfo($filename, PATHINFO_EXTENSION));
if (isset($mimes[$ext])) {
return is_array($mimes[$ext]) ? $mimes[$ext][0] : $mimes[$ext];
} else {
return 'application/octet-stream';
}
}
}

114
extend/service/PayService.php
View File

@ -14,8 +14,7 @@
namespace service;
use library\Data;
use library\QRcode;
use Endroid\QrCode\QrCode;
use think\Db;
use think\Log;
use Wechat\WechatPay;
@ -46,21 +45,64 @@ class PayService {
* @param string $from 订单来源
* @return bool
*/
static public function createQrc($pay, $order_no, $fee, $title, $from = 'wechat') {
$prepayid = self::_createPrepayid($pay, null, $order_no, $fee, $title, 'NATIVE', $from);
public static function createWechatPayQrc($pay, $order_no, $fee, $title, $from = 'wechat') {
$prepayid = self::_createWechatPrepayid($pay, null, $order_no, $fee, $title, 'NATIVE', $from);
if ($prepayid === false) {
return false;
}
$filename = join('/', str_split(md5($prepayid), 16)) . '.png';
$filename = 'wechat/payqrc/' . join('/', str_split(md5($prepayid), 16)) . '.png';
if (!FileService::hasFile($filename)) {
FileService::save($filename, QRcode::png($prepayid, $filename, Constants::QR_ECLEVEL_L, 8));
$qrCode = new QrCode();
$qrCode->setText($prepayid);
FileService::save($filename, $qrCode->get());
}
$filename = ROOT_PATH . "public/upload/{$pay->appid}/payqrc/" . join('/', str_split(md5($prepayid), 16)) . '.png';
!is_dir(dirname($filename)) && mkdir(dirname($filename), 0755, true);
!file_exists($filename) && QRcode::png($prepayid, $filename, Constants::QR_ECLEVEL_L, 8);
ob_clean();
header("Content-type: image/png");
exit(readfile($filename));
FileService::readFile($filename);
}
/**
* 创建微信JSAPI支付签名包
* @param WechatPay $pay 支付SDK
* @param string $openid 微信用户openid
* @param string $order_no 系统订单号
* @param int $fee 支付金额
* @param string $title 订单标题
* @return bool|array
*/
public static function createWechatPayJsPicker($pay, $openid, $order_no, $fee, $title) {
if (($prepayid = self::_createWechatPrepayid($pay, $openid, $order_no, $fee, $title, 'JSAPI')) === false) {
return false;
}
return $pay->createMchPay($prepayid);
}
/**
* 微信退款操作
* @param WechatPay $pay 支付SDK
* @param string $order_no 系统订单号
* @param int $fee 退款金额
* @param string|null $refund_no 退款订单号
* @return bool
*/
public static function putWechatRefund($pay, $order_no, $fee = 0, $refund_no = NULL, $refund_account = '') {
$map = array('order_no' => $order_no, 'is_pay' => '1', 'appid' => $pay->appid);
$notify = Db::name('WechatPayPrepayid')->where($map)->find();
if (empty($notify)) {
Log::error("内部订单号{$order_no}验证退款失败");
return false;
}
if (false !== $pay->refund($notify['out_trade_no'], $notify['transaction_id'], is_null($refund_no) ? "T{$order_no}" : $refund_no, $notify['fee'], empty($fee) ? $notify['fee'] : $fee, '', $refund_account)) {
$data = ['out_trade_no' => $notify['out_trade_no'], 'is_refund' => "1", 'refund_at' => date('Y-m-d H:i:s'), 'expires_in' => time() + 7000];
if (DataService::save('wechat_pay_prepayid', $data, 'out_trade_no')) {
return true;
}
Log::error("内部订单号{$order_no}退款成功，系统更新异常");
return false;
}
Log::error("内部订单号{$order_no}退款失败，{$pay->errMsg}");
return false;
}
/**
@ -74,11 +116,12 @@ class PayService {
* @param string $from 订单来源
* @return bool|string
*/
static protected function _createPrepayid($pay, $openid, $order_no, $fee, $title, $trade_type = 'JSAPI', $from = 'shop') {
protected static function _createWechatPrepayid($pay, $openid, $order_no, $fee, $title, $trade_type = 'JSAPI', $from = 'shop') {
$map = ['order_no' => $order_no, 'is_pay' => '1', 'expires_in' => time(), 'appid' => $pay->appid];
$prepayinfo = Db::table('wechat_pay_prepayid')->where('appid=:appid and order_no=:order_no and (is_pay=:is_pay or expires_in>:expires_in)', $map)->find();
$where = 'appid=:appid and order_no=:order_no and (is_pay=:is_pay or expires_in>:expires_in)';
$prepayinfo = Db::name('WechatPayPrepayid')->where($where, $map)->find();
if (empty($prepayinfo) || empty($prepayinfo['prepayid'])) {
$out_trade_no = Data::createSequence(18, 'WXPAY-OUTER-NO');
$out_trade_no = DataService::createSequence(18, 'WXPAY-OUTER-NO');
$prepayid = $pay->getPrepayId($openid, $title, $out_trade_no, $fee, url("@store/api/notify", '', true, true), $trade_type);
if (empty($prepayid)) {
Log::error("内部订单号{$order_no}生成预支付失败，{$pay->errMsg}");
@ -94,7 +137,7 @@ class PayService {
'expires_in' => time() + 5400, // 微信预支付码有效时间1.5小时（最长为2小时）
'from' => $from // 订单来源
];
if (Db::table('wechat_pay_prepayid')->insert($data) > 0) {
if (Db::name('WechatPayPrepayid')->insert($data) > 0) {
Log::notice("内部订单号{$order_no}生成预支付成功,{$prepayid}");
return $prepayid;
}
@ -102,47 +145,4 @@ class PayService {
return $prepayinfo['prepayid'];
}
/**
* 创建微信JSAPI支付签名包
* @param WechatPay $pay 支付SDK
* @param string $openid 微信用户openid
* @param string $order_no 系统订单号
* @param int $fee 支付金额
* @param string $title 订单标题
* @return bool|array
*/
static public function createJs($pay, $openid, $order_no, $fee, $title) {
if (($prepayid = self::_createPrepayid($pay, $openid, $order_no, $fee, $title, 'JSAPI')) === false) {
return false;
}
return $pay->createMchPay($prepayid);
}
/**
* 微信退款操作
* @param WechatPay $pay 支付SDK
* @param string $order_no 系统订单号
* @param int $fee 退款金额
* @param string|null $refund_no 退款订单号
* @return bool
*/
static public function refund($pay, $order_no, $fee = 0, $refund_no = NULL, $refund_account = '') {
$map = array('order_no' => $order_no, 'is_pay' => '1', 'appid' => $pay->appid);
$notify = Db::name('WechatPayPrepayid')->where($map)->find();
if (empty($notify)) {
Log::error("内部订单号{$order_no}验证退款失败");
return false;
}
if (false !== $pay->refund($notify['out_trade_no'], $notify['transaction_id'], is_null($refund_no) ? "T{$order_no}" : $refund_no, $notify['fee'], empty($fee) ? $notify['fee'] : $fee, '', $refund_account)) {
$data = ['out_trade_no' => $notify['out_trade_no'], 'is_refund' => "1", 'refund_at' => date('Y-m-d H:i:s'), 'expires_in' => time() + 7000];
if (Data::save('wechat_pay_prepayid', $data, 'out_trade_no')) {
return true;
}
Log::error("内部订单号{$order_no}退款成功，系统更新异常");
return false;
}
Log::error("内部订单号{$order_no}退款失败，{$pay->errMsg}");
return false;
}
}

226
extend/library/Tools.php → extend/service/ToolsService.php
View File

@ -1,114 +1,112 @@
<?php
// +----------------------------------------------------------------------
// | Think.Admin
// +----------------------------------------------------------------------
// | 版权所有 2016~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/Think.Admin
// +----------------------------------------------------------------------
namespace library;
/**
* 通用工具化辅助类
*
* @version 1.0
* @author Anyon <zoujingli@qq.com>
* @date 2016/10/20 16:21
*/
class Tools {
/**
* Cors Options 授权处理
*/
static public function corsOptionsHandler() {
if (request()->isOptions()) {
header('Access-Control-Allow-Origin:*');
header('Access-Control-Allow-Headers:Accept,Referer,Host,Keep-Alive,User-Agent,X-Requested-With,Cache-Control,Content-Type,token');
header('Access-Control-Allow-Credentials:true');
header('Access-Control-Allow-Methods:GET,POST,OPTIONS');
header('Access-Control-Max-Age:1728000');
header('Content-Type:text/plain charset=UTF-8');
header('Content-Length: 0', true);
header('status: 204');
header('HTTP/1.0 204 No Content');
exit;
}
}
/**
* 一维数据数组生成数据树
* @param array $list 数据列表
* @param string $id 父ID Key
* @param string $pid ID Key
* @param string $son 定义子数据Key
* @return array
*/
static public function arr2tree($list, $id = 'id', $pid = 'pid', $son = 'sub') {
$tree = $map = array();
foreach ($list as $item) {
$map[$item[$id]] = $item;
}
foreach ($list as $item) {
if (isset($item[$pid]) && isset($map[$item[$pid]])) {
$map[$item[$pid]][$son][] = &$map[$item[$id]];
} else {
$tree[] = &$map[$item[$id]];
}
}
unset($map);
return $tree;
}
/**
* 一维数据数组生成数据树
* @param array $list 数据列表
* @param string $id ID Key
* @param string $pid 父ID Key
* @param string $path
* @return array
*/
static public function arr2table($list, $id = 'id', $pid = 'pid', $path = 'path', $ppath = '') {
$_array_tree = self::arr2tree($list, $id, $pid);
$tree = array();
foreach ($_array_tree as $_tree) {
$_tree[$path] = $ppath . '-' . $_tree[$id];
$_tree['spl'] = str_repeat("&nbsp;&nbsp;&nbsp;├&nbsp;&nbsp;", substr_count($ppath, '-'));
if (!isset($_tree['sub'])) {
$_tree['sub'] = array();
}
$sub = $_tree['sub'];
unset($_tree['sub']);
$tree[] = $_tree;
if (!empty($sub)) {
$sub_array = self::arr2table($sub, $id, $pid, $path, $_tree[$path]);
$tree = array_merge($tree, (Array) $sub_array);
}
}
return $tree;
}
/**
* 获取数据树子ID
* @param array $list 数据列表
* @param int $id 起始ID
* @param string $key 子Key
* @param string $pkey 父Key
* @return array
*/
static public function getArrSubIds($list, $id = 0, $key = 'id', $pkey = 'pid') {
$ids = array(intval($id));
foreach ($list as $vo) {
if (intval($vo[$pkey]) > 0 && intval($vo[$pkey]) == intval($id)) {
$ids = array_merge($ids, self::getArrSubIds($list, intval($vo[$key]), $key, $pkey));
}
}
return $ids;
}
}
<?php
// +----------------------------------------------------------------------
// | Think.Admin
// +----------------------------------------------------------------------
// | 版权所有 2016~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/Think.Admin
// +----------------------------------------------------------------------
namespace service;
/**
* 系统工具服务
*
* @author Anyon <zoujingli@qq.com>
* @date 2016/10/25 14:49
*/
class ToolsService {
/**
* Cors Options 授权处理
*/
public static function corsOptionsHandler() {
if (request()->isOptions()) {
header('Access-Control-Allow-Origin:*');
header('Access-Control-Allow-Headers:Accept,Referer,Host,Keep-Alive,User-Agent,X-Requested-With,Cache-Control,Content-Type,token');
header('Access-Control-Allow-Credentials:true');
header('Access-Control-Allow-Methods:GET,POST,OPTIONS');
header('Access-Control-Max-Age:1728000');
header('Content-Type:text/plain charset=UTF-8');
header('Content-Length: 0', true);
header('status: 204');
header('HTTP/1.0 204 No Content');
exit;
}
}
/**
* 一维数据数组生成数据树
* @param array $list 数据列表
* @param string $id 父ID Key
* @param string $pid ID Key
* @param string $son 定义子数据Key
* @return array
*/
public static function arr2tree($list, $id = 'id', $pid = 'pid', $son = 'sub') {
$tree = $map = array();
foreach ($list as $item) {
$map[$item[$id]] = $item;
}
foreach ($list as $item) {
if (isset($item[$pid]) && isset($map[$item[$pid]])) {
$map[$item[$pid]][$son][] = &$map[$item[$id]];
} else {
$tree[] = &$map[$item[$id]];
}
}
unset($map);
return $tree;
}
/**
* 一维数据数组生成数据树
* @param array $list 数据列表
* @param string $id ID Key
* @param string $pid 父ID Key
* @param string $path
* @return array
*/
public static function arr2table($list, $id = 'id', $pid = 'pid', $path = 'path', $ppath = '') {
$_array_tree = self::arr2tree($list, $id, $pid);
$tree = array();
foreach ($_array_tree as $_tree) {
$_tree[$path] = $ppath . '-' . $_tree[$id];
$_tree['spl'] = str_repeat("&nbsp;&nbsp;&nbsp;├&nbsp;&nbsp;", substr_count($ppath, '-'));
if (!isset($_tree['sub'])) {
$_tree['sub'] = array();
}
$sub = $_tree['sub'];
unset($_tree['sub']);
$tree[] = $_tree;
if (!empty($sub)) {
$sub_array = self::arr2table($sub, $id, $pid, $path, $_tree[$path]);
$tree = array_merge($tree, (Array)$sub_array);
}
}
return $tree;
}
/**
* 获取数据树子ID
* @param array $list 数据列表
* @param int $id 起始ID
* @param string $key 子Key
* @param string $pkey 父Key
* @return array
*/
public static function getArrSubIds($list, $id = 0, $key = 'id', $pkey = 'pid') {
$ids = array(intval($id));
foreach ($list as $vo) {
if (intval($vo[$pkey]) > 0 && intval($vo[$pkey]) == intval($id)) {
$ids = array_merge($ids, self::getArrSubIds($list, intval($vo[$key]), $key, $pkey));
}
}
return $ids;
}
}

212
extend/service/WechatService.php Normal file
View File

@ -0,0 +1,212 @@
<?php
// +----------------------------------------------------------------------
// | Think.Admin
// +----------------------------------------------------------------------
// | 版权所有 2016~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/Think.Admin
// +----------------------------------------------------------------------
namespace service;
use think\Db;
use think\Log;
/**
* 微信数据服务
* Class WechatService
* @package service
* @author Anyon <zoujingli@qq.com>
* @date 2017/03/22 15:32
*/
class WechatService {
/**
* 通过图文ID读取图文信息
* @param int $id 本地图文ID
* @param array $where 额外的查询条件
* @return array
*/
public static function getNewsById($id, $where = []) {
$data = Db::name('WechatNews')->where('id', $id)->where($where)->find();
$article_ids = explode(',', $data['article_id']);
$articles = Db::name('WechatNewsArticle')->where('id', 'in', $article_ids)->select();
$data['articles'] = array();
foreach ($article_ids as $article_id) {
foreach ($articles as $article) {
if (intval($article['id']) === intval($article_id)) {
unset($article['create_by'], $article['create_at']);
$data['articles'][] = $article;
}
}
}
unset($articles);
return $data;
}
/**
* 上传图片永久素材
* @param string $local_url 文件URL地址
* @param string $type 文件类型
* @param bool $is_video 是否为视频文件
* @param array $video_info 视频信息
* @return string|null
*/
public static function uploadForeverMedia($local_url = '', $type = 'image', $is_video = false, $video_info = array()) {
# 检测文件上否已经上传过了
$wechat = &load_wechat('media');
$map = ['md5' => ($md5 = md5($local_url)), 'appid' => $wechat->appid];
# 检查文件URL是否已经上传为永久素材
if (($result = Db::name('WechatNewsMedia')->where($map)->find()) && !empty($result)) {
return $result['media_id'];
}
# 下载临时文件到本地
$filename = 'wechat/' . join('/', str_split($md5, 16)) . '.' . pathinfo($local_url, PATHINFO_EXTENSION);
$upload = FileService::local($filename, file_get_contents($local_url));
if (!empty($upload) && isset($upload['file']) && file_exists($upload['file'])) {
# 上传图片素材
$result = $wechat->uploadForeverMedia(array('media' => "@{$upload['file']}"), $type, $is_video, $video_info);
# 删除本地文件
@unlink($filename);
if (false !== $result) {
$data = ['md5' => $md5, 'type' => $type, 'appid' => $wechat->appid, 'media_id' => $result['media_id'], 'local_url' => $local_url,];
isset($result['url']) && $data['media_url'] = $result['url'];
if (false !== Db::name('WechatNewsMedia')->insert($data)) {
return $data['media_id'];
}
}
}
Log::error("素材上传失败，请稍后再试！{$wechat->errMsg}[{$wechat->errCode}]");
return NULL;
}
/**
* 从微信服务器获取所有标签
* @return bool
*/
public static function syncFansTags() {
$wechat = &load_wechat("User");
if (($result = $wechat->getTags()) !== false) {
$tags = $result['tags'];
foreach ($tags as &$tag) {
$tag['appid'] = $wechat->appid;
}
Db::name('WechatFansTags')->where('appid', $wechat->appid)->delete();
foreach (array_chunk($tags, 100) as $list) {
Db::name('WechatFansTags')->insertAll($list);
}
}
return true;
}
/**
* 同步粉丝的标签
* @param string $openid
* @return bool
*/
public static function syncFansTagsByOpenid($openid) {
$wechat = &load_wechat('User');
$tagsid = $wechat->getUserTags($openid);
if ($tagsid === false || !is_array($tagsid)) {
return false;
}
$data = ['appid' => $wechat->appid, 'openid' => $openid, 'tagid_list' => join(',', $tagsid)];
return DataService::save('wechat_fans', $data, 'openid', ['appid' => $wechat->appid]);
}
/**
* 保存/更新粉丝信息
* @param array $userInfo
* @param string $appid
* @return bool
*/
public static function setFansInfo($userInfo, $appid = '') {
if (!empty($userInfo['subscribe_time'])) {
$userInfo['subscribe_at'] = date('Y-m-d H:i:s', $userInfo['subscribe_time']);
}
if (!empty($userInfo['tagid_list']) && is_array($userInfo['tagid_list'])) {
$userInfo['tagid_list'] = join(',', $userInfo['tagid_list']);
}
$userInfo['appid'] = $appid;
return DataService::save('WechatFans', $userInfo, 'openid');
}
/**
* 读取粉丝信息
* @param string $openid
* @return array|false
*/
public static function getFansInfo($openid) {
return Db::name('WechatFans')->where('openid', $openid)->find();
}
/**
* 同步获取粉丝列表
* @param string $next_openid
* @return bool
*/
public static function syncAllFans($next_openid = '') {
$wechat = &load_wechat('User');
$result = $wechat->getUserList($next_openid);
if ($result === false || empty($result['data']['openid'])) {
Log::error("获取粉丝列表失败，{$wechat->errMsg} [{$wechat->errCode}]");
return false;
}
foreach (array_chunk($result['data']['openid'], 100) as $openids) {
if (false === ($info = $wechat->getUserBatchInfo($openids)) || !isset($info['user_info_list'])) {
Log::error("获取用户信息失败，$wechat->errMsg");
return false;
}
foreach ($info['user_info_list'] as $userInfo) {
if (false === self::setFansInfo($userInfo, $wechat->appid)) {
Log::error('更新粉丝信息更新失败！');
return false;
}
if ($result['next_openid'] === $userInfo['openid']) {
unset($result['next_openid']);
}
}
}
return !empty($result['next_openid']) ? self::syncAllFans($result['next_openid']) : true;
}
/**
* 同步获取黑名单信息
* @param string $next_openid
* @return bool
*/
public static function syncBlackFans($next_openid = '') {
$wechat = &load_wechat('User');
$result = $wechat->getBacklist($next_openid);
if ($result === false || (empty($result['data']['openid']))) {
if (empty($result['total'])) {
return true;
}
Log::error("获取粉丝黑名单列表失败，{$wechat->errMsg} [{$wechat->errCode}]");
return false;
}
foreach ($result['data']['openid'] as $openid) {
if (false === ($userInfo = $wechat->getUserInfo($openid))) {
Log::error("获取用户[{$openid}]信息失败，$wechat->errMsg");
return false;
}
$userInfo['is_back'] = '1';
if (false === self::setFansInfo($userInfo)) {
Log::error('更新粉丝信息更新失败！');
return false;
}
if ($result['next_openid'] === $openid) {
unset($result['next_openid']);
}
}
return !empty($result['next_openid']) ? self::syncBlackFans($result['next_openid']) : true;
}
}