_query($this->table)->layTable(function () { $this->title = '微信用户管理'; }, function (QueryHelper $query) { $query->where(['appid' => WechatService::instance()->getAppid()]); $query->like('nickname')->equal('subscribe,is_black')->dateBetween('subscribe_at'); }); } /** * 列表数据处理 * @param array $data */ protected function _index_page_filter(array &$data) { foreach ($data as &$vo) $vo['subscribe_at'] = format_datetime($vo['subscribe_at']); } /** * 同步用户数据 * @auth true */ public function sync() { sysoplog('微信授权配置', '创建粉丝用户同步任务'); $this->_queue('同步微信用户数据', "xadmin:fansall"); } /** * 黑名单列表操作 * @auth true */ public function black() { $data = $this->_vali([ 'openid.require' => '操作用户不能为空！', 'black.require' => '操作类型不能为空！', ]); try { foreach (array_chunk(explode(',', $data['openid']), 20) as $openids) { if ($data['black']) { WechatService::WeChatUser()->batchBlackList($openids); $this->app->db->name('WechatFans')->whereIn('openid', $openids)->update(['is_black' => 1]); } else { WechatService::WeChatUser()->batchUnblackList($openids); $this->app->db->name('WechatFans')->whereIn('openid', $openids)->update(['is_black' => 0]); } } if (empty($data['black'])) { $this->success('移出黑名单成功！'); } else { $this->success('拉入黑名单成功！'); } } catch (HttpResponseException $exception) { throw $exception; } catch (\Exception $exception) { $this->error("黑名单操作失败，请稍候再试！
{$exception->getMessage()}"); } } /** * 删除用户信息 * @auth true * @throws \think\db\exception\DbException */ public function remove() { $this->_delete($this->table); } /** * 清空用户数据 * @auth true */ public function truncate() { try { $this->_query('WechatFans')->empty(); $this->_query('WechatFansTags')->empty(); $this->success('清空用户数据成功！'); } catch (HttpResponseException $exception) { throw $exception; } catch (\Exception $exception) { $this->error("清空用户数据失败，{$exception->getMessage()}"); } } }