Changes for page 2 Script
Last modified by Devin Chen on 2025/06/06 14:03
From version 24.1
edited by Hunter
on 2022/10/09 15:02
on 2022/10/09 15:02
Change comment:
There is no comment for this version
To version 12.1
edited by Jim(Forgotten)
on 2022/07/09 17:02
on 2022/07/09 17:02
Change comment:
There is no comment for this version
Summary
-
Page properties (2 modified, 0 added, 0 removed)
-
Attachments (0 modified, 0 added, 1 removed)
Details
- Page properties
-
- Author
-
... ... @@ -1,1 +1,1 @@ 1 -XWiki. Hunter1 +XWiki.Jim - 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 ... ... @@ -135,210 +135,7 @@ 135 135 end 136 136 {{/code}} 137 137 138 -== **1.6 LINE Notify** == 139 139 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 - 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 -{{code language="Lua"}} 222 -local tempBit = 0 223 -local tempWord = 0 224 - 225 -local https = require("https") 226 -local json = require("json") 227 -local ltn12 = require("ltn12") 228 - 229 -local SID = 'AC1703bd710ffa98006d2bcc0b8d6ca63a' 230 -local Token = 'd3c11897623c39e538b20263ec190ae0' 231 - 232 -local twilioPhoneNumber = '+14155238886' 233 -local receiverPhoneNumber = '+8615880018277' 234 - 235 -local b='ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/' 236 -function encodingBase64(data) 237 - return ((data:gsub('.', function(x) 238 - local r,b='',x:byte() 239 - for i=8,1,-1 do r=r..(b%2^i-b%2^(i-1)>0 and '1' or '0') end 240 - return r; 241 - end)..'0000'):gsub('%d%d%d?%d?%d?%d?', function(x) 242 - if (#x < 6) then return '' end 243 - local c=0 244 - for i=1,6 do c=c+(x:sub(i,i)=='1' and 2^(6-i) or 0) end 245 - return b:sub(c+1,c+1) 246 - end)..({ '', '==', '=' })[#data%3+1]) 247 -end 248 - 249 -function encodeUrl(str) 250 - str = string.gsub(str, "([^%w%.%- ])", function(c) 251 - return string.format("%%%02X", string.byte(c)) end) 252 - return string.gsub(str, " ", "+") 253 -end 254 - 255 - 256 - 257 - 258 -function requestBodySplice(message, sender, receiver) 259 - local reqBody = '' 260 - local encodeMess = encodeUrl(message) 261 - local encodeSend = encodeUrl(sender) 262 - local encodeRece = encodeUrl(receiver) 263 - --reqBody = "Body=Hello%20Wecon2&From=whatsapp%3A%2B14155238886&To=whatsapp%3A%2B8615880018277" 264 - reqBody = string.format("Body=%s&From=whatsapp:%s&To=whatsapp:%s", encodeMess, encodeSend, encodeRece) 265 - print(reqBody) 266 - return reqBody 267 -end 268 - 269 - 270 --- Send http.get request and return response result 271 -function getHttpsUrl(url,header,reqbody) 272 - local body = {} 273 - local bodyJson = json.encode(body) 274 - local result_table, code, headers, status = https.request{ 275 - method = "POST", 276 - url = url, 277 - source = ltn12.source.string(reqbody), 278 - headers = header, 279 - sink = ltn12.sink.table(body) 280 - } 281 - print("code:"..code) 282 - if code~= 200 then 283 - return 284 - else 285 - return body 286 - end 287 -end 288 - 289 -function getMessageUrl(whatsAppMessage) 290 - local auth = SID..':'..Token 291 - local url = "https://api.twilio.com/2010-04-01/Accounts/"..SID.."/Messages" 292 - --local reqMess = "message="..twilioMessage 293 - local reqMess = requestBodySplice(whatsAppMessage, twilioPhoneNumber, receiverPhoneNumber) 294 - local headers = 295 - { 296 - ["Authorization"] = "Basic "..encodingBase64(auth), 297 - ["Content-Type"] = "application/x-www-form-urlencoded", 298 - ["Content-Length"] = #reqMess 299 - } 300 - 301 - print("Get the link:"..url) 302 - getHttpsUrl(url, headers, reqMess) 303 -end 304 - 305 - 306 - 307 -function Twilio.main() 308 - --dosomething 309 - --local auth = SID..':'..Token 310 - --print(requestBodySplice("HelloWorld", twilioPhoneNumber, receiverPhoneNumber)) 311 - --print(encodingBase64(auth)) 312 - local bitValue = addr_getbit("@testBit"); 313 - local message = '' 314 - print("b=="..bitValue) 315 - if bitValue == 1 and bitValue ~= tempBit then 316 - message = 'Alarm V-Box triggered, the output is '.. bitValue 317 - getMessageUrl(message) 318 - print("Notification pushed of triggering alarm,"..bitValue) 319 - elseif bitValue == 0 and bitValue ~= tempBit then 320 - message = 'Alarm V-Box dismissed, the output is '.. bitValue 321 - getMessageUrl(message) 322 - print("Notification pushed of dismissing alarm,"..bitValue) 323 - end 324 - tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform 325 - 326 - local wordValue = addr_getword("@testWord") 327 - print("w=="..wordValue) 328 - --dosomething 329 - if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then 330 - message = 'Alarm V-Box triggered, the temperature is '.. wordValue 331 - getMessageUrl(message) 332 - print("Notification pushed of triggering alarm,"..wordValue) 333 - elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then 334 - message = 'Alarm V-Box dismissed, the temperature is '.. wordValue 335 - getMessageUrl(message) 336 - print("Notification pushed of dismissing alarm,"..wordValue) 337 - end 338 - tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform 339 -end 340 -{{/code}} 341 - 342 342 = **2 V-Box connect with third part server** = 343 343 344 344 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. ... ... @@ -357,280 +357,150 @@ 357 357 358 358 (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate 359 359 360 -(% class="wikigeneratedid" %) 361 -**✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool. 157 +== **2.1 V-Box connect with customer server:grouprobotinfo.com** == 362 362 363 -(% class="wikigeneratedid" %) 364 -Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]** 365 - 366 -== **2.1 V-Box connect with test server(General Example)** == 367 - 368 -{{code language="lua"}} 369 ---MQTT configuration table 370 -local MQTT_CFG={} 371 -MQTT_CFG.username = "weconsupport" 372 -MQTT_CFG.password = "123456" 373 -MQTT_CFG.netway = 0 374 -MQTT_CFG.keepalive = 60 375 -MQTT_CFG.cleansession = 1 376 ---TCP URL 377 -MQTT_URL = "tcp://mq.tongxinmao.com:1883" 378 ---Client ID 379 -MQTT_CLIENT_ID = "V-BOXH-AG" 380 - 381 ---Generate UUID 382 -function uuid() 383 - local seed = {'e','1','2','3','4','5','6','7','8','9','a','b','c','d','e','f'} 384 - local tb = {} 385 - for i=1, 32 do 386 - table.insert(tb, seed[math.random(1,16)]) 387 - end 388 - local sid=table.concat(tb) 389 - return string.format('%s', 390 - string.sub(sid,1,32) 391 - ) 392 -end 393 - 394 - 395 ---Topic name to subscribed 396 -local SUBSCRIBE_TOPIC = 'testtopic/test/no1/123456' 397 - 398 ---Topic name to be published 399 -local PUBLISH_TOPIC = 'testtopic/test/no1/7890' 400 - 401 - 402 ---real time 403 -local LAST_TIME = 0 404 - 405 - 406 ---initialize mqtt 407 -function mqtt_init() 408 - print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID)) 409 - g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable 410 - if g_mq then 411 - g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages 412 - print("mqtt init success") 413 - else 414 - print("mqtt init failed:", err) 415 - end 416 -end 417 - 418 --- connect to mqtt 419 -function mqtt_connect() 420 - print("mqtt connecting...") 421 - local stat, err = g_mq:connect(MQTT_CFG) 422 - if stat == nil then 423 - print("mqtt connect failed:", err) 424 - return 425 - else 426 - print("mqtt connected") 427 - end 428 - g_mq:subscribe(SUBSCRIBE_TOPIC, 0) 429 -end 430 - 431 --- Received message callback function 432 -function mqtt_msg_callback(topic, msg) 433 - print("topic:", topic) 434 - print("msg:", msg) 435 - local objMsg = json.decode(msg) 436 - local water = objMsg.data.waterlevel 437 - local temp = objMsg.data.temperature 438 - addr_setword("@HDW20",water) 439 - addr_setword("@HDW10",temp) 440 -end 441 - 442 ---Send data (data upload to platform and encapsulate it with custom functions) 443 -function send_data() 444 - local pub_data = { 445 - timestamp = os.time(), 446 - messageId = 1, 447 - event = 'test_data', 448 - mfrs = 'V-Box', 449 - data = { 450 - id = uuid(), 451 - waterlevel = addr_getword("@HDW10"), 452 - temperature = addr_getword("@HDW20") 453 - } 454 - } 455 - return g_mq:publish(PUBLISH_TOPIC, json.encode(pub_data), 0, 0) 456 -end 457 - 458 - 459 ---main function fixed timed execution 460 -function MQTT.main() 461 - --dosomething 462 - print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main start") 463 - --determine the mqtt object whether exist 464 - if g_mq then 465 - --determine the mqtt object whether has been connected or not 466 - if g_mq:isconnected() then 467 - send_data() 468 - else 469 - --if exceed 20 sec not connect, reconnect once 470 - if os.time() - LAST_TIME > 20 then 471 - LAST_TIME = os.time() 472 - --connect to mqtt or reconnect 473 - mqtt_connect() 474 - end 475 - end 476 - else 477 - --mqtt object does not exist so create new one 478 - mqtt_init() 479 - end 480 - print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main end") 481 -end 482 -{{/code}} 483 - 484 -== **2.2 V-Box connect with customer server:grouprobotinfo.com** == 485 - 486 486 This demo does not use SSL certification. Script is as below 487 487 488 488 Demo1: 489 489 490 -{{code language="lua"}} 491 --- Meta class 492 ---main 163 +(% class="box infomessage" %) 164 +((( 165 +~-~- Meta class 166 +~-~-main 493 493 function mq.main() 494 - if not mq.m then 495 - local err = "" 168 + if not mq.m then 169 + local err = "" 170 +\\ mq.m, err = mqtt.create("tcp:~/~/grouprobotinfo.com:1883", "ClienID") ~-~- create connection 171 + if mq.m then 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 178 + } 179 + mq.m:on("message", function(topic, msg) ~-~- Register for receiving message callbacks 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")) 186 + end) 187 + mq.m:on("arrived", function() ~-~- Registration for sending messages to callbacks 188 + print("msg arrived") 189 + end) 190 + else 191 + print("mqtt create failed:", err) ~-~- Create object failed 192 + end 193 + else 194 + if mq.m:isconnected() then ~-~- If online, post a message 195 + local phaseStatus ="unknow" 196 + if addr_getbit("@Standby")== 1 then 197 + phaseStatus = "Standby" 198 + elseif addr_getbit("@Pre-Freeze")==1 then 199 + phaseStatus= "Pre-Freeze" 200 + elseif addr_getbit("@Prepare")==1 then 201 + phaseStatus ="Prepare" 202 + elseif addr_getbit("@Primary Dry")==1 then 203 + phaseStatus = "Primary dry" 204 + elseif addr_getbit("@Secondary Dry")==1 then 205 + phaseStatus = "Secondary Dry" 206 + end 207 +~-~- print(addr_getbit("@Primary Dry")) 208 +~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-- 209 + local activating ="unknow" 210 + if addr_getbit("@Compressor")==1 then 211 + activating = ",".."Compressor" 212 + end 213 + if addr_getbit("@Silicone Pump")==1 then 214 + activating = activating..",".."Silicone Pump" 215 + end 216 + if addr_getbit("@Vacuum Pump")==1 then 217 + activating = activating..",".."Vacuum Pump" 218 + end 219 + if addr_getbit("@Root Pump")==1 then 220 + activating = activating..",".."Root Pump" 221 + end 222 + if addr_getbit("@Heater")==1 then 223 + activating = activating..",".."Heater" 224 + end 225 + if addr_getbit("@Valve Silicone")==1 then 226 + activating = activating..",".."Valve Silicone" 227 + end 228 + if addr_getbit("@Valve Ice Condenser")==1 then 229 + activating = activating..",".."Valve Ice Condenser" 230 + end 231 + if addr_getbit("@Valve Vacuum Pump")==1 then 232 + activating = activating..",".."Valve Vacuum Pump" 233 + end 234 + local pr_activating =string.sub(activating,2) 235 + ~-~- print(pr_activating) 496 496 497 - mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection 498 - if mq.m then 499 - mq.config = { 500 - username = "",-- ID 501 - password = "",-- password 502 - netway = 1, -- Ethernet connection, WIFI=1 503 - -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds. 504 - -- cleansession = 0, -- Optional, keep session 505 - } 506 - mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks 507 - local str = string.format("%s:%s", topic, msg) 508 - -- print("mqtt msg:", str) -- Print out the received topics and content 509 - end 510 - ) 511 - mq.m:on("offline", function (cause) -- Register for lost connection callbacks 512 - -- addr_setstring("@xxx", "cause"..(cause or " got nil")) 513 - end) 514 - mq.m:on("arrived", function() -- Registration for sending messages to callbacks 515 - print("msg arrived") 516 - end) 517 - else 518 - print("mqtt create failed:", err) -- Create object failed 519 - end 520 - else 521 - if mq.m:isconnected() then -- If online, post a message 522 - local phaseStatus ="unknow" 523 - if addr_getbit("@Standby")== 1 then 524 - phaseStatus = "Standby" 525 - elseif addr_getbit("@Pre-Freeze")==1 then 526 - phaseStatus= "Pre-Freeze" 527 - elseif addr_getbit("@Prepare")==1 then 528 - phaseStatus ="Prepare" 529 - elseif addr_getbit("@Primary Dry")==1 then 530 - phaseStatus = "Primary dry" 531 - elseif addr_getbit("@Secondary Dry")==1 then 532 - phaseStatus = "Secondary Dry" 533 - end 534 --- print(addr_getbit("@Primary Dry")) 535 -------------------------------------------------------------------------------------------------------------------------- 536 - local activating ="unknow" 537 - if addr_getbit("@Compressor")==1 then 538 - activating = ",".."Compressor" 539 - end 540 - if addr_getbit("@Silicone Pump")==1 then 541 - activating = activating..",".."Silicone Pump" 542 - end 543 - if addr_getbit("@Vacuum Pump")==1 then 544 - activating = activating..",".."Vacuum Pump" 545 - end 546 - if addr_getbit("@Root Pump")==1 then 547 - activating = activating..",".."Root Pump" 548 - end 549 - if addr_getbit("@Heater")==1 then 550 - activating = activating..",".."Heater" 551 - end 552 - if addr_getbit("@Valve Silicone")==1 then 553 - activating = activating..",".."Valve Silicone" 554 - end 555 - if addr_getbit("@Valve Ice Condenser")==1 then 556 - activating = activating..",".."Valve Ice Condenser" 557 - end 558 - if addr_getbit("@Valve Vacuum Pump")==1 then 559 - activating = activating..",".."Valve Vacuum Pump" 560 - end 561 - local pr_activating =string.sub(activating,2) 562 - -- print(pr_activating) 563 563 564 - 565 - 566 - local status_text ="unknow" 567 - if addr_getbit("@Status Run")==1 then 568 - status_text = "RUNNING" 569 - else 570 - status_text = "STOP" 571 - end 572 -------------------------------------------------------------------------------------------------------------------------- 573 - 574 - local js = {type="status", 575 - mc_name ="FD300", 576 - status=status_text, 577 - elapsed_time={ 578 - hour=addr_getword("@Elapsed Time (Hour)"), 579 - min=addr_getword("@Elapsed Time (Minute)"), 580 - sec=addr_getword("@Elapsed Time (Second)") 581 - }, 582 - phase = phaseStatus, 583 - step = addr_getword("@Step"), 584 - activating_output = pr_activating, 585 - sv=addr_getshort("@SV Silicone")/10, 586 - pv=addr_getshort("@PV Silicone")/10, 587 - product1=addr_getshort("@Product 1")/10, 588 - 589 - product2=addr_getshort("@Product 2")/10, 590 - product3=addr_getshort("@Product 3")/10, 591 - product4=addr_getshort("@Product 4")/10, 592 - ice1=addr_getshort("@Ice condenser 1")/10, 593 - ice2=addr_getshort("@Ice condenser 2")/10, 594 - vacuum=addr_getfloat("@Vacuum") 595 - 596 - } 597 - local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"), 598 - ODPC = addr_getbit("@B_25395#W0.01"), 599 - MTPC=addr_getbit("@B_25395#W0.02"), 600 - HTT = addr_getbit("@B_25395#W1.03"), 601 - CPC = addr_getbit("@B_25395#W0.08"), 602 - CPSP =addr_getbit("@B_25395#W1.00"), 603 - CPVP =addr_getbit("@B_25395#W0.10"), 604 - CPRP =addr_getbit("@B_25395#W0.11"), 605 - HP =addr_getbit("@B_25395#W1.01"), 606 - PP= addr_getbit("@B_25395#W1.02"), 607 - PO=addr_getbit("@B_25395#W0.07"), 608 - FSE=addr_getbit("@B_25395#W2.04"), 609 - AVVSVV=addr_getbit("@B_25395#W1.12"), 610 - ICHT=addr_getbit("@B_25395#W3.06") 611 - 612 - } 613 - 614 - -- ("@B_25395#CIO1.02") 615 - mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 616 - mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 617 - else 618 - local stat, err = mq.m:connect(mq.config) -- connection 619 - if stat == nil then --Determine whether to connect 620 - print("mqtt connect failed:", err) 621 - return -- Connection failed, return directly 622 - end 623 - mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics 624 - 625 - end 626 - -- mq.m:unsubscribe("stc/test") 627 - -- mq.m:disconnect() -- close matt 628 - -- mq.m:close() -- close clase 629 - end 238 + local status_text ="unknow" 239 + if addr_getbit("@Status Run")==1 then 240 + status_text = "RUNNING" 241 + else 242 + status_text = "STOP" 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 +\\ } 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 + } 282 +\\ ~-~- ("@B_25395#CIO1.02") 283 + mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 284 + mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 285 + else 286 + local stat, err = mq.m:connect(mq.config) ~-~- connection 287 + if stat == nil then ~-~-Determine whether to connect 288 + print("mqtt connect failed:", err) 289 + return ~-~- Connection failed, return directly 290 + end 291 + mq.m:subscribe("mqtt-v-box-epsilon", 0)~-~- Subscribe to topics 292 +\\ end 293 + ~-~- mq.m:unsubscribe("stc/test") 294 + ~-~- mq.m:disconnect() ~-~- close matt 295 + ~-~- mq.m:close() ~-~- close clase 296 + end 630 630 end 631 - {{/code}}298 +))) 632 632 633 -== **2. 3V-Box connect with Azure platform** ==300 +== **2.2 V-Box connect with Azure platform** == 634 634 635 635 In this demo,V-Box connects with Azure by SSL certification. 636 636 ... ... @@ -761,7 +761,7 @@ 761 761 end 762 762 ))) 763 763 764 -== **2. 4How 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 +== **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)** == 765 765 766 766 1.Register a account: [[https:~~/~~/www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ>>https://www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ]] 767 767 ... ... @@ -910,7 +910,7 @@ 910 910 (% style="text-align:center" %) 911 911 [[image:1624441186851-536.png||height="434" width="700" class="img-thumbnail"]] 912 912 913 -== **2. 5V-Box connect with Huawei platform** ==580 +== **2.4 V-Box connect with Huawei platform** == 914 914 915 915 In this demo,V-Box connects with Huawei by SSL certification. 916 916 ... ... @@ -1031,7 +1031,7 @@ 1031 1031 (% style="text-align:center" %) 1032 1032 [[image:1624506666650-161.png||height="547" width="1000" class="img-thumbnail"]] 1033 1033 1034 -== **2. 6V-Box connect with AWS platform** ==701 +== **2.5 V-Box connect with AWS platform** == 1035 1035 1036 1036 === **Log in AWS** === 1037 1037 ... ... @@ -1088,67 +1088,115 @@ 1088 1088 } 1089 1089 {{/code}} 1090 1090 1091 - ===**Create things**===758 +1. **Create things** 1092 1092 1093 1093 Click “Manage”~-~-->“Things”~-~-->“Create things”~-~-->“Create single thing” 1094 1094 1095 -[[image:image-20220709165402-6.png]] 1096 1096 1097 -[[image:image-20220709165402-7.png]] 763 +| 764 +| |[[image:image-20220709165402-6.png]] 1098 1098 766 +| 767 +| |[[image:image-20220709165402-7.png]] 768 + 769 +| 770 +| |[[image:image-20220709165402-8.png]] 771 + 1099 1099 Name the thing~-~-->Click “Next” 1100 1100 1101 -[[image:image-20220709165402-8.png]] 1102 1102 1103 1103 Select the way to create certificate 1104 1104 1105 -[[image:image-20220709165402-9.png]] 1106 1106 778 +| 779 +| |[[image:image-20220709165402-9.png]] 780 + 1107 1107 Select policy 1108 1108 1109 -[[image:image-20220709165402-10.png]] 1110 1110 1111 -[[image:image-20220709165402-11.png]] 784 +| 785 +| |[[image:image-20220709165402-10.png]] 1112 1112 1113 1113 1114 -=== **Test with MQTT.fx tool** === 1115 1115 789 + 790 + 791 + 792 + 793 + 794 + 795 +| 796 +| |[[image:image-20220709165402-11.png]] 797 + 798 + 799 + 800 + 801 + 802 + 803 +1. **Test with MQTT.fx tool** 804 + 1116 1116 Click “View Setting” to get the “Broker Adress” 1117 1117 1118 -[[image:image-20220709165402-13.png]] 1119 1119 1120 -[[image:image-20220709165402-12.png]] 808 +| 809 +| |[[image:image-20220709165402-12.png]] 1121 1121 1122 -Create one connection in MQTT.fx tool, set broker port as 8883. 811 +| 812 +| |[[image:image-20220709165402-13.png]] 1123 1123 1124 -[[image:image-20220709165402-14.png]] 1125 1125 815 + 816 + 817 + 818 + 819 + 820 + 821 +| 822 +| |[[image:image-20220709165402-14.png]] 823 + 824 +Create one connection in MQTT.fx tool, set broker port as 8883. 825 + 1126 1126 Upload the CA File, Client Certificate File, Client Key File 1127 1127 1128 -[[image:image-20220709165402-15.png]] 1129 1129 829 +| 830 +| |[[image:image-20220709165402-15.png]] 831 + 832 + 1130 1130 Publish message to topic “TEST” 1131 1131 1132 -[[image:image-20220709165402-17.png]] 1133 1133 1134 -Click”Test”~-~-->”MQTT test client”~-~-->”Subscrible to a topic”, to get message publish from MQTT.fx tool. 836 +| 837 +| |[[image:image-20220709165402-16.png]] 1135 1135 1136 -[[image:image-20220709173500-1.png]] 839 +| 840 +| |[[image:image-20220709165402-17.png]] 1137 1137 842 +Click”Test”~-~-->”MQTT test client”~-~-->”Subscrible to a topic”, to get message publish from MQTT.fx tool. 843 + 1138 1138 And we can also send message form AWS platform to MQTT.fx tool. 1139 1139 1140 -[[image:image-20220709165402-18.png]] 1141 1141 1142 -=== **Configurate in CloudTool** === 847 +| 848 +| |[[image:image-20220709165402-18.png]] 1143 1143 850 + 851 +1. **Configurate in CloudTool** 852 + 1144 1144 Copy the same setting in MQTT.fx to MQTT configuration 1145 1145 1146 -[[image:image-20220709165402-19.png]] 1147 1147 856 +| 857 +| |[[image:image-20220709165402-19.png]] 858 + 1148 1148 Add a lua script and copy the lua demo into it. 1149 1149 1150 -[[image:image-20220709165402-20.png]] 1151 1151 862 +| 863 +| |[[image:image-20220709165402-20.png]] 864 + 865 + 866 + 1152 1152 sprint = print 1153 1153 1154 1154 ~-~-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) ... ... @@ -1329,6 +1329,10 @@ 1329 1329 1330 1330 end 1331 1331 1047 + 1048 + 1332 1332 Get message in AWS 1333 1333 1334 -[[image:image-20220709165402-21.png]] 1051 + 1052 +| 1053 +| |[[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