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

Update Fans.php

Browse Source
This commit is contained in:
邹景立 2021-01-18 10:29:26 +08:00
parent 3815bca3b5
commit 43aa856db3
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
app/wechat/command/Fans.php
View File

@ -47,6 +47,7 @@ class Fans extends Command
* 执行指令 * 执行指令
* @param Input $input * @param Input $input
* @param Output $output * @param Output $output
* @return void
* @throws \think\admin\Exception * @throws \think\admin\Exception
*/ */
protected function execute(Input $input, Output $output) protected function execute(Input $input, Output $output)
@ -82,7 +83,7 @@ class Fans extends Command
foreach (array_chunk($result['data']['openid'], 100) as $openids) { foreach (array_chunk($result['data']['openid'], 100) as $openids) {
$info = WechatService::WeChatUser()->getBatchUserInfo($openids); $info = WechatService::WeChatUser()->getBatchUserInfo($openids);
if (is_array($info) && !empty($info['user_info_list'])) { if (is_array($info) && !empty($info['user_info_list'])) {
foreach ($info['user_info_list'] as $user) { foreach ($info['user_info_list'] as $user) if (isset($user['nickname'])) {
$this->queue->message($result['total'], ++$done, "-> {$user['openid']} {$user['nickname']}"); $this->queue->message($result['total'], ++$done, "-> {$user['openid']} {$user['nickname']}");
FansService::instance()->set($user, $appid); FansService::instance()->set($user, $appid);
} }
@ -111,10 +112,11 @@ class Fans extends Command
{ {
$wechat = WechatService::WeChatUser(); $wechat = WechatService::WeChatUser();
$this->output->comment('开始更新黑名单的微信用户'); $this->output->comment('开始更新黑名单的微信用户');
[$map, $data] = [['is_black' => 0], ['is_black' => 1]];
while (!is_null($next) && is_array($result = $wechat->getBlackList($next)) && !empty($result['data']['openid'])) { while (!is_null($next) && is_array($result = $wechat->getBlackList($next)) && !empty($result['data']['openid'])) {
$done += $result['count']; $done += $result['count'];
foreach (array_chunk($result['data']['openid'], 100) as $chunk) { foreach (array_chunk($result['data']['openid'], 100) as $chunk) {
$this->app->db->name('WechatFans')->where(['is_black' => '0'])->whereIn('openid', $chunk)->update(['is_black' => '1']); $this->app->db->name('WechatFans')->where($map)->whereIn('openid', $chunk)->update($data);
} }
$this->setQueueProgress("--> 共计同步微信黑名单{$result['total']}人"); $this->setQueueProgress("--> 共计同步微信黑名单{$result['total']}人");
$next = $result['total'] > $done ? $result['next_openid'] : null; $next = $result['total'] > $done ? $result['next_openid'] : null;