cunkebao_v3/Server/application/command/CleanPlaceholderUsernameCommand.php

<?php

namespace app\command;

use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\console\input\Option;
use think\Db;

/**
 * 占位用户名数据清洗（REQ-CKB-65）
 *
 * 库内历史 username 为占位「我 / 用户 / undefined / 空」，展示层已过滤，
 * 本命令做数据侧统计与（可选）规范化清洗。
 *
 * 默认 dry-run（只统计不改库）：
 *   php think clean:placeholderUsername
 * 实际写入（须显式 --apply=1）：
 *   php think clean:placeholderUsername --apply=1 [--companyId=]
 */
class CleanPlaceholderUsernameCommand extends Command
{
    /** 视为占位的用户名 */
    private const PLACEHOLDERS = ['我', '用户', 'undefined', 'null', 'User', 'user'];

    protected function configure()
    {
        $this->setName('clean:placeholderUsername')
            ->setDescription('清洗 users 表占位用户名（默认 dry-run，--apply=1 才写库）')
            ->addOption('companyId', null, Option::VALUE_OPTIONAL, '公司 ID，0=全部', 0)
            ->addOption('apply', null, Option::VALUE_OPTIONAL, '1=实际写库，默认 0 仅统计', 0)
            ->addOption('limit', null, Option::VALUE_OPTIONAL, '最多处理条数，0=全量', 0);
    }

    protected function execute(Input $input, Output $output)
    {
        $companyId = max(0, (int)$input->getOption('companyId'));
        $apply = (string)$input->getOption('apply') === '1';
        $limit = max(0, (int)$input->getOption('limit'));

        $query = Db::name('users')->where(function ($q) {
            $q->whereIn('username', self::PLACEHOLDERS)
                ->whereOr('username', '')
                ->whereOr('username', null);
        });
        if ($companyId > 0) {
            $query->where('companyId', $companyId);
        }

        $total = (int)(clone $query)->count();
        $rows = (clone $query)
            ->field('id,companyId,username,phone,account')
            ->limit($limit > 0 ? $limit : 1000)
            ->select();

        $output->writeln(sprintf(
            '<info>[clean:placeholderUsername] 占位用户名命中 %d 条（companyId=%s, mode=%s）</info>',
            $total,
            $companyId ?: 'ALL',
            $apply ? 'APPLY' : 'DRY-RUN'
        ));

        $updated = 0;
        $skipped = 0;
        foreach ($rows as $r) {
            $fallback = $this->resolveFallback($r);
            if ($fallback === '') {
                $skipped++;
                continue;
            }
            if (!$apply) {
                $output->writeln(sprintf(
                    '  - id=%d company=%s "%s" → "%s"',
                    $r['id'],
                    $r['companyId'] ?? '',
                    (string)($r['username'] ?? ''),
                    $fallback
                ));
                continue;
            }
            Db::name('users')->where('id', $r['id'])->update(['username' => $fallback]);
            $updated++;
        }

        $output->writeln(sprintf(
            '<info>[clean:placeholderUsername] done total=%d updated=%d skipped(无可推断回退)=%d</info>',
            $total,
            $apply ? $updated : 0,
            $skipped
        ));
        if (!$apply) {
            $output->writeln('<comment>dry-run 模式未写库；确认无误后加 --apply=1 执行。</comment>');
        }
        return 0;
    }

    /**
     * 优先账号别名（非纯数字）→ 手机脱敏「客服****」；都无则空（跳过，不强改）
     */
    private function resolveFallback(array $r): string
    {
        $account = trim((string)($r['account'] ?? ''));
        if ($account !== '' && !is_numeric($account)) {
            return $account;
        }
        $phone = preg_replace('/\D/', '', (string)($r['phone'] ?? ''));
        if (strlen($phone) >= 4) {
            return '客服' . substr($phone, -4);
        }
        return '';
    }
}