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

[更新]移除无效类库

Browse Source
This commit is contained in:
Anyon 2018-03-15 20:53:20 +08:00
parent 257a5671e9
commit dfaafae076
3 changed files with 0 additions and 293 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

123
application/admin/service/FansService.php
View File

@ -1,123 +0,0 @@
<?php
// +----------------------------------------------------------------------
// | ThinkAdmin
// +----------------------------------------------------------------------
// | 版权所有 2014~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/ThinkAdmin
// +----------------------------------------------------------------------
namespace app\wechat\service;
use service\DataService;
use service\ToolsService;
use service\WechatService;
use think\Db;
/**
* 微信粉丝数据服务
* Class FansService
* @package app\wechat
*/
class FansService
{
/**
* 增加或更新粉丝信息
* @param array $user
* @return bool
* @throws \think\Exception
* @throws \think\exception\PDOException
*/
public static function set(array $user)
{
$user['appid'] = sysconf('wechat_appid');
if (!empty($user['subscribe_time'])) {
$user['subscribe_at'] = date('Y-m-d H:i:s', $user['subscribe_time']);
}
if (isset($user['tagid_list']) && is_array($user['tagid_list'])) {
$user['tagid_list'] = join(',', $user['tagid_list']);
}
foreach (['country', 'province', 'city', 'nickname', 'remark'] as $field) {
isset($user[$field]) && $user[$field] = ToolsService::emojiEncode($user[$field]);
}
unset($user['privilege'], $user['groupid']);
return DataService::save('WechatFans', $user, 'openid');
}
/**
* 获取粉丝信息
* @param string $openid
* @return array
* @throws \think\Exception
* @throws \think\exception\PDOException
*/
public static function get($openid)
{
$map = ['openid' => $openid, 'appid' => sysconf('wechat_appid')];
$user = Db::name('WechatFans')->where($map)->find();
foreach (['country', 'province', 'city', 'nickname', 'remark'] as $k) {
isset($user[$k]) && $user[$k] = ToolsService::emojiDecode($user[$k]);
}
return $user;
}
/**
* 同步所有粉丝记录
* @param string $next_openid
* @return bool
* @throws \WeChat\Exceptions\InvalidResponseException
* @throws \WeChat\Exceptions\LocalCacheException
* @throws \think\Exception
* @throws \think\exception\PDOException
*/
public static function sync($next_openid = '')
{
$wechat = WechatService::user();
$result = $wechat->getUserList($next_openid);
if (empty($result['data']['openid'])) {
return false;
}
foreach (array_chunk($result['data']['openid'], 100) as $openids) {
foreach ($wechat->getBatchUserInfo($openids)['user_info_list'] as $user) {
if (false === self::set($user)) {
return false;
}
if ($result['next_openid'] === $user['openid']) {
unset($result['next_openid']);
}
}
}
return empty($result['next_openid']) ? true : self::sync($result['next_openid']);
}
/**
* 同步获取黑名单信息
* @param string $next_openid
* @return bool
* @throws \WeChat\Exceptions\InvalidResponseException
* @throws \WeChat\Exceptions\LocalCacheException
* @throws \think\Exception
* @throws \think\exception\PDOException
*/
public static function syncBlack($next_openid = '')
{
$wechat = WechatService::user();
$result = $wechat->getBlackList($next_openid);
foreach (array_chunk($result['data']['openid'], 100) as $openids) {
$info = $wechat->getBatchUserInfo($openids);
foreach ($info as $user) {
$user['is_black'] = '1';
if (self::set($user) && $result['next_openid'] === $user['openid']) {
unset($result['next_openid']);
}
}
}
return empty($result['next_openid']) ? true : self::syncBlack($result['next_openid']);
}
}

101
application/admin/service/MediaService.php
View File

@ -1,101 +0,0 @@
<?php
// +----------------------------------------------------------------------
// | ThinkAdmin
// +----------------------------------------------------------------------
// | 版权所有 2014~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/ThinkAdmin
// +----------------------------------------------------------------------
namespace app\wechat\service;
use service\WechatService;
use think\Db;
/**
* 微信媒体文件管理
* Class MediaService
* @package app\wechat\service
*/
class MediaService
{
/**
* 通过图文ID读取图文信息
* @param int $id 本地图文ID
* @param array $where 额外的查询条件
* @return array
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
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')->whereIn('id', $article_ids)->select();
$data['articles'] = [];
foreach ($article_ids as $article_id) {
foreach ($articles as $article) {
if (intval($article['id']) === intval($article_id)) {
unset($article['create_by'], $article['create_at']);
$article['content'] = htmlspecialchars_decode($article['content']);
$data['articles'][] = $article;
}
}
}
return $data;
}
/**
* 上传图片到微信服务器
* @param string $local_url 图文地址
* @return string
* @throws \WeChat\Exceptions\InvalidResponseException
* @throws \WeChat\Exceptions\LocalCacheException
*/
public static function uploadImage($local_url)
{
$media_url = Db::name('WechatNewsImage')->where(['md5' => md5($local_url)])->value('media_url');
if (!empty($media_url)) {
return $media_url;
}
$result = WechatService::wechat()->upFile(base64_encode(file_get_contents($local_url)), $local_url);
$info = WechatService::media()->uploadImg($result['file']);
WechatService::wechat()->rmFile($local_url);
$data = ['local_url' => $local_url, 'media_url' => $info['url'], 'md5' => md5($local_url)];
Db::name('WechatNewsImage')->insert($data);
return $info['url'];
}
/**
* 上传图片永久素材，返回素材media_id
* @param string $local_url 文件URL地址
* @param string $type 文件类型
* @param array $video_info 视频信息
* @return string|null
* @throws \WeChat\Exceptions\InvalidResponseException
* @throws \WeChat\Exceptions\LocalCacheException
* @throws \think\Exception
* @throws \think\exception\PDOException
*/
public static function uploadForeverMedia($local_url, $type = 'image', $video_info = [])
{
$map = ['md5' => md5($local_url), 'appid' => sysconf('wechat_appid')];
if (($media_id = Db::name('WechatNewsMedia')->where($map)->value('media_id'))) {
return $media_id;
}
$result = WechatService::wechat()->upFile(base64_encode(file_get_contents($local_url)), $local_url);
$result = WechatService::media()->addMaterial($result['file'], $type, $video_info);
WechatService::wechat()->rmFile($local_url);
$data = ['md5' => $map['md5'], 'type' => $type, 'appid' => $map['appid'], 'media_id' => $result['media_id'], 'local_url' => $local_url];
isset($result['url']) && $data['media_url'] = $result['url'];
Db::name('WechatNewsMedia')->insert($data);
return $data['media_id'];
}
}

69
application/admin/service/TagsService.php
View File

@ -1,69 +0,0 @@
<?php
// +----------------------------------------------------------------------
// | ThinkAdmin
// +----------------------------------------------------------------------
// | 版权所有 2014~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://think.ctolog.com
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/ThinkAdmin
// +----------------------------------------------------------------------
namespace app\wechat\service;
use service\DataService;
use service\WechatService;
use think\Db;
/**
* 粉丝标签服务
* Class TagsService
* @package app\wechat\service
*/
class TagsService
{
/**
* 同步粉丝的标签
* @param string $openid
* @return bool
* @throws \WeChat\Exceptions\InvalidResponseException
* @throws \WeChat\Exceptions\LocalCacheException
* @throws \think\Exception
* @throws \think\exception\PDOException
*/
public static function syncTagsByOpenid($openid)
{
$tagsid = WechatService::tags()->getUserTagId($openid);
if (!is_array($tagsid)) {
return false;
}
$data = ['openid' => $openid, 'tagid_list' => join(',', $tagsid)];
return DataService::save('WechatFans', $data, 'openid', ['appid' => sysconf('wechat_appid')]);
}
/**
* 从微信服务器获取所有标签
* @return bool
* @throws \WeChat\Exceptions\InvalidResponseException
* @throws \WeChat\Exceptions\LocalCacheException
* @throws \think\Exception
* @throws \think\exception\PDOException
*/
public static function sync()
{
$appid = sysconf('wechat_appid');
$result = WechatService::tags()->getTags();
Db::name('WechatFansTags')->where(['appid' => $appid])->delete();
foreach (array_chunk($result['tags'], 100) as $list) {
foreach ($list as &$vo) {
$vo['appid'] = $appid;
}
Db::name('WechatFansTags')->insertAll($list);
}
return true;
}
}