Merge pull request #191 from qccoders/scanning-backend

Implement scanning backend

Author: wburklund

api/QCVOC.Api/Scans/Controller/ScansController.cs

@@ -16,6 +16,7 @@ namespace QCVOC.Api.Scans.Controller
     using QCVOC.Api.Events.Data.Model;
     using QCVOC.Api.Scans.Data.DTO;
     using QCVOC.Api.Scans.Data.Model;
+    using QCVOC.Api.Services.Data.Model;
     using QCVOC.Api.Veterans;
     using QCVOC.Api.Veterans.Data.Model;
 
@@ -34,16 +35,19 @@ public class ScansController : Controller
         /// <param name="scanRepository">The repository used for Scan data access.</param>
         /// <param name="eventRepository">The repository used for Event data access.</param>
         /// <param name="veteranRepository">The repository used for Veteran data access.</param>
-        public ScansController(ITripleKeyRepository<Scan> scanRepository, ISingleKeyRepository<Event> eventRepository, ISingleKeyRepository<Veteran> veteranRepository)
+        /// <param name="serviceRepository">The repository used for Service data access.</param>
+        public ScansController(ITripleKeyRepository<Scan> scanRepository, ISingleKeyRepository<Event> eventRepository, ISingleKeyRepository<Veteran> veteranRepository, ISingleKeyRepository<Service> serviceRepository)
         {
             ScanRepository = scanRepository;
             EventRepository = eventRepository;
             VeteranRepository = veteranRepository;
+            ServiceRepository = serviceRepository;
         }
 
         private ITripleKeyRepository<Scan> ScanRepository { get; set; }
         private ISingleKeyRepository<Event> EventRepository { get; }
         private ISingleKeyRepository<Veteran> VeteranRepository { get; set; }
+        private ISingleKeyRepository<Service> ServiceRepository { get; set; }
 
         /// <summary>
         ///     Returns a list of Scans.
@@ -68,12 +72,12 @@ public IActionResult GetAll([FromQuery]ScanFilters filters)
         /// </summary>
         /// <param name="scan">The scan context.</param>
         /// <returns>See attributes.</returns>
-        /// <response code="200">The Veteran is already checked in.</response>
-        /// <response code="201">The Veteran was checked in.</response>
+        /// <response code="200">The Scan has already been recorded.</response>
+        /// <response code="201">The Scan was recorded or updated.</response>
         /// <response code="400">The specified Scan was invalid.</response>
         /// <response code="401">Unauthorized.</response>
         /// <response code="403">The Veteran has not checked in for the Event.</response>
-        /// <response code="404">Either the specified Veteran or Event was invalid.</response>
+        /// <response code="404">The specified Veteran, Event or Service was invalid.</response>
         /// <response code="500">The server encountered an error while processing the request.</response>
         [HttpPost("")]
         [Authorize]
@@ -95,7 +99,7 @@ public IActionResult Scan([FromBody]ScanRequest scan)
 
             if (@event == default(Event))
             {
-                StatusCode(403, "The specified Event is not found.");
+                StatusCode(404, "The specified Event could not be found.");
             }
 
             var veteran = VeteranRepository
@@ -104,12 +108,47 @@ public IActionResult Scan([FromBody]ScanRequest scan)
 
             if (veteran == default(Veteran))
             {
-                return StatusCode(403, "The specified Card Id doesn't match an enrolled Veteran.");
+                return StatusCode(404, "The specified Card Id doesn't match an enrolled Veteran.");
             }
 
+            var scanRecord = new Scan()
+            {
+                EventId = (Guid)scan.EventId,
+                VeteranId = veteran.Id,
+                ServiceId = scan.ServiceId,
+                PlusOne = scan.PlusOne,
+                ScanById = User.GetId(),
+                ScanDate = DateTime.UtcNow,
+            };
+
             var previousScans = ScanRepository.GetAll(new ScanFilters() { EventId = scan.EventId, VeteranId = veteran.Id });
 
-            if (scan.ServiceId == Guid.Empty && !previousScans.Where(s => s.ServiceId == Guid.Empty).Any())
+            if (scan.ServiceId == Guid.Empty)
+            {
+                var existingCheckIn = previousScans.Where(s => s.ServiceId == Guid.Empty).SingleOrDefault();
+
+                if (existingCheckIn == default(Scan))
+                {
+                    return CreateScan(scanRecord);
+                }
+                else if (existingCheckIn.PlusOne != scan.PlusOne)
+                {
+                    return UpdateScan(scanRecord);
+                }
+                else
+                {
+                    return StatusCode(200, existingCheckIn);
+                }
+            }
+
+            var service = ServiceRepository.Get(scan.ServiceId);
+
+            if (service == default(Service))
+            {
+                return StatusCode(404, "The specified Service could not be found.");
+            }
+
+            if (!previousScans.Where(s => s.ServiceId == Guid.Empty).Any())
             {
                 return StatusCode(403, "The Veteran has not checked in for this Event.");
             }
@@ -119,25 +158,33 @@ public IActionResult Scan([FromBody]ScanRequest scan)
                 return StatusCode(200, previousScans.Where(s => s.ServiceId == scan.ServiceId).SingleOrDefault());
             }
 
-            var scanRecord = new Scan()
-            {
-                EventId = (Guid)scan.EventId,
-                VeteranId = veteran.Id,
-                ServiceId = scan.ServiceId,
-                PlusOne = scan.PlusOne,
-                ScanById = User.GetId(),
-                ScanDate = DateTime.UtcNow,
-            };
+            return CreateScan(scanRecord);
+        }
 
+        private IActionResult CreateScan(Scan scan)
+        {
             try
             {
-                var createdScan = ScanRepository.Create(scanRecord);
+                var createdScan = ScanRepository.Create(scan);
                 return StatusCode(201, createdScan);
             }
             catch (Exception ex)
             {
                 throw new Exception($"Error processing Scan: {ex.Message}.  See inner Exception for details.", ex);
             }
         }
+
+        private IActionResult UpdateScan(Scan scan)
+        {
+            try
+            {
+                var updatedScan = ScanRepository.Update(scan);
+                return StatusCode(201, updatedScan);
+            }
+            catch (Exception ex)
+            {
+                throw new Exception($"Error processing Scan: {ex.Message}.  See inner Exception for details.", ex);
+            }
+        }
     }
 }

api/QCVOC.Api/Scans/Data/Repository/ScanRepository.cs

@@ -170,15 +170,41 @@ LIMIT @limit OFFSET @offset
         }
 
         /// <summary>
-        ///     Not implemented; Scan records are immutable.
+        ///     Updates the specified <paramref name="scan"/>.
         /// </summary>
-        /// <param name="scan">N/A</param>
-        /// <returns>Nothing</returns>
-        /// <exception cref="NotImplementedException">Thrown on invocation.</exception>
-        [Obsolete("Scan records may not be updated.", true)]
+        /// <param name="scan">the Scan to update.</param>
+        /// <returns>The updated Scan.</returns>
         public Scan Update(Scan scan)
         {
-            throw new NotImplementedException("Scan records may not be updated.");
+            var builder = new SqlBuilder();
+
+            var query = builder.AddTemplate(@"
+                UPDATE scans
+                SET
+                    plusone = @plusone,
+                    scandate = @scandate,
+                    scanbyid = @scanbyid
+                WHERE eventid = @eventid
+                AND veteranid = @veteranid
+                AND serviceid = @serviceid
+            ");
+
+            builder.AddParameters(new
+            {
+                plusone = scan.PlusOne,
+                scandate = scan.ScanDate,
+                scanbyid = scan.ScanById,
+                eventid = scan.EventId,
+                veteranid = scan.VeteranId,
+                serviceid = scan.ServiceId,
+            });
+
+            using (var db = ConnectionFactory.CreateConnection())
+            {
+                db.Execute(query.RawSql, query.Parameters);
+            }
+
+            return Get(scan.EventId, scan.VeteranId, scan.ServiceId);
         }
     }
 }