Changes for page ThingsBoard
Last modified by Dilisi S on 2025/04/23 19:23
Summary
-
Page properties (1 modified, 0 added, 0 removed)
-
Attachments (0 modified, 0 added, 3 removed)
Details
- Page properties
-
- Content
-
... ... @@ -164,6 +164,7 @@ 164 164 [[image:ins1.png||height="310" width="500"]] 165 165 166 166 167 +(% class="wikigeneratedid" %) 167 167 = 3. Creating Devices = 168 168 169 169 ... ... @@ -207,93 +207,138 @@ 207 207 208 208 The **Add data converter** window will appear. Name it ‘**MQTT Uplink Converter NB/CB**’ and select the Type as **Uplink**. 209 209 210 -Click on the ** TBEL** buttonif it has not been selected by default.211 +Click on the **JavaScript** button. 211 211 212 - Modifythe defaultTBELfunction tomatch withyourdeviceas describedbelow:213 +Delete the default decoder function in the code editor. Now copy and paste the following decoder function written in **JavaScript** in to the **code editor**. This decoder function is compatible for both NB and CB series devices. 213 213 215 +{{info}} 216 +Please note that the value assigned to the IMEI field in the payload will be used by ThingsBoard to create a device on the platform with the same name. 217 +{{/info}} 214 214 215 -~1. Uncomment line 11: 216 - 217 -var data = decodeToJson(payload) 218 - 219 -[[image:Screenshot 2025-03-26 at 18.15.08.png||height="219" width="500"]] 220 - 221 - 222 -3. Modify the telemetry section to allow parsed data to be assigned to the fields. 223 - 224 -telemetry: { 225 - temperature: data.temperature, 226 - humidity: data.humidity, 227 - rawData: payloadStr 228 - } 229 - 230 - 231 - 232 232 {{code language="JavaScript"}} 233 -// Decode an uplink message from a buffer 234 -// payload - array of bytes 235 -// metadata - key/value object 236 - 237 -/** Decoder **/ 238 - 220 +//Version: 0.1 239 239 // decode payload to string 240 240 var payloadStr = decodeToString(payload); 241 241 242 242 // decode payload to JSON 225 +var objdata = {}; 226 +var obj1 = {}; 243 243 var data = decodeToJson(payload); 228 +var deviceName = data.IMEI; 229 +delete data.IMEI; 230 +var modelname = "Dragino " + data.Model; 231 +//var mod = data.mod 232 +delete data.Model; 233 +//delete data.mod 234 +var timestamp = new Date().getTime(); 244 244 245 -var deviceName = 'Device B'; 246 -var deviceType = 'thermostat'; 247 -var customerName = 'Customer C'; 248 -var groupName = 'thermostat devices'; 249 -var manufacturer = 'Example corporation'; 250 -// use assetName and assetType instead of deviceName and deviceType 251 -// to automatically create assets instead of devices. 252 -// var assetName = 'Asset A'; 253 -// var assetType = 'building'; 236 +for (var key in data) { 237 + 238 + if (Number(key)) { 239 + obj1[key] = data[key]; 240 + obj1[key][obj1[key].length - 1] = Number(new Date( 241 + obj1[key][obj1[key].length - 1])); 254 254 255 -// Result object with device/asset attributes/telemetry data 243 + } 244 +//Alec submitted25/02/25 245 +//turn old key into new 246 + else if (key === "Reading") { 247 + objdata["reading"] = data[key]; 248 + } else if (key === "work mode") { 249 + objdata["work_mode"] = data[key]; 250 + } else if (key === "hum") { 251 + objdata["humidity"] = data[key]; 252 + }else if (key === "hum2") { 253 + objdata["humidity2"] = data[key]; 254 + } else if (key === "hum3") { 255 + objdata["humidity3"] = data[key]; 256 + } else if (key === "tem") { 257 + objdata["temperature"] = data[key]; 258 + } else if (key === "tem2") { 259 + objdata["temperature2"] = data[key]; 260 + } else if (key === "tem3") { 261 + objdata["temperature3"] = data[key]; 262 + } else if (key === "DS18B20_Temp") { 263 + objdata["temperature_pro"] = data[key]; 264 + } else if (key === "ds18b20_temperature") { 265 + objdata["temperature_pro"] = data[key]; 266 + } else if (key === "DS18B20_temperature_pro") { 267 + objdata["temperature_pro"] = data[key]; 268 + } else if (key === "tdc send flag") { 269 + objdata["tdc_send_flag"] = data[key]; 270 + } else if (key === "trigger mode") { 271 + objdata["trigger_mode"] = data[key]; 272 + } else if (key === "soil dielectric constant") { 273 + objdata["soil_dielectric_constant"] = data[key]; 274 + } else if (key === "door open num") { 275 + objdata["door_open_num"] = data[key]; 276 + } else if (key === "door duration") { 277 + objdata["door_duration"] = data[key]; 278 + } else if (key === "count time") { 279 + objdata["count_time"] = data[key]; 280 + } else if (key === "last open time2") { 281 + objdata["last_open_time2"] = data[key]; 282 + } else if (key === "last open time3") { 283 + objdata["last_open_time3"] = data[key]; 284 + } 285 +//Alec submitted25/02/25 286 + else { 287 + objdata[key] = data[key] 288 + } 289 +} 290 +var listdata = [{ 291 + "ts": timestamp, 292 + "values": objdata 293 +}] 294 +for (var key1 in obj1) { 295 + if (modelname == "Dragino RS485-NB") { 296 + listdata.push({ 297 + "ts": obj1[key1][obj1[key1].length - 1], 298 + "values": { 299 + "Payload": obj1[key1][0], 300 + } 301 + }) 302 + } else { 303 + listdata.push({ 304 + "ts": obj1[key1][obj1[key1].length - 1], 305 + "values": { 306 + "values": obj1[key1] 307 + }, 308 + }) 309 + } 310 +} 256 256 var result = { 257 -// Use deviceName and deviceType or assetName and assetType, but not both. 258 - deviceName: deviceName, 259 - deviceType: deviceType, 260 -// assetName: assetName, 261 -// assetType: assetType, 262 -// customerName: customerName, 263 - groupName: groupName, 264 - attributes: { 265 - model: 'Model A', 266 - serialNumber: 'SN111', 267 - integrationName: metadata['integrationName'], 268 - manufacturer: manufacturer 269 - }, 270 - telemetry: { 271 - temperature: data.temperature, 272 - humidity: data.humidity, 273 - rawData: payloadStr 274 - } 275 -}; 276 276 277 -/** Helper functions 'decodeToString' and 'decodeToJson' are already built-in **/ 313 + deviceName: deviceName, 314 + deviceType: modelname, 315 + attributes: { 316 + model: modelname, 317 + //customerName: "NB-CB", 318 + //groupName: "NB-CB", 319 + //integrationName: metadata['integrationName'] 278 278 279 -return result; 280 -{{/code}} 321 + }, 322 + telemetry: listdata 323 +} 281 281 282 -We use the same decoder function for all our devices. However, you need to modify a few things for each device. Among these, **deviceName** is a **mandatory** field. You should assign a device name to the **deviceName** field that matches the name of your device in the **Devices** section. 325 +function decodeToString(payload) { 326 + return String.fromCharCode.apply(String, payload); 327 +} 283 283 284 -For example, if your device name is **Device B**, you can change **Device A** to **Device B**. 329 +function decodeToJson(payload) { 330 + // covert payload to string. 331 + var str = decodeToString(payload); 285 285 333 + // parse string to JSON 334 + var data = JSON.parse(str); 335 + return data; 336 +} 286 286 287 -{{code language="JavaScript"}} 288 -var deviceName = 'Device A'; 289 -var deviceType = 'thermostat'; 290 -var customerName = 'Customer C'; 291 -var groupName = 'thermostat devices'; 292 -var manufacturer = 'Example corporation'; 338 +return result; 293 293 {{/code}} 294 294 295 295 296 - Once you modify the decoder function, click on the **Add** button.342 +Click on the **Add** button. 297 297 298 298 299 299 [[image:mqtt-uplink.png||width="500"]] ... ... @@ -362,15 +362,16 @@ 362 362 363 363 **Connection:** 364 364 365 -* **Host**: Cluster URL (Eg. **//011731f7xxxxxxxxxxxfbbedfc63f4.s1.eu.hivemq.cloud//**)411 +* **Host**: Cluster URL (Eg. 011731f7xxxxxxxxxxxfbbedfc63f4.s1.eu.hivemq.cloud) 366 366 * **Port**: 8883 367 367 * **Credentials**: Basic 368 368 * **Enable SSL**: YES 369 369 * **Username**: Username (from your HiveMQ Cloud Cluster with your credentials) 370 370 * **Password:** Password (from your HiveMQ Cloud Cluster with your credentials) 371 -* **Topic: v1/devices/me/telemetry** (The topic can be anything; you can even use just the device name. For example, you can use your device name here, such as devices/a/telemetry.)417 +* **Topic: v1/devices/me/telemetry** (The topic can be anything; you can even use just the device name. For example, you can use your device name here, such as S31B-NB.) 372 372 * **QoS:** 0-At most once 373 373 420 + 374 374 [[image:add-integration-connection.png||height="511" width="500"]] 375 375 376 376
- Screenshot 2025-03-26 at 18.15.08.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.pradeeka - Size
-
... ... @@ -1,1 +1,0 @@ 1 -92.2 KB - Content
- Screenshot 2025-03-26 at 19.47.52.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.pradeeka - Size
-
... ... @@ -1,1 +1,0 @@ 1 -168.4 KB - Content
- Screenshot 2025-03-26 at 19.49.31.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.pradeeka - Size
-
... ... @@ -1,1 +1,0 @@ 1 -133.0 KB - Content