Browse Source

refactor code

pull/7373/head
Yuriy Lytvynchuk 4 years ago
parent
commit
8b9eb43322
  1. 5
      application/src/main/java/org/thingsboard/server/actors/ruleChain/DefaultTbContext.java
  2. 2
      rule-engine/rule-engine-api/src/main/java/org/thingsboard/rule/engine/api/TbContext.java
  3. 12
      rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/util/EntitiesTenantIdAsyncLoader.java

5
application/src/main/java/org/thingsboard/server/actors/ruleChain/DefaultTbContext.java

@ -722,11 +722,6 @@ class DefaultTbContext implements TbContext {
return mainCtx.getTenantProfileCache().get(getTenantId());
}
@Override
public TenantProfile getTenantProfile(TenantId tenantId) {
return mainCtx.getTenantProfileCache().get(tenantId);
}
@Override
public WidgetsBundleService getWidgetBundleService() {
return mainCtx.getWidgetsBundleService();

2
rule-engine/rule-engine-api/src/main/java/org/thingsboard/rule/engine/api/TbContext.java

@ -308,8 +308,6 @@ public interface TbContext {
TenantProfile getTenantProfile();
TenantProfile getTenantProfile(TenantId tenantId);
WidgetsBundleService getWidgetBundleService();
WidgetTypeService getWidgetTypeService();

12
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/util/EntitiesTenantIdAsyncLoader.java

@ -100,7 +100,7 @@ public class EntitiesTenantIdAsyncLoader {
hasTenantId = Futures.immediateFuture(ctx.getWidgetBundleService().findWidgetsBundleById(tenantId, new WidgetsBundleId(id)));
break;
case RPC:
hasTenantId = ctx.getRpcService().findRpcByIdAsync(ctx.getTenantId(), new RpcId(id));
hasTenantId = ctx.getRpcService().findRpcByIdAsync(tenantId, new RpcId(id));
break;
case QUEUE:
hasTenantId = Futures.immediateFuture(ctx.getQueueService().findQueueById(tenantId, new QueueId(id)));
@ -112,16 +112,18 @@ public class EntitiesTenantIdAsyncLoader {
hasTenantId = ctx.getResourceService().findResourceInfoByIdAsync(tenantId, new TbResourceId(id));
break;
case RULE_NODE:
hasTenantId = null;
RuleNode ruleNode = ctx.getRuleChainService().findRuleNodeById(tenantId, new RuleNodeId(id));
if (ruleNode != null) {
return Futures.immediateFuture(tenantId);
hasTenantId = ctx.getRuleChainService().findRuleChainByIdAsync(tenantId, ruleNode.getRuleChainId());
} else {
hasTenantId = Futures.immediateFuture(null);
}
break;
case TENANT_PROFILE:
hasTenantId = null;
if (ctx.getTenantProfile() == ctx.getTenantProfile(new TenantId(id))) {
if (ctx.getTenantProfile().getId().equals(id)) {
return Futures.immediateFuture(tenantId);
} else {
hasTenantId = Futures.immediateFuture(null);
}
break;
default:

Loading…
Cancel
Save