Implement admin batch preprocess of images without thumbnails

Author: webprofusion-chrisc

API/OCM.Net/OCM.API.Core/Common/MediaItemManager.cs

@@ -222,5 +222,139 @@ public void DeleteMediaItem(int userId, int mediaItemId)
                 AuditLogManager.Log(user, AuditEventType.DeletedItem, "{EntityType:\"Comment\", EntityID:" + mediaItemId + ",ChargePointID:" + cpID + "}", "User deleted media item");
             }
         }
+
+        public async Task<List<MediaItem>> GetMediaItemsWithMissingThumbnails(int maxResults = 100)
+        {
+            var dataModel = new OCMEntities();
+
+            var items = dataModel.MediaItems
+                .Where(m => m.IsEnabled == true && 
+                            m.ItemUrl != null && 
+                            (m.ItemThumbnailUrl == null || m.ItemThumbnailUrl == "") &&
+                            !m.IsExternalResource &&
+                            !m.IsVideo)
+                .Take(maxResults)
+                .ToList();
+
+            return items;
+        }
+
+        public async Task<ReprocessMediaResult> ReprocessMediaItem(int mediaItemId, string tempFolderPath)
+        {
+            var result = new ReprocessMediaResult { MediaItemId = mediaItemId };
+            var dataModel = new OCMEntities();
+
+            var mediaItem = dataModel.MediaItems.FirstOrDefault(m => m.Id == mediaItemId);
+            
+            if (mediaItem == null)
+            {
+                result.Success = false;
+                result.Message = "Media item not found";
+                return result;
+            }
+
+            if (string.IsNullOrEmpty(mediaItem.ItemUrl))
+            {
+                result.Success = false;
+                result.Message = "No original image URL";
+                return result;
+            }
+
+            if (mediaItem.IsVideo || mediaItem.IsExternalResource)
+            {
+                result.Success = false;
+                result.Message = "Cannot reprocess video or external resources";
+                return result;
+            }
+
+            // Get POI info for metadata
+            var poi = await new POIManager().Get(mediaItem.ChargePointId);
+            if (poi == null)
+            {
+                result.Success = false;
+                result.Message = "Associated charging location not found";
+                return result;
+            }
+
+            try
+            {
+                // Download the original image
+                string extension = Path.GetExtension(mediaItem.ItemUrl).ToLower();
+                if (string.IsNullOrEmpty(extension))
+                {
+                    extension = ".jpg";
+                }
+
+                string tempOriginalFile = Path.Combine(tempFolderPath, $"temp_original_{mediaItemId}{extension}");
+                
+                using (var client = new System.Net.Http.HttpClient())
+                {
+                    client.Timeout = TimeSpan.FromMinutes(2);
+                    var imageBytes = await client.GetByteArrayAsync(mediaItem.ItemUrl);
+                    await File.WriteAllBytesAsync(tempOriginalFile, imageBytes);
+                }
+
+                // Generate thumbnails
+                string destFolderPrefix = poi.AddressInfo.Country.ISOCode + "/" + "OCM" + poi.ID + "/";
+                string dateStamp = String.Format("{0:yyyyMMddHHmmssff}", DateTime.UtcNow);
+                string thumbFileName = "OCM-" + poi.ID + ".thmb." + dateStamp + extension;
+                string mediumFileName = "OCM-" + poi.ID + ".medi." + dateStamp + extension;
+
+                string thumbFilePath = Path.Combine(tempFolderPath, thumbFileName);
+                string mediumFilePath = Path.Combine(tempFolderPath, mediumFileName);
+
+                GenerateImageThumbnails(tempOriginalFile, thumbFilePath, 100);
+                GenerateImageThumbnails(tempOriginalFile, mediumFilePath, 400);
+
+                // Upload to storage
+                var storage = new StorageManager();
+                var metadataTags = new List<KeyValuePair<string, string>>
+                {
+                    new KeyValuePair<string, string>("OCM", poi.ID.ToString()),
+                    new KeyValuePair<string, string>("Latitude", poi.AddressInfo.Latitude.ToString()),
+                    new KeyValuePair<string, string>("Longitude", poi.AddressInfo.Longitude.ToString())
+                };
+
+                string thumbnailUrl = await storage.UploadImageAsync(thumbFilePath, destFolderPrefix + thumbFileName, metadataTags);
+                string mediumUrl = await storage.UploadImageAsync(mediumFilePath, destFolderPrefix + mediumFileName, metadataTags);
+
+                // Update database
+                mediaItem.ItemThumbnailUrl = thumbnailUrl;
+                await dataModel.SaveChangesAsync();
+
+                // Clean up temp files
+                try
+                {
+                    File.Delete(tempOriginalFile);
+                    File.Delete(thumbFilePath);
+                    File.Delete(mediumFilePath);
+                }
+                catch { }
+
+                result.Success = true;
+                result.Message = "Successfully reprocessed";
+                result.ThumbnailUrl = thumbnailUrl;
+                result.MediumUrl = mediumUrl;
+
+                AuditLogManager.Log(null, AuditEventType.UpdatedItem, $"Reprocessed media item {mediaItemId}, generated thumbnail: {thumbnailUrl}", "");
+            }
+            catch (Exception ex)
+            {
+                result.Success = false;
+                result.Message = $"Error: {ex.Message}";
+                AuditLogManager.Log(null, AuditEventType.SystemErrorAPI, $"Failed to reprocess media item {mediaItemId}: {ex.Message}", ex.ToString());
+            }
+
+            return result;
+        }
+    }
+
+    public class ReprocessMediaResult
+    {
+        public int MediaItemId { get; set; }
+        public bool Success { get; set; }
+        public string Message { get; set; }
+        public string ThumbnailUrl { get; set; }
+        public string MediumUrl { get; set; }
     }
 }

Website/OCM.Web/Controllers/AdminController.cs

@@ -1,6 +1,7 @@
 using System;
 using System.Collections.Generic;
 using System.Configuration;
+using System.IO;
 using System.Linq;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Http;
@@ -448,5 +449,85 @@ public async Task<ActionResult> Benchmarks()
             var results = await cache.PerformPOIQueryBenchmark(10, "bounding");
             return View(results);
         }
+
+        [Authorize(Roles = "Admin")]
+        public async Task<ActionResult> MediaItemsWithoutThumbnails()
+        {
+            var mediaManager = new MediaItemManager();
+            var items = await mediaManager.GetMediaItemsWithMissingThumbnails(100);
+            
+            ViewBag.TotalCount = items.Count;
+            return View(items);
+        }
+
+        [Authorize(Roles = "Admin")]
+        [HttpPost]
+        public async Task<JsonResult> ReprocessMediaItem(int id)
+        {
+            var mediaManager = new MediaItemManager();
+            string tempFolder = Path.Combine(Path.GetTempPath(), "OCM_MediaReprocess");
+            
+            if (!Directory.Exists(tempFolder))
+            {
+                Directory.CreateDirectory(tempFolder);
+            }
+
+            var result = await mediaManager.ReprocessMediaItem(id, tempFolder);
+            
+            return Json(new
+            {
+                success = result.Success,
+                message = result.Message,
+                thumbnailUrl = result.ThumbnailUrl,
+                mediumUrl = result.MediumUrl
+            });
+        }
+
+        [Authorize(Roles = "Admin")]
+        [HttpPost]
+        public async Task<JsonResult> ReprocessAllMissingThumbnails(int batchSize = 10)
+        {
+            var mediaManager = new MediaItemManager();
+            var items = await mediaManager.GetMediaItemsWithMissingThumbnails(batchSize);
+            
+            string tempFolder = Path.Combine(Path.GetTempPath(), "OCM_MediaReprocess");
+            if (!Directory.Exists(tempFolder))
+            {
+                Directory.CreateDirectory(tempFolder);
+            }
+
+            int successCount = 0;
+            int failureCount = 0;
+            var results = new List<object>();
+
+            foreach (var item in items)
+            {
+                var result = await mediaManager.ReprocessMediaItem(item.Id, tempFolder);
+                
+                if (result.Success)
+                {
+                    successCount++;
+                }
+                else
+                {
+                    failureCount++;
+                }
+
+                results.Add(new
+                {
+                    id = item.Id,
+                    success = result.Success,
+                    message = result.Message
+                });
+            }
+
+            return Json(new
+            {
+                totalProcessed = items.Count,
+                successCount = successCount,
+                failureCount = failureCount,
+                results = results
+            });
+        }
     }
 }

Website/OCM.Web/Views/Admin/Index.cshtml

@@ -14,6 +14,8 @@
         <ul>
             <li>@Html.ActionLink("Check POI Cache Status", "CheckPOIMirrorStatus", "Admin")</li>
             <li>@Html.ActionLink("Benchmark Tests", "Benchmarks", "Admin")</li>
+
+            <li>@Html.ActionLink("Fix Media Item Thumbnails", "MediaItemsWithoutThumbnails", "Admin")</li>
         </ul>
 
         <h3>Data Import</h3>