Skip to Content

Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03
From version 42.1
edited by Hunter
on 2023/03/30 16:29
Change comment: There is no comment for this version
To version 22.1
edited by Hunter
on 2022/09/08 18:57
Change comment: There is no comment for this version

Summary

Details

Page properties
Content
... ... @@ -70,12 +70,6 @@
70 70  
71 71  This example shows how to use the Bot API to send message into Telegram group or channel. When monitoring bit "@HDX" changes, it will trigger and send the message. Please replace with your own Token and chat id.
72 72  
73 -As for How to get the botToken and chatID, please check the followig videos:
74 -
75 -[[https:~~/~~/www.youtube.com/watch?v=zh6yYlnjX7k>>https://www.youtube.com/watch?v=zh6yYlnjX7k]]
76 -
77 -[[https:~~/~~/www.youtube.com/watch?v=Pj8mwuMZZvg>>https://www.youtube.com/watch?v=Pj8mwuMZZvg]]
78 -
79 79  {{code language="Lua"}}
80 80  local tempBit = 0
81 81  local tempWord = 0
... ... @@ -220,247 +220,6 @@
220 220  end
221 221  {{/code}}
222 222  
223 -== **1.7 Twilio WhatsApp Messaging** ==
224 -
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 -
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 -
231 -{{code language="Lua"}}
232 -local tempBit = 0
233 -local tempWord = 0
234 -
235 -local https = require("https")
236 -local json = require("json")
237 -local ltn12 = require("ltn12")
238 -
239 -local SID = 'AC1703bd710ffa98006d2bcc0b********'
240 -local Token = 'd3c11897623c39e538b20263ec19****'
241 -
242 -local twilioPhoneNumber = '+14155238886'
243 -local receiverPhoneNumber = '+8615880018277'
244 -
245 -local b='ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/'
246 -function encodingBase64(data)
247 - return ((data:gsub('.', function(x)
248 - local r,b='',x:byte()
249 - for i=8,1,-1 do r=r..(b%2^i-b%2^(i-1)>0 and '1' or '0') end
250 - return r;
251 - end)..'0000'):gsub('%d%d%d?%d?%d?%d?', function(x)
252 - if (#x < 6) then return '' end
253 - local c=0
254 - for i=1,6 do c=c+(x:sub(i,i)=='1' and 2^(6-i) or 0) end
255 - return b:sub(c+1,c+1)
256 - end)..({ '', '==', '=' })[#data%3+1])
257 -end
258 -
259 -function encodeUrl(str)
260 - str = string.gsub(str, "([^%w%.%- ])", function(c)
261 - return string.format("%%%02X", string.byte(c)) end)
262 - return string.gsub(str, " ", "+")
263 -end
264 -
265 -
266 -
267 -
268 -function requestBodySplice(message, sender, receiver)
269 - local reqBody = ''
270 - local encodeMess = encodeUrl(message)
271 - local encodeSend = encodeUrl(sender)
272 - local encodeRece = encodeUrl(receiver)
273 - --reqBody = "Body=Hello%20Wecon2&From=whatsapp%3A%2B14155238886&To=whatsapp%3A%2B8615880018277"
274 - reqBody = string.format("Body=%s&From=whatsapp:%s&To=whatsapp:%s", encodeMess, encodeSend, encodeRece)
275 - print(reqBody)
276 - return reqBody
277 -end
278 -
279 -
280 --- Send http.get request and return response result
281 -function getHttpsUrl(url,header,reqbody)
282 - local body = {}
283 - local bodyJson = json.encode(body)
284 - local result_table, code, headers, status = https.request{
285 - method = "POST",
286 - url = url,
287 - source = ltn12.source.string(reqbody),
288 - headers = header,
289 - sink = ltn12.sink.table(body)
290 - }
291 - print("code:"..code)
292 - if code~= 200 then
293 - return
294 - else
295 - return body
296 - end
297 -end
298 -
299 -function getMessageUrl(whatsAppMessage)
300 - local auth = SID..':'..Token
301 - local url = "https://api.twilio.com/2010-04-01/Accounts/"..SID.."/Messages"
302 - --local reqMess = "message="..twilioMessage
303 - local reqMess = requestBodySplice(whatsAppMessage, twilioPhoneNumber, receiverPhoneNumber)
304 - local headers =
305 - {
306 - ["Authorization"] = "Basic "..encodingBase64(auth),
307 - ["Content-Type"] = "application/x-www-form-urlencoded",
308 - ["Content-Length"] = #reqMess
309 - }
310 -
311 - print("Get the link:"..url)
312 - getHttpsUrl(url, headers, reqMess)
313 -end
314 -
315 -
316 -
317 -function Twilio.main()
318 - --dosomething
319 - --local auth = SID..':'..Token
320 - --print(requestBodySplice("HelloWorld", twilioPhoneNumber, receiverPhoneNumber))
321 - --print(encodingBase64(auth))
322 - local bitValue = addr_getbit("@testBit");
323 - local message = ''
324 - print("b=="..bitValue)
325 - if bitValue == 1 and bitValue ~= tempBit then
326 - message = 'Alarm V-Box triggered, the output is '.. bitValue
327 - getMessageUrl(message)
328 - print("Notification pushed of triggering alarm,"..bitValue)
329 - elseif bitValue == 0 and bitValue ~= tempBit then
330 - message = 'Alarm V-Box dismissed, the output is '.. bitValue
331 - getMessageUrl(message)
332 - print("Notification pushed of dismissing alarm,"..bitValue)
333 - end
334 - tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform
335 -
336 - local wordValue = addr_getword("@testWord")
337 - print("w=="..wordValue)
338 - --dosomething
339 - if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then
340 - message = 'Alarm V-Box triggered, the temperature is '.. wordValue
341 - getMessageUrl(message)
342 - print("Notification pushed of triggering alarm,"..wordValue)
343 - elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then
344 - message = 'Alarm V-Box dismissed, the temperature is '.. wordValue
345 - getMessageUrl(message)
346 - print("Notification pushed of dismissing alarm,"..wordValue)
347 - end
348 - tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform
349 -end
350 -{{/code}}
351 -
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 -
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}}
235 +(% 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 5 sec not connect, reconnect once
621 - if os.time() - LAST_TIME > 5 then
344 + --if exceed 20 sec not connect, reconnect once
345 + 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
... ... @@ -644,134 +644,142 @@
644 644  -- Meta class
645 645  --main
646 646  function mq.main()
647 - if not mq.m then
648 - local err = ""
369 + if not mq.m then
370 +  local err = ""
649 649  
650 - mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection
651 - if mq.m then
652 - mq.config = {
653 - username = "",-- ID
654 - password = "",-- password
655 - netway = 1, -- Ethernet connection, WIFI=1
656 - -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds.
657 - -- cleansession = 0, -- Optional, keep session
658 - }
659 - mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks
660 - local str = string.format("%s:%s", topic, msg)
661 - -- print("mqtt msg:", str) -- Print out the received topics and content
662 - end)
663 - mq.m:on("offline", function (cause) -- Register for lost connection callbacks
664 - -- addr_setstring("@xxx", "cause"..(cause or " got nil"))
665 - end)
666 - mq.m:on("arrived", function() -- Registration for sending messages to callbacks
667 - print("msg arrived")
668 - end)
669 - else
670 - print("mqtt create failed:", err) -- Create object failed
671 - end
672 - else
673 - if mq.m:isconnected() then -- If online, post a message
674 - local phaseStatus ="unknow"
675 - if addr_getbit("@Standby")== 1 then
676 - phaseStatus = "Standby"
677 - elseif addr_getbit("@Pre-Freeze")==1 then
678 - phaseStatus= "Pre-Freeze"
679 - elseif addr_getbit("@Prepare")==1 then
680 - phaseStatus ="Prepare"
681 - elseif addr_getbit("@Primary Dry")==1 then
682 - phaseStatus = "Primary dry"
683 - elseif addr_getbit("@Secondary Dry")==1 then
684 - phaseStatus = "Secondary Dry"
685 - end
686 - --print(addr_getbit("@Primary Dry"))
372 +  mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID")  -- create connection
373 +  if mq.m then
374 +   mq.config = {
375 +    username = "",-- ID
376 +    password = "",-- password
377 +    netway = 1, -- Ethernet connection, WIFI=1
378 +    -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds.
379 +    -- cleansession = 0, -- Optional, keep session
380 +   }
381 +   mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks
382 +    local str = string.format("%s:%s", topic, msg)
383 +    -- print("mqtt msg:", str) -- Print out the received topics and content
384 +   end
385 +   )
386 +   mq.m:on("offline", function (cause) -- Register for lost connection callbacks
387 +    -- addr_setstring("@xxx", "cause"..(cause or " got nil"))
388 +   end)
389 +   mq.m:on("arrived", function() -- Registration for sending messages to callbacks 
390 +    print("msg arrived")
391 +   end)
392 +  else
393 +   print("mqtt create failed:", err) -- Create object failed
394 +  end
395 + else
396 +  if mq.m:isconnected() then -- If online, post a message
397 +     local phaseStatus ="unknow"
398 +     if addr_getbit("@Standby")== 1 then
399 +         phaseStatus = "Standby"
400 +     elseif addr_getbit("@Pre-Freeze")==1 then
401 +         phaseStatus= "Pre-Freeze"
402 +     elseif addr_getbit("@Prepare")==1 then
403 +         phaseStatus ="Prepare"
404 +     elseif addr_getbit("@Primary Dry")==1 then
405 +         phaseStatus = "Primary dry"
406 +     elseif addr_getbit("@Secondary Dry")==1 then
407 +         phaseStatus = "Secondary Dry"
408 +     end
409 +--   print(addr_getbit("@Primary Dry"))
687 687  -------------------------------------------------------------------------------------------------------------------------
688 - local activating ="unknow"
689 - if addr_getbit("@Compressor")==1 then
690 - activating = ",".."Compressor"
691 - end
692 - if addr_getbit("@Silicone Pump")==1 then
693 - activating = activating..",".."Silicone Pump"
694 - end
695 - if addr_getbit("@Vacuum Pump")==1 then
696 - activating = activating..",".."Vacuum Pump"
697 - end
698 - if addr_getbit("@Root Pump")==1 then
699 - activating = activating..",".."Root Pump"
700 - end
701 - if addr_getbit("@Heater")==1 then
702 - activating = activating..",".."Heater"
703 - end
704 - if addr_getbit("@Valve Silicone")==1 then
705 - activating = activating..",".."Valve Silicone"
706 - end
707 - if addr_getbit("@Valve Ice Condenser")==1 then
708 - activating = activating..",".."Valve Ice Condenser"
709 - end
710 - if addr_getbit("@Valve Vacuum Pump")==1 then
711 - activating = activating..",".."Valve Vacuum Pump"
712 - end
713 - local pr_activating =string.sub(activating,2)
714 - -- print(pr_activating)
715 - local status_text ="unknow"
716 - if addr_getbit("@Status Run")==1 then
717 - status_text = "RUNNING"
718 - else
719 - status_text = "STOP"
720 - end
721 --------------------------------------------------------------------------------------------------------------------------
722 - local js = {type="status",
723 - mc_name ="FD300",
724 - status=status_text,
725 - elapsed_time={
726 - hour=addr_getword("@Elapsed Time (Hour)"),
727 - min=addr_getword("@Elapsed Time (Minute)"),
728 - sec=addr_getword("@Elapsed Time (Second)")
729 - },
730 - phase = phaseStatus,
731 - step = addr_getword("@Step"),
732 - activating_output = pr_activating,
733 - sv=addr_getshort("@SV Silicone")/10,
734 - pv=addr_getshort("@PV Silicone")/10,
735 - product1=addr_getshort("@Product 1")/10,
411 +     local activating ="unknow"
412 +     if addr_getbit("@Compressor")==1 then
413 +         activating = ",".."Compressor"
414 +     end
415 +     if addr_getbit("@Silicone Pump")==1 then
416 +         activating = activating..",".."Silicone Pump"
417 +     end
418 +     if addr_getbit("@Vacuum Pump")==1 then
419 +         activating = activating..",".."Vacuum Pump"
420 +     end
421 +     if addr_getbit("@Root Pump")==1 then
422 +         activating = activating..",".."Root Pump"
423 +     end
424 +     if addr_getbit("@Heater")==1 then
425 +         activating = activating..",".."Heater"
426 +     end
427 +     if addr_getbit("@Valve Silicone")==1 then
428 +         activating = activating..",".."Valve Silicone"
429 +     end
430 +     if addr_getbit("@Valve Ice Condenser")==1 then
431 +         activating = activating..",".."Valve Ice Condenser"
432 +     end
433 +     if addr_getbit("@Valve Vacuum Pump")==1 then
434 +         activating = activating..",".."Valve Vacuum Pump"
435 +     end
436 +     local pr_activating =string.sub(activating,2)
437 +    --  print(pr_activating)  
736 736  
737 - product2=addr_getshort("@Product 2")/10,
738 - product3=addr_getshort("@Product 3")/10,
739 - product4=addr_getshort("@Product 4")/10,
740 - ice1=addr_getshort("@Ice condenser 1")/10,
741 - ice2=addr_getshort("@Ice condenser 2")/10,
742 - vacuum=addr_getfloat("@Vacuum")
743 - }
744 - local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"),
745 - ODPC = addr_getbit("@B_25395#W0.01"),
746 - MTPC=addr_getbit("@B_25395#W0.02"),
747 - HTT = addr_getbit("@B_25395#W1.03"),
748 - CPC = addr_getbit("@B_25395#W0.08"),
749 - CPSP =addr_getbit("@B_25395#W1.00"),
750 - CPVP =addr_getbit("@B_25395#W0.10"),
751 - CPRP =addr_getbit("@B_25395#W0.11"),
752 - HP =addr_getbit("@B_25395#W1.01"),
753 - PP= addr_getbit("@B_25395#W1.02"),
754 - PO=addr_getbit("@B_25395#W0.07"),
755 - FSE=addr_getbit("@B_25395#W2.04"),
756 - AVVSVV=addr_getbit("@B_25395#W1.12"),
757 - ICHT=addr_getbit("@B_25395#W3.06")
758 - }
759 - -- ("@B_25395#CIO1.02")
760 - mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0)
761 - mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0)
762 - else
763 - local stat, err = mq.m:connect(mq.config) -- connection
764 - if stat == nil then --Determine whether to connect
765 - print("mqtt connect failed:", err)
766 - return -- Connection failed, return directly
767 - end
768 - mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics
769 769  
770 - end
771 - -- mq.m:unsubscribe("stc/test")
772 - -- mq.m:disconnect() -- close matt
773 - -- mq.m:close() -- close clase
774 - end
440 +
441 +     local status_text ="unknow"
442 +     if addr_getbit("@Status Run")==1 then
443 +         status_text = "RUNNING"
444 +     else
445 +         status_text = "STOP"
446 +     end
447 +-------------------------------------------------------------------------------------------------------------------------      
448 +
449 +     local js =  {type="status",
450 +                  mc_name ="FD300",
451 +                  status=status_text,
452 +                  elapsed_time={
453 +                                hour=addr_getword("@Elapsed Time (Hour)"),
454 +                                min=addr_getword("@Elapsed Time (Minute)"),
455 +                                sec=addr_getword("@Elapsed Time (Second)")
456 +                                },
457 +                   phase = phaseStatus,
458 +                   step = addr_getword("@Step"),
459 +                   activating_output = pr_activating,
460 +                   sv=addr_getshort("@SV Silicone")/10,
461 +                   pv=addr_getshort("@PV Silicone")/10,
462 +                   product1=addr_getshort("@Product 1")/10,
463 +
464 +                   product2=addr_getshort("@Product 2")/10,
465 +                   product3=addr_getshort("@Product 3")/10,
466 +                   product4=addr_getshort("@Product 4")/10,
467 +                   ice1=addr_getshort("@Ice condenser 1")/10,
468 +                   ice2=addr_getshort("@Ice condenser 2")/10,
469 +                   vacuum=addr_getfloat("@Vacuum")
470 +
471 +                }
472 +     local jsAlarm = {  HPC = addr_getbit("@B_25395#W0.00"),
473 +                        ODPC = addr_getbit("@B_25395#W0.01"),
474 +                        MTPC=addr_getbit("@B_25395#W0.02"),
475 +                        HTT = addr_getbit("@B_25395#W1.03"),
476 +                        CPC = addr_getbit("@B_25395#W0.08"),
477 +                        CPSP =addr_getbit("@B_25395#W1.00"),
478 +                        CPVP =addr_getbit("@B_25395#W0.10"),
479 +                        CPRP =addr_getbit("@B_25395#W0.11"),
480 +                        HP =addr_getbit("@B_25395#W1.01"),
481 +                        PP= addr_getbit("@B_25395#W1.02"),
482 +                        PO=addr_getbit("@B_25395#W0.07"),
483 +                        FSE=addr_getbit("@B_25395#W2.04"),
484 +                        AVVSVV=addr_getbit("@B_25395#W1.12"),
485 +                        ICHT=addr_getbit("@B_25395#W3.06")
486 +
487 +                }
488 +
489 +    -- ("@B_25395#CIO1.02")
490 +     mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0)
491 +     mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0)
492 +  else
493 +   local stat, err = mq.m:connect(mq.config) -- connection
494 +   if stat == nil then --Determine whether to connect
495 +    print("mqtt connect failed:", err)
496 +    return -- Connection failed, return directly
497 +   end
498 +   mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics
499 +
500 +  end
501 +  -- mq.m:unsubscribe("stc/test")
502 +  -- mq.m:disconnect() -- close matt
503 +  -- mq.m:close() -- close clase
504 + end
775 775  end
776 776  {{/code}}
777 777  
... ... @@ -1201,20 +1201,35 @@
1201 1201  
1202 1202  {{code language="java"}}
1203 1203  {
934 +
1204 1204    "Version": "2012-10-17",
936 +
1205 1205    "Statement": [
938 +
1206 1206      {
940 +
1207 1207        "Effect": "Allow",
942 +
1208 1208        "Action": [
944 +
1209 1209          "iot:Connect",
946 +
1210 1210          "iot:Publish",
948 +
1211 1211          "iot:Subscribe",
950 +
1212 1212          "iot:Receive",
952 +
1213 1213          "greengrass:Discover"
954 +
1214 1214        ],
956 +
1215 1215        "Resource": "*"
958 +
1216 1216      }
960 +
1217 1217    ]
962 +
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)
1029 +~-~-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
1033 +~-~-publish to topics
1294 1294  
1295 1295  local pub_RE_TOPIC = string.format('TEST')
1296 1296  
1297 ---Subscribe topics
1037 +~-~-Subscribe topics
1298 1298  
1299 1299  local Subscribe_RE_TOPIC1 = string.format('TEST')
1300 1300  
1301 ---variable
1041 +~-~-variable
1302 1302  
1303 1303  local last_time = 0
1304 1304  
1305 ---Timing main function
1045 +~-~-Timing main function
1306 1306  
1307 1307  function aws.main()
1308 1308  
1309 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1049 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1310 1310  
1311 - if g_mq then
1051 + if g_mq then
1312 1312  
1313 - if g_mq:isconnected() then
1053 + if g_mq:isconnected() then
1314 1314  
1315 - send_Data()
1055 + send_Data()
1316 1316  
1317 - else
1057 + else
1318 1318  
1319 - if os.time() - last_time > 5 then
1059 + if os.time() - last_time > 5 then
1320 1320  
1321 - last_time = os.time()
1061 + last_time = os.time()
1322 1322  
1323 - mymqtt_connect()
1063 + mymqtt_connect()
1324 1324  
1325 - end
1326 -
1327 1327   end
1328 1328  
1329 - else
1067 + end
1330 1330  
1331 - mymqtt_init()
1069 + else
1332 1332  
1333 - end
1071 + mymqtt_init()
1334 1334  
1335 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1073 + end
1336 1336  
1075 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1076 +
1337 1337  end
1338 1338  
1339 1339  
1080 +~-~- Initialize MQTT
1340 1340  
1341 --- Initialize MQTT
1342 -
1343 1343  function mymqtt_init()
1344 1344  
1345 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1084 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1346 1346  
1347 - 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
1086 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
1348 1348  
1349 - if g_mq then
1088 + if g_mq then
1350 1350  
1351 - g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1090 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1352 1352  
1353 - sprint("mqtt init success")
1092 + sprint("mqtt init success")
1354 1354  
1355 - else
1094 + else
1356 1356  
1357 - sprint("mqtt init failed:", err)
1096 + sprint("mqtt init failed:", err)
1358 1358  
1359 - end
1098 + end
1360 1360  
1361 1361  end
1362 1362  
1363 --- Connect to MQTT server
1102 +~-~- Connect to MQTT server
1364 1364  
1365 1365  function mymqtt_connect()
1366 1366  
1367 - sprint("mqtt connecting...")
1106 + sprint("mqtt connecting...")
1368 1368  
1369 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1108 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1370 1370  
1371 - if stat == nil then
1110 + if stat == nil then
1372 1372  
1373 - sprint("mqtt connect failed:", err)
1112 + sprint("mqtt connect failed:", err)
1374 1374  
1375 - return
1114 + return
1376 1376  
1377 - else
1116 + else
1378 1378  
1379 - sprint("mqtt connected")
1118 + sprint("mqtt connected")
1380 1380  
1381 - end
1120 + end
1382 1382  
1383 - g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
1122 + g_mq:subscribe(TEST, 0)
1384 1384  
1385 1385  end
1386 1386  
1387 --- Receive MQTT message callback function
1126 +~-~- Receive MQTT message callback function
1388 1388  
1389 1389  function mymqtt_msg_callback(topic, msg)
1390 1390  
1391 - print("topic:",topic)
1130 + print("topic:",topic)
1392 1392  
1393 - print("revdata:",msg)
1132 + print("revdata:",msg)
1394 1394  
1395 - local revData = json.decode(msg)
1134 + local revData = json.decode(msg)
1396 1396  
1397 - print (revData)
1136 + print (revData)
1398 1398  
1399 - if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1138 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1400 1400  
1401 - if string.match(topic,Subscribe_RE_TOPIC1) then
1140 +if string.match(topic,Subscribe_RE_TOPIC1) then
1402 1402  
1403 - --if revData ~= nil then
1142 + ~-~-if revData ~~= nil then
1404 1404  
1405 - for k,v in pairs (revData) do
1144 + for k,v in pairs (revData) do
1406 1406  
1407 - print("printing revdata after kv here")
1146 + print("printing revdata after kv here")
1408 1408  
1409 - print (k,v)
1148 + print (k,v)
1410 1410  
1411 - end
1150 + end
1412 1412  
1413 - print ("current state is",fanstate)
1152 + print ("current state is",fanstate)
1414 1414  
1415 - --end
1154 + ~-~-end
1416 1416  
1417 - end
1156 +end
1418 1418  
1419 - end
1158 +end
1420 1420  
1421 1421  end
1422 1422  
1423 1423  
1163 +~-~-Get real-time data
1424 1424  
1425 ---Get real-time data
1426 -
1427 1427  function getData()
1428 1428  
1429 - local jdata = {}
1167 + local jdata = {}
1430 1430  
1431 - local addr = bns_get_alldata()
1169 + local addr = bns_get_alldata()
1432 1432  
1433 - print(json.encode(addr))
1171 + print(json.encode(addr))
1434 1434  
1435 - for i,v in pairs(addr) do
1173 + for i,v in pairs(addr) do
1436 1436  
1437 - if v[2] == 1 then
1175 + if v[2] == 1 then
1438 1438  
1439 - jdata[v[3]] = v[4]
1177 + jdata[v[3]] = v[4]
1440 1440  
1441 - end
1179 + end
1442 1442  
1443 - end
1181 + end
1444 1444  
1445 - return jdata
1183 + return jdata
1446 1446  
1447 1447  end
1448 1448  
1449 ---send data
1187 +~-~-send data
1450 1450  
1451 1451  function send_Data()
1452 1452  
1453 - local pub_data =
1454 - {
1455 - 123
1456 - }
1191 + local pub_data =
1457 1457  
1193 + {
1194 +
1195 +123
1196 +
1197 +}
1198 +
1458 1458  sprint(json.encode(pub_data))
1459 1459  
1460 1460  print("..........",pub_RE_TOPIC)
1461 1461  
1462 - return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1203 + 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  
InputHTTPparameter.png
Author
... ... @@ -1,1 +1,0 @@
1 -XWiki.Hunter
Size
... ... @@ -1,1 +1,0 @@
1 -17.9 KB
Content