完善语言文件的生成

Atomx.Core/Jos/LocalizationJob.cs

@@ -34,63 +34,97 @@ namespace Atomx.Core.Jos
             try
             {
                 var translations = data.FromJson<Dictionary<string, string>>();
-
-                var fileName = $"{culture}.json";
-                var filePath = Path.Combine(path, fileName);
-                if (!Directory.Exists(path))
+                if (translations == null)
                 {
-                    Directory.CreateDirectory(path);
-                    _logger.LogInformation("Created Resources directory: {Path}", path);
+                    _logger.LogError("No translations provided for culture: {Culture}", culture);
                 }
-
-                var fileData = new Dictionary<string, string>();
-                if (File.Exists(filePath))
+                else
                 {
-                    var json = await File.ReadAllTextAsync(filePath);
-                    fileData = JsonSerializer.Deserialize<Dictionary<string, string>>(json, new JsonSerializerOptions
+
+                    var fileName = $"{culture}.json";
+                    var filePath = Path.Combine(path, fileName);
+                    if (!Directory.Exists(path))
                     {
-                        PropertyNamingPolicy = JsonNamingPolicy.CamelCase
-                    }) ?? new Dictionary<string, string>();
+                        Directory.CreateDirectory(path);
+                        _logger.LogInformation("Created Resources directory: {Path}", path);
+                    }
+
+                    var fileData = new Dictionary<string, string>();
+                    if (File.Exists(filePath))
+                    {
+                        var json = await File.ReadAllTextAsync(filePath);
+                        fileData = JsonSerializer.Deserialize<Dictionary<string, string>>(json, new JsonSerializerOptions
+                        {
+                            PropertyNamingPolicy = JsonNamingPolicy.CamelCase
+                        }) ?? new Dictionary<string, string>();
+                    }
+
+                    foreach (var item in translations)
+                    {
+                        fileData[item.Key] = item.Value;
+                    }
+
+                    var options = new JsonSerializerOptions
+                    {
+                        PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
+                        WriteIndented = true
+                    };
+                    var updatedJson = JsonSerializer.Serialize(fileData, options);
+                    await File.WriteAllTextAsync(filePath, updatedJson);
+
+                    // 更新文件后，更新数据库中的资源版本
+                    string fileHash;
+                    using (var sha256 = SHA256.Create())
+                    using (var stream = File.OpenRead(filePath))
+                    {
+                        var hashBytes = sha256.ComputeHash(stream);
+                        fileHash = BitConverter.ToString(hashBytes).Replace("-", "").ToLowerInvariant();
+                        Console.WriteLine(fileHash);
+                    }
+                    var language = _dbContext.Languages.FirstOrDefault(l => l.Culture == culture);
+                    if (language != null)
+                    {
+                        language.UpdateTime = DateTime.UtcNow;
+                        language.ResourceVersion = fileHash;
+                        await _dbContext.SaveChangesAsync();
+                        await _cacheService.GetLanguageById(language.Id, language);
+                    }
+
+
+                    _logger.LogInformation("Saved localization file for culture: {Culture} with {Count} translations. File hash: {Hash}",
+                           culture, translations.Count, fileHash);
                 }
-
-                foreach (var item in translations)
-                {
-                    fileData[item.Key] = item.Value;
-                }
-
-                var options = new JsonSerializerOptions
-                {
-                    PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
-                    WriteIndented = true
-                };
-                var updatedJson = JsonSerializer.Serialize(fileData, options);
-                await File.WriteAllTextAsync(filePath, updatedJson);
-
-                // 更新文件后，更新数据库中的资源版本
-                string fileHash;
-                using (var sha256 = SHA256.Create())
-                using (var stream = File.OpenRead(filePath))
-                {
-                    var hashBytes = sha256.ComputeHash(stream);
-                    fileHash = BitConverter.ToString(hashBytes).Replace("-", "").ToLowerInvariant();
-                }
-                var language = _dbContext.Languages.FirstOrDefault(l => l.Culture == culture);
-                if (language != null)
-                {
-                    language.UpdateTime = DateTime.UtcNow;
-                    language.ResourceVersion = fileHash;
-                    await _dbContext.SaveChangesAsync();
-                    await _cacheService.GetLanguageById(language.Id, language);
-                }
-
-
-                _logger.LogInformation("Saved localization file for culture: {Culture} with {Count} translations. File hash: {Hash}",
-                       culture, translations.Count, fileHash);
             }
             catch (Exception ex)
             {
                 _logger.LogError(ex, "Error saving localization file for culture: {Culture}", culture);
             }
         }
+
+        /// <summary>
+        /// 重构指定文化的本地化文件
+        /// </summary>
+        /// <param name="path"></param>
+        /// <param name="culture"></param>
+        [AutomaticRetry(Attempts = 3, OnAttemptsExceeded = AttemptsExceededAction.Delete)]
+        [DisableConcurrentExecution(60)]
+        public void RebuildCultureFile(string path, string culture)
+        {
+            var language = _dbContext.Languages.FirstOrDefault(l => l.Culture == culture);
+            if (language != null)
+            {
+                var translations = _dbContext.LocaleResources
+                    .Where(lr => lr.LanguageId == language.Id)
+                    .ToDictionary(lr => lr.Name, lr => lr.Value);
+                var data = JsonSerializer.Serialize(translations, new JsonSerializerOptions
+                {
+                    PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
+                    WriteIndented = true
+                });
+
+                _ = ExecuteAsync(path, culture, data);
+            }
+            _logger.LogError("Language not found for culture: {Culture}, cannot rebuild localization file.", culture);
+        }
     }
 }