Skip to Content

Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03
From version 18.1
edited by Stone Wu
on 2022/07/25 11:32
Change comment: Renamed back-links.
To version 51.1
edited by Hunter
on 2023/05/06 10:19
Change comment: There is no comment for this version

Summary

Details

Page properties
Author
... ... @@ -1,1 +1,1 @@
1 -XWiki.Stone
1 +XWiki.Hunter
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.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.Manual.04 Lua Script.01 Lua Functions.WebHome]]
17 17  
18 18  == **1.2 Arithmetic** ==
19 19  
... ... @@ -27,25 +27,19 @@
27 27  
28 28  == **1.4 Short message** ==
29 29  
30 -When the alarm condition is reached: temp1 > 5 & temp2 >10 & temp3 < 20(lasts more than 5 seconds) , then send an "alarm trigger" sms.
30 +The following demo shows that when the alarm condition is reached: temp1 > 5 & temp2 >10 & temp3 < 20(lasts more than 5 seconds) , then send an "alarm trigger" sms.
31 31  
32 -When the alarm condition is released，then send an "alarm release" sms.
32 +When the alarm condition is released，then send an  "alarm release" sms. Script is as below:
33 33  
34 -(% style="text-align:center" %)
35 -[[image:1645535936750-316.png||height="385" width="400" class="img-thumbnail"]]
36 -
37 -Script is as below:
38 -
39 -(% class="box infomessage" %)
40 -(((
34 +{{code language="lua"}}
41 41  function sms.main()
42 -~-~-~-~-~-~-send condition~-~-~-~-~-~-
36 +------send condition------
43 43  local temp1 = addr_getword("@Temperature1")
44 44  local temp2 = addr_getword("@Temperature2")
45 45  local temp3 = addr_getword("@Temperature3")
46 46  local timer = addr_getword("@Timer")
47 47  local tag = addr_getbit("@Tag")
48 -~-~-~-~-~-~-lasting time~-~-~-~-~-~-
42 +------lasting time------
49 49  if temp1 > 5 and temp2 > 10 and temp3 < 20 then
50 50   timer = timer + 1
51 51   addr_setword("@Timer",timer)
... ... @@ -53,7 +53,7 @@
53 53   timer = 0
54 54   addr_setword("@Timer",timer)
55 55  end
56 -~-~-~-~-~-~-send sms & output Y0~-~-~-~-~-~-
50 +------send sms & output Y0------
57 57  if timer > 5 then
58 58   if tag == 0 then
59 59   send_sms_ira("19859254700","alarm trigger")
... ... @@ -64,12 +64,18 @@
64 64  addr_setbit("@Tag",0)
65 65  end
66 66  end
67 -)))
61 +{{/code}}
68 68  
69 69  == **1.5 Telegram notification** ==
70 70  
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  
67 +As for How to get the botToken and chatID, please check the followig videos:
68 +
69 +[[https:~~/~~/www.youtube.com/watch?v=zh6yYlnjX7k>>https://www.youtube.com/watch?v=zh6yYlnjX7k]]
70 +
71 +[[https:~~/~~/www.youtube.com/watch?v=Pj8mwuMZZvg>>https://www.youtube.com/watch?v=Pj8mwuMZZvg]]
72 +
73 73  {{code language="Lua"}}
74 74  local tempBit = 0
75 75  local tempWord = 0
... ... @@ -135,7 +135,343 @@
135 135  end
136 136  {{/code}}
137 137  
138 +== **1.6 LINE Notify** ==
138 138  
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 +
142 +{{code language="lua"}}
143 +local tempBit = 0
144 +local tempWord = 0
145 +
146 +local LineToken = "08XCpubkOdwGdGgRTXF0x8umiyrALtoM0v6lBFUV6PC"
147 +
148 +local https = require("https")
149 +local json = require("json")
150 +local ltn12 = require("ltn12")
151 +
152 +-- Send http.get request and return response result
153 +function getHttpsUrl(url,header,reqbody)
154 + local body = {}
155 + local bodyJson = json.encode(body)
156 + local result_table, code, headers, status = https.request{
157 + method = "POST",
158 + url = url,
159 + source = ltn12.source.string(reqbody),
160 + headers = header,
161 + sink = ltn12.sink.table(body)
162 + }
163 + print("code:"..code)
164 + if code~= 200 then
165 + return
166 + else
167 + return body
168 + end
169 +end
170 +
171 +function getMessageUrl(lineMessage)
172 + local url = "https://notify-api.line.me/api/notify"
173 + local reqMess = "message="..lineMessage
174 + local headers =
175 + {
176 + ["Authorization"] = "Bearer "..LineToken,
177 + ["Content-Type"] = "application/x-www-form-urlencoded",
178 + ["Content-Length"] = #reqMess
179 + }
180 +
181 + print("Get the link:"..url)
182 + getHttpsUrl(url, headers, reqMess)
183 +end
184 +
185 +
186 +function linenotify.main()
187 + local bitValue = addr_getbit("@test");
188 + local message = ''
189 + print("b=="..bitValue)
190 + if bitValue == 1 and bitValue ~= tempBit then
191 + message = 'Alarm V-Box triggered, the output is '.. bitValue
192 + getMessageUrl(message)
193 + print("Notification pushed of triggering alarm,"..bitValue)
194 + elseif bitValue == 0 and bitValue ~= tempBit then
195 + message = 'Alarm V-Box dismissed, the output is '.. bitValue
196 + getMessageUrl(message)
197 + print("Notification pushed of dismissing alarm,"..bitValue)
198 + end
199 + tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform
200 +
201 + local wordValue = addr_getword("@t2")
202 + print("w=="..wordValue)
203 + --dosomething
204 + if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then
205 + message = 'Alarm V-Box triggered, the temperature is '.. wordValue
206 + getMessageUrl(message)
207 + print("Notification pushed of triggering alarm,"..wordValue)
208 + elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then
209 + message = 'Alarm V-Box dismissed, the temperature is '.. wordValue
210 + getMessageUrl(message)
211 + print("Notification pushed of dismissing alarm,"..wordValue)
212 + end
213 + tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform
214 +end
215 +{{/code}}
216 +
217 +== **1.7 Twilio WhatsApp Messaging** ==
218 +
219 +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.
220 +
221 +About how to register the Twilio API, please check the following video:
222 +
223 +[[https:~~/~~/www.youtube.com/watch?v=Id4lKichauU>>https://www.youtube.com/watch?v=Id4lKichauU]]
224 +
225 +{{code language="Lua"}}
226 +local tempBit = 0
227 +local tempWord = 0
228 +
229 +local https = require("https")
230 +local json = require("json")
231 +local ltn12 = require("ltn12")
232 +
233 +local SID = 'AC1703bd710ffa98006d2bcc0b********'
234 +local Token = 'd3c11897623c39e538b20263ec19****'
235 +
236 +local twilioPhoneNumber = '+14155238886'
237 +local receiverPhoneNumber = '+8615880018277'
238 +
239 +local b='ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/'
240 +function encodingBase64(data)
241 + return ((data:gsub('.', function(x)
242 + local r,b='',x:byte()
243 + for i=8,1,-1 do r=r..(b%2^i-b%2^(i-1)>0 and '1' or '0') end
244 + return r;
245 + end)..'0000'):gsub('%d%d%d?%d?%d?%d?', function(x)
246 + if (#x < 6) then return '' end
247 + local c=0
248 + for i=1,6 do c=c+(x:sub(i,i)=='1' and 2^(6-i) or 0) end
249 + return b:sub(c+1,c+1)
250 + end)..({ '', '==', '=' })[#data%3+1])
251 +end
252 +
253 +function encodeUrl(str)
254 + str = string.gsub(str, "([^%w%.%- ])", function(c)
255 + return string.format("%%%02X", string.byte(c)) end)
256 + return string.gsub(str, " ", "+")
257 +end
258 +
259 +
260 +
261 +
262 +function requestBodySplice(message, sender, receiver)
263 + local reqBody = ''
264 + local encodeMess = encodeUrl(message)
265 + local encodeSend = encodeUrl(sender)
266 + local encodeRece = encodeUrl(receiver)
267 + --reqBody = "Body=Hello%20Wecon2&From=whatsapp%3A%2B14155238886&To=whatsapp%3A%2B8615880018277"
268 + reqBody = string.format("Body=%s&From=whatsapp:%s&To=whatsapp:%s", encodeMess, encodeSend, encodeRece)
269 + print(reqBody)
270 + return reqBody
271 +end
272 +
273 +
274 +-- Send http.get request and return response result
275 +function getHttpsUrl(url,header,reqbody)
276 + local body = {}
277 + local bodyJson = json.encode(body)
278 + local result_table, code, headers, status = https.request{
279 + method = "POST",
280 + url = url,
281 + source = ltn12.source.string(reqbody),
282 + headers = header,
283 + sink = ltn12.sink.table(body)
284 + }
285 + print("code:"..code)
286 + if code~= 200 then
287 + return
288 + else
289 + return body
290 + end
291 +end
292 +
293 +function getMessageUrl(whatsAppMessage)
294 + local auth = SID..':'..Token
295 + local url = "https://api.twilio.com/2010-04-01/Accounts/"..SID.."/Messages"
296 + --local reqMess = "message="..twilioMessage
297 + local reqMess = requestBodySplice(whatsAppMessage, twilioPhoneNumber, receiverPhoneNumber)
298 + local headers =
299 + {
300 + ["Authorization"] = "Basic "..encodingBase64(auth),
301 + ["Content-Type"] = "application/x-www-form-urlencoded",
302 + ["Content-Length"] = #reqMess
303 + }
304 +
305 + print("Get the link:"..url)
306 + getHttpsUrl(url, headers, reqMess)
307 +end
308 +
309 +
310 +
311 +function Twilio.main()
312 + --dosomething
313 + --local auth = SID..':'..Token
314 + --print(requestBodySplice("HelloWorld", twilioPhoneNumber, receiverPhoneNumber))
315 + --print(encodingBase64(auth))
316 + local bitValue = addr_getbit("@testBit");
317 + local message = ''
318 + print("b=="..bitValue)
319 + if bitValue == 1 and bitValue ~= tempBit then
320 + message = 'Alarm V-Box triggered, the output is '.. bitValue
321 + getMessageUrl(message)
322 + print("Notification pushed of triggering alarm,"..bitValue)
323 + elseif bitValue == 0 and bitValue ~= tempBit then
324 + message = 'Alarm V-Box dismissed, the output is '.. bitValue
325 + getMessageUrl(message)
326 + print("Notification pushed of dismissing alarm,"..bitValue)
327 + end
328 + tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform
329 +
330 + local wordValue = addr_getword("@testWord")
331 + print("w=="..wordValue)
332 + --dosomething
333 + if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then
334 + message = 'Alarm V-Box triggered, the temperature is '.. wordValue
335 + getMessageUrl(message)
336 + print("Notification pushed of triggering alarm,"..wordValue)
337 + elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then
338 + message = 'Alarm V-Box dismissed, the temperature is '.. wordValue
339 + getMessageUrl(message)
340 + print("Notification pushed of dismissing alarm,"..wordValue)
341 + end
342 + tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform
343 +end
344 +{{/code}}
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 +
139 139  = **2 V-Box connect with third part server** =
140 140  
141 141  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.
... ... @@ -154,149 +154,303 @@
154 154  
155 155  (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate
156 156  
157 -== **2.1 V-Box connect with customer server:grouprobotinfo.com** ==
493 +{{info}}
494 +**✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool.
495 +{{/info}}
158 158  
497 +(% class="wikigeneratedid" %)
498 +Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]**
499 +
500 +== **2.1 V-Box connect with test server(General Example)** ==
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 +{{code language="lua"}}
522 +--MQTT configuration table
523 +local MQTT_CFG={}
524 +MQTT_CFG.username = "weconsupport"
525 +MQTT_CFG.password = "123456"
526 +MQTT_CFG.netway = 0
527 +MQTT_CFG.keepalive = 60
528 +MQTT_CFG.cleansession = 1
529 +--TCP URL
530 +MQTT_URL = "tcp://mq.tongxinmao.com:1883"
531 +--Client ID
532 +MQTT_CLIENT_ID = "V-BOXH-AG"
533 +
534 +--Generate UUID
535 +function uuid()
536 + local seed = {'e','1','2','3','4','5','6','7','8','9','a','b','c','d','e','f'}
537 + local tb = {}
538 + for i=1, 32 do
539 + table.insert(tb, seed[math.random(1,16)])
540 + end
541 + local sid=table.concat(tb)
542 + return string.format('%s',
543 + string.sub(sid,1,32)
544 + )
545 +end
546 +
547 +
548 +--Topic name to subscribed
549 +local SUBSCRIBE_TOPIC = 'testtopic/test/no1/123456'
550 +
551 +--Topic name to be published
552 +local PUBLISH_TOPIC = 'testtopic/test/no1/7890'
553 +
554 +
555 +--real time
556 +local LAST_TIME = 0
557 +
558 +
559 +--initialize mqtt
560 +function mqtt_init()
561 + print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID))
562 + if g_mq then
563 + mqtt.close() --Close mqtt object
564 + end
565 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable
566 + if g_mq then
567 + g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages
568 + g_mq:on("offline", mqtt_msg_offline) -- Register a callback for offline
569 + print("mqtt init success")
570 + else
571 + print("mqtt init failed:", err)
572 + end
573 +end
574 +
575 +-- connect to mqtt
576 +function mqtt_connect()
577 + print("mqtt connecting...")
578 + local stat, err = g_mq:connect(MQTT_CFG)
579 + if stat == nil then
580 + print("mqtt connect failed:", err)
581 + return
582 + else
583 + print("mqtt connected")
584 + end
585 + g_mq:subscribe(SUBSCRIBE_TOPIC, 0)
586 +end
587 +
588 +--Offline callback function
589 +function mqtt_msg_offline(cause)
590 + print("mqtt offline, cause:", cause)
591 +end
592 +
593 +-- Received message callback function
594 +function mqtt_msg_callback(topic, msg)
595 + print("topic:", topic)
596 + print("msg:", msg)
597 + local objMsg = json.decode(msg)
598 + local water = objMsg.data.waterlevel
599 + local temp = objMsg.data.temperature
600 + addr_setword("@HDW20",water)
601 + addr_setword("@HDW10",temp)
602 +end
603 +
604 +--Send data (data upload to platform and encapsulate it with custom functions)
605 +function send_data()
606 + local pub_data = {
607 + timestamp = os.time(),
608 + messageId = 1,
609 + event = 'test_data',
610 + mfrs = 'V-Box',
611 + data = {
612 + id = uuid(),
613 + waterlevel = addr_getword("@HDW10"),
614 + temperature = addr_getword("@HDW20")
615 + }
616 + }
617 + return g_mq:publish(PUBLISH_TOPIC, json.encode(pub_data), 0, 0)
618 +end
619 +
620 +
621 +--main function fixed timed execution
622 +function MQTT.main()
623 + --dosomething
624 + print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main start")
625 + --determine the mqtt object whether exist
626 + if g_mq then
627 + --determine the mqtt object whether has been connected or not
628 + if g_mq:isconnected() then
629 + send_data()
630 + else
631 + --if exceed 5 sec not connect, reconnect once
632 + if os.time() - LAST_TIME > 5 then
633 + LAST_TIME = os.time()
634 + --reinitial the mqtt object
635 + mqtt_init()
636 + --connect to mqtt or reconnect
637 + mqtt_connect()
638 + end
639 + end
640 + else
641 + --mqtt object does not exist so create new one
642 + mqtt_init()
643 + end
644 + print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main end")
645 +end
646 +{{/code}}
647 +
648 +== **2.2 V-Box connect with customer server:grouprobotinfo.com** ==
649 +
159 159  This demo does not use SSL certification. Script is as below
160 160  
161 161  Demo1:
162 162  
163 -(% class="box infomessage" %)
164 -(((
165 -~-~- Meta class
166 -~-~-main
654 +{{code language="lua"}}
655 +-- Meta class
656 +--main
167 167  function mq.main()
168 168   if not mq.m then
169 169   local err = ""
170 -\\ mq.m, err = mqtt.create("tcp:~/~/grouprobotinfo.com:1883", "ClienID") ~-~- create connection
660 +
661 + mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection
171 171   if mq.m then
172 172   mq.config = {
173 - username = "",~-~- ID
174 - password = "",~-~- password
175 - netway = 1, ~-~- Ethernet connection, WIFI=1
176 - ~-~- keepalive = 100, ~-~- Optional, set the connection heartbeat interval for 100 seconds.
177 - ~-~- cleansession = 0, ~-~- Optional, keep session
664 + username = "",-- ID
665 + password = "",-- password
666 + netway = 1, -- Ethernet connection, WIFI=1
667 + -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds.
668 + -- cleansession = 0, -- Optional, keep session
178 178   }
179 - mq.m:on("message", function(topic, msg) ~-~- Register for receiving message callbacks
670 + mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks
180 180   local str = string.format("%s:%s", topic, msg)
181 - ~-~- print("mqtt msg:", str) ~-~- Print out the received topics and content
182 - end
183 - )
184 - mq.m:on("offline", function (cause) ~-~- Register for lost connection callbacks
185 - ~-~- addr_setstring("@xxx", "cause"..(cause or " got nil"))
672 + -- print("mqtt msg:", str) -- Print out the received topics and content
186 186   end)
187 - mq.m:on("arrived", function() ~-~- Registration for sending messages to callbacks 
674 + mq.m:on("offline", function (cause) -- Register for lost connection callbacks
675 + -- addr_setstring("@xxx", "cause"..(cause or " got nil"))
676 + end)
677 + mq.m:on("arrived", function() -- Registration for sending messages to callbacks
188 188   print("msg arrived")
189 189   end)
190 190   else
191 - print("mqtt create failed:", err) ~-~- Create object failed
681 + print("mqtt create failed:", err) -- Create object failed
192 192   end
193 193   else
194 - if mq.m:isconnected() then ~-~- If online, post a message
684 + if mq.m:isconnected() then -- If online, post a message
195 195   local phaseStatus ="unknow"
196 196   if addr_getbit("@Standby")== 1 then
197 - phaseStatus = "Standby"
687 + phaseStatus = "Standby"
198 198   elseif addr_getbit("@Pre-Freeze")==1 then
199 - phaseStatus= "Pre-Freeze"
689 + phaseStatus= "Pre-Freeze"
200 200   elseif addr_getbit("@Prepare")==1 then
201 - phaseStatus ="Prepare"
691 + phaseStatus ="Prepare"
202 202   elseif addr_getbit("@Primary Dry")==1 then
203 - phaseStatus = "Primary dry"
693 + phaseStatus = "Primary dry"
204 204   elseif addr_getbit("@Secondary Dry")==1 then
205 - phaseStatus = "Secondary Dry"
695 + phaseStatus = "Secondary Dry"
206 206   end
207 -~-~- print(addr_getbit("@Primary Dry"))
208 -~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~--
697 + --print(addr_getbit("@Primary Dry"))
698 +-------------------------------------------------------------------------------------------------------------------------
209 209   local activating ="unknow"
210 210   if addr_getbit("@Compressor")==1 then
211 - activating = ",".."Compressor"
701 + activating = ",".."Compressor"
212 212   end
213 213   if addr_getbit("@Silicone Pump")==1 then
214 - activating = activating..",".."Silicone Pump"
704 + activating = activating..",".."Silicone Pump"
215 215   end
216 216   if addr_getbit("@Vacuum Pump")==1 then
217 - activating = activating..",".."Vacuum Pump"
707 + activating = activating..",".."Vacuum Pump"
218 218   end
219 219   if addr_getbit("@Root Pump")==1 then
220 - activating = activating..",".."Root Pump"
710 + activating = activating..",".."Root Pump"
221 221   end
222 222   if addr_getbit("@Heater")==1 then
223 - activating = activating..",".."Heater"
713 + activating = activating..",".."Heater"
224 224   end
225 225   if addr_getbit("@Valve Silicone")==1 then
226 - activating = activating..",".."Valve Silicone"
716 + activating = activating..",".."Valve Silicone"
227 227   end
228 228   if addr_getbit("@Valve Ice Condenser")==1 then
229 - activating = activating..",".."Valve Ice Condenser"
719 + activating = activating..",".."Valve Ice Condenser"
230 230   end
231 231   if addr_getbit("@Valve Vacuum Pump")==1 then
232 - activating = activating..",".."Valve Vacuum Pump"
722 + activating = activating..",".."Valve Vacuum Pump"
233 233   end
234 234   local pr_activating =string.sub(activating,2)
235 - ~-~- print(pr_activating) 
236 -
237 -
725 + -- print(pr_activating)
238 238   local status_text ="unknow"
239 239   if addr_getbit("@Status Run")==1 then
240 - status_text = "RUNNING"
728 + status_text = "RUNNING"
241 241   else
242 - status_text = "STOP"
730 + status_text = "STOP"
243 243   end
244 -~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~--
245 -\\ local js = {type="status",
246 - mc_name ="FD300",
247 - status=status_text,
248 - elapsed_time={
249 - hour=addr_getword("@Elapsed Time (Hour)"),
250 - min=addr_getword("@Elapsed Time (Minute)"),
251 - sec=addr_getword("@Elapsed Time (Second)")
252 - },
253 - phase = phaseStatus,
254 - step = addr_getword("@Step"),
255 - activating_output = pr_activating,
256 - sv=addr_getshort("@SV Silicone")/10,
257 - pv=addr_getshort("@PV Silicone")/10,
258 - product1=addr_getshort("@Product 1")/10,
259 -\\ product2=addr_getshort("@Product 2")/10,
260 - product3=addr_getshort("@Product 3")/10,
261 - product4=addr_getshort("@Product 4")/10,
262 - ice1=addr_getshort("@Ice condenser 1")/10,
263 - ice2=addr_getshort("@Ice condenser 2")/10,
264 - vacuum=addr_getfloat("@Vacuum")
265 -\\ }
732 +-------------------------------------------------------------------------------------------------------------------------
733 + local js = {type="status",
734 + mc_name ="FD300",
735 + status=status_text,
736 + elapsed_time={
737 + hour=addr_getword("@Elapsed Time (Hour)"),
738 + min=addr_getword("@Elapsed Time (Minute)"),
739 + sec=addr_getword("@Elapsed Time (Second)")
740 + },
741 + phase = phaseStatus,
742 + step = addr_getword("@Step"),
743 + activating_output = pr_activating,
744 + sv=addr_getshort("@SV Silicone")/10,
745 + pv=addr_getshort("@PV Silicone")/10,
746 + product1=addr_getshort("@Product 1")/10,
747 +
748 + product2=addr_getshort("@Product 2")/10,
749 + product3=addr_getshort("@Product 3")/10,
750 + product4=addr_getshort("@Product 4")/10,
751 + ice1=addr_getshort("@Ice condenser 1")/10,
752 + ice2=addr_getshort("@Ice condenser 2")/10,
753 + vacuum=addr_getfloat("@Vacuum")
754 + }
266 266   local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"),
267 - ODPC = addr_getbit("@B_25395#W0.01"),
268 - MTPC=addr_getbit("@B_25395#W0.02"),
269 - HTT = addr_getbit("@B_25395#W1.03"),
270 - CPC = addr_getbit("@B_25395#W0.08"),
271 - CPSP =addr_getbit("@B_25395#W1.00"),
272 - CPVP =addr_getbit("@B_25395#W0.10"),
273 - CPRP =addr_getbit("@B_25395#W0.11"),
274 - HP =addr_getbit("@B_25395#W1.01"),
275 - PP= addr_getbit("@B_25395#W1.02"),
276 - PO=addr_getbit("@B_25395#W0.07"),
277 - FSE=addr_getbit("@B_25395#W2.04"),
278 - AVVSVV=addr_getbit("@B_25395#W1.12"),
279 - ICHT=addr_getbit("@B_25395#W3.06")
280 -\\ }
281 -\\ ~-~- ("@B_25395#CIO1.02")
756 + ODPC = addr_getbit("@B_25395#W0.01"),
757 + MTPC=addr_getbit("@B_25395#W0.02"),
758 + HTT = addr_getbit("@B_25395#W1.03"),
759 + CPC = addr_getbit("@B_25395#W0.08"),
760 + CPSP =addr_getbit("@B_25395#W1.00"),
761 + CPVP =addr_getbit("@B_25395#W0.10"),
762 + CPRP =addr_getbit("@B_25395#W0.11"),
763 + HP =addr_getbit("@B_25395#W1.01"),
764 + PP= addr_getbit("@B_25395#W1.02"),
765 + PO=addr_getbit("@B_25395#W0.07"),
766 + FSE=addr_getbit("@B_25395#W2.04"),
767 + AVVSVV=addr_getbit("@B_25395#W1.12"),
768 + ICHT=addr_getbit("@B_25395#W3.06")
769 + }
770 + -- ("@B_25395#CIO1.02")
282 282   mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0)
283 283   mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0)
284 284   else
285 - local stat, err = mq.m:connect(mq.config) ~-~- connection
286 - if stat == nil then ~-~-Determine whether to connect
774 + local stat, err = mq.m:connect(mq.config) -- connection
775 + if stat == nil then --Determine whether to connect
287 287   print("mqtt connect failed:", err)
288 - return ~-~- Connection failed, return directly
777 + return -- Connection failed, return directly
289 289   end
290 - mq.m:subscribe("mqtt-v-box-epsilon", 0)~-~- Subscribe to topics
291 -\\ end
292 - ~-~- mq.m:unsubscribe("stc/test")
293 - ~-~- mq.m:disconnect() ~-~- close matt
294 - ~-~- mq.m:close() ~-~- close clase
779 + mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics
780 +
781 + end
782 + -- mq.m:unsubscribe("stc/test")
783 + -- mq.m:disconnect() -- close matt
784 + -- mq.m:close() -- close clase
295 295   end
296 296  end
297 -)))
787 +{{/code}}
298 298  
299 -== **2.2 V-Box connect with Azure platform** ==
789 +== **2.3 V-Box connect with Azure platform** ==
300 300  
301 301  In this demo,V-Box connects with Azure by SSL certification.
302 302  
... ... @@ -427,7 +427,7 @@
427 427  end
428 428  )))
429 429  
430 -== **2.3 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）** ==
920 +== **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）** ==
431 431  
432 432  1.Register a account: [[https:~~/~~/www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ>>https://www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ]]
433 433  
... ... @@ -576,7 +576,7 @@
576 576  (% style="text-align:center" %)
577 577  [[image:1624441186851-536.png||height="434" width="700" class="img-thumbnail"]]
578 578  
579 -== **2.4 V-Box connect with Huawei platform** ==
1069 +== **2.5 V-Box connect with Huawei platform** ==
580 580  
581 581  In this demo,V-Box connects with Huawei by SSL certification.
582 582  
... ... @@ -697,7 +697,7 @@
697 697  (% style="text-align:center" %)
698 698  [[image:1624506666650-161.png||height="547" width="1000" class="img-thumbnail"]]
699 699  
700 -== **2.5 V-Box connect with AWS platform** ==
1190 +== **2.6 V-Box connect with AWS platform** ==
701 701  
702 702  === **Log in AWS** ===
703 703  
... ... @@ -722,35 +722,20 @@
722 722  
723 723  {{code language="java"}}
724 724  {
725 -
726 726    "Version": "2012-10-17",
727 -
728 728    "Statement": [
729 -
730 730      {
731 -
732 732        "Effect": "Allow",
733 -
734 734        "Action": [
735 -
736 736          "iot:Connect",
737 -
738 738          "iot:Publish",
739 -
740 740          "iot:Subscribe",
741 -
742 742          "iot:Receive",
743 -
744 744          "greengrass:Discover"
745 -
746 746        ],
747 -
748 748        "Resource": "*"
749 -
750 750      }
751 -
752 752    ]
753 -
754 754  }
755 755  {{/code}}
756 756  
... ... @@ -815,185 +815,190 @@
815 815  
816 816  [[image:image-20220709165402-20.png]]
817 817  
1293 +{{info}}
1294 +**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701
1295 +{{/info}}
1296 +
1297 +{{code language="lua"}}
818 818  sprint = print
819 819  
820 -~-~-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)
1300 +--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)
821 821  
822 822  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
823 823  
824 -~-~-publish to topics
1304 +--publish to topics
825 825  
826 826  local pub_RE_TOPIC = string.format('TEST')
827 827  
828 -~-~-Subscribe topics
1308 +--Subscribe topics
829 829  
830 830  local Subscribe_RE_TOPIC1 = string.format('TEST')
831 831  
832 -~-~-variable
1312 +--variable
833 833  
834 834  local last_time = 0
835 835  
836 -~-~-Timing main function
1316 +--Timing main function
837 837  
838 838  function aws.main()
839 839  
840 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1320 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
841 841  
842 - if g_mq then
1322 + if g_mq then
843 843  
844 - if g_mq:isconnected() then
1324 + if g_mq:isconnected() then
845 845  
846 - send_Data()
1326 + send_Data()
847 847  
848 - else
1328 + else
849 849  
850 - if os.time() - last_time > 5 then
1330 + if os.time() - last_time > 5 then
851 851  
852 - last_time = os.time()
1332 + last_time = os.time()
853 853  
854 - mymqtt_connect()
1334 + mymqtt_connect()
855 855  
1336 + end
1337 +
856 856   end
857 857  
858 - end
1340 + else
859 859  
860 - else
1342 + mymqtt_init()
861 861  
862 - mymqtt_init()
1344 + end
863 863  
864 - end
1346 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
865 865  
866 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
867 -
868 868  end
869 869  
870 870  
871 -~-~- Initialize MQTT
872 872  
1352 +-- Initialize MQTT
1353 +
873 873  function mymqtt_init()
874 874  
875 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1356 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
876 876  
877 - g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
1358 + 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
878 878  
879 - if g_mq then
1360 + if g_mq then
880 880  
881 - g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1362 + g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
882 882  
883 - sprint("mqtt init success")
1364 + sprint("mqtt init success")
884 884  
885 - else
1366 + else
886 886  
887 - sprint("mqtt init failed:", err)
1368 + sprint("mqtt init failed:", err)
888 888  
889 - end
1370 + end
890 890  
891 891  end
892 892  
893 -~-~- Connect to MQTT server
1374 +-- Connect to MQTT server
894 894  
895 895  function mymqtt_connect()
896 896  
897 - sprint("mqtt connecting...")
1378 + sprint("mqtt connecting...")
898 898  
899 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1380 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
900 900  
901 - if stat == nil then
1382 + if stat == nil then
902 902  
903 - sprint("mqtt connect failed:", err)
1384 + sprint("mqtt connect failed:", err)
904 904  
905 - return
1386 + return
906 906  
907 - else
1388 + else
908 908  
909 - sprint("mqtt connected")
1390 + sprint("mqtt connected")
910 910  
911 - end
1392 + end
912 912  
913 - g_mq:subscribe(TEST, 0)
1394 + g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
914 914  
915 915  end
916 916  
917 -~-~- Receive MQTT message callback function
1398 +-- Receive MQTT message callback function
918 918  
919 919  function mymqtt_msg_callback(topic, msg)
920 920  
921 - print("topic:",topic)
1402 + print("topic:",topic)
922 922  
923 - print("revdata:",msg)
1404 + print("revdata:",msg)
924 924  
925 - local revData = json.decode(msg)
1406 + local revData = json.decode(msg)
926 926  
927 - print (revData)
1408 + print (revData)
928 928  
929 - if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1410 + if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
930 930  
931 -if string.match(topic,Subscribe_RE_TOPIC1) then
1412 + if string.match(topic,Subscribe_RE_TOPIC1) then
932 932  
933 - ~-~-if revData ~~= nil then
1414 + --if revData ~= nil then
934 934  
935 - for k,v in pairs (revData) do
1416 + for k,v in pairs (revData) do
936 936  
937 - print("printing revdata after kv here")
1418 + print("printing revdata after kv here")
938 938  
939 - print (k,v)
1420 + print (k,v)
940 940  
941 - end
1422 + end
942 942  
943 - print ("current state is",fanstate)
1424 + print ("current state is",fanstate)
944 944  
945 - ~-~-end
1426 + --end
946 946  
947 -end
1428 + end
948 948  
949 -end
1430 + end
950 950  
951 951  end
952 952  
953 953  
954 -~-~-Get real-time data
955 955  
1436 +--Get real-time data
1437 +
956 956  function getData()
957 957  
958 - local jdata = {}
1440 + local jdata = {}
959 959  
960 - local addr = bns_get_alldata()
1442 + local addr = bns_get_alldata()
961 961  
962 - print(json.encode(addr))
1444 + print(json.encode(addr))
963 963  
964 - for i,v in pairs(addr) do
1446 + for i,v in pairs(addr) do
965 965  
966 - if v[2] == 1 then
1448 + if v[2] == 1 then
967 967  
968 - jdata[v[3]] = v[4]
1450 + jdata[v[3]] = v[4]
969 969  
970 - end
1452 + end
971 971  
972 - end
1454 + end
973 973  
974 - return jdata
1456 + return jdata
975 975  
976 976  end
977 977  
978 -~-~-send data
1460 +--send data
979 979  
980 980  function send_Data()
981 981  
982 - local pub_data =
1464 + local pub_data =
1465 + {
1466 + 123
1467 + }
983 983  
984 - {
985 -
986 -123
987 -
988 -}
989 -
990 990  sprint(json.encode(pub_data))
991 991  
992 992  print("..........",pub_RE_TOPIC)
993 993  
994 - return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1473 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
995 995  
996 996  end
1476 +{{/code}}
997 997  
998 998  Get message in AWS
999 999  
InputHTTPparameter.png
Author
... ... @@ -1,0 +1,1 @@
1 +XWiki.Hunter
Size
... ... @@ -1,0 +1,1 @@
1 +17.9 KB
Content