Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03

From version 55.1
edited by Hunter
on 2023/08/03 15:02
Change comment: Replaced user [xwiki:XWiki.hunter123] in fields [author, contentAuthor] to user [xwiki:XWiki.Hunter]
To version 32.1
edited by Hunter
on 2022/11/22 14:09
Change comment: There is no comment for this version

Summary

Details

Page properties
Content
... ... @@ -27,19 +27,25 @@
27 27  
28 28  == **1.4 Short message** ==
29 29  
30 -The following demo shows that when the alarm 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  "alarm release" sms. 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,29 +499,9 @@
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={}
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 5 sec not connect, reconnect once
633 - if os.time() - LAST_TIME > 5 then
577 + --if exceed 20 sec not connect, reconnect once
578 + 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
... ... @@ -1213,20 +1213,35 @@
1213 1213  
1214 1214  {{code language="java"}}
1215 1215  {
1159 +
1216 1216    "Version": "2012-10-17",
1161 +
1217 1217    "Statement": [
1163 +
1218 1218      {
1165 +
1219 1219        "Effect": "Allow",
1167 +
1220 1220        "Action": [
1169 +
1221 1221          "iot:Connect",
1171 +
1222 1222          "iot:Publish",
1173 +
1223 1223          "iot:Subscribe",
1175 +
1224 1224          "iot:Receive",
1177 +
1225 1225          "greengrass:Discover"
1179 +
1226 1226        ],
1181 +
1227 1227        "Resource": "*"
1183 +
1228 1228      }
1185 +
1229 1229    ]
1187 +
1230 1230  }
1231 1231  {{/code}}
1232 1232  
... ... @@ -1291,190 +1291,185 @@
1291 1291  
1292 1292  [[image:image-20220709165402-20.png]]
1293 1293  
1294 -{{info}}
1295 -**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701
1296 -{{/info}}
1297 -
1298 -{{code language="lua"}}
1299 1299  sprint = print
1300 1300  
1301 ---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)
1302 1302  
1303 1303  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
1304 1304  
1305 ---publish to topics
1258 +~-~-publish to topics
1306 1306  
1307 1307  local pub_RE_TOPIC = string.format('TEST')
1308 1308  
1309 ---Subscribe topics
1262 +~-~-Subscribe topics
1310 1310  
1311 1311  local Subscribe_RE_TOPIC1 = string.format('TEST')
1312 1312  
1313 ---variable
1266 +~-~-variable
1314 1314  
1315 1315  local last_time = 0
1316 1316  
1317 ---Timing main function
1270 +~-~-Timing main function
1318 1318  
1319 1319  function aws.main()
1320 1320  
1321 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1274 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1322 1322  
1323 - if g_mq then
1276 + if g_mq then
1324 1324  
1325 - if g_mq:isconnected() then
1278 + if g_mq:isconnected() then
1326 1326  
1327 - send_Data()
1280 + send_Data()
1328 1328  
1329 - else
1282 + else
1330 1330  
1331 - if os.time() - last_time > 5 then
1284 + if os.time() - last_time > 5 then
1332 1332  
1333 - last_time = os.time()
1286 + last_time = os.time()
1334 1334  
1335 - mymqtt_connect()
1288 + mymqtt_connect()
1336 1336  
1337 - end
1338 -
1339 1339   end
1340 1340  
1341 - else
1292 + end
1342 1342  
1343 - mymqtt_init()
1294 + else
1344 1344  
1345 - end
1296 + mymqtt_init()
1346 1346  
1347 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1298 + end
1348 1348  
1300 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1301 +
1349 1349  end
1350 1350  
1351 1351  
1305 +~-~- Initialize MQTT
1352 1352  
1353 --- Initialize MQTT
1354 -
1355 1355  function mymqtt_init()
1356 1356  
1357 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1309 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1358 1358  
1359 - 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
1311 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
1360 1360  
1361 - if g_mq then
1313 + if g_mq then
1362 1362  
1363 - g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1315 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1364 1364  
1365 - sprint("mqtt init success")
1317 + sprint("mqtt init success")
1366 1366  
1367 - else
1319 + else
1368 1368  
1369 - sprint("mqtt init failed:", err)
1321 + sprint("mqtt init failed:", err)
1370 1370  
1371 - end
1323 + end
1372 1372  
1373 1373  end
1374 1374  
1375 --- Connect to MQTT server
1327 +~-~- Connect to MQTT server
1376 1376  
1377 1377  function mymqtt_connect()
1378 1378  
1379 - sprint("mqtt connecting...")
1331 + sprint("mqtt connecting...")
1380 1380  
1381 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1333 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1382 1382  
1383 - if stat == nil then
1335 + if stat == nil then
1384 1384  
1385 - sprint("mqtt connect failed:", err)
1337 + sprint("mqtt connect failed:", err)
1386 1386  
1387 - return
1339 + return
1388 1388  
1389 - else
1341 + else
1390 1390  
1391 - sprint("mqtt connected")
1343 + sprint("mqtt connected")
1392 1392  
1393 - end
1345 + end
1394 1394  
1395 - g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
1347 + g_mq:subscribe(TEST, 0)
1396 1396  
1397 1397  end
1398 1398  
1399 --- Receive MQTT message callback function
1351 +~-~- Receive MQTT message callback function
1400 1400  
1401 1401  function mymqtt_msg_callback(topic, msg)
1402 1402  
1403 - print("topic:",topic)
1355 + print("topic:",topic)
1404 1404  
1405 - print("revdata:",msg)
1357 + print("revdata:",msg)
1406 1406  
1407 - local revData = json.decode(msg)
1359 + local revData = json.decode(msg)
1408 1408  
1409 - print (revData)
1361 + print (revData)
1410 1410  
1411 - if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1363 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1412 1412  
1413 - if string.match(topic,Subscribe_RE_TOPIC1) then
1365 +if string.match(topic,Subscribe_RE_TOPIC1) then
1414 1414  
1415 - --if revData ~= nil then
1367 + ~-~-if revData ~~= nil then
1416 1416  
1417 - for k,v in pairs (revData) do
1369 + for k,v in pairs (revData) do
1418 1418  
1419 - print("printing revdata after kv here")
1371 + print("printing revdata after kv here")
1420 1420  
1421 - print (k,v)
1373 + print (k,v)
1422 1422  
1423 - end
1375 + end
1424 1424  
1425 - print ("current state is",fanstate)
1377 + print ("current state is",fanstate)
1426 1426  
1427 - --end
1379 + ~-~-end
1428 1428  
1429 - end
1381 +end
1430 1430  
1431 - end
1383 +end
1432 1432  
1433 1433  end
1434 1434  
1435 1435  
1388 +~-~-Get real-time data
1436 1436  
1437 ---Get real-time data
1438 -
1439 1439  function getData()
1440 1440  
1441 - local jdata = {}
1392 + local jdata = {}
1442 1442  
1443 - local addr = bns_get_alldata()
1394 + local addr = bns_get_alldata()
1444 1444  
1445 - print(json.encode(addr))
1396 + print(json.encode(addr))
1446 1446  
1447 - for i,v in pairs(addr) do
1398 + for i,v in pairs(addr) do
1448 1448  
1449 - if v[2] == 1 then
1400 + if v[2] == 1 then
1450 1450  
1451 - jdata[v[3]] = v[4]
1402 + jdata[v[3]] = v[4]
1452 1452  
1453 - end
1404 + end
1454 1454  
1455 - end
1406 + end
1456 1456  
1457 - return jdata
1408 + return jdata
1458 1458  
1459 1459  end
1460 1460  
1461 ---send data
1412 +~-~-send data
1462 1462  
1463 1463  function send_Data()
1464 1464  
1465 - local pub_data =
1466 - {
1467 - 123
1468 - }
1416 + local pub_data =
1469 1469  
1418 + {
1419 +
1420 +123
1421 +
1422 +}
1423 +
1470 1470  sprint(json.encode(pub_data))
1471 1471  
1472 1472  print("..........",pub_RE_TOPIC)
1473 1473  
1474 - return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1428 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1475 1475  
1476 1476  end
1477 -{{/code}}
1478 1478  
1479 1479  Get message in AWS
1480 1480