197 lines
13 KiB
PHP
197 lines
13 KiB
PHP
<?php
|
||
|
||
declare(strict_types=1);
|
||
|
||
require dirname(__DIR__) . '/vendor/autoload.php';
|
||
require __DIR__ . '/fixtures/CompleteTcmCase.php';
|
||
|
||
use app\adminapi\logic\tcm\PatientAiReportLogic;
|
||
use app\adminapi\service\AiRequiredSource;
|
||
use app\adminapi\service\TcmClinicalEvidenceContract as Contract;
|
||
use app\adminapi\service\TcmClinicalEvidenceIndex as Index;
|
||
use app\adminapi\service\TcmClinicalFactStateGuard as Guard;
|
||
|
||
// Pure source/protocol regressions. No stream, model, transport, DB or report rewrite.
|
||
$count = 0;
|
||
$failures = [];
|
||
$expect = static function (bool $ok, string $message) use (&$count, &$failures): void {
|
||
++$count;
|
||
if (!$ok) $failures[] = $message;
|
||
};
|
||
$snapshot = (new ReflectionMethod(PatientAiReportLogic::class, 'buildSourceSnapshotFromRows'))
|
||
->invoke(null, CompleteTcmCase::rows());
|
||
$submission = (new ReflectionMethod(PatientAiReportLogic::class, 'sanitizeSnapshotForUpstream'))
|
||
->invoke(null, AiRequiredSource::submission($snapshot));
|
||
$ledger = Guard::build(CompleteTcmCase::current(), $submission);
|
||
$index = Index::build($ledger);
|
||
$sourceHash = hash('sha256', json_encode($ledger, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES));
|
||
$expect($sourceHash === '2ebbec0b558347bf4ee128dfb5a9e63fc4e355d58f7226486a2ae96098bd57f6',
|
||
'Immutable complete source projection, including all original IDs, qualifiers, scopes and dates.');
|
||
$expect(hash_file('sha256', __DIR__ . '/fixtures/CompleteTcmCase.php')
|
||
=== 'b54c47ec11f6a99dc87bdda78629e18c8a6f37a64017e42a72db399c727cb1c6', 'Immutable fixture bytes.');
|
||
|
||
$first = "一、四诊\n\n";
|
||
foreach (Index::ROLES as $label => $role) {
|
||
$sourceSpan = null;
|
||
foreach ($index['sources'] as $source) {
|
||
if ($source['scope'] !== 'current') continue;
|
||
foreach ($source['spans'] as $span) {
|
||
if ($span['role'] === $role && $span['recorded']) { $sourceSpan = [$source, trim($span['quote'])]; break 2; }
|
||
}
|
||
}
|
||
if ($role === 'palpation' && $sourceSpan === null) {
|
||
$first .= "切诊：其他触诊未记录，脉象见独立脉象项。\n\n";
|
||
continue;
|
||
}
|
||
$expect($sourceSpan !== null, 'A recorded role has its actual current source.');
|
||
[$source, $quote] = $sourceSpan;
|
||
$first .= $label . '：' . $source['date'] . '“' . $quote . '”（' . $source['id'] . "）。\n\n";
|
||
}
|
||
$head = $first . "二、八纲\n\n";
|
||
$check = static function (string $text, bool $valid, string $code = '', bool $contract = false) use ($ledger, $index, $head, $expect): array {
|
||
$original = $text;
|
||
$result = $contract ? Contract::validate($index, $head . $text, true) : Guard::validate($ledger, $text);
|
||
$expect($result['valid'] === $valid, ($contract ? 'Contract ' : 'Guard ')
|
||
. json_encode([$text, $result], JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES));
|
||
if ($code !== '') $expect(in_array($code, array_column($result['issues'], 'code'), true), 'Expected ' . $code . ': ' . $text);
|
||
$expect($text === $original, 'Every original report byte survives pure validation.');
|
||
return $result;
|
||
};
|
||
|
||
$medication = '现用二甲双胍0.5g、每日2次，既有医嘱，相关记录见s6，不擅停换。';
|
||
$inference = '不能仅据相关阴性记录反推为纯虚无实。';
|
||
$question = '适用前须核实：是否存在近期新发发热、恶寒、咳痰、胸闷或腹胀纳差等可能提示外邪或邪实未清的表现？';
|
||
$future = '适用条件为复核后仍以活动后气短、自汗、乏力、脉无力和少津为核心，且不存在更需优先处理的急性代谢异常、感染或器质性心肺问题。';
|
||
$trigger = '如症状突然加重或出现意识异常，应及时按急症评估。';
|
||
$reproductions = ['medication' => $medication, 'inference' => $inference, 'question' => $question, 'future' => $future, 'trigger' => $trigger];
|
||
if (in_array('--reproduce', $argv, true)) {
|
||
foreach ($reproductions as $label => $text) {
|
||
echo json_encode(['case' => $label, 'text' => $text, 'guard' => Guard::validate($ledger, $text),
|
||
'contract' => Contract::validate($index, $head . $text, true)], JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES) . "\n";
|
||
}
|
||
$clauses = new ReflectionMethod(Guard::class, 'reportClauses');
|
||
foreach (['tcm_complete_v43r21_cap8_openai_deadline_20261024_openai_next_full90_openai',
|
||
'tcm_complete_v43r21_cap8_single_openai_20261024_0_openai', 'tcm_complete_v43r21_cap8_mixed_c4_20261024_3_openai'] as $stem) {
|
||
$path = dirname(__DIR__, 2) . '/app/artifacts/ai_concurrency/' . $stem . '.rejected.json';
|
||
if (!is_file($path)) continue;
|
||
$saved = json_decode((string) file_get_contents($path), true, 512, JSON_THROW_ON_ERROR);
|
||
foreach ($saved['rejections'] as $n => $rejection) {
|
||
echo json_encode(['retained' => $stem . '#' . $n, 'sha256' => hash('sha256', $rejection['unit']),
|
||
'guard' => Guard::validate($ledger, $rejection['unit']),
|
||
'contract' => Contract::validate($index, $head . $rejection['unit'], true)], JSON_UNESCAPED_UNICODE) . "\n";
|
||
foreach ($clauses->invoke(null, $ledger, $rejection['unit']) as $entry) {
|
||
$result = Guard::validate($ledger, $entry['text']);
|
||
if (!$result['valid'] || $entry['annotation_invalid']) echo json_encode(['held_view' => $entry,
|
||
'guard' => $result], JSON_UNESCAPED_UNICODE) . "\n";
|
||
}
|
||
}
|
||
}
|
||
exit($failures === [] ? 0 : 1);
|
||
}
|
||
foreach ($reproductions as $text) { $check($text, true); $check($text, true, '', true); }
|
||
|
||
// Exact original retained units: do not alter snapshots or infer a successful live result.
|
||
$retained = [
|
||
['tcm_complete_v43r21_cap8_mixed_c4_20261024_3_openai', 1, 'dba0a7500da83bfbcf4c6c6845f7e4ad7aa78d701f9e6054a5fac4c004691617'],
|
||
['tcm_complete_v43r21_cap8_openai_deadline_20261024_openai_next_full90_openai', 0, '492602512704b309ba07b06d0a47d509b3c9b4cdb147e3ef43741247c31dfb9e'],
|
||
['tcm_complete_v43r21_cap8_openai_deadline_20261024_openai_next_full90_openai', 1, '0033369090211c54c6af2d62e792dd0cb7b7d776d0f5e547b6070fca8e4a6728'],
|
||
['tcm_complete_v43r21_cap8_single_openai_20261024_0_openai', 0, 'bbc1eddd8df19c1b5546990975867b8056d0241e235783e56fdba6de685e2b11'],
|
||
];
|
||
foreach ($retained as [$stem, $number, $hash]) {
|
||
$path = dirname(__DIR__, 2) . '/app/artifacts/ai_concurrency/' . $stem . '.rejected.json';
|
||
if (!is_file($path)) continue;
|
||
$saved = json_decode((string) file_get_contents($path), true, 512, JSON_THROW_ON_ERROR);
|
||
$unit = $saved['rejections'][$number]['unit'];
|
||
if ($hash !== '') $expect(hash('sha256', $unit) === $hash, 'Exact retained source bytes: ' . $stem);
|
||
$check($unit, true); $check($unit, true, '', true);
|
||
}
|
||
|
||
$assertions = [
|
||
['患者有心悸', 'NEGATIVE_TO_POSITIVE'], ['患者无固定刺痛', 'UNKNOWN_TO_NEGATIVE'],
|
||
['患者有固定刺痛', 'UNKNOWN_TO_POSITIVE'], ['心悸未记录', 'NEGATIVE_TO_UNKNOWN'],
|
||
['口干未记录', 'POSITIVE_TO_UNKNOWN'], ['舌质红绛', 'TONGUE_FEATURE_NOT_IN_CURRENT_SOURCE'],
|
||
['脉滑', 'PULSE_FEATURE_NOT_IN_CURRENT_SOURCE'], ['无五心烦热', 'NEGATION_SCOPE_WIDENED'],
|
||
];
|
||
foreach ([$medication, $inference, $question, $future, $trigger] as $role) {
|
||
$base = preg_replace('/[。？]$/u', '', $role) ?? $role;
|
||
foreach (['，', ',', '且', '但', '并', '并且', '同时', '还', '又', '另'] as $joiner) {
|
||
foreach ($assertions as [$assertion, $code]) {
|
||
$check($base . $joiner . $assertion . '。', false, $code);
|
||
}
|
||
}
|
||
foreach ($assertions as [$assertion, $code]) $check($assertion . '，' . $base . '。', false, $code);
|
||
}
|
||
foreach (['s5', 's30', 's999', 's0'] as $id) $check(str_replace('s6', $id, $medication), false, 'SOURCE_ANNOTATION_INVALID');
|
||
foreach ([
|
||
'相关记录见s6。', '既有医嘱，相关记录见s6。', '口干，相关记录见s6。',
|
||
'现用二甲双胍0.6g、每日2次，既有医嘱，相关记录见s6。',
|
||
'现用二甲双胍0.5g、每日3次，既有医嘱，相关记录见s6。',
|
||
'现用二甲双胍0.5g、每日2次，已停用，相关记录见s6。',
|
||
'历史现用二甲双胍0.5g、每日2次，既有医嘱，相关记录见s6。',
|
||
'2026-10-22现用二甲双胍0.5g、每日2次，既有医嘱，相关记录见s6。',
|
||
] as $text) $check($text, false, 'SOURCE_ANNOTATION_INVALID');
|
||
foreach ([$question, $future, $medication, $inference, $trigger] as $role) {
|
||
foreach (['（s999）', '（2026-10-22，s2）', '（2026-13-99，s2）'] as $annotation) {
|
||
$check((preg_replace('/[。？]$/u', '', $role) ?? $role) . $annotation . '。', false, 'SOURCE_ANNOTATION_INVALID');
|
||
}
|
||
}
|
||
foreach ([
|
||
['适用条件为仍以乏力为核心，且不存在感染。', 'NEGATION_SCOPE_WIDENED'],
|
||
['适用条件为已复核后仍以乏力为核心，且不存在感染。', 'NEGATION_SCOPE_WIDENED'],
|
||
['适用条件为复核后仍以患者乏力为核心，且不存在感染。', 'NEGATION_SCOPE_WIDENED'],
|
||
['适用条件为复核后仍以当前乏力为核心，且不存在感染。', 'NEGATION_SCOPE_WIDENED'],
|
||
['适用条件为复核后仍以口干未记录为核心，且不存在感染。', ''],
|
||
['适用条件为复核后仍以乏力为核心，口干未记录，且不存在感染。', 'POSITIVE_TO_UNKNOWN'],
|
||
['如症状突然加重或出现意识异常。', 'NEGATIVE_TO_POSITIVE'],
|
||
['如症状突然加重或出现意识异常，可考虑观察。', 'NEGATIVE_TO_POSITIVE'],
|
||
['如症状突然加重或出现患者有心悸，应及时按急症评估。', 'NEGATIVE_TO_POSITIVE'],
|
||
['如症状突然加重或出现意识异常且患者有心悸，应及时按急症评估。', 'NEGATIVE_TO_POSITIVE'],
|
||
['如症状突然加重或出现意识异常，口干未记录，应及时按急症评估。', 'POSITIVE_TO_UNKNOWN'],
|
||
] as [$text, $code]) $check($text, false, $code);
|
||
foreach (['表', '里', '寒', '热', '虚', '实', '阴', '阳'] as $category) {
|
||
$check('不能仅据相关阴性记录反推为纯虚无' . $category . '。', true);
|
||
$check('不能仅据相关阴性记录反推为纯虚无' . $category . '。', true, '', true);
|
||
}
|
||
foreach (['2026-10-23“无固定刺痛”（s2）。',
|
||
'2026-10-22“无咳嗽咯痰、胸痛心悸、浮肿或腹泻。”（s2）。',
|
||
'2026-10-23“无咳嗽咯痰、胸痛心悸、浮肿或腹泻。”（s999）。',
|
||
'2026-10-23“无五心烦热、潮热盗汗，无畏寒肢冷。”（s2）。'] as $denial) {
|
||
$check($inference . $denial, false, '', true);
|
||
}
|
||
foreach (['无明显急性感染诱因', '无明显五心烦热'] as $qualified) {
|
||
$check($qualified . '。', true);
|
||
$check(str_replace('明显', '', $qualified) . '。', false, 'NEGATION_SCOPE_WIDENED');
|
||
$check('2026-10-23“' . str_replace('明显', '', $qualified) . '”（s2）。', false, '', true);
|
||
}
|
||
foreach ([
|
||
'不能仅据相关阴性记录反推为患者无固定刺痛。',
|
||
'不能仅据相关阴性记录反推为纯虚无实且患者无固定刺痛。',
|
||
'并非不能仅据相关阴性记录反推为纯虚无实。',
|
||
'不能不据相关阴性记录反推为纯虚无实。',
|
||
'患者不能仅据相关阴性记录反推为纯虚无实。',
|
||
] as $text) $check($text, false, 'UNQUOTED_PATIENT_DENIAL', true);
|
||
foreach (['患者无固定刺痛。', '患者无腰酸耳鸣。'] as $text) $check($text, false, 'UNKNOWN_TO_NEGATIVE');
|
||
$unknown = Guard::build(['diagnosis_date' => '2026-10-23', 'tongue' => '未记录', 'pulse' => '未记录']);
|
||
foreach (['舌象正常。', '脉象正常。', '舌象无异常。', '脉象无异常。'] as $text) {
|
||
$result = Guard::validate($unknown, $text);
|
||
$expect(!$result['valid'], 'Unknown exam never becomes negative or normal: ' . $text);
|
||
}
|
||
foreach (['tcm_complete_v43r21_cap8_single_qwen_20261024_0_qwen',
|
||
'tcm_complete_v43r21_cap8_mixed_c4_20261024_0_qwen', 'tcm_complete_v43r21_cap8_mixed_c4_20261024_1_qwen',
|
||
'tcm_complete_v43r21_cap8_qwen_deadline_20261024_qwen_next_full90_qwen'] as $stem) {
|
||
$path = dirname(__DIR__, 2) . '/app/artifacts/ai_concurrency/' . $stem . '.rejected.json';
|
||
if (!is_file($path)) continue;
|
||
$saved = json_decode((string) file_get_contents($path), true, 512, JSON_THROW_ON_ERROR);
|
||
foreach ($saved['rejections'] as $entry) $check($entry['unit'], false, 'NEGATION_SCOPE_WIDENED');
|
||
}
|
||
$expect(hash('sha256', json_encode($ledger, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES)) === $sourceHash,
|
||
'Validation preserves every ledger byte.');
|
||
$expect(!class_exists('app\\adminapi\\service\\TcmClinicalReportStream', false)
|
||
&& !class_exists('app\\adminapi\\logic\\tcm\\DiagnosisAiLogic', false), 'No peer stream/diagnosis logic is loaded.');
|
||
if ($failures !== []) {
|
||
fwrite(STDERR, 'TCM r21 rejected role: ' . count($failures) . ' failures / ' . $count . " assertions\n"
|
||
. implode("\n", $failures) . "\n");
|
||
exit(1);
|
||
}
|
||
echo "TCM r21 rejected role: {$count} assertions passed (pure production Guard/Contract; no model/network).\n";
|