Changes for page 2 Script
Last modified by Devin Chen on 2025/06/06 14:03
Summary
-
Page properties (1 modified, 0 added, 0 removed)
Details
- Page properties
-
- Content
-
... ... @@ -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 ... ... @@ -441,37 +441,6 @@ 441 441 end 442 442 {{/code}} 443 443 444 -== **1.9 High-Low Byte Switch** == 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 475 = **2 V-Box connect with third part server** = 476 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. ... ... @@ -490,9 +490,8 @@ 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}}468 +(% 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,25 +499,6 @@ 499 499 500 500 == **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={} ... ... @@ -559,13 +559,9 @@ 559 559 --initialize mqtt 560 560 function mqtt_init() 561 561 print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID)) 562 - if g_mq then 563 - mqtt.close(g_mq) --Close mqtt object 564 - end 565 565 g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable 566 566 if g_mq then 567 567 g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages 568 - g_mq:on("offline", mqtt_msg_offline) -- Register a callback for offline 569 569 print("mqtt init success") 570 570 else 571 571 print("mqtt init failed:", err) ... ... @@ -585,11 +585,6 @@ 585 585 g_mq:subscribe(SUBSCRIBE_TOPIC, 0) 586 586 end 587 587 588 ---Offline callback function 589 -function mqtt_msg_offline(cause) 590 - print("mqtt offline, cause:", cause) 591 -end 592 - 593 593 -- Received message callback function 594 594 function mqtt_msg_callback(topic, msg) 595 595 print("topic:", topic) ... ... @@ -628,11 +628,9 @@ 628 628 if g_mq:isconnected() then 629 629 send_data() 630 630 else 631 - --if exceed 5sec not connect, reconnect once632 - if os.time() - LAST_TIME > 5then577 + --if exceed 20 sec not connect, reconnect once 578 + if os.time() - LAST_TIME > 20 then 633 633 LAST_TIME = os.time() 634 - --reinitial the mqtt object 635 - mqtt_init() 636 636 --connect to mqtt or reconnect 637 637 mqtt_connect() 638 638 end ... ... @@ -1212,20 +1212,35 @@ 1212 1212 1213 1213 {{code language="java"}} 1214 1214 { 1159 + 1215 1215 "Version": "2012-10-17", 1161 + 1216 1216 "Statement": [ 1163 + 1217 1217 { 1165 + 1218 1218 "Effect": "Allow", 1167 + 1219 1219 "Action": [ 1169 + 1220 1220 "iot:Connect", 1171 + 1221 1221 "iot:Publish", 1173 + 1222 1222 "iot:Subscribe", 1175 + 1223 1223 "iot:Receive", 1177 + 1224 1224 "greengrass:Discover" 1179 + 1225 1225 ], 1181 + 1226 1226 "Resource": "*" 1183 + 1227 1227 } 1185 + 1228 1228 ] 1187 + 1229 1229 } 1230 1230 {{/code}} 1231 1231 ... ... @@ -1290,190 +1290,185 @@ 1290 1290 1291 1291 [[image:image-20220709165402-20.png]] 1292 1292 1293 -{{info}} 1294 -**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701 1295 -{{/info}} 1296 - 1297 -{{code language="lua"}} 1298 1298 sprint = print 1299 1299 1300 ---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) 1254 +~-~-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) 1301 1301 1302 1302 local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg() 1303 1303 1304 ---publish to topics 1258 +~-~-publish to topics 1305 1305 1306 1306 local pub_RE_TOPIC = string.format('TEST') 1307 1307 1308 ---Subscribe topics 1262 +~-~-Subscribe topics 1309 1309 1310 1310 local Subscribe_RE_TOPIC1 = string.format('TEST') 1311 1311 1312 ---variable 1266 +~-~-variable 1313 1313 1314 1314 local last_time = 0 1315 1315 1316 ---Timing main function 1270 +~-~-Timing main function 1317 1317 1318 1318 function aws.main() 1319 1319 1320 - 1274 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start") 1321 1321 1322 - 1276 + if g_mq then 1323 1323 1324 - 1278 + if g_mq:isconnected() then 1325 1325 1326 - 1280 + send_Data() 1327 1327 1328 - 1282 + else 1329 1329 1330 - 1284 + if os.time() - last_time > 5 then 1331 1331 1332 - 1286 + last_time = os.time() 1333 1333 1334 - 1288 + mymqtt_connect() 1335 1335 1336 - end 1337 - 1338 1338 end 1339 1339 1340 - lse1292 + end 1341 1341 1342 - mymqtt_init()1294 + else 1343 1343 1344 - end1296 + mymqtt_init() 1345 1345 1346 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.mainend")1298 + end 1347 1347 1300 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end") 1301 + 1348 1348 end 1349 1349 1350 1350 1305 +~-~- Initialize MQTT 1351 1351 1352 --- Initialize MQTT 1353 - 1354 1354 function mymqtt_init() 1355 1355 1356 - 1309 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) 1357 1357 1358 - , 1) -- Create the object and declare it as a global variable, 1 means using the domain to connect1311 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable 1359 1359 1360 - 1313 + if g_mq then 1361 1361 1362 - 1315 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks 1363 1363 1364 - 1317 + sprint("mqtt init success") 1365 1365 1366 - 1319 + else 1367 1367 1368 - 1321 + sprint("mqtt init failed:", err) 1369 1369 1370 - 1323 + end 1371 1371 1372 1372 end 1373 1373 1374 --- Connect to MQTT server 1327 +~-~- Connect to MQTT server 1375 1375 1376 1376 function mymqtt_connect() 1377 1377 1378 - 1331 + sprint("mqtt connecting...") 1379 1379 1380 - 1333 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) 1381 1381 1382 - 1335 + if stat == nil then 1383 1383 1384 - 1337 + sprint("mqtt connect failed:", err) 1385 1385 1386 - 1339 + return 1387 1387 1388 - 1341 + else 1389 1389 1390 - 1343 + sprint("mqtt connected") 1391 1391 1392 - 1345 + end 1393 1393 1394 - Subscribe_RE_TOPIC1, 0)1347 + g_mq:subscribe(TEST, 0) 1395 1395 1396 1396 end 1397 1397 1398 --- Receive MQTT message callback function 1351 +~-~- Receive MQTT message callback function 1399 1399 1400 1400 function mymqtt_msg_callback(topic, msg) 1401 1401 1402 - 1355 + print("topic:",topic) 1403 1403 1404 - 1357 + print("revdata:",msg) 1405 1405 1406 - 1359 + local revData = json.decode(msg) 1407 1407 1408 - 1361 + print (revData) 1409 1409 1410 - 1363 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud 1411 1411 1412 - 1365 +if string.match(topic,Subscribe_RE_TOPIC1) then 1413 1413 1414 - 1367 + ~-~-if revData ~~= nil then 1415 1415 1416 - 1369 + for k,v in pairs (revData) do 1417 1417 1418 - 1371 + print("printing revdata after kv here") 1419 1419 1420 - 1373 + print (k,v) 1421 1421 1422 - 1375 + end 1423 1423 1424 - 1377 + print ("current state is",fanstate) 1425 1425 1426 - 1379 + ~-~-end 1427 1427 1428 - 1381 +end 1429 1429 1430 - 1383 +end 1431 1431 1432 1432 end 1433 1433 1434 1434 1388 +~-~-Get real-time data 1435 1435 1436 ---Get real-time data 1437 - 1438 1438 function getData() 1439 1439 1440 - 1392 + local jdata = {} 1441 1441 1442 - 1394 + local addr = bns_get_alldata() 1443 1443 1444 - 1396 + print(json.encode(addr)) 1445 1445 1446 - 1398 + for i,v in pairs(addr) do 1447 1447 1448 - 1400 + if v[2] == 1 then 1449 1449 1450 - 1402 + jdata[v[3]] = v[4] 1451 1451 1452 - 1404 + end 1453 1453 1454 - 1406 + end 1455 1455 1456 - 1408 + return jdata 1457 1457 1458 1458 end 1459 1459 1460 ---send data 1412 +~-~-send data 1461 1461 1462 1462 function send_Data() 1463 1463 1464 - local pub_data = 1465 - { 1466 - 123 1467 - } 1416 + local pub_data = 1468 1468 1418 + { 1419 + 1420 +123 1421 + 1422 +} 1423 + 1469 1469 sprint(json.encode(pub_data)) 1470 1470 1471 1471 print("..........",pub_RE_TOPIC) 1472 1472 1473 - 1428 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) 1474 1474 1475 1475 end 1476 -{{/code}} 1477 1477 1478 1478 Get message in AWS 1479 1479