Skip to Content

Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03
From version 27.1
edited by Hunter
on 2022/10/25 09:39
Change comment: There is no comment for this version
To version 60.1
edited by Theodore Xu
on 2023/08/24 17:17
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
... ... @@ -1,9 +1,9 @@
1 1  = **1 General Script Demo** =
2 2  
3 -== **1.1 Address Operation:Write/Read data from address A to B** ==
3 +== **1.1 Address Operation** ==
4 4  
5 5  (((
6 -For example:transfer D2 to D0
6 +Write/Read data from address A to B**. **For example:transfer D2 to D0
7 7  )))
8 8  
9 9  (% style="text-align:center" %)
... ... @@ -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  
... ... @@ -349,8 +349,137 @@
349 349  end
350 350  {{/code}}
351 351  
352 -= **2 V-Box connect with third part server** =
346 +== **1.8 How to parse value from HTTP response body** ==
353 353  
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":
349 +
350 +(% style="text-align:center" %)
351 +[[image:InputHTTPparameter.png]]
352 +
353 +Then the response body would be like as following:
354 +
355 +{{code language="json"}}
356 +{
357 + "location": {
358 + "name": "Madrid",
359 + "region": "Madrid",
360 + "country": "Spain",
361 + "lat": 40.4,
362 + "lon": -3.68,
363 + "tz_id": "Europe/Madrid",
364 + "localtime_epoch": 1669022636,
365 + "localtime": "2022-11-21 10:23"
366 + },
367 + "current": {
368 + "last_updated_epoch": 1669022100,
369 + "last_updated": "2022-11-21 10:15",
370 + "temp_c": 13.0,
371 + "temp_f": 55.4,
372 + "is_day": 1,
373 + "condition": {
374 + "text": "Partly cloudy",
375 + "icon": "//cdn.weatherapi.com/weather/64x64/day/116.png",
376 + "code": 1003
377 + },
378 + "wind_mph": 11.9,
379 + "wind_kph": 19.1,
380 + "wind_degree": 210,
381 + "wind_dir": "SSW",
382 + "pressure_mb": 1015.0,
383 + "pressure_in": 29.97,
384 + "precip_mm": 0.0,
385 + "precip_in": 0.0,
386 + "humidity": 88,
387 + "cloud": 75,
388 + "feelslike_c": 10.8,
389 + "feelslike_f": 51.4,
390 + "vis_km": 10.0,
391 + "vis_miles": 6.0,
392 + "uv": 3.0,
393 + "gust_mph": 22.1,
394 + "gust_kph": 35.6
395 + }
396 +}
397 +{{/code}}
398 +
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:
401 +
402 +{{code language="lua"}}
403 +local APIkey = '70faaecf926b4341b1974006221711'
404 +
405 +
406 +local http = require("socket.http")
407 +local json = require("json")
408 +
409 +-- Send http.get request and return response result
410 +function getHttpsUrl(url)
411 + local result_table, code, headers, status = http.request(url)
412 + print("code:"..code)
413 + if code~= 200 then
414 + return
415 + else
416 + return result_table
417 + end
418 +end
419 +
420 +function sendAPI(key, city)
421 + local url = "http://api.weatherapi.com/v1/current.json?key="..key.."&q="..city.."&aqi=no"
422 + --local url = 'http://v-box.net'
423 + --local url = 'https://www.google.com/'
424 + --http://api.weatherapi.com/v1/current.json?key=70faaecf926b4341b1974006221711&q=Barcelona&aqi=no
425 + print("Get the link:"..url)
426 + local body = getHttpsUrl(url)
427 + --print(body)
428 + local jsonBody = json.decode(body)
429 + --print(jsonBody["current"]["temp_c"])
430 + --print(type(jsonBody["current"]["temp_c"]))
431 + --print(type(jsonBody["current"]["humidity"]))
432 + addr_setfloat("@HDW6060", jsonBody["current"]["temp_c"])
433 + addr_setword("@HDW7070", jsonBody["current"]["humidity"])
434 +end
435 +
436 +
437 +function Weather.main()
438 + local cityName = addr_getstring("@HDW5050",6)
439 + print("cityName: "..cityName)
440 + sendAPI(APIkey, cityName)
441 +end
442 +{{/code}}
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 += **2 Third part server** =
476 +
354 354  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.
355 355  
356 356  (% class="mark" %)1.Europe server:eu.v-box.net
... ... @@ -367,17 +367,38 @@
367 367  
368 368  (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate
369 369  
370 -(% class="wikigeneratedid" %)
493 +{{info}}
371 371  **✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool.
495 +{{/info}}
372 372  
373 373  (% class="wikigeneratedid" %)
374 374  Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]**
375 375  
376 -== **2.1 V-Box connect with test server(General Example)** ==
500 +== **2.1 Test server(General Example)** ==
377 377  
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 +
378 378  {{code language="lua"}}
379 379  --MQTT configuration table
380 380  local MQTT_CFG={}
524 +--if there is no need the username and password, please put them as ""
381 381  MQTT_CFG.username = "weconsupport"
382 382  MQTT_CFG.password = "123456"
383 383  MQTT_CFG.netway = 0
... ... @@ -416,9 +416,13 @@
416 416  --initialize mqtt
417 417  function mqtt_init()
418 418   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
419 419   g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable
420 420   if g_mq then
421 421   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
422 422   print("mqtt init success")
423 423   else
424 424   print("mqtt init failed:", err)
... ... @@ -438,6 +438,11 @@
438 438   g_mq:subscribe(SUBSCRIBE_TOPIC, 0)
439 439  end
440 440  
589 +--Offline callback function
590 +function mqtt_msg_offline(cause)
591 + print("mqtt offline, cause:", cause)
592 +end
593 +
441 441  -- Received message callback function
442 442  function mqtt_msg_callback(topic, msg)
443 443   print("topic:", topic)
... ... @@ -476,9 +476,11 @@
476 476   if g_mq:isconnected() then
477 477   send_data()
478 478   else
479 - --if exceed 20 sec not connect, reconnect once
480 - if os.time() - LAST_TIME > 20 then
632 + --if exceed 5 sec not connect, reconnect once
633 + if os.time() - LAST_TIME > 5 then
481 481   LAST_TIME = os.time()
635 + --reinitial the mqtt object
636 + mqtt_init()
482 482   --connect to mqtt or reconnect
483 483   mqtt_connect()
484 484   end
... ... @@ -491,7 +491,7 @@
491 491  end
492 492  {{/code}}
493 493  
494 -== **2.2 V-Box connect with customer server:grouprobotinfo.com** ==
649 +== **2.2 Customer server:grouprobotinfo.com** ==
495 495  
496 496  This demo does not use SSL certification. Script is as below
497 497  
... ... @@ -501,146 +501,138 @@
501 501  -- Meta class
502 502  --main
503 503  function mq.main()
504 - if not mq.m then
505 -  local err = ""
659 + if not mq.m then
660 + local err = ""
506 506  
507 -  mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID")  -- create connection
508 -  if mq.m then
509 -   mq.config = {
510 -    username = "",-- ID
511 -    password = "",-- password
512 -    netway = 1, -- Ethernet connection, WIFI=1
513 -    -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds.
514 -    -- cleansession = 0, -- Optional, keep session
515 -   }
516 -   mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks
517 -    local str = string.format("%s:%s", topic, msg)
518 -    -- print("mqtt msg:", str) -- Print out the received topics and content
519 -   end
520 -   )
521 -   mq.m:on("offline", function (cause) -- Register for lost connection callbacks
522 -    -- addr_setstring("@xxx", "cause"..(cause or " got nil"))
523 -   end)
524 -   mq.m:on("arrived", function() -- Registration for sending messages to callbacks 
525 -    print("msg arrived")
526 -   end)
527 -  else
528 -   print("mqtt create failed:", err) -- Create object failed
529 -  end
530 - else
531 -  if mq.m:isconnected() then -- If online, post a message
532 -     local phaseStatus ="unknow"
533 -     if addr_getbit("@Standby")== 1 then
534 -         phaseStatus = "Standby"
535 -     elseif addr_getbit("@Pre-Freeze")==1 then
536 -         phaseStatus= "Pre-Freeze"
537 -     elseif addr_getbit("@Prepare")==1 then
538 -         phaseStatus ="Prepare"
539 -     elseif addr_getbit("@Primary Dry")==1 then
540 -         phaseStatus = "Primary dry"
541 -     elseif addr_getbit("@Secondary Dry")==1 then
542 -         phaseStatus = "Secondary Dry"
543 -     end
544 ---   print(addr_getbit("@Primary Dry"))
662 + mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection
663 + if mq.m then
664 + mq.config = {
665 + username = "",-- ID
666 + password = "",-- password
667 + netway = 1, -- Ethernet connection, WIFI=1
668 + -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds.
669 + -- cleansession = 0, -- Optional, keep session
670 + }
671 + mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks
672 + local str = string.format("%s:%s", topic, msg)
673 + -- print("mqtt msg:", str) -- Print out the received topics and content
674 + end)
675 + mq.m:on("offline", function (cause) -- Register for lost connection callbacks
676 + -- addr_setstring("@xxx", "cause"..(cause or " got nil"))
677 + end)
678 + mq.m:on("arrived", function() -- Registration for sending messages to callbacks
679 + print("msg arrived")
680 + end)
681 + else
682 + print("mqtt create failed:", err) -- Create object failed
683 + end
684 + else
685 + if mq.m:isconnected() then -- If online, post a message
686 + local phaseStatus ="unknow"
687 + if addr_getbit("@Standby")== 1 then
688 + phaseStatus = "Standby"
689 + elseif addr_getbit("@Pre-Freeze")==1 then
690 + phaseStatus= "Pre-Freeze"
691 + elseif addr_getbit("@Prepare")==1 then
692 + phaseStatus ="Prepare"
693 + elseif addr_getbit("@Primary Dry")==1 then
694 + phaseStatus = "Primary dry"
695 + elseif addr_getbit("@Secondary Dry")==1 then
696 + phaseStatus = "Secondary Dry"
697 + end
698 + --print(addr_getbit("@Primary Dry"))
545 545  -------------------------------------------------------------------------------------------------------------------------
546 -     local activating ="unknow"
547 -     if addr_getbit("@Compressor")==1 then
548 -         activating = ",".."Compressor"
549 -     end
550 -     if addr_getbit("@Silicone Pump")==1 then
551 -         activating = activating..",".."Silicone Pump"
552 -     end
553 -     if addr_getbit("@Vacuum Pump")==1 then
554 -         activating = activating..",".."Vacuum Pump"
555 -     end
556 -     if addr_getbit("@Root Pump")==1 then
557 -         activating = activating..",".."Root Pump"
558 -     end
559 -     if addr_getbit("@Heater")==1 then
560 -         activating = activating..",".."Heater"
561 -     end
562 -     if addr_getbit("@Valve Silicone")==1 then
563 -         activating = activating..",".."Valve Silicone"
564 -     end
565 -     if addr_getbit("@Valve Ice Condenser")==1 then
566 -         activating = activating..",".."Valve Ice Condenser"
567 -     end
568 -     if addr_getbit("@Valve Vacuum Pump")==1 then
569 -         activating = activating..",".."Valve Vacuum Pump"
570 -     end
571 -     local pr_activating =string.sub(activating,2)
572 -    --  print(pr_activating)  
700 + local activating ="unknow"
701 + if addr_getbit("@Compressor")==1 then
702 + activating = ",".."Compressor"
703 + end
704 + if addr_getbit("@Silicone Pump")==1 then
705 + activating = activating..",".."Silicone Pump"
706 + end
707 + if addr_getbit("@Vacuum Pump")==1 then
708 + activating = activating..",".."Vacuum Pump"
709 + end
710 + if addr_getbit("@Root Pump")==1 then
711 + activating = activating..",".."Root Pump"
712 + end
713 + if addr_getbit("@Heater")==1 then
714 + activating = activating..",".."Heater"
715 + end
716 + if addr_getbit("@Valve Silicone")==1 then
717 + activating = activating..",".."Valve Silicone"
718 + end
719 + if addr_getbit("@Valve Ice Condenser")==1 then
720 + activating = activating..",".."Valve Ice Condenser"
721 + end
722 + if addr_getbit("@Valve Vacuum Pump")==1 then
723 + activating = activating..",".."Valve Vacuum Pump"
724 + end
725 + local pr_activating =string.sub(activating,2)
726 + -- print(pr_activating)
727 + local status_text ="unknow"
728 + if addr_getbit("@Status Run")==1 then
729 + status_text = "RUNNING"
730 + else
731 + status_text = "STOP"
732 + end
733 +-------------------------------------------------------------------------------------------------------------------------
734 + local js = {type="status",
735 + mc_name ="FD300",
736 + status=status_text,
737 + elapsed_time={
738 + hour=addr_getword("@Elapsed Time (Hour)"),
739 + min=addr_getword("@Elapsed Time (Minute)"),
740 + sec=addr_getword("@Elapsed Time (Second)")
741 + },
742 + phase = phaseStatus,
743 + step = addr_getword("@Step"),
744 + activating_output = pr_activating,
745 + sv=addr_getshort("@SV Silicone")/10,
746 + pv=addr_getshort("@PV Silicone")/10,
747 + product1=addr_getshort("@Product 1")/10,
573 573  
749 + product2=addr_getshort("@Product 2")/10,
750 + product3=addr_getshort("@Product 3")/10,
751 + product4=addr_getshort("@Product 4")/10,
752 + ice1=addr_getshort("@Ice condenser 1")/10,
753 + ice2=addr_getshort("@Ice condenser 2")/10,
754 + vacuum=addr_getfloat("@Vacuum")
755 + }
756 + local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"),
757 + ODPC = addr_getbit("@B_25395#W0.01"),
758 + MTPC=addr_getbit("@B_25395#W0.02"),
759 + HTT = addr_getbit("@B_25395#W1.03"),
760 + CPC = addr_getbit("@B_25395#W0.08"),
761 + CPSP =addr_getbit("@B_25395#W1.00"),
762 + CPVP =addr_getbit("@B_25395#W0.10"),
763 + CPRP =addr_getbit("@B_25395#W0.11"),
764 + HP =addr_getbit("@B_25395#W1.01"),
765 + PP= addr_getbit("@B_25395#W1.02"),
766 + PO=addr_getbit("@B_25395#W0.07"),
767 + FSE=addr_getbit("@B_25395#W2.04"),
768 + AVVSVV=addr_getbit("@B_25395#W1.12"),
769 + ICHT=addr_getbit("@B_25395#W3.06")
770 + }
771 + -- ("@B_25395#CIO1.02")
772 + mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0)
773 + mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0)
774 + else
775 + local stat, err = mq.m:connect(mq.config) -- connection
776 + if stat == nil then --Determine whether to connect
777 + print("mqtt connect failed:", err)
778 + return -- Connection failed, return directly
779 + end
780 + mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics
574 574  
575 -
576 -     local status_text ="unknow"
577 -     if addr_getbit("@Status Run")==1 then
578 -         status_text = "RUNNING"
579 -     else
580 -         status_text = "STOP"
581 -     end
582 --------------------------------------------------------------------------------------------------------------------------      
583 -
584 -     local js =  {type="status",
585 -                  mc_name ="FD300",
586 -                  status=status_text,
587 -                  elapsed_time={
588 -                                hour=addr_getword("@Elapsed Time (Hour)"),
589 -                                min=addr_getword("@Elapsed Time (Minute)"),
590 -                                sec=addr_getword("@Elapsed Time (Second)")
591 -                                },
592 -                   phase = phaseStatus,
593 -                   step = addr_getword("@Step"),
594 -                   activating_output = pr_activating,
595 -                   sv=addr_getshort("@SV Silicone")/10,
596 -                   pv=addr_getshort("@PV Silicone")/10,
597 -                   product1=addr_getshort("@Product 1")/10,
598 -
599 -                   product2=addr_getshort("@Product 2")/10,
600 -                   product3=addr_getshort("@Product 3")/10,
601 -                   product4=addr_getshort("@Product 4")/10,
602 -                   ice1=addr_getshort("@Ice condenser 1")/10,
603 -                   ice2=addr_getshort("@Ice condenser 2")/10,
604 -                   vacuum=addr_getfloat("@Vacuum")
605 -
606 -                }
607 -     local jsAlarm = {  HPC = addr_getbit("@B_25395#W0.00"),
608 -                        ODPC = addr_getbit("@B_25395#W0.01"),
609 -                        MTPC=addr_getbit("@B_25395#W0.02"),
610 -                        HTT = addr_getbit("@B_25395#W1.03"),
611 -                        CPC = addr_getbit("@B_25395#W0.08"),
612 -                        CPSP =addr_getbit("@B_25395#W1.00"),
613 -                        CPVP =addr_getbit("@B_25395#W0.10"),
614 -                        CPRP =addr_getbit("@B_25395#W0.11"),
615 -                        HP =addr_getbit("@B_25395#W1.01"),
616 -                        PP= addr_getbit("@B_25395#W1.02"),
617 -                        PO=addr_getbit("@B_25395#W0.07"),
618 -                        FSE=addr_getbit("@B_25395#W2.04"),
619 -                        AVVSVV=addr_getbit("@B_25395#W1.12"),
620 -                        ICHT=addr_getbit("@B_25395#W3.06")
621 -
622 -                }
623 -
624 -    -- ("@B_25395#CIO1.02")
625 -     mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0)
626 -     mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0)
627 -  else
628 -   local stat, err = mq.m:connect(mq.config) -- connection
629 -   if stat == nil then --Determine whether to connect
630 -    print("mqtt connect failed:", err)
631 -    return -- Connection failed, return directly
632 -   end
633 -   mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics
634 -
635 -  end
636 -  -- mq.m:unsubscribe("stc/test")
637 -  -- mq.m:disconnect() -- close matt
638 -  -- mq.m:close() -- close clase
639 - end
782 + end
783 + -- mq.m:unsubscribe("stc/test")
784 + -- mq.m:disconnect() -- close matt
785 + -- mq.m:close() -- close clase
786 + end
640 640  end
641 641  {{/code}}
642 642  
643 -== **2.3 V-Box connect with Azure platform** ==
790 +== **2.3 Azure platform** ==
644 644  
645 645  In this demo,V-Box connects with Azure by SSL certification.
646 646  
... ... @@ -771,8 +771,12 @@
771 771  end
772 772  )))
773 773  
774 -== **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** ==
775 775  
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 +
776 776  1.Register a account: [[https:~~/~~/www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ>>https://www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ]]
777 777  
778 778  2.log in the Huawei IOTDA
... ... @@ -920,10 +920,8 @@
920 920  (% style="text-align:center" %)
921 921  [[image:1624441186851-536.png||height="434" width="700" class="img-thumbnail"]]
922 922  
923 -== **2.5 V-Box connect with Huawei platform** ==
1074 +=== Huawei by SSL certification. ===
924 924  
925 -In this demo,V-Box connects with Huawei by SSL certification.
926 -
927 927  1.Create a project access for Huawei IOT
928 928  
929 929  2.configure MQTT configuration
... ... @@ -1041,7 +1041,7 @@
1041 1041  (% style="text-align:center" %)
1042 1042  [[image:1624506666650-161.png||height="547" width="1000" class="img-thumbnail"]]
1043 1043  
1044 -== **2.6 V-Box connect with AWS platform** ==
1193 +== **2.6 AWS platform** ==
1045 1045  
1046 1046  === **Log in AWS** ===
1047 1047  
... ... @@ -1066,35 +1066,20 @@
1066 1066  
1067 1067  {{code language="java"}}
1068 1068  {
1069 -
1070 1070    "Version": "2012-10-17",
1071 -
1072 1072    "Statement": [
1073 -
1074 1074      {
1075 -
1076 1076        "Effect": "Allow",
1077 -
1078 1078        "Action": [
1079 -
1080 1080          "iot:Connect",
1081 -
1082 1082          "iot:Publish",
1083 -
1084 1084          "iot:Subscribe",
1085 -
1086 1086          "iot:Receive",
1087 -
1088 1088          "greengrass:Discover"
1089 -
1090 1090        ],
1091 -
1092 1092        "Resource": "*"
1093 -
1094 1094      }
1095 -
1096 1096    ]
1097 -
1098 1098  }
1099 1099  {{/code}}
1100 1100  
... ... @@ -1121,7 +1121,7 @@
1121 1121  [[image:image-20220709165402-11.png]]
1122 1122  
1123 1123  
1124 -=== **Test with MQTT.fx tool** ===
1258 +=== **MQTT.fx tool** ===
1125 1125  
1126 1126  Click “View Setting” to get the “Broker Adress”
1127 1127  
... ... @@ -1149,7 +1149,7 @@
1149 1149  
1150 1150  [[image:image-20220709165402-18.png]]
1151 1151  
1152 -=== **Configurate in CloudTool** ===
1286 +=== **CloudTool** ===
1153 1153  
1154 1154  Copy the same setting in MQTT.fx to MQTT configuration
1155 1155  
... ... @@ -1159,185 +1159,190 @@
1159 1159  
1160 1160  [[image:image-20220709165402-20.png]]
1161 1161  
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"}}
1162 1162  sprint = print
1163 1163  
1164 -~-~-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)
1165 1165  
1166 1166  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
1167 1167  
1168 -~-~-publish to topics
1307 +--publish to topics
1169 1169  
1170 1170  local pub_RE_TOPIC = string.format('TEST')
1171 1171  
1172 -~-~-Subscribe topics
1311 +--Subscribe topics
1173 1173  
1174 1174  local Subscribe_RE_TOPIC1 = string.format('TEST')
1175 1175  
1176 -~-~-variable
1315 +--variable
1177 1177  
1178 1178  local last_time = 0
1179 1179  
1180 -~-~-Timing main function
1319 +--Timing main function
1181 1181  
1182 1182  function aws.main()
1183 1183  
1184 - 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")
1185 1185  
1186 - if g_mq then
1325 + if g_mq then
1187 1187  
1188 - if g_mq:isconnected() then
1327 + if g_mq:isconnected() then
1189 1189  
1190 - send_Data()
1329 + send_Data()
1191 1191  
1192 - else
1331 + else
1193 1193  
1194 - if os.time() - last_time > 5 then
1333 + if os.time() - last_time > 5 then
1195 1195  
1196 - last_time = os.time()
1335 + last_time = os.time()
1197 1197  
1198 - mymqtt_connect()
1337 + mymqtt_connect()
1199 1199  
1339 + end
1340 +
1200 1200   end
1201 1201  
1202 - end
1343 + else
1203 1203  
1204 - else
1345 + mymqtt_init()
1205 1205  
1206 - mymqtt_init()
1347 + end
1207 1207  
1208 - end
1349 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1209 1209  
1210 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1211 -
1212 1212  end
1213 1213  
1214 1214  
1215 -~-~- Initialize MQTT
1216 1216  
1355 +-- Initialize MQTT
1356 +
1217 1217  function mymqtt_init()
1218 1218  
1219 - 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))
1220 1220  
1221 - 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
1222 1222  
1223 - if g_mq then
1363 + if g_mq then
1224 1224  
1225 - 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
1226 1226  
1227 - sprint("mqtt init success")
1367 + sprint("mqtt init success")
1228 1228  
1229 - else
1369 + else
1230 1230  
1231 - sprint("mqtt init failed:", err)
1371 + sprint("mqtt init failed:", err)
1232 1232  
1233 - end
1373 + end
1234 1234  
1235 1235  end
1236 1236  
1237 -~-~- Connect to MQTT server
1377 +-- Connect to MQTT server
1238 1238  
1239 1239  function mymqtt_connect()
1240 1240  
1241 - sprint("mqtt connecting...")
1381 + sprint("mqtt connecting...")
1242 1242  
1243 - 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)
1244 1244  
1245 - if stat == nil then
1385 + if stat == nil then
1246 1246  
1247 - sprint("mqtt connect failed:", err)
1387 + sprint("mqtt connect failed:", err)
1248 1248  
1249 - return
1389 + return
1250 1250  
1251 - else
1391 + else
1252 1252  
1253 - sprint("mqtt connected")
1393 + sprint("mqtt connected")
1254 1254  
1255 - end
1395 + end
1256 1256  
1257 - g_mq:subscribe(TEST, 0)
1397 + g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
1258 1258  
1259 1259  end
1260 1260  
1261 -~-~- Receive MQTT message callback function
1401 +-- Receive MQTT message callback function
1262 1262  
1263 1263  function mymqtt_msg_callback(topic, msg)
1264 1264  
1265 - print("topic:",topic)
1405 + print("topic:",topic)
1266 1266  
1267 - print("revdata:",msg)
1407 + print("revdata:",msg)
1268 1268  
1269 - local revData = json.decode(msg)
1409 + local revData = json.decode(msg)
1270 1270  
1271 - print (revData)
1411 + print (revData)
1272 1272  
1273 - 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
1274 1274  
1275 -if string.match(topic,Subscribe_RE_TOPIC1) then
1415 + if string.match(topic,Subscribe_RE_TOPIC1) then
1276 1276  
1277 - ~-~-if revData ~~= nil then
1417 + --if revData ~= nil then
1278 1278  
1279 - for k,v in pairs (revData) do
1419 + for k,v in pairs (revData) do
1280 1280  
1281 - print("printing revdata after kv here")
1421 + print("printing revdata after kv here")
1282 1282  
1283 - print (k,v)
1423 + print (k,v)
1284 1284  
1285 - end
1425 + end
1286 1286  
1287 - print ("current state is",fanstate)
1427 + print ("current state is",fanstate)
1288 1288  
1289 - ~-~-end
1429 + --end
1290 1290  
1291 -end
1431 + end
1292 1292  
1293 -end
1433 + end
1294 1294  
1295 1295  end
1296 1296  
1297 1297  
1298 -~-~-Get real-time data
1299 1299  
1439 +--Get real-time data
1440 +
1300 1300  function getData()
1301 1301  
1302 - local jdata = {}
1443 + local jdata = {}
1303 1303  
1304 - local addr = bns_get_alldata()
1445 + local addr = bns_get_alldata()
1305 1305  
1306 - print(json.encode(addr))
1447 + print(json.encode(addr))
1307 1307  
1308 - for i,v in pairs(addr) do
1449 + for i,v in pairs(addr) do
1309 1309  
1310 - if v[2] == 1 then
1451 + if v[2] == 1 then
1311 1311  
1312 - jdata[v[3]] = v[4]
1453 + jdata[v[3]] = v[4]
1313 1313  
1314 - end
1455 + end
1315 1315  
1316 - end
1457 + end
1317 1317  
1318 - return jdata
1459 + return jdata
1319 1319  
1320 1320  end
1321 1321  
1322 -~-~-send data
1463 +--send data
1323 1323  
1324 1324  function send_Data()
1325 1325  
1326 - local pub_data =
1467 + local pub_data =
1468 + {
1469 + 123
1470 + }
1327 1327  
1328 - {
1329 -
1330 -123
1331 -
1332 -}
1333 -
1334 1334  sprint(json.encode(pub_data))
1335 1335  
1336 1336  print("..........",pub_RE_TOPIC)
1337 1337  
1338 - 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)
1339 1339  
1340 1340  end
1479 +{{/code}}
1341 1341  
1342 1342  Get message in AWS
1343 1343  
InputHTTPparameter.png
Author
... ... @@ -1,0 +1,1 @@
1 +XWiki.Hunter
Size
... ... @@ -1,0 +1,1 @@
1 +17.9 KB
Content