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 2019-08-27 11:45:56 +08:00
parent 1c55630ab5
commit b46aa9809b
2 changed files with 36 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
application/wechat/command/Fans.php
View File

@ -1,15 +1,16 @@
<?php <?php
// +---------------------------------------------------------------------- // +----------------------------------------------------------------------
// | framework // | ThinkAdmin
// +---------------------------------------------------------------------- // +----------------------------------------------------------------------
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ] // | 版权所有 2014~2019 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +---------------------------------------------------------------------- // +----------------------------------------------------------------------
// | 官方网站: http://framework.thinkadmin.top // | 官方网站: http://demo.thinkadmin.top
// +---------------------------------------------------------------------- // +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org ) // | 开源协议 ( https://mit-license.org )
// +---------------------------------------------------------------------- // +----------------------------------------------------------------------
// | github开源项目：https://github.com/zoujingli/framework // | gitee 代码仓库：https://gitee.com/zoujingli/ThinkAdmin
// | github 代码仓库：https://github.com/zoujingli/ThinkAdmin
// +---------------------------------------------------------------------- // +----------------------------------------------------------------------
namespace app\wechat\command; namespace app\wechat\command;
@ -32,7 +33,7 @@ class Fans extends Command
* 需要处理的模块 * 需要处理的模块
* @var array * @var array
*/ */
protected $module = ['list', 'black', 'tags']; protected $module = ['list', 'tags', 'black'];
/** /**
* 执行指令 * 执行指令
@ -53,29 +54,28 @@ class Fans extends Command
/** /**
* 同步微信粉丝列表 * 同步微信粉丝列表
* @param string $next * @param string $next
* @param integer $index * @param integer $done
* @throws \WeChat\Exceptions\InvalidResponseException * @throws \WeChat\Exceptions\InvalidResponseException
* @throws \WeChat\Exceptions\LocalCacheException * @throws \WeChat\Exceptions\LocalCacheException
* @throws \think\Exception * @throws \think\Exception
* @throws \think\exception\PDOException * @throws \think\exception\PDOException
*/ */
protected function _list($next = '', $index = 0) protected function _list($next = '', $done = 0)
{ {
$appid = WechatService::getAppid(); $appid = WechatService::getAppid();
$wechat = WechatService::WeChatUser(); $wechat = WechatService::WeChatUser();
$this->output->comment('preparing synchronize fans list ...'); $this->output->comment('preparing synchronize fans list ...');
while (true) if (is_array($result = $wechat->getUserList($next)) && !empty($result['data']['openid'])) { while ($next !== null && is_array($result = $wechat->getUserList($next)) && !empty($result['data']['openid'])) {
foreach (array_chunk($result['data']['openid'], 100) as $chunk) { foreach (array_chunk($result['data']['openid'], 100) as $chunk) {
if (is_array($list = $wechat->getBatchUserInfo($chunk)) && !empty($list['user_info_list'])) { if (is_array($list = $wechat->getBatchUserInfo($chunk)) && !empty($list['user_info_list'])) {
foreach ($list['user_info_list'] as $user) { foreach ($list['user_info_list'] as $user) {
$indexString = str_pad(++$index, strlen($result['total']), '0', STR_PAD_LEFT); $indexString = str_pad(++$done, strlen($result['total']), '0', STR_PAD_LEFT);
$this->output->writeln("({$indexString}/{$result['total']}) updating wechat user {$user['openid']} {$user['nickname']}"); $this->output->writeln("({$indexString}/{$result['total']}) updating wechat user {$user['openid']} {$user['nickname']}");
\app\wechat\service\FansService::set($user, $appid); \app\wechat\service\FansService::set($user, $appid);
} }
} }
} }
if (in_array($result['next_openid'], $result['data']['openid'])) break; $next = $result['total'] > $done ? $result['next_openid'] : null;
else $next = $result['next_openid'];
} }
$this->output->comment('synchronized fans list successful.'); $this->output->comment('synchronized fans list successful.');
} }
@ -83,27 +83,25 @@ class Fans extends Command
/** /**
* 同步粉丝黑名单列表 * 同步粉丝黑名单列表
* @param string $next * @param string $next
* @param integer $index * @param integer $done
* @throws \WeChat\Exceptions\InvalidResponseException * @throws \WeChat\Exceptions\InvalidResponseException
* @throws \WeChat\Exceptions\LocalCacheException * @throws \WeChat\Exceptions\LocalCacheException
* @throws \think\Exception * @throws \think\Exception
* @throws \think\exception\PDOException * @throws \think\exception\PDOException
*/ */
public function _black($next = '', $index = 0) public function _black($next = '', $done = 0)
{ {
$wechat = WechatService::WeChatUser(); $wechat = WechatService::WeChatUser();
$this->output->comment('prepare synchronize fans black ...'); $this->output->comment('prepare synchronize fans black ...');
while (true) if (is_array($result = $wechat->getBlackList($next)) && !empty($result['data']['openid'])) { while ($next !== null && is_array($result = $wechat->getBlackList($next)) && !empty($result['data']['openid'])) {
foreach (array_chunk($result['data']['openid'], 100) as $chunk) { foreach (array_chunk($result['data']['openid'], 100) as $chunk) {
foreach ($chunk as $openid) { foreach ($chunk as $openid) {
$indexString = str_pad(++$index, strlen($result['total']), '0', STR_PAD_LEFT); $indexString = str_pad(++$done, strlen($result['total']), '0', STR_PAD_LEFT);
$this->output->writeln("({$indexString}/{$result['total']}) updating wechat black {$openid}"); $this->output->writeln("({$indexString}/{$result['total']}) updating wechat black {$openid}");
} }
$where = [['is_black', 'eq', '0'], ['openid', 'in', $chunk]]; Db::name('WechatFans')->where(['is_black' => '0'])->whereIn('openid', $chunk)->update(['is_black' => '1']);
Db::name('WechatFans')->where($where)->update(['is_black' => '1']);
} }
if (in_array($result['next_openid'], $result['data']['openid'])) break; $next = $result['total'] > $done ? $result['next_openid'] : null;
else $next = $result['next_openid'];
} }
$this->output->comment('synchronized fans black successful.'); $this->output->comment('synchronized fans black successful.');
} }

33
application/wechat/queue/WechatQueue.php
View File

@ -39,24 +39,27 @@ class WechatQueue extends JobsQueue
try { try {
$appid = WechatService::getAppid(); $appid = WechatService::getAppid();
$wechat = WechatService::WeChatUser(); $wechat = WechatService::WeChatUser();
$next = ''; // 获取远程粉丝 // 获取远程粉丝
list($next, $done) = ['', 0];
$this->output->writeln('Start synchronizing fans from the Wechat server'); $this->output->writeln('Start synchronizing fans from the Wechat server');
while (is_array($result = $wechat->getUserList($next)) && !empty($result['data']['openid'])) { while ($next !== null && is_array($result = $wechat->getUserList($next)) && !empty($result['data']['openid'])) {
foreach (array_chunk($result['data']['openid'], 100) as $chunk) $done += $result['count'];
if (is_array($list = $wechat->getBatchUserInfo($chunk)) && !empty($list['user_info_list']))
foreach ($list['user_info_list'] as $user) FansService::set($user, $appid);
if (in_array($result['next_openid'], $result['data']['openid'])) break;
$next = $result['next_openid'];
}
$next = ''; // 同步粉丝黑名单
$this->output->writeln('Start synchronizing black from the Wechat server');
while (is_array($result = $wechat->getBlackList($next)) && !empty($result['data']['openid'])) {
foreach (array_chunk($result['data']['openid'], 100) as $chunk) { foreach (array_chunk($result['data']['openid'], 100) as $chunk) {
$where = [['is_black', 'eq', '0'], ['openid', 'in', $chunk]]; if (is_array($list = $wechat->getBatchUserInfo($chunk)) && !empty($list['user_info_list'])) {
Db::name('WechatFans')->where($where)->update(['is_black' => '1']); foreach ($list['user_info_list'] as $user) FansService::set($user, $appid);
} }
if (in_array($result['next_openid'], $result['data']['openid'])) break; }
$next = $result['next_openid']; $next = $result['total'] > $done ? $result['next_openid'] : null;
}
// 同步粉丝黑名单
list($next, $done) = ['', 0];
$this->output->writeln('Start synchronizing black from the Wechat server');
while ($next !== null && is_array($result = $wechat->getBlackList($next)) && !empty($result['data']['openid'])) {
$done += $result['count'];
foreach (array_chunk($result['data']['openid'], 100) as $chunk) {
Db::name('WechatFans')->where(['is_black' => '0'])->whereIn('openid', $chunk)->update(['is_black' => '1']);
}
$next = $result['total'] > $done ? $result['next_openid'] : null;
} }
// 同步粉丝标签列表 // 同步粉丝标签列表
$this->output->writeln('Start synchronizing tags from the Wechat server'); $this->output->writeln('Start synchronizing tags from the Wechat server');