dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update constructRuleChainUpdatedMsg

Browse Source
This commit is contained in:
Andrii Landiak 2023-11-15 17:48:36 +02:00
parent 0f26d7a5f0
commit a8aeaa80c1
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
application/src/main/java/org/thingsboard/server/service/edge/rpc/constructor/RuleChainMsgConstructor.java
View File

@ -37,6 +37,7 @@ import org.thingsboard.server.service.edge.rpc.utils.EdgeVersionUtils;
public class RuleChainMsgConstructor { public class RuleChainMsgConstructor {
public RuleChainUpdateMsg constructRuleChainUpdatedMsg(UpdateMsgType msgType, RuleChain ruleChain, boolean isRoot, EdgeVersion edgeVersion) { public RuleChainUpdateMsg constructRuleChainUpdatedMsg(UpdateMsgType msgType, RuleChain ruleChain, boolean isRoot, EdgeVersion edgeVersion) {
boolean isTemplateRoot = ruleChain.isRoot();
if (EdgeVersionUtils.isEdgeVersionOlderThan_3_6_2(edgeVersion)) { if (EdgeVersionUtils.isEdgeVersionOlderThan_3_6_2(edgeVersion)) {
return constructDeprecatedRuleChainUpdatedMsg(msgType, ruleChain, isRoot); return constructDeprecatedRuleChainUpdatedMsg(msgType, ruleChain, isRoot);
} }
@ -44,7 +45,7 @@ public class RuleChainMsgConstructor {
RuleChainUpdateMsg result = RuleChainUpdateMsg.newBuilder().setMsgType(msgType).setEntity(JacksonUtil.toString(ruleChain)) RuleChainUpdateMsg result = RuleChainUpdateMsg.newBuilder().setMsgType(msgType).setEntity(JacksonUtil.toString(ruleChain))
.setIdMSB(ruleChain.getId().getId().getMostSignificantBits()) .setIdMSB(ruleChain.getId().getId().getMostSignificantBits())
.setIdLSB(ruleChain.getId().getId().getLeastSignificantBits()).build(); .setIdLSB(ruleChain.getId().getId().getLeastSignificantBits()).build();
ruleChain.setRoot(false); ruleChain.setRoot(isTemplateRoot);
return result; return result;
} }