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

Add spark command abdm:hiu-fetch-by-consent for manual data_fetch of a specific consent artifact id

Browse Source
This commit is contained in:
DevSoftTech Server 2026-07-28 22:57:57 +05:30
parent 759d17d7a3
commit d2c25b9e38
1 changed files with 57 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
app/Commands/AbdmHiuFetchByConsent.php Normal file
View File

@ -0,0 +1,57 @@
<?php
namespace App\Commands;
use App\Libraries\Abdm\M3HiuWorkflowService;
use CodeIgniter\CLI\BaseCommand;
use CodeIgniter\CLI\CLI;
/**
* One-off diagnostic/repair command: manually trigger a data_fetch for a
* specific ABDM consent artifact id, bypassing the normal consent_request ->
* consent_reconcile discovery chain. Useful when the bridge/gateway created
* multiple consent artifacts under one consent request (one per linked HIP
* facility) and HMS only captured/polled a single artifact id.
*
* Usage:
* php spark abdm:hiu-fetch-by-consent --consent_id=<artifact_id> --abha_address=<abha> [--hfr_id=<hfr>]
*/
class AbdmHiuFetchByConsent extends BaseCommand
{
protected $group = 'ABDM';
protected $name = 'abdm:hiu-fetch-by-consent';
protected $description = 'Manually run data_fetch for a specific ABDM consent artifact id.';
protected $usage = 'abdm:hiu-fetch-by-consent --consent_id=<artifact_id> --abha_address=<abha> [--hfr_id=<hfr>]';
protected $options = [
'--consent_id' => 'ABDM consent artifact id to fetch decrypted data for.',
'--abha_address' => 'Patient ABHA address, e.g. someone@sbx.',
'--hfr_id' => 'Optional HFR id override (defaults to hospital_setting.ABDM_HFR_ID).',
];
public function run(array $params)
{
$consentId = trim((string) (CLI::getOption('consent_id') ?? ''));
$abhaAddress = trim((string) (CLI::getOption('abha_address') ?? ''));
$hfrId = trim((string) (CLI::getOption('hfr_id') ?? ''));
if ($consentId === '' || $abhaAddress === '') {
CLI::error('Both --consent_id and --abha_address are required.');
return;
}
$payload = [
'consent_id' => $consentId,
'abdm_consent_artifact_id' => $consentId,
'abha_address' => $abhaAddress,
];
if ($hfrId !== '') {
$payload['hfr_id'] = $hfrId;
}
$service = new M3HiuWorkflowService();
$result = $service->runOperation('data_fetch', $payload);
CLI::write('=== data_fetch result ===', 'yellow');
CLI::write(json_encode($result, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE));
}
}