Changes for page 2 Script

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

From version 32.1
edited by Hunter
on 2022/11/22 14:09
Change comment: There is no comment for this version
To version 59.1
edited by Theodore Xu
on 2023/08/24 17:16
Change comment: There is no comment for this version

Summary

Details

Page properties
Author
... ... @@ -1,1 +1,1 @@
1 -XWiki.Hunter
1 +XWiki.AiXia
Content
... ... @@ -27,25 +27,19 @@
27 27  
28 28  == **1.4 Short message** ==
29 29  
30 -When the alarm condition is reached: temp1 > 5 & temp2 >10 & temp3 < 20(lasts more than 5 seconds) , then send an "alarm trigger" sms.
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.
31 31  
32 -When the alarm condition is released,then send an "alarm release" sms.
32 +When the alarm condition is released,then send an  "alarm release" sms. Script is as below:
33 33  
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 -(((
34 +{{code language="lua"}}
41 41  function sms.main()
42 -~-~-~-~-~-~-send condition~-~-~-~-~-~-
36 +------send condition------
43 43  local temp1 = addr_getword("@Temperature1")
44 44  local temp2 = addr_getword("@Temperature2")
45 45  local temp3 = addr_getword("@Temperature3")
46 46  local timer = addr_getword("@Timer")
47 47  local tag = addr_getbit("@Tag")
48 -~-~-~-~-~-~-lasting time~-~-~-~-~-~-
42 +------lasting time------
49 49  if temp1 > 5 and temp2 > 10 and temp3 < 20 then
50 50   timer = timer + 1
51 51   addr_setword("@Timer",timer)
... ... @@ -53,7 +53,7 @@
53 53   timer = 0
54 54   addr_setword("@Timer",timer)
55 55  end
56 -~-~-~-~-~-~-send sms & output Y0~-~-~-~-~-~-
50 +------send sms & output Y0------
57 57  if timer > 5 then
58 58   if tag == 0 then
59 59   send_sms_ira("19859254700","alarm trigger")
... ... @@ -64,7 +64,7 @@
64 64  addr_setbit("@Tag",0)
65 65  end
66 66  end
67 -)))
61 +{{/code}}
68 68  
69 69  == **1.5 Telegram notification** ==
70 70  
... ... @@ -145,7 +145,7 @@
145 145  
146 146  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.
147 147  
148 -{{code}}
142 +{{code language="lua"}}
149 149  local tempBit = 0
150 150  local tempWord = 0
151 151  
... ... @@ -447,8 +447,39 @@
447 447  end
448 448  {{/code}}
449 449  
450 -= **2 V-Box connect with third part server** =
444 +== **1.9 High-Low Byte Switch** ==
451 451  
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 +
452 452  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.
453 453  
454 454  (% class="mark" %)1.Europe server:eu.v-box.net
... ... @@ -465,17 +465,38 @@
465 465  
466 466  (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate
467 467  
468 -(% class="wikigeneratedid" %)
493 +{{info}}
469 469  **✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool.
495 +{{/info}}
470 470  
471 471  (% class="wikigeneratedid" %)
472 472  Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]**
473 473  
474 -== **2.1 V-Box connect with test server(General Example)** ==
500 +== **2.1 Test server(General Example)** ==
475 475  
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 +
476 476  {{code language="lua"}}
477 477  --MQTT configuration table
478 478  local MQTT_CFG={}
524 +--if there is no need the username and password, please put them as ""
479 479  MQTT_CFG.username = "weconsupport"
480 480  MQTT_CFG.password = "123456"
481 481  MQTT_CFG.netway = 0
... ... @@ -514,9 +514,13 @@
514 514  --initialize mqtt
515 515  function mqtt_init()
516 516   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
517 517   g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable
518 518   if g_mq then
519 519   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
520 520   print("mqtt init success")
521 521   else
522 522   print("mqtt init failed:", err)
... ... @@ -536,6 +536,11 @@
536 536   g_mq:subscribe(SUBSCRIBE_TOPIC, 0)
537 537  end
538 538  
589 +--Offline callback function
590 +function mqtt_msg_offline(cause)
591 + print("mqtt offline, cause:", cause)
592 +end
593 +
539 539  -- Received message callback function
540 540  function mqtt_msg_callback(topic, msg)
541 541   print("topic:", topic)
... ... @@ -574,9 +574,11 @@
574 574   if g_mq:isconnected() then
575 575   send_data()
576 576   else
577 - --if exceed 20 sec not connect, reconnect once
578 - if os.time() - LAST_TIME > 20 then
632 + --if exceed 5 sec not connect, reconnect once
633 + if os.time() - LAST_TIME > 5 then
579 579   LAST_TIME = os.time()
635 + --reinitial the mqtt object
636 + mqtt_init()
580 580   --connect to mqtt or reconnect
581 581   mqtt_connect()
582 582   end
... ... @@ -589,7 +589,7 @@
589 589  end
590 590  {{/code}}
591 591  
592 -== **2.2 V-Box connect with customer server:grouprobotinfo.com** ==
649 +== **2.2 Customer server:grouprobotinfo.com** ==
593 593  
594 594  This demo does not use SSL certification. Script is as below
595 595  
... ... @@ -730,7 +730,7 @@
730 730  end
731 731  {{/code}}
732 732  
733 -== **2.3 V-Box connect with Azure platform** ==
790 +== **2.3 Azure platform** ==
734 734  
735 735  In this demo,V-Box connects with Azure by SSL certification.
736 736  
... ... @@ -861,8 +861,12 @@
861 861  end
862 862  )))
863 863  
864 -== **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)** ==
921 +== **2.4 Huawei platform** ==
865 865  
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 +
866 866  1.Register a account: [[https:~~/~~/www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ>>https://www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ]]
867 867  
868 868  2.log in the Huawei IOTDA
... ... @@ -1010,10 +1010,8 @@
1010 1010  (% style="text-align:center" %)
1011 1011  [[image:1624441186851-536.png||height="434" width="700" class="img-thumbnail"]]
1012 1012  
1013 -== **2.5 V-Box connect with Huawei platform** ==
1074 +=== Huawei by SSL certification. ===
1014 1014  
1015 -In this demo,V-Box connects with Huawei by SSL certification.
1016 -
1017 1017  1.Create a project access for Huawei IOT
1018 1018  
1019 1019  2.configure MQTT configuration
... ... @@ -1131,7 +1131,7 @@
1131 1131  (% style="text-align:center" %)
1132 1132  [[image:1624506666650-161.png||height="547" width="1000" class="img-thumbnail"]]
1133 1133  
1134 -== **2.6 V-Box connect with AWS platform** ==
1193 +== **2.6 AWS platform** ==
1135 1135  
1136 1136  === **Log in AWS** ===
1137 1137  
... ... @@ -1156,35 +1156,20 @@
1156 1156  
1157 1157  {{code language="java"}}
1158 1158  {
1159 -
1160 1160    "Version": "2012-10-17",
1161 -
1162 1162    "Statement": [
1163 -
1164 1164      {
1165 -
1166 1166        "Effect": "Allow",
1167 -
1168 1168        "Action": [
1169 -
1170 1170          "iot:Connect",
1171 -
1172 1172          "iot:Publish",
1173 -
1174 1174          "iot:Subscribe",
1175 -
1176 1176          "iot:Receive",
1177 -
1178 1178          "greengrass:Discover"
1179 -
1180 1180        ],
1181 -
1182 1182        "Resource": "*"
1183 -
1184 1184      }
1185 -
1186 1186    ]
1187 -
1188 1188  }
1189 1189  {{/code}}
1190 1190  
... ... @@ -1211,7 +1211,7 @@
1211 1211  [[image:image-20220709165402-11.png]]
1212 1212  
1213 1213  
1214 -=== **Test with MQTT.fx tool** ===
1258 +=== **MQTT.fx tool** ===
1215 1215  
1216 1216  Click “View Setting” to get the “Broker Adress”
1217 1217  
... ... @@ -1239,7 +1239,7 @@
1239 1239  
1240 1240  [[image:image-20220709165402-18.png]]
1241 1241  
1242 -=== **Configurate in CloudTool** ===
1286 +=== **CloudTool** ===
1243 1243  
1244 1244  Copy the same setting in MQTT.fx to MQTT configuration
1245 1245  
... ... @@ -1249,185 +1249,190 @@
1249 1249  
1250 1250  [[image:image-20220709165402-20.png]]
1251 1251  
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"}}
1252 1252  sprint = print
1253 1253  
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)
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 1255  
1256 1256  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
1257 1257  
1258 -~-~-publish to topics
1307 +--publish to topics
1259 1259  
1260 1260  local pub_RE_TOPIC = string.format('TEST')
1261 1261  
1262 -~-~-Subscribe topics
1311 +--Subscribe topics
1263 1263  
1264 1264  local Subscribe_RE_TOPIC1 = string.format('TEST')
1265 1265  
1266 -~-~-variable
1315 +--variable
1267 1267  
1268 1268  local last_time = 0
1269 1269  
1270 -~-~-Timing main function
1319 +--Timing main function
1271 1271  
1272 1272  function aws.main()
1273 1273  
1274 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1323 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1275 1275  
1276 - if g_mq then
1325 + if g_mq then
1277 1277  
1278 - if g_mq:isconnected() then
1327 + if g_mq:isconnected() then
1279 1279  
1280 - send_Data()
1329 + send_Data()
1281 1281  
1282 - else
1331 + else
1283 1283  
1284 - if os.time() - last_time > 5 then
1333 + if os.time() - last_time > 5 then
1285 1285  
1286 - last_time = os.time()
1335 + last_time = os.time()
1287 1287  
1288 - mymqtt_connect()
1337 + mymqtt_connect()
1289 1289  
1339 + end
1340 +
1290 1290   end
1291 1291  
1292 - end
1343 + else
1293 1293  
1294 - else
1345 + mymqtt_init()
1295 1295  
1296 - mymqtt_init()
1347 + end
1297 1297  
1298 - end
1349 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1299 1299  
1300 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1301 -
1302 1302  end
1303 1303  
1304 1304  
1305 -~-~- Initialize MQTT
1306 1306  
1355 +-- Initialize MQTT
1356 +
1307 1307  function mymqtt_init()
1308 1308  
1309 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1359 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1310 1310  
1311 - g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
1361 + 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
1312 1312  
1313 - if g_mq then
1363 + if g_mq then
1314 1314  
1315 - g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1365 + g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1316 1316  
1317 - sprint("mqtt init success")
1367 + sprint("mqtt init success")
1318 1318  
1319 - else
1369 + else
1320 1320  
1321 - sprint("mqtt init failed:", err)
1371 + sprint("mqtt init failed:", err)
1322 1322  
1323 - end
1373 + end
1324 1324  
1325 1325  end
1326 1326  
1327 -~-~- Connect to MQTT server
1377 +-- Connect to MQTT server
1328 1328  
1329 1329  function mymqtt_connect()
1330 1330  
1331 - sprint("mqtt connecting...")
1381 + sprint("mqtt connecting...")
1332 1332  
1333 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1383 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1334 1334  
1335 - if stat == nil then
1385 + if stat == nil then
1336 1336  
1337 - sprint("mqtt connect failed:", err)
1387 + sprint("mqtt connect failed:", err)
1338 1338  
1339 - return
1389 + return
1340 1340  
1341 - else
1391 + else
1342 1342  
1343 - sprint("mqtt connected")
1393 + sprint("mqtt connected")
1344 1344  
1345 - end
1395 + end
1346 1346  
1347 - g_mq:subscribe(TEST, 0)
1397 + g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
1348 1348  
1349 1349  end
1350 1350  
1351 -~-~- Receive MQTT message callback function
1401 +-- Receive MQTT message callback function
1352 1352  
1353 1353  function mymqtt_msg_callback(topic, msg)
1354 1354  
1355 - print("topic:",topic)
1405 + print("topic:",topic)
1356 1356  
1357 - print("revdata:",msg)
1407 + print("revdata:",msg)
1358 1358  
1359 - local revData = json.decode(msg)
1409 + local revData = json.decode(msg)
1360 1360  
1361 - print (revData)
1411 + print (revData)
1362 1362  
1363 - if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1413 + if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1364 1364  
1365 -if string.match(topic,Subscribe_RE_TOPIC1) then
1415 + if string.match(topic,Subscribe_RE_TOPIC1) then
1366 1366  
1367 - ~-~-if revData ~~= nil then
1417 + --if revData ~= nil then
1368 1368  
1369 - for k,v in pairs (revData) do
1419 + for k,v in pairs (revData) do
1370 1370  
1371 - print("printing revdata after kv here")
1421 + print("printing revdata after kv here")
1372 1372  
1373 - print (k,v)
1423 + print (k,v)
1374 1374  
1375 - end
1425 + end
1376 1376  
1377 - print ("current state is",fanstate)
1427 + print ("current state is",fanstate)
1378 1378  
1379 - ~-~-end
1429 + --end
1380 1380  
1381 -end
1431 + end
1382 1382  
1383 -end
1433 + end
1384 1384  
1385 1385  end
1386 1386  
1387 1387  
1388 -~-~-Get real-time data
1389 1389  
1439 +--Get real-time data
1440 +
1390 1390  function getData()
1391 1391  
1392 - local jdata = {}
1443 + local jdata = {}
1393 1393  
1394 - local addr = bns_get_alldata()
1445 + local addr = bns_get_alldata()
1395 1395  
1396 - print(json.encode(addr))
1447 + print(json.encode(addr))
1397 1397  
1398 - for i,v in pairs(addr) do
1449 + for i,v in pairs(addr) do
1399 1399  
1400 - if v[2] == 1 then
1451 + if v[2] == 1 then
1401 1401  
1402 - jdata[v[3]] = v[4]
1453 + jdata[v[3]] = v[4]
1403 1403  
1404 - end
1455 + end
1405 1405  
1406 - end
1457 + end
1407 1407  
1408 - return jdata
1459 + return jdata
1409 1409  
1410 1410  end
1411 1411  
1412 -~-~-send data
1463 +--send data
1413 1413  
1414 1414  function send_Data()
1415 1415  
1416 - local pub_data =
1467 + local pub_data =
1468 + {
1469 + 123
1470 + }
1417 1417  
1418 - {
1419 -
1420 -123
1421 -
1422 -}
1423 -
1424 1424  sprint(json.encode(pub_data))
1425 1425  
1426 1426  print("..........",pub_RE_TOPIC)
1427 1427  
1428 - return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1476 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1429 1429  
1430 1430  end
1479 +{{/code}}
1431 1431  
1432 1432  Get message in AWS
1433 1433