Files
YunTongJackYunTask/Reportapi/MyCode.Project.Services/IServices/IWorkProcessService.cs

85 lines
2.9 KiB
C#
Raw Normal View History

2025-07-04 09:50:02 +08:00
using MyCode.Project.Domain.Model;
using MyCode.Project.Infrastructure.Enumeration;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace MyCode.Project.Services
{
public interface IWorkProcessService
{
/// <summary>
2025-07-07 13:54:21 +08:00
/// 添加调度任务
2025-07-04 09:50:02 +08:00
/// </summary>
2025-07-07 13:54:21 +08:00
/// <typeparam name="T">执行类</typeparam>
/// <param name="merchantId">商家ID</param>
/// <param name="methodName">方法名</param>
/// <param name="remark">备注</param>
/// <param name="entity">参数信息</param>
/// <param name="funcType">执行类型</param>
void Add<T>(Guid merchantId, string methodName, string remark = "", object entity = null, int priority = 5, FuncType funcType = FuncType.Method) where T : class;
2025-07-04 09:50:02 +08:00
/// <summary>
2025-07-07 13:54:21 +08:00
/// 添加调度任务
2025-07-04 09:50:02 +08:00
/// </summary>
2025-07-07 13:54:21 +08:00
/// <param name="merchantId">商家ID</param>
/// <param name="type">执行类</param>
/// <param name="methodName">方法名</param>
/// <param name="remark">备注</param>
/// <param name="entity">参数信息</param>
/// <param name="funcType">执行类型</param>
void Add(Guid merchantId, Type type, string methodName, string remark = "", object entity = null,
FuncType funcType = FuncType.Method, int priority = 5);
2025-07-04 09:50:02 +08:00
2025-07-07 13:54:21 +08:00
/// <summary>
/// 添加调度任务
/// </summary>
/// <param name="merchantId">商家ID</param>
/// <param name="typePath">类型路径Lxm.IServices.IWorkProcessService, Lxm.Services</param>
/// <param name="methodName">方法名</param>
/// <param name="remark">备注</param>
/// <param name="paramInfo">参数信息</param>
/// <param name="funcType">执行类型</param>
void Add(Guid merchantId, string typePath, string methodName, string remark = "", string paramInfo = "",
FuncType funcType = FuncType.Method, int priority = 5);
2025-07-04 09:50:02 +08:00
/// <summary>
/// 执行每次执行10条数据
/// </summary>
2025-07-07 13:54:21 +08:00
void Execute();
2025-07-04 09:50:02 +08:00
/// <summary>
/// 重启失败调度
/// </summary>
void RestratStopProcess();
/// <summary>
/// 重新启用某个暂停了的调度
/// </summary>
/// <param name="workprocessId"></param>
2025-07-07 13:54:21 +08:00
void RestartStopProcess(Guid workprocessId);
2025-07-04 09:50:02 +08:00
/// <summary>
2025-07-07 13:54:21 +08:00
/// 调度执行优先级比较低的任务
2025-07-04 09:50:02 +08:00
/// </summary>
2025-07-07 13:54:21 +08:00
void ExecuteOther();
/// <summary>
/// 调度执行优先级等于2的任务
/// </summary>
void ExecutePriority2Work();
2025-07-04 09:50:02 +08:00
/// <summary>
2025-07-07 13:54:21 +08:00
/// 调度执行优先级=6的任务
2025-07-04 09:50:02 +08:00
/// </summary>
2025-07-07 13:54:21 +08:00
void ExecutePriority6();
2025-07-04 09:50:02 +08:00
/// <summary>
2025-07-07 13:54:21 +08:00
/// 重试失败的任务
2025-07-04 09:50:02 +08:00
/// </summary>
2025-07-07 13:54:21 +08:00
void RetryTask();
2025-07-04 09:50:02 +08:00
}
}