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

<?php

namespace app\superadmin\controller\traffic;

use app\common\service\TrafficPoolSystemIdentifierService;
use app\common\service\WechatIdentityService;
use think\Controller;
use think\Db;
use think\facade\Request;

/**
 * 客户详情（V2 traffic_pool_company）
 */
class GetPoolDetailController extends Controller
{
    protected function columnExistsRaw(string $table, string $column): bool
    {
        try {
            $rows = Db::query("SHOW COLUMNS FROM `{$table}` LIKE '{$column}'");
            return !empty($rows);
        } catch (\Throwable $e) {
            return false;
        }
    }

    protected function formatGender($gender): string
    {
        switch ((int) $gender) {
            case 1:
                return '男';
            case 2:
                return '女';
            default:
                return '保密';
        }
    }

    protected function formatRfmType($type): string
    {
        $map = [
            1 => '重要价值',
            2 => '重要发展',
            3 => '重要保持',
            4 => '重要挽留',
            5 => '一般价值',
            6 => '一般发展',
            7 => '一般保持',
            8 => '一般挽留',
        ];
        return $map[(int) $type] ?? '未评估';
    }

    public function index()
    {
        $id = Request::param('id/d');
        if (!$id) {
            return json(['code' => 400, 'msg' => '参数错误']);
        }

        try {
            $row = Db::name('traffic_pool_company')->alias('tpc')
                ->join('traffic_pool tp', 'tp.id = tpc.poolId')
                ->leftJoin('company c', 'c.companyId = tpc.companyId')
                ->where('tpc.id', $id)
                ->where('tpc.isDel', 0)
                ->field([
                    'tpc.id', 'tpc.createTime', 'tpc.identifier', 'tpc.ownerWechatId',
                    'tpc.rfmScore', 'tpc.rfmType', 'tpc.totalOrderAmount', 'tpc.totalOrderCount',
                    'tpc.phone', 'tpc.realName',
                    'tp.nickname', 'tp.avatar', 'tp.region', 'tp.gender', 'tp.wechatId',
                    'c.name as projectName',
                ])
                ->find();

            if (!$row) {
                return json(['code' => 404, 'msg' => '记录不存在']);
            }

            $identifier = (string) ($row['identifier'] ?? '');
            $wechatId = (string) ($row['wechatId'] ?? '');
            if (TrafficPoolSystemIdentifierService::isExcluded($identifier)
                || TrafficPoolSystemIdentifierService::isExcluded($wechatId)) {
                return json(['code' => 404, 'msg' => '记录不存在']);
            }

            $source = Db::name('traffic_pool_source')
                ->where('poolCompanyId', $id)
                ->order('id', 'desc')
                ->value('sourceName');
            $sourceQuery = Db::name('traffic_pool_source')
                ->where('poolCompanyId', $id)
                ->field('id,sourceName,createTime');
            $journeySlicedByOwner = false;
            if (!empty($row['ownerWechatId']) && $this->columnExistsRaw('ck_traffic_pool_source', 'ownerWechatId')) {
                $sourceQuery->where('ownerWechatId', $row['ownerWechatId']);
                $journeySlicedByOwner = true;
            }
            $sourceRows = $sourceQuery
                ->order('id', 'desc')
                ->limit(20)
                ->select();
            $sourceRows = $sourceRows ? (is_array($sourceRows) ? $sourceRows : $sourceRows->toArray()) : [];

            $tags = Db::name('traffic_pool_tag')
                ->where('poolCompanyId', $id)
                ->where('isDel', 0)
                ->column('tagName');

            $ownerDisplay = $row['ownerWechatId'] ?: '';
            if ($ownerDisplay !== '') {
                $wa = (new WechatIdentityService())->identityMap([$row['ownerWechatId']]);
                $wa = $wa[$row['ownerWechatId']] ?? [];
                if ($wa) {
                    $ownerDisplay = $wa['nickname'] ?: ($wa['alias'] ?: $row['ownerWechatId']);
                }
            }
            $ownerWechat = [];
            if (!empty($row['ownerWechatId'])) {
                $identity = (new WechatIdentityService())->identityMap([$row['ownerWechatId']]);
                $ownerWechat = $identity[$row['ownerWechatId']] ?? ['wechatId' => $row['ownerWechatId'], 'nickname' => '', 'alias' => '', 'avatar' => ''];
            }
            $journey = [];
            foreach ($sourceRows as $sr) {
                $journey[] = [
                    'type' => 'source',
                    'label' => (string) ($sr['sourceName'] ?? ''),
                    'time' => !empty($sr['createTime']) ? date('Y-m-d H:i:s', (int) $sr['createTime']) : '',
                ];
            }

            $rfmScore = is_array($row['rfmScore'])
                ? (float) ($row['rfmScore']['total'] ?? 0)
                : (float) ($row['rfmScore'] ?? 0);

            return json([
                'code' => 200,
                'msg'  => '获取成功',
                'data' => [
                    'source'             => $source ?: '',
                    'sources'            => array_map(function ($sr) {
                        return [
                            'sourceName' => (string) ($sr['sourceName'] ?? ''),
                            'createTime' => !empty($sr['createTime']) ? date('Y-m-d H:i:s', (int) $sr['createTime']) : '',
                        ];
                    }, $sourceRows),
                    'journey'            => $journey,
                    'journeySlicedByOwner' => $journeySlicedByOwner,
                    'addTime'            => $row['createTime'] ? date('Y-m-d H:i:s', (int) $row['createTime']) : null,
                    'projectName'        => $row['projectName'] ?: '',
                    'avatar'             => $row['avatar'] ?: '',
                    'nickname'           => $row['nickname'] ?: ($row['identifier'] ?: '未知'),
                    'region'             => $row['region'] ?: '',
                    'gender'             => $this->formatGender($row['gender'] ?? 0),
                    'tags'               => $tags ?: [],
                    'wechatId'           => $row['wechatId'] ?: $row['identifier'],
                    'ownerWechatId'      => $row['ownerWechatId'] ?: '',
                    'ownerWechatDisplay' => $ownerDisplay ?: '未绑定微信号',
                    'ownerWechat'        => $ownerWechat,
                    'rfmScore'           => round($rfmScore, 2),
                    'rfmType'            => (int) ($row['rfmType'] ?? 0),
                    'rfmTypeLabel'       => $this->formatRfmType($row['rfmType'] ?? 0),
                    'totalOrderAmount'   => round((float) ($row['totalOrderAmount'] ?? 0), 2),
                    'totalOrderCount'    => (int) ($row['totalOrderCount'] ?? 0),
                    'phone'              => $row['phone'] ?: '',
                    'realName'           => $row['realName'] ?: '',
                ],
            ]);
        } catch (\Exception $e) {
            return json(['code' => 500, 'msg' => '系统错误：' . $e->getMessage()]);
        }
    }
}