更新 docker-compose.yml 中的媒体文件路径，移除 JobTriggerController 和 NotifyController 中的未使用代码

docker-compose.yml

@@ -15,7 +15,7 @@
       - /etc/localtime:/etc/localtime:ro
       - /wd/media/tv:/data/media/tv:rw
       - /wd/media/anime:/data/media/anime:rw
-      - /wd/media/anime-other:/data/media/anime-other: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

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());
-    }
-}

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();
-    }
-}

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";

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;
-//         }
-//     }
-// }

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.##} 亿";
-    }
-}

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()}");
-        }
-    }
-}

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}");
-        }
-    }
-}

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());
-    }
-}

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);
-    }
-}

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}");
-    }
-}

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");
-        }
-    }
-}

src/WebApi/Controllers/JobTriggerController.cs

@@ -9,14 +9,7 @@ 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;
 
@@ -24,83 +17,13 @@ public class JobTriggerController : BaseController
     ///     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()
-    {
-        _logTotalNotifyJobRegistry.Job();
-
-        return "OK";
-    }
-
-    [HttpGet]
-    public string DiskActionMonitor()
-    {
-        _diskActionMonitorRegistry.Job();
-
-        return "OK";
-    }
-
-    [HttpGet]
-    public string HealthyTask()
-    {
-        _healthyTaskRegistry.Job();
-
-        return "OK";
-    }
-
-
-    [HttpGet]
-    public string RSyncTask()
-    {
-        _rSyncTaskRegistry.Job();
-
-        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(
@@ -152,7 +75,6 @@ public class JobTriggerController : BaseController
 
         return "OK";
     }
-
     
     [HttpGet]
     public string ConvertChineseNfoByPath(
@@ -166,12 +88,4 @@ public class JobTriggerController : BaseController
 
         return "OK";
     }
-
-    [HttpGet]
-    public string DiskMonitor()
-    {
-        _diskMonitorRegistry.Job();
-
-        return "OK";
-    }
 }

src/WebApi/Controllers/NotifyController.cs

@@ -21,40 +21,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 +62,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通知：

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";
-    }
-}