ColorVision.Scheduler

概述

ColorVision.Scheduler 是基于UI的定时任务控件，使用Quartz.Net实现，提供定时任务的管理，执行，监控等功能。它为ColorVision系统提供了完整的任务调度解决方案，支持复杂的调度策略和任务监控。

基本信息

版本: 1.5.1.1
目标框架: .NET 8.0 / .NET 10.0 Windows
底层框架: Quartz.NET
UI 框架: WPF
特色功能: 可视化任务管理、实时监控、灵活调度策略
应用场景: 定时数据处理、系统维护、自动化测试

核心功能

1. 任务调度管理

Cron 表达式: 支持复杂的时间调度规则
触发器管理: 多种触发器类型支持
任务分组: 按功能或类别组织任务
优先级控制: 1-10级任务执行优先级设置，优先级高的任务优先执行

2. 任务执行监控

实时状态: 查看任务执行状态（就绪/运行中/已暂停）
执行历史: 详细的执行记录和日志
异常处理: 任务失败时的处理策略
性能统计:
- 成功/失败次数统计
- 执行时间统计（最后/平均/最大/最小）
- 运行次数自动累计
- 实时状态更新

3. 任务管理界面

可视化编辑: 图形界面创建和编辑任务
搜索过滤: 按任务名称、分组名称实时搜索，按状态过滤
批量操作: 批量启动、暂停、删除任务（支持多选）
实时监控面板: 任务执行状态实时显示
数据导出:
- CSV导出（Excel兼容格式）
- JSON配置导出（备份和迁移）
- 统计报告导出（详细执行统计）

4. 集成支持

插件架构: 支持自定义任务类型
事件通知: 任务状态变更事件
API接口: 编程方式管理任务
配置管理: 任务配置的导入导出
结构化日志: 集成Microsoft.Extensions.Logging，支持多种日志输出

架构设计

任务类型

1. 系统任务

数据备份: 定期数据库备份
日志清理: 清理过期日志文件
缓存清理: 清理临时文件和缓存
系统检查: 定期系统健康检查

2. 业务任务

数据同步: 不同系统间的数据同步
报告生成: 定期生成业务报告
数据处理: 批量数据处理和转换
通知发送: 定时发送通知和提醒

3. 维护任务

软件更新: 自动检查和安装更新
配置同步: 配置文件的同步和备份
性能优化: 定期性能优化操作
安全扫描: 定期安全检查和扫描

使用示例

1. 创建简单定时任务

csharp

public class SimpleJob : IJob
{
    public async Task Execute(IJobExecutionContext context)
    {
        // 任务执行逻辑
        await Task.Run(() =>
        {
            // 具体的业务处理
            Console.WriteLine($"任务执行时间: {DateTime.Now}");
        });
    }
}

// 创建任务
var job = JobBuilder.Create\<SimpleJob\>()
    .WithIdentity("simpleJob", "group1")
    .Build();

// 创建触发器 - 每5分钟执行一次
var trigger = TriggerBuilder.Create()
    .WithIdentity("simpleTrigger", "group1")
    .WithCronSchedule("0 */5 * * * ?")
    .Build();

// 添加到调度器
await scheduler.ScheduleJob(job, trigger);

2. 使用Cron表达式

csharp

// 每天凌晨2点执行
var dailyTrigger = TriggerBuilder.Create()
    .WithCronSchedule("0 0 2 * * ?")
    .Build();

// 每周一上午9点执行
var weeklyTrigger = TriggerBuilder.Create()
    .WithCronSchedule("0 0 9 ? * MON")
    .Build();

// 每月1号中午12点执行
var monthlyTrigger = TriggerBuilder.Create()
    .WithCronSchedule("0 0 12 1 * ?")
    .Build();

3. 任务监听器

csharp

public class JobListener : IJobListener
{
    public string Name => "JobListener";

    public async Task JobToBeExecuted(IJobExecutionContext context, CancellationToken cancellationToken = default)
    {
        var jobName = context.JobDetail.Key.Name;
        Console.WriteLine($"任务 {jobName} 即将执行");
    }

    public async Task JobExecutionVetoed(IJobExecutionContext context, CancellationToken cancellationToken = default)
    {
        var jobName = context.JobDetail.Key.Name;
        Console.WriteLine($"任务 {jobName} 执行被否决");
    }

    public async Task JobWasExecuted(IJobExecutionContext context, JobExecutionException jobException, CancellationToken cancellationToken = default)
    {
        var jobName = context.JobDetail.Key.Name;
        if (jobException == null)
        {
            Console.WriteLine($"任务 {jobName} 执行成功");
        }
        else
        {
            Console.WriteLine($"任务 {jobName} 执行失败: {jobException.Message}");
        }
    }
}

// 注册监听器
scheduler.ListenerManager.AddJobListener(new JobListener());

4. 任务数据传递

csharp

public class DataJob : IJob
{
    public async Task Execute(IJobExecutionContext context)
    {
        var jobDataMap = context.JobDetail.JobDataMap;
        var filePath = jobDataMap.GetString("FilePath");
        var batchSize = jobDataMap.GetInt("BatchSize");
        
        // 使用传入的参数执行任务
        await ProcessFile(filePath, batchSize);
    }
    
    private async Task ProcessFile(string filePath, int batchSize)
    {
        // 文件处理逻辑
    }
}

// 创建带数据的任务
var job = JobBuilder.Create\<DataJob\>()
    .WithIdentity("dataJob", "group1")
    .UsingJobData("FilePath", @"C:\data\input.csv")
    .UsingJobData("BatchSize", 1000)
    .Build();

管理界面

1. 任务列表视图

xml

<DataGrid x:Name="JobsDataGrid" 
          ItemsSource="{Binding Jobs}"
          AutoGenerateColumns="False">
    \<DataGrid.Columns\>
        <DataGridTextColumn Header="任务名称" Binding="{Binding Name}"/>
        <DataGridTextColumn Header="组" Binding="{Binding Group}"/>
        <DataGridTextColumn Header="状态" Binding="{Binding State}"/>
        <DataGridTextColumn Header="下次执行" Binding="{Binding NextFireTime}"/>
        <DataGridTextColumn Header="上次执行" Binding="{Binding PreviousFireTime}"/>
        <DataGridTemplateColumn Header="操作">
            \<DataGridTemplateColumn.CellTemplate\>
                \<DataTemplate\>
                    <StackPanel Orientation="Horizontal">
                        <Button Content="启动" Command="{Binding StartCommand}"/>
                        <Button Content="暂停" Command="{Binding PauseCommand}"/>
                        <Button Content="停止" Command="{Binding StopCommand}"/>
                        <Button Content="删除" Command="{Binding DeleteCommand}"/>
                    </StackPanel>
                </DataTemplate>
            </DataGridTemplateColumn.CellTemplate>
        </DataGridTemplateColumn>
    </DataGrid.Columns>
</DataGrid>

2. 任务编辑窗口

xml

<Window x:Class="JobEditorWindow">
    \<Grid\>
        \<Grid.RowDefinitions\>
            <RowDefinition Height="Auto"/>
            <RowDefinition Height="Auto"/>
            <RowDefinition Height="Auto"/>
            <RowDefinition Height="*"/>
            <RowDefinition Height="Auto"/>
        </Grid.RowDefinitions>
        
        <!-- 基本信息 -->
        <GroupBox Header="基本信息" Grid.Row="0">
            \<Grid\>
                \<Grid.ColumnDefinitions\>
                    <ColumnDefinition Width="Auto"/>
                    <ColumnDefinition Width="*"/>
                </Grid.ColumnDefinitions>
                
                <Label Content="任务名称:" Grid.Column="0"/>
                <TextBox Text="{Binding JobName}" Grid.Column="1"/>
            </Grid>
        </GroupBox>
        
        <!-- 调度设置 -->
        <GroupBox Header="调度设置" Grid.Row="1">
            \<Grid\>
                <Label Content="Cron表达式:"/>
                <TextBox Text="{Binding CronExpression}"/>
            </Grid>
        </GroupBox>
        
        <!-- 参数设置 -->
        <GroupBox Header="任务参数" Grid.Row="2">
            <DataGrid ItemsSource="{Binding JobData}"/>
        </GroupBox>
        
        <!-- 按钮 -->
        <StackPanel Orientation="Horizontal" Grid.Row="4" HorizontalAlignment="Right">
            <Button Content="保存" Command="{Binding SaveCommand}"/>
            <Button Content="取消" Command="{Binding CancelCommand}"/>
        </StackPanel>
    </Grid>
</Window>

3. 监控面板

xml

<UserControl x:Class="SchedulerMonitorPanel">
    \<Grid\>
        \<Grid.RowDefinitions\>
            <RowDefinition Height="Auto"/>
            <RowDefinition Height="*"/>
        </Grid.RowDefinitions>
        
        <!-- 统计信息 -->
        <UniformGrid Rows="1" Columns="4" Grid.Row="0">
            <Border Background="LightBlue">
                <StackPanel HorizontalAlignment="Center">
                    <TextBlock Text="{Binding TotalJobs}" FontSize="24"/>
                    <TextBlock Text="总任务数"/>
                </StackPanel>
            </Border>
            
            <Border Background="LightGreen">
                <StackPanel HorizontalAlignment="Center">
                    <TextBlock Text="{Binding RunningJobs}" FontSize="24"/>
                    <TextBlock Text="运行中"/>
                </StackPanel>
            </Border>
            
            <Border Background="Yellow">
                <StackPanel HorizontalAlignment="Center">
                    <TextBlock Text="{Binding PausedJobs}" FontSize="24"/>
                    <TextBlock Text="已暂停"/>
                </StackPanel>
            </Border>
            
            <Border Background="LightCoral">
                <StackPanel HorizontalAlignment="Center">
                    <TextBlock Text="{Binding FailedJobs}" FontSize="24"/>
                    <TextBlock Text="失败"/>
                </StackPanel>
            </Border>
        </UniformGrid>
        
        <!-- 实时日志 -->
        <TextBox x:Name="LogTextBox" 
                 Grid.Row="1"
                 Text="{Binding LogContent}"
                 IsReadOnly="True"
                 VerticalScrollBarVisibility="Auto"
                 HorizontalScrollBarVisibility="Auto"/>
    </Grid>
</UserControl>

最佳实践

1. 任务设计原则

幂等性: 任务应该是幂等的，重复执行不会产生副作用
异常处理: 完善的异常处理和恢复机制
资源管理: 合理使用系统资源，避免资源泄漏
状态检查: 任务执行前检查系统状态

2. 调度策略

错峰执行: 避免多个重要任务同时执行
优先级设置: 为关键任务设置较高优先级（8-10），普通任务使用默认优先级（5）
依赖管理: 处理任务间的依赖关系
失败重试: 合理的重试策略和退避算法
负载均衡: 在多实例环境中合理分配任务

3. 监控和维护

日志记录: 详细记录任务执行过程
性能监控: 监控任务执行时间和资源消耗
统计分析: 定期查看任务统计报告，优化执行效率
数据导出: 定期导出任务配置作为备份
告警机制: 及时发现和处理任务异常
定期维护: 清理过期日志和数据

4. 安全考虑

权限控制: 限制任务的执行权限
数据保护: 保护敏感数据和配置
审计日志: 记录任务管理操作
网络安全: 在集群环境中确保通信安全

版本更新

v1.3.8.3 (2025-11)

新增功能:

✅ 任务优先级支持（1-10级）
✅ 执行统计（成功/失败次数、执行时间分析）
✅ 搜索和过滤（实时搜索、状态过滤）
✅ 批量操作（多选、批量启动/暂停/删除）
✅ 数据导出（CSV、JSON、统计报告）
✅ 结构化日志（Microsoft.Extensions.Logging）
✅ 增强错误处理和用户提示

优化改进:

✅ 修复所有编译警告
✅ 任务状态实时同步
✅ UI响应性能提升30%
✅ 诊断效率提升50%

检测器

算法原语

模板系统

ColorVision.Scheduler

目录

概述

基本信息

核心功能

1. 任务调度管理

2. 任务执行监控

3. 任务管理界面

4. 集成支持

架构设计

任务类型

1. 系统任务

2. 业务任务

3. 维护任务

使用示例

1. 创建简单定时任务

2. 使用Cron表达式

3. 任务监听器

4. 任务数据传递

管理界面

1. 任务列表视图

2. 任务编辑窗口

3. 监控面板

最佳实践

1. 任务设计原则

2. 调度策略

3. 监控和维护

4. 安全考虑

版本更新

v1.3.8.3 (2025-11)

相关资源

ColorVision.Scheduler ​

目录 ​

概述 ​

基本信息 ​

核心功能 ​

1. 任务调度管理 ​

2. 任务执行监控 ​

3. 任务管理界面 ​

4. 集成支持 ​

架构设计 ​

任务类型 ​

1. 系统任务 ​

2. 业务任务 ​

3. 维护任务 ​

使用示例 ​

1. 创建简单定时任务 ​

2. 使用Cron表达式 ​

3. 任务监听器 ​

4. 任务数据传递 ​

管理界面 ​

1. 任务列表视图 ​

2. 任务编辑窗口 ​

3. 监控面板 ​

最佳实践 ​

1. 任务设计原则 ​

2. 调度策略 ​

3. 监控和维护 ​

4. 安全考虑 ​

版本更新 ​

v1.3.8.3 (2025-11) ​

相关资源 ​

ColorVision.Scheduler

目录

概述

基本信息

核心功能

1. 任务调度管理

2. 任务执行监控

3. 任务管理界面

4. 集成支持

架构设计

任务类型

1. 系统任务

2. 业务任务

3. 维护任务

使用示例

1. 创建简单定时任务

2. 使用Cron表达式

3. 任务监听器

4. 任务数据传递

管理界面

1. 任务列表视图

2. 任务编辑窗口

3. 监控面板

最佳实践

1. 任务设计原则

2. 调度策略

3. 监控和维护

4. 安全考虑

版本更新

v1.3.8.3 (2025-11)

相关资源