xh-erp.7in6.com/application/common/library/ProcuremenSupplierScore.php

<?php

namespace app\common\library;

use think\Db;
use think\Log;

/**
 * 协助采购 — 供应商服务评分
 *
 * 表分工：
 * - supplier_service_score：订单明细（开标后按 ccydh×供应商写入，含本单总分 score）
 * - supplier_service_final_score：月度评审表（四项自动统计，满分 105；qp_manual=1 手工锁定不覆盖）
 *
 * 开标单笔总分 = 质量得分×质量% + 价格得分 [+ 交货得分×交货%]
 * 开标质量/交货得分：均取月度评审表（当月按上月起往前查，无则默认 50）
 * 开标价格得分 = (本单最低单价合计 / 本供应商单价合计) × 价格权重% × 100
 *
 * 月度评审（与开标单笔分离）：
 * 质量40 = 合格率对照(20) + 客户投诉(10) + 生产中断(10)
 * 价格15 = 全部严格低于最高限价→15，否则（等于限价/限价空）→10
 * 交货40 = 准时率对照(30) + 生产中断(10，出现一次得0)
 * 增值10 = 未报价订单数≤3→10，>3→0（按订单号去重）
 * 最终得分 = 四项相加；等级 A≥90 / B≥70 / C≥60 / D
 */
class ProcuremenSupplierScore
{
    public const TABLE_RULE = 'supplier_score_rule';
    /** 订单明细评分表 */
    public const TABLE_SCORE = 'supplier_service_score';
    /** 月度汇总表（总分 + 最终得分） */
    public const TABLE_FINAL = 'supplier_service_final_score';

    /** @var bool|null */
    protected static $schemaReady = null;

    /** 结构探测缓存键（升版本可强制再跑一遍迁移） */
    const SCHEMA_CACHE_KEY = 'procuremen_supplier_score_schema_ok_v6';

    public static function ensureSchema(): void
    {
        if (self::$schemaReady === true) {
            return;
        }
        // 跨请求缓存：命中后直接返回，禁止再跑 SHOW COLUMNS / ALTER / 规则种子
        try {
            if (\think\Cache::get(self::SCHEMA_CACHE_KEY)) {
                self::$schemaReady = true;

                return;
            }
            try {
                \think\Cache::rm('procuremen_supplier_score_schema_ok_v1');
                \think\Cache::rm('procuremen_supplier_score_schema_ok_v2');
                \think\Cache::rm('procuremen_supplier_score_schema_ok_v3');
                \think\Cache::rm('procuremen_supplier_score_schema_ok_v4');
                \think\Cache::rm('procuremen_supplier_score_schema_ok_v5');
            } catch (\Throwable $e) {
            }
        } catch (\Throwable $e) {
        }
        try {
            Db::query('SELECT 1 FROM `' . self::TABLE_RULE . '` LIMIT 1');
            Db::query('SELECT 1 FROM `' . self::TABLE_SCORE . '` LIMIT 1');
            self::runSchemaMigrations();
            self::$schemaReady = true;
            try {
                \think\Cache::set(self::SCHEMA_CACHE_KEY, 1, 86400);
            } catch (\Throwable $e) {
            }

            return;
        } catch (\Throwable $e) {
        }
        $sqlFile = APP_PATH . 'extra' . DIRECTORY_SEPARATOR . 'supplier_score_install.sql';
        if (is_file($sqlFile)) {
            $sql = file_get_contents($sqlFile);
            if (is_string($sql) && $sql !== '') {
                foreach (preg_split('/;\s*[\r\n]+/', $sql) as $stmt) {
                    $stmt = trim($stmt);
                    if ($stmt === '' || stripos($stmt, 'CREATE TABLE') === false) {
                        continue;
                    }
                    try {
                        Db::execute($stmt);
                    } catch (\Throwable $ignore) {
                    }
                }
            }
        }
        self::runSchemaMigrations();
        self::$schemaReady = true;
        try {
            \think\Cache::set(self::SCHEMA_CACHE_KEY, 1, 86400);
        } catch (\Throwable $e) {
        }
    }

    /** 首次（或缓存失效）时执行表结构迁移与默认规则种子 */
    protected static function runSchemaMigrations(): void
    {
        self::ensureRuleNameColumn();
        self::dropObsoleteRuleColumns();
        self::ensureDefaultRule();
        self::ensureOrderTypeRules();
        self::ensureScoreWeightColumns();
        self::ensureLeadColumns();
        self::ensureIntegerColumns();
        self::ensureFinalScoreTable();
    }

    /** 月度记录表（商务技术分 / 价格分 / 最终得分，仅本页展示与导出） */
    public static function ensureFinalScoreTable(): void
    {
        static $done = false;
        if ($done) {
            return;
        }
        try {
            if (\think\Cache::get('procuremen_supplier_final_score_table_ok_v1')) {
                $done = true;

                return;
            }
        } catch (\Throwable $e) {
        }
        $ddl = "CREATE TABLE IF NOT EXISTS `" . self::TABLE_FINAL . "` (
  `id` int unsigned NOT NULL AUTO_INCREMENT,
  `ym` char(7) NOT NULL DEFAULT '' COMMENT '年月 YYYY-MM',
  `company_name` varchar(128) NOT NULL DEFAULT '' COMMENT '供应商名称',
  `score` decimal(10,2) NOT NULL DEFAULT 0.00 COMMENT '月度总分(兼容旧字段)',
  `quality_score` decimal(10,2) DEFAULT NULL COMMENT '商务技术分(人工，空=未填)',
  `price_score` decimal(10,2) DEFAULT NULL COMMENT '价格分(人工，空=未填)',
  `delivery_score` decimal(10,2) DEFAULT NULL COMMENT '交货分(人工，空=未填)',
  `value_added_score` decimal(10,2) DEFAULT NULL COMMENT '增值服务(人工，空=未填)',
  `final_score` decimal(10,2) DEFAULT NULL COMMENT '最终得分(人工，空=未填)',
  `score_grade` char(1) NOT NULL DEFAULT '' COMMENT '评分等级 A/B/C/D',
  `qp_manual` tinyint unsigned NOT NULL DEFAULT 0 COMMENT '1=商务技术分/价格分/交货分已人工修改',
  `createtime` datetime DEFAULT NULL,
  `updatetime` datetime DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_ym_company` (`ym`,`company_name`),
  KEY `idx_ym` (`ym`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='供应商月度评审记录'";
        try {
            Db::execute($ddl);
        } catch (\Throwable $e) {
            Log::write('supplier monthly score table: ' . $e->getMessage(), 'error');
        }
        self::ensureMonthlyScoreColumns();
        $done = true;
        try {
            \think\Cache::set('procuremen_supplier_final_score_table_ok_v1', 1, 86400);
        } catch (\Throwable $e) {
        }
    }

    /** 历史月度表补商务技术分/价格分等字段 */
    protected static function ensureMonthlyScoreColumns(): void
    {
        $adds = [
            'score'         => "ADD COLUMN `score` decimal(10,2) NOT NULL DEFAULT 0.00 COMMENT '月度总分(兼容旧字段)' AFTER `company_name`",
            'quality_score' => "ADD COLUMN `quality_score` decimal(10,2) DEFAULT NULL COMMENT '商务技术分(人工，空=未填)' AFTER `score`",
            'price_score'    => "ADD COLUMN `price_score` decimal(10,2) DEFAULT NULL COMMENT '价格分(人工，空=未填)' AFTER `quality_score`",
            'delivery_score' => "ADD COLUMN `delivery_score` decimal(10,2) DEFAULT NULL COMMENT '交货分(人工，空=未填)' AFTER `price_score`",
            'value_added_score' => "ADD COLUMN `value_added_score` decimal(10,2) DEFAULT NULL COMMENT '增值服务(人工，空=未填)' AFTER `delivery_score`",
            'score_grade'    => "ADD COLUMN `score_grade` char(1) NOT NULL DEFAULT '' COMMENT '评分等级 A/B/C/D' AFTER `final_score`",
            'qp_manual'      => "ADD COLUMN `qp_manual` tinyint unsigned NOT NULL DEFAULT 0 COMMENT '1=商务技术分/价格分/交货分/增值服务已人工修改' AFTER `score_grade`",
        ];
        foreach ($adds as $col => $ddl) {
            try {
                $cols = Db::query("SHOW COLUMNS FROM `" . self::TABLE_FINAL . "` LIKE '{$col}'");
                if (!is_array($cols) || $cols === []) {
                    Db::execute("ALTER TABLE `" . self::TABLE_FINAL . "` {$ddl}");
                }
            } catch (\Throwable $e) {
                Log::write("supplier monthly {$col} column: " . $e->getMessage(), 'error');
            }
        }
        // 分数字段允许 NULL：空=未填，列表不显示 0
        foreach ([
            'quality_score'      => '商务技术分(人工，空=未填)',
            'price_score'        => '价格分(人工，空=未填)',
            'delivery_score'     => '交货分(人工，空=未填)',
            'value_added_score'  => '增值服务(人工，空=未填)',
            'final_score'        => '最终得分(人工，空=未填)',
        ] as $col => $comment) {
            try {
                $info = Db::query("SHOW COLUMNS FROM `" . self::TABLE_FINAL . "` LIKE '{$col}'");
                if (is_array($info) && $info !== []) {
                    $null = strtoupper((string)($info[0]['Null'] ?? ''));
                    if ($null !== 'YES') {
                        Db::execute(
                            "ALTER TABLE `" . self::TABLE_FINAL . "` MODIFY COLUMN `{$col}` decimal(10,2) DEFAULT NULL COMMENT '{$comment}'"
                        );
                    }
                }
            } catch (\Throwable $e) {
                Log::write("supplier monthly {$col} null: " . $e->getMessage(), 'error');
            }
        }
    }

    /** 规范化评分等级：空 / A / B / C / D */
    public static function normalizeScoreGrade($raw): string
    {
        $g = strtoupper(trim((string)$raw));
        if (in_array($g, ['A', 'B', 'C', 'D'], true)) {
            return $g;
        }

        return '';
    }

    /**
     * 综合评分标准：A≥90  B 70-89  C 60-69  D<60
     *
     * @param mixed $score
     */
    public static function gradeFromFinalScore($score): string
    {
        if ($score === null || $score === '') {
            return '';
        }
        if (!is_numeric($score)) {
            return '';
        }
        $n = (float)$score;
        if ($n >= 90) {
            return 'A';
        }
        if ($n >= 70) {
            return 'B';
        }
        if ($n >= 60) {
            return 'C';
        }

        return 'D';
    }

    /**
     * 最终得分 = 质量 + 价格 + 交货 + 增值服务（空项按 0；四项全空则 null）
     *
     * @param mixed $quality
     * @param mixed $price
     * @param mixed $delivery
     * @param mixed $valueAdded
     */
    public static function sumFinalScore($quality, $price, $delivery, $valueAdded): ?float
    {
        $parts = [$quality, $price, $delivery, $valueAdded];
        $any = false;
        $sum = 0.0;
        foreach ($parts as $p) {
            if ($p === null || $p === '') {
                continue;
            }
            if (!is_numeric($p)) {
                continue;
            }
            $any = true;
            $sum += (float)$p;
        }

        return $any ? round($sum, 2) : null;
    }

    /**
     * 按订单明细重算并写入某月评审记录（商务技术分/价格分；保留已填最终得分）
     *
     * @param array<int, string>|null $onlyCompanies 仅同步这些供应商；null=当月全部
     */
    public static function syncMonthlyScoresForYm(string $ym, ?array $onlyCompanies = null): void
    {
        $ym = trim($ym);
        if (!preg_match('/^\d{4}-\d{2}$/', $ym)) {
            return;
        }
        self::ensureSchema();
        self::ensureFinalScoreTable();
        try {
            $query = Db::table(self::TABLE_SCORE)
                ->where('ym', $ym)
                ->field('company_name,score,quality_score,price_score,lead_score');
            if (is_array($onlyCompanies) && $onlyCompanies !== []) {
                $names = [];
                foreach ($onlyCompanies as $n) {
                    $n = trim((string)$n);
                    if ($n !== '') {
                        $names[$n] = true;
                    }
                }
                if ($names === []) {
                    return;
                }
                $query->where('company_name', 'in', array_keys($names));
            }
            $rows = $query->select();
        } catch (\Throwable $e) {
            // 无 lead_score 列时回退
            try {
                $query = Db::table(self::TABLE_SCORE)
                    ->where('ym', $ym)
                    ->field('company_name,score,quality_score,price_score');
                if (is_array($onlyCompanies) && $onlyCompanies !== []) {
                    $names = [];
                    foreach ($onlyCompanies as $n) {
                        $n = trim((string)$n);
                        if ($n !== '') {
                            $names[$n] = true;
                        }
                    }
                    if ($names === []) {
                        return;
                    }
                    $query->where('company_name', 'in', array_keys($names));
                }
                $rows = $query->select();
            } catch (\Throwable $e2) {
                Log::write('supplier monthly sync read: ' . $e2->getMessage(), 'error');

                return;
            }
        }
        if (!is_array($rows)) {
            return;
        }
        $agg = [];
        foreach ($rows as $r) {
            if (!is_array($r)) {
                continue;
            }
            $cn = trim((string)($r['company_name'] ?? ''));
            if ($cn === '') {
                continue;
            }
            if (!isset($agg[$cn])) {
                $agg[$cn] = [
                    'score_sum'     => 0.0,
                    'quality_sum'   => 0.0,
                    'price_sum'     => 0.0,
                    'delivery_sum'  => 0.0,
                    'cnt'           => 0,
                ];
            }
            $agg[$cn]['score_sum'] += (float)($r['score'] ?? 0);
            $agg[$cn]['quality_sum'] += (float)($r['quality_score'] ?? 0);
            $agg[$cn]['price_sum'] += (float)($r['price_score'] ?? 0);
            $agg[$cn]['delivery_sum'] += (float)($r['lead_score'] ?? 0);
            $agg[$cn]['cnt']++;
        }
        $now = date('Y-m-d H:i:s');
        foreach ($agg as $cn => $a) {
            $cnt = (int)$a['cnt'];
            $avgScore = $cnt > 0 ? round($a['score_sum'] / $cnt, 2) : 0.0;
            $avgPrice = $cnt > 0 ? round($a['price_sum'] / $cnt, 2) : 0.0;
            $avgDelivery = $cnt > 0 ? round($a['delivery_sum'] / $cnt, 2) : 0.0;
            try {
                $exists = Db::table(self::TABLE_FINAL)->where('ym', $ym)->where('company_name', $cn)->find();
                if (is_array($exists) && $exists !== []) {
                    // 已手工保存：不再按订单明细重算覆盖
                    if ((int)($exists['qp_manual'] ?? 0) === 1) {
                        continue;
                    }
                    $upd = [
                        'score'           => $avgScore,
                        'price_score'     => $avgPrice,
                        'delivery_score'  => $avgDelivery,
                        'updatetime'      => $now,
                    ];
                    Db::table(self::TABLE_FINAL)->where('id', (int)($exists['id'] ?? 0))->update($upd);
                } else {
                    Db::table(self::TABLE_FINAL)->insert([
                        'ym'                => $ym,
                        'company_name'      => $cn,
                        'score'             => $avgScore,
                        'quality_score'     => null,
                        'price_score'       => $avgPrice,
                        'delivery_score'    => $avgDelivery,
                        'value_added_score' => null,
                        'final_score'       => null,
                        'score_grade'       => '',
                        'qp_manual'         => 0,
                        'createtime'        => $now,
                        'updatetime'        => $now,
                    ]);
                }
            } catch (\Throwable $e) {
                Log::write('supplier monthly sync write: ' . $e->getMessage(), 'error');
            }
        }
    }

    /**
     * 读取某月各供应商最终得分（仅已人工填写的）
     *
     * @return array<string, float> company_name => final_score
     */
    public static function loadFinalScoreMapByYm(string $ym): array
    {
        $ym = trim($ym);
        if (!preg_match('/^\d{4}-\d{2}$/', $ym)) {
            return [];
        }
        self::ensureFinalScoreTable();
        try {
            $rows = Db::table(self::TABLE_FINAL)
                ->where('ym', $ym)
                ->whereNotNull('final_score')
                ->field('company_name,final_score')
                ->select();
        } catch (\Throwable $e) {
            return [];
        }
        if (!is_array($rows)) {
            return [];
        }
        $out = [];
        foreach ($rows as $r) {
            if (!is_array($r)) {
                continue;
            }
            $cn = trim((string)($r['company_name'] ?? ''));
            if ($cn === '') {
                continue;
            }
            $out[$cn] = round((float)($r['final_score'] ?? 0), 2);
        }

        return $out;
    }

    /**
     * 读取库中可选分数：NULL/空串 → null；合法数字 → float
     *
     * @param mixed $raw
     */
    public static function readOptionalScoreValue($raw): ?float
    {
        if ($raw === null) {
            return null;
        }
        if (is_string($raw) && trim($raw) === '') {
            return null;
        }
        if (!is_numeric($raw)) {
            return null;
        }

        return round((float)$raw, 2);
    }

    /**
     * 可选分数展示：空不显示 0
     *
     * @param float|null $n
     */
    public static function formatOptionalScore(?float $n): string
    {
        if ($n === null) {
            return '';
        }

        return self::formatScore($n);
    }

    /**
     * 开标后把本月询价供应商名称写入月度评审表：不存在则插入空行，已存在不改（分数人工填）
     *
     * @param array<int, string> $companyNames
     * @return int 新插入条数
     */
    public static function ensureMonthlySupplierNames(string $ym, array $companyNames): int
    {
        $ym = trim($ym);
        if (!preg_match('/^\d{4}-\d{2}$/', $ym)) {
            return 0;
        }
        $uniq = [];
        foreach ($companyNames as $n) {
            $n = trim((string)$n);
            if ($n !== '') {
                $uniq[$n] = true;
            }
        }
        if ($uniq === []) {
            return 0;
        }
        self::ensureFinalScoreTable();
        $now = date('Y-m-d H:i:s');
        $inserted = 0;
        foreach (array_keys($uniq) as $cn) {
            try {
                $exists = Db::table(self::TABLE_FINAL)->where('ym', $ym)->where('company_name', $cn)->find();
                if (is_array($exists) && $exists !== []) {
                    continue;
                }
                Db::table(self::TABLE_FINAL)->insert([
                    'ym'                => $ym,
                    'company_name'      => $cn,
                    'score'             => 0,
                    'quality_score'     => null,
                    'price_score'       => null,
                    'delivery_score'    => null,
                    'value_added_score' => null,
                    'final_score'       => null,
                    'score_grade'       => '',
                    'qp_manual'         => 0,
                    'createtime'        => $now,
                    'updatetime'        => $now,
                ]);
                $inserted++;
            } catch (\Throwable $e) {
                // 并发下唯一键冲突视为已存在
                if (stripos($e->getMessage(), 'Duplicate') === false) {
                    Log::write('supplier monthly ensure name: ' . $e->getMessage(), 'error');
                }
            }
        }

        return $inserted;
    }

    /**
     * 按当月订单评分表中的供应商，补齐月度评审表名称（仅新增空行）
     */
    public static function ensureMonthlySupplierNamesFromOrderYm(string $ym): void
    {
        $ym = trim($ym);
        if (!preg_match('/^\d{4}-\d{2}$/', $ym)) {
            return;
        }
        self::ensureSchema();
        self::ensureFinalScoreTable();
        try {
            $rows = Db::table(self::TABLE_SCORE)
                ->where('ym', $ym)
                ->field('company_name')
                ->group('company_name')
                ->select();
        } catch (\Throwable $e) {
            return;
        }
        if (!is_array($rows) || $rows === []) {
            return;
        }
        $names = [];
        foreach ($rows as $r) {
            if (!is_array($r)) {
                continue;
            }
            $cn = trim((string)($r['company_name'] ?? ''));
            if ($cn !== '') {
                $names[] = $cn;
            }
        }
        self::ensureMonthlySupplierNames($ym, $names);
    }

    /**
     * 合格率百分比 → 质量「合格率」分项（满分 20）
     * 100→20；95-99→18；90-94→16；85-89→14；70-84→12；&lt;70→10
     */
    public static function mapPassRatePercentToQualityScore(float $passRatePercent): float
    {
        if ($passRatePercent >= 100) {
            return 20.0;
        }
        if ($passRatePercent >= 95) {
            return 18.0;
        }
        if ($passRatePercent >= 90) {
            return 16.0;
        }
        if ($passRatePercent >= 85) {
            return 14.0;
        }
        if ($passRatePercent >= 70) {
            return 12.0;
        }

        return 10.0;
    }

    /**
     * 交货准时率百分比 → 交货「准时率」分项（满分 30）
     * 100→30；95-99→20；90-94→15；85-89→10；70-84→5；&lt;70→0
     */
    public static function mapOnTimeRatePercentToDeliveryScore(float $onTimeRatePercent): float
    {
        if ($onTimeRatePercent >= 100) {
            return 30.0;
        }
        if ($onTimeRatePercent >= 95) {
            return 20.0;
        }
        if ($onTimeRatePercent >= 90) {
            return 15.0;
        }
        if ($onTimeRatePercent >= 85) {
            return 10.0;
        }
        if ($onTimeRatePercent >= 70) {
            return 5.0;
        }

        return 0.0;
    }

    /**
     * 解析金额/限价；空或非数字返回 null
     *
     * @param mixed $raw
     */
    public static function parseMoneyValue($raw): ?float
    {
        if ($raw === null) {
            return null;
        }
        $s = trim((string)$raw);
        if ($s === '') {
            return null;
        }
        $s = str_replace([',', '，', ' '], '', $s);
        if ($s === '' || !is_numeric($s)) {
            return null;
        }

        return (float)$s;
    }

    /**
     * 报价是否视为未填（空 / 0 / 0.00）
     *
     * @param mixed $raw
     */
    public static function isBlankQuoteAmount($raw): bool
    {
        $v = self::parseMoneyValue($raw);
        if ($v === null) {
            return true;
        }

        return abs($v) < 0.0000001;
    }

    /**
     * 工序完结年月（YYYY-MM）
     * 优先：采购确认 / 直接完结操作时间；其次采购单 pick_time/createtime/dStamp；再无：入库评分时间
     *
     * @param int[]                                                    $scydgyIds
     * @param array<int, array{createtime?:mixed,updatetime?:mixed}> $inboundTimeBySid
     * @return array<int, string> scydgy_id => YYYY-MM
     */
    public static function loadCompletedYmMapByScydgyIds(array $scydgyIds, array $inboundTimeBySid = []): array
    {
        $ids = [];
        foreach ($scydgyIds as $sid) {
            $sid = (int)$sid;
            if ($sid > 0) {
                $ids[$sid] = true;
            }
        }
        if ($ids === []) {
            return [];
        }
        $sidList = array_keys($ids);
        $completeTsMap = ProcuremenTime::loadOperLogTimestampMap($sidList, ['purchase_confirm', 'mark_complete']);
        $poBySid = [];
        try {
            $poRows = Db::table('purchase_order')
                ->where('scydgy_id', 'in', $sidList)
                ->field('scydgy_id,pick_time,createtime,dStamp')
                ->select();
        } catch (\Throwable $e) {
            $poRows = [];
        }
        if (is_array($poRows)) {
            foreach ($poRows as $po) {
                if (!is_array($po)) {
                    continue;
                }
                $sid = (int)($po['scydgy_id'] ?? 0);
                if ($sid > 0) {
                    $poBySid[$sid] = $po;
                }
            }
        }
        $out = [];
        foreach ($sidList as $sid) {
            $row = $poBySid[$sid] ?? ['scydgy_id' => $sid];
            $done = ProcuremenTime::resolveCompletedDone($row, $completeTsMap);
            $ts = (int)($done['ts'] ?? 0);
            if ($ts <= 946684800 && isset($inboundTimeBySid[$sid])) {
                $t1 = ProcuremenTime::parseToTimestamp($inboundTimeBySid[$sid]['updatetime'] ?? null);
                $t2 = ProcuremenTime::parseToTimestamp($inboundTimeBySid[$sid]['createtime'] ?? null);
                $ts = max($t1, $t2);
            }
            if ($ts > 946684800) {
                $out[$sid] = date('Y-m', $ts);
            }
        }

        return $out;
    }

    /**
     * 某供应商某月入库评分订单聚合（按订单号去重）
     * 月份按工序「完结时间」归属，不用质量评分创建/更新时间
     *
     * @return array<string, array{result:string,delivery_status:string,customer_complaint:int,order_interrupt:int}>
     */
    public static function loadInboundOrderAggByCompanyYm(string $companyName, string $ym): array
    {
        $companyName = trim($companyName);
        $ym = self::formatScoreYm($ym);
        if ($companyName === '' || $ym === '') {
            return [];
        }
        /** @var array<string, array{result:string,delivery_status:string,customer_complaint:int,order_interrupt:int}> $byOrder */
        $byOrder = [];
        try {
            $rows = Db::table('purchase_order_inbound_score')
                ->where('company_name', $companyName)
                ->field('scydgy_id,ccydh,result,delivery_status,customer_complaint,order_interrupt,createtime,updatetime')
                ->select();
        } catch (\Throwable $e) {
            try {
                $rows = Db::table('purchase_order_inbound_score')
                    ->where('company_name', $companyName)
                    ->field('scydgy_id,ccydh,result,createtime,updatetime')
                    ->select();
            } catch (\Throwable $e2) {
                $rows = [];
                Log::write('loadInboundOrderAgg table: ' . $e2->getMessage(), 'error');
            }
        }
        if (!is_array($rows) || $rows === []) {
            $legacy = self::loadInboundOrderResultsFromOperLogs($companyName, $ym);
            foreach ($legacy as $ccydh => $res) {
                $byOrder[$ccydh] = [
                    'result'             => $res,
                    'delivery_status'    => '',
                    'customer_complaint' => 0,
                    'order_interrupt'    => 0,
                ];
            }

            return $byOrder;
        }
        $sidSet = [];
        $inboundTimeBySid = [];
        foreach ($rows as $r) {
            if (!is_array($r)) {
                continue;
            }
            $sid = (int)($r['scydgy_id'] ?? 0);
            if ($sid <= 0) {
                continue;
            }
            $sidSet[$sid] = true;
            $inboundTimeBySid[$sid] = [
                'createtime' => $r['createtime'] ?? null,
                'updatetime' => $r['updatetime'] ?? null,
            ];
        }
        $completedYmMap = self::loadCompletedYmMapByScydgyIds(array_keys($sidSet), $inboundTimeBySid);
        foreach ($rows as $r) {
            if (!is_array($r)) {
                continue;
            }
            $sid = (int)($r['scydgy_id'] ?? 0);
            $rowYm = $sid > 0 ? (string)($completedYmMap[$sid] ?? '') : '';
            if ($rowYm === '' && $sid <= 0) {
                // 无工序 id：回退评分时间
                $t1 = ProcuremenTime::parseToTimestamp($r['updatetime'] ?? null);
                $t2 = ProcuremenTime::parseToTimestamp($r['createtime'] ?? null);
                $ts = max($t1, $t2);
                $rowYm = $ts > 946684800 ? date('Y-m', $ts) : '';
            }
            if ($rowYm !== $ym) {
                continue;
            }
            $ccydh = trim((string)($r['ccydh'] ?? ''));
            $res = trim((string)($r['result'] ?? ''));
            if ($ccydh === '' || ($res !== '合格' && $res !== '不合格')) {
                continue;
            }
            $ds = trim((string)($r['delivery_status'] ?? ''));
            if ($ds !== '准时' && $ds !== '滞后') {
                $ds = '';
            }
            $complaint = (int)($r['customer_complaint'] ?? 0) === 1 ? 1 : 0;
            $interrupt = (int)($r['order_interrupt'] ?? 0) === 1 ? 1 : 0;
            if (!isset($byOrder[$ccydh])) {
                $byOrder[$ccydh] = [
                    'result'             => $res,
                    'delivery_status'    => $ds,
                    'customer_complaint' => $complaint,
                    'order_interrupt'    => $interrupt,
                ];
                continue;
            }
            if ($res === '不合格') {
                $byOrder[$ccydh]['result'] = '不合格';
            }
            if ($byOrder[$ccydh]['delivery_status'] === '' && $ds !== '') {
                $byOrder[$ccydh]['delivery_status'] = $ds;
            }
            if ($complaint === 1) {
                $byOrder[$ccydh]['customer_complaint'] = 1;
            }
            if ($interrupt === 1) {
                $byOrder[$ccydh]['order_interrupt'] = 1;
            }
        }
        if ($byOrder !== []) {
            return $byOrder;
        }
        // 回退：操作日志仅能还原合格/不合格（同样按完结月过滤）
        $legacy = self::loadInboundOrderResultsFromOperLogs($companyName, $ym);
        foreach ($legacy as $ccydh => $res) {
            $byOrder[$ccydh] = [
                'result'             => $res,
                'delivery_status'    => '',
                'customer_complaint' => 0,
                'order_interrupt'    => 0,
            ];
        }

        return $byOrder;
    }

    /**
     * 某供应商某月：订单号 => 合格|不合格（兼容旧调用）
     *
     * @return array<string, string>
     */
    public static function loadInboundOrderResultsByCompanyYm(string $companyName, string $ym): array
    {
        $out = [];
        foreach (self::loadInboundOrderAggByCompanyYm($companyName, $ym) as $ccydh => $agg) {
            $out[$ccydh] = (string)($agg['result'] ?? '');
        }

        return $out;
    }

    /**
     * 操作日志回退：订单号 => 合格|不合格（按工序完结月过滤）
     *
     * @return array<string, string>
     */
    protected static function loadInboundOrderResultsFromOperLogs(string $companyName, string $ym): array
    {
        $byOrder = [];
        try {
            $logs = Db::table('purchase_order_oper_log')
                ->where(function ($q) {
                    $q->where('action', '入库评分')->whereOr('action', 'inbound_score');
                })
                ->field('scydgy_id,content,createtime')
                ->order('id', 'asc')
                ->select();
        } catch (\Throwable $e) {
            Log::write('loadInboundOrderResults logs: ' . $e->getMessage(), 'error');

            return [];
        }
        if (!is_array($logs) || $logs === []) {
            return [];
        }
        $sidResult = [];
        $inboundTimeBySid = [];
        foreach ($logs as $lg) {
            if (!is_array($lg)) {
                continue;
            }
            $sid = (int)($lg['scydgy_id'] ?? 0);
            if ($sid <= 0) {
                continue;
            }
            $content = trim((string)($lg['content'] ?? ''));
            if (!preg_match('/(合格|不合格)/u', $content, $m)) {
                continue;
            }
            $sidResult[$sid] = $m[1];
            $inboundTimeBySid[$sid] = [
                'createtime' => $lg['createtime'] ?? null,
                'updatetime' => $lg['createtime'] ?? null,
            ];
        }
        if ($sidResult === []) {
            return [];
        }
        try {
            $poRows = Db::table('purchase_order')
                ->where('scydgy_id', 'in', array_keys($sidResult))
                ->where('pick_company_name', $companyName)
                ->field('scydgy_id,CCYDH,pick_company_name')
                ->select();
        } catch (\Throwable $e) {
            return [];
        }
        if (!is_array($poRows)) {
            return [];
        }
        $completedYmMap = self::loadCompletedYmMapByScydgyIds(array_keys($sidResult), $inboundTimeBySid);
        foreach ($poRows as $po) {
            if (!is_array($po)) {
                continue;
            }
            $sid = (int)($po['scydgy_id'] ?? 0);
            $ccydh = trim((string)($po['CCYDH'] ?? ''));
            $res = $sidResult[$sid] ?? '';
            if ($sid <= 0 || $ccydh === '' || ($res !== '合格' && $res !== '不合格')) {
                continue;
            }
            if ((string)($completedYmMap[$sid] ?? '') !== $ym) {
                continue;
            }
            if (!isset($byOrder[$ccydh]) || $res === '不合格') {
                $byOrder[$ccydh] = $res;
            }
        }

        return $byOrder;
    }

    /**
     * 质量得分（满分 40）= 合格率分(20) + 客户投诉(10) + 生产中断(10)
     *
     * @return float|null 无入库评分订单时返回 null
     */
    public static function calcQualityScoreFromInbound(string $companyName, string $ym): ?float
    {
        $companyName = trim($companyName);
        $ym = self::formatScoreYm($ym);
        if ($companyName === '' || $ym === '') {
            return null;
        }
        $byOrder = self::loadInboundOrderAggByCompanyYm($companyName, $ym);
        $total = count($byOrder);
        if ($total < 1) {
            return null;
        }
        $fail = 0;
        $complaintAny = false;
        $interruptCnt = 0;
        foreach ($byOrder as $agg) {
            if (($agg['result'] ?? '') === '不合格') {
                $fail++;
            }
            if ((int)($agg['customer_complaint'] ?? 0) === 1) {
                $complaintAny = true;
            }
            if ((int)($agg['order_interrupt'] ?? 0) === 1) {
                $interruptCnt++;
            }
        }
        $passRate = (1 - ($fail / $total)) * 100;
        $passScore = self::mapPassRatePercentToQualityScore($passRate);
        $complaintScore = $complaintAny ? 0.0 : 10.0;
        if ($interruptCnt >= 3) {
            $interruptScore = 0.0;
        } else {
            $interruptScore = max(0.0, 10.0 - 2.0 * $interruptCnt);
        }

        return round($passScore + $complaintScore + $interruptScore, 2);
    }

    /**
     * 交货得分（满分 40）= 准时率分(30) + 生产中断(10，出现一次得 0)
     *
     * @return float|null 无入库评分订单时返回 null
     */
    public static function calcDeliveryScoreFromInbound(string $companyName, string $ym): ?float
    {
        $companyName = trim($companyName);
        $ym = self::formatScoreYm($ym);
        if ($companyName === '' || $ym === '') {
            return null;
        }
        $byOrder = self::loadInboundOrderAggByCompanyYm($companyName, $ym);
        $total = count($byOrder);
        if ($total < 1) {
            return null;
        }
        $late = 0;
        $interruptAny = false;
        foreach ($byOrder as $agg) {
            if (($agg['delivery_status'] ?? '') === '滞后') {
                $late++;
            }
            if ((int)($agg['order_interrupt'] ?? 0) === 1) {
                $interruptAny = true;
            }
        }
        $onTimeRate = (1 - ($late / $total)) * 100;
        $onTimeScore = self::mapOnTimeRatePercentToDeliveryScore($onTimeRate);
        $interruptScore = $interruptAny ? 0.0 : 10.0;

        return round($onTimeScore + $interruptScore, 2);
    }

    /**
     * 价格得分（满分 15）：全部严格低于最高限价→15；任一单等于限价或限价为空→10
     *
     * @return float|null 无比价订单时返回 null
     */
    public static function calcPriceScoreFromCeiling(string $companyName, string $ym): ?float
    {
        $companyName = trim($companyName);
        $ym = self::formatScoreYm($ym);
        if ($companyName === '' || $ym === '') {
            return null;
        }
        $byOrder = self::loadInboundOrderAggByCompanyYm($companyName, $ym);
        if ($byOrder === []) {
            return null;
        }
        $ccydhList = array_keys($byOrder);
        $compared = 0;
        $allStrictlyBelow = true;
        try {
            $poRows = Db::table('purchase_order')
                ->alias('po')
                ->join('purchase_order_detail d', 'd.scydgy_id = po.scydgy_id')
                ->where('po.CCYDH', 'in', $ccydhList)
                ->where('d.company_name', $companyName)
                ->whereRaw(
                    '(po.mod_rq IS NULL OR TRIM(CAST(po.mod_rq AS CHAR(32))) = \'\' OR TRIM(CAST(po.mod_rq AS CHAR(32))) LIKE \'0000-00-00%\')'
                )
                ->field('po.CCYDH,po.ceilingPrice,d.amount')
                ->select();
        } catch (\Throwable $e) {
            try {
                $poRows = Db::table('purchase_order')
                    ->alias('po')
                    ->join('purchase_order_detail d', 'd.scydgy_id = po.scydgy_id')
                    ->where('po.CCYDH', 'in', $ccydhList)
                    ->where('d.company_name', $companyName)
                    ->field('po.CCYDH,po.ceilingPrice,d.amount')
                    ->select();
            } catch (\Throwable $e2) {
                Log::write('calcPriceScoreFromCeiling: ' . $e2->getMessage(), 'error');

                return null;
            }
        }
        if (!is_array($poRows) || $poRows === []) {
            return null;
        }
        /** @var array<string, bool> $orderStrictBelow 订单是否全部严格低于限价 */
        $orderStrictBelow = [];
        foreach ($poRows as $r) {
            if (!is_array($r)) {
                continue;
            }
            $ccydh = trim((string)($r['CCYDH'] ?? $r['ccydh'] ?? ''));
            if ($ccydh === '' || !isset($byOrder[$ccydh])) {
                continue;
            }
            if (self::isBlankQuoteAmount($r['amount'] ?? null)) {
                continue;
            }
            $amount = self::parseMoneyValue($r['amount'] ?? null);
            if ($amount === null) {
                continue;
            }
            $compared++;
            if (!isset($orderStrictBelow[$ccydh])) {
                $orderStrictBelow[$ccydh] = true;
            }
            $ceiling = self::parseMoneyValue($r['ceilingPrice'] ?? $r['ceiling_price'] ?? null);
            if ($ceiling === null) {
                // 限价空 → 该单非严格低于
                $orderStrictBelow[$ccydh] = false;
                continue;
            }
            // 严格低于才算；等于或高于都不算
            if ($amount >= $ceiling - 0.0000001) {
                $orderStrictBelow[$ccydh] = false;
            }
        }
        if ($compared < 1 || $orderStrictBelow === []) {
            return null;
        }
        foreach ($orderStrictBelow as $ok) {
            if (!$ok) {
                $allStrictlyBelow = false;
                break;
            }
        }

        return $allStrictlyBelow ? 15.0 : 10.0;
    }

    /**
     * 增值服务（满分 10）：未报价订单数（按订单号去重）≤3 →10；>3 →0
     * 须当月已有完结/入库评分订单才计分（与本月订单明细同源）；仅有询价无完结单 → null
     *
     * @return float|null 无本月完结订单或无询价记录时返回 null
     */
    public static function calcValueAddedScoreFromUnquoted(string $companyName, string $ym): ?float
    {
        $companyName = trim($companyName);
        $ym = self::formatScoreYm($ym);
        if ($companyName === '' || $ym === '') {
            return null;
        }
        // 无本月入库完结订单则不计增值（避免「明细 0 单却有 10 分」）
        $inboundOrders = self::loadInboundOrderAggByCompanyYm($companyName, $ym);
        if ($inboundOrders === []) {
            return null;
        }
        $stats = self::loadUnquotedOrderStatsByCompanyYm($companyName, $ym);
        if ($stats === null) {
            return null;
        }
        $unquoted = (int)($stats['unquoted'] ?? 0);

        return $unquoted <= 3 ? 10.0 : 0.0;
    }

    /**
     * 某供应商某月询价订单：总数 / 未报价数（均按 CCYDH 去重）
     *
     * @return array{total:int,unquoted:int}|null 无询价记录时 null
     */
    public static function loadUnquotedOrderStatsByCompanyYm(string $companyName, string $ym): ?array
    {
        $companyName = trim($companyName);
        $ym = self::formatScoreYm($ym);
        if ($companyName === '' || $ym === '') {
            return null;
        }
        $ymEsc = str_replace(["\\", "'", '%', '_'], ["\\\\", "''", '\\%', '\\_'], $ym);
        try {
            $rows = Db::table('purchase_order_detail')
                ->alias('d')
                ->join('purchase_order po', 'po.scydgy_id = d.scydgy_id')
                ->where('d.company_name', $companyName)
                ->whereRaw(
                    "("
                    . "CASE "
                    . "WHEN po.createtime IS NOT NULL AND CAST(po.createtime AS CHAR(32)) REGEXP '^[0-9]{10,}$' "
                    . "THEN FROM_UNIXTIME(CAST(po.createtime AS UNSIGNED)) "
                    . "WHEN po.createtime IS NOT NULL AND TRIM(CAST(po.createtime AS CHAR(32))) <> '' "
                    . "AND TRIM(CAST(po.createtime AS CHAR(32))) NOT LIKE '0000-00-00%' "
                    . "THEN TRIM(CAST(po.createtime AS CHAR(32))) "
                    . "ELSE TRIM(CAST(IFNULL(po.dStamp, '') AS CHAR(32))) "
                    . "END"
                    . ") LIKE '{$ymEsc}-%'"
                )
                ->whereRaw(
                    '(po.mod_rq IS NULL OR TRIM(CAST(po.mod_rq AS CHAR(32))) = \'\' OR TRIM(CAST(po.mod_rq AS CHAR(32))) LIKE \'0000-00-00%\')'
                )
                ->field('po.CCYDH,d.amount')
                ->select();
        } catch (\Throwable $e) {
            Log::write('loadUnquotedOrderStats: ' . $e->getMessage(), 'error');

            return null;
        }
        if (!is_array($rows) || $rows === []) {
            return null;
        }
        /** @var array<string, bool> $quotedByOrder 订单是否至少有一条有效报价 */
        $quotedByOrder = [];
        foreach ($rows as $r) {
            if (!is_array($r)) {
                continue;
            }
            $ccydh = trim((string)($r['CCYDH'] ?? $r['ccydh'] ?? ''));
            if ($ccydh === '') {
                continue;
            }
            if (!isset($quotedByOrder[$ccydh])) {
                $quotedByOrder[$ccydh] = false;
            }
            if (!self::isBlankQuoteAmount($r['amount'] ?? null)) {
                $quotedByOrder[$ccydh] = true;
            }
        }
        if ($quotedByOrder === []) {
            return null;
        }
        $total = count($quotedByOrder);
        $unquoted = 0;
        foreach ($quotedByOrder as $quoted) {
            if (!$quoted) {
                $unquoted++;
            }
        }

        return ['total' => $total, 'unquoted' => $unquoted];
    }

    /**
     * 收集某月需重算的供应商名称
     * （按完结月有入库评分的供应商 + 当月询价明细 + 月度表已有行，便于清掉错月脏数据）
     *
     * @return string[]
     */
    public static function collectMonthlyReviewCompanyNames(string $ym, ?string $onlyCompany = null): array
    {
        $ym = self::formatScoreYm($ym);
        if ($ym === '') {
            return [];
        }
        $onlyCompany = $onlyCompany !== null ? trim($onlyCompany) : '';
        if ($onlyCompany !== '') {
            return [$onlyCompany];
        }
        $companies = [];
        // 1) 当月完结（采购确认/直接完结）的工序 → 供应商
        $ymEsc = str_replace(["\\", "'", '%', '_'], ["\\\\", "''", '\\%', '\\_'], $ym);
        try {
            $completeActs = ProcuremenOperLog::expandActionQueryValues(['purchase_confirm', 'mark_complete']);
            $clog = Db::table('purchase_order_oper_log')
                ->where(ProcuremenOperLog::COL_ACTION, 'in', $completeActs)
                ->where(ProcuremenOperLog::COL_TIME, 'like', $ym . '%')
                ->field(ProcuremenOperLog::COL_SCYDGY_ID)
                ->select();
        } catch (\Throwable $e) {
            $clog = [];
        }
        $completeSids = [];
        if (is_array($clog)) {
            foreach ($clog as $lg) {
                if (!is_array($lg)) {
                    continue;
                }
                $sid = (int)($lg[ProcuremenOperLog::COL_SCYDGY_ID] ?? $lg['scydgy_id'] ?? 0);
                if ($sid > 0) {
                    $completeSids[$sid] = true;
                }
            }
        }
        // 2) 全部有入库评分的供应商：再按完结月精确过滤
        try {
            $scoreRows = Db::table('purchase_order_inbound_score')
                ->field('scydgy_id,company_name,createtime,updatetime')
                ->select();
        } catch (\Throwable $e) {
            $scoreRows = [];
            Log::write('collectMonthlyReviewCompanyNames inbound: ' . $e->getMessage(), 'error');
        }
        $sidSet = $completeSids;
        $inboundTimeBySid = [];
        $companyBySid = [];
        if (is_array($scoreRows)) {
            foreach ($scoreRows as $r) {
                if (!is_array($r)) {
                    continue;
                }
                $sid = (int)($r['scydgy_id'] ?? 0);
                $cn = trim((string)($r['company_name'] ?? ''));
                if ($sid > 0) {
                    $sidSet[$sid] = true;
                    $inboundTimeBySid[$sid] = [
                        'createtime' => $r['createtime'] ?? null,
                        'updatetime' => $r['updatetime'] ?? null,
                    ];
                    if ($cn !== '') {
                        $companyBySid[$sid] = $cn;
                    }
                } elseif ($cn !== '') {
                    // 无工序 id：按评分时间归月
                    $t1 = ProcuremenTime::parseToTimestamp($r['updatetime'] ?? null);
                    $t2 = ProcuremenTime::parseToTimestamp($r['createtime'] ?? null);
                    $ts = max($t1, $t2);
                    if ($ts > 946684800 && date('Y-m', $ts) === $ym) {
                        $companies[$cn] = true;
                    }
                }
            }
        }
        if ($sidSet !== []) {
            $completedYmMap = self::loadCompletedYmMapByScydgyIds(array_keys($sidSet), $inboundTimeBySid);
            $needPoNames = [];
            foreach ($completedYmMap as $sid => $rowYm) {
                if ($rowYm !== $ym) {
                    continue;
                }
                if (isset($companyBySid[$sid]) && $companyBySid[$sid] !== '') {
                    $companies[$companyBySid[$sid]] = true;
                } else {
                    $needPoNames[(int)$sid] = true;
                }
            }
            if ($needPoNames !== []) {
                try {
                    $poRows = Db::table('purchase_order')
                        ->where('scydgy_id', 'in', array_keys($needPoNames))
                        ->field('scydgy_id,pick_company_name')
                        ->select();
                } catch (\Throwable $e) {
                    $poRows = [];
                }
                if (is_array($poRows)) {
                    foreach ($poRows as $po) {
                        if (!is_array($po)) {
                            continue;
                        }
                        $cn = trim((string)($po['pick_company_name'] ?? ''));
                        if ($cn !== '') {
                            $companies[$cn] = true;
                        }
                    }
                }
            }
        }
        // 3) 并入当月有询价明细的供应商（增值服务未报价统计）
        try {
            $detailRows = Db::table('purchase_order_detail')
                ->alias('d')
                ->join('purchase_order po', 'po.scydgy_id = d.scydgy_id')
                ->whereRaw(
                    "("
                    . "CASE "
                    . "WHEN po.createtime IS NOT NULL AND CAST(po.createtime AS CHAR(32)) REGEXP '^[0-9]{10,}$' "
                    . "THEN FROM_UNIXTIME(CAST(po.createtime AS UNSIGNED)) "
                    . "WHEN po.createtime IS NOT NULL AND TRIM(CAST(po.createtime AS CHAR(32))) <> '' "
                    . "AND TRIM(CAST(po.createtime AS CHAR(32))) NOT LIKE '0000-00-00%' "
                    . "THEN TRIM(CAST(po.createtime AS CHAR(32))) "
                    . "ELSE TRIM(CAST(IFNULL(po.dStamp, '') AS CHAR(32))) "
                    . "END"
                    . ") LIKE '{$ymEsc}-%'"
                )
                ->field('d.company_name')
                ->group('d.company_name')
                ->select();
        } catch (\Throwable $e) {
            $detailRows = [];
        }
        if (is_array($detailRows)) {
            foreach ($detailRows as $dr) {
                if (!is_array($dr)) {
                    continue;
                }
                $cn = trim((string)($dr['company_name'] ?? ''));
                if ($cn !== '') {
                    $companies[$cn] = true;
                }
            }
        }
        // 4) 月度表已有行：重算时可清掉错月残留
        try {
            $finalRows = Db::table(self::TABLE_FINAL)
                ->where('ym', $ym)
                ->field('company_name')
                ->select();
        } catch (\Throwable $e) {
            $finalRows = [];
        }
        if (is_array($finalRows)) {
            foreach ($finalRows as $fr) {
                if (!is_array($fr)) {
                    continue;
                }
                $cn = trim((string)($fr['company_name'] ?? ''));
                if ($cn !== '') {
                    $companies[$cn] = true;
                }
            }
        }

        return array_keys($companies);
    }

    /**
     * 按新月度规则重算四项得分 + 最终分/等级（满分 105）
     * 已手工保存（qp_manual=1）的供应商跳过
     *
     * @param string|null $onlyCompany 仅同步该供应商；null=当月相关全部
     * @return array{updated:int,skipped:int}
     */
    public static function syncMonthlyReviewScoresFromRules(string $ym, ?string $onlyCompany = null): array
    {
        $ym = self::formatScoreYm($ym);
        $result = ['updated' => 0, 'skipped' => 0];
        if ($ym === '') {
            return $result;
        }
        self::ensureFinalScoreTable();
        self::repairInboundScoreFromOperLogs($ym);
        $companies = self::collectMonthlyReviewCompanyNames($ym, $onlyCompany);
        if ($companies === []) {
            return $result;
        }
        self::ensureMonthlySupplierNames($ym, $companies);
        $now = date('Y-m-d H:i:s');
        foreach ($companies as $cn) {
            $cn = trim((string)$cn);
            if ($cn === '') {
                continue;
            }
            try {
                $exists = Db::table(self::TABLE_FINAL)->where('ym', $ym)->where('company_name', $cn)->find();
                if (is_array($exists) && $exists !== [] && (int)($exists['qp_manual'] ?? 0) === 1) {
                    $result['skipped']++;
                    continue;
                }
                $quality = self::calcQualityScoreFromInbound($cn, $ym);
                $price = self::calcPriceScoreFromCeiling($cn, $ym);
                $delivery = self::calcDeliveryScoreFromInbound($cn, $ym);
                // 与「本月订单明细」一致：当月无完结/入库评分订单时，增值也不单独给分
                $valueAdded = null;
                if ($quality !== null || $price !== null || $delivery !== null) {
                    $valueAdded = self::calcValueAddedScoreFromUnquoted($cn, $ym);
                }
                $final = self::sumFinalScore($quality, $price, $delivery, $valueAdded);
                $grade = $final !== null ? self::gradeFromFinalScore($final) : '';
                $scoreCompat = $final !== null ? $final : 0.0;
                if (!is_array($exists) || $exists === []) {
                    Db::table(self::TABLE_FINAL)->insert([
                        'ym'                => $ym,
                        'company_name'      => $cn,
                        'score'             => $scoreCompat,
                        'quality_score'     => $quality,
                        'price_score'       => $price,
                        'delivery_score'    => $delivery,
                        'value_added_score' => $valueAdded,
                        'final_score'       => $final,
                        'score_grade'       => $grade,
                        'qp_manual'         => 0,
                        'createtime'        => $now,
                        'updatetime'        => $now,
                    ]);
                } else {
                    Db::table(self::TABLE_FINAL)->where('id', (int)($exists['id'] ?? 0))->update([
                        'score'             => $scoreCompat,
                        'quality_score'     => $quality,
                        'price_score'       => $price,
                        'delivery_score'    => $delivery,
                        'value_added_score' => $valueAdded,
                        'final_score'       => $final,
                        'score_grade'       => $grade,
                        'updatetime'        => $now,
                    ]);
                }
                $result['updated']++;
            } catch (\Throwable $e) {
                Log::write('syncMonthlyReviewScoresFromRules write: ' . $e->getMessage(), 'error');
            }
        }

        return $result;
    }

    /**
     * 兼容旧入口：改为按月度四项规则同步
     *
     * @param string|null $onlyCompany 仅同步该供应商；null=当月相关全部
     */
    public static function syncQualityScoreFromInbound(string $ym, ?string $onlyCompany = null): void
    {
        self::syncMonthlyReviewScoresFromRules($ym, $onlyCompany);
    }

    /**
     * 操作日志有入库评分、评分表缺失时，回填 purchase_order_inbound_score
     */
    public static function repairInboundScoreFromOperLogs(string $ym): void
    {
        $ym = self::formatScoreYm($ym);
        if ($ym === '') {
            return;
        }
        try {
            $logs = Db::table('purchase_order_oper_log')
                ->where(function ($q) {
                    $q->where('action', '入库评分')->whereOr('action', 'inbound_score');
                })
                ->where('createtime', 'like', $ym . '%')
                ->field('scydgy_id,content,createtime,admin_id,admin_name,purchase_order_id')
                ->order('id', 'asc')
                ->select();
        } catch (\Throwable $e) {
            return;
        }
        if (!is_array($logs) || $logs === []) {
            return;
        }
        $best = [];
        foreach ($logs as $lg) {
            if (!is_array($lg)) {
                continue;
            }
            $sid = (int)($lg['scydgy_id'] ?? 0);
            if ($sid <= 0) {
                continue;
            }
            $content = trim((string)($lg['content'] ?? ''));
            if (!preg_match('/(合格|不合格)/u', $content, $m)) {
                continue;
            }
            $best[$sid] = [
                'result'            => $m[1],
                'createtime'        => trim((string)($lg['createtime'] ?? '')),
                'admin_id'          => (int)($lg['admin_id'] ?? 0),
                'admin_name'        => trim((string)($lg['admin_name'] ?? '')),
                'purchase_order_id' => (int)($lg['purchase_order_id'] ?? 0),
            ];
        }
        if ($best === []) {
            return;
        }
        try {
            $existRows = Db::table('purchase_order_inbound_score')
                ->where('scydgy_id', 'in', array_keys($best))
                ->field('scydgy_id')
                ->select();
        } catch (\Throwable $e) {
            return;
        }
        $existSids = [];
        if (is_array($existRows)) {
            foreach ($existRows as $er) {
                if (is_array($er)) {
                    $existSids[(int)($er['scydgy_id'] ?? 0)] = true;
                }
            }
        }
        $needSids = [];
        foreach (array_keys($best) as $sid) {
            if (empty($existSids[$sid])) {
                $needSids[] = $sid;
            }
        }
        if ($needSids === []) {
            return;
        }
        try {
            $poRows = Db::table('purchase_order')
                ->where('scydgy_id', 'in', $needSids)
                ->field('id,scydgy_id,CCYDH,CYJMC,CGYMC,pick_company_name')
                ->select();
        } catch (\Throwable $e) {
            return;
        }
        if (!is_array($poRows)) {
            return;
        }
        foreach ($poRows as $po) {
            if (!is_array($po)) {
                continue;
            }
            $sid = (int)($po['scydgy_id'] ?? 0);
            if ($sid <= 0 || empty($best[$sid])) {
                continue;
            }
            $b = $best[$sid];
            $now = $b['createtime'] !== '' ? $b['createtime'] : date('Y-m-d H:i:s');
            $data = [
                'scydgy_id'         => $sid,
                'purchase_order_id' => (int)($po['id'] ?? 0) > 0 ? (int)$po['id'] : (int)$b['purchase_order_id'],
                'ccydh'             => trim((string)($po['CCYDH'] ?? '')),
                'cyjmc'             => trim((string)($po['CYJMC'] ?? '')),
                'cgymc'             => trim((string)($po['CGYMC'] ?? '')),
                'company_name'      => trim((string)($po['pick_company_name'] ?? '')),
                'result'            => $b['result'],
                'admin_id'          => (int)$b['admin_id'],
                'admin_name'        => (string)$b['admin_name'],
                'createtime'        => $now,
                'updatetime'        => $now,
            ];
            if ($data['company_name'] === '' || $data['ccydh'] === '') {
                continue;
            }
            try {
                Db::table('purchase_order_inbound_score')->insert($data);
            } catch (\Throwable $e) {
                // 唯一键冲突忽略
                if (stripos($e->getMessage(), 'Duplicate') === false) {
                    Log::write('repairInboundScoreFromOperLogs: ' . $e->getMessage(), 'error');
                }
            }
        }
    }

    /**
     * 读取某月评审记录（仅读月度表）
     *
     * @param bool $resync true=先补齐供应商并按规则重算；false=只读库（导出用，避免卡顿）
     * @return array<string, array{score:float,quality_score:?float,price_score:?float,delivery_score:?float,final_score:?float,final_saved:int,score_grade:string,score_date:string}>
     */
    public static function loadMonthlyMapByYm(string $ym, bool $resync = true): array
    {
        $ym = trim($ym);
        if (!preg_match('/^\d{4}-\d{2}$/', $ym)) {
            return [];
        }
        self::ensureFinalScoreTable();
        if ($resync) {
            // 本月询价（开标后已写入订单评分表）的供应商：名称不存在则加空行，已存在不动
            self::ensureMonthlySupplierNamesFromOrderYm($ym);
            // 按月度规则重算质量/价格/交货/增值（满分105；qp_manual=1 跳过）
            self::syncMonthlyReviewScoresFromRules($ym);
        }
        try {
            $rows = Db::table(self::TABLE_FINAL)
                ->where('ym', $ym)
                ->field('company_name,score,quality_score,price_score,delivery_score,value_added_score,final_score,score_grade,ym')
                ->select();
        } catch (\Throwable $e) {
            return [];
        }
        if (!is_array($rows)) {
            return [];
        }
        $out = [];
        foreach ($rows as $r) {
            if (!is_array($r)) {
                continue;
            }
            $cn = trim((string)($r['company_name'] ?? $r['Company_name'] ?? ''));
            if ($cn === '') {
                continue;
            }
            $quality = self::readOptionalScoreValue($r['quality_score'] ?? null);
            $price = self::readOptionalScoreValue($r['price_score'] ?? null);
            $delivery = self::readOptionalScoreValue($r['delivery_score'] ?? null);
            $valueAdded = self::readOptionalScoreValue($r['value_added_score'] ?? null);
            $final = self::readOptionalScoreValue($r['final_score'] ?? null);
            $out[$cn] = [
                'score'              => round((float)($r['score'] ?? 0), 2),
                'quality_score'      => $quality,
                'price_score'        => $price,
                'delivery_score'     => $delivery,
                'value_added_score'  => $valueAdded,
                'final_score'        => $final,
                'final_saved'        => $final !== null ? 1 : 0,
                'score_grade'        => self::normalizeScoreGrade($r['score_grade'] ?? ''),
                // 列表「日期」列按 ym（YYYY-MM）展示，不到日
                'score_date'         => self::formatScoreYm($r['ym'] ?? $ym),
            ];
        }

        return $out;
    }

    /**
     * 规范为 YYYY-MM（月度评审日期）
     *
     * @param mixed $raw
     */
    public static function formatScoreYm($raw): string
    {
        $raw = trim((string)$raw);
        if (preg_match('/^\d{4}-\d{2}$/', $raw)) {
            return $raw;
        }
        if (preg_match('/^(\d{4})\D+(\d{1,2})/', $raw, $m)) {
            return sprintf('%04d-%02d', (int)$m[1], (int)$m[2]);
        }

        return '';
    }

    /**
     * @param mixed $raw
     */
    public static function formatScoreDateYmd($raw): string
    {
        $raw = trim((string)$raw);
        if ($raw === '' || stripos($raw, '0000-00-00') === 0) {
            return '';
        }
        $ts = strtotime(str_replace('T', ' ', $raw));

        return ($ts !== false && $ts > 0) ? date('Y-m-d', $ts) : '';
    }

    /**
     * 解析可选分数：空=null；非法=false；合法=float
     *
     * @param mixed $raw
     * @return float|null|false
     */
    protected static function parseOptionalScore($raw)
    {
        if ($raw === null) {
            return null;
        }
        if (is_string($raw) && trim($raw) === '') {
            return null;
        }
        if (!is_numeric($raw)) {
            return false;
        }

        return round((float)$raw, 2);
    }

    /**
     * 批量保存某月评审分：商务技术分 / 价格分 / 交货分 / 最终得分 / 评分等级
     *
     * @param array<int, array{company_name?:string,quality_score?:mixed,price_score?:mixed,delivery_score?:mixed,final_score?:mixed,score_grade?:mixed}> $items
     * @return array{done:int,saved:int,cleared:int,error:string}
     */
    public static function saveFinalScoresForYm(string $ym, array $items): array
    {
        $ym = trim($ym);
        $result = ['done' => 0, 'saved' => 0, 'cleared' => 0, 'error' => ''];
        if (!preg_match('/^\d{4}-\d{2}$/', $ym)) {
            $result['error'] = '月份无效';

            return $result;
        }
        if ($items === []) {
            $result['error'] = '没有可保存的数据';

            return $result;
        }
        self::ensureFinalScoreTable();
        try {
            Db::query('SELECT 1 FROM `' . self::TABLE_FINAL . '` LIMIT 1');
        } catch (\Throwable $e) {
            $result['error'] = '月度汇总表未创建，请联系管理员';

            return $result;
        }
        $now = date('Y-m-d H:i:s');
        foreach ($items as $it) {
            if (!is_array($it)) {
                continue;
            }
            $cn = trim((string)($it['company_name'] ?? ''));
            if ($cn === '') {
                continue;
            }
            $grade = self::normalizeScoreGrade($it['score_grade'] ?? '');
            $quality = self::parseOptionalScore($it['quality_score'] ?? null);
            $price = self::parseOptionalScore($it['price_score'] ?? null);
            $delivery = self::parseOptionalScore($it['delivery_score'] ?? null);
            $valueAdded = self::parseOptionalScore($it['value_added_score'] ?? null);
            $final = self::parseOptionalScore($it['final_score'] ?? null);
            if ($quality === false || $price === false || $delivery === false || $valueAdded === false || $final === false) {
                continue;
            }
            // 未填最终得分时，按四项自动汇总
            if ($final === null) {
                $final = self::sumFinalScore($quality, $price, $delivery, $valueAdded);
            }
            // 未选等级时，按最终得分自动定级
            if ($grade === '' && $final !== null) {
                $grade = self::gradeFromFinalScore($final);
            }
            $hasQp = array_key_exists('quality_score', $it)
                || array_key_exists('price_score', $it)
                || array_key_exists('delivery_score', $it)
                || array_key_exists('value_added_score', $it);
            $hasAny = $final !== null || $grade !== ''
                || $quality !== null || $price !== null || $delivery !== null || $valueAdded !== null;
            // 全空行不写入，避免误把未改供应商标成手工锁定
            if (!$hasAny) {
                continue;
            }
            try {
                $exists = Db::table(self::TABLE_FINAL)->where('ym', $ym)->where('company_name', $cn)->find();
                $upd = [
                    'final_score' => $final,
                    'score_grade' => $grade,
                    'updatetime'  => $now,
                    // 保存即视为手工确认，之后不再跑查询计算规则覆盖
                    'qp_manual'   => 1,
                ];
                if ($hasQp) {
                    // 空值存 NULL，列表显示空白而不是 0
                    $upd['quality_score'] = $quality;
                    $upd['price_score'] = $price;
                    $upd['delivery_score'] = $delivery;
                    $upd['value_added_score'] = $valueAdded;
                    $upd['score'] = self::sumFinalScore($quality, $price, $delivery, $valueAdded) ?? 0;
                }
                if (is_array($exists) && $exists !== []) {
                    Db::table(self::TABLE_FINAL)->where('id', (int)($exists['id'] ?? 0))->update($upd);
                } else {
                    Db::table(self::TABLE_FINAL)->insert([
                        'ym'                => $ym,
                        'company_name'      => $cn,
                        'score'             => $hasQp ? (self::sumFinalScore($quality, $price, $delivery, $valueAdded) ?? 0) : 0,
                        'quality_score'     => $hasQp ? $quality : null,
                        'price_score'       => $hasQp ? $price : null,
                        'delivery_score'    => $hasQp ? $delivery : null,
                        'value_added_score' => $hasQp ? $valueAdded : null,
                        'final_score'       => $final,
                        'score_grade'       => $grade,
                        'qp_manual'         => 1,
                        'createtime'        => $now,
                        'updatetime'        => $now,
                    ]);
                }
                if ($final === null && $grade === '' && !$hasQp) {
                    $result['cleared']++;
                } else {
                    $result['saved']++;
                }
                $result['done']++;
            } catch (\Throwable $e) {
                Log::write('supplier final score save: ' . $e->getMessage(), 'error');
                $result['error'] = $e->getMessage();
            }
        }

        return $result;
    }

    /** 历史表补质量/价格百分比字段 */
    protected static function ensureScoreWeightColumns(): void
    {
        try {
            $cols = Db::query("SHOW COLUMNS FROM `" . self::TABLE_SCORE . "` LIKE 'quality_weight'");
            if (!is_array($cols) || $cols === []) {
                Db::execute(
                    "ALTER TABLE `" . self::TABLE_SCORE . "` ADD COLUMN `quality_weight` int unsigned NOT NULL DEFAULT 50 COMMENT '质量百分比' AFTER `quality_score`"
                );
            }
            $cols2 = Db::query("SHOW COLUMNS FROM `" . self::TABLE_SCORE . "` LIKE 'price_weight'");
            if (!is_array($cols2) || $cols2 === []) {
                Db::execute(
                    "ALTER TABLE `" . self::TABLE_SCORE . "` ADD COLUMN `price_weight` int unsigned NOT NULL DEFAULT 50 COMMENT '价格百分比' AFTER `price_sum`"
                );
            }
        } catch (\Throwable $e) {
            Log::write('supplier score weight columns: ' . $e->getMessage(), 'error');
        }
    }

    /** 历史表补交货期权重/得分字段 */
    protected static function ensureLeadColumns(): void
    {
        $adds = [
            self::TABLE_RULE => [
                'lead_weight'  => "ADD COLUMN `lead_weight` int unsigned NOT NULL DEFAULT 0 COMMENT '交货期得分权重(%)' AFTER `price_weight`",
            ],
            self::TABLE_SCORE => [
                'lead_days_sum' => "ADD COLUMN `lead_days_sum` int NOT NULL DEFAULT 0 COMMENT '本单工序工期合计(天)' AFTER `price_score`",
                'lead_weight'   => "ADD COLUMN `lead_weight` int unsigned NOT NULL DEFAULT 0 COMMENT '交货期百分比' AFTER `lead_days_sum`",
                'lead_enabled'  => "ADD COLUMN `lead_enabled` tinyint unsigned NOT NULL DEFAULT 0 COMMENT '1=当时纳入总分' AFTER `lead_weight`",
                'lead_score'    => "ADD COLUMN `lead_score` decimal(10,2) NOT NULL DEFAULT 0.00 COMMENT '交货期评分值' AFTER `lead_enabled`",
            ],
        ];
        foreach ($adds as $table => $cols) {
            foreach ($cols as $col => $ddl) {
                try {
                    $info = Db::query("SHOW COLUMNS FROM `{$table}` LIKE '{$col}'");
                    if (is_array($info) && $info !== []) {
                        continue;
                    }
                    Db::execute("ALTER TABLE `{$table}` {$ddl}");
                } catch (\Throwable $e) {
                    Log::write("supplier score lead column {$table}.{$col}: " . $e->getMessage(), 'error');
                }
            }
        }
    }

    /** 将权重/质量分/单价合计等字段改为整数（去掉 .00） */
    protected static function ensureIntegerColumns(): void
    {
        $defs = [
            self::TABLE_RULE => [
                'quality_weight' => "int unsigned NOT NULL DEFAULT 50 COMMENT '上年度质量评分权重(%)'",
                'price_weight'   => "int unsigned NOT NULL DEFAULT 50 COMMENT '单价评分权重(%)'",
                'lead_weight'    => "int unsigned NOT NULL DEFAULT 0 COMMENT '交货期得分权重(%)'",
            ],
            self::TABLE_SCORE => [
                'quality_score'  => "int NOT NULL DEFAULT 0 COMMENT '上年度质量评分'",
                'quality_weight' => "int unsigned NOT NULL DEFAULT 50 COMMENT '质量百分比'",
                'price_weight'   => "int unsigned NOT NULL DEFAULT 50 COMMENT '价格百分比'",
                'lead_days_sum'  => "int NOT NULL DEFAULT 0 COMMENT '本单工序工期合计(天)'",
                'lead_weight'    => "int unsigned NOT NULL DEFAULT 0 COMMENT '交货期百分比'",
            ],
        ];
        foreach ($defs as $table => $cols) {
            foreach ($cols as $col => $def) {
                try {
                    $info = Db::query("SHOW COLUMNS FROM `{$table}` LIKE '{$col}'");
                    if (!is_array($info) || $info === []) {
                        continue;
                    }
                    $type = strtolower((string)($info[0]['Type'] ?? $info[0]['type'] ?? ''));
                    if (preg_match('/^(tiny|small|medium|big)?int\b/', $type)) {
                        continue;
                    }
                    Db::execute("ALTER TABLE `{$table}` MODIFY COLUMN `{$col}` {$def}");
                } catch (\Throwable $e) {
                    Log::write("supplier score int column {$table}.{$col}: " . $e->getMessage(), 'error');
                }
            }
        }
        // 单价合计需保留小数（如 0.25），不可用 int
        try {
            $info = Db::query("SHOW COLUMNS FROM `" . self::TABLE_SCORE . "` LIKE 'price_sum'");
            if (is_array($info) && $info !== []) {
                $type = strtolower((string)($info[0]['Type'] ?? $info[0]['type'] ?? ''));
                if (preg_match('/^(tiny|small|medium|big)?int\b/', $type)) {
                    Db::execute(
                        "ALTER TABLE `" . self::TABLE_SCORE . "` MODIFY COLUMN `price_sum` decimal(12,4) NOT NULL DEFAULT 0.0000 COMMENT '本单工序单价合计'"
                    );
                }
            }
        } catch (\Throwable $e) {
            Log::write('supplier score price_sum decimal: ' . $e->getMessage(), 'error');
        }
    }

    protected static function ensureDefaultRule(): void
    {
        self::ensureRuleNameColumn();
        self::ensureOrderTypeRules();
    }

    /**
     * 规则表去掉页面未用字段：lead_enabled、status
     * （交期是否纳入由 lead_weight>0 判断；删除用物理删除）
     */
    protected static function dropObsoleteRuleColumns(): void
    {
        static $done = false;
        if ($done) {
            return;
        }
        $done = true;
        foreach (['lead_enabled', 'status'] as $col) {
            try {
                $cols = Db::query('SHOW COLUMNS FROM `' . self::TABLE_RULE . '` LIKE \'' . $col . '\'');
                if (is_array($cols) && $cols !== []) {
                    Db::execute('ALTER TABLE `' . self::TABLE_RULE . '` DROP COLUMN `' . $col . '`');
                }
            } catch (\Throwable $e) {
                Log::write('supplier_score_rule drop ' . $col . ': ' . $e->getMessage(), 'error');
            }
        }
    }

    /**
     * 规则表补「规则名称/订单类型」字段（历史库可能缺此列）
     */
    protected static function ensureRuleNameColumn(): void
    {
        static $done = false;
        if ($done) {
            return;
        }
        try {
            $cols = Db::query('SHOW COLUMNS FROM `' . self::TABLE_RULE . '` LIKE \'name\'');
            if (!is_array($cols) || $cols === []) {
                Db::execute(
                    'ALTER TABLE `' . self::TABLE_RULE . '` ADD COLUMN `name` varchar(100) NOT NULL DEFAULT \'\' COMMENT \'规则名称/订单类型\' AFTER `id`'
                );
                $cols = Db::query('SHOW COLUMNS FROM `' . self::TABLE_RULE . '` LIKE \'name\'');
            }
            if (is_array($cols) && $cols !== []) {
                $done = true;
            }
        } catch (\Throwable $e) {
            Log::write('supplier_score_rule.name: ' . $e->getMessage(), 'error');
        }
    }

    /**
     * 写入/对齐「不同订单供应商评分权重方案」三条规则
     */
    protected static function ensureOrderTypeRules(): void
    {
        static $done = false;
        if ($done) {
            return;
        }
        try {
            if (\think\Cache::get('procuremen_supplier_order_type_rules_ok_v1')) {
                $done = true;

                return;
            }
        } catch (\Throwable $e) {
        }
        self::ensureRuleNameColumn();
        $schemes = [
            [
                'name'           => '普通订单（价格优先）',
                'quality_weight' => 30,
                'price_weight'   => 50,
                'lead_weight'    => 20,
            ],
            [
                'name'           => '急单（交期优先）',
                'quality_weight' => 30,
                'price_weight'   => 20,
                'lead_weight'    => 50,
            ],
            [
                'name'           => '重点产品（质量优先）',
                'quality_weight' => 50,
                'price_weight'   => 20,
                'lead_weight'    => 30,
            ],
        ];
        $now = date('Y-m-d H:i:s');
        try {
            // 确认 name 列已存在再继续
            $cols = Db::query('SHOW COLUMNS FROM `' . self::TABLE_RULE . '` LIKE \'name\'');
            if (!is_array($cols) || $cols === []) {
                Log::write('supplier_score_rule.name still missing, skip seed', 'error');

                return;
            }
            foreach ($schemes as $s) {
                $exist = Db::table(self::TABLE_RULE)->where('name', $s['name'])->find();
                if (!is_array($exist)) {
                    // 兼容旧数据：无 name 时按三档百分比匹配
                    $exist = Db::table(self::TABLE_RULE)
                        ->where('quality_weight', (int)$s['quality_weight'])
                        ->where('price_weight', (int)$s['price_weight'])
                        ->where('lead_weight', (int)$s['lead_weight'])
                        ->where(function ($q) {
                            $q->whereNull('name')->whereOr('name', '');
                        })
                        ->order('id', 'asc')
                        ->find();
                }
                $payload = [
                    'name'           => $s['name'],
                    'quality_weight' => (int)$s['quality_weight'],
                    'price_weight'   => (int)$s['price_weight'],
                    'lead_weight'    => (int)$s['lead_weight'],
                    'updatetime'     => $now,
                ];
                if (is_array($exist)) {
                    // 已存在：只补空名称，不覆盖人工改过的权重
                    $existName = trim((string)($exist['name'] ?? ''));
                    if ($existName === '') {
                        Db::table(self::TABLE_RULE)->where('id', (int)$exist['id'])->update([
                            'name'       => $s['name'],
                            'updatetime' => $now,
                        ]);
                    }
                } else {
                    $payload['is_default'] = 0;
                    $payload['createtime'] = $now;
                    Db::table(self::TABLE_RULE)->insert($payload);
                }
            }
            // 非方案内的旧行直接删除，列表只保留三条
            $names = [];
            foreach ($schemes as $s) {
                $names[] = $s['name'];
            }
            $nameIn = "'" . implode("','", array_map('addslashes', $names)) . "'";
            Db::execute(
                'DELETE FROM `' . self::TABLE_RULE . '` '
                . 'WHERE `name` NOT IN (' . $nameIn . ') OR `name` IS NULL OR `name`=\'\''
            );

            $hasDefault = Db::table(self::TABLE_RULE)->where('is_default', 1)->find();
            if (!is_array($hasDefault)) {
                $def = Db::table(self::TABLE_RULE)->where('name', '普通订单（价格优先）')->find();
                if (!is_array($def)) {
                    $def = Db::table(self::TABLE_RULE)->order('id', 'asc')->find();
                }
                if (is_array($def)) {
                    Db::table(self::TABLE_RULE)->where('id', (int)$def['id'])->update([
                        'is_default' => 1,
                        'updatetime' => $now,
                    ]);
                }
            }
            $done = true;
            try {
                \think\Cache::set('procuremen_supplier_order_type_rules_ok_v1', 1, 86400);
            } catch (\Throwable $e) {
            }
        } catch (\Throwable $e) {
            Log::write('supplier score ensureOrderTypeRules: ' . $e->getMessage(), 'error');
        }
    }

    /**
     * 下拉用：正常状态的评分规则（订单类型）
     *
     * @return array<int, array{id:int,name:string,label:string,quality_weight:int,price_weight:int,lead_weight:int,is_default:int}>
     */
    public static function listRulesForSelect(): array
    {
        self::ensureSchema();
        $out = [];
        try {
            $rows = Db::table(self::TABLE_RULE)
                ->order('is_default', 'desc')
                ->order('id', 'asc')
                ->select();
            if (!is_array($rows)) {
                return $out;
            }
            foreach ($rows as $row) {
                if (!is_array($row)) {
                    continue;
                }
                $name = trim((string)($row['name'] ?? ''));
                if ($name === '') {
                    continue;
                }
                $qw = (int)($row['quality_weight'] ?? 0);
                $pw = (int)($row['price_weight'] ?? 0);
                $lw = (int)($row['lead_weight'] ?? 0);
                $out[] = [
                    'id'             => (int)($row['id'] ?? 0),
                    'name'           => $name,
                    'label'          => $name . '｜质量' . $qw . '%｜价格' . $pw . '%｜交期' . $lw . '%',
                    'quality_weight' => $qw,
                    'price_weight'   => $pw,
                    'lead_weight'    => $lw,
                    'is_default'     => !empty($row['is_default']) ? 1 : 0,
                ];
            }
        } catch (\Throwable $e) {
        }

        return $out;
    }

    /**
     * 按订单号解析评分规则：优先下发时写入的权重快照，否则按 score_rule_id 读规则表，再否则默认
     *
     * @return array{id:int,name:string,quality_weight:int,price_weight:int,lead_weight:int,lead_enabled:int}
     */
    public static function resolveRuleForCcydh(string $ccydh, ?array $poHint = null): array
    {
        $ccydh = trim($ccydh);
        if ($ccydh === '' && (!is_array($poHint) || $poHint === [])) {
            return self::getDefaultRule();
        }
        try {
            $po = is_array($poHint) && $poHint !== [] ? $poHint : null;
            if ($po === null && $ccydh !== '') {
                self::ensureSchema();
                $po = Db::table('purchase_order')->where('CCYDH', $ccydh)->order('id', 'desc')->find();
            }
            if (is_array($po)) {
                $ruleId = (int)($po['score_rule_id'] ?? 0);
                $qw = (int)($po['score_quality_weight'] ?? 0);
                $pw = (int)($po['score_price_weight'] ?? 0);
                $lw = (int)($po['score_lead_weight'] ?? 0);
                // 下发时已快照：开标/展示一律用快照，不受后续规则修改影响（无需 ensureSchema）
                if ($ruleId > 0 && ($qw + $pw + $lw) > 0) {
                    $name = trim((string)($po['score_rule_name'] ?? ''));
                    if ($name === '') {
                        $live = self::getRuleById($ruleId);
                        $name = (string)($live['name'] ?? '');
                    }

                    return [
                        'id'             => $ruleId,
                        'name'           => $name,
                        'quality_weight' => max(0, $qw),
                        'price_weight'   => max(0, $pw),
                        'lead_weight'    => max(0, $lw),
                        'lead_enabled'   => $lw > 0 ? 1 : 0,
                    ];
                }
                if ($ruleId > 0) {
                    $rule = self::getRuleById($ruleId);
                    if ((int)($rule['id'] ?? 0) > 0) {
                        return $rule;
                    }
                }
            }
        } catch (\Throwable $e) {
        }

        return self::getDefaultRule();
    }

    /**
     * @return array{id:int,name:string,quality_weight:int,price_weight:int,lead_weight:int,lead_enabled:int}
     */
    public static function getRuleById(int $id): array
    {
        if ($id <= 0) {
            return self::getDefaultRule();
        }
        self::ensureSchema();
        try {
            $row = Db::table(self::TABLE_RULE)
                ->where('id', $id)
                ->find();
            if (is_array($row)) {
                $lw = (int)($row['lead_weight'] ?? 0);

                return [
                    'id'             => (int)($row['id'] ?? 0),
                    'name'           => trim((string)($row['name'] ?? '')),
                    'quality_weight' => (int)($row['quality_weight'] ?? 50),
                    'price_weight'   => (int)($row['price_weight'] ?? 50),
                    'lead_weight'    => $lw,
                    'lead_enabled'   => $lw > 0 ? 1 : 0,
                ];
            }
        } catch (\Throwable $e) {
        }

        return self::getDefaultRule();
    }

    /**
     * @return array{id:int,name:string,quality_weight:int,price_weight:int,lead_weight:int,lead_enabled:int}
     */
    public static function getDefaultRule(): array
    {
        self::ensureSchema();
        try {
            $row = Db::table(self::TABLE_RULE)
                ->where('is_default', 1)
                ->order('id', 'desc')
                ->find();
            if (!is_array($row)) {
                $row = Db::table(self::TABLE_RULE)->order('id', 'asc')->find();
            }
            if (is_array($row)) {
                $lw = (int)($row['lead_weight'] ?? 0);

                return [
                    'id'             => (int)($row['id'] ?? 0),
                    'name'           => trim((string)($row['name'] ?? '')),
                    'quality_weight' => (int)($row['quality_weight'] ?? 50),
                    'price_weight'   => (int)($row['price_weight'] ?? 50),
                    'lead_weight'    => $lw,
                    'lead_enabled'   => $lw > 0 ? 1 : 0,
                ];
            }
        } catch (\Throwable $e) {
        }

        return [
            'id'             => 0,
            'name'           => '内置默认',
            'quality_weight' => 50,
            'price_weight'   => 50,
            'lead_weight'    => 0,
            'lead_enabled'   => 0,
        ];
    }

    /**
     * 规范年月；空则取当前月
     */
    public static function normalizeYm(?string $ym): string
    {
        $ym = trim((string)$ym);
        if (preg_match('/^\d{4}-\d{2}$/', $ym)) {
            return $ym;
        }

        return date('Y-m');
    }

    /**
     * 上一自然月 YYYY-MM
     */
    public static function previousYm(string $ym): string
    {
        $ym = self::normalizeYm($ym);
        $ts = strtotime($ym . '-01');
        if ($ts === false) {
            $ts = time();
        }

        return date('Y-m', strtotime('-1 month', $ts));
    }

    /**
     * 从月度评审表取指定分项：当月按上月起往前查，都没有则默认 50
     *
     * @param array<int, string> $companyNames
     * @param 'quality_score'|'delivery_score' $field
     * @return array<string, float> company_name => score
     */
    protected static function loadReviewFieldScoreMap(array $companyNames, string $field, ?string $asOfYm = null): array
    {
        $asOfYm = self::normalizeYm($asOfYm);
        $default = 50.0;
        $map = [];
        $names = [];
        foreach ($companyNames as $n) {
            $n = trim((string)$n);
            if ($n !== '') {
                $names[$n] = true;
                $map[$n] = $default;
            }
        }
        if ($names === [] || !in_array($field, ['quality_score', 'delivery_score'], true)) {
            return $map;
        }
        self::ensureFinalScoreTable();
        try {
            // 当月按上个月起查：ym < asOfYm，且该分项已填写
            $rows = Db::table(self::TABLE_FINAL)
                ->where('company_name', 'in', array_keys($names))
                ->where('ym', '<', $asOfYm)
                ->whereNotNull($field)
                ->field('company_name,ym,' . $field)
                ->order('ym', 'desc')
                ->select();
        } catch (\Throwable $e) {
            return $map;
        }
        if (!is_array($rows)) {
            return $map;
        }
        $seen = [];
        foreach ($rows as $r) {
            if (!is_array($r)) {
                continue;
            }
            $cn = trim((string)($r['company_name'] ?? ''));
            if ($cn === '' || isset($seen[$cn])) {
                continue;
            }
            $score = self::readOptionalScoreValue($r[$field] ?? null);
            if ($score === null) {
                continue;
            }
            $seen[$cn] = true;
            $map[$cn] = round((float)$score, 2);
        }

        return $map;
    }

    /**
     * 从月度评审表取质量得分：当月按上月起往前查，都没有则默认 50
     *
     * @param array<int, string> $companyNames
     * @return array<string, float> company_name => quality_score
     */
    public static function loadReviewQualityScoreMap(array $companyNames, ?string $asOfYm = null): array
    {
        return self::loadReviewFieldScoreMap($companyNames, 'quality_score', $asOfYm);
    }

    /**
     * 从月度评审表取交货得分：当月按上月起往前查，都没有则默认 50（与质量得分口径一致）
     *
     * @param array<int, string> $companyNames
     * @return array<string, float> company_name => delivery_score
     */
    public static function loadReviewDeliveryScoreMap(array $companyNames, ?string $asOfYm = null): array
    {
        return self::loadReviewFieldScoreMap($companyNames, 'delivery_score', $asOfYm);
    }

    /**
     * 按公司名批量取供应商 id（兼容旧调用保留评分字段结构）
     *
     * @param array<int, string> $companyNames
     * @return array<string, array{id:int,score:float,monthly_score:?float,quality_avg:float}>
     */
    public static function loadCustomerScoreMap(array $companyNames): array
    {
        $map = [];
        $names = [];
        foreach ($companyNames as $n) {
            $n = trim((string)$n);
            if ($n !== '') {
                $names[$n] = true;
            }
        }
        if ($names === []) {
            return $map;
        }
        try {
            $rows = Db::table('customer')
                ->where('company_name', 'in', array_keys($names))
                ->field('id,company_name')
                ->select();
        } catch (\Throwable $e) {
            return $map;
        }
        if (!is_array($rows)) {
            return $map;
        }
        foreach ($rows as $r) {
            if (!is_array($r)) {
                continue;
            }
            $cn = trim((string)($r['company_name'] ?? ''));
            if ($cn === '') {
                continue;
            }
            $map[$cn] = [
                'id'            => (int)($r['id'] ?? 0),
                'score'         => 0.0,
                'monthly_score' => null,
                'quality_avg'   => 50.0,
            ];
        }

        return $map;
    }

    /**
     * 从报价组计算本单各供应商得分（不写库）
     *
     * @param array<int, array<string, mixed>> $quoteGroups loadAuditSupplierQuoteGroups 结构（name/lines[].amount）
     * @param string|null $asOfYm 订单所属月；商务/技术分从该月的上月起往前查评审表
     * @return array<string, array{
     *   company_name:string,customer_id:int,quality_score:float,price_sum:float,
     *   price_score:float,score:float,rank_no:int,score_text:string,rank_text:string
     * }>
     */
    public static function calculateForQuoteGroups(array $quoteGroups, ?array $rule = null, ?string $asOfYm = null): array
    {
        $rule = $rule ?: self::getDefaultRule();
        $qw = max(0, (float)($rule['quality_weight'] ?? 50));
        $pw = max(0, (float)($rule['price_weight'] ?? 50));
        $lw = max(0, (float)($rule['lead_weight'] ?? 0));
        // 填 0 的权重不参与计算
        $leadEnabled = $lw > 0 ? 1 : 0;
        $wSum = $qw + $pw + $lw;
        if ($wSum <= 0) {
            $qw = 50;
            $pw = 50;
            $lw = 0;
            $leadEnabled = 0;
            $wSum = 100;
        }

        $names = [];
        foreach ($quoteGroups as $g) {
            if (!is_array($g)) {
                continue;
            }
            $cn = trim((string)($g['name'] ?? $g['company_name'] ?? ''));
            if ($cn !== '') {
                $names[] = $cn;
            }
        }
        $custMap = self::loadCustomerScoreMap($names);
        $reviewMap = self::loadReviewQualityScoreMap($names, $asOfYm);
        $deliveryMap = self::loadReviewDeliveryScoreMap($names, $asOfYm);

        $items = [];
        $priceSums = [];
        foreach ($quoteGroups as $g) {
            if (!is_array($g)) {
                continue;
            }
            $cn = trim((string)($g['name'] ?? $g['company_name'] ?? ''));
            if ($cn === '') {
                continue;
            }
            $priceSum = 0.0;
            $hasPrice = false;
            $leadSum = 0;
            $hasLead = false;
            // 确认页用 lines，审批页用 pick_lines
            $lineRows = $g['lines'] ?? $g['pick_lines'] ?? [];
            if (!is_array($lineRows)) {
                $lineRows = [];
            }
            foreach ($lineRows as $ln) {
                if (!is_array($ln)) {
                    continue;
                }
                if (empty($ln['amount_quote_pending'])) {
                    $am = self::resolveQuoteLineAmountRaw($ln);
                    if ($am !== '' && $am !== '0' && $am !== '0.00' && is_numeric($am)) {
                        $priceSum += (float)$am;
                        $hasPrice = true;
                    }
                }
                if (empty($ln['lead_days_quote_pending'])) {
                    $ldRaw = $ln['lead_days'] ?? null;
                    if ($ldRaw !== null && $ldRaw !== '' && is_numeric($ldRaw)) {
                        $ld = (int)$ldRaw;
                        if ($ld > 0) {
                            $leadSum += $ld;
                            $hasLead = true;
                        }
                    }
                }
            }
            // 质量/交货得分：月度评审表，当月按上月起往前，默认 50
            $quality = (float)($reviewMap[$cn] ?? 50);
            $deliveryScore = (float)($deliveryMap[$cn] ?? 50);
            $psum = $hasPrice ? round($priceSum, 2) : 0;
            $lsum = $hasLead ? (int)$leadSum : 0;
            $items[$cn] = [
                'company_name'         => $cn,
                'customer_id'          => (int)($custMap[$cn]['id'] ?? 0),
                'quality_score'        => $quality,
                'quality_score_text'   => self::formatScore($quality),
                'quality_weight'       => (int)$qw,
                'price_sum'            => $psum,
                'price_sum_text'       => self::formatScore($psum),
                'price_weight'         => (int)$pw,
                'has_price'            => $hasPrice,
                'price_score'          => 0.0,
                'price_score_text'     => '0',
                'lead_days_sum'        => $lsum,
                'lead_days_sum_text'   => (string)$lsum,
                'lead_weight'          => (int)$lw,
                'lead_enabled'         => $leadEnabled,
                'has_lead'             => $hasLead,
                'lead_score'           => $leadEnabled ? $deliveryScore : 0.0,
                'lead_score_text'      => $leadEnabled ? self::formatScore($deliveryScore) : '0',
                'score'                => 0.0,
                'rank_no'              => 0,
                'score_text'           => '',
                'rank_text'            => '',
            ];
            if ($hasPrice && $priceSum > 0) {
                $priceSums[$cn] = $priceSum;
            }
        }

        $minSum = null;
        foreach ($priceSums as $ps) {
            if ($minSum === null || $ps < $minSum) {
                $minSum = $ps;
            }
        }
        foreach ($items as $cn => &$it) {
            // 单价未填写：价格得分与总分均为 0
            if ($pw > 0 && (empty($it['has_price']) || (float)($it['price_sum'] ?? 0) <= 0)) {
                $it['price_score'] = 0.0;
                $it['price_score_text'] = '0';
                $it['lead_score'] = 0.0;
                $it['lead_score_text'] = self::formatScore(0);
                $it['score'] = 0.0;
                $it['score_text'] = '0';
                continue;
            }

            // 价格得分 = (最低单价合计 / 本供应商单价合计) × 价格权重% × 100
            if ($pw > 0 && !empty($it['has_price']) && $it['price_sum'] > 0 && $minSum !== null && $minSum > 0) {
                $ratio = round($minSum / (float)$it['price_sum'], 4);
                $it['price_score'] = round($ratio * ($pw / 100) * 100, 2);
            } else {
                $it['price_score'] = 0.0;
            }
            $it['price_score_text'] = self::formatScore($it['price_score']);

            // 交货得分已在上方取自月度评审（与质量得分同口径）
            if (!$leadEnabled) {
                $it['lead_score'] = 0.0;
                $it['lead_score_text'] = '0';
            } else {
                $it['lead_score_text'] = self::formatScore($it['lead_score']);
            }

            // 总分 = 质量得分×质量% + 价格得分(已含价格权重) [+ 交货得分×交货%]
            $total = 0.0;
            if ($qw > 0) {
                $total += $it['quality_score'] * ($qw / 100);
            }
            if ($pw > 0) {
                $total += (float)$it['price_score'];
            }
            if ($lw > 0) {
                $total += (float)$it['lead_score'] * ($lw / 100);
            }
            $it['score'] = round($total, 2);
            $it['score_text'] = self::formatScore($it['score']);
        }
        unset($it);

        $sorted = $items;
        uasort($sorted, function ($a, $b) {
            $sa = (float)($a['score'] ?? 0);
            $sb = (float)($b['score'] ?? 0);
            if ($sa !== $sb) {
                return $sb <=> $sa;
            }

            return strcmp((string)($a['company_name'] ?? ''), (string)($b['company_name'] ?? ''));
        });
        $rank = 0;
        foreach ($sorted as $cn => $row) {
            $rank++;
            $items[$cn]['rank_no'] = $rank;
            $items[$cn]['rank_text'] = (string)$rank;
        }

        return $items;
    }

    public static function formatScore($n): string
    {
        $s = rtrim(rtrim(sprintf('%.2F', (float)$n), '0'), '.');

        return $s === '' ? '0' : $s;
    }

    /**
     * 报价行单价原文（兼容确认页 amount、审批页 unit_price_text/amount_text）
     *
     * @param array<string, mixed> $ln
     */
    protected static function resolveQuoteLineAmountRaw(array $ln): string
    {
        foreach (['amount', 'unit_price_text', 'amount_text'] as $k) {
            if (!array_key_exists($k, $ln) || $ln[$k] === null) {
                continue;
            }
            $am = trim((string)$ln[$k]);
            if ($am === '' || $am === '未填写' || $am === '未开标验证' || $am === '开标验证后查看') {
                continue;
            }
            // 去掉千分位等
            $am = str_replace([',', '，', ' '], '', $am);
            if ($am !== '' && is_numeric($am)) {
                return $am;
            }
        }

        return '';
    }

    /**
     * 总分简要文案（仅总分数字；分项见独立字段）
     *
     * @param array<string, mixed> $hit calculate/loadSaved 单项
     */
    public static function formatScoreDetailText(array $hit): string
    {
        return self::formatScore($hit['score'] ?? 0);
    }

    /**
     * 分项得分展示文案（确认/详情表格用）
     *
     * @param array<string, mixed> $hit
     */
    public static function formatScorePartsHtml(array $hit): string
    {
        $qw = (float)($hit['quality_weight'] ?? 0);
        $pw = (float)($hit['price_weight'] ?? 0);
        $lw = (float)($hit['lead_weight'] ?? 0);
        $lines = [];
        if ($qw > 0) {
            $lines[] = '质量得分 ' . self::formatScore($hit['quality_score'] ?? 0);
        }
        if ($pw > 0) {
            $lines[] = '价格得分 ' . self::formatScore($hit['price_score'] ?? 0);
        }
        if ($lw > 0) {
            $lines[] = '交货得分 ' . self::formatScore($hit['lead_score'] ?? 0);
        }
        $lines[] = '总分 ' . self::formatScore($hit['score'] ?? 0);

        return implode("\n", $lines);
    }

    /**
     * 评分规则文案（用于确认页 / 详情展示）
     * 百分比取当前默认规则；权重大于 0 的项才写入公式
     *
     * @param array{quality_weight?:float|int|string,price_weight?:float|int|string,lead_weight?:float|int|string}|null $rule
     */
    public static function formatRuleFormulaText(?array $rule = null): string
    {
        $rule = $rule ?: self::getDefaultRule();
        $qw = (float)($rule['quality_weight'] ?? 50);
        $pw = (float)($rule['price_weight'] ?? 50);
        $lw = (float)($rule['lead_weight'] ?? 0);
        $parts = [];
        if ($qw > 0) {
            $parts[] = '（质量得分×' . self::formatWeightPercent($qw) . '%）';
        }
        if ($pw > 0) {
            $parts[] = '（价格得分）';
        }
        if ($lw > 0) {
            $parts[] = '（交货得分×' . self::formatWeightPercent($lw) . '%）';
        }
        $formula = $parts === []
            ? '（总分）=（质量得分×50%）+（价格得分）'
            : '（总分）=' . implode('+', $parts);
        $formula .= '；质量得分、交货得分取月度评审（当月按上月起往前查，无则默认50）';
        if ($pw > 0) {
            $formula .= '；价格得分=（最低单价合计/本供应商单价合计）×'
                . self::formatWeightPercent($pw) . '%×100';
        }

        return $formula;
    }

    /**
     * 报价组是否展示交货期留痕列（已落库纳入，或尚无落库且当前默认规则交货分>0）
     *
     * @param array<int, array<string, mixed>> $quoteGroups
     */
    public static function detectShowLeadScore(array $quoteGroups = [], ?array $rule = null): bool
    {
        $hasSavedScore = false;
        foreach ($quoteGroups as $g) {
            if (!is_array($g)) {
                continue;
            }
            if (!empty($g['show_service_lead_score'])) {
                return true;
            }
            if (!empty($g['show_service_score'])) {
                $hasSavedScore = true;
            }
        }
        // 历史单已按旧规则落库且交货期权重为 0：不显示这两列
        if ($hasSavedScore) {
            return false;
        }
        $rule = $rule ?: self::getDefaultRule();

        return (float)($rule['lead_weight'] ?? 0) > 0;
    }

    /**
     * 评分规则提示：优先用传入规则；无则用默认规则
     *
     * @param array<int, array<string, mixed>> $quoteGroups 保留参数兼容调用方
     * @param array{quality_weight?:float|int|string,price_weight?:float|int|string,lead_weight?:float|int|string}|null $rule
     */
    public static function formatRuleFormulaTextForGroups(array $quoteGroups = [], ?array $rule = null): string
    {
        return self::formatRuleFormulaText($rule);
    }

    protected static function formatWeightPercent($n): string
    {
        $s = rtrim(rtrim(sprintf('%.2F', (float)$n), '0'), '.');

        return $s === '' ? '0' : $s;
    }

    /**
     * 开标验证通过后：计算并写入供应商服务评分表
     *
     * @param array<int, array<string, mixed>> $quoteGroups
     */
    public static function saveForOrder(string $ccydh, array $quoteGroups, ?string $ym = null): void
    {
        $ccydh = trim($ccydh);
        if ($ccydh === '') {
            return;
        }
        self::ensureSchema();
        $rule = self::resolveRuleForCcydh($ccydh);
        if ($ym === null || $ym === '') {
            $ym = date('Y-m');
        }
        $ym = self::normalizeYm($ym);
        $calc = self::calculateForQuoteGroups($quoteGroups, $rule, $ym);
        if ($calc === []) {
            return;
        }
        $now = date('Y-m-d H:i:s');
        try {
            Db::table(self::TABLE_SCORE)->where('ccydh', $ccydh)->delete();
            $rows = [];
            foreach ($calc as $it) {
                $rows[] = [
                    'customer_id'    => (int)($it['customer_id'] ?? 0),
                    'company_name'   => (string)($it['company_name'] ?? ''),
                    'ym'             => $ym,
                    'ccydh'          => $ccydh,
                    'score'          => (float)($it['score'] ?? 0),
                    'rank_no'        => (int)($it['rank_no'] ?? 0),
                    'quality_score'  => (int)round((float)($it['quality_score'] ?? 0)),
                    'quality_weight' => (int)($rule['quality_weight'] ?? 50),
                    'price_sum'      => round((float)($it['price_sum'] ?? 0), 4),
                    'price_weight'   => (int)($rule['price_weight'] ?? 50),
                    'price_score'    => (float)($it['price_score'] ?? 0),
                    'lead_days_sum'  => (int)round((float)($it['lead_days_sum'] ?? 0)),
                    'lead_weight'    => (int)($rule['lead_weight'] ?? 0),
                    'lead_enabled'   => ((int)($rule['lead_weight'] ?? 0) > 0) ? 1 : 0,
                    'lead_score'     => (float)($it['lead_score'] ?? 0),
                    'rule_id'        => (int)($rule['id'] ?? 0),
                    'createtime'     => $now,
                    'updatetime'     => $now,
                ];
            }
            if ($rows !== []) {
                Db::table(self::TABLE_SCORE)->insertAll($rows);
            }
            // 开标后：本月询价供应商名称写入月度评审表（不存在才加空行，已有记录不覆盖）
            $monthNames = [];
            foreach ($quoteGroups as $g) {
                if (!is_array($g)) {
                    continue;
                }
                $cn = trim((string)($g['name'] ?? $g['company_name'] ?? ''));
                if ($cn !== '') {
                    $monthNames[] = $cn;
                }
            }
            foreach ($rows as $row) {
                $cn = trim((string)($row['company_name'] ?? ''));
                if ($cn !== '') {
                    $monthNames[] = $cn;
                }
            }
            self::ensureMonthlySupplierNames($ym, $monthNames);
        } catch (\Throwable $e) {
            Log::write('supplier service score save: ' . $e->getMessage(), 'error');
        }
    }

    /**
     * 读取某订单已落库评分；无则返回空
     *
     * @return array<string, array<string, mixed>>
     */
    public static function loadSavedByCcydh(string $ccydh): array
    {
        $ccydh = trim($ccydh);
        if ($ccydh === '') {
            return [];
        }
        try {
            $rows = Db::table(self::TABLE_SCORE)->where('ccydh', $ccydh)->select();
        } catch (\Throwable $e) {
            try {
                self::ensureSchema();
                $rows = Db::table(self::TABLE_SCORE)->where('ccydh', $ccydh)->select();
            } catch (\Throwable $e2) {
                return [];
            }
        }
        if (!is_array($rows)) {
            return [];
        }
        $out = [];
        foreach ($rows as $r) {
            if (!is_array($r)) {
                continue;
            }
            $cn = trim((string)($r['company_name'] ?? ''));
            if ($cn === '') {
                continue;
            }
            $qualityScore = (int)round((float)($r['quality_score'] ?? 0));
            $priceSum = round((float)($r['price_sum'] ?? 0), 4);
            $qw = (int)($r['quality_weight'] ?? 50);
            $pw = (int)($r['price_weight'] ?? 50);
            $lw = (int)($r['lead_weight'] ?? 0);
            $leadEnabled = $lw > 0 ? 1 : 0;
            $leadSum = (int)round((float)($r['lead_days_sum'] ?? 0));
            $leadScore = (float)($r['lead_score'] ?? 0);
            $out[$cn] = [
                'company_name'         => $cn,
                'customer_id'          => (int)($r['customer_id'] ?? 0),
                'quality_score'        => $qualityScore,
                'quality_score_text'   => (string)$qualityScore,
                'quality_weight'       => $qw,
                'price_sum'            => $priceSum,
                'price_sum_text'       => self::formatScore($priceSum),
                'price_weight'         => $pw,
                'price_score'          => (float)($r['price_score'] ?? 0),
                'price_score_text'     => self::formatScore($r['price_score'] ?? 0),
                'lead_days_sum'        => $leadSum,
                'lead_days_sum_text'   => $leadEnabled ? (string)$leadSum : '',
                'lead_weight'          => $lw,
                'lead_enabled'         => $leadEnabled,
                'lead_score'           => $leadScore,
                'lead_score_text'      => $leadEnabled ? self::formatScore($leadScore) : '',
                'score'                => (float)($r['score'] ?? 0),
                'rank_no'              => (int)($r['rank_no'] ?? 0),
                'score_text'           => self::formatScore($r['score'] ?? 0),
                'rank_text'            => ((int)($r['rank_no'] ?? 0)) > 0 ? (string)(int)($r['rank_no'] ?? 0) : '',
                '_row_id'              => (int)($r['id'] ?? 0),
            ];
        }

        // 按单价合计重算价格得分/总分（兼容历史把权重算进价格得分的数据）
        $minSum = null;
        foreach ($out as $it) {
            $ps = (float)($it['price_sum'] ?? 0);
            if ($ps > 0 && ($minSum === null || $ps < $minSum)) {
                $minSum = $ps;
            }
        }
        foreach ($out as $cn => &$it) {
            $qw = (int)($it['quality_weight'] ?? 50);
            $pw = (int)($it['price_weight'] ?? 50);
            $lw = (int)($it['lead_weight'] ?? 0);
            $priceSum = (float)($it['price_sum'] ?? 0);
            // 单价未填写：总分为 0
            if ($pw > 0 && $priceSum <= 0) {
                $it['price_score'] = 0.0;
                $it['price_score_text'] = '0';
                $it['score'] = 0.0;
                $it['score_text'] = '0';
                continue;
            }
            if ($pw > 0 && $priceSum > 0 && $minSum !== null && $minSum > 0) {
                $ratio = round($minSum / $priceSum, 4);
                $it['price_score'] = round($ratio * ($pw / 100) * 100, 2);
            } else {
                $it['price_score'] = 0.0;
            }
            $it['price_score_text'] = self::formatScore($it['price_score']);
            $total = 0.0;
            if ($qw > 0) {
                $total += (float)$it['quality_score'] * ($qw / 100);
            }
            if ($pw > 0) {
                $total += (float)$it['price_score'];
            }
            if ($lw > 0) {
                $total += (float)$it['lead_score'] * ($lw / 100);
            }
            $it['score'] = round($total, 2);
            $it['score_text'] = self::formatScore($it['score']);
        }
        unset($it);

        $sorted = $out;
        uasort($sorted, static function ($a, $b) {
            $sa = (float)($a['score'] ?? 0);
            $sb = (float)($b['score'] ?? 0);
            if ($sa !== $sb) {
                return $sb <=> $sa;
            }

            return strcmp((string)($a['company_name'] ?? ''), (string)($b['company_name'] ?? ''));
        });
        $rank = 0;
        foreach ($sorted as $cn => $row) {
            $rank++;
            $oldRank = (int)($out[$cn]['rank_no'] ?? 0);
            $out[$cn]['rank_no'] = $rank;
            $out[$cn]['rank_text'] = (string)$rank;
            $rowId = (int)($out[$cn]['_row_id'] ?? 0);
            if ($rowId > 0) {
                $upd = [];
                if ($oldRank !== $rank) {
                    $upd['rank_no'] = $rank;
                }
                foreach ($rows as $r) {
                    if (!is_array($r) || (int)($r['id'] ?? 0) !== $rowId) {
                        continue;
                    }
                    if (abs((float)($r['price_score'] ?? 0) - (float)$out[$cn]['price_score']) > 0.001) {
                        $upd['price_score'] = $out[$cn]['price_score'];
                    }
                    if (abs((float)($r['score'] ?? 0) - (float)$out[$cn]['score']) > 0.001) {
                        $upd['score'] = $out[$cn]['score'];
                    }
                    break;
                }
                if ($upd !== []) {
                    try {
                        Db::table(self::TABLE_SCORE)->where('id', $rowId)->update($upd);
                    } catch (\Throwable $e) {
                    }
                }
            }
            unset($out[$cn]['_row_id']);
        }

        return $out;
    }

    /**
     * 清空报价组上的评分留痕字段
     *
     * @param array<string, mixed> $g
     */
    protected static function clearScoreTrailOnGroup(array &$g, int $showFlag = 0): void
    {
        $g['service_rank'] = '';
        $g['service_score'] = '';
        $g['service_rank_text'] = '';
        $g['service_score_text'] = '';
        $g['service_score_parts_text'] = '';
        $g['service_quality_score'] = '';
        $g['service_quality_score_text'] = '';
        $g['service_price_sum'] = '';
        $g['service_price_sum_text'] = '';
        $g['service_price_score'] = '';
        $g['service_price_score_text'] = '';
        $g['service_lead_days_sum'] = '';
        $g['service_lead_days_sum_text'] = '';
        $g['service_lead_score'] = '';
        $g['service_lead_score_text'] = '';
        $g['service_lead_enabled'] = 0;
        $g['service_quality_weight'] = '';
        $g['service_price_weight'] = '';
        $g['service_lead_weight'] = '';
        $g['show_service_score'] = $showFlag;
        $g['show_service_lead_score'] = 0;
    }

    /**
     * 把排名/评分挂到报价组上（开标后可见）
     * 详情等读路径：优先读已落库评分，避免每次打开重算写库拖慢弹窗
     *
     * @param array<int, array<string, mixed>> $quoteGroups
     * @return array<int, array<string, mixed>>
     */
    public static function attachToQuoteGroups(array $quoteGroups, string $ccydh, bool $quoteVisible): array
    {
        if (!$quoteVisible || $quoteGroups === []) {
            foreach ($quoteGroups as &$g) {
                if (!is_array($g)) {
                    continue;
                }
                self::clearScoreTrailOnGroup($g, 0);
            }
            unset($g);

            return $quoteGroups;
        }

        $saved = self::loadSavedByCcydh($ccydh);
        $needCalc = ($saved === []);
        if (!$needCalc) {
            $anyHit = false;
            foreach ($quoteGroups as $g) {
                if (!is_array($g)) {
                    continue;
                }
                $cn = trim((string)($g['name'] ?? $g['company_name'] ?? ''));
                if ($cn !== '' && isset($saved[$cn])) {
                    $anyHit = true;
                    break;
                }
            }
            $needCalc = !$anyHit;
        }
        // 无落库记录时仅内存计算用于展示；落库由开标验证 saveForOrder 负责
        if ($needCalc) {
            $saved = self::calculateForQuoteGroups($quoteGroups, null, date('Y-m'));
        }

        foreach ($quoteGroups as &$g) {
            if (!is_array($g)) {
                continue;
            }
            $cn = trim((string)($g['name'] ?? $g['company_name'] ?? ''));
            $hit = ($cn !== '' && isset($saved[$cn]) && is_array($saved[$cn])) ? $saved[$cn] : null;
            if (is_array($hit)) {
                $g['service_rank'] = (int)($hit['rank_no'] ?? 0);
                $g['service_score'] = (float)($hit['score'] ?? 0);
                $g['service_rank_text'] = (string)($hit['rank_text'] ?? '');
                $g['service_score_text'] = self::formatScoreDetailText($hit);
                $g['service_score_parts_text'] = self::formatScorePartsHtml($hit);
                $qs = round((float)($hit['quality_score'] ?? 0), 2);
                $ps = (float)($hit['price_score'] ?? 0);
                $psum = round((float)($hit['price_sum'] ?? 0), 2);
                $leadEnabled = ((int)($hit['lead_weight'] ?? 0) > 0) ? 1 : 0;
                $ls = (float)($hit['lead_score'] ?? 0);
                $lsum = (int)round((float)($hit['lead_days_sum'] ?? 0));
                $g['service_quality_score'] = $qs;
                $g['service_quality_score_text'] = (string)($hit['quality_score_text'] ?? self::formatScore($qs));
                $g['service_price_sum'] = $psum;
                $g['service_price_sum_text'] = (string)($hit['price_sum_text'] ?? $psum);
                $g['service_price_score'] = $ps;
                $g['service_price_score_text'] = (string)($hit['price_score_text'] ?? self::formatScore($ps));
                $g['service_lead_enabled'] = $leadEnabled;
                $g['show_service_lead_score'] = $leadEnabled;
                $g['service_lead_days_sum'] = $lsum;
                $g['service_lead_days_sum_text'] = $leadEnabled ? (string)($hit['lead_days_sum_text'] ?? $lsum) : '';
                $g['service_lead_score'] = $ls;
                $g['service_lead_score_text'] = $leadEnabled ? (string)($hit['lead_score_text'] ?? self::formatScore($ls)) : '';
                $g['service_quality_weight'] = (int)($hit['quality_weight'] ?? 50);
                $g['service_price_weight'] = (int)($hit['price_weight'] ?? 50);
                $g['service_lead_weight'] = (int)($hit['lead_weight'] ?? 0);
                $g['show_service_score'] = 1;
            } else {
                self::clearScoreTrailOnGroup($g, 1);
            }
        }
        unset($g);

        // 开标后按排名升序（第1名在最前）；无排名的放最后
        usort($quoteGroups, function ($a, $b) {
            $ra = is_array($a) ? (int)($a['service_rank'] ?? 0) : 0;
            $rb = is_array($b) ? (int)($b['service_rank'] ?? 0) : 0;
            $ha = $ra > 0;
            $hb = $rb > 0;
            if ($ha !== $hb) {
                return $ha ? -1 : 1;
            }
            if ($ha && $ra !== $rb) {
                return $ra <=> $rb;
            }
            $sa = is_array($a) ? (float)($a['service_score'] ?? 0) : 0.0;
            $sb = is_array($b) ? (float)($b['service_score'] ?? 0) : 0.0;
            if ($sa !== $sb) {
                return $sb <=> $sa;
            }
            $na = is_array($a) ? trim((string)($a['name'] ?? $a['company_name'] ?? '')) : '';
            $nb = is_array($b) ? trim((string)($b['name'] ?? $b['company_name'] ?? '')) : '';

            return strcmp($na, $nb);
        });

        return $quoteGroups;
    }
}