luosheng/Modbus.Net
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ApplyTo change

Browse Source
This commit is contained in:
luosheng
2023-02-15 17:40:22 +08:00
parent af928c5932
commit 62f63c142a
1 changed files with 2 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
Modbus.Net/Modbus.Net/Job/MachineJobScheduler.cs
View File

@@ -160,29 +160,8 @@ namespace Modbus.Net
public async Task<MachineSetJobScheduler> ApplyTo<TMachineKey>(string queryId, Dictionary<string, ReturnUnit> values, MachineDataType machineDataType) where TMachineKey : IEquatable<TMachineKey> public async Task<MachineSetJobScheduler> ApplyTo<TMachineKey>(string queryId, Dictionary<string, ReturnUnit> values, MachineDataType machineDataType) where TMachineKey : IEquatable<TMachineKey>
{ {
JobKey jobKey = JobKey.Create("Modbus.Net.DataQuery.Job." + queryId, "Modbus.Net.DataQuery.Group." + _trigger.Key.Name); var applyJobScheduler = await Apply<TMachineKey>(queryId, values, machineDataType);
return await applyJobScheduler.Query();
IJobDetail job = JobBuilder.Create<MachineQueryDataJob<TMachineKey>>()
.WithIdentity(jobKey)
.StoreDurably(true)
.Build();
job.JobDataMap.Put("DataType", machineDataType);
job.JobDataMap.Put("Value", values);
if (_parentJobKey != null)
{
var listener = _scheduler.ListenerManager.GetJobListener("Modbus.Net.DataQuery.Chain." + _trigger.Key.Name) as JobChainingJobListenerWithDataMap;
listener.AddJobChainLink(_parentJobKey, jobKey);
await _scheduler.AddJob(job, true);
}
else
{
await _scheduler.ScheduleJob(job, _trigger);
}
return new MachineSetJobScheduler(_scheduler, _trigger, jobKey);
} }
} }