From dfbc7fffb3a6a4b30a84891dd63440acc281f40e Mon Sep 17 00:00:00 2001 From: movingsam Date: Tue, 13 Aug 2024 10:17:10 +0800 Subject: [PATCH] bugfixed --- AutoDispathingWork/Program.cs | 3 +-- AutoDispathingWork/WechatRobot.cs | 7 +------ AutoDispathingWork/Worker.cs | 7 +++++++ 3 files changed, 9 insertions(+), 8 deletions(-) diff --git a/AutoDispathingWork/Program.cs b/AutoDispathingWork/Program.cs index f5ee0a3..1a2240e 100644 --- a/AutoDispathingWork/Program.cs +++ b/AutoDispathingWork/Program.cs @@ -67,8 +67,7 @@ app.UseCors("AllowAllOrigin"); #if DEBUG app.UseSwagger(); app.UseSwaggerUI(); -var wechatRobot = app.Services.GetService(); -wechatRobot.SetKey("e68b3791-e040-4c9b-9ac0-6f424e662185"); +app.Services.GetService(); #endif diff --git a/AutoDispathingWork/WechatRobot.cs b/AutoDispathingWork/WechatRobot.cs index b818ff4..f15753b 100644 --- a/AutoDispathingWork/WechatRobot.cs +++ b/AutoDispathingWork/WechatRobot.cs @@ -24,12 +24,7 @@ public class WechatRobot client.BaseAddress = new Uri(ApiUrl); this._logger = logger; _client = client; - } - - public WechatRobot SetKey(string key) - { - this._key = key; - return this; + _key = "e68b3791-e040-4c9b-9ac0-6f424e662185"; } public async Task SendText(string content, bool isAtAll) diff --git a/AutoDispathingWork/Worker.cs b/AutoDispathingWork/Worker.cs index ec675c1..6d64cf5 100644 --- a/AutoDispathingWork/Worker.cs +++ b/AutoDispathingWork/Worker.cs @@ -1,5 +1,6 @@ using AutoDispathingWork.Utils; using WorkerService1.Domains; +using WorkerService1.Dto; using WorkerService1.Services; namespace WorkerService1; @@ -45,6 +46,7 @@ public class Worker : BackgroundService private static async Task Handle() { var _spiderServices = StaticServiceProvider.Current.GetRequiredService(); + var logger= StaticServiceProvider.Current.GetRequiredService>(); var listRes = await _spiderServices.GetTaskList(1); if (listRes.IsSuccess) { @@ -70,6 +72,11 @@ public class Worker : BackgroundService } else { + if (result.Code == SpiderResponseCode.Fail) + { + logger.LogError($"派发任务失败,错误信息:{result.Message}"); + continue; + } var message = $"派发任务失败,错误信息:{result.Message}"; message.Error(); }