d_s_bisht/devsofttech_hms_ci4
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Resolve fallback consent status in OPD flow

Browse Source
This commit is contained in:
DevSoftTech Server 2026-07-28 01:53:44 +05:30
parent 05d35f6021
commit c2a3e3054f
1 changed files with 68 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
app/Controllers/Patient.php
View File

@ -1547,6 +1547,74 @@ class Patient extends BaseController
|| stripos($errorText, 'NOT_FOUND') !== false); || stripos($errorText, 'NOT_FOUND') !== false);
if ($isNonFatalPending) { if ($isNonFatalPending) {
$fallbackLookup = [
'abha_address' => $abhaContext['abha_address'],
];
if ($consentRequestRef !== '') {
$fallbackLookup['consentRequestId'] = $consentRequestRef;
}
if ($consentArtifactRef !== '') {
$fallbackLookup['consentId'] = $consentArtifactRef;
}
if ($flowRefId !== '') {
$fallbackLookup['request_id'] = $flowRefId;
}
if ($consentRequestRef !== '' || $consentArtifactRef !== '') {
try {
$fallbackReconcile = $service->runOperation('consent_reconcile', $fallbackLookup);
} catch (\Throwable $e) {
$fallbackReconcile = [
'ok' => 0,
'http_code' => 500,
'error_text' => 'Unable to reconcile consent status using fallback reference: ' . $e->getMessage(),
];
}
if ((int) ($fallbackReconcile['ok'] ?? 0) === 1) {
$reconcileResult = $fallbackReconcile;
$state = $this->deriveAutoFlowState($reconcileResult);
if ($state === 'GRANTED') {
$fetchPayload = [
'abha_address' => $abhaContext['abha_address'],
'consentId' => $consentArtifactRef,
];
if ($fetchPayload['consentId'] === '') {
unset($fetchPayload['consentId']);
if ($consentRequestRef !== '') {
$fetchPayload['consentRequestId'] = $consentRequestRef;
}
}
try {
$fetchResult = $service->runOperation('data_fetch', $fetchPayload);
} catch (\Throwable $e) {
return $this->response->setStatusCode(500)->setJSON([
'ok' => 0,
'phase' => 'FETCH_FAILED',
'error' => 'Unable to fetch ABDM content after fallback reconcile: ' . $e->getMessage(),
'request_id' => $flowRefId,
]);
}
if ((int) ($fetchResult['ok'] ?? 0) === 1) {
return $this->response->setJSON([
'ok' => 1,
'phase' => 'COMPLETED',
'poll_again' => 0,
'request_id' => $flowRefId,
'message' => 'Consent status was resolved using fallback bridge reference and data fetched successfully.',
'data' => [
'consent_request' => $consentResult,
'consent_reconcile' => $reconcileResult,
'data_fetch' => $fetchResult,
],
]);
}
}
}
}
$altConsentRequestRef = trim((string) ($consentRequestRef !== '' ? $consentRequestRef : ($lastSync['consent_request_id'] ?? ''))); $altConsentRequestRef = trim((string) ($consentRequestRef !== '' ? $consentRequestRef : ($lastSync['consent_request_id'] ?? '')));
$altConsentArtifactRef = trim((string) ($consentArtifactRef !== '' ? $consentArtifactRef : ($lastSync['consent_id'] ?? ''))); $altConsentArtifactRef = trim((string) ($consentArtifactRef !== '' ? $consentArtifactRef : ($lastSync['consent_id'] ?? '')));
$canDirectFetch = ($altConsentArtifactRef !== '' && preg_match('/^REQ-/i', $altConsentArtifactRef) !== 1) $canDirectFetch = ($altConsentArtifactRef !== '' && preg_match('/^REQ-/i', $altConsentArtifactRef) !== 1)