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:
邹景立 2021-09-13 16:56:16 +08:00
parent c880049fb9
commit 1e43ec64fa
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

@ -102,11 +102,13 @@ class Fans extends Command
*/ */
public function _black(string $next = '', int $done = 0): string public function _black(string $next = '', int $done = 0): string
{ {
$wechat = WechatService::WeChatUser();
$this->setQueueProgress("开始更新黑名单的微信用户"); $this->setQueueProgress("开始更新黑名单的微信用户");
[$map, $data, $wechat] = [['is_black' => 0], ['is_black' => 1], WechatService::WeChatUser()];
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'])) {
foreach (array_chunk($result['data']['openid'], 100) as $chunk) { foreach (array_chunk($result['data']['openid'], 100) as $chunk) {
$this->app->db->name('WechatFans')->where($map)->whereIn('openid', $chunk)->update($data); $done += count($chunk);
$map = [['is_black', '=', 0], ['openid', 'in', $chunk]];
$this->app->db->name('WechatFans')->where($map)->update(['is_black' => 1]);
} }
$next = $result['total'] > $done ? $result['next_openid'] : null; $next = $result['total'] > $done ? $result['next_openid'] : null;
} }