|
|
|
@ -12,8 +12,10 @@ using System.Linq;
|
|
|
|
|
namespace IoTNode.Services
|
|
|
|
|
{
|
|
|
|
|
public class IoTNodeEventHandler :
|
|
|
|
|
IEventHander<EntityInsertedEvent<IoTTimer>>,
|
|
|
|
|
IEventHander<EntityUpdatedEvent<IoTTimer>>,
|
|
|
|
|
IEventHander<EntityDeletedEvent<IoTTimer>>,
|
|
|
|
|
IEventHander<EntityInsertedEvent<IoTTigger>>,
|
|
|
|
|
IEventHander<EntityUpdatedEvent<IoTTigger>>,
|
|
|
|
|
IEventHander<EntityDeletedEvent<IoTTigger>>,
|
|
|
|
|
IEventHander<EntityUpdatedEvent<Data>>
|
|
|
|
@ -26,6 +28,11 @@ namespace IoTNode.Services
|
|
|
|
|
this._sp = sp;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public void Handle(EntityInsertedEvent<IoTTimer> message)
|
|
|
|
|
{
|
|
|
|
|
RecurringJob.AddOrUpdate<IoTNodeJob>(message.Data.Id.ToString(), o => o.TimerHanle(message.Data.Id), message.Data.Cron);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public void Handle(EntityUpdatedEvent<IoTTimer> message)
|
|
|
|
|
{
|
|
|
|
|
RecurringJob.AddOrUpdate<IoTNodeJob>(message.Data.Id.ToString(), o => o.TimerHanle(message.Data.Id), message.Data.Cron);
|
|
|
|
@ -36,6 +43,11 @@ namespace IoTNode.Services
|
|
|
|
|
RecurringJob.RemoveIfExists(message.Data.Id.ToString());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public void Handle(EntityInsertedEvent<IoTTigger> message)
|
|
|
|
|
{
|
|
|
|
|
Tiggers.TryAdd(message.Data.Id, message.Data);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public void Handle(EntityUpdatedEvent<IoTTigger> message)
|
|
|
|
|
{
|
|
|
|
|
Tiggers.TryRemove(message.Data.Id, out IoTTigger tigger);
|
|
|
|
|