{
-
- /**
- * 重写分页查询方法
- *
- * @param page 分页参数
- * @param wrapper 查询条件
- * @return 分页结果
- */
- > P selectVoPage(IPage page, @Param("ew") Wrapper wrapper);
-
- /**
- * 根据批次ID查询定时任务
- *
- * @param batchId 批次ID
- * @return 定时任务列表
- */
- List selectByBatchId(Long batchId);
-
- /**
- * 根据任务类型查询定时任务
- *
- * @param taskType 任务类型
- * @return 定时任务列表
- */
- List selectByTaskType(String taskType);
-
- /**
- * 根据任务状态查询定时任务
- *
- * @param taskStatus 任务状态
- * @return 定时任务列表
- */
- List selectByTaskStatus(String taskStatus);
-
- /**
- * 根据批次ID和任务类型查询定时任务
- *
- * @param batchId 批次ID
- * @param taskType 任务类型
- * @return 定时任务列表
- */
- List selectByBatchAndType(@Param("batchId") Long batchId, @Param("taskType") String taskType);
-
- /**
- * 查询待执行的定时任务
- *
- * @return 待执行的定时任务列表
- */
- List selectPendingTasks();
-
- /**
- * 查询即将执行的定时任务(指定时间内)
- *
- * @param minutes 分钟数
- * @return 即将执行的定时任务列表
- */
- List selectUpcomingTasks(Integer minutes);
-
- /**
- * 查询已过期但未执行的定时任务
- *
- * @return 已过期的定时任务列表
- */
- List selectOverdueTasks();
-
- /**
- * 查询执行失败的定时任务
- *
- * @return 执行失败的定时任务列表
- */
- List selectFailedTasks();
-
- /**
- * 查询指定时间范围内的定时任务
- *
- * @param startTime 开始时间
- * @param endTime 结束时间
- * @return 定时任务列表
- */
- List selectByTimeRange(@Param("startTime") Date startTime, @Param("endTime") Date endTime);
-
- /**
- * 查询指定批次的最新定时任务
- *
- * @param batchId 批次ID
- * @param limit 限制条数
- * @return 最新定时任务列表
- */
- List selectLatestByBatchId(@Param("batchId") Long batchId, @Param("limit") Integer limit);
-
- /**
- * 批量插入定时任务
- *
- * @param tasks 定时任务列表
- * @return 插入结果
- */
- int batchInsert(@Param("tasks") List tasks);
-
- /**
- * 批量更新任务状态
- *
- * @param ids 任务ID列表
- * @param taskStatus 任务状态
- * @return 更新结果
- */
- int batchUpdateStatus(@Param("ids") List ids, @Param("taskStatus") String taskStatus);
-
- /**
- * 更新任务执行结果
- *
- * @param id 任务ID
- * @param taskStatus 任务状态
- * @param executeTime 执行时间
- * @param errorMessage 错误信息
- * @return 更新结果
- */
- int updateExecuteResult(@Param("id") Long id, @Param("taskStatus") String taskStatus, @Param("executeTime") Date executeTime, @Param("errorMessage") String errorMessage);
-
- /**
- * 根据批次ID删除定时任务
- *
- * @param batchId 批次ID
- * @return 删除结果
- */
- int deleteByBatchId(Long batchId);
-
- /**
- * 删除指定状态的定时任务
- *
- * @param taskStatus 任务状态
- * @return 删除结果
- */
- int deleteByTaskStatus(String taskStatus);
-
- /**
- * 删除指定时间之前的定时任务
- *
- * @param beforeTime 时间点
- * @return 删除结果
- */
- int deleteBeforeTime(Date beforeTime);
-
- /**
- * 统计指定批次的定时任务数量
- *
- * @param batchId 批次ID
- * @return 定时任务数量
- */
- int countByBatchId(Long batchId);
-
- /**
- * 统计指定任务类型的数量
- *
- * @param taskType 任务类型
- * @return 任务数量
- */
- int countByTaskType(String taskType);
-
- /**
- * 统计指定任务状态的数量
- *
- * @param taskStatus 任务状态
- * @return 任务数量
- */
- int countByTaskStatus(String taskStatus);
-
- /**
- * 统计待执行的任务数量
- *
- * @return 待执行任务数量
- */
- int countPendingTasks();
-
- /**
- * 统计执行失败的任务数量
- *
- * @return 失败任务数量
- */
- int countFailedTasks();
-
- /**
- * 查询任务类型统计
- *
- * @param batchId 批次ID(可选)
- * @return 任务类型统计列表
- */
- List