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

Merge pull request #5852 from Nikitozin/feature/PROD-1251

Browse Source 
[WIP][3.3.3] Add statement for support double type.
This commit is contained in:
Andrew Shvayka 2022-01-13 15:48:53 +02:00 committed by GitHub
commit bea3c86f67
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/action/TbSaveToCustomCassandraTableNode.java
View File

@ -179,14 +179,19 @@ public class TbSaveToCustomCassandraTableNode implements TbNode {
if (key.equals(ENTITY_ID)) {
stmtBuilder.setUuid(i.get(), msg.getOriginator().getId());
} else if (dataAsObject.has(key)) {
if (dataAsObject.get(key).isJsonPrimitive()) {
JsonPrimitive primitive = dataAsObject.get(key).getAsJsonPrimitive();
JsonElement dataKeyElement = dataAsObject.get(key);
if (dataKeyElement.isJsonPrimitive()) {
JsonPrimitive primitive = dataKeyElement.getAsJsonPrimitive();
if (primitive.isNumber()) {
stmtBuilder.setLong(i.get(), dataAsObject.get(key).getAsLong());
if (primitive.getAsString().contains(".")) {
stmtBuilder.setDouble(i.get(), primitive.getAsDouble());
} else {
stmtBuilder.setLong(i.get(), primitive.getAsLong());
}
} else if (primitive.isBoolean()) {
stmtBuilder.setBoolean(i.get(), dataAsObject.get(key).getAsBoolean());
stmtBuilder.setBoolean(i.get(), primitive.getAsBoolean());
} else if (primitive.isString()) {
stmtBuilder.setString(i.get(), dataAsObject.get(key).getAsString());
stmtBuilder.setString(i.get(), primitive.getAsString());
} else {
stmtBuilder.setToNull(i.get());
}