Skip to Content

Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03
From version 30.1
edited by Hunter
on 2022/11/21 17:31
Change comment: There is no comment for this version
To version 48.1
edited by Hunter
on 2023/03/30 16:44
Change comment: There is no comment for this version

Summary

Details

Page properties
Content
... ... @@ -349,7 +349,6 @@
349 349  end
350 350  {{/code}}
351 351  
352 -
353 353  == **1.8 How to parse value from HTTP response body** ==
354 354  
355 355  This example use [[https:~~/~~/www.weatherapi.com/>>https://www.weatherapi.com/]] as example, to show how to parse value from HTTP response body. When we input the city name into address "@HDW5050":
... ... @@ -448,6 +448,20 @@
448 448  end
449 449  {{/code}}
450 450  
450 +== **1.9 High-Low Byte Switch** ==
451 +
452 +The following example is converting the floating number from order 1234 to order 3412, and formating output the number with 2 decimal point. About which high-low word order corresponding to which value, please refer to the [[Address Operation Table>>doc:V-BOX.V-Net.Manual.04 Lua Script.01 Lua Functions.WebHome||anchor="H2Addressoperation"]].
453 +
454 +{{code language="lua"}}
455 +function highLowByteSwitch(floatNumber)
456 + addr_setfloat("@W_0#HDW23036",floatNumber,0,2)
457 + local newFloat = addr_getfloat("@W_0#HDW23036")
458 + local formattedFloat = string.format("%.2f",newFloat)
459 + print("The formatted float value is the : "..formattedFloat)
460 + return formattedFloat
461 +end
462 +{{/code}}
463 +
451 451  = **2 V-Box connect with third part server** =
452 452  
453 453  V-Box have two mode.One is for V-Net,User need to use WECON server to store data.We call this V-NET platform.
... ... @@ -466,8 +466,9 @@
466 466  
467 467  (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate
468 468  
469 -(% class="wikigeneratedid" %)
482 +{{info}}
470 470  **✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool.
484 +{{/info}}
471 471  
472 472  (% class="wikigeneratedid" %)
473 473  Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]**
... ... @@ -474,6 +474,25 @@
474 474  
475 475  == **2.1 V-Box connect with test server(General Example)** ==
476 476  
491 +The following example is trying to publish to the topic "testtopic/test/no1/7890", and subscribe the topic "testtopic/test/no1/123456".
492 +
493 +And the JSON message is like follows:
494 +
495 +{{code language="JSON"}}
496 +{
497 + "timestamp": 1631152760,
498 + "messageId": 1,
499 + "event": "test_data",
500 + "mfrs": "HMI/box",
501 + "data":
502 + {
503 + "id" : 1436217747670454274,
504 + "waterlevel" : 48,
505 + "temperture" : 23
506 + }
507 +}
508 +{{/code}}
509 +
477 477  {{code language="lua"}}
478 478  --MQTT configuration table
479 479  local MQTT_CFG={}
... ... @@ -515,9 +515,13 @@
515 515  --initialize mqtt
516 516  function mqtt_init()
517 517   print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID))
551 + if g_mq then
552 + mqtt.close() --Close mqtt object
553 + end
518 518   g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable
519 519   if g_mq then
520 520   g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages
557 + g_mq:on("offline", mqtt_msg_offline) -- Register a callback for offline
521 521   print("mqtt init success")
522 522   else
523 523   print("mqtt init failed:", err)
... ... @@ -537,6 +537,11 @@
537 537   g_mq:subscribe(SUBSCRIBE_TOPIC, 0)
538 538  end
539 539  
577 +--Offline callback function
578 +function mqtt_msg_offline(cause)
579 + print("mqtt offline, cause:", cause)
580 +end
581 +
540 540  -- Received message callback function
541 541  function mqtt_msg_callback(topic, msg)
542 542   print("topic:", topic)
... ... @@ -575,9 +575,11 @@
575 575   if g_mq:isconnected() then
576 576   send_data()
577 577   else
578 - --if exceed 20 sec not connect, reconnect once
579 - if os.time() - LAST_TIME > 20 then
620 + --if exceed 5 sec not connect, reconnect once
621 + if os.time() - LAST_TIME > 5 then
580 580   LAST_TIME = os.time()
623 + --reinitial the mqtt object
624 + mqtt_init()
581 581   --connect to mqtt or reconnect
582 582   mqtt_connect()
583 583   end
... ... @@ -1157,35 +1157,20 @@
1157 1157  
1158 1158  {{code language="java"}}
1159 1159  {
1160 -
1161 1161    "Version": "2012-10-17",
1162 -
1163 1163    "Statement": [
1164 -
1165 1165      {
1166 -
1167 1167        "Effect": "Allow",
1168 -
1169 1169        "Action": [
1170 -
1171 1171          "iot:Connect",
1172 -
1173 1173          "iot:Publish",
1174 -
1175 1175          "iot:Subscribe",
1176 -
1177 1177          "iot:Receive",
1178 -
1179 1179          "greengrass:Discover"
1180 -
1181 1181        ],
1182 -
1183 1183        "Resource": "*"
1184 -
1185 1185      }
1186 -
1187 1187    ]
1188 -
1189 1189  }
1190 1190  {{/code}}
1191 1191  
... ... @@ -1250,185 +1250,190 @@
1250 1250  
1251 1251  [[image:image-20220709165402-20.png]]
1252 1252  
1282 +{{info}}
1283 +**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701
1284 +{{/info}}
1285 +
1286 +{{code language="lua"}}
1253 1253  sprint = print
1254 1254  
1255 -~-~-Cloud mode interface to obtain the MQTT information configured by the cloud platform: (5 returns, namely the server address, client ID, connection table, last word table, certificate table)
1289 +--Cloud mode interface to obtain the MQTT information configured by the cloud platform: (5 returns, namely the server address, client ID, connection table, last word table, certificate table)
1256 1256  
1257 1257  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
1258 1258  
1259 -~-~-publish to topics
1293 +--publish to topics
1260 1260  
1261 1261  local pub_RE_TOPIC = string.format('TEST')
1262 1262  
1263 -~-~-Subscribe topics
1297 +--Subscribe topics
1264 1264  
1265 1265  local Subscribe_RE_TOPIC1 = string.format('TEST')
1266 1266  
1267 -~-~-variable
1301 +--variable
1268 1268  
1269 1269  local last_time = 0
1270 1270  
1271 -~-~-Timing main function
1305 +--Timing main function
1272 1272  
1273 1273  function aws.main()
1274 1274  
1275 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1309 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1276 1276  
1277 - if g_mq then
1311 + if g_mq then
1278 1278  
1279 - if g_mq:isconnected() then
1313 + if g_mq:isconnected() then
1280 1280  
1281 - send_Data()
1315 + send_Data()
1282 1282  
1283 - else
1317 + else
1284 1284  
1285 - if os.time() - last_time > 5 then
1319 + if os.time() - last_time > 5 then
1286 1286  
1287 - last_time = os.time()
1321 + last_time = os.time()
1288 1288  
1289 - mymqtt_connect()
1323 + mymqtt_connect()
1290 1290  
1325 + end
1326 +
1291 1291   end
1292 1292  
1293 - end
1329 + else
1294 1294  
1295 - else
1331 + mymqtt_init()
1296 1296  
1297 - mymqtt_init()
1333 + end
1298 1298  
1299 - end
1335 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1300 1300  
1301 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1302 -
1303 1303  end
1304 1304  
1305 1305  
1306 -~-~- Initialize MQTT
1307 1307  
1341 +-- Initialize MQTT
1342 +
1308 1308  function mymqtt_init()
1309 1309  
1310 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1345 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1311 1311  
1312 - g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
1347 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID, 1) -- Create the object and declare it as a global variable, 1 means using the domain to connect
1313 1313  
1314 - if g_mq then
1349 + if g_mq then
1315 1315  
1316 - g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1351 + g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1317 1317  
1318 - sprint("mqtt init success")
1353 + sprint("mqtt init success")
1319 1319  
1320 - else
1355 + else
1321 1321  
1322 - sprint("mqtt init failed:", err)
1357 + sprint("mqtt init failed:", err)
1323 1323  
1324 - end
1359 + end
1325 1325  
1326 1326  end
1327 1327  
1328 -~-~- Connect to MQTT server
1363 +-- Connect to MQTT server
1329 1329  
1330 1330  function mymqtt_connect()
1331 1331  
1332 - sprint("mqtt connecting...")
1367 + sprint("mqtt connecting...")
1333 1333  
1334 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1369 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1335 1335  
1336 - if stat == nil then
1371 + if stat == nil then
1337 1337  
1338 - sprint("mqtt connect failed:", err)
1373 + sprint("mqtt connect failed:", err)
1339 1339  
1340 - return
1375 + return
1341 1341  
1342 - else
1377 + else
1343 1343  
1344 - sprint("mqtt connected")
1379 + sprint("mqtt connected")
1345 1345  
1346 - end
1381 + end
1347 1347  
1348 - g_mq:subscribe(TEST, 0)
1383 + g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
1349 1349  
1350 1350  end
1351 1351  
1352 -~-~- Receive MQTT message callback function
1387 +-- Receive MQTT message callback function
1353 1353  
1354 1354  function mymqtt_msg_callback(topic, msg)
1355 1355  
1356 - print("topic:",topic)
1391 + print("topic:",topic)
1357 1357  
1358 - print("revdata:",msg)
1393 + print("revdata:",msg)
1359 1359  
1360 - local revData = json.decode(msg)
1395 + local revData = json.decode(msg)
1361 1361  
1362 - print (revData)
1397 + print (revData)
1363 1363  
1364 - if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1399 + if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1365 1365  
1366 -if string.match(topic,Subscribe_RE_TOPIC1) then
1401 + if string.match(topic,Subscribe_RE_TOPIC1) then
1367 1367  
1368 - ~-~-if revData ~~= nil then
1403 + --if revData ~= nil then
1369 1369  
1370 - for k,v in pairs (revData) do
1405 + for k,v in pairs (revData) do
1371 1371  
1372 - print("printing revdata after kv here")
1407 + print("printing revdata after kv here")
1373 1373  
1374 - print (k,v)
1409 + print (k,v)
1375 1375  
1376 - end
1411 + end
1377 1377  
1378 - print ("current state is",fanstate)
1413 + print ("current state is",fanstate)
1379 1379  
1380 - ~-~-end
1415 + --end
1381 1381  
1382 -end
1417 + end
1383 1383  
1384 -end
1419 + end
1385 1385  
1386 1386  end
1387 1387  
1388 1388  
1389 -~-~-Get real-time data
1390 1390  
1425 +--Get real-time data
1426 +
1391 1391  function getData()
1392 1392  
1393 - local jdata = {}
1429 + local jdata = {}
1394 1394  
1395 - local addr = bns_get_alldata()
1431 + local addr = bns_get_alldata()
1396 1396  
1397 - print(json.encode(addr))
1433 + print(json.encode(addr))
1398 1398  
1399 - for i,v in pairs(addr) do
1435 + for i,v in pairs(addr) do
1400 1400  
1401 - if v[2] == 1 then
1437 + if v[2] == 1 then
1402 1402  
1403 - jdata[v[3]] = v[4]
1439 + jdata[v[3]] = v[4]
1404 1404  
1405 - end
1441 + end
1406 1406  
1407 - end
1443 + end
1408 1408  
1409 - return jdata
1445 + return jdata
1410 1410  
1411 1411  end
1412 1412  
1413 -~-~-send data
1449 +--send data
1414 1414  
1415 1415  function send_Data()
1416 1416  
1417 - local pub_data =
1453 + local pub_data =
1454 + {
1455 + 123
1456 + }
1418 1418  
1419 - {
1420 -
1421 -123
1422 -
1423 -}
1424 -
1425 1425  sprint(json.encode(pub_data))
1426 1426  
1427 1427  print("..........",pub_RE_TOPIC)
1428 1428  
1429 - return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1462 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1430 1430  
1431 1431  end
1465 +{{/code}}
1432 1432  
1433 1433  Get message in AWS
1434 1434