|
@@ -69,7 +69,7 @@ public class DeviceAlarmModelParser implements RuleModelParserStrategy {
|
|
//定时节点
|
|
//定时节点
|
|
//TimerTaskExecutorProvider
|
|
//TimerTaskExecutorProvider
|
|
RuleNodeModel timer = new RuleNodeModel();
|
|
RuleNodeModel timer = new RuleNodeModel();
|
|
- timer.setId("timer:" + (++index));
|
|
|
|
|
|
+ timer.setId("timer:" + (index));
|
|
timer.setName("定时发送设备消息");
|
|
timer.setName("定时发送设备消息");
|
|
timer.setExecutor("timer");
|
|
timer.setExecutor("timer");
|
|
timer.setConfiguration(Collections.singletonMap("cron", timerTrigger.getCron()));
|
|
timer.setConfiguration(Collections.singletonMap("cron", timerTrigger.getCron()));
|
|
@@ -91,7 +91,7 @@ public class DeviceAlarmModelParser implements RuleModelParserStrategy {
|
|
//设备指令发送节点
|
|
//设备指令发送节点
|
|
//DeviceMessageSendTaskExecutorProvider
|
|
//DeviceMessageSendTaskExecutorProvider
|
|
RuleNodeModel messageSender = new RuleNodeModel();
|
|
RuleNodeModel messageSender = new RuleNodeModel();
|
|
- messageSender.setId("message-sender:" + (++index));
|
|
|
|
|
|
+ messageSender.setId("message-sender:" + (index));
|
|
messageSender.setName("定时发送设备消息");
|
|
messageSender.setName("定时发送设备消息");
|
|
messageSender.setExecutor("device-message-sender");
|
|
messageSender.setExecutor("device-message-sender");
|
|
messageSender.setConfiguration(senderDeviceMessageSendConfig.toMap());
|
|
messageSender.setConfiguration(senderDeviceMessageSendConfig.toMap());
|
|
@@ -118,6 +118,7 @@ public class DeviceAlarmModelParser implements RuleModelParserStrategy {
|
|
toAlarm.setTarget(conditionNode);
|
|
toAlarm.setTarget(conditionNode);
|
|
messageSender.getOutputs().add(toAlarm);
|
|
messageSender.getOutputs().add(toAlarm);
|
|
conditionNode.getInputs().add(toAlarm);
|
|
conditionNode.getInputs().add(toAlarm);
|
|
|
|
+ index++;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|