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 15.2
edited by Leo Wei
on 2022/07/09 17:46
Change comment: There is no comment for this version

Summary

Details

Page properties
Author
... ... @@ -1,1 +1,1 @@
1 -XWiki.Hunter
1 +XWiki.admin
Content
... ... @@ -13,7 +13,7 @@
13 13  for example. addr_setshort(addr,num) Function: Write 16-bit signed decimal address
14 14  addr_getshort(addr) Function:Read 16-bit signed decimal address
15 15  addr_getword(string addr)Function: Read 16-bit unsigned decimal address
16 -More script function are in the second section of [[“V-BOX Script Interface Manual”>>doc:V-BOX.V-Net.Manual.04 Lua Script.01 Lua Functions.WebHome]]
16 +More script function are in the second section of [[“V-BOX Script Interface Manual”>>doc:V-BOX.V-Net.1\.User Manual.04 Lua Script.01 Lua Functions.WebHome]]
17 17  
18 18  == **1.2 Arithmetic** ==
19 19  
... ... @@ -36,46 +36,39 @@
36 36  
37 37  Script is as below:
38 38  
39 -(% class="box infomessage" %)
40 -(((
39 +{{code language="Lua"}}
41 41  function sms.main()
42 -~-~-~-~-~-~-send condition~-~-~-~-~-~-
41 +------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~-~-~-~-~-~-
47 +------lasting time------
49 49  if temp1 > 5 and temp2 > 10 and temp3 < 20 then
50 - timer = timer + 1
51 - addr_setword("@Timer",timer)
49 + timer = timer + 1
50 + addr_setword("@Timer",timer)
52 52  else
53 - timer = 0
54 - addr_setword("@Timer",timer)
52 + timer = 0
53 + addr_setword("@Timer",timer)
55 55  end
56 -~-~-~-~-~-~-send sms & output Y0~-~-~-~-~-~-
55 +------send sms & output Y0------
57 57  if timer > 5 then
58 - if tag == 0 then
59 - send_sms_ira("19859254700","alarm trigger")
60 - addr_setbit("@Tag",1)
61 - end
57 + if tag == 0 then
58 + send_sms_ira("19859254700","alarm trigger")
59 + addr_setbit("@Tag",1)
60 + end
62 62  elseif tag == 1 then
63 63  send_sms_ira("19859254700","alarm release")
64 64  addr_setbit("@Tag",0)
65 65  end
66 66  end
67 -)))
66 +{{/code}}
68 68  
69 69  == **1.5 Telegram notification** ==
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
... ... @@ -141,210 +141,7 @@
141 141  end
142 142  {{/code}}
143 143  
144 -== **1.6 LINE Notify** ==
145 145  
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 -
148 -{{code}}
149 -local tempBit = 0
150 -local tempWord = 0
151 -
152 -local LineToken = "08XCpubkOdwGdGgRTXF0x8umiyrALtoM0v6lBFUV6PC"
153 -
154 -local https = require("https")
155 -local json = require("json")
156 -local ltn12 = require("ltn12")
157 -
158 --- Send http.get request and return response result
159 -function getHttpsUrl(url,header,reqbody)
160 - local body = {}
161 - local bodyJson = json.encode(body)
162 - local result_table, code, headers, status = https.request{
163 - method = "POST",
164 - url = url,
165 - source = ltn12.source.string(reqbody),
166 - headers = header,
167 - sink = ltn12.sink.table(body)
168 - }
169 - print("code:"..code)
170 - if code~= 200 then
171 - return
172 - else
173 - return body
174 - end
175 -end
176 -
177 -function getMessageUrl(lineMessage)
178 - local url = "https://notify-api.line.me/api/notify"
179 - local reqMess = "message="..lineMessage
180 - local headers =
181 - {
182 - ["Authorization"] = "Bearer "..LineToken,
183 - ["Content-Type"] = "application/x-www-form-urlencoded",
184 - ["Content-Length"] = #reqMess
185 - }
186 -
187 - print("Get the link:"..url)
188 - getHttpsUrl(url, headers, reqMess)
189 -end
190 -
191 -
192 -function linenotify.main()
193 - local bitValue = addr_getbit("@test");
194 - local message = ''
195 - print("b=="..bitValue)
196 - if bitValue == 1 and bitValue ~= tempBit then
197 - message = 'Alarm V-Box triggered, the output is '.. bitValue
198 - getMessageUrl(message)
199 - print("Notification pushed of triggering alarm,"..bitValue)
200 - elseif bitValue == 0 and bitValue ~= tempBit then
201 - message = 'Alarm V-Box dismissed, the output is '.. bitValue
202 - getMessageUrl(message)
203 - print("Notification pushed of dismissing alarm,"..bitValue)
204 - end
205 - tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform
206 -
207 - local wordValue = addr_getword("@t2")
208 - print("w=="..wordValue)
209 - --dosomething
210 - if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then
211 - message = 'Alarm V-Box triggered, the temperature is '.. wordValue
212 - getMessageUrl(message)
213 - print("Notification pushed of triggering alarm,"..wordValue)
214 - elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then
215 - message = 'Alarm V-Box dismissed, the temperature is '.. wordValue
216 - getMessageUrl(message)
217 - print("Notification pushed of dismissing alarm,"..wordValue)
218 - end
219 - tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform
220 -end
221 -{{/code}}
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 -{{code language="Lua"}}
228 -local tempBit = 0
229 -local tempWord = 0
230 -
231 -local https = require("https")
232 -local json = require("json")
233 -local ltn12 = require("ltn12")
234 -
235 -local SID = 'AC1703bd710ffa98006d2bcc0b********'
236 -local Token = 'd3c11897623c39e538b20263ec19****'
237 -
238 -local twilioPhoneNumber = '+14155238886'
239 -local receiverPhoneNumber = '+8615880018277'
240 -
241 -local b='ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/'
242 -function encodingBase64(data)
243 - return ((data:gsub('.', function(x)
244 - local r,b='',x:byte()
245 - for i=8,1,-1 do r=r..(b%2^i-b%2^(i-1)>0 and '1' or '0') end
246 - return r;
247 - end)..'0000'):gsub('%d%d%d?%d?%d?%d?', function(x)
248 - if (#x < 6) then return '' end
249 - local c=0
250 - for i=1,6 do c=c+(x:sub(i,i)=='1' and 2^(6-i) or 0) end
251 - return b:sub(c+1,c+1)
252 - end)..({ '', '==', '=' })[#data%3+1])
253 -end
254 -
255 -function encodeUrl(str)
256 - str = string.gsub(str, "([^%w%.%- ])", function(c)
257 - return string.format("%%%02X", string.byte(c)) end)
258 - return string.gsub(str, " ", "+")
259 -end
260 -
261 -
262 -
263 -
264 -function requestBodySplice(message, sender, receiver)
265 - local reqBody = ''
266 - local encodeMess = encodeUrl(message)
267 - local encodeSend = encodeUrl(sender)
268 - local encodeRece = encodeUrl(receiver)
269 - --reqBody = "Body=Hello%20Wecon2&From=whatsapp%3A%2B14155238886&To=whatsapp%3A%2B8615880018277"
270 - reqBody = string.format("Body=%s&From=whatsapp:%s&To=whatsapp:%s", encodeMess, encodeSend, encodeRece)
271 - print(reqBody)
272 - return reqBody
273 -end
274 -
275 -
276 --- Send http.get request and return response result
277 -function getHttpsUrl(url,header,reqbody)
278 - local body = {}
279 - local bodyJson = json.encode(body)
280 - local result_table, code, headers, status = https.request{
281 - method = "POST",
282 - url = url,
283 - source = ltn12.source.string(reqbody),
284 - headers = header,
285 - sink = ltn12.sink.table(body)
286 - }
287 - print("code:"..code)
288 - if code~= 200 then
289 - return
290 - else
291 - return body
292 - end
293 -end
294 -
295 -function getMessageUrl(whatsAppMessage)
296 - local auth = SID..':'..Token
297 - local url = "https://api.twilio.com/2010-04-01/Accounts/"..SID.."/Messages"
298 - --local reqMess = "message="..twilioMessage
299 - local reqMess = requestBodySplice(whatsAppMessage, twilioPhoneNumber, receiverPhoneNumber)
300 - local headers =
301 - {
302 - ["Authorization"] = "Basic "..encodingBase64(auth),
303 - ["Content-Type"] = "application/x-www-form-urlencoded",
304 - ["Content-Length"] = #reqMess
305 - }
306 -
307 - print("Get the link:"..url)
308 - getHttpsUrl(url, headers, reqMess)
309 -end
310 -
311 -
312 -
313 -function Twilio.main()
314 - --dosomething
315 - --local auth = SID..':'..Token
316 - --print(requestBodySplice("HelloWorld", twilioPhoneNumber, receiverPhoneNumber))
317 - --print(encodingBase64(auth))
318 - local bitValue = addr_getbit("@testBit");
319 - local message = ''
320 - print("b=="..bitValue)
321 - if bitValue == 1 and bitValue ~= tempBit then
322 - message = 'Alarm V-Box triggered, the output is '.. bitValue
323 - getMessageUrl(message)
324 - print("Notification pushed of triggering alarm,"..bitValue)
325 - elseif bitValue == 0 and bitValue ~= tempBit then
326 - message = 'Alarm V-Box dismissed, the output is '.. bitValue
327 - getMessageUrl(message)
328 - print("Notification pushed of dismissing alarm,"..bitValue)
329 - end
330 - tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform
331 -
332 - local wordValue = addr_getword("@testWord")
333 - print("w=="..wordValue)
334 - --dosomething
335 - if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then
336 - message = 'Alarm V-Box triggered, the temperature is '.. wordValue
337 - getMessageUrl(message)
338 - print("Notification pushed of triggering alarm,"..wordValue)
339 - elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then
340 - message = 'Alarm V-Box dismissed, the temperature is '.. wordValue
341 - getMessageUrl(message)
342 - print("Notification pushed of dismissing alarm,"..wordValue)
343 - end
344 - tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform
345 -end
346 -{{/code}}
347 -
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,137 +363,13 @@
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" %)
367 -**✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool.
156 +== **2.1 V-Box connect with customer server:grouprobotinfo.com** ==
368 368  
369 -(% class="wikigeneratedid" %)
370 -Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]**
371 -
372 -== **2.1 V-Box connect with test server(General Example)** ==
373 -
374 -{{code language="lua"}}
375 ---MQTT configuration table
376 -local MQTT_CFG={}
377 -MQTT_CFG.username = "weconsupport"
378 -MQTT_CFG.password = "123456"
379 -MQTT_CFG.netway = 0
380 -MQTT_CFG.keepalive = 60
381 -MQTT_CFG.cleansession = 1
382 ---TCP URL
383 -MQTT_URL = "tcp://mq.tongxinmao.com:1883"
384 ---Client ID
385 -MQTT_CLIENT_ID = "V-BOXH-AG"
386 -
387 ---Generate UUID
388 -function uuid()
389 - local seed = {'e','1','2','3','4','5','6','7','8','9','a','b','c','d','e','f'}
390 - local tb = {}
391 - for i=1, 32 do
392 - table.insert(tb, seed[math.random(1,16)])
393 - end
394 - local sid=table.concat(tb)
395 - return string.format('%s',
396 - string.sub(sid,1,32)
397 - )
398 -end
399 -
400 -
401 ---Topic name to subscribed
402 -local SUBSCRIBE_TOPIC = 'testtopic/test/no1/123456'
403 -
404 ---Topic name to be published
405 -local PUBLISH_TOPIC = 'testtopic/test/no1/7890'
406 -
407 -
408 ---real time
409 -local LAST_TIME = 0
410 -
411 -
412 ---initialize mqtt
413 -function mqtt_init()
414 - print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID))
415 - g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable
416 - if g_mq then
417 - g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages
418 - print("mqtt init success")
419 - else
420 - print("mqtt init failed:", err)
421 - end
422 -end
423 -
424 --- connect to mqtt
425 -function mqtt_connect()
426 - print("mqtt connecting...")
427 - local stat, err = g_mq:connect(MQTT_CFG)
428 - if stat == nil then
429 - print("mqtt connect failed:", err)
430 - return
431 - else
432 - print("mqtt connected")
433 - end
434 - g_mq:subscribe(SUBSCRIBE_TOPIC, 0)
435 -end
436 -
437 --- Received message callback function
438 -function mqtt_msg_callback(topic, msg)
439 - print("topic:", topic)
440 - print("msg:", msg)
441 - local objMsg = json.decode(msg)
442 - local water = objMsg.data.waterlevel
443 - local temp = objMsg.data.temperature
444 - addr_setword("@HDW20",water)
445 - addr_setword("@HDW10",temp)
446 -end
447 -
448 ---Send data (data upload to platform and encapsulate it with custom functions)
449 -function send_data()
450 - local pub_data = {
451 - timestamp = os.time(),
452 - messageId = 1,
453 - event = 'test_data',
454 - mfrs = 'V-Box',
455 - data = {
456 - id = uuid(),
457 - waterlevel = addr_getword("@HDW10"),
458 - temperature = addr_getword("@HDW20")
459 - }
460 - }
461 - return g_mq:publish(PUBLISH_TOPIC, json.encode(pub_data), 0, 0)
462 -end
463 -
464 -
465 ---main function fixed timed execution
466 -function MQTT.main()
467 - --dosomething
468 - print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main start")
469 - --determine the mqtt object whether exist
470 - if g_mq then
471 - --determine the mqtt object whether has been connected or not
472 - if g_mq:isconnected() then
473 - send_data()
474 - else
475 - --if exceed 20 sec not connect, reconnect once
476 - if os.time() - LAST_TIME > 20 then
477 - LAST_TIME = os.time()
478 - --connect to mqtt or reconnect
479 - mqtt_connect()
480 - end
481 - end
482 - else
483 - --mqtt object does not exist so create new one
484 - mqtt_init()
485 - end
486 - print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main end")
487 -end
488 -{{/code}}
489 -
490 -== **2.2 V-Box connect with customer server:grouprobotinfo.com** ==
491 -
492 492  This demo does not use SSL certification. Script is as below
493 493  
494 494  Demo1:
495 495  
496 -{{code language="lua"}}
162 +{{code language="Lua"}}
497 497  -- Meta class
498 498  --main
499 499  function mq.main()
... ... @@ -614,7 +614,7 @@
614 614                          FSE=addr_getbit("@B_25395#W2.04"),
615 615                          AVVSVV=addr_getbit("@B_25395#W1.12"),
616 616                          ICHT=addr_getbit("@B_25395#W3.06")
617 -
283 +  
618 618                  }
619 619  
620 620      -- ("@B_25395#CIO1.02")
... ... @@ -636,7 +636,7 @@
636 636  end
637 637  {{/code}}
638 638  
639 -== **2.3 V-Box connect with Azure platform** ==
305 +== **2.2 V-Box connect with Azure platform** ==
640 640  
641 641  In this demo,V-Box connects with Azure by SSL certification.
642 642  
... ... @@ -646,129 +646,137 @@
646 646  
647 647  Script is as below
648 648  
649 -(% class="box infomessage" %)
650 -(((
651 -~-~-https:~/~/support.huaweicloud.com/qs-IoT/iot_05_0005.html mqtt.fx monitor to connect azure iot
315 +{{code language="Lua"}}
316 +--https://support.huaweicloud.com/qs-IoT/iot_05_0005.html  mqtt.fx monitor to connect azure iot
652 652  sprint = print
653 653  
654 -~-~-Get custom configuration parameters (vbox custom information)
655 -~-~-local CUSTOM = bns_get_config("bind")
656 -~-~-local DS_ID = CUSTOM.DSID or "60a71ccbbbe12002c08f3a1a_WECON"
319 +--Get custom configuration parameters (vbox custom information)
320 +--local CUSTOM = bns_get_config("bind")
321 +--local DS_ID = CUSTOM.DSID or "60a71ccbbbe12002c08f3a1a_WECON"
657 657  
658 658  
659 -~-~-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)
324 +
325 +--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)
660 660  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
661 661  
662 -~-~-MQTT_CFG.username = '60a71ccbbbe12002c08f3a1a_WECON'
663 -~-~-MQTT_CFG.password='wecon123'
664 -~-~-MQTT_CLIENTID = '60a71ccbbbe12002c08f3a1a_WECON_0_0_2021052110usernxame:60a71ccbbbe12002c08f3a1a_WECONpassword:a0a951581855aa8e0262129da6cf1b43f2c0ecfac4fa56117fc5a20c90be169a'
328 +--MQTT_CFG.username = '60a71ccbbbe12002c08f3a1a_WECON'
329 +--MQTT_CFG.password='wecon123'
330 +--MQTT_CLIENTID = '60a71ccbbbe12002c08f3a1a_WECON_0_0_2021052110usernxame:60a71ccbbbe12002c08f3a1a_WECONpassword:a0a951581855aa8e0262129da6cf1b43f2c0ecfac4fa56117fc5a20c90be169a'
665 665  
666 -~-~-publish to topics
332 +--publish to topics
667 667  local pub_RE_TOPIC = string.format('devices/wecon_02/messages/events/')
668 -~-~-Subscribe topics
334 +--Subscribe topics
669 669  local Subscribe_RE_TOPIC1 = string.format('devices/wecon_02/messages/devicebound/#')
670 670  
671 -~-~-variable
337 +--variable
672 672  local last_time = 0
673 673  
674 674  
675 -~-~-Timing main function
341 +
342 +--Timing main function
676 676  function Azure.main()
677 677  
678 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main start")
679 - if g_mq then
680 - if g_mq:isconnected() then
681 - send_Data()
682 - else
683 - if os.time() - last_time > 20 then
684 - last_time = os.time()
685 - mymqtt_connect()
686 - end
687 - end
688 - else
689 - mymqtt_init()
690 - end
691 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main end")
345 +   sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main start")
346 +   if g_mq then
347 +        if g_mq:isconnected() then
348 +            send_Data()
349 +        else
350 +            if os.time() - last_time > 20 then
351 +                last_time = os.time()
352 +                mymqtt_connect()
353 +            end
354 +        end
355 +    else
356 +        mymqtt_init()
357 +    end
358 +    sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main end")
692 692  end
693 693  
694 -~-~- Initialize MQTT
361 +-- Initialize MQTT
695 695  function mymqtt_init()
696 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
697 - g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
698 - if g_mq then
699 - g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
700 - sprint("mqtt init success")
701 - else
702 - sprint("mqtt init failed:", err)
703 - end
363 +    sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
364 +    g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) -- Create the object and declare it as a global variable
365 +    if g_mq then
366 +        g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
367 +        sprint("mqtt init success")
368 +    else
369 +        sprint("mqtt init failed:", err)
370 +    end
704 704  end
705 705  
706 -~-~- Connect to MQTT server
373 +-- Connect to MQTT server
707 707  function mymqtt_connect()
708 - sprint("mqtt connecting...")
709 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
710 - if stat == nil then
711 - sprint("mqtt connect failed:", err)
712 - return
713 - else
714 - sprint("mqtt connected")
715 - end
716 - g_mq:subscribe(Subscribe_RE_TOPIC1, 0) 
375 +    sprint("mqtt connecting...")
376 +    local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
377 +    if stat == nil then
378 +        sprint("mqtt connect failed:", err)
379 +        return
380 +    else
381 +        sprint("mqtt connected")
382 +    end
383 +    g_mq:subscribe(Subscribe_RE_TOPIC1, 0) 
717 717  end
718 718  
719 -~-~- Receive MQTT message callback function
386 +-- Receive MQTT message callback function
720 720  function mymqtt_msg_callback(topic, msg)
721 - print("topic:",topic)
722 - print("revdata:",msg)
723 - ~-~- local revData = json.decode(msg)
724 - ~-~- if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
725 -~-~- if string.match(topic,Subscribe_RE_TOPIC1) then
726 - ~-~- print("topi11:",topic)
727 - setValue(revData)
728 - ~-~- end
388 +    print("topic:",topic)
389 +    print("revdata:",msg)
390 +   -- local revData = json.decode(msg)
391 + --  if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
392 +-- if string.match(topic,Subscribe_RE_TOPIC1) then
393 +     --   print("topi11:",topic)
394 +       setValue(revData)
395 +   -- end
729 729  end
730 730  
731 -~-~-Process the received data
732 -~-~-function setValue(revData)
733 - ~-~- if revData ~~=nil then 
734 - ~-~- for i,v in pairs(revData) do
735 - ~-~- print("Data received:",i,v)
736 - ~-~- end
737 - ~-~- end
738 -~-~-end
398 +--Process the received data
399 +--function setValue(revData)
400 +   -- if revData ~=nil then 
401 + --       for i,v in pairs(revData) do
402 +  --          print("Data received:",i,v)
403 +  --      end
404 +   -- end
405 +--end
739 739  
740 -~-~-Get real-time data
407 +--Get real-time data
741 741  function getData()
742 - local jdata = {}
743 - local addr = bns_get_alldata()
744 - print(json.encode(addr))
745 - for i,v in pairs(addr) do
746 - if v[2] == 1 then
747 - jdata[v[3]] = v[4]
748 - end
749 - end
750 - return jdata
751 -end
409 +    local jdata = {}
410 +    local addr = bns_get_alldata()
411 +    print(json.encode(addr))
412 +    for i,v in pairs(addr) do
413 +        if v[2] == 1 then
414 +           jdata[v[3]] = v[4]
415 +        end
416 +    end
417 +    return jdata
418 +end 
752 752  
753 753  
754 -~-~-send data
421 +
422 +--send data
755 755  function send_Data()
756 - local pub_data = {100
757 - ~-~- services=~{~{
758 -\\ ~-~-serviceId ='Temperature',
759 - ~-~- properties={
760 - ~-~- value = 55
761 - ~-~- },
762 - ~-~- }}
424 +    local pub_data = {100
425 +     --   services={{
426 +
427 +            --serviceId ='Temperature',
428 +           -- properties={
429 +               -- value = 55
430 +           -- },
431 +       -- }}
763 763  }
764 764  sprint(json.encode(pub_data))
765 765  print("..........",pub_RE_TOPIC)
766 - return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
435 +    return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
767 767  end
768 -)))
437 +{{/code}}
769 769  
770 -== **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)** ==
439 +== **2.3 How to configure the Huawei platform?** ==
771 771  
441 +(% class="box infomessage" %)
442 +(((
443 +✎Note: Huawei IOT DA function is only in China area.If you want this function,you need to use chinese mobile to register
444 +)))
445 +
772 772  1.Register a account: [[https:~~/~~/www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ>>https://www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ]]
773 773  
774 774  2.log in the Huawei IOTDA
... ... @@ -916,7 +916,7 @@
916 916  (% style="text-align:center" %)
917 917  [[image:1624441186851-536.png||height="434" width="700" class="img-thumbnail"]]
918 918  
919 -== **2.5 V-Box connect with Huawei platform** ==
593 +== **2.4 V-Box connect with Huawei platform** ==
920 920  
921 921  In this demo,V-Box connects with Huawei by SSL certification.
922 922  
... ... @@ -1037,7 +1037,7 @@
1037 1037  (% style="text-align:center" %)
1038 1038  [[image:1624506666650-161.png||height="547" width="1000" class="img-thumbnail"]]
1039 1039  
1040 -== **2.6 V-Box connect with AWS platform** ==
714 +== **2.5 V-Box connect with AWS platform** ==
1041 1041  
1042 1042  === **Log in AWS** ===
1043 1043  
... ... @@ -1094,67 +1094,99 @@
1094 1094  }
1095 1095  {{/code}}
1096 1096  
1097 -=== **Create things** ===
771 +1. **Create things**
1098 1098  
1099 1099  Click “Manage”~-~-->“Things”~-~-->“Create things”~-~-->“Create single thing”
1100 1100  
1101 -[[image:image-20220709165402-6.png]]
1102 1102  
1103 -[[image:image-20220709165402-7.png]]
776 +|
777 +| |[[image:image-20220709165402-6.png]]
1104 1104  
779 +|
780 +| |[[image:image-20220709165402-7.png]]
781 +
782 +|
783 +| |[[image:image-20220709165402-8.png]]
784 +
1105 1105  Name the thing~-~-->Click “Next”
1106 1106  
1107 -[[image:image-20220709165402-8.png]]
1108 1108  
1109 1109  Select the way to create certificate
1110 1110  
1111 -[[image:image-20220709165402-9.png]]
1112 1112  
791 +|
792 +| |[[image:image-20220709165402-9.png]]
793 +
1113 1113  Select policy
1114 1114  
1115 -[[image:image-20220709165402-10.png]]
1116 1116  
1117 -[[image:image-20220709165402-11.png]]
797 +|
798 +| |[[image:image-20220709165402-10.png]]
1118 1118  
1119 1119  
1120 -=== **Test with MQTT.fx tool** ===
1121 1121  
802 +
803 +
804 +|
805 +| |[[image:image-20220709165402-11.png]]
806 +
807 +
808 +1. **Test with MQTT.fx tool**
809 +
1122 1122  Click “View Setting” to get the “Broker Adress”
1123 1123  
1124 -[[image:image-20220709165402-13.png]]
1125 1125  
1126 -[[image:image-20220709165402-12.png]]
813 +|
814 +| |[[image:image-20220709165402-12.png]]
1127 1127  
1128 -Create one connection in MQTT.fx tool, set broker port as 8883.
816 +|
817 +| |[[image:image-20220709165402-13.png]]
1129 1129  
1130 -[[image:image-20220709165402-14.png]]
1131 1131  
820 +
821 +
822 +|
823 +| |[[image:image-20220709165402-14.png]]
824 +
825 +Create one connection in MQTT.fx tool, set broker port as 8883.
826 +
1132 1132  Upload the CA File, Client Certificate File, Client Key File
1133 1133  
1134 -[[image:image-20220709165402-15.png]]
1135 1135  
830 +|
831 +| |[[image:image-20220709165402-15.png]]
832 +
1136 1136  Publish message to topic “TEST”
1137 1137  
1138 -[[image:image-20220709165402-17.png]]
1139 1139  
1140 -Click”Test”~-~-->”MQTT test client”~-~-->”Subscrible to a topic”, to get message publish from MQTT.fx tool.
836 +|
837 +| |[[image:image-20220709165402-16.png]]
1141 1141  
1142 -[[image:image-20220709173500-1.png]]
839 +|
840 +| |[[image:image-20220709165402-17.png]]
1143 1143  
842 +Click”Test”~-~-->”MQTT test client”~-~-->”Subscrible to a topic”, to get message publish from MQTT.fx tool.
843 +
1144 1144  And we can also send message form AWS platform to MQTT.fx tool.
1145 1145  
1146 -[[image:image-20220709165402-18.png]]
1147 1147  
1148 -=== **Configurate in CloudTool** ===
847 +|
848 +| |[[image:image-20220709165402-18.png]]
1149 1149  
850 +1. **Configurate in CloudTool**
851 +
1150 1150  Copy the same setting in MQTT.fx to MQTT configuration
1151 1151  
1152 -[[image:image-20220709165402-19.png]]
1153 1153  
855 +|
856 +| |[[image:image-20220709165402-19.png]]
857 +
1154 1154   Add a lua script and copy the lua demo into it.
1155 1155  
1156 -[[image:image-20220709165402-20.png]]
1157 1157  
861 +|
862 +| |[[image:image-20220709165402-20.png]]
863 +
1158 1158  sprint = print
1159 1159  
1160 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)
... ... @@ -1335,6 +1335,10 @@
1335 1335  
1336 1336  end
1337 1337  
1044 +
1045 +
1338 1338  Get message in AWS
1339 1339  
1340 -[[image:image-20220709165402-21.png]]
1048 +
1049 +|
1050 +| |[[image:image-20220709165402-21.png]]
image-20220709173500-1.png
Author
... ... @@ -1,1 +1,0 @@
1 -XWiki.Jim
Size
... ... @@ -1,1 +1,0 @@
1 -1.5 MB
Content