Upload files to ".Net Capstone Project"

.Net Capstone Project/ConditionsController.cs

@@ -0,0 +1,330 @@
+using ClinicalInsightsPro.API.Data;
+using ClinicalInsightsPro.API.DTOs;
+using ClinicalInsightsPro.API.Models;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.EntityFrameworkCore;
+using ClinicalInsightsPro.API.Services.Interfaces;
+
+namespace ClinicalInsightsPro.API.Controllers;
+
+[ApiController]
+[Route("api/patients/{patientId}/[controller]")]
+[Authorize]
+public class ConditionsController : ControllerBase
+{
+    private readonly ApplicationDbContext _db;
+private readonly IMedplumFhirService _medplumFhirService;
+
+    public ConditionsController(
+    ApplicationDbContext db,
+    IMedplumFhirService medplumFhirService)
+{
+    _db = db;
+    _medplumFhirService = medplumFhirService;
+}
+
+    private async Task<bool> PatientExists(string patientId)
+    {
+        return await _db.Patient.AnyAsync(x => x.Id == patientId);
+    }
+
+    [HttpGet("/api/conditions")]
+    public async Task<IActionResult> GetAll()
+    {
+       var conditions = await _db.Condition
+    .Include(x => x.Patient)
+    .Select(condition => new ConditionListDto
+    {
+        Id = condition.Id,
+
+        PatientId = condition.PatientId,
+
+        PatientName =
+            condition.Patient != null
+                ? $"{condition.Patient.GivenName} {condition.Patient.FamilyName}"
+                : string.Empty,
+
+        ConditionCode = condition.ConditionCode,
+
+        ConditionDisplay = condition.ConditionDisplay,
+
+        ClinicalStatusDisplay =
+            condition.ClinicalStatusDisplay,
+
+        VerificationStatusDisplay =
+            condition.VerificationStatusDisplay,
+
+        SeverityDisplay =
+            condition.SeverityDisplay,
+
+        RecordedDate =
+            condition.RecordedDate
+    })
+    .ToListAsync();
+
+return Ok(conditions);
+
+    }
+
+    [HttpGet]
+    public async Task<IActionResult> GetByPatient(string patientId)
+    {
+        if (!await PatientExists(patientId))
+            return NotFound(new
+            {
+                error = $"Patient '{patientId}' was not found."
+            });
+
+        var conditions = await _db.Condition
+            .Where(x => x.PatientId == patientId)
+            .AsNoTracking()
+            .ToListAsync();
+
+        return Ok(conditions);
+    }
+
+    [HttpGet("{id}")]
+    public async Task<IActionResult> Get(
+        string patientId,
+        string id)
+    {
+        var condition = await _db.Condition
+            .AsNoTracking()
+            .FirstOrDefaultAsync(x =>
+                x.Id == id &&
+                x.PatientId == patientId);
+
+        if (condition == null)
+            return NotFound(new
+            {
+                error = $"Condition '{id}' was not found."
+            });
+
+        return Ok(condition);
+    }
+
+    [HttpPost]
+    public async Task<IActionResult> Create(
+        string patientId,
+        [FromBody] ConditionRequestDto request)
+    {
+        if (!await PatientExists(patientId))
+            return NotFound(new
+            {
+                error = $"Patient '{patientId}' was not found."
+            });
+
+        var condition = new Condition
+        {
+            ConditionId = Guid.NewGuid().ToString(),
+
+            ResourceType = "Condition",
+
+            PatientId = patientId,
+
+            ClinicalStatusCode =
+                request.ClinicalStatusCode,
+
+            ClinicalStatusDisplay =
+                request.ClinicalStatusDisplay,
+
+            VerificationStatusCode =
+                request.VerificationStatusCode,
+
+            VerificationStatusDisplay =
+                request.VerificationStatusDisplay,
+
+            SeverityCode =
+                request.SeverityCode,
+
+            SeverityDisplay =
+                request.SeverityDisplay,
+
+            ConditionCode =
+                request.ConditionCode,
+
+            ConditionDisplay =
+                request.ConditionDisplay,
+
+            OnsetDateTime =
+                request.OnsetDateTime,
+
+            AbatementDateTime =
+                request.AbatementDateTime,
+
+            RecordedDate =
+                request.RecordedDate,
+
+            RecorderId =
+                request.RecorderId,
+
+            AsserterId =
+                request.AsserterId,
+
+            CreatedBy = "System",
+            CreatedDate = DateTime.UtcNow,
+
+            VersionId = Guid.NewGuid().ToString(),
+            LastUpdated = DateTime.UtcNow
+        };
+
+        _db.Condition.Add(condition);
+
+        await _db.SaveChangesAsync();
+
+        return CreatedAtAction(
+            nameof(Get),
+            new
+            {
+                patientId,
+                id = condition.Id
+            },
+            condition);
+    }
+
+    [HttpPut("{id}")]
+    public async Task<IActionResult> Update(
+        string patientId,
+        string id,
+        [FromBody] ConditionRequestDto request)
+    {
+        var condition = await _db.Condition
+            .FirstOrDefaultAsync(x =>
+                x.Id == id &&
+                x.PatientId == patientId);
+
+        if (condition == null)
+            return NotFound(new
+            {
+                error = $"Condition '{id}' was not found."
+            });
+
+        condition.ClinicalStatusCode =
+            request.ClinicalStatusCode;
+
+        condition.ClinicalStatusDisplay =
+            request.ClinicalStatusDisplay;
+
+        condition.VerificationStatusCode =
+            request.VerificationStatusCode;
+
+        condition.VerificationStatusDisplay =
+            request.VerificationStatusDisplay;
+
+        condition.SeverityCode =
+            request.SeverityCode;
+
+        condition.SeverityDisplay =
+            request.SeverityDisplay;
+
+        condition.ConditionCode =
+            request.ConditionCode;
+
+        condition.ConditionDisplay =
+            request.ConditionDisplay;
+
+        condition.OnsetDateTime =
+            request.OnsetDateTime;
+
+        condition.AbatementDateTime =
+            request.AbatementDateTime;
+
+        condition.RecordedDate =
+            request.RecordedDate;
+
+        condition.RecorderId =
+            request.RecorderId;
+
+        condition.AsserterId =
+            request.AsserterId;
+
+        condition.UpdatedBy = "System";
+        condition.UpdatedDate = DateTime.UtcNow;
+        condition.LastUpdated = DateTime.UtcNow;
+
+        await _db.SaveChangesAsync();
+
+        return Ok(condition);
+    }
+
+    [HttpDelete("{id}")]
+    public async Task<IActionResult> Delete(
+        string patientId,
+        string id)
+    {
+        var condition = await _db.Condition
+            .FirstOrDefaultAsync(x =>
+                x.Id == id &&
+                x.PatientId == patientId);
+
+        if (condition == null)
+            return NotFound(new
+            {
+                error = $"Condition '{id}' was not found."
+            });
+
+        _db.Condition.Remove(condition);
+
+        await _db.SaveChangesAsync();
+
+        return NoContent();
+    }
+
+ [HttpPost("/api/conditions/sync-from-medplum")]
+public async Task<IActionResult> SyncFromMedplum()
+{
+    var conditions =
+        await _medplumFhirService.PullAllConditionsFromMedplumAsync();
+
+    int imported = 0;
+
+    foreach (var condition in conditions)
+    {
+        // Medplum Patient Id -> Local Patient Id mapping. Falls back to
+        // matching the local Patient's own Id too — a patient that was
+        // seeded locally (or pulled from Medplum without MedplumId being
+        // set for some reason) but whose id happens to equal the Medplum
+        // patient id would otherwise be silently skipped here.
+        var localPatient = await _db.Patient
+            .FirstOrDefaultAsync(p =>
+                p.MedplumId == condition.PatientId ||
+                p.Id == condition.PatientId);
+
+        if (localPatient == null)
+        {
+            continue;
+        }
+
+        // Local Patient Id save karo
+        condition.PatientId = localPatient.Id;
+
+        var exists = await _db.Condition
+            .AnyAsync(x => x.MedplumId == condition.MedplumId);
+
+        if (!exists)
+        {
+            condition.Id = Guid.NewGuid().ToString();
+
+            if (string.IsNullOrWhiteSpace(condition.ConditionId))
+            {
+                condition.ConditionId = Guid.NewGuid().ToString();
+            }
+
+            condition.CreatedDate = DateTime.UtcNow;
+            condition.LastUpdated = DateTime.UtcNow;
+            condition.VersionId = Guid.NewGuid().ToString();
+
+            _db.Condition.Add(condition);
+            imported++;
+        }
+    }
+
+    await _db.SaveChangesAsync();
+
+    return Ok(new
+    {
+        Imported = imported
+    });
+}
+}