nanguaboss
64 lines
2.5 KiB
PHP
64 lines
2.5 KiB
PHP
<?php
|
|
/**
|
|
* 完整度全量重算脚本（CLI 运行）
|
|
* 用法：php tools/recalc_completeness.php [--dry-run]
|
|
* 作用：遍历 persons / companies / social_accounts / media_commercial_attributes
|
|
* 全部记录，按三层完整度判定规则重新计算并刷新 is_incomplete。
|
|
* 场景：完整性规则变更后回填存量数据（如 v1.0.29 规则修订后）。
|
|
*/
|
|
require_once __DIR__ . '/../api/common/db.php';
|
|
require_once __DIR__ . '/../api/common/completeness.php';
|
|
|
|
$dryRun = in_array('--dry-run', $argv, true);
|
|
|
|
$pdo = DB::getInstance()->getPdo();
|
|
$summary = [];
|
|
|
|
/** 逐条重算某表 */
|
|
function recalcTable(PDO $pdo, $table, $sql, $dryRun, &$summary, $label, $realTable = null, $idCol = 'id')
|
|
{
|
|
$realTable = $realTable ?: $table;
|
|
$rows = $pdo->query($sql)->fetchAll(PDO::FETCH_COLUMN);
|
|
$total = count($rows);
|
|
$changed = 0;
|
|
foreach ($rows as $id) {
|
|
$id = (int)$id;
|
|
if ($dryRun) {
|
|
// 只读计算，不写库
|
|
$info = completenessInfo($pdo, $table, $id);
|
|
} else {
|
|
$info = updateIncomplete($pdo, $table, $id);
|
|
}
|
|
if ($info === null) {
|
|
continue;
|
|
}
|
|
if ($dryRun) {
|
|
$flag = $info['is_complete'] ? 0 : 1;
|
|
$cur = (int)$pdo->query("SELECT is_incomplete FROM `$realTable` WHERE `$idCol` = $id")->fetchColumn();
|
|
if ($cur !== $flag) {
|
|
$changed++;
|
|
}
|
|
} else {
|
|
$changed++;
|
|
}
|
|
}
|
|
$summary[$label] = ['total' => $total, 'changed' => $changed];
|
|
}
|
|
|
|
echo $dryRun ? "[DRY-RUN] 仅统计，不写库\n" : "开始全量重算完整度标记...\n";
|
|
|
|
recalcTable($pdo, 'persons', "SELECT id FROM persons", $dryRun, $summary, 'persons');
|
|
recalcTable($pdo, 'companies', "SELECT id FROM companies", $dryRun, $summary, 'companies');
|
|
recalcTable($pdo, 'social_accounts', "SELECT id FROM social_accounts", $dryRun, $summary, 'social_accounts');
|
|
recalcTable($pdo, 'media', "SELECT social_account_id FROM media_commercial_attributes", $dryRun, $summary, 'media', 'media_commercial_attributes', 'social_account_id');
|
|
|
|
foreach ($summary as $label => $s) {
|
|
printf("%-16s 共 %d 条，%s %d 条\n", $label, $s['total'], $dryRun ? '将被更新' : '已更新', $s['changed']);
|
|
}
|
|
|
|
$softTotal = 0;
|
|
foreach (['companies', 'persons', 'social_accounts', 'media_commercial_attributes'] as $t) {
|
|
$softTotal += (int)$pdo->query("SELECT COUNT(*) FROM `$t` WHERE is_incomplete = 1")->fetchColumn();
|
|
}
|
|
echo "重算后软碎片总数：{$softTotal}\n";
|