Skip to Content

Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03
From version 26.1
edited by Hunter
on 2022/10/25 09:36
Change comment: There is no comment for this version
To version 50.1
edited by Hunter
on 2023/05/06 10:12
Change comment: There is no comment for this version

Summary

Details

Page properties
Content
... ... @@ -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}}
148 +{{code language="lua"}}
149 149  local tempBit = 0
150 150  local tempWord = 0
151 151  
... ... @@ -224,6 +224,10 @@
224 224  
225 225  This example shows how to use the Twilio API to send WhatsApp message to private number. When monitoring bit "@testBit" changes, it will trigger and send the message. Please replace with your own SID, Token, twilioPhoneNumber and receiverPhoneNumber.
226 226  
227 +About how to register the Twilio API, please check the following video:
228 +
229 +[[https:~~/~~/www.youtube.com/watch?v=Id4lKichauU>>https://www.youtube.com/watch?v=Id4lKichauU]]
230 +
227 227  {{code language="Lua"}}
228 228  local tempBit = 0
229 229  local tempWord = 0
... ... @@ -345,6 +345,135 @@
345 345  end
346 346  {{/code}}
347 347  
352 +== **1.8 How to parse value from HTTP response body** ==
353 +
354 +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":
355 +
356 +(% style="text-align:center" %)
357 +[[image:InputHTTPparameter.png]]
358 +
359 +Then the response body would be like as following:
360 +
361 +{{code language="json"}}
362 +{
363 + "location": {
364 + "name": "Madrid",
365 + "region": "Madrid",
366 + "country": "Spain",
367 + "lat": 40.4,
368 + "lon": -3.68,
369 + "tz_id": "Europe/Madrid",
370 + "localtime_epoch": 1669022636,
371 + "localtime": "2022-11-21 10:23"
372 + },
373 + "current": {
374 + "last_updated_epoch": 1669022100,
375 + "last_updated": "2022-11-21 10:15",
376 + "temp_c": 13.0,
377 + "temp_f": 55.4,
378 + "is_day": 1,
379 + "condition": {
380 + "text": "Partly cloudy",
381 + "icon": "//cdn.weatherapi.com/weather/64x64/day/116.png",
382 + "code": 1003
383 + },
384 + "wind_mph": 11.9,
385 + "wind_kph": 19.1,
386 + "wind_degree": 210,
387 + "wind_dir": "SSW",
388 + "pressure_mb": 1015.0,
389 + "pressure_in": 29.97,
390 + "precip_mm": 0.0,
391 + "precip_in": 0.0,
392 + "humidity": 88,
393 + "cloud": 75,
394 + "feelslike_c": 10.8,
395 + "feelslike_f": 51.4,
396 + "vis_km": 10.0,
397 + "vis_miles": 6.0,
398 + "uv": 3.0,
399 + "gust_mph": 22.1,
400 + "gust_kph": 35.6
401 + }
402 +}
403 +{{/code}}
404 +
405 +(% class="wikigeneratedid" %)
406 +So we decode json into lua object to assign the value into addresses HDW6060(temperature), HDW7070(humidity), the code example like follows:
407 +
408 +{{code language="lua"}}
409 +local APIkey = '70faaecf926b4341b1974006221711'
410 +
411 +
412 +local http = require("socket.http")
413 +local json = require("json")
414 +
415 +-- Send http.get request and return response result
416 +function getHttpsUrl(url)
417 + local result_table, code, headers, status = http.request(url)
418 + print("code:"..code)
419 + if code~= 200 then
420 + return
421 + else
422 + return result_table
423 + end
424 +end
425 +
426 +function sendAPI(key, city)
427 + local url = "http://api.weatherapi.com/v1/current.json?key="..key.."&q="..city.."&aqi=no"
428 + --local url = 'http://v-box.net'
429 + --local url = 'https://www.google.com/'
430 + --http://api.weatherapi.com/v1/current.json?key=70faaecf926b4341b1974006221711&q=Barcelona&aqi=no
431 + print("Get the link:"..url)
432 + local body = getHttpsUrl(url)
433 + --print(body)
434 + local jsonBody = json.decode(body)
435 + --print(jsonBody["current"]["temp_c"])
436 + --print(type(jsonBody["current"]["temp_c"]))
437 + --print(type(jsonBody["current"]["humidity"]))
438 + addr_setfloat("@HDW6060", jsonBody["current"]["temp_c"])
439 + addr_setword("@HDW7070", jsonBody["current"]["humidity"])
440 +end
441 +
442 +
443 +function Weather.main()
444 + local cityName = addr_getstring("@HDW5050",6)
445 + print("cityName: "..cityName)
446 + sendAPI(APIkey, cityName)
447 +end
448 +{{/code}}
449 +
450 +== **1.9 High-Low Byte Switch** ==
451 +
452 +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"]].
453 +
454 +{{code language="lua"}}
455 +function highLowByteSwitch(floatNumber)
456 + addr_setfloat("@W_0#HDW23036",floatNumber,0,2)
457 + local newFloat = addr_getfloat("@W_0#HDW23036")
458 + local formattedFloat = string.format("%.2f",newFloat)
459 + print("The formatted float value is the : "..formattedFloat)
460 + return formattedFloat
461 +end
462 +{{/code}}
463 +
464 +== **1.10 Read 64bits Unsigned Value** ==
465 +
466 +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.
467 +
468 +{{code language="lua"}}
469 +function addr_getquatra(address)
470 + local highAddress = addr_newnoaddr(address,2)
471 + local low32 = addr_getdword(address)
472 + local high32 = addr_getdword(highAddress)
473 + --print("the low number is "..low32)
474 + --print("the high number is "..high32)
475 + local formatVal = string.format("%64.0f",2^32*high32+low32)
476 + print("the format value is ".. formatVal)
477 + return formatVal
478 +end
479 +{{/code}}
480 +
348 348  = **2 V-Box connect with third part server** =
349 349  
350 350  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.
... ... @@ -363,8 +363,9 @@
363 363  
364 364  (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate
365 365  
366 -(% class="wikigeneratedid" %)
499 +{{info}}
367 367  **✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool.
501 +{{/info}}
368 368  
369 369  (% class="wikigeneratedid" %)
370 370  Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]**
... ... @@ -371,6 +371,25 @@
371 371  
372 372  == **2.1 V-Box connect with test server(General Example)** ==
373 373  
508 +The following example is trying to publish to the topic "testtopic/test/no1/7890", and subscribe the topic "testtopic/test/no1/123456".
509 +
510 +And the JSON message is like follows:
511 +
512 +{{code language="JSON"}}
513 +{
514 + "timestamp": 1631152760,
515 + "messageId": 1,
516 + "event": "test_data",
517 + "mfrs": "HMI/box",
518 + "data":
519 + {
520 + "id" : 1436217747670454274,
521 + "waterlevel" : 48,
522 + "temperture" : 23
523 + }
524 +}
525 +{{/code}}
526 +
374 374  {{code language="lua"}}
375 375  --MQTT configuration table
376 376  local MQTT_CFG={}
... ... @@ -412,9 +412,13 @@
412 412  --initialize mqtt
413 413  function mqtt_init()
414 414   print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID))
568 + if g_mq then
569 + mqtt.close() --Close mqtt object
570 + end
415 415   g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable
416 416   if g_mq then
417 417   g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages
574 + g_mq:on("offline", mqtt_msg_offline) -- Register a callback for offline
418 418   print("mqtt init success")
419 419   else
420 420   print("mqtt init failed:", err)
... ... @@ -434,6 +434,11 @@
434 434   g_mq:subscribe(SUBSCRIBE_TOPIC, 0)
435 435  end
436 436  
594 +--Offline callback function
595 +function mqtt_msg_offline(cause)
596 + print("mqtt offline, cause:", cause)
597 +end
598 +
437 437  -- Received message callback function
438 438  function mqtt_msg_callback(topic, msg)
439 439   print("topic:", topic)
... ... @@ -472,9 +472,11 @@
472 472   if g_mq:isconnected() then
473 473   send_data()
474 474   else
475 - --if exceed 20 sec not connect, reconnect once
476 - if os.time() - LAST_TIME > 20 then
637 + --if exceed 5 sec not connect, reconnect once
638 + if os.time() - LAST_TIME > 5 then
477 477   LAST_TIME = os.time()
640 + --reinitial the mqtt object
641 + mqtt_init()
478 478   --connect to mqtt or reconnect
479 479   mqtt_connect()
480 480   end
... ... @@ -497,142 +497,134 @@
497 497  -- Meta class
498 498  --main
499 499  function mq.main()
500 - if not mq.m then
501 -  local err = ""
664 + if not mq.m then
665 + local err = ""
502 502  
503 -  mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID")  -- create connection
504 -  if mq.m then
505 -   mq.config = {
506 -    username = "",-- ID
507 -    password = "",-- password
508 -    netway = 1, -- Ethernet connection, WIFI=1
509 -    -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds.
510 -    -- cleansession = 0, -- Optional, keep session
511 -   }
512 -   mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks
513 -    local str = string.format("%s:%s", topic, msg)
514 -    -- print("mqtt msg:", str) -- Print out the received topics and content
515 -   end
516 -   )
517 -   mq.m:on("offline", function (cause) -- Register for lost connection callbacks
518 -    -- addr_setstring("@xxx", "cause"..(cause or " got nil"))
519 -   end)
520 -   mq.m:on("arrived", function() -- Registration for sending messages to callbacks 
521 -    print("msg arrived")
522 -   end)
523 -  else
524 -   print("mqtt create failed:", err) -- Create object failed
525 -  end
526 - else
527 -  if mq.m:isconnected() then -- If online, post a message
528 -     local phaseStatus ="unknow"
529 -     if addr_getbit("@Standby")== 1 then
530 -         phaseStatus = "Standby"
531 -     elseif addr_getbit("@Pre-Freeze")==1 then
532 -         phaseStatus= "Pre-Freeze"
533 -     elseif addr_getbit("@Prepare")==1 then
534 -         phaseStatus ="Prepare"
535 -     elseif addr_getbit("@Primary Dry")==1 then
536 -         phaseStatus = "Primary dry"
537 -     elseif addr_getbit("@Secondary Dry")==1 then
538 -         phaseStatus = "Secondary Dry"
539 -     end
540 ---   print(addr_getbit("@Primary Dry"))
667 + mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection
668 + if mq.m then
669 + mq.config = {
670 + username = "",-- ID
671 + password = "",-- password
672 + netway = 1, -- Ethernet connection, WIFI=1
673 + -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds.
674 + -- cleansession = 0, -- Optional, keep session
675 + }
676 + mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks
677 + local str = string.format("%s:%s", topic, msg)
678 + -- print("mqtt msg:", str) -- Print out the received topics and content
679 + end)
680 + mq.m:on("offline", function (cause) -- Register for lost connection callbacks
681 + -- addr_setstring("@xxx", "cause"..(cause or " got nil"))
682 + end)
683 + mq.m:on("arrived", function() -- Registration for sending messages to callbacks
684 + print("msg arrived")
685 + end)
686 + else
687 + print("mqtt create failed:", err) -- Create object failed
688 + end
689 + else
690 + if mq.m:isconnected() then -- If online, post a message
691 + local phaseStatus ="unknow"
692 + if addr_getbit("@Standby")== 1 then
693 + phaseStatus = "Standby"
694 + elseif addr_getbit("@Pre-Freeze")==1 then
695 + phaseStatus= "Pre-Freeze"
696 + elseif addr_getbit("@Prepare")==1 then
697 + phaseStatus ="Prepare"
698 + elseif addr_getbit("@Primary Dry")==1 then
699 + phaseStatus = "Primary dry"
700 + elseif addr_getbit("@Secondary Dry")==1 then
701 + phaseStatus = "Secondary Dry"
702 + end
703 + --print(addr_getbit("@Primary Dry"))
541 541  -------------------------------------------------------------------------------------------------------------------------
542 -     local activating ="unknow"
543 -     if addr_getbit("@Compressor")==1 then
544 -         activating = ",".."Compressor"
545 -     end
546 -     if addr_getbit("@Silicone Pump")==1 then
547 -         activating = activating..",".."Silicone Pump"
548 -     end
549 -     if addr_getbit("@Vacuum Pump")==1 then
550 -         activating = activating..",".."Vacuum Pump"
551 -     end
552 -     if addr_getbit("@Root Pump")==1 then
553 -         activating = activating..",".."Root Pump"
554 -     end
555 -     if addr_getbit("@Heater")==1 then
556 -         activating = activating..",".."Heater"
557 -     end
558 -     if addr_getbit("@Valve Silicone")==1 then
559 -         activating = activating..",".."Valve Silicone"
560 -     end
561 -     if addr_getbit("@Valve Ice Condenser")==1 then
562 -         activating = activating..",".."Valve Ice Condenser"
563 -     end
564 -     if addr_getbit("@Valve Vacuum Pump")==1 then
565 -         activating = activating..",".."Valve Vacuum Pump"
566 -     end
567 -     local pr_activating =string.sub(activating,2)
568 -    --  print(pr_activating)  
705 + local activating ="unknow"
706 + if addr_getbit("@Compressor")==1 then
707 + activating = ",".."Compressor"
708 + end
709 + if addr_getbit("@Silicone Pump")==1 then
710 + activating = activating..",".."Silicone Pump"
711 + end
712 + if addr_getbit("@Vacuum Pump")==1 then
713 + activating = activating..",".."Vacuum Pump"
714 + end
715 + if addr_getbit("@Root Pump")==1 then
716 + activating = activating..",".."Root Pump"
717 + end
718 + if addr_getbit("@Heater")==1 then
719 + activating = activating..",".."Heater"
720 + end
721 + if addr_getbit("@Valve Silicone")==1 then
722 + activating = activating..",".."Valve Silicone"
723 + end
724 + if addr_getbit("@Valve Ice Condenser")==1 then
725 + activating = activating..",".."Valve Ice Condenser"
726 + end
727 + if addr_getbit("@Valve Vacuum Pump")==1 then
728 + activating = activating..",".."Valve Vacuum Pump"
729 + end
730 + local pr_activating =string.sub(activating,2)
731 + -- print(pr_activating)
732 + local status_text ="unknow"
733 + if addr_getbit("@Status Run")==1 then
734 + status_text = "RUNNING"
735 + else
736 + status_text = "STOP"
737 + end
738 +-------------------------------------------------------------------------------------------------------------------------
739 + local js = {type="status",
740 + mc_name ="FD300",
741 + status=status_text,
742 + elapsed_time={
743 + hour=addr_getword("@Elapsed Time (Hour)"),
744 + min=addr_getword("@Elapsed Time (Minute)"),
745 + sec=addr_getword("@Elapsed Time (Second)")
746 + },
747 + phase = phaseStatus,
748 + step = addr_getword("@Step"),
749 + activating_output = pr_activating,
750 + sv=addr_getshort("@SV Silicone")/10,
751 + pv=addr_getshort("@PV Silicone")/10,
752 + product1=addr_getshort("@Product 1")/10,
569 569  
754 + product2=addr_getshort("@Product 2")/10,
755 + product3=addr_getshort("@Product 3")/10,
756 + product4=addr_getshort("@Product 4")/10,
757 + ice1=addr_getshort("@Ice condenser 1")/10,
758 + ice2=addr_getshort("@Ice condenser 2")/10,
759 + vacuum=addr_getfloat("@Vacuum")
760 + }
761 + local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"),
762 + ODPC = addr_getbit("@B_25395#W0.01"),
763 + MTPC=addr_getbit("@B_25395#W0.02"),
764 + HTT = addr_getbit("@B_25395#W1.03"),
765 + CPC = addr_getbit("@B_25395#W0.08"),
766 + CPSP =addr_getbit("@B_25395#W1.00"),
767 + CPVP =addr_getbit("@B_25395#W0.10"),
768 + CPRP =addr_getbit("@B_25395#W0.11"),
769 + HP =addr_getbit("@B_25395#W1.01"),
770 + PP= addr_getbit("@B_25395#W1.02"),
771 + PO=addr_getbit("@B_25395#W0.07"),
772 + FSE=addr_getbit("@B_25395#W2.04"),
773 + AVVSVV=addr_getbit("@B_25395#W1.12"),
774 + ICHT=addr_getbit("@B_25395#W3.06")
775 + }
776 + -- ("@B_25395#CIO1.02")
777 + mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0)
778 + mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0)
779 + else
780 + local stat, err = mq.m:connect(mq.config) -- connection
781 + if stat == nil then --Determine whether to connect
782 + print("mqtt connect failed:", err)
783 + return -- Connection failed, return directly
784 + end
785 + mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics
570 570  
571 -
572 -     local status_text ="unknow"
573 -     if addr_getbit("@Status Run")==1 then
574 -         status_text = "RUNNING"
575 -     else
576 -         status_text = "STOP"
577 -     end
578 --------------------------------------------------------------------------------------------------------------------------      
579 -
580 -     local js =  {type="status",
581 -                  mc_name ="FD300",
582 -                  status=status_text,
583 -                  elapsed_time={
584 -                                hour=addr_getword("@Elapsed Time (Hour)"),
585 -                                min=addr_getword("@Elapsed Time (Minute)"),
586 -                                sec=addr_getword("@Elapsed Time (Second)")
587 -                                },
588 -                   phase = phaseStatus,
589 -                   step = addr_getword("@Step"),
590 -                   activating_output = pr_activating,
591 -                   sv=addr_getshort("@SV Silicone")/10,
592 -                   pv=addr_getshort("@PV Silicone")/10,
593 -                   product1=addr_getshort("@Product 1")/10,
594 -
595 -                   product2=addr_getshort("@Product 2")/10,
596 -                   product3=addr_getshort("@Product 3")/10,
597 -                   product4=addr_getshort("@Product 4")/10,
598 -                   ice1=addr_getshort("@Ice condenser 1")/10,
599 -                   ice2=addr_getshort("@Ice condenser 2")/10,
600 -                   vacuum=addr_getfloat("@Vacuum")
601 -
602 -                }
603 -     local jsAlarm = {  HPC = addr_getbit("@B_25395#W0.00"),
604 -                        ODPC = addr_getbit("@B_25395#W0.01"),
605 -                        MTPC=addr_getbit("@B_25395#W0.02"),
606 -                        HTT = addr_getbit("@B_25395#W1.03"),
607 -                        CPC = addr_getbit("@B_25395#W0.08"),
608 -                        CPSP =addr_getbit("@B_25395#W1.00"),
609 -                        CPVP =addr_getbit("@B_25395#W0.10"),
610 -                        CPRP =addr_getbit("@B_25395#W0.11"),
611 -                        HP =addr_getbit("@B_25395#W1.01"),
612 -                        PP= addr_getbit("@B_25395#W1.02"),
613 -                        PO=addr_getbit("@B_25395#W0.07"),
614 -                        FSE=addr_getbit("@B_25395#W2.04"),
615 -                        AVVSVV=addr_getbit("@B_25395#W1.12"),
616 -                        ICHT=addr_getbit("@B_25395#W3.06")
617 -
618 -                }
619 -
620 -    -- ("@B_25395#CIO1.02")
621 -     mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0)
622 -     mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0)
623 -  else
624 -   local stat, err = mq.m:connect(mq.config) -- connection
625 -   if stat == nil then --Determine whether to connect
626 -    print("mqtt connect failed:", err)
627 -    return -- Connection failed, return directly
628 -   end
629 -   mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics
630 -
631 -  end
632 -  -- mq.m:unsubscribe("stc/test")
633 -  -- mq.m:disconnect() -- close matt
634 -  -- mq.m:close() -- close clase
635 - end
787 + end
788 + -- mq.m:unsubscribe("stc/test")
789 + -- mq.m:disconnect() -- close matt
790 + -- mq.m:close() -- close clase
791 + end
636 636  end
637 637  {{/code}}
638 638  
... ... @@ -1062,35 +1062,20 @@
1062 1062  
1063 1063  {{code language="java"}}
1064 1064  {
1065 -
1066 1066    "Version": "2012-10-17",
1067 -
1068 1068    "Statement": [
1069 -
1070 1070      {
1071 -
1072 1072        "Effect": "Allow",
1073 -
1074 1074        "Action": [
1075 -
1076 1076          "iot:Connect",
1077 -
1078 1078          "iot:Publish",
1079 -
1080 1080          "iot:Subscribe",
1081 -
1082 1082          "iot:Receive",
1083 -
1084 1084          "greengrass:Discover"
1085 -
1086 1086        ],
1087 -
1088 1088        "Resource": "*"
1089 -
1090 1090      }
1091 -
1092 1092    ]
1093 -
1094 1094  }
1095 1095  {{/code}}
1096 1096  
... ... @@ -1155,185 +1155,190 @@
1155 1155  
1156 1156  [[image:image-20220709165402-20.png]]
1157 1157  
1299 +{{info}}
1300 +**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701
1301 +{{/info}}
1302 +
1303 +{{code language="lua"}}
1158 1158  sprint = print
1159 1159  
1160 -~-~-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)
1306 +--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)
1161 1161  
1162 1162  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
1163 1163  
1164 -~-~-publish to topics
1310 +--publish to topics
1165 1165  
1166 1166  local pub_RE_TOPIC = string.format('TEST')
1167 1167  
1168 -~-~-Subscribe topics
1314 +--Subscribe topics
1169 1169  
1170 1170  local Subscribe_RE_TOPIC1 = string.format('TEST')
1171 1171  
1172 -~-~-variable
1318 +--variable
1173 1173  
1174 1174  local last_time = 0
1175 1175  
1176 -~-~-Timing main function
1322 +--Timing main function
1177 1177  
1178 1178  function aws.main()
1179 1179  
1180 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1326 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1181 1181  
1182 - if g_mq then
1328 + if g_mq then
1183 1183  
1184 - if g_mq:isconnected() then
1330 + if g_mq:isconnected() then
1185 1185  
1186 - send_Data()
1332 + send_Data()
1187 1187  
1188 - else
1334 + else
1189 1189  
1190 - if os.time() - last_time > 5 then
1336 + if os.time() - last_time > 5 then
1191 1191  
1192 - last_time = os.time()
1338 + last_time = os.time()
1193 1193  
1194 - mymqtt_connect()
1340 + mymqtt_connect()
1195 1195  
1342 + end
1343 +
1196 1196   end
1197 1197  
1198 - end
1346 + else
1199 1199  
1200 - else
1348 + mymqtt_init()
1201 1201  
1202 - mymqtt_init()
1350 + end
1203 1203  
1204 - end
1352 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1205 1205  
1206 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1207 -
1208 1208  end
1209 1209  
1210 1210  
1211 -~-~- Initialize MQTT
1212 1212  
1358 +-- Initialize MQTT
1359 +
1213 1213  function mymqtt_init()
1214 1214  
1215 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1362 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1216 1216  
1217 - g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
1364 + 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
1218 1218  
1219 - if g_mq then
1366 + if g_mq then
1220 1220  
1221 - g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1368 + g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1222 1222  
1223 - sprint("mqtt init success")
1370 + sprint("mqtt init success")
1224 1224  
1225 - else
1372 + else
1226 1226  
1227 - sprint("mqtt init failed:", err)
1374 + sprint("mqtt init failed:", err)
1228 1228  
1229 - end
1376 + end
1230 1230  
1231 1231  end
1232 1232  
1233 -~-~- Connect to MQTT server
1380 +-- Connect to MQTT server
1234 1234  
1235 1235  function mymqtt_connect()
1236 1236  
1237 - sprint("mqtt connecting...")
1384 + sprint("mqtt connecting...")
1238 1238  
1239 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1386 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1240 1240  
1241 - if stat == nil then
1388 + if stat == nil then
1242 1242  
1243 - sprint("mqtt connect failed:", err)
1390 + sprint("mqtt connect failed:", err)
1244 1244  
1245 - return
1392 + return
1246 1246  
1247 - else
1394 + else
1248 1248  
1249 - sprint("mqtt connected")
1396 + sprint("mqtt connected")
1250 1250  
1251 - end
1398 + end
1252 1252  
1253 - g_mq:subscribe(TEST, 0)
1400 + g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
1254 1254  
1255 1255  end
1256 1256  
1257 -~-~- Receive MQTT message callback function
1404 +-- Receive MQTT message callback function
1258 1258  
1259 1259  function mymqtt_msg_callback(topic, msg)
1260 1260  
1261 - print("topic:",topic)
1408 + print("topic:",topic)
1262 1262  
1263 - print("revdata:",msg)
1410 + print("revdata:",msg)
1264 1264  
1265 - local revData = json.decode(msg)
1412 + local revData = json.decode(msg)
1266 1266  
1267 - print (revData)
1414 + print (revData)
1268 1268  
1269 - if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1416 + if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1270 1270  
1271 -if string.match(topic,Subscribe_RE_TOPIC1) then
1418 + if string.match(topic,Subscribe_RE_TOPIC1) then
1272 1272  
1273 - ~-~-if revData ~~= nil then
1420 + --if revData ~= nil then
1274 1274  
1275 - for k,v in pairs (revData) do
1422 + for k,v in pairs (revData) do
1276 1276  
1277 - print("printing revdata after kv here")
1424 + print("printing revdata after kv here")
1278 1278  
1279 - print (k,v)
1426 + print (k,v)
1280 1280  
1281 - end
1428 + end
1282 1282  
1283 - print ("current state is",fanstate)
1430 + print ("current state is",fanstate)
1284 1284  
1285 - ~-~-end
1432 + --end
1286 1286  
1287 -end
1434 + end
1288 1288  
1289 -end
1436 + end
1290 1290  
1291 1291  end
1292 1292  
1293 1293  
1294 -~-~-Get real-time data
1295 1295  
1442 +--Get real-time data
1443 +
1296 1296  function getData()
1297 1297  
1298 - local jdata = {}
1446 + local jdata = {}
1299 1299  
1300 - local addr = bns_get_alldata()
1448 + local addr = bns_get_alldata()
1301 1301  
1302 - print(json.encode(addr))
1450 + print(json.encode(addr))
1303 1303  
1304 - for i,v in pairs(addr) do
1452 + for i,v in pairs(addr) do
1305 1305  
1306 - if v[2] == 1 then
1454 + if v[2] == 1 then
1307 1307  
1308 - jdata[v[3]] = v[4]
1456 + jdata[v[3]] = v[4]
1309 1309  
1310 - end
1458 + end
1311 1311  
1312 - end
1460 + end
1313 1313  
1314 - return jdata
1462 + return jdata
1315 1315  
1316 1316  end
1317 1317  
1318 -~-~-send data
1466 +--send data
1319 1319  
1320 1320  function send_Data()
1321 1321  
1322 - local pub_data =
1470 + local pub_data =
1471 + {
1472 + 123
1473 + }
1323 1323  
1324 - {
1325 -
1326 -123
1327 -
1328 -}
1329 -
1330 1330  sprint(json.encode(pub_data))
1331 1331  
1332 1332  print("..........",pub_RE_TOPIC)
1333 1333  
1334 - return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1479 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1335 1335  
1336 1336  end
1482 +{{/code}}
1337 1337  
1338 1338  Get message in AWS
1339 1339  
InputHTTPparameter.png
Author
... ... @@ -1,0 +1,1 @@
1 +XWiki.Hunter
Size
... ... @@ -1,0 +1,1 @@
1 +17.9 KB
Content