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
-
... ... @@ -447,20 +447,6 @@ 447 447 end 448 448 {{/code}} 449 449 450 -== **1.9 High-Low Byte Switch** == 451 - 452 - 453 -{{code language="lua"}} 454 -function highLowByteSwitch(floatNumber) 455 - addr_setfloat("@W_0#HDW23036",floatNumber,0,2) 456 - local newFloat = addr_getfloat("@W_0#HDW23036") 457 - local formattedFloat = string.format("%.2f",newFloat) 458 - print("The formatted float value is the : "..formattedFloat) 459 - return formattedFloat 460 -end 461 -{{/code}} 462 - 463 - 464 464 = **2 V-Box connect with third part server** = 465 465 466 466 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. ... ... @@ -479,9 +479,8 @@ 479 479 480 480 (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate 481 481 482 - {{info}}468 +(% class="wikigeneratedid" %) 483 483 **✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool. 484 -{{/info}} 485 485 486 486 (% class="wikigeneratedid" %) 487 487 Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]** ... ... @@ -488,25 +488,6 @@ 488 488 489 489 == **2.1 V-Box connect with test server(General Example)** == 490 490 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 - 510 510 {{code language="lua"}} 511 511 --MQTT configuration table 512 512 local MQTT_CFG={} ... ... @@ -548,13 +548,9 @@ 548 548 --initialize mqtt 549 549 function mqtt_init() 550 550 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 554 554 g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable 555 555 if g_mq then 556 556 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 558 558 print("mqtt init success") 559 559 else 560 560 print("mqtt init failed:", err) ... ... @@ -574,11 +574,6 @@ 574 574 g_mq:subscribe(SUBSCRIBE_TOPIC, 0) 575 575 end 576 576 577 ---Offline callback function 578 -function mqtt_msg_offline(cause) 579 - print("mqtt offline, cause:", cause) 580 -end 581 - 582 582 -- Received message callback function 583 583 function mqtt_msg_callback(topic, msg) 584 584 print("topic:", topic) ... ... @@ -617,11 +617,9 @@ 617 617 if g_mq:isconnected() then 618 618 send_data() 619 619 else 620 - --if exceed 5sec not connect, reconnect once621 - if os.time() - LAST_TIME > 5then577 + --if exceed 20 sec not connect, reconnect once 578 + if os.time() - LAST_TIME > 20 then 622 622 LAST_TIME = os.time() 623 - --reinitial the mqtt object 624 - mqtt_init() 625 625 --connect to mqtt or reconnect 626 626 mqtt_connect() 627 627 end ... ... @@ -1201,20 +1201,35 @@ 1201 1201 1202 1202 {{code language="java"}} 1203 1203 { 1159 + 1204 1204 "Version": "2012-10-17", 1161 + 1205 1205 "Statement": [ 1163 + 1206 1206 { 1165 + 1207 1207 "Effect": "Allow", 1167 + 1208 1208 "Action": [ 1169 + 1209 1209 "iot:Connect", 1171 + 1210 1210 "iot:Publish", 1173 + 1211 1211 "iot:Subscribe", 1175 + 1212 1212 "iot:Receive", 1177 + 1213 1213 "greengrass:Discover" 1179 + 1214 1214 ], 1181 + 1215 1215 "Resource": "*" 1183 + 1216 1216 } 1185 + 1217 1217 ] 1187 + 1218 1218 } 1219 1219 {{/code}} 1220 1220 ... ... @@ -1279,190 +1279,185 @@ 1279 1279 1280 1280 [[image:image-20220709165402-20.png]] 1281 1281 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"}} 1287 1287 sprint = print 1288 1288 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) 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) 1290 1290 1291 1291 local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg() 1292 1292 1293 ---publish to topics 1258 +~-~-publish to topics 1294 1294 1295 1295 local pub_RE_TOPIC = string.format('TEST') 1296 1296 1297 ---Subscribe topics 1262 +~-~-Subscribe topics 1298 1298 1299 1299 local Subscribe_RE_TOPIC1 = string.format('TEST') 1300 1300 1301 ---variable 1266 +~-~-variable 1302 1302 1303 1303 local last_time = 0 1304 1304 1305 ---Timing main function 1270 +~-~-Timing main function 1306 1306 1307 1307 function aws.main() 1308 1308 1309 - 1274 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start") 1310 1310 1311 - 1276 + if g_mq then 1312 1312 1313 - 1278 + if g_mq:isconnected() then 1314 1314 1315 - 1280 + send_Data() 1316 1316 1317 - 1282 + else 1318 1318 1319 - 1284 + if os.time() - last_time > 5 then 1320 1320 1321 - 1286 + last_time = os.time() 1322 1322 1323 - 1288 + mymqtt_connect() 1324 1324 1325 - end 1326 - 1327 1327 end 1328 1328 1329 - lse1292 + end 1330 1330 1331 - mymqtt_init()1294 + else 1332 1332 1333 - end1296 + mymqtt_init() 1334 1334 1335 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.mainend")1298 + end 1336 1336 1300 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end") 1301 + 1337 1337 end 1338 1338 1339 1339 1305 +~-~- Initialize MQTT 1340 1340 1341 --- Initialize MQTT 1342 - 1343 1343 function mymqtt_init() 1344 1344 1345 - 1309 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) 1346 1346 1347 - , 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 1348 1348 1349 - 1313 + if g_mq then 1350 1350 1351 - 1315 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks 1352 1352 1353 - 1317 + sprint("mqtt init success") 1354 1354 1355 - 1319 + else 1356 1356 1357 - 1321 + sprint("mqtt init failed:", err) 1358 1358 1359 - 1323 + end 1360 1360 1361 1361 end 1362 1362 1363 --- Connect to MQTT server 1327 +~-~- Connect to MQTT server 1364 1364 1365 1365 function mymqtt_connect() 1366 1366 1367 - 1331 + sprint("mqtt connecting...") 1368 1368 1369 - 1333 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) 1370 1370 1371 - 1335 + if stat == nil then 1372 1372 1373 - 1337 + sprint("mqtt connect failed:", err) 1374 1374 1375 - 1339 + return 1376 1376 1377 - 1341 + else 1378 1378 1379 - 1343 + sprint("mqtt connected") 1380 1380 1381 - 1345 + end 1382 1382 1383 - Subscribe_RE_TOPIC1, 0)1347 + g_mq:subscribe(TEST, 0) 1384 1384 1385 1385 end 1386 1386 1387 --- Receive MQTT message callback function 1351 +~-~- Receive MQTT message callback function 1388 1388 1389 1389 function mymqtt_msg_callback(topic, msg) 1390 1390 1391 - 1355 + print("topic:",topic) 1392 1392 1393 - 1357 + print("revdata:",msg) 1394 1394 1395 - 1359 + local revData = json.decode(msg) 1396 1396 1397 - 1361 + print (revData) 1398 1398 1399 - 1363 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud 1400 1400 1401 - 1365 +if string.match(topic,Subscribe_RE_TOPIC1) then 1402 1402 1403 - 1367 + ~-~-if revData ~~= nil then 1404 1404 1405 - 1369 + for k,v in pairs (revData) do 1406 1406 1407 - 1371 + print("printing revdata after kv here") 1408 1408 1409 - 1373 + print (k,v) 1410 1410 1411 - 1375 + end 1412 1412 1413 - 1377 + print ("current state is",fanstate) 1414 1414 1415 - 1379 + ~-~-end 1416 1416 1417 - 1381 +end 1418 1418 1419 - 1383 +end 1420 1420 1421 1421 end 1422 1422 1423 1423 1388 +~-~-Get real-time data 1424 1424 1425 ---Get real-time data 1426 - 1427 1427 function getData() 1428 1428 1429 - 1392 + local jdata = {} 1430 1430 1431 - 1394 + local addr = bns_get_alldata() 1432 1432 1433 - 1396 + print(json.encode(addr)) 1434 1434 1435 - 1398 + for i,v in pairs(addr) do 1436 1436 1437 - 1400 + if v[2] == 1 then 1438 1438 1439 - 1402 + jdata[v[3]] = v[4] 1440 1440 1441 - 1404 + end 1442 1442 1443 - 1406 + end 1444 1444 1445 - 1408 + return jdata 1446 1446 1447 1447 end 1448 1448 1449 ---send data 1412 +~-~-send data 1450 1450 1451 1451 function send_Data() 1452 1452 1453 - local pub_data = 1454 - { 1455 - 123 1456 - } 1416 + local pub_data = 1457 1457 1418 + { 1419 + 1420 +123 1421 + 1422 +} 1423 + 1458 1458 sprint(json.encode(pub_data)) 1459 1459 1460 1460 print("..........",pub_RE_TOPIC) 1461 1461 1462 - 1428 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) 1463 1463 1464 1464 end 1465 -{{/code}} 1466 1466 1467 1467 Get message in AWS 1468 1468