diff --git a/VideoAnalysis/Controllers/ApiController.cs b/VideoAnalysis/Controllers/ApiController.cs index 3efa37b..10c246e 100644 --- a/VideoAnalysis/Controllers/ApiController.cs +++ b/VideoAnalysis/Controllers/ApiController.cs @@ -157,6 +157,8 @@ namespace Learn.VideoAnalysis.Controllers { if (!ModelState.IsValid) return BadRequest(ModelState); + if(await videoTaskDB.IsAnyAsync(s=>s.TagId == req.TagId) ) + return BadRequest("重复添加"); // 自动映射属性到哈希 var task = new VideoTask() { diff --git a/VideoAnalysisCore/AICore/ChatGPT/KIMI/MoonshotClient.cs b/VideoAnalysisCore/AICore/ChatGPT/KIMI/MoonshotClient.cs index a515e44..2bf230d 100644 --- a/VideoAnalysisCore/AICore/ChatGPT/KIMI/MoonshotClient.cs +++ b/VideoAnalysisCore/AICore/ChatGPT/KIMI/MoonshotClient.cs @@ -183,15 +183,15 @@ namespace VideoAnalysisCore.AICore.ChatGPT.KIMI private async Task PostJsonStreamAsync(string path, string json) { - var client = _httpClientFactory.CreateClient(); - client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", ApiKey); - var request = ToHttpRequest(path); var maxRestart = 4; var errorMSG = new Exception[maxRestart]; for (int i = 0; i < maxRestart; i++) { try { + var client = _httpClientFactory.CreateClient(); + client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", ApiKey); + var request = ToHttpRequest(path); request.Content = new StringContent(json, Encoding.UTF8, "application/json"); return await client.SendAsync(request, HttpCompletionOption.ResponseHeadersRead); } diff --git a/VideoAnalysisCore/Common/RedisExpand.cs b/VideoAnalysisCore/Common/RedisExpand.cs index fe9b1d7..d25307c 100644 --- a/VideoAnalysisCore/Common/RedisExpand.cs +++ b/VideoAnalysisCore/Common/RedisExpand.cs @@ -283,6 +283,7 @@ namespace VideoAnalysisCore.Common var tID = long.Parse(taskId); if (action is not null) { + var errArr = new Exception[3]; for (int i = 0; i < 3; i++) { Console.WriteLine(DateTime.Now.ToString("HH:mm:ss") + "-> 寮濮嬫墽琛 " + key + " " + taskId); @@ -299,11 +300,16 @@ namespace VideoAnalysisCore.Common } catch (Exception ex) { + errArr[i] = ex; + Console.WriteLine("====================[鍑虹幇寮傚父]===================="); + Console.WriteLine(ex.Message); + Console.WriteLine(ex.StackTrace); + Console.WriteLine("=============================================="); Thread.Sleep(1000); Console.WriteLine(DateTime.Now.ToString("HH:mm:ss") + "-> 绋嶅悗鍚庨噸璇." + key + " " + taskId ); - await SetTaskErrorMessage(tID, ex); } } + await SetTaskErrorMessage(tID, errArr.First()); } else {