wenkai.chen/tnb.server
Template
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

测试任务调度 还有问题

Browse Source
This commit is contained in:
周科达
2023-05-15 14:45:44 +08:00
parent c3809e2f45
commit 816eda3af3
2 changed files with 16 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
taskschedule/Tnb.TaskScheduler/Listener/GenerateSpotInspectionPlanTimeWorker.cs Normal file
View File

@@ -0,0 +1,11 @@
namespace JNPF.TaskScheduler.Listener
{
public class GenerateSpotInspectionPlanTimeWorker : ISpareTimeWorker
{
[SpareTime("0 45 14 * * ? *", "生成点巡检计划", ExecuteType = SpareTimeExecuteTypes.Serial,StartNow = false)]
public void GenerateSpotInspectionPlan(SpareTimer timer, long count)
{
Console.WriteLine("hello world");
}
}
}

8
taskschedule/Tnb.TaskScheduler/TimeTaskService.cs
View File

@@ -377,14 +377,16 @@ public class TimeTaskService : ITimeTaskService, IDynamicApiController, ITransie
/// <returns></returns> /// <returns></returns>
private async Task<List<TaskMethodInfo>> GetTaskMethods() private async Task<List<TaskMethodInfo>> GetTaskMethods()
{ {
var taskMethods = await _cacheManager.GetAsync<List<TaskMethodInfo>>(CommonConst.CACHEKEYTIMERJOB); // var taskMethods = await _cacheManager.GetAsync<List<TaskMethodInfo>>(CommonConst.CACHEKEYTIMERJOB);
if (taskMethods != null) return taskMethods; // if (taskMethods != null) return taskMethods;
List<TaskMethodInfo> taskMethods = null;
// 获取所有本地任务方法，必须有spareTimeAttribute特性 // 获取所有本地任务方法，必须有spareTimeAttribute特性
taskMethods = App.EffectiveTypes taskMethods = App.EffectiveTypes
.Where(u => u.IsClass && !u.IsInterface && !u.IsAbstract && typeof(ISpareTimeWorker).IsAssignableFrom(u)) .Where(u => u.IsClass && !u.IsInterface && !u.IsAbstract && typeof(ISpareTimeWorker).IsAssignableFrom(u))
.SelectMany(u => u.GetMethods(BindingFlags.Public | BindingFlags.Instance) .SelectMany(u => u.GetMethods(BindingFlags.Public | BindingFlags.Instance)
.Where(m => m.IsDefined(typeof(SpareTimeAttribute), false) && .Where(m => m.GetCustomAttributes(typeof(SpareTimeAttribute), false).ToString().Contains("SpareTime") &&
m.GetParameters().Length == 2 && m.GetParameters().Length == 2 &&
m.GetParameters()[0].ParameterType == typeof(SpareTimer) && m.GetParameters()[0].ParameterType == typeof(SpareTimer) &&
m.GetParameters()[1].ParameterType == typeof(long) && m.ReturnType == typeof(void)) m.GetParameters()[1].ParameterType == typeof(long) && m.ReturnType == typeof(void))