Changes for page 2 Script
Last modified by Devin Chen on 2025/06/06 14:03
From version 60.1
edited by Theodore Xu
on 2023/08/24 17:17
on 2023/08/24 17:17
Change comment:
There is no comment for this version
Summary
-
Page properties (2 modified, 0 added, 0 removed)
Details
- Page properties
-
- Author
-
... ... @@ -1,1 +1,1 @@ 1 -XWiki. AiXia1 +XWiki.Hunter - Content
-
... ... @@ -1,9 +1,9 @@ 1 1 = **1 General Script Demo** = 2 2 3 -== **1.1 Address Operation** == 3 +== **1.1 Address Operation:Write/Read data from address A to B** == 4 4 5 5 ((( 6 - Write/Read data from address A to B**. **For example:transfer D2 to D06 +For example:transfer D2 to D0 7 7 ))) 8 8 9 9 (% style="text-align:center" %) ... ... @@ -27,19 +27,25 @@ 27 27 28 28 == **1.4 Short message** == 29 29 30 - Thefollowingdemo showsthat whenthealarm condition is reached: temp1 > 5 & temp2 >10 & temp3 < 20(lasts more than 5 seconds) , then send an "alarm trigger" sms.30 +When the alarm condition is reached: temp1 > 5 & temp2 >10 & temp3 < 20(lasts more than 5 seconds) , then send an "alarm trigger" sms. 31 31 32 -When the alarm condition is released,then send an Script is as below:32 +When the alarm condition is released,then send an "alarm release" sms. 33 33 34 -{{code language="lua"}} 34 +(% style="text-align:center" %) 35 +[[image:1645535936750-316.png||height="385" width="400" class="img-thumbnail"]] 36 + 37 +Script is as below: 38 + 39 +(% class="box infomessage" %) 40 +((( 35 35 function sms.main() 36 -------send condition------ 42 +~-~-~-~-~-~-send condition~-~-~-~-~-~- 37 37 local temp1 = addr_getword("@Temperature1") 38 38 local temp2 = addr_getword("@Temperature2") 39 39 local temp3 = addr_getword("@Temperature3") 40 40 local timer = addr_getword("@Timer") 41 41 local tag = addr_getbit("@Tag") 42 -------lasting time------ 48 +~-~-~-~-~-~-lasting time~-~-~-~-~-~- 43 43 if temp1 > 5 and temp2 > 10 and temp3 < 20 then 44 44 timer = timer + 1 45 45 addr_setword("@Timer",timer) ... ... @@ -47,7 +47,7 @@ 47 47 timer = 0 48 48 addr_setword("@Timer",timer) 49 49 end 50 -------send sms & output Y0------ 56 +~-~-~-~-~-~-send sms & output Y0~-~-~-~-~-~- 51 51 if timer > 5 then 52 52 if tag == 0 then 53 53 send_sms_ira("19859254700","alarm trigger") ... ... @@ -58,7 +58,7 @@ 58 58 addr_setbit("@Tag",0) 59 59 end 60 60 end 61 - {{/code}}67 +))) 62 62 63 63 == **1.5 Telegram notification** == 64 64 ... ... @@ -139,7 +139,7 @@ 139 139 140 140 This example shows how to use the LINE Notify to send message into LINE group. When monitoring bit "@test" changes, it will trigger and send the message. Please replace with your own Token. 141 141 142 -{{code language="lua"}}148 +{{code}} 143 143 local tempBit = 0 144 144 local tempWord = 0 145 145 ... ... @@ -343,6 +343,7 @@ 343 343 end 344 344 {{/code}} 345 345 352 + 346 346 == **1.8 How to parse value from HTTP response body** == 347 347 348 348 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": ... ... @@ -397,7 +397,7 @@ 397 397 {{/code}} 398 398 399 399 (% class="wikigeneratedid" %) 400 -So we decode json into lua object to assign the value into addresses HDW6060(temperature), HDW7070(humidity) ,the code example like follows:407 +So we decode json into lua object to assign the value into addresses HDW6060(temperature), HDW7070(humidity) the code example like follows: 401 401 402 402 {{code language="lua"}} 403 403 local APIkey = '70faaecf926b4341b1974006221711' ... ... @@ -441,39 +441,8 @@ 441 441 end 442 442 {{/code}} 443 443 444 -= =**1.9High-LowByteSwitch** ==451 += **2 V-Box connect with third part server** = 445 445 446 -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"]]. 447 - 448 -{{code language="lua"}} 449 -function highLowByteSwitch(floatNumber) 450 - addr_setfloat("@W_0#HDW23036",floatNumber,0,2) 451 - local newFloat = addr_getfloat("@W_0#HDW23036") 452 - local formattedFloat = string.format("%.2f",newFloat) 453 - print("The formatted float value is the : "..formattedFloat) 454 - return formattedFloat 455 -end 456 -{{/code}} 457 - 458 -== **1.10 Read 64bits Unsigned Value** == 459 - 460 -In our built-in function library doesn't have the function for reading 64-bit unsigned format value, so the following function is for solve this. But if the number is greater 2^53, the precision will be lost. So the final result will be a little bit different from the original value. 461 - 462 -{{code language="lua"}} 463 -function addr_getquatra(address) 464 - local highAddress = addr_newnoaddr(address,2) 465 - local low32 = addr_getdword(address) 466 - local high32 = addr_getdword(highAddress) 467 - --print("the low number is "..low32) 468 - --print("the high number is "..high32) 469 - local formatVal = string.format("%64.0f",2^32*high32+low32) 470 - print("the format value is ".. formatVal) 471 - return formatVal 472 -end 473 -{{/code}} 474 - 475 -= **2 Third part server** = 476 - 477 477 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. 478 478 479 479 (% class="mark" %)1.Europe server:eu.v-box.net ... ... @@ -490,38 +490,17 @@ 490 490 491 491 (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate 492 492 493 - {{info}}469 +(% class="wikigeneratedid" %) 494 494 **✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool. 495 -{{/info}} 496 496 497 497 (% class="wikigeneratedid" %) 498 498 Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]** 499 499 500 -== **2.1 Test server(General Example)** ==475 +== **2.1 V-Box connect with test server(General Example)** == 501 501 502 -The following example is trying to publish to the topic "testtopic/test/no1/7890", and subscribe the topic "testtopic/test/no1/123456". 503 - 504 -And the JSON message is like follows: 505 - 506 -{{code language="JSON"}} 507 -{ 508 - "timestamp": 1631152760, 509 - "messageId": 1, 510 - "event": "test_data", 511 - "mfrs": "HMI/box", 512 - "data": 513 - { 514 - "id" : 1436217747670454274, 515 - "waterlevel" : 48, 516 - "temperture" : 23 517 - } 518 -} 519 -{{/code}} 520 - 521 521 {{code language="lua"}} 522 522 --MQTT configuration table 523 523 local MQTT_CFG={} 524 ---if there is no need the username and password, please put them as "" 525 525 MQTT_CFG.username = "weconsupport" 526 526 MQTT_CFG.password = "123456" 527 527 MQTT_CFG.netway = 0 ... ... @@ -560,13 +560,9 @@ 560 560 --initialize mqtt 561 561 function mqtt_init() 562 562 print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID)) 563 - if g_mq then 564 - mqtt.close(g_mq) --Close mqtt object 565 - end 566 566 g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable 567 567 if g_mq then 568 568 g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages 569 - g_mq:on("offline", mqtt_msg_offline) -- Register a callback for offline 570 570 print("mqtt init success") 571 571 else 572 572 print("mqtt init failed:", err) ... ... @@ -586,11 +586,6 @@ 586 586 g_mq:subscribe(SUBSCRIBE_TOPIC, 0) 587 587 end 588 588 589 ---Offline callback function 590 -function mqtt_msg_offline(cause) 591 - print("mqtt offline, cause:", cause) 592 -end 593 - 594 594 -- Received message callback function 595 595 function mqtt_msg_callback(topic, msg) 596 596 print("topic:", topic) ... ... @@ -629,11 +629,9 @@ 629 629 if g_mq:isconnected() then 630 630 send_data() 631 631 else 632 - --if exceed 5sec not connect, reconnect once633 - if os.time() - LAST_TIME > 5then578 + --if exceed 20 sec not connect, reconnect once 579 + if os.time() - LAST_TIME > 20 then 634 634 LAST_TIME = os.time() 635 - --reinitial the mqtt object 636 - mqtt_init() 637 637 --connect to mqtt or reconnect 638 638 mqtt_connect() 639 639 end ... ... @@ -646,7 +646,7 @@ 646 646 end 647 647 {{/code}} 648 648 649 -== **2.2 Customer server:grouprobotinfo.com** ==593 +== **2.2 V-Box connect with customer server:grouprobotinfo.com** == 650 650 651 651 This demo does not use SSL certification. Script is as below 652 652 ... ... @@ -787,7 +787,7 @@ 787 787 end 788 788 {{/code}} 789 789 790 -== **2.3 Azure platform** == 734 +== **2.3 V-Box connect with Azure platform** == 791 791 792 792 In this demo,V-Box connects with Azure by SSL certification. 793 793 ... ... @@ -918,12 +918,8 @@ 918 918 end 919 919 ))) 920 920 921 -== **2.4 Huawei platform** == 865 +== **2.4 How to configure the Huawei platform?(✎Note: Huawei IOT DA function is only in China area.If you want this function,you need to use chinese mobile to register)** == 922 922 923 -{{info}} 924 -**✎Note**:**Huawei IOT DA function is only in China area.If you want this function,you need to use chinese mobile to register** 925 -{{/info}} 926 - 927 927 1.Register a account: [[https:~~/~~/www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ>>https://www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ]] 928 928 929 929 2.log in the Huawei IOTDA ... ... @@ -1071,8 +1071,10 @@ 1071 1071 (% style="text-align:center" %) 1072 1072 [[image:1624441186851-536.png||height="434" width="700" class="img-thumbnail"]] 1073 1073 1074 -== =HuaweibySSLcertification.===1014 +== **2.5 V-Box connect with Huawei platform** == 1075 1075 1016 +In this demo,V-Box connects with Huawei by SSL certification. 1017 + 1076 1076 1.Create a project access for Huawei IOT 1077 1077 1078 1078 2.configure MQTT configuration ... ... @@ -1190,7 +1190,7 @@ 1190 1190 (% style="text-align:center" %) 1191 1191 [[image:1624506666650-161.png||height="547" width="1000" class="img-thumbnail"]] 1192 1192 1193 -== **2.6 AWS platform** == 1135 +== **2.6 V-Box connect with AWS platform** == 1194 1194 1195 1195 === **Log in AWS** === 1196 1196 ... ... @@ -1215,20 +1215,35 @@ 1215 1215 1216 1216 {{code language="java"}} 1217 1217 { 1160 + 1218 1218 "Version": "2012-10-17", 1162 + 1219 1219 "Statement": [ 1164 + 1220 1220 { 1166 + 1221 1221 "Effect": "Allow", 1168 + 1222 1222 "Action": [ 1170 + 1223 1223 "iot:Connect", 1172 + 1224 1224 "iot:Publish", 1174 + 1225 1225 "iot:Subscribe", 1176 + 1226 1226 "iot:Receive", 1178 + 1227 1227 "greengrass:Discover" 1180 + 1228 1228 ], 1182 + 1229 1229 "Resource": "*" 1184 + 1230 1230 } 1186 + 1231 1231 ] 1188 + 1232 1232 } 1233 1233 {{/code}} 1234 1234 ... ... @@ -1255,7 +1255,7 @@ 1255 1255 [[image:image-20220709165402-11.png]] 1256 1256 1257 1257 1258 -=== **MQTT.fx tool** === 1215 +=== **Test with MQTT.fx tool** === 1259 1259 1260 1260 Click “View Setting” to get the “Broker Adress” 1261 1261 ... ... @@ -1283,7 +1283,7 @@ 1283 1283 1284 1284 [[image:image-20220709165402-18.png]] 1285 1285 1286 -=== **CloudTool** === 1243 +=== **Configurate in CloudTool** === 1287 1287 1288 1288 Copy the same setting in MQTT.fx to MQTT configuration 1289 1289 ... ... @@ -1293,190 +1293,185 @@ 1293 1293 1294 1294 [[image:image-20220709165402-20.png]] 1295 1295 1296 -{{info}} 1297 -**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701 1298 -{{/info}} 1299 - 1300 -{{code language="lua"}} 1301 1301 sprint = print 1302 1302 1303 ---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) 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) 1304 1304 1305 1305 local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg() 1306 1306 1307 ---publish to topics 1259 +~-~-publish to topics 1308 1308 1309 1309 local pub_RE_TOPIC = string.format('TEST') 1310 1310 1311 ---Subscribe topics 1263 +~-~-Subscribe topics 1312 1312 1313 1313 local Subscribe_RE_TOPIC1 = string.format('TEST') 1314 1314 1315 ---variable 1267 +~-~-variable 1316 1316 1317 1317 local last_time = 0 1318 1318 1319 ---Timing main function 1271 +~-~-Timing main function 1320 1320 1321 1321 function aws.main() 1322 1322 1323 - 1275 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start") 1324 1324 1325 - 1277 + if g_mq then 1326 1326 1327 - 1279 + if g_mq:isconnected() then 1328 1328 1329 - 1281 + send_Data() 1330 1330 1331 - 1283 + else 1332 1332 1333 - 1285 + if os.time() - last_time > 5 then 1334 1334 1335 - 1287 + last_time = os.time() 1336 1336 1337 - 1289 + mymqtt_connect() 1338 1338 1339 - end 1340 - 1341 1341 end 1342 1342 1343 - lse1293 + end 1344 1344 1345 - mymqtt_init()1295 + else 1346 1346 1347 - end1297 + mymqtt_init() 1348 1348 1349 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.mainend")1299 + end 1350 1350 1301 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end") 1302 + 1351 1351 end 1352 1352 1353 1353 1306 +~-~- Initialize MQTT 1354 1354 1355 --- Initialize MQTT 1356 - 1357 1357 function mymqtt_init() 1358 1358 1359 - 1310 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) 1360 1360 1361 - , 1) -- Create the object and declare it as a global variable, 1 means using the domain to connect1312 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable 1362 1362 1363 - 1314 + if g_mq then 1364 1364 1365 - 1316 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks 1366 1366 1367 - 1318 + sprint("mqtt init success") 1368 1368 1369 - 1320 + else 1370 1370 1371 - 1322 + sprint("mqtt init failed:", err) 1372 1372 1373 - 1324 + end 1374 1374 1375 1375 end 1376 1376 1377 --- Connect to MQTT server 1328 +~-~- Connect to MQTT server 1378 1378 1379 1379 function mymqtt_connect() 1380 1380 1381 - 1332 + sprint("mqtt connecting...") 1382 1382 1383 - 1334 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) 1384 1384 1385 - 1336 + if stat == nil then 1386 1386 1387 - 1338 + sprint("mqtt connect failed:", err) 1388 1388 1389 - 1340 + return 1390 1390 1391 - 1342 + else 1392 1392 1393 - 1344 + sprint("mqtt connected") 1394 1394 1395 - 1346 + end 1396 1396 1397 - Subscribe_RE_TOPIC1, 0)1348 + g_mq:subscribe(TEST, 0) 1398 1398 1399 1399 end 1400 1400 1401 --- Receive MQTT message callback function 1352 +~-~- Receive MQTT message callback function 1402 1402 1403 1403 function mymqtt_msg_callback(topic, msg) 1404 1404 1405 - 1356 + print("topic:",topic) 1406 1406 1407 - 1358 + print("revdata:",msg) 1408 1408 1409 - 1360 + local revData = json.decode(msg) 1410 1410 1411 - 1362 + print (revData) 1412 1412 1413 - 1364 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud 1414 1414 1415 - 1366 +if string.match(topic,Subscribe_RE_TOPIC1) then 1416 1416 1417 - 1368 + ~-~-if revData ~~= nil then 1418 1418 1419 - 1370 + for k,v in pairs (revData) do 1420 1420 1421 - 1372 + print("printing revdata after kv here") 1422 1422 1423 - 1374 + print (k,v) 1424 1424 1425 - 1376 + end 1426 1426 1427 - 1378 + print ("current state is",fanstate) 1428 1428 1429 - 1380 + ~-~-end 1430 1430 1431 - 1382 +end 1432 1432 1433 - 1384 +end 1434 1434 1435 1435 end 1436 1436 1437 1437 1389 +~-~-Get real-time data 1438 1438 1439 ---Get real-time data 1440 - 1441 1441 function getData() 1442 1442 1443 - 1393 + local jdata = {} 1444 1444 1445 - 1395 + local addr = bns_get_alldata() 1446 1446 1447 - 1397 + print(json.encode(addr)) 1448 1448 1449 - 1399 + for i,v in pairs(addr) do 1450 1450 1451 - 1401 + if v[2] == 1 then 1452 1452 1453 - 1403 + jdata[v[3]] = v[4] 1454 1454 1455 - 1405 + end 1456 1456 1457 - 1407 + end 1458 1458 1459 - 1409 + return jdata 1460 1460 1461 1461 end 1462 1462 1463 ---send data 1413 +~-~-send data 1464 1464 1465 1465 function send_Data() 1466 1466 1467 - local pub_data = 1468 - { 1469 - 123 1470 - } 1417 + local pub_data = 1471 1471 1419 + { 1420 + 1421 +123 1422 + 1423 +} 1424 + 1472 1472 sprint(json.encode(pub_data)) 1473 1473 1474 1474 print("..........",pub_RE_TOPIC) 1475 1475 1476 - 1429 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) 1477 1477 1478 1478 end 1479 -{{/code}} 1480 1480 1481 1481 Get message in AWS 1482 1482