Changes for page 2 Script
Last modified by Devin Chen on 2025/06/06 14:03
Summary
-
Page properties (2 modified, 0 added, 0 removed)
-
Attachments (0 modified, 1 added, 0 removed)
Details
- Page properties
-
- Author
-
... ... @@ -1,1 +1,1 @@ 1 -XWiki. admin1 +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. 1\.UserManual.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 ... ... @@ -36,34 +36,35 @@ 36 36 37 37 Script is as below: 38 38 39 -{{code language="Lua"}} 39 +(% class="box infomessage" %) 40 +((( 40 40 function sms.main() 41 -------send condition------ 42 +~-~-~-~-~-~-send condition~-~-~-~-~-~- 42 42 local temp1 = addr_getword("@Temperature1") 43 43 local temp2 = addr_getword("@Temperature2") 44 44 local temp3 = addr_getword("@Temperature3") 45 45 local timer = addr_getword("@Timer") 46 46 local tag = addr_getbit("@Tag") 47 -------lasting time------ 48 +~-~-~-~-~-~-lasting time~-~-~-~-~-~- 48 48 if temp1 > 5 and temp2 > 10 and temp3 < 20 then 49 - 50 - 50 + timer = timer + 1 51 + addr_setword("@Timer",timer) 51 51 else 52 - 53 - 53 + timer = 0 54 + addr_setword("@Timer",timer) 54 54 end 55 -------send sms & output Y0------ 56 +~-~-~-~-~-~-send sms & output Y0~-~-~-~-~-~- 56 56 if timer > 5 then 57 - 58 - 59 - 60 - 58 + if tag == 0 then 59 + send_sms_ira("19859254700","alarm trigger") 60 + addr_setbit("@Tag",1) 61 + end 61 61 elseif tag == 1 then 62 62 send_sms_ira("19859254700","alarm release") 63 63 addr_setbit("@Tag",0) 64 64 end 65 65 end 66 - {{/code}}67 +))) 67 67 68 68 == **1.5 Telegram notification** == 69 69 ... ... @@ -134,7 +134,85 @@ 134 134 end 135 135 {{/code}} 136 136 138 +== **1.6 LINE Notify** == 137 137 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}} 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 + 138 138 = **2 V-Box connect with third part server** = 139 139 140 140 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. ... ... @@ -153,13 +153,137 @@ 153 153 154 154 (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate 155 155 156 -== **2.1 V-Box connect with customer server:grouprobotinfo.com** == 235 +(% class="wikigeneratedid" %) 236 +**✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool. 157 157 238 +(% class="wikigeneratedid" %) 239 +Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]** 240 + 241 +== **2.1 V-Box connect with test server(General Example)** == 242 + 243 +{{code language="lua"}} 244 +--MQTT configuration table 245 +local MQTT_CFG={} 246 +MQTT_CFG.username = "weconsupport" 247 +MQTT_CFG.password = "123456" 248 +MQTT_CFG.netway = 0 249 +MQTT_CFG.keepalive = 60 250 +MQTT_CFG.cleansession = 1 251 +--TCP URL 252 +MQTT_URL = "tcp://mq.tongxinmao.com:1883" 253 +--Client ID 254 +MQTT_CLIENT_ID = "V-BOXH-AG" 255 + 256 +--Generate UUID 257 +function uuid() 258 + local seed = {'e','1','2','3','4','5','6','7','8','9','a','b','c','d','e','f'} 259 + local tb = {} 260 + for i=1, 32 do 261 + table.insert(tb, seed[math.random(1,16)]) 262 + end 263 + local sid=table.concat(tb) 264 + return string.format('%s', 265 + string.sub(sid,1,32) 266 + ) 267 +end 268 + 269 + 270 +--Topic name to subscribed 271 +local SUBSCRIBE_TOPIC = 'testtopic/test/no1/123456' 272 + 273 +--Topic name to be published 274 +local PUBLISH_TOPIC = 'testtopic/test/no1/7890' 275 + 276 + 277 +--real time 278 +local LAST_TIME = 0 279 + 280 + 281 +--initialize mqtt 282 +function mqtt_init() 283 + print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID)) 284 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable 285 + if g_mq then 286 + g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages 287 + print("mqtt init success") 288 + else 289 + print("mqtt init failed:", err) 290 + end 291 +end 292 + 293 +-- connect to mqtt 294 +function mqtt_connect() 295 + print("mqtt connecting...") 296 + local stat, err = g_mq:connect(MQTT_CFG) 297 + if stat == nil then 298 + print("mqtt connect failed:", err) 299 + return 300 + else 301 + print("mqtt connected") 302 + end 303 + g_mq:subscribe(SUBSCRIBE_TOPIC, 0) 304 +end 305 + 306 +-- Received message callback function 307 +function mqtt_msg_callback(topic, msg) 308 + print("topic:", topic) 309 + print("msg:", msg) 310 + local objMsg = json.decode(msg) 311 + local water = objMsg.data.waterlevel 312 + local temp = objMsg.data.temperature 313 + addr_setword("@HDW20",water) 314 + addr_setword("@HDW10",temp) 315 +end 316 + 317 +--Send data (data upload to platform and encapsulate it with custom functions) 318 +function send_data() 319 + local pub_data = { 320 + timestamp = os.time(), 321 + messageId = 1, 322 + event = 'test_data', 323 + mfrs = 'V-Box', 324 + data = { 325 + id = uuid(), 326 + waterlevel = addr_getword("@HDW10"), 327 + temperature = addr_getword("@HDW20") 328 + } 329 + } 330 + return g_mq:publish(PUBLISH_TOPIC, json.encode(pub_data), 0, 0) 331 +end 332 + 333 + 334 +--main function fixed timed execution 335 +function MQTT.main() 336 + --dosomething 337 + print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main start") 338 + --determine the mqtt object whether exist 339 + if g_mq then 340 + --determine the mqtt object whether has been connected or not 341 + if g_mq:isconnected() then 342 + send_data() 343 + else 344 + --if exceed 20 sec not connect, reconnect once 345 + if os.time() - LAST_TIME > 20 then 346 + LAST_TIME = os.time() 347 + --connect to mqtt or reconnect 348 + mqtt_connect() 349 + end 350 + end 351 + else 352 + --mqtt object does not exist so create new one 353 + mqtt_init() 354 + end 355 + print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main end") 356 +end 357 +{{/code}} 358 + 359 +== **2.2 V-Box connect with customer server:grouprobotinfo.com** == 360 + 158 158 This demo does not use SSL certification. Script is as below 159 159 160 160 Demo1: 161 161 162 -{{code language=" Lua"}}365 +{{code language="lua"}} 163 163 -- Meta class 164 164 --main 165 165 function mq.main() ... ... @@ -280,7 +280,7 @@ 280 280 FSE=addr_getbit("@B_25395#W2.04"), 281 281 AVVSVV=addr_getbit("@B_25395#W1.12"), 282 282 ICHT=addr_getbit("@B_25395#W3.06") 283 - 486 + 284 284 } 285 285 286 286 -- ("@B_25395#CIO1.02") ... ... @@ -302,7 +302,7 @@ 302 302 end 303 303 {{/code}} 304 304 305 -== **2. 2V-Box connect with Azure platform** ==508 +== **2.3 V-Box connect with Azure platform** == 306 306 307 307 In this demo,V-Box connects with Azure by SSL certification. 308 308 ... ... @@ -312,136 +312,128 @@ 312 312 313 313 Script is as below 314 314 315 -{{code language="Lua"}} 316 ---https://support.huaweicloud.com/qs-IoT/iot_05_0005.html mqtt.fx monitor to connect azure iot 518 +(% class="box infomessage" %) 519 +((( 520 +~-~-https:~/~/support.huaweicloud.com/qs-IoT/iot_05_0005.html mqtt.fx monitor to connect azure iot 317 317 sprint = print 318 318 319 ---Get custom configuration parameters (vbox custom information) 320 ---local CUSTOM = bns_get_config("bind") 321 ---local DS_ID = CUSTOM.DSID or "60a71ccbbbe12002c08f3a1a_WECON" 523 +~-~-Get custom configuration parameters (vbox custom information) 524 +~-~-local CUSTOM = bns_get_config("bind") 525 +~-~-local DS_ID = CUSTOM.DSID or "60a71ccbbbe12002c08f3a1a_WECON" 322 322 323 323 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) 528 +~-~-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) 326 326 local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg() 327 327 328 ---MQTT_CFG.username = '60a71ccbbbe12002c08f3a1a_WECON' 329 ---MQTT_CFG.password='wecon123' 330 ---MQTT_CLIENTID = '60a71ccbbbe12002c08f3a1a_WECON_0_0_2021052110usernxame:60a71ccbbbe12002c08f3a1a_WECONpassword:a0a951581855aa8e0262129da6cf1b43f2c0ecfac4fa56117fc5a20c90be169a' 531 +~-~-MQTT_CFG.username = '60a71ccbbbe12002c08f3a1a_WECON' 532 +~-~-MQTT_CFG.password='wecon123' 533 +~-~-MQTT_CLIENTID = '60a71ccbbbe12002c08f3a1a_WECON_0_0_2021052110usernxame:60a71ccbbbe12002c08f3a1a_WECONpassword:a0a951581855aa8e0262129da6cf1b43f2c0ecfac4fa56117fc5a20c90be169a' 331 331 332 ---publish to topics 535 +~-~-publish to topics 333 333 local pub_RE_TOPIC = string.format('devices/wecon_02/messages/events/') 334 ---Subscribe topics 537 +~-~-Subscribe topics 335 335 local Subscribe_RE_TOPIC1 = string.format('devices/wecon_02/messages/devicebound/#') 336 336 337 ---variable 540 +~-~-variable 338 338 local last_time = 0 339 339 340 340 341 - 342 ---Timing main function 544 +~-~-Timing main function 343 343 function Azure.main() 344 344 345 - 346 - 347 - 348 - 349 - 350 - 351 - 352 - 353 - 354 - 355 - 356 - 357 - 358 - 547 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main start") 548 + if g_mq then 549 + if g_mq:isconnected() then 550 + send_Data() 551 + else 552 + if os.time() - last_time > 20 then 553 + last_time = os.time() 554 + mymqtt_connect() 555 + end 556 + end 557 + else 558 + mymqtt_init() 559 + end 560 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main end") 359 359 end 360 360 361 --- Initialize MQTT 563 +~-~- Initialize MQTT 362 362 function mymqtt_init() 363 - 364 - 365 - 366 - 367 - 368 - 369 - 370 - 565 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) 566 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable 567 + if g_mq then 568 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks 569 + sprint("mqtt init success") 570 + else 571 + sprint("mqtt init failed:", err) 572 + end 371 371 end 372 372 373 --- Connect to MQTT server 575 +~-~- Connect to MQTT server 374 374 function mymqtt_connect() 375 - 376 - 377 - 378 - 379 - 380 - 381 - 382 - 383 - 577 + sprint("mqtt connecting...") 578 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) 579 + if stat == nil then 580 + sprint("mqtt connect failed:", err) 581 + return 582 + else 583 + sprint("mqtt connected") 584 + end 585 + g_mq:subscribe(Subscribe_RE_TOPIC1, 0) 384 384 end 385 385 386 --- Receive MQTT message callback function 588 +~-~- Receive MQTT message callback function 387 387 function mymqtt_msg_callback(topic, msg) 388 - 389 - 390 - 391 - 392 --- if string.match(topic,Subscribe_RE_TOPIC1) then 393 - 394 - 395 - 590 + print("topic:",topic) 591 + print("revdata:",msg) 592 + ~-~- local revData = json.decode(msg) 593 + ~-~- if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud 594 +~-~- if string.match(topic,Subscribe_RE_TOPIC1) then 595 + ~-~- print("topi11:",topic) 596 + setValue(revData) 597 + ~-~- end 396 396 end 397 397 398 ---Process the received data 399 ---function setValue(revData) 400 - 401 - 402 - 403 - 404 - 405 ---end 600 +~-~-Process the received data 601 +~-~-function setValue(revData) 602 + ~-~- if revData ~~=nil then 603 + ~-~- for i,v in pairs(revData) do 604 + ~-~- print("Data received：",i,v) 605 + ~-~- end 606 + ~-~- end 607 +~-~-end 406 406 407 ---Get real-time data 609 +~-~-Get real-time data 408 408 function getData() 409 - 410 - 411 - 412 - 413 - 414 - 415 - 416 - 417 - 418 -end 611 + local jdata = {} 612 + local addr = bns_get_alldata() 613 + print(json.encode(addr)) 614 + for i,v in pairs(addr) do 615 + if v[2] == 1 then 616 + jdata[v[3]] = v[4] 617 + end 618 + end 619 + return jdata 620 +end 419 419 420 420 421 - 422 ---send data 623 +~-~-send data 423 423 function send_Data() 424 - local pub_data = {100 425 - -- services={{ 426 - 427 - --serviceId ='Temperature', 428 - -- properties={ 429 - -- value = 55 430 - -- }, 431 - -- }} 625 + local pub_data = {100 626 + ~-~- services=~{~{ 627 +\\ ~-~-serviceId ='Temperature', 628 + ~-~- properties={ 629 + ~-~- value = 55 630 + ~-~- }, 631 + ~-~- }} 432 432 } 433 433 sprint(json.encode(pub_data)) 434 434 print("..........",pub_RE_TOPIC) 435 - 635 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) 436 436 end 437 -{{/code}} 438 - 439 -(% class="box infomessage" %) 440 -((( 441 - 442 442 ))) 443 443 444 -== **2. 3How 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）** ==639 +== **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）** == 445 445 446 446 1.Register a account: [[https:~~/~~/www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ>>https://www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ]] 447 447 ... ... @@ -590,7 +590,7 @@ 590 590 (% style="text-align:center" %) 591 591 [[image:1624441186851-536.png||height="434" width="700" class="img-thumbnail"]] 592 592 593 -== **2. 4V-Box connect with Huawei platform** ==788 +== **2.5 V-Box connect with Huawei platform** == 594 594 595 595 In this demo,V-Box connects with Huawei by SSL certification. 596 596 ... ... @@ -711,7 +711,7 @@ 711 711 (% style="text-align:center" %) 712 712 [[image:1624506666650-161.png||height="547" width="1000" class="img-thumbnail"]] 713 713 714 -== **2. 5V-Box connect with AWS platform** ==909 +== **2.6 V-Box connect with AWS platform** == 715 715 716 716 === **Log in AWS** === 717 717 ... ... @@ -768,109 +768,67 @@ 768 768 } 769 769 {{/code}} 770 770 771 - 1.**Create things**966 +=== **Create things** === 772 772 773 773 Click “Manage”~-~-->“Things”~-~-->“Create things”~-~-->“Create single thing” 774 774 970 +[[image:image-20220709165402-6.png]] 775 775 776 -| 777 -| |[[image:image-20220709165402-6.png]] 972 +[[image:image-20220709165402-7.png]] 778 778 779 -| 780 -| |[[image:image-20220709165402-7.png]] 781 - 782 -| 783 -| |[[image:image-20220709165402-8.png]] 784 - 785 785 Name the thing~-~-->Click “Next” 786 786 976 +[[image:image-20220709165402-8.png]] 787 787 788 788 Select the way to create certificate 789 789 980 +[[image:image-20220709165402-9.png]] 790 790 791 -| 792 -| |[[image:image-20220709165402-9.png]] 793 - 794 794 Select policy 795 795 984 +[[image:image-20220709165402-10.png]] 796 796 797 -| 798 -| |[[image:image-20220709165402-10.png]] 986 +[[image:image-20220709165402-11.png]] 799 799 800 800 989 +=== **Test with MQTT.fx tool** === 801 801 802 - 803 - 804 - 805 - 806 - 807 -| 808 -| |[[image:image-20220709165402-11.png]] 809 - 810 - 811 - 812 - 813 - 814 -1. **Test with MQTT.fx tool** 815 - 816 816 Click “View Setting” to get the “Broker Adress” 817 817 993 +[[image:image-20220709165402-13.png]] 818 818 819 -| 820 -| |[[image:image-20220709165402-12.png]] 995 +[[image:image-20220709165402-12.png]] 821 821 822 -| 823 -| |[[image:image-20220709165402-13.png]] 824 - 825 - 826 - 827 - 828 - 829 - 830 - 831 -| 832 -| |[[image:image-20220709165402-14.png]] 833 - 834 834 Create one connection in MQTT.fx tool, set broker port as 8883. 835 835 999 +[[image:image-20220709165402-14.png]] 1000 + 836 836 Upload the CA File, Client Certificate File, Client Key File 837 837 1003 +[[image:image-20220709165402-15.png]] 838 838 839 -| 840 -| |[[image:image-20220709165402-15.png]] 841 - 842 842 Publish message to topic “TEST” 843 843 1007 +[[image:image-20220709165402-17.png]] 844 844 845 -| 846 -| |[[image:image-20220709165402-16.png]] 847 - 848 -| 849 -| |[[image:image-20220709165402-17.png]] 850 - 851 851 Click”Test”~-~-->”MQTT test client”~-~-->”Subscrible to a topic”, to get message publish from MQTT.fx tool. 852 852 1011 +[[image:image-20220709173500-1.png]] 1012 + 853 853 And we can also send message form AWS platform to MQTT.fx tool. 854 854 1015 +[[image:image-20220709165402-18.png]] 855 855 856 -| 857 -| |[[image:image-20220709165402-18.png]] 1017 +=== **Configurate in CloudTool** === 858 858 859 -1. **Configurate in CloudTool** 860 - 861 861 Copy the same setting in MQTT.fx to MQTT configuration 862 862 1021 +[[image:image-20220709165402-19.png]] 863 863 864 -| 865 -| |[[image:image-20220709165402-19.png]] 866 - 867 867 Add a lua script and copy the lua demo into it. 868 868 1025 +[[image:image-20220709165402-20.png]] 869 869 870 -| 871 -| |[[image:image-20220709165402-20.png]] 872 - 873 - 874 874 sprint = print 875 875 876 876 ~-~-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) ... ... @@ -1051,10 +1051,6 @@ 1051 1051 1052 1052 end 1053 1053 1054 - 1055 - 1056 1056 Get message in AWS 1057 1057 1058 - 1059 -| 1060 -| |[[image:image-20220709165402-21.png]] 1209 +[[image:image-20220709165402-21.png]]
- image-20220709173500-1.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.Jim - Size
-
... ... @@ -1,0 +1,1 @@ 1 +1.5 MB - Content