更新 替换掉阿里云过时的配置

优化 过时的RedisJoinQueue流程迁移到WorkFlow

Learn.VideoAnalysis.API/appsettings.json

@@ -61,20 +61,20 @@
       "UpdateTable": false
     },
     "AlibabaCloudVod": {
-      "AccessKeyId": "LTAI5tDC6p9h747B7FHbgwkH",
+      "AccessKeyId": "LTAI5tFLXyC3ixVdxhxLih8K",
-      "AccessKeySecret": "vRKgmbp1LB05LaGOjh3ZrZxbHSLYLF",
+      "AccessKeySecret": "dlGu3WMoW0XQaoAYxiCPpnxry6qLhB",
       "EndPoint": "vod.cn-shanghai.aliyuncs.com" //上传节点
     },
     "AliyunOSS": {
-      "AccessKeyId": "LTAI5tDC6p9h747B7FHbgwkH",
+      "AccessKeyId": "LTAI5tFLXyC3ixVdxhxLih8K",
-      "AccessKeySecret": "vRKgmbp1LB05LaGOjh3ZrZxbHSLYLF",
+      "AccessKeySecret": "dlGu3WMoW0XQaoAYxiCPpnxry6qLhB",
       "BucketDomain": "https://learn-videoanalysis.oss-cn-chengdu.aliyuncs.com",
       "Region": "cn-chengdu",
       "BucketName": "learn-videoanalysis",
       "EndPoint": "oss-cn-chengdu.aliyuncs.com" //上传节点
     },
     "OtherDBArr": [
-      {// 线上正式环境库
+      { // 线上正式环境库
         "ConfigId": 1001, //ResourceBank
         "ConnectionString": "AllowLoadLocalInfile=true;Server=rm-2vc20nd3d11g0oh6g2o.rwlb.cn-chengdu.rds.aliyuncs.com;User ID=marking;Password=poiuytPOIUYT098765)(*&^%;Port=3306;Database=resourcebank;CharSet=utf8mb4;pooling=true;SslMode=None",
         "SqlType": "MySql"

VideoAnalysis/appsettings.Production.json

@@ -22,14 +22,6 @@
     "FFmpeg": {
       " TimeSlice": 600
     },
-    "AliyunOSS": {
-      "AccessKeyId": "LTAI5tDC6p9h747B7FHbgwkH",
-      "AccessKeySecret": "vRKgmbp1LB05LaGOjh3ZrZxbHSLYLF",
-      "BucketDomain": "https://learn-videoanalysis.oss-cn-chengdu.aliyuncs.com",
-      "Region": "cn-chengdu",
-      "BucketName": "learn-videoanalysis",
-      "EndPoint": "oss-cn-chengdu.aliyuncs.com" //上传节点
-    },
     "DB": {
       //"ConnectionString": "AllowLoadLocalInfile=true;Server=10.255.255.3;Port=3306;Database=learn.videoanalysis;User ID=marking;Password=qwe123!@#;CharSet=utf8mb4;pooling=true;SslMode=None",
       "ConnectionString": "AllowLoadLocalInfile=true;Server=rm-2vc20nd3d11g0oh6g2o.rwlb.cn-chengdu.rds.aliyuncs.com;User ID=marking;Password=poiuytPOIUYT098765)(*&^%;Port=3306;Database=learn.videoanalysis;CharSet=utf8mb4;pooling=true;SslMode=None",

VideoAnalysis/appsettings.json

@@ -76,16 +76,16 @@
       //"ConnectionString": "AllowLoadLocalInfile=true;Server=rm-2vc20nd3d11g0oh6g2o.rwlb.cn-chengdu.rds.aliyuncs.com;User ID=marking;Password=poiuytPOIUYT098765)(*&^%;Port=3306;Database=learn.videoanalysis;CharSet=utf8mb4;pooling=true;SslMode=None",
 
       "SqlType": "MySql",
-      "UpdateTable": true
+      "UpdateTable": false
     },
     "AlibabaCloudVod": {
-      "AccessKeyId": "LTAI5tDC6p9h747B7FHbgwkH",
+      "AccessKeyId": "LTAI5tFLXyC3ixVdxhxLih8K",
-      "AccessKeySecret": "vRKgmbp1LB05LaGOjh3ZrZxbHSLYLF",
+      "AccessKeySecret": "dlGu3WMoW0XQaoAYxiCPpnxry6qLhB",
       "EndPoint": "vod.cn-shanghai.aliyuncs.com" //上传节点
     },
     "AliyunOSS": {
-      "AccessKeyId": "LTAI5tDC6p9h747B7FHbgwkH",
+      "AccessKeyId": "LTAI5tFLXyC3ixVdxhxLih8K",
-      "AccessKeySecret": "vRKgmbp1LB05LaGOjh3ZrZxbHSLYLF",
+      "AccessKeySecret": "dlGu3WMoW0XQaoAYxiCPpnxry6qLhB",
       "BucketDomain": "https://learn-videoanalysis.oss-cn-chengdu.aliyuncs.com",
       "Region": "cn-chengdu",
       "BucketName": "learn-videoanalysis",

VideoAnalysisCore/AICore/GPT/BaseGPT.cs

@@ -16,7 +16,7 @@ using VideoAnalysisCore.AICore.GPT.Gemini;
 namespace VideoAnalysisCore.AICore.GPT
 {
 
-    public interface IBserGPTWorkflow
+    public interface IBaseGPTWorkflow
     {
         /// <summary>
         /// 访问GPT
@@ -185,10 +185,13 @@ namespace VideoAnalysisCore.AICore.GPT
         public static void AddGPTService(this IServiceCollection services)
         {
             services.AddSingleton<DeepSeekGPTClient>();
-            services.AddSingleton<BSET_DeepSeekGPTClient>();
+            services.AddSingleton<BSET_DeepSeekGPTClient
+                
+                
+                >();
             services.AddSingleton<BestAIClient>();
             services.AddSingleton<GeminiGPTClient>();
-            services.AddSingleton<IBserGPTWorkflow, GTP_Analysis_1>();
+            services.AddSingleton<IBaseGPTWorkflow, GTP_Analysis_1>();
 
 
         }

VideoAnalysisCore/AICore/GPT/GTP_Analysis_1.cs

@@ -1,4 +1,4 @@
-using VideoAnalysisCore.Common;
+using VideoAnalysisCore.Common;
 using System.Text.Json;
 using VideoAnalysisCore.Model;
 using System.Text;
@@ -33,7 +33,7 @@ namespace VideoAnalysisCore.AICore.GPT
     /// <summary>
     /// 视频分析工作流1
     /// </summary>
-    public class GTP_Analysis_1 : IBserGPTWorkflow
+    public class GTP_Analysis_1 : IBaseGPTWorkflow
     {
         private readonly GeminiGPTClient geminiClient;
         private readonly DeepSeekGPTClient deepSeekClient;

VideoAnalysisCore/AICore/SherpaOnnx/SherpaVad.cs

@@ -1,4 +1,4 @@
-using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Options;
 using SherpaOnnx;
 using SqlSugar;

VideoAnalysisCore/Common/DownloadFile.cs

@@ -148,21 +148,34 @@ namespace VideoAnalysisCore.Common
         public async Task RunTask(string task, string workflowName = "VideoSliceWorkflow")
         {
             var taskId = long.Parse(task);
-            //获取资源文件 地址
+            var taskInfo = await GetTaskInfoAsync(taskId);
+            var fileUrl = await GetMediaUrlAsync(taskInfo);
+
+            // 准备本地目录
+            var localPath = task.LocalPath();
+            await PrepareDirectoryAndDbAsync(taskId, localPath);
+
+            // 处理 PPT 视频
+            await ProcessPPTVideoAsync(taskInfo, localPath, taskId, workflowName, task);
+
+            // 下载主视频
+            await DownloadWithCacheCheckAsync(taskId, fileUrl, localPath, taskVideoName, workflowName, task, "主视频");
+        }
+
+        private async Task<VideoTask> GetTaskInfoAsync(long taskId)
+        {
             var taskInfo = await videoTaskDB.CopyNew().AsQueryable()
                 .Where(s => s.Id == taskId).FirstAsync();
-            if (taskInfo is null )
+
+            if (taskInfo is null)
                 throw new Exception($"任务为null/是教研视频/没有视频课程名称");
+
+            return taskInfo;
+        }
+
+        private async Task<string> GetMediaUrlAsync(VideoTask taskInfo)
+        {
             var fileUrl = taskInfo.MediaUrl;
-            switch (taskInfo?.VideoType)
-            {
-                case AttachmentsInfoType.无:
-                case AttachmentsInfoType.新课:
-                case AttachmentsInfoType.复习:
-                    break;
-                default:
-                    throw new Exception("无效的课程类型");
-            }
             if (string.IsNullOrEmpty(fileUrl))
             {
                 var videoInfo = await vodClient.GetPlayInfoAsync(new GetPlayInfoRequest()
@@ -176,57 +189,70 @@ namespace VideoAnalysisCore.Common
                     throw new Exception($"{DateTime.Now} 视频订阅=>获取阿里云视频信息失败 VideoCode {taskInfo.TagId} StatusCode {videoInfo?.StatusCode}");
                 fileUrl = videoInfo.Body.PlayInfoList.PlayInfo.First().PlayURL;
             }
-            if (string.IsNullOrEmpty(fileUrl))
-                throw new Exception($"任务id[{task}] 资源地址无效 {fileUrl}");
 
-            // 尝试从 URL 中获取文件后缀
+            if (string.IsNullOrEmpty(fileUrl))
+                throw new Exception($"任务id[{taskInfo.Id}] 资源地址无效 {fileUrl}");
+
+            // 尝试从 URL 中获取文件后缀 (保留原有校验逻辑)
             string fileExtension = Path.GetExtension(new Uri(fileUrl).AbsolutePath);
-            //否则 获取 从Content-Type 获取文件后缀
             if (string.IsNullOrEmpty(fileExtension))
                 throw new Exception($"未能从资源路径中获取文件后缀");
 
-            //创建下载文件缓存路径
+            return fileUrl;
-            if (!Directory.Exists(AppCommon.TaskCachedFile)) Directory.CreateDirectory(AppCommon.TaskCachedFile);
+        }
 
-            var localPath = task.LocalPath();
+        private async Task PrepareDirectoryAndDbAsync(long taskId, string localPath)
-            var outputPath = Path.Combine(localPath, taskVideoName);
+        {
+            if (!Directory.Exists(AppCommon.TaskCachedFile)) Directory.CreateDirectory(AppCommon.TaskCachedFile);
             if (!Directory.Exists(localPath)) Directory.CreateDirectory(localPath);
 
+            var outputPath = Path.Combine(localPath, taskVideoName);
             await videoTaskDB.CopyNew()
                 .AsUpdateable()
                 .SetColumns(it => it.LocalMediaPath == outputPath)
-                .Where(it => it.Id == long.Parse(task))
+                .Where(it => it.Id == taskId)
                 .ExecuteCommandAsync();
-            //下载PPT视频
+        }
-            if (string.IsNullOrEmpty(taskInfo.PPTVideoUrl)&&
+
-                !string.IsNullOrEmpty(taskInfo.PPTVideoCode)) 
+        private async Task ProcessPPTVideoAsync(VideoTask taskInfo, string localPath, long taskId, string workflowName, string taskStr)
+        {
+            // 更新 PPT 视频 URL
+            if (string.IsNullOrEmpty(taskInfo.PPTVideoUrl) && !string.IsNullOrEmpty(taskInfo.PPTVideoCode))
             {
                 taskInfo.PPTVideoUrl = await packageInfoTaskDB.AsQueryable()
                     .Where(s => s.VideoCode == taskInfo.PPTVideoCode)
                     .Select(s => s.VideoUrl)
                     .FirstAsync();
+                
                 if (!string.IsNullOrEmpty(taskInfo.PPTVideoUrl))
+                {
                     await videoTaskDB.CopyNew().AsUpdateable(taskInfo)
                         .UpdateColumns(it => new { it.PPTVideoUrl })
                         .ExecuteCommandAsync();
-
+                }
             }
+
+            // 下载 PPT 视频
             if (!string.IsNullOrEmpty(taskInfo.PPTVideoUrl))
             {
-                await Download(taskInfo.PPTVideoUrl, localPath, taskPPTVideoName,
+                await DownloadWithCacheCheckAsync(taskId, taskInfo.PPTVideoUrl, localPath, taskPPTVideoName, workflowName, taskStr, "PPT视频", true);
-                    (s, e) => GetWorkflowManager(workflowName).SetTaskProgress(task, "PPT->" + Math.Round(e.ProgressPercentage, 1))
-                );
             }
-            try
+        }
+
+        private async Task DownloadWithCacheCheckAsync(long taskId, string url, string localPath, string fileName, string workflowName, string taskStr, string logPrefix, bool isPPT = false)
+        {
+            var filePath = Path.Combine(localPath, fileName);
+            if (File.Exists(filePath) && new FileInfo(filePath).Length > 10 * 1024 * 1024)
             {
-                //下载原视频
+                await GetWorkflowManager(workflowName).AddTaskLog(taskId, $"{logPrefix}命中本地缓存");
-                await Download(fileUrl, localPath, taskVideoName,
-                    (s, e) => GetWorkflowManager(workflowName).SetTaskProgress(task, Math.Round(e.ProgressPercentage, 1))
-                );
             }
-            catch 
+            else
             {
-                throw;
+                await Download(url, localPath, fileName, (s, e) =>
+                {
+                    var progressPrefix = isPPT ? "PPT->" : "";
+                    GetWorkflowManager(workflowName).SetTaskProgress(taskStr, $"{progressPrefix}" + Math.Round(e.ProgressPercentage, 1));
+                });
             }
         }
 
@@ -265,7 +291,7 @@ namespace VideoAnalysisCore.Common
                         try
                         {
                             using var scope = serviceProvider.CreateScope();
-                            var clearJob = scope.ServiceProvider.GetRequiredService<TaskFileClearJob>();
+                            var clearJob = scope.ServiceProvider.GetRequiredService<ClearAllCacheJob>();
                             await clearJob.Invoke();
                         }
                         catch (Exception ex)

VideoAnalysisCore/Common/RedisExpand.cs

@@ -1,4 +1,4 @@
-using FreeRedis;
+using FreeRedis;
 using FreeRedis.Internal;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.IdentityModel.Tokens;
@@ -140,25 +140,13 @@ namespace VideoAnalysisCore.Common
     public class RedisManager
     {
         public static bool StopTask { get; set; } = false;
-        public static Dictionary<RedisChannelEnum, Func<string, Task>> SubscribeList = new Dictionary<RedisChannelEnum, Func<string, Task>>();
-        
-        /// <summary>
-        /// 正在后台运行的任务集合
-        /// </summary>
-        public static ConcurrentDictionary<string, Task> RunningTasks = new ConcurrentDictionary<string, Task>();
-
-        private static CancellationTokenSource? _cts;
         private static Task? _workerTask;
 
         public RedisClient Redis { get; set; }
-        public Repository<VideoTask> videoTaskDB { get; set; }
-        public Repository<TaskLog> taskLogDB { get; set; }
 
-        public RedisManager(RedisClient redis, Repository<VideoTask> videoTaskDB, Repository<TaskLog> taskLogDB)
+        public RedisManager(RedisClient redis)
         {
             Redis = redis;
-            this.videoTaskDB = videoTaskDB;
-            this.taskLogDB = taskLogDB;
         }
 
 
@@ -170,37 +158,5 @@ namespace VideoAnalysisCore.Common
         {
             Redis.Set(RedisExpandKey.TaskGPT(taskId) + ":" + time, data, timeoutSeconds: 3600 * 24);
         }
-        /// <summary>
-        /// 加入到消费队列
-        /// </summary>
-        /// <param name="taskIds"></param>
-        public void JoinQueue(params long[] taskIds)
-        {   //事务
-            if (taskIds is null || taskIds.Length == 0)
-                return;
-            using (var tran = Redis.Multi())
-            {
-                foreach (var item in taskIds)
-                    tran.LPush(RedisExpandKey.ChannelKey, item);
-                tran.Exec();
-            }
-        }
-        
-        // AddTaskLog 已迁移至 WorkflowBase
-
-        /// <summary>
-        /// 获取任务进度
-        /// </summary>
-        /// <param name="taskId"></param>
-        /// <param name="workflowName">工作流名称(可选)</param>
-        public string GetTaskProgress(object taskId, string workflowName = "VideoSliceWorkflow")
-        {
-            var fieldName = workflowName == "VideoSliceWorkflow" ? "Progress" : $"Progress:{workflowName}";
-            return Redis.HMGet<string>(RedisExpandKey.Task(taskId), fieldName)[0] ?? "";
-        }
-        
-        // 注意：SetTaskProgress, TaskEnd, SetTaskErrorMessage, ClearTaskError, SetTaskError 
-        // 已迁移至 WorkflowBase，此处移除或标记为已废弃
-        
     }
 }

VideoAnalysisCore/Common/VideoSliceWorkflowManager.cs

@@ -39,13 +39,15 @@ namespace VideoAnalysisCore.Common
         private readonly IServiceProvider _serviceProvider;
         private readonly FFMPGEHandle _ffmpeg;
         private readonly SenseVoice _senseVoice;
+        private readonly TidySlideWorkflowManager _tidySlideWorkflowManager;
 
-        public VideoSliceWorkflowInit(VideoSliceWorkflowManager manager, IServiceProvider serviceProvider, FFMPGEHandle ffmpeg, SenseVoice senseVoice)
+        public VideoSliceWorkflowInit(VideoSliceWorkflowManager manager, IServiceProvider serviceProvider, FFMPGEHandle ffmpeg, SenseVoice senseVoice, TidySlideWorkflowManager tidySlideWorkflowManager)
         {
             _manager = manager;
             _serviceProvider = serviceProvider;
             _ffmpeg = ffmpeg;
             _senseVoice = senseVoice;
+            _tidySlideWorkflowManager = tidySlideWorkflowManager;
             Init();
             _manager.InitChannel();
         }
@@ -62,26 +64,36 @@ namespace VideoAnalysisCore.Common
                 await downloadService.RunTask(task, "VideoSliceWorkflow");
             });
             SubscribeList.Add(RedisChannelEnum.分离音频, _ffmpeg.RunAsync);
-            SubscribeList.Add(RedisChannelEnum.解析字幕, _senseVoice.RunTask);
+            SubscribeList.Add(RedisChannelEnum.解析字幕, async (task) =>
+            {
+                await _senseVoice.RunTask(task);
+                // 触发 TidySlide 工作流
+                if (AppCommon.Config.Workflow.TidySlide.Enabled)
+                {
+                    await _tidySlideWorkflowManager.AddTaskLog(long.Parse(task), "由解析字幕完成触发 TidySlide 工作流");
+                    //不阻塞
+                    _=_tidySlideWorkflowManager.InsertChannel(RedisTidySlideChannelEnum.下载文件, task);
+                }
+            });
 
             SubscribeList.Add(RedisChannelEnum.AI课程类型, async (task) =>
             {
                 using var scope = _serviceProvider.CreateScope();
-                var service = scope.ServiceProvider.GetService<IBserGPTWorkflow>();
+                var service = scope.ServiceProvider.GetService<IBaseGPTWorkflow>();
                 if (service is null) throw new Exception("IBserGPT 未注入");
                 await service.GetVideoType(task);
             });
             SubscribeList.Add(RedisChannelEnum.AI模型分析, async (task) =>
             {
                 using var scope = _serviceProvider.CreateScope();
-                var service = scope.ServiceProvider.GetService<IBserGPTWorkflow>();
+                var service = scope.ServiceProvider.GetService<IBaseGPTWorkflow>();
                 if (service is null) throw new Exception("IBserGPT 未注入");
                 await service.GetKnow(task);
             });
             SubscribeList.Add(RedisChannelEnum.AI分析试题, async (task) =>
             {
                 using var scope = _serviceProvider.CreateScope();
-                var service = scope.ServiceProvider.GetService<IBserGPTWorkflow>();
+                var service = scope.ServiceProvider.GetService<IBaseGPTWorkflow>();
                 if (service is null) throw new Exception("IBserGPT 未注入");
                 await service.GetVideoQuestion(task);
             });

VideoAnalysisCore/Common/WorkflowBase.cs

@@ -461,5 +461,19 @@ namespace VideoAnalysisCore.Common
             RunningTasks.TryAdd(tId, bgTask);
             await Task.CompletedTask;
         }
+
+
+        /// <summary>
+        /// 加入到消费队列
+        /// </summary>
+        /// <param name="taskIds"></param>
+        public void JoinQueue(params long[] taskIds)
+        {   
+            if (taskIds is null || taskIds.Length == 0)
+                return;
+            // 直接批量推入，避免循环和事务开销
+            var d = taskIds.Select(s => (object)s).ToArray();
+            Redis.LPush(ChannelKey, d);
+        }
     }
 }

VideoAnalysisCore/Controllers/LJZK_Controller.cs

@@ -39,11 +39,12 @@ namespace VideoAnalysisCore.Controllers
         private readonly Repository<NodePackageInfo> nodePackageInfoDB;
         private readonly Repository<VideoQuestion> videoQuestionDB;
         private readonly Repository<VideoQuestionKonw> videoQuestionKonwDB;
-        private readonly RedisManager redisManager; 
+        private readonly RedisManager redisManager;
+        readonly VideoSliceWorkflowManager videoSliceWorkflowManager;
 
         public LJZK_Controller(IMapper mp, Repository<NodeSubscription> nodesubscriptionDB,
             Repository<VideoTask> videoTaskDB = null, Repository<VideoKonwPoint> videoKonwPointDB = null
-            , Repository<NodePackageInfo> nodePackageInfoDB = null, Repository<VideoQuestion> videoQuestionDB = null, Repository<VideoQuestionKonw> videoQuestionKonwDB = null, Repository<CourseInfo> courseInfoDB = null, RedisManager redisManager = null, Repository<VideoTaskStage> videoTaskStageDB = null)
+            , Repository<NodePackageInfo> nodePackageInfoDB = null, Repository<VideoQuestion> videoQuestionDB = null, Repository<VideoQuestionKonw> videoQuestionKonwDB = null, Repository<CourseInfo> courseInfoDB = null, RedisManager redisManager = null, Repository<VideoTaskStage> videoTaskStageDB = null, VideoSliceWorkflowManager videoSliceWorkflowManager = null)
         {
             this.mp = mp;
             this.nodesubscriptionDB = nodesubscriptionDB;
@@ -55,6 +56,7 @@ namespace VideoAnalysisCore.Controllers
             this.courseInfoDB = courseInfoDB;
             this.redisManager = redisManager;
             this.videoTaskStageDB = videoTaskStageDB;
+            this.videoSliceWorkflowManager = videoSliceWorkflowManager;
         }
 
 
@@ -158,7 +160,7 @@ namespace VideoAnalysisCore.Controllers
             if (videos is null || videos.Count == 0)
                 return Ok();
             var ids = videos.Select(s => s.Id).ToArray();
-            redisManager.JoinQueue(ids);
+            videoSliceWorkflowManager.JoinQueue(ids);
             return Ok();
         }
 

VideoAnalysisCore/Controllers/VideoTaskController.cs

@@ -110,16 +110,30 @@ namespace VideoAnalysisCore.Controllers
 #endif
 
         /// <summary>
-        /// 插入批量任务id
+        /// 添加任务到 TidySlide队列
         /// </summary>
         /// <param name="ids">是否执行任务</param>
         /// <returns></returns>
-        [HttpPost(Name = "JoinQueue")]
+        [HttpPost(Name = "JoinQueueVideoSlice")]
-        public IActionResult JoinQueue(long[] ids)
+        public IActionResult JoinQueue( long[] ids)
         {
-            if (ids == null || ids.Count() == 0)
+            if (ids == null || ids.Length == 0)
                 return BadRequest("录入数据无效");
-            redisManager.JoinQueue(ids);
+            videoSliceWorkflowManager.JoinQueue(ids);
+            return Ok();
+        }
+
+        /// <summary>
+        /// 添加任务到 TidySlide队列
+        /// </summary>
+        /// <param name="ids"></param>
+        /// <returns></returns>
+        [HttpPost(Name = "JoinQueueTidySlide")]
+        public IActionResult JoinTidySlideQueue( long[] ids)
+        {
+            if (ids == null || ids.Length == 0)
+                return BadRequest("录入数据无效");
+            tidySlideWorkflowManager.JoinQueue(ids);
             return Ok();
         }
 
@@ -132,9 +146,9 @@ namespace VideoAnalysisCore.Controllers
         public IActionResult StartTask(bool task)
         {
             if (task)
-                videoSliceWorkflowManager.StopTask=false;
+                videoSliceWorkflowManager.StopTask = false;
             else
-                videoSliceWorkflowManager.StopTask=true;
+                videoSliceWorkflowManager.StopTask = true;
             return Ok();
         }
         /// <summary>
@@ -168,7 +182,7 @@ namespace VideoAnalysisCore.Controllers
         {
             using var s = file.OpenReadStream();
             var res = senseVoice.RunTask(s);
-            return  Ok(res);
+            return Ok(res);
         }
         /// <summary>
         /// 语音识别
@@ -248,7 +262,7 @@ namespace VideoAnalysisCore.Controllers
         /// <param name="req">请求体</param>
         /// <returns></returns>
         [HttpPost(Name = "VideoAnalysis_Batch")]
-        public async Task<IActionResult> VideoAnalysis_Batch(VideoAnalysisReq[] req) 
+        public async Task<IActionResult> VideoAnalysis_Batch(VideoAnalysisReq[] req)
         {
             foreach (var item in req)
                 await VideoAnalysis(item);
@@ -371,8 +385,8 @@ namespace VideoAnalysisCore.Controllers
                 .LRangeAsync<TaskLog>(RedisExpandKey.TaskLog, 0, 99))
                 .Where(s => s.VideoTaskId == id);
 
-            logArr =  logArr.Concat(insertData).ToArray();
+            logArr = logArr.Concat(insertData).ToArray();
-            
+
             // 获取所有相关工作流的状态
             var workflows = await baseService.Context.Queryable<VideoTaskWorkflow>()
                 .Where(w => w.VideoTaskId == id)
@@ -464,7 +478,15 @@ namespace VideoAnalysisCore.Controllers
         {
             // 扫描 Heartbeat Key
             var pattern = RedisExpandKey.DeviceHeartbeat("*");
-            var keys = redisManager.Redis.Scan(pattern, 1000).ToList();
+            var keys = new List<string>();
+            long cursor = 0;
+            do
+            {
+                var scanResult = redisManager.Redis.Scan(cursor, pattern, 1000, null);
+                keys.AddRange(scanResult.items);
+                cursor = scanResult.cursor;
+            } while (cursor != 0);
+
             var prefix = RedisExpandKey.DeviceHeartbeat("");
             var devices = keys.Select(k => k.Replace(prefix, "")).ToList();
             return Ok(devices);
@@ -490,7 +512,15 @@ namespace VideoAnalysisCore.Controllers
                 oldTaskArr = new List<long>();
                 // 直接扫描 Heartbeat Key 获取在线设备
                 var pattern = RedisExpandKey.DeviceHeartbeat("*");
-                var keys = redisManager.Redis.Scan(pattern, 1000).ToList();
+                var keys = new List<string>();
+                long cursor = 0;
+                do
+                {
+                    var scanResult = redisManager.Redis.Scan(cursor, pattern, 1000, null);
+                    keys.AddRange(scanResult.items);
+                    cursor = scanResult.cursor;
+                } while (cursor != 0);
+
                 var prefix = RedisExpandKey.DeviceHeartbeat("");
                 var onlineDevices = keys.Select(k => k.Replace(prefix, "")).ToList();
                 
@@ -537,7 +567,7 @@ namespace VideoAnalysisCore.Controllers
         public async Task<object> ErrorTaskList([FromBody] QueryRequestBase model)
         {
             var sqlquery = base.BaseQuery(model)
-                .Where(s => s.ErrorMessage!=null && s.ErrorMessage !="")
+                .Where(s => s.ErrorMessage != null && s.ErrorMessage != "")
                 .Select(s => new VideoTask
                 {
                     Id = s.Id,
@@ -562,14 +592,14 @@ namespace VideoAnalysisCore.Controllers
         /// <param name="id">查询模型</param>
         /// <returns></returns>
         [HttpGet]
-        public async Task<IEnumerable<TaskLog>> TaskLog(long id )
+        public async Task<IEnumerable<TaskLog>> TaskLog(long id)
         {
             var logArr = await taskLogDB.AsQueryable()
                 .Where(s => s.VideoTaskId == id)
                 .ToArrayAsync();
             var insertData = (await redisManager.Redis
                 .LRangeAsync<TaskLog>(RedisExpandKey.TaskLog, 0, 99))
-                .Where(s=>s.VideoTaskId == id);
+                .Where(s => s.VideoTaskId == id);
 
             return logArr.Concat(insertData);
         }
@@ -586,10 +616,10 @@ namespace VideoAnalysisCore.Controllers
             var result = await db.Queryable<TidySlideTaskResult>()
                 .Where(s => s.VideoTaskId == id)
                 .FirstAsync();
-            
+
             if (result == null)
                 return BadRequest("未找到 TidySlide 任务结果");
-            
+
             return Ok(result);
         }
     }

VideoAnalysisCore/VideoAnalysisCore.csproj

@@ -16,7 +16,7 @@
 		<PackageReference Include="AlibabaCloud.SDK.Vod20170321" Version="3.6.1" />
 		<PackageReference Include="Aliyun.OSS.SDK.NetCore" Version="2.14.1" />
 		<PackageReference Include="Coravel" Version="6.0.2" />
-		<PackageReference Include="FreeRedis" Version="1.3.2" />
+		<PackageReference Include="FreeRedis" Version="1.5.5" />
 		<PackageReference Include="Downloader" Version="3.2.1" />
 		<PackageReference Include="Mapster" Version="7.4.1-pre01" />
 		<PackageReference Include="Microsoft.AspNetCore.Cors" Version="2.3.0" />