415 lines
14 KiB
PHP
415 lines
14 KiB
PHP
<?php
|
|
/**
|
|
* Questionnaire structure revisions: bump, snapshot manifests, retire questions.
|
|
*/
|
|
|
|
function qdb_active_questions_clause(string $alias = 'question'): string {
|
|
return "COALESCE($alias.retiredAt, 0) = 0";
|
|
}
|
|
|
|
function qdb_active_options_clause(string $alias = 'answer_option'): string {
|
|
return "COALESCE($alias.retiredAt, 0) = 0";
|
|
}
|
|
|
|
function qdb_questionnaire_structure_revision(PDO $pdo, string $qnID): int {
|
|
$stmt = $pdo->prepare(
|
|
'SELECT COALESCE(structureRevision, 1) FROM questionnaire WHERE questionnaireID = :id'
|
|
);
|
|
$stmt->execute([':id' => $qnID]);
|
|
$rev = $stmt->fetchColumn();
|
|
return $rev !== false ? max(1, (int)$rev) : 1;
|
|
}
|
|
|
|
/**
|
|
* @return array<string, mixed>
|
|
*/
|
|
function qdb_build_structure_manifest(PDO $pdo, string $qnID, bool $includeRetired = false): array {
|
|
$where = 'questionnaireID = :qn';
|
|
if (!$includeRetired) {
|
|
$where .= ' AND ' . qdb_active_questions_clause('question');
|
|
}
|
|
$qStmt = $pdo->prepare(
|
|
"SELECT questionID, type, isRequired, configJson, defaultText, retiredAt
|
|
FROM question WHERE $where ORDER BY orderIndex"
|
|
);
|
|
$qStmt->execute([':qn' => $qnID]);
|
|
$questions = [];
|
|
foreach ($qStmt->fetchAll(PDO::FETCH_ASSOC) as $qRow) {
|
|
$fullId = $qRow['questionID'];
|
|
$shortId = qdb_question_local_id($fullId, $qnID);
|
|
$config = json_decode($qRow['configJson'] ?? '{}', true) ?: [];
|
|
$qKey = qdb_question_key($config, $qRow['defaultText']);
|
|
|
|
$optWhere = 'questionID = :qid';
|
|
if (!$includeRetired) {
|
|
$optWhere .= ' AND ' . qdb_active_options_clause('answer_option');
|
|
}
|
|
$aoStmt = $pdo->prepare(
|
|
"SELECT defaultText, points FROM answer_option WHERE $optWhere ORDER BY orderIndex"
|
|
);
|
|
$aoStmt->execute([':qid' => $fullId]);
|
|
$options = [];
|
|
foreach ($aoStmt->fetchAll(PDO::FETCH_ASSOC) as $ao) {
|
|
$options[] = [
|
|
'key' => $ao['defaultText'],
|
|
'points' => (int)$ao['points'],
|
|
];
|
|
}
|
|
|
|
$entry = [
|
|
'questionID' => $fullId,
|
|
'shortId' => $shortId,
|
|
'questionKey'=> $qKey,
|
|
'type' => $qRow['type'] ?? '',
|
|
'isRequired' => (int)($qRow['isRequired'] ?? 0) === 1,
|
|
'options' => $options,
|
|
];
|
|
if ($includeRetired && (int)($qRow['retiredAt'] ?? 0) > 0) {
|
|
$entry['retired'] = true;
|
|
}
|
|
if (($qRow['type'] ?? '') === 'glass_scale_question' && !empty($config['symptoms'])) {
|
|
$entry['symptoms'] = array_values(array_map('strval', (array)$config['symptoms']));
|
|
}
|
|
$questions[] = $entry;
|
|
}
|
|
|
|
return [
|
|
'questionnaireID' => $qnID,
|
|
'structureRevision' => qdb_questionnaire_structure_revision($pdo, $qnID),
|
|
'questions' => $questions,
|
|
];
|
|
}
|
|
|
|
/**
|
|
* @return array<string, mixed>|null
|
|
*/
|
|
function qdb_load_structure_manifest(PDO $pdo, string $qnID, int $revision): ?array {
|
|
$stmt = $pdo->prepare(
|
|
'SELECT manifestJson FROM questionnaire_structure_snapshot
|
|
WHERE questionnaireID = :qn AND structureRevision = :rev'
|
|
);
|
|
$stmt->execute([':qn' => $qnID, ':rev' => $revision]);
|
|
$json = $stmt->fetchColumn();
|
|
if ($json === false || $json === '') {
|
|
return null;
|
|
}
|
|
$decoded = json_decode((string)$json, true);
|
|
return is_array($decoded) ? $decoded : null;
|
|
}
|
|
|
|
function qdb_save_structure_snapshot(PDO $pdo, string $qnID, int $revision, array $manifest): void {
|
|
$json = json_encode($manifest, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
|
|
if ($json === false) {
|
|
$json = '{}';
|
|
}
|
|
$pdo->prepare(
|
|
'INSERT INTO questionnaire_structure_snapshot (questionnaireID, structureRevision, createdAt, manifestJson)
|
|
VALUES (:qn, :rev, :ts, :mj)
|
|
ON CONFLICT(questionnaireID, structureRevision) DO UPDATE SET
|
|
manifestJson = excluded.manifestJson,
|
|
createdAt = excluded.createdAt'
|
|
)->execute([
|
|
':qn' => $qnID,
|
|
':rev' => $revision,
|
|
':ts' => time(),
|
|
':mj' => $json,
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* Backfill revision-1 snapshots for questionnaires missing any snapshot row.
|
|
*/
|
|
function qdb_backfill_structure_snapshots(PDO $pdo): bool {
|
|
$ids = $pdo->query('SELECT questionnaireID FROM questionnaire')->fetchAll(PDO::FETCH_COLUMN);
|
|
$changed = false;
|
|
foreach ($ids as $qnID) {
|
|
$qnID = (string)$qnID;
|
|
$chk = $pdo->prepare(
|
|
'SELECT 1 FROM questionnaire_structure_snapshot
|
|
WHERE questionnaireID = :qn LIMIT 1'
|
|
);
|
|
$chk->execute([':qn' => $qnID]);
|
|
if ($chk->fetchColumn()) {
|
|
continue;
|
|
}
|
|
$rev = qdb_questionnaire_structure_revision($pdo, $qnID);
|
|
$manifest = qdb_build_structure_manifest($pdo, $qnID, true);
|
|
$manifest['structureRevision'] = $rev;
|
|
qdb_save_structure_snapshot($pdo, $qnID, $rev, $manifest);
|
|
$changed = true;
|
|
}
|
|
return $changed;
|
|
}
|
|
|
|
function qdb_bump_structure_revision(PDO $pdo, string $qnID, string $reason = ''): int {
|
|
$current = qdb_questionnaire_structure_revision($pdo, $qnID);
|
|
$manifest = qdb_build_structure_manifest($pdo, $qnID, false);
|
|
$manifest['structureRevision'] = $current;
|
|
qdb_save_structure_snapshot($pdo, $qnID, $current, $manifest);
|
|
|
|
$newRev = $current + 1;
|
|
$pdo->prepare(
|
|
'UPDATE questionnaire SET structureRevision = :rev, structureChangedAt = :ts WHERE questionnaireID = :qn'
|
|
)->execute([':rev' => $newRev, ':ts' => time(), ':qn' => $qnID]);
|
|
|
|
return $newRev;
|
|
}
|
|
|
|
function qdb_questionnaire_id_for_question(PDO $pdo, string $questionID): ?string {
|
|
$stmt = $pdo->prepare('SELECT questionnaireID FROM question WHERE questionID = :qid');
|
|
$stmt->execute([':qid' => $questionID]);
|
|
$id = $stmt->fetchColumn();
|
|
return $id !== false ? (string)$id : null;
|
|
}
|
|
|
|
function qdb_option_has_client_data(PDO $pdo, string $answerOptionID): bool {
|
|
$stmt = $pdo->prepare('SELECT 1 FROM client_answer WHERE answerOptionID = :id LIMIT 1');
|
|
$stmt->execute([':id' => $answerOptionID]);
|
|
if ($stmt->fetchColumn()) {
|
|
return true;
|
|
}
|
|
$chk = $pdo->query(
|
|
"SELECT 1 FROM sqlite_master WHERE type = 'table' AND name = 'client_answer_submission' LIMIT 1"
|
|
);
|
|
if (!$chk || !$chk->fetchColumn()) {
|
|
return false;
|
|
}
|
|
$stmt = $pdo->prepare(
|
|
'SELECT 1 FROM client_answer_submission WHERE answerOptionID = :id LIMIT 1'
|
|
);
|
|
$stmt->execute([':id' => $answerOptionID]);
|
|
return (bool)$stmt->fetchColumn();
|
|
}
|
|
|
|
function qdb_question_has_client_data(PDO $pdo, string $questionID): bool {
|
|
$stmt = $pdo->prepare('SELECT 1 FROM client_answer WHERE questionID = :qid LIMIT 1');
|
|
$stmt->execute([':qid' => $questionID]);
|
|
if ($stmt->fetchColumn()) {
|
|
return true;
|
|
}
|
|
$chk = $pdo->query(
|
|
"SELECT 1 FROM sqlite_master WHERE type = 'table' AND name = 'client_answer_submission' LIMIT 1"
|
|
);
|
|
if (!$chk || !$chk->fetchColumn()) {
|
|
return false;
|
|
}
|
|
$stmt = $pdo->prepare(
|
|
'SELECT 1 FROM client_answer_submission WHERE questionID = :qid LIMIT 1'
|
|
);
|
|
$stmt->execute([':qid' => $questionID]);
|
|
return (bool)$stmt->fetchColumn();
|
|
}
|
|
|
|
function qdb_retire_question(PDO $pdo, string $questionID, int $revision): void {
|
|
$pdo->prepare(
|
|
'UPDATE question SET retiredAt = :ts, retiredInRevision = :rev
|
|
WHERE questionID = :qid AND COALESCE(retiredAt, 0) = 0'
|
|
)->execute([':ts' => time(), ':rev' => $revision, ':qid' => $questionID]);
|
|
}
|
|
|
|
/**
|
|
* Build submit maps from a structure manifest (current or legacy).
|
|
*
|
|
* @return array{
|
|
* shortIdMap: array<string, string>,
|
|
* shortIdToType: array<string, string>,
|
|
* optionMap: array<string, array<string, array{answerOptionID: string, points: int}>>,
|
|
* symptomParentMap: array<string, string>,
|
|
* freeTextMaxLen: array<string, int>,
|
|
* manifestQuestionIds: list<string>
|
|
* }
|
|
*/
|
|
function qdb_submit_maps_from_manifest(PDO $pdo, string $qnID, array $manifest): array {
|
|
$shortIdMap = [];
|
|
$shortIdToType = [];
|
|
$optionMap = [];
|
|
$symptomParentMap = [];
|
|
$freeTextMaxLen = [];
|
|
$manifestQuestionIds = [];
|
|
|
|
foreach ($manifest['questions'] ?? [] as $qEntry) {
|
|
if (!is_array($qEntry)) {
|
|
continue;
|
|
}
|
|
$fullId = (string)($qEntry['questionID'] ?? '');
|
|
$shortId = (string)($qEntry['shortId'] ?? '');
|
|
if ($fullId === '' || $shortId === '') {
|
|
continue;
|
|
}
|
|
$type = (string)($qEntry['type'] ?? '');
|
|
$shortIdMap[$shortId] = $fullId;
|
|
$shortIdToType[$shortId] = $type;
|
|
$manifestQuestionIds[] = $fullId;
|
|
|
|
if ($type === 'free_text') {
|
|
$cfgStmt = $pdo->prepare('SELECT configJson FROM question WHERE questionID = :qid');
|
|
$cfgStmt->execute([':qid' => $fullId]);
|
|
$cfgJson = $cfgStmt->fetchColumn();
|
|
$cfg = json_decode($cfgJson ?: '{}', true) ?: [];
|
|
$freeTextMaxLen[$fullId] = max(1, min((int)($cfg['maxLength'] ?? 500), 10000));
|
|
}
|
|
|
|
$optionMap[$fullId] = [];
|
|
foreach ($qEntry['options'] ?? [] as $opt) {
|
|
if (!is_array($opt)) {
|
|
continue;
|
|
}
|
|
$key = (string)($opt['key'] ?? '');
|
|
if ($key === '') {
|
|
continue;
|
|
}
|
|
$aoStmt = $pdo->prepare(
|
|
'SELECT answerOptionID, points FROM answer_option
|
|
WHERE questionID = :qid AND defaultText = :k LIMIT 1'
|
|
);
|
|
$aoStmt->execute([':qid' => $fullId, ':k' => $key]);
|
|
$aoRow = $aoStmt->fetch(PDO::FETCH_ASSOC);
|
|
$optionMap[$fullId][$key] = [
|
|
'answerOptionID' => $aoRow ? (string)$aoRow['answerOptionID'] : '',
|
|
'points' => $aoRow ? (int)$aoRow['points'] : (int)($opt['points'] ?? 0),
|
|
];
|
|
}
|
|
|
|
if ($type === 'glass_scale_question') {
|
|
foreach ($qEntry['symptoms'] ?? [] as $symptomKey) {
|
|
$sk = trim((string)$symptomKey);
|
|
if ($sk !== '') {
|
|
$symptomParentMap[$sk] = $fullId;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if ($symptomParentMap === []) {
|
|
$symptomParentMap = qdb_glass_symptom_parent_map($pdo, $qnID);
|
|
}
|
|
|
|
return [
|
|
'shortIdMap' => $shortIdMap,
|
|
'shortIdToType' => $shortIdToType,
|
|
'optionMap' => $optionMap,
|
|
'symptomParentMap' => $symptomParentMap,
|
|
'freeTextMaxLen' => $freeTextMaxLen,
|
|
'manifestQuestionIds' => $manifestQuestionIds,
|
|
];
|
|
}
|
|
|
|
/**
|
|
* Build submit maps from active DB questions (current revision).
|
|
*
|
|
* @return array<string, mixed>
|
|
*/
|
|
function qdb_submit_maps_from_active_questions(PDO $pdo, string $qnID): array {
|
|
$manifest = qdb_build_structure_manifest($pdo, $qnID, false);
|
|
$manifest['structureRevision'] = qdb_questionnaire_structure_revision($pdo, $qnID);
|
|
return qdb_submit_maps_from_manifest($pdo, $qnID, $manifest);
|
|
}
|
|
|
|
/**
|
|
* @return list<array{field: string, header: string, questionID: string, type: string}>
|
|
*/
|
|
function qdb_result_columns_from_manifest(array $manifest): array {
|
|
$cols = [];
|
|
foreach ($manifest['questions'] ?? [] as $qEntry) {
|
|
if (!is_array($qEntry)) {
|
|
continue;
|
|
}
|
|
$fullId = (string)($qEntry['questionID'] ?? '');
|
|
$shortId = (string)($qEntry['shortId'] ?? '');
|
|
$qKey = (string)($qEntry['questionKey'] ?? '');
|
|
$type = (string)($qEntry['type'] ?? '');
|
|
if ($fullId === '') {
|
|
continue;
|
|
}
|
|
$header = $qKey !== '' ? $qKey : ($shortId !== '' ? $shortId : $fullId);
|
|
$cols[] = [
|
|
'field' => $header,
|
|
'header' => $header,
|
|
'questionID' => $fullId,
|
|
'type' => $type,
|
|
];
|
|
if ($type === 'glass_scale_question') {
|
|
foreach ($qEntry['symptoms'] ?? [] as $symptomKey) {
|
|
$sk = trim((string)$symptomKey);
|
|
if ($sk === '') {
|
|
continue;
|
|
}
|
|
$cols[] = [
|
|
'field' => $sk,
|
|
'header' => $sk,
|
|
'questionID' => $fullId,
|
|
'type' => 'glass_symptom',
|
|
'symptomKey' => $sk,
|
|
];
|
|
}
|
|
}
|
|
}
|
|
return $cols;
|
|
}
|
|
|
|
function qdb_compute_questionnaire_score_from_manifest(
|
|
PDO $pdo,
|
|
string $clientCode,
|
|
array $manifest
|
|
): int {
|
|
require_once __DIR__ . '/scoring.php';
|
|
$qnID = (string)($manifest['questionnaireID'] ?? '');
|
|
if ($qnID === '') {
|
|
return 0;
|
|
}
|
|
|
|
$questionIDs = [];
|
|
foreach ($manifest['questions'] ?? [] as $qEntry) {
|
|
if (is_array($qEntry) && !empty($qEntry['questionID'])) {
|
|
$questionIDs[] = (string)$qEntry['questionID'];
|
|
}
|
|
}
|
|
if ($questionIDs === []) {
|
|
return 0;
|
|
}
|
|
|
|
$ph = implode(',', array_fill(0, count($questionIDs), '?'));
|
|
$aStmt = $pdo->prepare(
|
|
"SELECT ca.questionID, ca.answerOptionID, ca.freeTextValue, ca.numericValue,
|
|
ao.defaultText AS optionKey
|
|
FROM client_answer ca
|
|
LEFT JOIN answer_option ao ON ao.answerOptionID = ca.answerOptionID
|
|
WHERE ca.clientCode = ? AND ca.questionID IN ($ph)"
|
|
);
|
|
$aStmt->execute(array_merge([$clientCode], $questionIDs));
|
|
$answersByQuestion = [];
|
|
foreach ($aStmt->fetchAll(PDO::FETCH_ASSOC) as $a) {
|
|
$answersByQuestion[$a['questionID']] = $a;
|
|
}
|
|
|
|
$total = 0;
|
|
foreach ($manifest['questions'] ?? [] as $qEntry) {
|
|
if (!is_array($qEntry)) {
|
|
continue;
|
|
}
|
|
$fullId = (string)($qEntry['questionID'] ?? '');
|
|
$type = (string)($qEntry['type'] ?? '');
|
|
$optionPoints = [];
|
|
foreach ($qEntry['options'] ?? [] as $opt) {
|
|
if (is_array($opt) && isset($opt['key'])) {
|
|
$optionPoints[(string)$opt['key']] = (int)($opt['points'] ?? 0);
|
|
}
|
|
}
|
|
$qRow = [
|
|
'questionID' => $fullId,
|
|
'type' => $type,
|
|
'configJson' => json_encode(
|
|
['symptoms' => $qEntry['symptoms'] ?? []],
|
|
JSON_UNESCAPED_UNICODE
|
|
),
|
|
];
|
|
$total += qdb_score_points_for_question(
|
|
$pdo,
|
|
$qRow,
|
|
$answersByQuestion[$fullId] ?? null,
|
|
$optionPoints
|
|
);
|
|
}
|
|
return $total;
|
|
}
|