1

2025-11-12 14:31:57 +08:00 · 2025-11-12 14:28:26 +08:00 · 2025-10-10 18:39:39 +08:00 · 2025-09-30 17:17:43 +08:00 · 2025-09-29 18:36:45 +08:00 · 2025-09-29 11:25:35 +08:00
22 changed files with 977 additions and 1617 deletions
--- a/.vscode/launch.json
+++ b/.vscode/launch.json
@@ -0,0 +1,35 @@
 {
    "version": "0.2.0",
    "configurations": [
        {
            // 使用 IntelliSense 找出 C# 调试存在哪些属性
            // 将悬停用于现有属性的说明
            // 有关详细信息，请访问 https://github.com/dotnet/vscode-csharp/blob/main/debugger-launchjson.md。
            "name": ".NET Core Launch (web)",
            "type": "coreclr",
            "request": "launch",
            "preLaunchTask": "build",
            // 如果已更改目标框架，请确保更新程序路径。
            "program": "${workspaceFolder}/src/WebApi/bin/Debug/net8.0/WebApi.dll",
            "args": [],
            "cwd": "${workspaceFolder}/src/WebApi",
            "stopAtEntry": false,
            // 启用在启动 ASP.NET Core 时启动 Web 浏览器。有关详细信息: https://aka.ms/VSCode-CS-LaunchJson-WebBrowser
            "serverReadyAction": {
                "action": "openExternally",
                "pattern": "\\bNow listening on:\\s+(https?://\\S+)"
            },
            "env": {
                "ASPNETCORE_ENVIRONMENT": "Development"
            },
            "sourceFileMap": {
                "/Views": "${workspaceFolder}/Views"
            }
        },
        {
            "name": ".NET Core Attach",
            "type": "coreclr",
            "request": "attach"
        }
    ]
 }
--- a/.vscode/tasks.json
+++ b/.vscode/tasks.json
@@ -0,0 +1,41 @@
 {
    "version": "2.0.0",
    "tasks": [
        {
            "label": "build",
            "command": "dotnet",
            "type": "process",
            "args": [
                "build",
                "${workspaceFolder}/NasRobot.sln",
                "/property:GenerateFullPaths=true",
                "/consoleloggerparameters:NoSummary;ForceNoAlign"
            ],
            "problemMatcher": "$msCompile"
        },
        {
            "label": "publish",
            "command": "dotnet",
            "type": "process",
            "args": [
                "publish",
                "${workspaceFolder}/NasRobot.sln",
                "/property:GenerateFullPaths=true",
                "/consoleloggerparameters:NoSummary;ForceNoAlign"
            ],
            "problemMatcher": "$msCompile"
        },
        {
            "label": "watch",
            "command": "dotnet",
            "type": "process",
            "args": [
                "watch",
                "run",
                "--project",
                "${workspaceFolder}/NasRobot.sln"
            ],
            "problemMatcher": "$msCompile"
        }
    ]
 }
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -6,16 +6,17 @@
    container_name: nas_robot
    restart: always
    privileged: true 
-    user: root
+    user: "root:root"
    networks:
      - all_in
    environment:
      - TZ=Asia/Shanghai
    volumes:
      - /etc/localtime:/etc/localtime:ro
-      - /wd/volc/media/tv:/data/media/tv:rw
+      - /wd/media/tv:/data/media/tv:rw
-      - /wd/volc/media/anime:/data/media/anime:rw
+      - /wd/media/anime:/data/media/anime:rw
-      - /wd/volc/media/anime-other:/data/media/anime-other:rw
+      - /wd/media/music:/data/media/music:rw
      - /wd/media/others/anime:/data/media/anime-other:rw
      - /wd/apps/vols/nas_robot:/app/data:rw
      - /wd:/host/wd:ro
      - /proc/mounts:/host/proc/mounts:ro
--- a/src/Core/Command.cs
+++ b/src/Core/Command.cs
@@ -1,23 +0,0 @@
 using System.Net;
 using System.Net.Http.Json;
 namespace Core;
 public static class Command
 {
    public static async Task<(HttpStatusCode responseCode, string responseStr)> ExecAsync(params string[] commands)
    {
        var execUrl = "http://192.168.31.14:45321/exec";
        var client = new HttpClient();
        var content = JsonContent.Create(new
        {
            Token = "4CeVaIQGbB4Qln9%V@Bh8bMYSpHIUV66",
            Script = commands
        });
        var response = await client.PostAsync(execUrl, content);
        return (response.StatusCode, await response.Content.ReadAsStringAsync());
    }
 }
--- a/src/Core/Tools.cs
+++ b/src/Core/Tools.cs
@@ -1,9 +0,0 @@
 namespace Core;
 public static class Tools
 {
    public static long ToUnixTimeMilliseconds(this DateTime dateTime)
    {
        return new DateTimeOffset(dateTime).ToUnixTimeMilliseconds();
    }
 }
--- a/src/Core/WxNotify.cs
+++ b/src/Core/WxNotify.cs
@@ -4,34 +4,6 @@ namespace Core;
 public static class WxNotify
 {
    public static async Task SendDiskInfoAsync(string msg)
    {
        // 晚上11点到早上8点不通知，输出到控制台
        if (DateTime.Now.Hour >= 23 || DateTime.Now.Hour < 8)
        {
            Console.WriteLine("======================Skip WxNotify======================");
            Console.WriteLine(msg);
            Console.WriteLine("======================Skip WxNotify======================");
            return;
        }
        var wxRebotUrl = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=96f9fa23-a959-4492-ac3a-7415fae19680";
        var client = new HttpClient();
        var requestBody =
            """
            {
              "msgtype": "markdown",
              "markdown": {
                "content": "{Msg}"
              }
            }
            """;
        // 转义
        requestBody = requestBody.Replace("{Msg}", msg.Replace("\r\n", "\n"));
        await client.PostAsync(wxRebotUrl, new StringContent(requestBody, Encoding.UTF8, "application/json"));
    }
    public static async Task SendCommonAsync(string msg)
    {
        var wxRebotUrl = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=96f9fa23-a959-4492-ac3a-7415fae19680";
--- a/src/Interface/Jobs/IChineseNfoRegistry.cs
+++ b/src/Interface/Jobs/IChineseNfoRegistry.cs
@@ -2,5 +2,11 @@ namespace Interface.Jobs;
 public interface IChineseNfoRegistry
 {
-    void Job(bool ignoreLocked, bool ignoreCompleted);
+    void Job(
        string? path = null,
        int? seasonNumber = null,
        int? episodeNumber = null,
        bool ignoreLocked = false, 
        bool ignoreCompleted = false
    );
 }
--- a/src/Service/Jobs/ChineseNfoRegistry.Bak.cs
+++ b/src/Service/Jobs/ChineseNfoRegistry.Bak.cs
@@ -1,482 +0,0 @@
 // using System.Diagnostics;
 // using System.Net;
 // using System.Text.Json.Nodes;
 // using System.Xml;
 // using Core;
 // using FluentScheduler;
 // using Interface.Jobs;
 // using Microsoft.Extensions.Configuration;
 // using Microsoft.Extensions.Logging;
 //
 // namespace Service.Jobs;
 //
 // public class ChineseNfoRegistry : Registry, IChineseNfoRegistry
 // {
 //     private readonly IConfiguration _configuration;
 //     private readonly ILogger<ChineseNfoRegistry> _logger;
 //     private readonly HttpClient _client;
 //
 //     public ChineseNfoRegistry(IConfiguration configuration, ILogger<ChineseNfoRegistry> logger)
 //     {
 //         _configuration = configuration;
 //         _logger = logger;
 //
 //         var httpClientHandler = new HttpClientHandler();
 //
 //         var proxyAddress = _configuration["ChineseNfo:HttpProxy"];
 //
 //         if (string.IsNullOrEmpty(proxyAddress) == false)
 //         {
 //             httpClientHandler.Proxy = string.IsNullOrEmpty(proxyAddress) ? null : new WebProxy(proxyAddress, false);
 //             httpClientHandler.UseProxy = !string.IsNullOrEmpty(proxyAddress);
 //         }
 //
 //         _client = new HttpClient(httpClientHandler);
 //         _client.BaseAddress = new Uri("http://api.themoviedb.org");
 //
 //         Schedule(() => Job(true, true)).ToRunEvery(1).Days();
 //     }
 //
 //     public async void Job(bool ignoreLocked, bool ignoreCompleted)
 //     {
 //         try
 //         {
 //             await JobExecute(ignoreLocked, ignoreCompleted);
 //         }
 //         catch (Exception e)
 //         {
 //             _logger.LogError(e, "ChineseNfoRegistry.Job() error");
 //         }
 //     }
 //
 //
 //     private async Task JobExecute(bool ignoreLocked, bool ignoreCompleted)
 //     {
 //         // 读取环境变量 tv folder 
 //         var tvFolder = _configuration["ChineseNfo:TvFolder"];
 //         if (string.IsNullOrEmpty(tvFolder))
 //         {
 //             Console.WriteLine("请设置环境变量 tv_folder");
 //             return;
 //         }
 //
 //         var successCount = 0;
 //         var failedCount = 0;
 //         var skippedCount = 0;
 //
 //         // 扫描 tvshow.nfo 文件
 //         var tvShowFiles = Directory.GetFiles(tvFolder, "tvshow.nfo", SearchOption.AllDirectories);
 //
 //         foreach (var tvShowFile in tvShowFiles)
 //         {
 //             var nfoContent = File.ReadAllText(tvShowFile);
 //
 //             // 读取 使用XML解析器 读取 <uniqueid type="tmdb">60059</uniqueid>
 //             var tvXml = new XmlDocument();
 //             tvXml.LoadXml(nfoContent);
 //             var uniqueIdNode = tvXml.SelectSingleNode("//uniqueid[@type='tmdb']");
 //             if (uniqueIdNode == null)
 //             {
 //                 Console.WriteLine($"{tvShowFile}  &  未找到 tmdb id");
 //                 continue;
 //             }
 //
 //             if (!int.TryParse(uniqueIdNode.InnerText, out var tmdbId))
 //             {
 //                 Console.WriteLine($"{tvShowFile}  &  tmdb id 不是数字");
 //                 continue;
 //             }
 //
 //             await SetTvInfo(tvShowFile, tvXml, tmdbId);
 //             
 //             // 获取 tvShowFile 的文件夹
 //             var folderPath = Path.GetDirectoryName(tvShowFile);
 //
 //             if (folderPath == null)
 //             {
 //                 Console.WriteLine($"{tvShowFile}  &  未找到文件夹");
 //                 continue;
 //             }
 //
 //             // 扫描文件夹下其他 nfo 文件
 //             var seasonFiles = Directory.GetFiles(folderPath, "*.nfo", SearchOption.AllDirectories);
 //
 //             seasonFiles = seasonFiles.Where(x => !x.EndsWith("tvshow.nfo")).ToArray();
 //
 //             foreach (var episodeFile in seasonFiles)
 //             {
 //                 await SetEpisodeInfo(episodeFile, tmdbId);
 //             }
 //         }
 //
 //         await WxNotify.SendCommonAsync($"ChineseNfoRegistry.Job() success: {successCount}, failed: {failedCount}, skipped: {skippedCount}");
 //
 //         async Task SetTvInfo(string tvShowFile,XmlDocument tvXml, int tmdbId)
 //         {
 //              // 检查 lockdata
 //             var lockedNode = tvXml.SelectSingleNode("//lockdata");
 //             if (lockedNode != null && lockedNode.InnerText == "true" && ignoreLocked == false)
 //             {
 //                 skippedCount++;
 //                 Console.WriteLine($"{tvShowFile}  &  已锁定");
 //                 return;
 //             }
 //             
 //             // 获取tv info
 //             var tvJson = await GetTmdbTv(tvShowFile, tmdbId);
 //             
 //             if (tvJson == null)
 //             {
 //                 failedCount++;
 //                 return;
 //             }
 //             
 //             var title = tvJson["name"]?.ToString();
 //             var overview = tvJson["overview"]?.ToString();
 //             var poster =tvJson["poster_path"]?.ToString();
 //             var genres = tvJson["genres"]
 //                 ?.AsArray()
 //                 .Select(x => x?["name"]?.ToString())
 //                 .Where(x=> !string.IsNullOrEmpty(x))
 //                 .ToList();
 //
 //             if (!string.IsNullOrEmpty(title))
 //             {
 //                 title = $"<![CDATA[{title}]]>";
 //                 var titleNode = tvXml.SelectSingleNode("//title");
 //                 if (titleNode != null)
 //                 {
 //                     if (titleNode.InnerXml != title)
 //                     {
 //                         titleNode.InnerXml = title;
 //                         successCount++;
 //                     }    
 //                 }
 //                 
 //                 var sorttitleNode = tvXml.SelectSingleNode("//sorttitle");
 //                 if (sorttitleNode != null)
 //                 {
 //                     if (sorttitleNode.InnerXml != title)
 //                     {
 //                         sorttitleNode.InnerXml = title;
 //                         successCount++;
 //                     }
 //                 }
 //             }
 //             
 //             if (!string.IsNullOrEmpty(overview))
 //             {
 //                 overview = $"<![CDATA[{overview}]]>";
 //                 var plotNode = tvXml.SelectSingleNode("//plot");
 //                 if (plotNode != null)
 //                 {
 //                     if (plotNode.InnerXml != overview)
 //                     {
 //                         plotNode.InnerXml = overview;
 //                         successCount++;
 //                     }
 //                 }
 //                 
 //                 var outlineNode = tvXml.SelectSingleNode("//outline");
 //                 if (outlineNode != null)
 //                 {
 //                     if (outlineNode.InnerXml != overview)
 //                     {
 //                         outlineNode.InnerXml = overview;
 //                         successCount++;
 //                     }
 //                 }
 //             }
 //             
 //             if(!string.IsNullOrEmpty(poster))
 //             {
 //                 poster = $"http://image.tmdb.org/t/p/w1280/{poster}";
 //                 // 下载并覆盖海报
 //                 var posterPath = tvShowFile.Replace("tvshow.nfo", $"poster.{poster.Split('.').Last()}");
 //                 
 //                 using var client = new HttpClient();
 //                 var response = await client.GetAsync(poster);
 //                 if (response.IsSuccessStatusCode)
 //                 {
 //                     var bytes = await response.Content.ReadAsByteArrayAsync();
 //                     
 //                     if (File.Exists(posterPath))
 //                     {
 //                         File.Delete(posterPath);
 //                     }
 //                     
 //                     await File.WriteAllBytesAsync(posterPath, bytes);
 //                     successCount++;
 //                 }
 //             }
 //
 //
 //             if (genres?.Any() == true)
 //             {
 //                 // 删除原有的 <genre> 节点
 //                 var genreNodes = tvXml.SelectNodes("//genre");
 //                 if (genreNodes != null)
 //                 {
 //                     foreach (XmlNode genreNode in genreNodes)
 //                     {
 //                         tvXml.DocumentElement?.RemoveChild(genreNode);
 //                     }
 //                 }
 //                 
 //                 // 添加新的 <genre> 节点
 //                 foreach (var genre in genres)
 //                 {
 //                     var genreNode = tvXml.CreateElement("genre");
 //                     genreNode.InnerText = genre!;
 //                     tvXml.DocumentElement?.AppendChild(genreNode);
 //                 }
 //                 successCount++;
 //             }
 //             
 //             if (successCount == 0)
 //             {
 //                 skippedCount++;
 //                 Console.WriteLine($"{tvShowFile}  &  无更新");
 //                 return;
 //             }
 //             
 //             // 锁定节点
 //             if(lockedNode == null)
 //             {
 //                 lockedNode = tvXml.CreateElement("lockdata");
 //                 tvXml.DocumentElement?.AppendChild(lockedNode);
 //                 lockedNode.InnerText = "true";
 //             }
 //             else
 //             {
 //                 lockedNode.InnerText = "true";
 //             }
 //             
 //             // 添加一个已完成节点
 //             var completedNode = tvXml.SelectSingleNode("//completed");
 //             if (completedNode == null)
 //             {
 //                 completedNode = tvXml.CreateElement("completed");
 //                 tvXml.DocumentElement?.AppendChild(completedNode);
 //             }
 //             completedNode.InnerText = "true";
 //             
 //             try
 //             {
 //                 tvXml.Save(tvShowFile);
 //             }
 //             catch (Exception e)
 //             {
 //                 Console.WriteLine(e);
 //                 failedCount++;
 //             }
 //         }
 //
 //         async Task SetEpisodeInfo(string episodeFile, int tmdbId)
 //         {
 //             var episodeContent = await File.ReadAllTextAsync(episodeFile);
 //             var episodeXml = new XmlDocument();
 //             episodeXml.LoadXml(episodeContent);
 //
 //             // 判断有无 completed 节点
 //             var completedNode = episodeXml.SelectSingleNode("//completed");
 //             if (completedNode != null && ignoreCompleted == false)
 //             {
 //                 skippedCount++;
 //                 Console.WriteLine($"{episodeFile}  &  已完成");
 //                 return;
 //             }
 //
 //             // 判断 locked == true
 //             var lockedNode = episodeXml.SelectSingleNode("//lockdata");
 //             if (lockedNode != null && lockedNode.InnerText == "true" && ignoreLocked == false)
 //             {
 //                 skippedCount++;
 //                 Console.WriteLine($"{episodeFile}  &  已锁定");
 //                 return;
 //             }
 //
 //             // 读取 <season>1</season>
 //             var seasonNode = episodeXml.SelectSingleNode("//season");
 //             if (seasonNode == null)
 //             {
 //                 failedCount++;
 //                 Console.WriteLine($"{episodeFile}  &  未找到 season");
 //                 return;
 //             }
 //
 //             // 读取 <episode>1</episode>
 //             var episodeNode = episodeXml.SelectSingleNode("//episode");
 //             if (episodeNode == null)
 //             {
 //                 failedCount++;
 //                 Console.WriteLine($"{episodeFile}  &  未找到 episode");
 //                 return;
 //             }
 //
 //             if (!int.TryParse(seasonNode.InnerText, out var season))
 //             {
 //                 failedCount++;
 //                 Console.WriteLine($"{episodeFile}  &  season 不是数字");
 //                 return;
 //             }
 //
 //             if (!int.TryParse(episodeNode.InnerText, out var episode))
 //             {
 //                 failedCount++;
 //                 Console.WriteLine($"{episodeFile}  &  episode 不是数字");
 //                 return;
 //             }
 //
 //             // 设置 title 
 //             var titleNode = episodeXml.SelectSingleNode("//title");
 //             if (titleNode == null)
 //             {
 //                 failedCount++;
 //                 Console.WriteLine($"{episodeFile}  &  未找到 title");
 //                 return;
 //             }
 //
 //             var json = await GetTmdbEpisode(
 //                 episodeFile,
 //                 tmdbId,
 //                 season,
 //                 episode);
 //
 //             if (json == null)
 //             {
 //                 failedCount++;
 //                 return;
 //             }
 //
 //             var title = json["name"]?.ToString();
 //             var overview = json["overview"]?.ToString();
 //
 //             var isUpdate = false;
 //             if (!string.IsNullOrEmpty(title))
 //             {
 //                 title = $"<![CDATA[{title}]]>";
 //
 //                 if (titleNode.InnerXml != title)
 //                 {
 //                     isUpdate = true;
 //                     // 写入且不转义
 //                     titleNode.InnerXml = title;
 //                 }
 //             }
 //
 //             var plotNode = episodeXml.SelectSingleNode("//plot");
 //
 //             if (!string.IsNullOrEmpty(overview) && plotNode != null)
 //             {
 //                 overview = $"<![CDATA[{overview}]]>";
 //                 if (plotNode.InnerXml != overview)
 //                 {
 //                     isUpdate = true;
 //                     plotNode.InnerXml = overview;
 //                 }
 //             }
 //
 //             if (!isUpdate)
 //             {
 //                 skippedCount++;
 //                 Console.WriteLine($"{episodeFile}  &  无更新");
 //                 return;
 //             }
 //
 //             successCount++;
 //
 //             // 添加一个已完成节点
 //             if (completedNode == null)
 //             {
 //                 episodeXml.DocumentElement?.AppendChild(episodeXml.CreateElement("completed"));
 //             }
 //
 //             // 锁定
 //             if (lockedNode == null)
 //             {
 //                 lockedNode = episodeXml.CreateElement("lockdata");
 //                 episodeXml.DocumentElement?.AppendChild(lockedNode);
 //                 lockedNode.InnerText = "true";
 //             }
 //             else
 //             {
 //                 lockedNode.InnerText = "true";
 //             }
 //
 //             try
 //             {
 //                 episodeXml.Save(episodeFile);
 //             }
 //             catch (Exception e)
 //             {
 //                 Console.WriteLine(e);
 //                 return;
 //             }
 //
 //             Console.WriteLine($"{episodeFile}  &  {title}  &  {overview}");
 //         }
 //     }
 //
 //     private async Task<JsonObject?> GetTmdbTv(
 //         string path,
 //         int tmdbId)
 //     {
 //         const string tvUrl = "/3/tv/{0}?api_key=e28e1bc408db7adefc8bacce225c5085&language=zh-CN";
 //         var requestUrl = string.Format(tvUrl, tmdbId);
 //
 //         try
 //         {
 //             var response = await _client.GetAsync(requestUrl);
 //             
 //             if (!response.IsSuccessStatusCode)
 //             {
 //                 Console.WriteLine($"{requestUrl} & {path} &  {response.StatusCode}");
 //                 return null;
 //             }
 //             
 //             await Task.Delay(10000);
 //
 //             var content = await response.Content.ReadAsStringAsync();
 //             var json = JsonNode.Parse(content);
 //             return json as JsonObject;
 //         }
 //         catch (Exception e)
 //         {
 //             Console.WriteLine($"{requestUrl} & {path} \r {e}");
 //             return null;
 //         }
 //     }
 //     
 //     private async Task<JsonObject?> GetTmdbEpisode(
 //         string path,
 //         int tmdbId,
 //         int season,
 //         int episode)
 //     {
 //         const string episodeUrl = "/3/tv/{0}/season/{1}/episode/{2}?api_key=e28e1bc408db7adefc8bacce225c5085&language=zh-CN";
 //         var requestUrl = string.Format(episodeUrl, tmdbId, season, episode);
 //
 //         try
 //         {
 //             var response = await _client.GetAsync(requestUrl);
 //             
 //             await Task.Delay(10000);
 //             
 //             if (!response.IsSuccessStatusCode)
 //             {
 //                 Console.WriteLine($"{requestUrl} & {path} &  {response.StatusCode}");
 //                 return null;
 //             }
 //
 //             var content = await response.Content.ReadAsStringAsync();
 //             var json = JsonNode.Parse(content);
 //             return json as JsonObject;
 //         }
 //         catch (Exception e)
 //         {
 //             Console.WriteLine($"{requestUrl} & {path} \r {e}");
 //             return null;
 //         }
 //     }
 // }
--- a/src/Service/Jobs/ChineseNfoRegistry.cs
+++ b/src/Service/Jobs/ChineseNfoRegistry.cs
@@ -1,5 +1,7 @@
 using System.Net;
 using System.Text.RegularExpressions;
 using System.Xml;
 using Core;
 using FluentScheduler;
 using FreeSql;
 using FreeSql.DataAnnotations;
@@ -44,105 +46,575 @@ public class ChineseNfoRegistry : Registry, IChineseNfoRegistry
            .UseAutoSyncStructure(true)
            .Build();
-        Schedule(() => Job(true, true)).ToRunEvery(1).Days();
+        Schedule(() => Job(ignoreLocked: true, ignoreCompleted: true)).ToRunEvery(1).Days();
    }
-    public async void Job(bool ignoreLocked, bool ignoreCompleted)
+    public void Job(
        string? path = null,
        int? seasonNumber = null,
        int? episodeNumber = null,
        bool ignoreLocked = false,
        bool ignoreCompleted = false
    )
    {
        try
        {
-            await JobExecute(ignoreLocked, ignoreCompleted);
+            var lockAll = "lock-all";
            lock (lockAll)
            {
                var lockKey = $"{path}-{seasonNumber}-{episodeNumber}";
                lock (lockKey)
                {
                    JobExecute(path, seasonNumber, episodeNumber, ignoreLocked, ignoreCompleted).Wait();
                }
            }
        }
        catch (Exception e)
        {
-            _logger.LogError(e, "ChineseNfoRegistry.Job() error");
+            _logger.LogError(e, "error");
            WxNotify.SendCommonAsync($"ChineseNfoRegistry.Job() 执行失败 {e.Message}").Wait();
        }
        finally
        {
            _logger.LogInformation("ChineseNfoRegistry.Job() 执行结束");
        }
    }
    private async Task JobExecute(
-        bool ignoreLocked,
+        string? requestPath = null,
-        bool ignoreCompleted,
+        int? requestSeasonNumber = null,
-        string[]? includeFields = null)
+        int? requestEpisodeNumber = null,
        bool ignoreLocked = false,
        bool ignoreCompleted = false)
    {
        var tvFolder = _configuration["ChineseNfo:TvFolder"];
        if (string.IsNullOrEmpty(tvFolder))
        {
-            _logger.LogError("ChineseNfoRegistry.Job() tvFolder is null or empty");
+            _logger.LogError("tvFolder is null or empty");
            return;
        }
        /*
         * 1. 支持指定字段
         * 2. 接口数据保留
         * 3. 支持语言降级到繁体
         * 4. 支持演员名称翻译
         */
        var fields =
            includeFields ??
            [
                "tv.title",
                "tv.plot",
                "tv.outline",
                "tv.poster",
                "tv.genre",
                "tv.actor.name",
                "tv.actor.role",
                "season.title",
                "season.plot",
                "episode.title",
                "episode.plot",
                "episode.actor.name",
            ];
        var tvNfos = Directory.GetFiles(tvFolder, "tvshow.nfo", SearchOption.AllDirectories);
        if (tvNfos.Length == 0)
        {
-            _logger.LogError("ChineseNfoRegistry.Job() tvNfo is null or empty");
+            _logger.LogError("tvNfo is null or empty");
            return;
        }
        var ctn = new ChineseNfoContent();
        foreach (var tv in tvNfos)
        {
-            await HandleTv(tv);
+            ctn.tvNfoPath = tv;
            if (await HandleTv() == false)
            {
                continue;
            }
            var sseasons = Directory.GetDirectories(Path.GetDirectoryName(tv) ?? string.Empty, "Season *", SearchOption.AllDirectories);
            var sseasonsNumbers = sseasons.Select(x => x.Split("Season ")[1]).Select(int.Parse).ToList();
            foreach (var seasonNumber in sseasonsNumbers)
            {
                ctn.seasonNumber = seasonNumber;
                ctn.seasonNfoPath = Path.Combine(Path.GetDirectoryName(tv) ?? string.Empty, $"Season {seasonNumber}", "season.nfo");
                if (requestSeasonNumber != null && requestSeasonNumber != seasonNumber)
                {
                    continue;
                }
                if (File.Exists(ctn.seasonNfoPath) && await HandleSeason() == false)
                {
                    continue;
                }
                var episodeNfos = Directory
                    .GetFiles(Path.GetDirectoryName(ctn.seasonNfoPath) ?? string.Empty, "*.nfo", SearchOption.AllDirectories)
                    .Where(x => !x.EndsWith("season.nfo"))
                    .ToList();
                foreach (var episode in episodeNfos)
                {
                    ctn.episodeNfoPath = episode;
                    _logger.LogInformation("ctn.episodeNfoPath: " + ctn.episodeNfoPath);
                    try
                    {
                        await HandleEpisode();
                    }
                    catch (Exception e)
                    {
                        Console.WriteLine(e);
                    }
                }
            }
        }
-        async Task<string[]?> HandleTv(string tvNfo)
+        async Task<bool> HandleTv()
        {
-            var nfoContent = File.ReadAllText(tvNfo);
+            if (!string.IsNullOrEmpty(requestPath))
            {
                var latestPath = Path.GetFileName(requestPath) ?? string.Empty;
                if (!ctn.tvNfoPath.Contains(latestPath))
                {
                    return false;
                }
            }
            _logger.LogInformation("开始处理 TV");
            var nfoContent = File.ReadAllText(ctn.tvNfoPath);
            var tvXml = new XmlDocument();
            tvXml.LoadXml(nfoContent);
            var uniqueIdNode = tvXml.SelectSingleNode("//uniqueid[@type='tmdb']");
            if (uniqueIdNode == null)
            {
-                _logger.LogError("ChineseNfoRegistry.Job() uniqueIdNode is null");
+                _logger.LogError("uniqueIdNode is null");
-                return null;
+                return false;
            }
            if (!int.TryParse(uniqueIdNode.InnerText, out var tmdbId))
            {
-                _logger.LogError("ChineseNfoRegistry.Job() tmdbId is null");
+                _logger.LogError("tmdbId is null");
                return false;
            }
            ctn.tvId = tmdbId;
            var isLockedNode = tvXml.SelectSingleNode("//locked");
            if (isLockedNode != null && isLockedNode.InnerText == "true" && ignoreLocked)
            {
                _logger.LogInformation("tvNfo is locked");
                return true;
            }
            var isCompletedNode = tvXml.SelectSingleNode("//completed");
            if (isCompletedNode != null && isCompletedNode.InnerText == "true" && ignoreCompleted)
            {
                _logger.LogInformation("tvNfo is completed");
                return true;
            }
            var tvInfo = await GetTmdbTv(ctn.tvNfoPath, tmdbId);
            if (tvInfo == null)
            {
                _logger.LogError("tvInfo is null");
                return true;
            }
            if (tvInfo["name"] != null)
            {
                var titleNode = tvXml.SelectSingleNode("//title");
                if (titleNode != null)
                {
                    titleNode.InnerXml = $"<![CDATA[{tvInfo["name"]}]]>";
                }
                var sorttitleNode = tvXml.SelectSingleNode("//sorttitle");
                if (sorttitleNode != null)
                {
                    sorttitleNode.InnerXml = $"<![CDATA[{tvInfo["name"]}]]>";
                }
                _logger.LogInformation("tvInfo: {tvInfo}", tvInfo["name"]);
            }
            if (tvInfo["overview"] != null)
            {
                var plotNode = tvXml.SelectSingleNode("//plot");
                if (plotNode != null)
                {
                    plotNode.InnerXml = $"<![CDATA[{tvInfo["overview"]}]]>";
                }
                var outlineNode = tvXml.SelectSingleNode("//outline");
                if (outlineNode != null)
                {
                    outlineNode.InnerXml = $"<![CDATA[{tvInfo["overview"]}]]>";
                }
                _logger.LogInformation("tvInfo: {tvInfo}", tvInfo["overview"]);
            }
            if (tvInfo["poster_path"] != null)
            {
                var posterPath = tvInfo["poster_path"]!.ToString();
                var image = await GetTmdbImage(ctn.tvNfoPath, posterPath);
                if (image != null)
                {
                    var imagePath = Path.Combine(Path.GetDirectoryName(ctn.tvNfoPath) ?? string.Empty, "poster" + Path.GetExtension(posterPath));
                    await File.WriteAllBytesAsync(imagePath, image);
                }
            }
            var actors = tvXml.SelectNodes("//actor");
            if (actors != null)
            {
                foreach (XmlNode actor in actors)
                {
                    await HandleActor(actor);
                }
            }
            _logger.LogInformation("tmdbId: {tmdbId}, name: {name}", tmdbId, tvInfo["name"]?.ToString());
            if (isLockedNode != null)
            {
                isLockedNode.InnerText = "true";
            }
            else
            {
                isLockedNode = tvXml.CreateElement("locked");
                tvXml.DocumentElement?.AppendChild(isLockedNode);
                isLockedNode.InnerText = "true";
            }
            if (isCompletedNode != null)
            {
                isCompletedNode.InnerText = "true";
            }
            else
            {
                isCompletedNode = tvXml.CreateElement("completed");
                tvXml.DocumentElement?.AppendChild(isCompletedNode);
                isCompletedNode.InnerText = "true";
            }
            // 保存
            tvXml.Save(ctn.tvNfoPath);
            return true;
        }
        async Task<bool> HandleSeason()
        {
            if (string.IsNullOrEmpty(ctn.seasonNfoPath))
            {
                _logger.LogError("seasonNfoPath is null or empty");
                return false;
            }
            var nfoContent = File.ReadAllText(ctn.seasonNfoPath);
            var seasonXml = new XmlDocument();
            seasonXml.LoadXml(nfoContent);
            var seasonNumberNode = seasonXml.SelectSingleNode("//seasonnumber");
            if (seasonNumberNode == null)
            {
                _logger.LogError("seasonNumberNode is null");
                return false;
            }
            if (!int.TryParse(seasonNumberNode.InnerText, out var seasonNumber))
            {
                _logger.LogError("seasonNumber is null");
                return false;
            }
            ctn.seasonNumber = seasonNumber;
            _logger.LogInformation("开始处理 Season");
            var isLockedNode = seasonXml.SelectSingleNode("//locked");
            if (isLockedNode != null && isLockedNode.InnerText == "true" && ignoreLocked)
            {
                _logger.LogInformation("seasonNfo is locked");
                return true;
            }
            var isCompletedNode = seasonXml.SelectSingleNode("//completed");
            if (isCompletedNode != null && isCompletedNode.InnerText == "true" && ignoreCompleted)
            {
                _logger.LogInformation("seasonNfo is completed");
                return true;
            }
            var seasonInfo = await GetTmdbSeason(ctn);
            if (seasonInfo == null)
            {
                _logger.LogError("seasonInfo is null");
                return true;
            }
            var titleNode = seasonXml.SelectSingleNode("//sorttitle");
            if (titleNode != null && seasonInfo["name"] != null)
            {
                _logger.LogInformation("seasonInfo: {seasonInfo}", seasonInfo["name"]);
                titleNode.InnerXml = $"<![CDATA[{seasonInfo["name"]}]]>";
            }
            var plotNode = seasonXml.SelectSingleNode("//plot");
            if (plotNode != null && seasonInfo["overview"] != null)
            {
                _logger.LogInformation("seasonInfo: {seasonInfo}", seasonInfo["overview"]);
                plotNode.InnerXml = $"<![CDATA[{seasonInfo["overview"]}]]>";
            }
            var outlineNode = seasonXml.SelectSingleNode("//outline");
            if (outlineNode != null && seasonInfo["overview"] != null)
            {
                _logger.LogInformation("seasonInfo: {seasonInfo}", seasonInfo["overview"]);
                outlineNode.InnerXml = $"<![CDATA[{seasonInfo["overview"]}]]>";
            }
            var poster_path = seasonInfo["poster_path"]?.ToString();
            if (poster_path != null)
            {
                var image = await GetTmdbImage(ctn.seasonNfoPath, poster_path);
                if (image != null)
                {
                    var imagePath = Path.Combine(Path.GetDirectoryName(ctn.tvNfoPath) ?? string.Empty, "season" + seasonNumber.ToString("D2") + "-poster" + Path.GetExtension(poster_path));
                    await File.WriteAllBytesAsync(imagePath, image);
                }
            }
            if (isLockedNode != null)
            {
                isLockedNode.InnerText = "true";
            }
            else
            {
                isLockedNode = seasonXml.CreateElement("locked");
                seasonXml.DocumentElement?.AppendChild(isLockedNode);
                isLockedNode.InnerText = "true";
            }
            if (isCompletedNode != null)
            {
                isCompletedNode.InnerText = "true";
            }
            else
            {
                isCompletedNode = seasonXml.CreateElement("completed");
                seasonXml.DocumentElement?.AppendChild(isCompletedNode);
                isCompletedNode.InnerText = "true";
            }
            seasonXml.Save(ctn.seasonNfoPath);
            return true;
        }
        async Task HandleEpisode()
        {
            if (string.IsNullOrEmpty(ctn.episodeNfoPath))
            {
                _logger.LogError("episodeNfoPath is null or empty");
                return;
            }
            var nfoContent = File.ReadAllText(ctn.episodeNfoPath);
            var episodeXml = new XmlDocument();
            episodeXml.LoadXml(nfoContent);
            var episodeNumberNode = episodeXml.SelectSingleNode("//episode");
            if (episodeNumberNode == null)
            {
                _logger.LogError("episodeNumberNode is null");
                return;
            }
            if (!int.TryParse(episodeNumberNode.InnerText, out var episodeNumber))
            {
                _logger.LogError("episodeNumber is null");
                return;
            }
            ctn.episodeNumber = episodeNumber;
            if (!string.IsNullOrEmpty(requestPath))
            {
                if (requestSeasonNumber != null)
                {
                    if (requestEpisodeNumber != null)
                    {
                        if (episodeNumber != requestEpisodeNumber)
                        {
                            return;
                        }
                    }
                }
            }
            _logger.LogInformation("开始处理 Episode");
            var isLockedNode = episodeXml.SelectSingleNode("//locked");
            if (isLockedNode != null && isLockedNode.InnerText == "true" && ignoreLocked)
            {
                _logger.LogInformation("episodeNfo is locked");
                return;
            }
            var isCompletedNode = episodeXml.SelectSingleNode("//completed");
            if (isCompletedNode != null && isCompletedNode.InnerText == "true" && ignoreCompleted)
            {
                _logger.LogInformation("episodeNfo is completed");
                return;
            }
            var episodeInfo = await GetTmdbEpisode(ctn);
            if (episodeInfo == null)
            {
                _logger.LogError("episodeInfo is null");
                return;
            }
            var titleNode = episodeXml.SelectSingleNode("//title");
            if (titleNode != null && episodeInfo["name"] != null)
            {
                _logger.LogInformation("episodeInfo: {episodeInfo}", episodeInfo["name"]);
                titleNode.InnerXml = $"<![CDATA[{episodeInfo["name"]}]]>";
            }
            var plotNode = episodeXml.SelectSingleNode("//plot");
            if (plotNode != null && episodeInfo["overview"] != null)
            {
                _logger.LogInformation("episodeInfo: {episodeInfo}", episodeInfo["overview"]);
                plotNode.InnerXml = $"<![CDATA[{episodeInfo["overview"]}]]>";
            }
            var outlineNode = episodeXml.SelectSingleNode("//outline");
            if (outlineNode != null && episodeInfo["overview"] != null)
            {
                _logger.LogInformation("episodeInfo: {episodeInfo}", episodeInfo["overview"]);
                outlineNode.InnerXml = $"<![CDATA[{episodeInfo["overview"]}]]>";
            }
            var actors = episodeXml.SelectNodes("//actor");
            if (actors != null)
            {
                foreach (XmlNode actor in actors)
                {
                    await HandleActor(actor);
                }
            }
            _logger.LogInformation("tmdbId: {tmdbId}, name: {name}", ctn.tvId, episodeInfo["name"]?.ToString());
            if (isLockedNode != null)
            {
                isLockedNode.InnerText = "true";
            }
            else
            {
                isLockedNode = episodeXml.CreateElement("locked");
                episodeXml.DocumentElement?.AppendChild(isLockedNode);
                isLockedNode.InnerText = "true";
            }
            if (isCompletedNode != null)
            {
                isCompletedNode.InnerText = "true";
            }
            else
            {
                isCompletedNode = episodeXml.CreateElement("completed");
                episodeXml.DocumentElement?.AppendChild(isCompletedNode);
                isCompletedNode.InnerText = "true";
            }
            // 保存
            episodeXml.Save(ctn.episodeNfoPath);
        }
        async Task<string?> GetTmdbPersonName(
            string path,
            int? tmdbId = null,
            string? name = null
        )
        {
            if (tmdbId != null)
            {
                var person = await GetTmdbPerson(path, tmdbId.Value);
                return person?["name"]?.ToString() ?? name;
            }
            if (string.IsNullOrEmpty(name) == false)
            {
                // 如果名称是中文直接返回
                if (Regex.IsMatch(name, "^[\u4e00-\u9fa5]+$"))
                {
                    return name;
                }
                var person = await GetTmdbPersonSearch(path, name);
                return person?["name"]?.ToString() ?? name;
            }
            return null;
        }
-            var a = await GetTmdbTv(tvNfo, tmdbId);
+        async Task HandleActor(XmlNode actor)
        {
            var nameNode = actor.SelectSingleNode("name");
            var tmdbIdNode = actor.SelectSingleNode("tmdbid");
            if (nameNode != null || tmdbIdNode != null)
            {
                var name = await GetTmdbPersonName(
                    tvFolder,
                    int.TryParse(tmdbIdNode?.InnerText, out var actorTmdbId) ? actorTmdbId : null,
                    nameNode?.InnerText
                );
-            _logger.LogInformation("ChineseNfoRegistry.Job() tmdbId: {tmdbId}, name: {name}", tmdbId,a?["name"]?.ToString());
+                if (name == null)
-            return [];
+                {
                    return;
                }
                if (nameNode != null)
                {
                    nameNode.InnerXml = $"<![CDATA[{name}]]>";
                }
                else
                {
                    actor.AppendChild(new XmlDocument().CreateElement("name"));
                    nameNode = actor.SelectSingleNode("name");
                    nameNode!.InnerXml = $"<![CDATA[{name}]]>";
                }
                _logger.LogInformation("actor: {actor}", name);
            }
        }
    }
    private async Task<JObject?> GetTmdbTv(
        string path,
-        int tmdbId,
+        int tmdbId)
        TheMovieDbLanguage language = TheMovieDbLanguage.ZhCn)
    {
        var record = await _freeSql.Select<TheMovieDbRecord>()
            .Where(x => x.Type == TheMovieDbType.Tv)
            .Where(x => x.UniqueId == tmdbId.ToString())
            .FirstAsync();
@@ -154,21 +626,10 @@ public class ChineseNfoRegistry : Registry, IChineseNfoRegistry
        record = new TheMovieDbRecord
        {
            Type = TheMovieDbType.Tv,
-            UniqueId = tmdbId.ToString(),
+            UniqueId = tmdbId.ToString()
            Language = language
        };
-        string tvUrl = "/3/tv/{0}?api_key=e28e1bc408db7adefc8bacce225c5085&language=";
+        string tvUrl = "/3/tv/{0}?api_key=e28e1bc408db7adefc8bacce225c5085&language=zh-CN";
        if(language == TheMovieDbLanguage.ZhCn)
        {
            tvUrl += "zh-CN";
        }
        else
        {
            tvUrl += "zh-TW";
        }
        var requestUrl = string.Format(tvUrl, tmdbId);
        try
@@ -177,34 +638,266 @@ public class ChineseNfoRegistry : Registry, IChineseNfoRegistry
            if (!response.IsSuccessStatusCode)
            {
-                Console.WriteLine($"{requestUrl} & {path} &  {response.StatusCode}");
+                _logger.LogError("ChineseNfoRegistry.GetTmdbTv() 接口调用失败 {requestUrl} & {path} &  {response.StatusCode}", requestUrl, path, response.StatusCode);
                return null;
            }
            var str = await response.Content.ReadAsStringAsync();
            var json = JObject.Parse(str);
            var name = json["name"];
            // 判断是否包含中文字符
            var isChinese = name != null && name.ToString().Any(c => c >= 0x4E00 && c <= 0x9FA5);
            if (language == TheMovieDbLanguage.ZhCn && !isChinese)
            {
                _logger.LogWarning("ChineseNfoRegistry.GetTmdbTv() name: {name}, 无中文文字, 降级到繁体字", name);
                // 降级到繁体
                return await GetTmdbTv(path, tmdbId, TheMovieDbLanguage.ZhTw);
            }
            record.Json = str;
-            _freeSql.Insert(record);
+            await _freeSql.Insert(record).ExecuteIdentityAsync();
-            _logger.LogInformation("ChineseNfoRegistry.GetTmdbTv() 接口调用, 休眠 5S");
+            _logger.LogInformation("ChineseNfoRegistry.GetTmdbTv() 接口调用, 休眠 1S");
-            await Task.Delay(5000);
+            await Task.Delay(1000);
            return json;
        }
        catch (Exception e)
        {
-            Console.WriteLine($"{requestUrl} & {path} \r {e}");
+            _logger.LogError("ChineseNfoRegistry.GetTmdbTv() 接口调用失败 {requestUrl} & {path} \r {e}", requestUrl, path, e);
            return null;
        }
    }
    private async Task<JObject?> GetTmdbPerson(
        string path,
        int tmdbId)
    {
        var record = await _freeSql.Select<TheMovieDbRecord>()
            .Where(x => x.Type == TheMovieDbType.Person)
            .Where(x => x.UniqueId == tmdbId.ToString())
            .FirstAsync();
        if (record != null)
        {
            return JObject.Parse(record.Json);
        }
        record = new TheMovieDbRecord
        {
            Type = TheMovieDbType.Person,
            UniqueId = tmdbId.ToString(),
            Language = TheMovieDbLanguage.ZhCn
        };
        var requestUrl = string.Format("/3/person/{0}?api_key=e28e1bc408db7adefc8bacce225c5085&language=zh-CN", tmdbId);
        try
        {
            var response = await _apiClient.GetAsync(requestUrl);
            if (!response.IsSuccessStatusCode)
            {
                _logger.LogError("ChineseNfoRegistry.GetTmdbPerson() 接口调用失败 {requestUrl} & {path} &  {response.StatusCode}", requestUrl, path, response.StatusCode);
                return null;
            }
            var str = await response.Content.ReadAsStringAsync();
            var json = JObject.Parse(str);
            record.Json = str;
            await _freeSql.Insert(record).ExecuteIdentityAsync();
            _logger.LogInformation("ChineseNfoRegistry.GetTmdbPerson() 接口调用, 休眠 1S");
            await Task.Delay(1000);
            return json;
        }
        catch (Exception e)
        {
            _logger.LogError("ChineseNfoRegistry.GetTmdbPerson() 接口调用失败 {requestUrl} & {path} \r {e}", requestUrl, path, e);
            return null;
        }
    }
    private async Task<JObject?> GetTmdbPersonSearch(
        string path,
        string name)
    {
        var record = await _freeSql.Select<TheMovieDbRecord>()
            .Where(x => x.Type == TheMovieDbType.Person)
            .Where(x => x.UniqueId == name)
            .FirstAsync();
        if (record != null)
        {
            return JObject.Parse(record.Json);
        }
        record = new TheMovieDbRecord
        {
            Type = TheMovieDbType.Person,
            UniqueId = name
        };
        var requestUrl = string.Format("/3/search/person?api_key=e28e1bc408db7adefc8bacce225c5085&language=zh-CN&query={0}", name);
        try
        {
            var response = await _apiClient.GetAsync(requestUrl);
            if (!response.IsSuccessStatusCode)
            {
                _logger.LogError("ChineseNfoRegistry.GetTmdbPersonSearch() 接口调用失败 {requestUrl} & {path} &  {response.StatusCode}", requestUrl, path, response.StatusCode);
                return null;
            }
            var str = await response.Content.ReadAsStringAsync();
            var json = JObject.Parse(str);
            var results = json["results"];
            if (results != null)
            {
                foreach (var result in results.Cast<JObject>())
                {
                    record.Json = result.ToString();
                    await _freeSql.Insert(record).ExecuteIdentityAsync();
                    _logger.LogInformation("ChineseNfoRegistry.GetTmdbPersonSearch() 接口调用, 休眠 1S");
                    await Task.Delay(1000);
                    return result;
                }
            }
            return null;
        }
        catch (Exception e)
        {
            _logger.LogError("ChineseNfoRegistry.GetTmdbPersonSearch() 接口调用失败 {requestUrl} & {path} \r {e}", requestUrl, path, e);
            return null;
        }
    }
    private async Task<byte[]?> GetTmdbImage(
        string path,
        string posterPath)
    {
        var requestUrl = string.Format("/t/p/w1280/{0}", posterPath);
        try
        {
            var response = await _imageClient.GetAsync(requestUrl);
            if (!response.IsSuccessStatusCode)
            {
                _logger.LogError("ChineseNfoRegistry.GetTmdbImage() 接口调用失败 {requestUrl} & {path} &  {response.StatusCode}", requestUrl, path, response.StatusCode);
                return null;
            }
            return await response.Content.ReadAsByteArrayAsync();
        }
        catch (Exception e)
        {
            _logger.LogError("ChineseNfoRegistry.GetTmdbImage() 接口调用失败 {requestUrl} & {path} \r {e}", requestUrl, path, e);
            return null;
        }
    }
    private async Task<JObject?> GetTmdbSeason(ChineseNfoContent ctn)
    {
        if (ctn.seasonNumber == 0 || string.IsNullOrEmpty(ctn.seasonNfoPath))
        {
            _logger.LogError("seasonNfoPath is null or empty");
            return null;
        }
        var uniqueId = $"{ctn.tvId}-{ctn.seasonNumber}";
        var record = await _freeSql.Select<TheMovieDbRecord>()
            .Where(x => x.Type == TheMovieDbType.Season)
            .Where(x => x.UniqueId == uniqueId)
            .FirstAsync();
        if (record != null)
        {
            return JObject.Parse(record.Json);
        }
        record = new TheMovieDbRecord
        {
            Type = TheMovieDbType.Season,
            UniqueId = uniqueId
        };
        var requestUrl = string.Format("/3/tv/{0}/season/{1}?api_key=e28e1bc408db7adefc8bacce225c5085&language=zh-CN", ctn.tvId, ctn.seasonNumber);
        try
        {
            var response = await _apiClient.GetAsync(requestUrl);
            if (!response.IsSuccessStatusCode)
            {
                _logger.LogError("ChineseNfoRegistry.GetTmdbSeason() 接口调用失败 {requestUrl} & {path} &  {response.StatusCode}", requestUrl, ctn.tvNfoPath, response.StatusCode);
                return null;
            }
            var str = await response.Content.ReadAsStringAsync();
            record.Json = str;
            await _freeSql.Insert(record).ExecuteIdentityAsync();
            _logger.LogInformation("ChineseNfoRegistry.GetTmdbSeason() 接口调用, 休眠 1S");
            await Task.Delay(1000);
            return JObject.Parse(str);
        }
        catch (Exception e)
        {
            _logger.LogError("ChineseNfoRegistry.GetTmdbSeason() 接口调用失败 {requestUrl} & {path} \r {e}", requestUrl, ctn.tvNfoPath, e);
            return null;
        }
    }
    private async Task<JObject?> GetTmdbEpisode(ChineseNfoContent ctn)
    {
        var uniqueId = $"{ctn.tvId}-{ctn.seasonNumber}-{ctn.episodeNumber}";
        var record = await _freeSql.Select<TheMovieDbRecord>()
            .Where(x => x.Type == TheMovieDbType.Episode)
            .Where(x => x.UniqueId == uniqueId)
            .FirstAsync();
        if (record != null)
        {
            return JObject.Parse(record.Json);
        }
        record = new TheMovieDbRecord
        {
            Type = TheMovieDbType.Episode,
            UniqueId = uniqueId
        };
        var requestUrl = string.Format("/3/tv/{0}/season/{1}/episode/{2}?api_key=e28e1bc408db7adefc8bacce225c5085&language=zh-CN", ctn.tvId, ctn.seasonNumber, ctn.episodeNumber);
        try
        {
            var response = await _apiClient.GetAsync(requestUrl);
            if (!response.IsSuccessStatusCode)
            {
                _logger.LogError("ChineseNfoRegistry.GetTmdbEpisode() 接口调用失败 {requestUrl} & {path} &  {response.StatusCode}", requestUrl, ctn.episodeNfoPath, response.StatusCode);
                return null;
            }
            var str = await response.Content.ReadAsStringAsync();
            record.Json = str;
            await _freeSql.Insert(record).ExecuteIdentityAsync();
            _logger.LogInformation("ChineseNfoRegistry.GetTmdbEpisode() 接口调用, 休眠 1S");
            await Task.Delay(1000);
            return JObject.Parse(str);
        }
        catch (Exception e)
        {
            _logger.LogError("ChineseNfoRegistry.GetTmdbEpisode() 接口调用失败 {requestUrl} & {path} \r {e}", requestUrl, ctn.episodeNfoPath, e);
            return null;
        }
    }
@@ -212,6 +905,7 @@ public class ChineseNfoRegistry : Registry, IChineseNfoRegistry
 public class TheMovieDbRecord
 {
    [Column(IsPrimary = true, IsIdentity = true)]
    public long Id { get; set; }
    public TheMovieDbType Type { get; set; }
@@ -220,8 +914,7 @@ public class TheMovieDbRecord
    public TheMovieDbLanguage Language { get; set; }
-    [Column(DbType = "text")] 
+    [Column(DbType = "text")] public string Json { get; set; } = string.Empty;
    public string Json { get; set; } = string.Empty;
 }
 public enum TheMovieDbType
@@ -229,6 +922,7 @@ public enum TheMovieDbType
    Tv = 1,
    Season = 2,
    Episode = 3,
    Person = 4
 }
 public enum TheMovieDbLanguage
@@ -236,3 +930,18 @@ public enum TheMovieDbLanguage
    ZhCn = 1,
    ZhTw = 2
 }
 public class ChineseNfoContent
 {
    public int tvId { get; set; }
    public string tvNfoPath { get; set; } = string.Empty;
    public int seasonNumber { get; set; }
    public string seasonNfoPath { get; set; } = string.Empty;
    public int episodeNumber { get; set; }
    public string episodeNfoPath { get; set; } = string.Empty;
 }
--- a/src/Service/Jobs/DiskActionMonitorRegistry.cs
+++ b/src/Service/Jobs/DiskActionMonitorRegistry.cs
@@ -1,174 +0,0 @@
 using Core;
 using FluentScheduler;
 using Interface.Jobs;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Logging;
 namespace Service.Jobs;
 public enum DiskNotifyType
 {
    Action,
    Sleep
 }
 public class DiskActionMonitorRegistry : Registry, IDiskActionMonitorRegistry
 {
    private readonly IConfiguration _configuration;
    private static Dictionary<string, int> _lastReadCount = new();
    private static Dictionary<string, int> _lastWriteCount = new();
    private readonly ILogger<DiskActionMonitorRegistry> _logger;
    private static readonly Dictionary<string, List<(DateTime, DiskNotifyType)>> LatestNotifyTimes = new();
    private static readonly Dictionary<string, DateTime> LastChangedTimes = new();
    public DiskActionMonitorRegistry(IConfiguration configuration, ILogger<DiskActionMonitorRegistry> logger)
    {
        _configuration = configuration;
        _logger = logger;
        Schedule(Job).ToRunEvery(5).Seconds();
    }
    public async void Job()
    {
        try
        {
            await JobExecute();
        }
        catch (Exception e)
        {
            _logger.LogError(e, "DiskActionMonitorRegistry.Job() error");
        }
    }
    private async Task JobExecute()
    {
        var filePath = _configuration["DiskActionMonitor:FilePath"] ?? throw new ArgumentNullException($"DiskActionMonitor:FilePath");
        var disks = _configuration
            .GetSection("DiskActionMonitor:Disks")
            .GetChildren()
            .Select(x => x.Value);
        foreach (var disk in disks)
        {
            if (string.IsNullOrEmpty(disk))
            {
                continue;
            }
            if (!_lastReadCount.ContainsKey(disk))
            {
                _lastReadCount.Add(disk, 0);
            }
            if (!_lastWriteCount.ContainsKey(disk))
            {
                _lastWriteCount.Add(disk, 0);
            }
            if (!LatestNotifyTimes.ContainsKey(disk))
            {
                LatestNotifyTimes.Add(disk, new());
            }
            if (!LastChangedTimes.ContainsKey(disk))
            {
                LastChangedTimes.Add(disk, DateTime.Now);
            }
            var content = await File.ReadAllTextAsync(string.Format(filePath, disk));
            var cols = content.Split(" ", StringSplitOptions.RemoveEmptyEntries);
            var readCount = TryGetByIndex(cols, 2);
            var writeCount = TryGetByIndex(cols, 6);
            if (!int.TryParse(readCount, out var read) || !int.TryParse(writeCount, out var write))
            {
                continue; // 读取失败
            }
            var readDiff = read - _lastReadCount[disk];
            var writeDiff = write - _lastWriteCount[disk];
            _lastReadCount[disk] = read;
            _lastWriteCount[disk] = write;
            if (readDiff > 0 || writeDiff > 0)
            {
                _logger.LogInformation($"[{disk}]  ReadDiff: {readDiff}, WriteDiff: {writeDiff}");
            }
            if (readDiff > 10 || writeDiff > 10)
            {
                // 上一次通知的是休眠或者没有通知 发现有变换通知变化
                if (LatestNotifyTimes[disk].Any() == false
                    || LatestNotifyTimes[disk].Last().Item2 == DiskNotifyType.Sleep)
                {
                    LatestNotifyTimes[disk].Add((DateTime.Now, DiskNotifyType.Action));
                    await WxNotify.SendDiskInfoAsync(@$"
 ## 磁盘 <font color='info'> {disk} </font> 刚发生读写操作 🙋
 > 当前累计读: <font color='warning'> {GetEasyReadNumber(read)} </font>、新增读： <font color='warning'> {GetEasyReadNumber(readDiff)} </font>
 > 当前累计写: <font color='warning'> {GetEasyReadNumber(write)} </font>、新增写： <font color='warning'> {GetEasyReadNumber(writeDiff)} </font>
 当前时间: <font color='comment'> {DateTime.Now:yyyy-M-d H:m:s} </font>");
                }
                else if (DateTime.Now - LatestNotifyTimes[disk].Last().Item1 > TimeSpan.FromHours(1))
                {
                    LatestNotifyTimes[disk].Add((DateTime.Now, DiskNotifyType.Action));
                    await WxNotify.SendDiskInfoAsync(@$"
 ## 磁盘 <font color='info'> {disk} </font>  连续运行超一小时 👨‍💻
 > 当前累计读: <font color='warning'> {GetEasyReadNumber(read)} </font>
 > 当前累计写: <font color='warning'> {GetEasyReadNumber(write)} </font>
 当前时间: <font color='comment'> {DateTime.Now:yyyy-M-d H:m:s} </font>");
                }
                _lastReadCount[disk] = read;
                _lastWriteCount[disk] = write;
                LastChangedTimes[disk] = DateTime.Now;
                continue;
            }
            // 没有变化 上一次是启动通知且超过10分钟，通知休眠
            if (LatestNotifyTimes[disk].Any() == false
                || (LatestNotifyTimes[disk].Last().Item2 == DiskNotifyType.Action
                    && DateTime.Now - LastChangedTimes[disk] > TimeSpan.FromMinutes(10)))
            {
                LatestNotifyTimes[disk].Add((DateTime.Now, DiskNotifyType.Sleep));
                await WxNotify.SendDiskInfoAsync(@$"
 ## 磁盘 <font color='info'> {disk} </font> 长时间无读写变化 😪
 > 上一次读写时间：{LatestNotifyTimes[disk].Last(x => x.Item2 == DiskNotifyType.Action).Item1:yyyy-M-d H:m:s}
 > 当前累计读: <font color='warning'> {GetEasyReadNumber(read)} </font>
 > 当前累计写: <font color='warning'> {GetEasyReadNumber(write)} </font>
 当前时间: <font color='comment'> {DateTime.Now:yyyy-M-d H:m:s} </font>");
            }
        }
    }
    private string TryGetByIndex(string[] arr, int index) => index < arr.Length ? arr[index] : string.Empty;
    private string GetEasyReadNumber(int number)
    {
        if (number < 10000)
        {
            return number.ToString();
        }
        if (number < 100000000)
        {
            return $"{number / 10000M:0.##} 万";
        }
        return $"{number / 100000000M:0.##} 亿";
    }
 }
--- a/src/Service/Jobs/DiskMonitorRegistry.cs
+++ b/src/Service/Jobs/DiskMonitorRegistry.cs
@@ -1,104 +0,0 @@
 using System.Diagnostics;
 using System.Text;
 using FluentScheduler;
 using InfluxDB.Client;
 using InfluxDB.Client.Api.Domain;
 using InfluxDB.Client.Writes;
 using Interface.Jobs;
 namespace Service.Jobs;
 public class DiskMonitorRegistry : Registry, IDiskMonitorRegistry
 {
    public DiskMonitorRegistry()
    {
        Schedule(Job).ToRunNow().AndEvery(1).Hours();
    }
    public void Job()
    {
        try
        {
            JobExecute();
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
        }
    }
    private void JobExecute()
    {
        // 执行 cmd 命令 获取执行结果
        var command = "df -h";
        var process = new Process
        {
            StartInfo = new()
            {
                FileName = "/bin/bash",
                Arguments = $"-c \"{command}\"",
                RedirectStandardOutput = true,
                UseShellExecute = false,
                CreateNoWindow = true
            }
        };
        process.Start();
        var result = process.StandardOutput.ReadToEnd();
        process.WaitForExit();
        var format = FormatResult(result);
        WriteToInfluxDB(format);
    }
    private string FormatResult(string result)
    {
        var lines = result.Split("\n");
        var sb = new StringBuilder();
        foreach (var line in lines)
        {
            var cols = line.Split(" ", StringSplitOptions.RemoveEmptyEntries);
            if (line.Contains("/host/wd/"))
            {
                sb.AppendLine($"{cols[5].Substring("/host".Length)},{cols[1]},{cols[4].TrimEnd('%')},{cols[3]}");
            }
        }
        return sb.ToString();
    }
    private void WriteToInfluxDB(string result)
    {
        var lines = result.Split("\n");
        using var client = new InfluxDBClient("http://influxdb:8086", "BD4A71llb9_XbCA5mmKDbc_yTYwadPPLwyk4nAQ0l_yR_WJmw_-dMOWIs0KlS7-pZtHot_HrejY5GcOohKElmA==");
        using var writeApi = client.GetWriteApi();
        foreach (var line in lines)
        {
            Console.WriteLine(line);
            var cols = line.Split(",", StringSplitOptions.RemoveEmptyEntries);
            if(cols.Length != 4) continue;
            var path = cols[0];
            var totalSize = cols[1];
            var usedPercent = cols[2];
            var available = cols[3];
            var point = PointData
                .Measurement("disk_usage")
                .Tag("path", path)
                .Field("total_size", totalSize)
                .Field("used_percent", double.Parse(usedPercent))
                .Field("available", available)
                .Timestamp(DateTime.UtcNow, WritePrecision.Ns);
            writeApi.WritePoint(point, "def-bucket", "def-org");
            Console.WriteLine($"[DiskMonitor] Write point: {point.ToLineProtocol()}");
        }
    }
 }
--- a/src/Service/Jobs/HealthyTaskRegistry.cs
+++ b/src/Service/Jobs/HealthyTaskRegistry.cs
@@ -1,95 +0,0 @@
 using System.Diagnostics;
 using System.Net;
 using System.Net.Http.Headers;
 using System.Net.Http.Json;
 using System.Text;
 using Core;
 using FluentScheduler;
 using Interface.Jobs;
 using Microsoft.Extensions.Configuration;
 namespace Service.Jobs;
 public class HealthyTaskRegistry : Registry, IHealthyTaskRegistry
 {
    private readonly IConfiguration _configuration;
    public HealthyTaskRegistry(IConfiguration configuration)
    {
        _configuration = configuration;
        Schedule(Job).ToRunNow().AndEvery(2).Minutes();
    }
    public async void Job()
    {
        try
        {
            await JobExecute();
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
            await WxNotify.SendCommonAsync($"HealthyTaskRegistry.Job() error: {e}");
        }
    }
    private async Task JobExecute()
    {
        // 获取 配置 是个 KV 集合
        var configs = _configuration.GetSection("HealthyTasks");
        // 遍历配置
        foreach (var item in configs.GetChildren())
        {
            // 获取配置的 containerName 和 url
            var containerName = item["ContainerName"];
            var url = item["Url"];
            // 执行
            await ExecuteItem(containerName!, url!);
        }
    }
    private async Task ExecuteItem(string containerName, string url)
    {
        try
        {
            var client = new HttpClient();
            // basic auth
            string authInfo = Convert.ToBase64String(Encoding.ASCII.GetBytes("suncheng:SCsunch940622"));
            client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Basic", authInfo);
            var response = await client.GetAsync(url);
            if (response.StatusCode != HttpStatusCode.OK)
            {
                throw new Exception($"StatusCode: {response.StatusCode}");
            }
            Console.WriteLine($"ContainerName: {containerName}, Url: {url}, StatusCode: {response.StatusCode}");
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
            await WxNotify.SendCommonAsync($"ExecuteItem {containerName} error: {e.Message}");
            await ExecuteReboot(containerName);
        }
    }
    private async Task ExecuteReboot(string containerName)
    {
        var command = $"docker restart {containerName}";
        var (responseCode, message) = await Command.ExecAsync(command);
        if (responseCode != HttpStatusCode.OK)
        {
            await WxNotify.SendCommonAsync($"ExecuteReboot {containerName} error: {responseCode} message: {message}");
        }
        else
        {
            await WxNotify.SendCommonAsync($"ContainerName: {containerName}");
        }
    }
 }
--- a/src/Service/Jobs/LogTotalNotifyJobRegistry.cs
+++ b/src/Service/Jobs/LogTotalNotifyJobRegistry.cs
@@ -1,106 +0,0 @@
 using System.Text;
 using Core;
 using FluentScheduler;
 using Interface.Jobs;
 using Microsoft.Extensions.Configuration;
 using Newtonsoft.Json.Linq;
 namespace Service.Jobs;
 public class LogTotalNotifyJobRegistry : Registry, ILogTotalNotifyJobRegistry
 {
    private readonly IConfiguration _configuration;
    public LogTotalNotifyJobRegistry(IConfiguration configuration)
    {
        _configuration = configuration;
        Schedule(Job).ToRunEvery(1).Days().At(8, 30);
    }
    public async void Job()
    {
        try
        {
            // await JobExecute();
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
            await WxNotify.SendCommonAsync($"LogTotalNotifyJobRegistry.Job() error: {e}");
        }
    }
    private async Task JobExecute()
    {
        var client = new HttpClient();
        client.DefaultRequestHeaders.Add("Authorization", $"Bearer {_configuration["Grafana:Token"]}");
        var requestBody =
            """
            {
              "queries": [
                {
                  "datasource": {
                    "type": "loki",
                    "uid": "edf5cwf6n6i2oe"
                  },
                  "editorMode": "builder",
                  "expr": "sum by(container_name) (count_over_time({compose_project=~\"dockers|immich|nasrobot|elasticsearch|webui-docker\"} [1h]))",
                  "queryType": "range",
                  "refId": "A",
                  "datasourceId": 2,
                  "intervalMs": 3600000
                }
              ],
              "from": "1708963200000",
              "to": "1709049600000"
            }
            """;
        requestBody = requestBody.Replace("1708963200000", DateTime.Today.AddDays(-2).ToUnixTimeMilliseconds().ToString());
        requestBody = requestBody.Replace("1709049600000", DateTime.Today.AddDays(-1).ToUnixTimeMilliseconds().ToString());
        var content = new StringContent(requestBody, Encoding.UTF8, "application/json");
        var response = await client.PostAsync(_configuration["Grafana:LokiUrl"], content);
        var result = await response.Content.ReadAsStringAsync();
        var jObject = JObject.Parse(result);
        var frames = jObject["results"]?["A"]?["frames"];
        if (frames == null)
        {
            throw new Exception("frames is null");
        }
        var msg = new StringBuilder();
        msg.AppendLine($"## {DateTime.Today.AddDays(-1):yyyy-MM-dd}日志明细如下：");
        var total = 0;
        var kv = new Dictionary<string, int>();
        foreach (var item in frames)
        {
            var name = item["schema"]?["fields"]?.LastOrDefault()?["labels"]?["container_name"]?.ToString();
            if (string.IsNullOrEmpty(name))
            {
                continue;
            }
            var values = item["data"]?["values"]?.LastOrDefault()?.ToObject<int[]>();
            var value = values?.Sum() ?? 0;
            total += value;
            kv[name] = value;
        }
        foreach (var (key, value) in kv.OrderByDescending(x => x.Value))
        {
            msg.AppendLine($"<font color='info'>**{key}**</font>: <font color='warning'>{value}</font>");
        }
        msg.AppendLine("");
        msg.AppendLine($"> **总计**: <font color='warning'>{total}</font>");
        await WxNotify.SendCommonAsync(msg.ToString());
    }
 }
--- a/src/Service/Jobs/RSyncTaskRegistry.cs
+++ b/src/Service/Jobs/RSyncTaskRegistry.cs
@@ -1,69 +0,0 @@
 using System.Diagnostics;
 using System.Net.Http.Json;
 using Core;
 using FluentScheduler;
 using Interface.Jobs;
 using Microsoft.Extensions.Configuration;
 namespace Service.Jobs;
 public class RSyncTaskRegistry : Registry, IRSyncTaskRegistry
 {
    private readonly IConfiguration _configuration;
    public RSyncTaskRegistry(IConfiguration configuration)
    {
        _configuration = configuration;
        Schedule(Job).ToRunEvery(1).Days().At(10, 0);
    }
    public async void Job()
    {
        try
        {
            // await JobExecute();
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
            await WxNotify.SendCommonAsync($"RSyncTaskRegistry.Job() error: {e}");
        }
    }
    private async Task JobExecute()
    {
        var config = _configuration.GetSection("SyncTask");
        foreach (var item in config.GetSection("SyncPaths").GetChildren())
        {
            var source = Path.Combine(config["SourceRoot"]!, item["Source"]!);
            var isDeleteAfter = item["DeleteAfter"] == "true";
            await ExecuteItem(source, config["TargetRoot"]!, item["Target"]!, isDeleteAfter);
        }
    }
    private async Task ExecuteItem(string source, string remote, string destination, bool isDeleteAfter)
    {
        var logName = $"rclone_output_{destination.Replace("/", "_")}{DateTime.Now:yyMMddHHmm}.log";
        var commands = new[]
        {
            $"rclone sync " +
            $"{source} " +
            $"{remote}:{destination} " +
            $"--fast-list " +
            $"--size-only " +
            $"{(isDeleteAfter ? "--delete-after" : "--delete-excluded")} " +
            $"> /wd/logs/{logName} 2>&1"
        };
        await WxNotify.SendCommonAsync($@"RSyncTaskRegistry.ExecuteItem() 
 `{commands[0]}`
 > {DateTime.Now:yyyy-MM-dd HH:mm:ss}
 ");
        _ = Command.ExecAsync(commands);
    }
 }
--- a/src/Service/Jobs/ShutdownRegistry.cs
+++ b/src/Service/Jobs/ShutdownRegistry.cs
@@ -1,61 +0,0 @@
 using System.Net;
 using Core;
 using FluentScheduler;
 using Interface.Jobs;
 namespace Service.Jobs;
 public class ShutdownRegistry : Registry, IShutdownRegistry
 {
    public ShutdownRegistry()
    {
        Schedule(Job).ToRunEvery(1).Days().At(23, 30);
    }
    public async void Job()
    {
        try
        {
            await JobExecute();
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
            await WxNotify.SendCommonAsync($"ShutdownRegistry.Job() error: {e}");
        }
    }
    private async Task JobExecute()
    {
        var command = "shutdown 9";
        var (responseCode, msg) = await Command.ExecAsync(command);
        var wxMsg = $@"
 # 定时关机指令执行 
 > 执行结果：{responseCode}
 > 执行消息：{msg}
 如需取消关机请点击：[取消关机](http://suncheng.online:35642/api/JobTrigger/CancelShutdown)
 ";
        await WxNotify.SendCommonAsync(wxMsg);
        if (responseCode == HttpStatusCode.OK)
        {
            // 每三分钟提醒一次
            _ = Task.Delay(3 * 60 * 1000).ContinueWith(async _ => await WxNotify.SendCommonAsync(wxMsg));
        }
    }
    public async Task CancelShutdown()
    {
        var command = "shutdown -c";
        var (responseCode, _) = await Command.ExecAsync(command);
        await WxNotify.SendCommonAsync($"取消关机指令执行完成 {responseCode}");
    }
 }
--- a/src/Service/Jobs/StartupRegistry.cs
+++ b/src/Service/Jobs/StartupRegistry.cs
@@ -1,46 +0,0 @@
 using System.Net;
 using Core;
 using FluentScheduler;
 using Interface.Jobs;
 namespace Service.Jobs;
 public class StartupRegistry : Registry, IStartupRegistry
 {
    public StartupRegistry()
    {
        Schedule(Job).ToRunNow();
    }
    public async void Job()
    {
        try
        {
            // await JobExecute();
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
            await WxNotify.SendCommonAsync($"StartupRegistry.Job() error: {e}");
        }
    }
    private async Task JobExecute()
    {
        var commands = new[]
        {
            "chmod 777 /var/run/docker.sock",
        };
        var (responseCode, _) = await Command.ExecAsync(commands);
        if (responseCode != HttpStatusCode.OK)
        {
            await WxNotify.SendCommonAsync($"StartupRegistry.Job() error: {responseCode}");
        }
        else
        {
            await WxNotify.SendCommonAsync("StartupRegistry.Job() success");
        }
    }
 }
--- a/src/WebApi/Controllers/JobTriggerController.cs
+++ b/src/WebApi/Controllers/JobTriggerController.cs
@@ -1,112 +1,125 @@
-using Interface.Jobs;
+using System.Text.Json.Nodes;
 using Core;
 using Interface.Jobs;
 using Microsoft.AspNetCore.Mvc;
 using Newtonsoft.Json;
 using Newtonsoft.Json.Linq;
 namespace WebApi.Controllers;
 public class JobTriggerController : BaseController
 {
    private readonly ILogTotalNotifyJobRegistry _logTotalNotifyJobRegistry;
    private readonly IDiskActionMonitorRegistry _diskActionMonitorRegistry;
    private readonly IHealthyTaskRegistry _healthyTaskRegistry;
    private readonly IRSyncTaskRegistry _rSyncTaskRegistry;
    private readonly IStartupRegistry _startupRegistry;
    private readonly IShutdownRegistry _shutdownRegistry;
    private readonly IChineseNfoRegistry _chineseNfoRegistry;
-    private readonly IDiskMonitorRegistry _diskMonitorRegistry;
+
    private readonly ILogger<JobTriggerController> _logger;
    /// <summary>
    ///     ctor
    /// </summary>
    public JobTriggerController(
        ILogTotalNotifyJobRegistry logTotalNotifyJobRegistry,
        IDiskActionMonitorRegistry diskActionMonitorRegistry,
        IHealthyTaskRegistry healthyTaskRegistry,
        IRSyncTaskRegistry rSyncTaskRegistry,
        IStartupRegistry startupRegistry, 
        IShutdownRegistry shutdownRegistry, 
        IChineseNfoRegistry chineseNfoRegistry,
-        IDiskMonitorRegistry diskMonitorRegistry)
+        ILogger<JobTriggerController> logger)
    {
        _logTotalNotifyJobRegistry = logTotalNotifyJobRegistry;
        _diskActionMonitorRegistry = diskActionMonitorRegistry;
        _healthyTaskRegistry = healthyTaskRegistry;
        _rSyncTaskRegistry = rSyncTaskRegistry;
        _startupRegistry = startupRegistry;
        _shutdownRegistry = shutdownRegistry;
        _chineseNfoRegistry = chineseNfoRegistry;
-        _diskMonitorRegistry = diskMonitorRegistry;
+        _logger = logger;
    }
    [HttpGet]
-    public string LogTotalNotify()
+    public string ConvertChineseNfo(
        bool ignoreLocked = true,
        bool ignoreCompleted = true)
    {
-        _logTotalNotifyJobRegistry.Job();
+        _chineseNfoRegistry.Job(ignoreLocked: ignoreLocked, ignoreCompleted: ignoreCompleted);
        return "OK";
    }
    [HttpPost]
    public async Task<string> SonarrChangedConvertChineseNfo()
    {
        var body = Request.Body;
        using var reader = new StreamReader(body);
        var text = await reader.ReadToEndAsync();
        var json = JsonConvert.DeserializeObject<JObject>(text);
        var eventType = json?["eventType"]?.ToString();
        if (eventType != "Download")
        {
            return "OK";
        }
        _logger.LogInformation("SonarrChangedConvertChineseNfo() called");
        await Task.Delay(10_000);
        var seasonNumber = json?["episodes"]?[0]?["seasonNumber"]?.ToObject<int>();
        var episodeNumber = json?["episodes"]?[0]?["episodeNumber"]?.ToObject<int>();
        var path = json?["series"]?["path"]?.ToString();
        await WxNotify.SendCommonAsync($"SonarrChangedConvertChineseNfo() path: {path}, seasonNumber: {seasonNumber}, episodeNumber: {episodeNumber}");
        _logger.LogInformation("SonarrChangedConvertChineseNfo() path: {path}, seasonNumber: {seasonNumber}, episodeNumber: {episodeNumber}", path, seasonNumber, episodeNumber);
        if (string.IsNullOrEmpty(path) || seasonNumber == null || episodeNumber == null)
        {
            return "OK";
        }
        await Task.Delay(10_000); // 休眠10S，防止文件还未能创建
        _chineseNfoRegistry.Job(path: path, seasonNumber: seasonNumber, episodeNumber: episodeNumber, ignoreLocked: true, ignoreCompleted: true);
        return "OK";
    }
    [HttpGet]
-    public string DiskActionMonitor()
+    public string ConvertChineseNfoByPath(
        string path,
        int? seasonNumber = null,
        int? episodeNumber = null,
        bool ignoreLocked = true,
        bool ignoreCompleted = true)
    {
-        _diskActionMonitorRegistry.Job();
+        _chineseNfoRegistry.Job(path: path, seasonNumber: seasonNumber, episodeNumber: episodeNumber, ignoreLocked: ignoreLocked, ignoreCompleted: ignoreCompleted);
        return "OK";
    }
    [HttpGet]
-    public string HealthyTask()
+    public string MusicTagAsync()
    {
-        _healthyTaskRegistry.Job();
+        var musicPath = "/data/media/music";
        List<string> musicType = ["mp3", "flac", "m4a", "wav", "ape", "ogg", "wma", "alac", "aac", "dsd"];
-        return "OK";
+        // 递归获取所有音乐文件
        var files = Directory.GetFiles(musicPath, "*.*", SearchOption.AllDirectories)
            .Where(f => musicType.Contains(Path.GetExtension(f).TrimStart('.').ToLower()))
            .ToList();
        foreach (var file in files)
        {
            _logger.LogInformation("Processing music file: {file}", file);
            try
            {
                var fileTag = TagLib.File.Create(file);
                var artist = fileTag.Tag.FirstPerformer ?? "未知艺术家";
                var album = fileTag.Tag.Album ?? "未知专辑";
                var title = fileTag.Tag.Title ?? Path.GetFileNameWithoutExtension(file);
                var year = fileTag.Tag.Year > 0 ? fileTag.Tag.Year.ToString() : "未知年份";
                var genre = fileTag.Tag.FirstGenre ?? "未知风格";
                _logger.LogInformation("Tag info - Artist: {artist}, Album: {album}, Title: {title}, Year: {year}, Genre: {genre}", artist, album, title, year, genre);
            }
-
+            catch (Exception e)
    [HttpGet]
    public string RSyncTask()
            {
-        _rSyncTaskRegistry.Job();
+                _logger.LogError(e, "Error processing music file: {file}", file);
        return "OK";
            }
    [HttpGet]
    public string Startup()
    {
        _startupRegistry.Job();
        return "OK";
        }
    [HttpGet]
    public string Shutdown()
    {
        _shutdownRegistry.Job();
        return "OK";
    }
    [HttpGet]
    public string CancelShutdown()
    {
        _shutdownRegistry.CancelShutdown();
        return "OK";
    }
    [HttpGet]
    public string ConvertChineseNfo(bool ignoreLocked = false, bool ignoreCompleted = false)
    {
        _chineseNfoRegistry.Job(ignoreLocked, ignoreCompleted);
        return "OK";
    }
    [HttpGet]
    public string DiskMonitor()
    {
        _diskMonitorRegistry.Job();
        return "OK";
    }
 }
--- a/src/WebApi/Controllers/NotifyController.cs
+++ b/src/WebApi/Controllers/NotifyController.cs
@@ -7,10 +7,6 @@ namespace WebApi.Controllers;
 public class NotifyController : BaseController
 {
    public NotifyController()
    {
    }
    [HttpPost]
    public async Task<string> Radarr()
    {
@@ -21,40 +17,6 @@ public class NotifyController : BaseController
        Console.WriteLine(text);
        /*
         {
  "movie": {
    "id": 1,
    "title": "Test Title",
    "year": 1970,
    "releaseDate": "1970-01-01",
    "folderPath": "C:\\testpath",
    "tmdbId": 0,
    "tags": [
      "test-tag"
    ]
  },
  "remoteMovie": {
    "tmdbId": 1234,
    "imdbId": "5678",
    "title": "Test title",
    "year": 1970
  },
  "release": {
    "quality": "Test Quality",
    "qualityVersion": 1,
    "releaseGroup": "Test Group",
    "releaseTitle": "Test Title",
    "indexer": "Test Indexer",
    "size": 9999999,
    "customFormatScore": 0
  },
  "eventType": "Test",
  "instanceName": "Radarr",
  "applicationUrl": ""
 }
         */
        var jsonObj = JsonConvert.DeserializeObject<JObject>(text);
        var notify = @$"# Radarr通知：
@@ -96,189 +58,6 @@ public class NotifyController : BaseController
        Console.WriteLine(text);
        /*
 {
  "series": {
    "id": 86,
    "title": "Demon Slayer: Kimetsu no Yaiba",
    "titleSlug": "demon-slayer-kimetsu-no-yaiba",
    "path": "/data/anime/Demon Slayer - Kimetsu no Yaiba",
    "tvdbId": 348545,
    "tvMazeId": 41469,
    "tmdbId": 85937,
    "imdbId": "tt9335498",
    "type": "anime",
    "year": 2019,
    "genres": [
      "Action",
      "Adventure",
      "Animation",
      "Anime",
      "Drama",
      "Fantasy",
      "Thriller"
    ],
    "images": [
      {
        "coverType": "banner",
        "url": "/MediaCover/86/banner.jpg?lastWrite=638509998968281535",
        "remoteUrl": "https://artworks.thetvdb.com/banners/graphical/5ccd960cc3aa0.jpg"
      },
      {
        "coverType": "poster",
        "url": "/MediaCover/86/poster.jpg?lastWrite=638509998969561521",
        "remoteUrl": "https://artworks.thetvdb.com/banners/v4/series/348545/posters/60908d475f49a.jpg"
      },
      {
        "coverType": "fanart",
        "url": "/MediaCover/86/fanart.jpg?lastWrite=638509998971801497",
        "remoteUrl": "https://artworks.thetvdb.com/banners/fanart/original/5c93cbb2b60b6.jpg"
      },
      {
        "coverType": "clearlogo",
        "url": "/MediaCover/86/clearlogo.png?lastWrite=638509998972921485",
        "remoteUrl": "https://artworks.thetvdb.com/banners/v4/series/348545/clearlogo/611c7fa8222d6.png"
      }
    ],
    "tags": [
      "anime"
    ]
  },
  "episodes": [
    {
      "id": 2716,
      "episodeNumber": 2,
      "seasonNumber": 5,
      "title": "Water Hashira Giyu Tomioka's Pain",
      "overview": "Kagaya's Kasugai Crow suddenly appears in front of Tamayo and invites her to the Demon Slayer headquarters — even though she is a demon. Meanwhile, Tanjiro, who is recovering at the Butterfly Mansion, receives a letter from Kagaya...",
      "airDate": "2024-05-19",
      "airDateUtc": "2024-05-19T14:15:00Z",
      "seriesId": 86,
      "tvdbId": 10445764
    }
  ],
  "release": {
    "quality": "WEBDL-1080p",
    "qualityVersion": 1,
    "releaseGroup": "ToonsHub",
    "releaseTitle": "[ToonsHub] Demon Slayer Kimetsu no Yaiba S05E02 1080p CR WEB-DL AAC2.0 x264 (Multi-Subs)",
    "indexer": "Knaben ",
    "size": 1395864320,
    "customFormatScore": 0,
    "customFormats": []
  },
  "downloadClient": "aria2",
  "downloadClientType": "Aria2",
  "downloadId": "915718C3A8A5B15BD3C32A2B05885953D96AFADD",
  "customFormatInfo": {
    "customFormats": [],
    "customFormatScore": 0
  },
  "eventType": "Grab",
  "instanceName": "Sonarr",
  "applicationUrl": ""
 }
 --------------------------
 {
  "series": {
    "id": 86,
    "title": "Demon Slayer: Kimetsu no Yaiba",
    "titleSlug": "demon-slayer-kimetsu-no-yaiba",
    "path": "/data/anime/Demon Slayer - Kimetsu no Yaiba",
    "tvdbId": 348545,
    "tvMazeId": 41469,
    "tmdbId": 85937,
    "imdbId": "tt9335498",
    "type": "anime",
    "year": 2019,
    "genres": [
      "Action",
      "Adventure",
      "Animation",
      "Anime",
      "Drama",
      "Fantasy",
      "Thriller"
    ],
    "images": [
      {
        "coverType": "banner",
        "url": "/MediaCover/86/banner.jpg?lastWrite=638509998968281535",
        "remoteUrl": "https://artworks.thetvdb.com/banners/graphical/5ccd960cc3aa0.jpg"
      },
      {
        "coverType": "poster",
        "url": "/MediaCover/86/poster.jpg?lastWrite=638509998969561521",
        "remoteUrl": "https://artworks.thetvdb.com/banners/v4/series/348545/posters/60908d475f49a.jpg"
      },
      {
        "coverType": "fanart",
        "url": "/MediaCover/86/fanart.jpg?lastWrite=638509998971801497",
        "remoteUrl": "https://artworks.thetvdb.com/banners/fanart/original/5c93cbb2b60b6.jpg"
      },
      {
        "coverType": "clearlogo",
        "url": "/MediaCover/86/clearlogo.png?lastWrite=638509998972921485",
        "remoteUrl": "https://artworks.thetvdb.com/banners/v4/series/348545/clearlogo/611c7fa8222d6.png"
      }
    ],
    "tags": [
      "anime"
    ]
  },
  "episodes": [
    {
      "id": 2716,
      "episodeNumber": 2,
      "seasonNumber": 5,
      "title": "Water Hashira Giyu Tomioka's Pain",
      "overview": "Kagaya's Kasugai Crow suddenly appears in front of Tamayo and invites her to the Demon Slayer headquarters — even though she is a demon. Meanwhile, Tanjiro, who is recovering at the Butterfly Mansion, receives a letter from Kagaya...",
      "airDate": "2024-05-19",
      "airDateUtc": "2024-05-19T14:15:00Z",
      "seriesId": 86,
      "tvdbId": 10445764
    }
  ],
  "downloadInfo": {
    "quality": "WEBDL-1080p",
    "qualityVersion": 1,
    "title": "Demon.Slayer.Kimetsu.no.Yaiba.S57E02.Water.Hashira.Giyu.Tomiokas.Pain.1080p.CR.WEB-DL.JPN.AAC2.0.H.264.MSubs-ToonsHub.mkv",
    "size": 1446462408
  },
  "downloadClient": "aria2",
  "downloadClientType": "Aria2",
  "downloadId": "915718C3A8A5B15BD3C32A2B05885953D96AFADD",
  "downloadStatus": "Warning",
  "downloadStatusMessages": [
    {
      "title": "One or more episodes expected in this release were not imported or missing from the release",
      "messages": []
    },
    {
      "title": "Demon.Slayer.Kimetsu.no.Yaiba.S57E02.Water.Hashira.Giyu.Tomiokas.Pain.1080p.CR.WEB-DL.JPN.AAC2.0.H.264.MSubs-ToonsHub.mkv",
      "messages": [
        "Invalid season or episode"
      ]
    }
  ],
  "customFormatInfo": {
    "customFormats": [],
    "customFormatScore": 0
  },
  "release": {
    "releaseTitle": "[ToonsHub] Demon Slayer Kimetsu no Yaiba S05E02 1080p CR WEB-DL AAC2.0 x264 (Multi-Subs)",
    "indexer": "Knaben ",
    "size": 1395864320
  },
  "eventType": "ManualInteractionRequired",
  "instanceName": "Sonarr",
  "applicationUrl": ""
 }
         */
        var jsonObj = JsonConvert.DeserializeObject<JObject>(text);
        var notify = @$"# Sonarr通知：
@@ -302,7 +81,12 @@ public class NotifyController : BaseController
        if (jsonObj["release"] != null)
        {
-            var gb = (jsonObj["release"]!.ToObject<decimal>() / 1024M / 1024M / 1024M).ToString("0.##");
+            var gb = jsonObj["release"]!["size"]!.ToString();
            gb = decimal.TryParse(gb, out var size) 
                ? (size / 1024M / 1024M / 1024M).ToString("0.##") 
                : "0";
            notify += @$"
 索引器：<font color='info'> {jsonObj["release"]!["indexer"]} </font>
 发布组：<font color='info'> {jsonObj["release"]!["releaseGroup"]}({jsonObj["release"]!["quality"] ?? jsonObj["downloadInfo"]!["quality"]}) </font>
--- a/src/WebApi/Controllers/XiaoController.cs
+++ b/src/WebApi/Controllers/XiaoController.cs
@@ -1,34 +0,0 @@
 using Core;
 using Microsoft.AspNetCore.Mvc;
 namespace WebApi.Controllers;
 public class XiaoController : BaseController
 {
    private readonly ILogger<XiaoController> _logger;
    public XiaoController(ILogger<XiaoController> logger)
    {
        _logger = logger;
    }
    [HttpGet]
    public async Task<string> GotoHomeGame()
    {
        await WxNotify.SendCommonAsync("接收到启动游戏机指令");
        var commands = new[]
        {
            "grub-reboot 2",
            "reboot"
        };
        _ = Task.Run(async () =>
        {
            await Task.Delay(3000);
            _ = await Command.ExecAsync(commands);
        });
        return "OK";
    }
 }
--- a/src/WebApi/Program.cs
+++ b/src/WebApi/Program.cs
@@ -36,18 +36,18 @@ app.MapControllers();
 // JobManager.Initialize((DiskActionMonitorRegistry)diskActionMonitorRegistry);
 // var syncTaskRegistry = app.Services.GetRequiredService<IRSyncTaskRegistry>();
 // JobManager.Initialize((RSyncTaskRegistry)syncTaskRegistry);
-var healthyTaskRegistry = app.Services.GetRequiredService<IHealthyTaskRegistry>();
+// var healthyTaskRegistry = app.Services.GetRequiredService<IHealthyTaskRegistry>();
-JobManager.Initialize((HealthyTaskRegistry)healthyTaskRegistry);
+// JobManager.Initialize((HealthyTaskRegistry)healthyTaskRegistry);
 // var rsyncTaskRegistry = app.Services.GetRequiredService<IRSyncTaskRegistry>();
 // JobManager.Initialize((RSyncTaskRegistry)rsyncTaskRegistry);
 // var startupRegistry = app.Services.GetRequiredService<IStartupRegistry>();
 // JobManager.Initialize((StartupRegistry)startupRegistry);
 // var shutdownRegistry = app.Services.GetRequiredService<IShutdownRegistry>();
 // JobManager.Initialize((ShutdownRegistry)shutdownRegistry);
-var chineseNfoRegistry = app.Services.GetRequiredService<IChineseNfoRegistry>();
+// var chineseNfoRegistry = app.Services.GetRequiredService<IChineseNfoRegistry>();
-JobManager.Initialize((ChineseNfoRegistry)chineseNfoRegistry);
+// JobManager.Initialize((ChineseNfoRegistry)chineseNfoRegistry);
-var diskMonitorRegistry = app.Services.GetRequiredService<IDiskMonitorRegistry>();
+// var diskMonitorRegistry = app.Services.GetRequiredService<IDiskMonitorRegistry>();
-JobManager.Initialize((DiskMonitorRegistry)diskMonitorRegistry);
+// JobManager.Initialize((DiskMonitorRegistry)diskMonitorRegistry);
 #endif
 app.Run();
--- a/src/WebApi/WebApi.csproj
+++ b/src/WebApi/WebApi.csproj
@@ -9,8 +9,9 @@
    </PropertyGroup>
    <ItemGroup>
-        <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="8.0.0"/>
+        <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="8.0.0" />
-        <PackageReference Include="Swashbuckle.AspNetCore" Version="6.4.0"/>
+        <PackageReference Include="Swashbuckle.AspNetCore" Version="6.4.0" />
        <PackageReference Include="taglib-sharp-netstandard2.0" Version="2.1.0" />
    </ItemGroup>
    <ItemGroup>
--- a/src/WebApi/appsettings.Development.json
+++ b/src/WebApi/appsettings.Development.json
@@ -31,6 +31,7 @@
  ],
  "ChineseNfo": {
    "TvFolder": "D:\\codes\\others\\ConvertChineseNfo",
-    "HttpProxy": "http://suncheng.online:47890"
+    "HttpProxy": "",
    "ConnectionString": "Data Source=D:\\codes\\others\\ConvertChineseNfo\\chinesenfo.db;"
  }
 }
Author	SHA1	Message	Date
孙诚	b304269079	1 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 25s Details Docker Build & Deploy / Deploy to Production (push) Successful in 6s Details	2025-11-12 14:31:57 +08:00
孙诚	e7168a2fe6	1 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 1m0s Details Docker Build & Deploy / Deploy to Production (push) Successful in 7s Details	2025-11-12 14:28:26 +08:00
孙诚	626a8a2950	1 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 23s Details Docker Build & Deploy / Deploy to Production (push) Successful in 10s Details	2025-10-10 18:39:39 +08:00
孙诚	a650d4197a	更新 docker-compose.yml 中的媒体文件路径，移除 JobTriggerController 和 NotifyController 中的未使用代码 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 48s Details Docker Build & Deploy / Deploy to Production (push) Successful in 6s Details	2025-09-30 17:17:43 +08:00
孙诚	f93cd5b405	1 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 23s Details Docker Build & Deploy / Deploy to Production (push) Successful in 6s Details	2025-09-29 18:36:45 +08:00
孙诚	e682814630	添加异常处理以捕获 HandleEpisode 方法中的错误 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 24s Details Docker Build & Deploy / Deploy to Production (push) Successful in 7s Details	2025-09-29 11:25:35 +08:00
孙诚	33b17c9937	注释掉 DiskMonitorRegistry 的初始化代码 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 28s Details Docker Build & Deploy / Deploy to Production (push) Successful in 7s Details	2025-09-29 11:08:51 +08:00
孙诚	e739638fae	更新 docker-compose.yml 中的媒体文件路径 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 7s Details Docker Build & Deploy / Deploy to Production (push) Successful in 13s Details	2025-09-29 11:06:28 +08:00
孙诚	7e67e26bb2	1 Some checks failed Docker Build & Deploy / Build Docker Image (push) Successful in 15s Details Docker Build & Deploy / Deploy to Production (push) Failing after 2s Details	2025-05-26 23:03:57 +08:00
suncheng	46832d78a2	更新 src/WebApi/Program.cs All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 14s Details Docker Build & Deploy / Deploy to Production (push) Successful in 4s Details	2025-05-24 16:40:46 +08:00
孙诚	2c728891a5	1 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 15s Details Docker Build & Deploy / Deploy to Production (push) Successful in 3s Details	2025-04-22 19:27:19 +08:00
孙诚	a60c058a49	1 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 13s Details Docker Build & Deploy / Deploy to Production (push) Successful in 4s Details	2025-04-22 17:52:47 +08:00
孙诚	b492658dc6	优化 ChineseNfoRegistry 类中的季号验证逻辑，简化条件判断以提高代码可读性。 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 13s Details Docker Build & Deploy / Deploy to Production (push) Successful in 4s Details	2025-04-22 17:51:14 +08:00
孙诚	aa1970a36e	优化季节 NFO 文件处理逻辑，修复季号提取中的字符串分割问题，并增加日志记录以便于调试。 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 25s Details Docker Build & Deploy / Deploy to Production (push) Successful in 5s Details	2025-04-22 17:43:09 +08:00
孙诚	1e4da61d68	更新 docker-compose.yml 文件，将用户配置修改为 "1000:1000" 格式，以确保容器的权限设置更加明确。 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 4s Details Docker Build & Deploy / Deploy to Production (push) Successful in 4s Details	2025-04-22 17:36:04 +08:00
孙诚	90ccaba1a3	更新 ChineseNfoRegistry 类，优化季节 NFO 文件处理逻辑，移除不必要的文件创建步骤，增强季号验证和处理的准确性。 Some checks failed Docker Build & Deploy / Build Docker Image (push) Successful in 12s Details Docker Build & Deploy / Deploy to Production (push) Failing after 4s Details	2025-04-22 17:33:44 +08:00
孙诚	cb41791656	1 Some checks failed Docker Build & Deploy / Build Docker Image (push) Successful in 25s Details Docker Build & Deploy / Deploy to Production (push) Failing after 4s Details	2025-04-22 17:30:11 +08:00
孙诚	8ebab0d6f8	在 JobTriggerController 类中增加了 10 秒的延迟，以防止文件未能创建的问题，确保后续处理的稳定性。 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 13s Details Docker Build & Deploy / Deploy to Production (push) Successful in 4s Details	2025-04-22 16:19:43 +08:00
孙诚	7a18330524	更新 ChineseNfoRegistry 类，简化季号和集号的处理逻辑，增强错误日志记录，确保在处理 NFO 文件时更好地捕获异常情况。 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 14s Details Docker Build & Deploy / Deploy to Production (push) Successful in 4s Details	2025-04-22 16:17:09 +08:00
孙诚	84e35fb631	更新 IChineseNfoRegistry 和 ChineseNfoRegistry 类，修改 Job 方法的季号和集号参数类型为 int，增强类型安全性；简化日志记录，减少冗余信息，提高可读性。	2025-04-22 15:57:58 +08:00
孙诚	6c443f2fde	更新 NotifyController 类，修正 JSON 对象转换方式，将 ToObject<string>() 方法改为 ToString()，以提高代码的准确性和可读性。 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 14s Details Docker Build & Deploy / Deploy to Production (push) Successful in 4s Details	2025-04-22 15:27:56 +08:00
孙诚	3403881b2a	更新 ChineseNfoRegistry 类，优化 Job 方法的锁定逻辑，改为同步执行以避免潜在的并发问题；更新 JobTriggerController 类，增加日志记录以跟踪路径、季号和集号的处理情况。 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 15s Details Docker Build & Deploy / Deploy to Production (push) Successful in 5s Details	2025-04-22 15:24:21 +08:00
孙诚	2364e41825	更新 ChineseNfoRegistry 类，简化日志记录逻辑，改进季号和集号的提取方式，增强代码可读性。 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 12s Details Docker Build & Deploy / Deploy to Production (push) Successful in 3s Details	2025-04-21 17:43:48 +08:00
孙诚	d379f516c5	更新 ChineseNfoRegistry 类，增强日志记录以反映季号和集号的比较结果，改进路径和参数验证逻辑。 Some checks failed Docker Build & Deploy / Build Docker Image (push) Failing after 9s Details Docker Build & Deploy / Deploy to Production (push) Has been skipped Details	2025-04-21 17:27:19 +08:00
孙诚	694db295a9	更新 ChineseNfoRegistry 类，修正路径检查逻辑以使用最新路径；更新 JobTriggerController 类，移除 tmdbId 参数，改为使用路径参数。 Some checks failed Docker Build & Deploy / Build Docker Image (push) Failing after 20s Details Docker Build & Deploy / Deploy to Production (push) Has been skipped Details	2025-04-21 16:20:03 +08:00
孙诚	8ceb88846c	更新 ChineseNfoRegistry 类，增加季节 NFO 文件创建逻辑；更新 JobTriggerController 类，新增根据路径转换中文 NFO 的方法，支持季号和集号参数。 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 14s Details Docker Build & Deploy / Deploy to Production (push) Successful in 4s Details	2025-04-21 13:23:42 +08:00
孙诚	84357b7f31	更新 ChineseNfoRegistry 类中的日志记录，将错误日志改为信息日志，以改善日志的可读性和准确性。 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 13s Details Docker Build & Deploy / Deploy to Production (push) Successful in 3s Details	2025-04-17 19:07:49 +08:00
孙诚	6773efb842	更新 IChineseNfoRegistry 和 ChineseNfoRegistry 类中的 Job 方法，将 tmdbId 参数更改为 path，并在 JobExecute 方法中增加路径、季号和集号的验证逻辑，改进日志记录以增强错误处理。 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 17s Details Docker Build & Deploy / Deploy to Production (push) Successful in 4s Details	2025-04-17 19:00:56 +08:00
孙诚	25ace6703f	更新 JobTriggerController 中的 ConvertChineseNfo 方法，默认参数改为忽略锁定和已完成的任务。	2025-04-17 18:48:56 +08:00
孙诚	903fd8e256	更新 JobTriggerController 中的 Job 方法，增加参数以忽略锁定和已完成的任务。 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 14s Details Docker Build & Deploy / Deploy to Production (push) Successful in 6s Details	2025-04-17 18:48:40 +08:00
孙诚	3288df0f25	更新 ChineseNfoRegistry 类中的 JobExecute 方法，增加可选参数以支持 TMDB ID、季号和集号；改进错误处理，使用日志记录替代控制台输出。 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 15s Details Docker Build & Deploy / Deploy to Production (push) Successful in 5s Details	2025-04-17 18:46:41 +08:00
孙诚	ec3434da82	Improve error handling and logging in ChineseNfoRegistry job methods; adjust delay duration for TMDB API calls All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 12s Details Docker Build & Deploy / Deploy to Production (push) Successful in 4s Details	2025-04-16 18:54:25 +08:00
孙诚	bf4faca1a7	Enhance ChineseNfoRegistry job method to support optional parameters for TMDB ID, season, and episode; update configuration for HTTP proxy and connection string Some checks failed Docker Build & Deploy / Build Docker Image (push) Failing after 4s Details Docker Build & Deploy / Deploy to Production (push) Has been skipped Details	2025-04-16 18:26:31 +08:00
孙诚	fae4754df4	1 All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 20s Details Docker Build & Deploy / Deploy to Production (push) Successful in 5s Details	2025-04-03 17:03:42 +08:00
孙诚	7b0c5f8ce2	Use ExecuteIdentityAsync for record insertion in ChineseNfoRegistry All checks were successful Docker Build & Deploy / Build Docker Image (push) Successful in 11s Details Docker Build & Deploy / Deploy to Production (push) Successful in 4s Details	2025-04-03 17:02:10 +08:00