cunkebao_v3/Server/application/superadmin/controller/traffic/GetPoolSummaryController.php

<?php

namespace app\superadmin\controller\traffic;

use app\common\service\TrafficPoolSystemIdentifierService;
use app\superadmin\controller\BaseController;
use app\superadmin\service\CompanyClassificationService;
use library\ResponseHelper;
use think\Db;

/**
 * 客户池摘要（REQ-SA-80/81）
 * - 全平台只返回摘要，不返回明细列表
 * - 供前端默认引导「先选项目/Top5」使用
 */
class GetPoolSummaryController extends BaseController
{
    public function index()
    {
        $companyId = (int) $this->request->param('companyId/d', 0);
        $pageSize = min(100, max(1, (int) $this->request->param('limit/d', 50)));

        if ($companyId > 0) {
            $base = Db::name('traffic_pool_company')->alias('tpc')
                ->where('tpc.companyId', $companyId)
                ->where('tpc.isDel', 0);
            TrafficPoolSystemIdentifierService::applyExcludeToCompanyQuery($base, 'tpc');
            $total = (int) (clone $base)->count('tpc.id');
            $bound = (int) (clone $base)->where('tpc.ownerWechatId', '<>', '')->whereNotNull('tpc.ownerWechatId')->count('tpc.id');
            $unbound = max(0, $total - $bound);
            return ResponseHelper::success([
                'scope' => 'company',
                'companyId' => $companyId,
                'totalCustomers' => $total,
                'boundCustomers' => $bound,
                'unboundCustomers' => $unbound,
                'pageSize' => $pageSize,
                'totalPages' => $pageSize > 0 ? (int) ceil($total / $pageSize) : 0,
            ]);
        }

        $base = Db::name('traffic_pool_company')->alias('tpc')
            ->where('tpc.isDel', 0);
        TrafficPoolSystemIdentifierService::applyExcludeToCompanyQuery($base, 'tpc');
        $totalCustomers = (int) (clone $base)->count('tpc.id');
        $boundCustomers = (int) (clone $base)->where('tpc.ownerWechatId', '<>', '')->whereNotNull('tpc.ownerWechatId')->count('tpc.id');
        $unboundCustomers = max(0, $totalCustomers - $boundCustomers);

        $rows = (clone $base)
            ->field('tpc.companyId, COUNT(tpc.id) as customerCount')
            ->group('tpc.companyId')
            ->order('customerCount', 'desc')
            ->limit(50)
            ->select();
        $rows = $rows ? (is_array($rows) ? $rows : $rows->toArray()) : [];
        $companyIds = array_values(array_unique(array_map(function ($r) {
            return (int) $r['companyId'];
        }, $rows)));
        $nameMap = [];
        if (!empty($companyIds)) {
            $nameMap = Db::name('company')->whereIn('companyId', $companyIds)->where('deleteTime', 0)->column('name', 'companyId');
        }

        $classifier = new CompanyClassificationService();
        $metaMap = $classifier->buildMetaMap($companyIds);
        $normalRows = [];
        foreach ($rows as $r) {
            $cid = (int) $r['companyId'];
            $meta = $metaMap[$cid] ?? [];
            if ($classifier->matchesTag($meta, CompanyClassificationService::TAG_NORMAL)) {
                $normalRows[] = [
                    'companyId' => $cid,
                    'companyName' => (string) ($nameMap[$cid] ?? ('项目#' . $cid)),
                    'customerCount' => (int) $r['customerCount'],
                ];
            }
        }

        return ResponseHelper::success([
            'scope' => 'global',
            'totalCustomers' => $totalCustomers,
            'boundCustomers' => $boundCustomers,
            'unboundCustomers' => $unboundCustomers,
            'topNormalProjects' => array_slice($normalRows, 0, 5),
            'pageSize' => $pageSize,
            'totalPages' => $pageSize > 0 ? (int) ceil($totalCustomers / $pageSize) : 0,
        ]);
    }
}