Skip to Content

Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03
From version 57.1
edited by Theodore Xu
on 2023/08/24 17:13
Change comment: There is no comment for this version
To version 27.1
edited by Hunter
on 2022/10/25 09:39
Change comment: There is no comment for this version

Summary

Details

Page properties
Author
... ... @@ -1,1 +1,1 @@
1 -XWiki.AiXia
1 +XWiki.Hunter
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  
... ... @@ -343,135 +343,6 @@
343 343  end
344 344  {{/code}}
345 345  
346 -== **1.8 How to parse value from HTTP response body** ==
347 -
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 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,38 +490,17 @@
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}}
370 +(% 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 499  
500 -== **2.1 Test server(General Example)** ==
376 +== **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
479 + --if exceed 20 sec not connect, reconnect once
480 + 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
... ... @@ -646,7 +646,7 @@
646 646  end
647 647  {{/code}}
648 648  
649 -== **2.2 Customer server:grouprobotinfo.com** ==
494 +== **2.2 V-Box connect with customer server:grouprobotinfo.com** ==
650 650  
651 651  This demo does not use SSL certification. Script is as below
652 652  
... ... @@ -656,138 +656,146 @@
656 656  -- Meta class
657 657  --main
658 658  function mq.main()
659 - if not mq.m then
660 - local err = ""
504 + if not mq.m then
505 +  local err = ""
661 661  
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"))
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"))
699 699  -------------------------------------------------------------------------------------------------------------------------
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,
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)  
748 748  
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
781 781  
782 - end
783 - -- mq.m:unsubscribe("stc/test")
784 - -- mq.m:disconnect() -- close matt
785 - -- mq.m:close() -- close clase
786 - end
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
787 787  end
788 788  {{/code}}
789 789  
790 -== **2.3 Azure platform** ==
643 +== **2.3 V-Box connect with Azure platform** ==
791 791  
792 792  In this demo,V-Box connects with Azure by SSL certification.
793 793  
... ... @@ -918,14 +918,8 @@
918 918  end
919 919  )))
920 920  
921 -== **2.4 Huawei platform** ==
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）** ==
922 922  
923 -
924 -
925 -{{info}}
926 -**✎Note**:**Huawei IOT DA function is only in China area.If you want this function,you need to use chinese mobile to register**
927 -{{/info}}
928 -
929 929  1.Register a account: [[https:~~/~~/www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ>>https://www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ]]
930 930  
931 931  2.log in the Huawei IOTDA
... ... @@ -1073,7 +1073,7 @@
1073 1073  (% style="text-align:center" %)
1074 1074  [[image:1624441186851-536.png||height="434" width="700" class="img-thumbnail"]]
1075 1075  
1076 -== **2.5 Huawei platform** ==
923 +== **2.5 V-Box connect with Huawei platform** ==
1077 1077  
1078 1078  In this demo,V-Box connects with Huawei by SSL certification.
1079 1079  
... ... @@ -1194,7 +1194,7 @@
1194 1194  (% style="text-align:center" %)
1195 1195  [[image:1624506666650-161.png||height="547" width="1000" class="img-thumbnail"]]
1196 1196  
1197 -== **2.6 AWS platform** ==
1044 +== **2.6 V-Box connect with AWS platform** ==
1198 1198  
1199 1199  === **Log in AWS** ===
1200 1200  
... ... @@ -1219,20 +1219,35 @@
1219 1219  
1220 1220  {{code language="java"}}
1221 1221  {
1069 +
1222 1222    "Version": "2012-10-17",
1071 +
1223 1223    "Statement": [
1073 +
1224 1224      {
1075 +
1225 1225        "Effect": "Allow",
1077 +
1226 1226        "Action": [
1079 +
1227 1227          "iot:Connect",
1081 +
1228 1228          "iot:Publish",
1083 +
1229 1229          "iot:Subscribe",
1085 +
1230 1230          "iot:Receive",
1087 +
1231 1231          "greengrass:Discover"
1089 +
1232 1232        ],
1091 +
1233 1233        "Resource": "*"
1093 +
1234 1234      }
1095 +
1235 1235    ]
1097 +
1236 1236  }
1237 1237  {{/code}}
1238 1238  
... ... @@ -1259,7 +1259,7 @@
1259 1259  [[image:image-20220709165402-11.png]]
1260 1260  
1261 1261  
1262 -=== **MQTT.fx tool** ===
1124 +=== **Test with MQTT.fx tool** ===
1263 1263  
1264 1264  Click “View Setting” to get the “Broker Adress”
1265 1265  
... ... @@ -1287,7 +1287,7 @@
1287 1287  
1288 1288  [[image:image-20220709165402-18.png]]
1289 1289  
1290 -=== **CloudTool** ===
1152 +=== **Configurate in CloudTool** ===
1291 1291  
1292 1292  Copy the same setting in MQTT.fx to MQTT configuration
1293 1293  
... ... @@ -1297,190 +1297,185 @@
1297 1297  
1298 1298  [[image:image-20220709165402-20.png]]
1299 1299  
1300 -{{info}}
1301 -**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701
1302 -{{/info}}
1303 -
1304 -{{code language="lua"}}
1305 1305  sprint = print
1306 1306  
1307 ---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)
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)
1308 1308  
1309 1309  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
1310 1310  
1311 ---publish to topics
1168 +~-~-publish to topics
1312 1312  
1313 1313  local pub_RE_TOPIC = string.format('TEST')
1314 1314  
1315 ---Subscribe topics
1172 +~-~-Subscribe topics
1316 1316  
1317 1317  local Subscribe_RE_TOPIC1 = string.format('TEST')
1318 1318  
1319 ---variable
1176 +~-~-variable
1320 1320  
1321 1321  local last_time = 0
1322 1322  
1323 ---Timing main function
1180 +~-~-Timing main function
1324 1324  
1325 1325  function aws.main()
1326 1326  
1327 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1184 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1328 1328  
1329 - if g_mq then
1186 + if g_mq then
1330 1330  
1331 - if g_mq:isconnected() then
1188 + if g_mq:isconnected() then
1332 1332  
1333 - send_Data()
1190 + send_Data()
1334 1334  
1335 - else
1192 + else
1336 1336  
1337 - if os.time() - last_time > 5 then
1194 + if os.time() - last_time > 5 then
1338 1338  
1339 - last_time = os.time()
1196 + last_time = os.time()
1340 1340  
1341 - mymqtt_connect()
1198 + mymqtt_connect()
1342 1342  
1343 - end
1344 -
1345 1345   end
1346 1346  
1347 - else
1202 + end
1348 1348  
1349 - mymqtt_init()
1204 + else
1350 1350  
1351 - end
1206 + mymqtt_init()
1352 1352  
1353 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1208 + end
1354 1354  
1210 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1211 +
1355 1355  end
1356 1356  
1357 1357  
1215 +~-~- Initialize MQTT
1358 1358  
1359 --- Initialize MQTT
1360 -
1361 1361  function mymqtt_init()
1362 1362  
1363 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1219 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1364 1364  
1365 - 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
1221 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
1366 1366  
1367 - if g_mq then
1223 + if g_mq then
1368 1368  
1369 - g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1225 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1370 1370  
1371 - sprint("mqtt init success")
1227 + sprint("mqtt init success")
1372 1372  
1373 - else
1229 + else
1374 1374  
1375 - sprint("mqtt init failed:", err)
1231 + sprint("mqtt init failed:", err)
1376 1376  
1377 - end
1233 + end
1378 1378  
1379 1379  end
1380 1380  
1381 --- Connect to MQTT server
1237 +~-~- Connect to MQTT server
1382 1382  
1383 1383  function mymqtt_connect()
1384 1384  
1385 - sprint("mqtt connecting...")
1241 + sprint("mqtt connecting...")
1386 1386  
1387 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1243 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1388 1388  
1389 - if stat == nil then
1245 + if stat == nil then
1390 1390  
1391 - sprint("mqtt connect failed:", err)
1247 + sprint("mqtt connect failed:", err)
1392 1392  
1393 - return
1249 + return
1394 1394  
1395 - else
1251 + else
1396 1396  
1397 - sprint("mqtt connected")
1253 + sprint("mqtt connected")
1398 1398  
1399 - end
1255 + end
1400 1400  
1401 - g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
1257 + g_mq:subscribe(TEST, 0)
1402 1402  
1403 1403  end
1404 1404  
1405 --- Receive MQTT message callback function
1261 +~-~- Receive MQTT message callback function
1406 1406  
1407 1407  function mymqtt_msg_callback(topic, msg)
1408 1408  
1409 - print("topic:",topic)
1265 + print("topic:",topic)
1410 1410  
1411 - print("revdata:",msg)
1267 + print("revdata:",msg)
1412 1412  
1413 - local revData = json.decode(msg)
1269 + local revData = json.decode(msg)
1414 1414  
1415 - print (revData)
1271 + print (revData)
1416 1416  
1417 - if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1273 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1418 1418  
1419 - if string.match(topic,Subscribe_RE_TOPIC1) then
1275 +if string.match(topic,Subscribe_RE_TOPIC1) then
1420 1420  
1421 - --if revData ~= nil then
1277 + ~-~-if revData ~~= nil then
1422 1422  
1423 - for k,v in pairs (revData) do
1279 + for k,v in pairs (revData) do
1424 1424  
1425 - print("printing revdata after kv here")
1281 + print("printing revdata after kv here")
1426 1426  
1427 - print (k,v)
1283 + print (k,v)
1428 1428  
1429 - end
1285 + end
1430 1430  
1431 - print ("current state is",fanstate)
1287 + print ("current state is",fanstate)
1432 1432  
1433 - --end
1289 + ~-~-end
1434 1434  
1435 - end
1291 +end
1436 1436  
1437 - end
1293 +end
1438 1438  
1439 1439  end
1440 1440  
1441 1441  
1298 +~-~-Get real-time data
1442 1442  
1443 ---Get real-time data
1444 -
1445 1445  function getData()
1446 1446  
1447 - local jdata = {}
1302 + local jdata = {}
1448 1448  
1449 - local addr = bns_get_alldata()
1304 + local addr = bns_get_alldata()
1450 1450  
1451 - print(json.encode(addr))
1306 + print(json.encode(addr))
1452 1452  
1453 - for i,v in pairs(addr) do
1308 + for i,v in pairs(addr) do
1454 1454  
1455 - if v[2] == 1 then
1310 + if v[2] == 1 then
1456 1456  
1457 - jdata[v[3]] = v[4]
1312 + jdata[v[3]] = v[4]
1458 1458  
1459 - end
1314 + end
1460 1460  
1461 - end
1316 + end
1462 1462  
1463 - return jdata
1318 + return jdata
1464 1464  
1465 1465  end
1466 1466  
1467 ---send data
1322 +~-~-send data
1468 1468  
1469 1469  function send_Data()
1470 1470  
1471 - local pub_data =
1472 - {
1473 - 123
1474 - }
1326 + local pub_data =
1475 1475  
1328 + {
1329 +
1330 +123
1331 +
1332 +}
1333 +
1476 1476  sprint(json.encode(pub_data))
1477 1477  
1478 1478  print("..........",pub_RE_TOPIC)
1479 1479  
1480 - return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1338 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1481 1481  
1482 1482  end
1483 -{{/code}}
1484 1484  
1485 1485  Get message in AWS
1486 1486  
InputHTTPparameter.png
Author
... ... @@ -1,1 +1,0 @@
1 -XWiki.Hunter
Size
... ... @@ -1,1 +1,0 @@
1 -17.9 KB
Content