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, 0 added, 1 removed)
Details
- Page properties
-
- Author
-
... ... @@ -1,1 +1,1 @@ 1 -XWiki. Hunter1 +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 - 51 - 49 + timer = timer + 1 50 + addr_setword("@Timer",timer) 52 52 else 53 - 54 - 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 - 59 - 60 - 61 - 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,214 +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 -About how to register the Twilio API, please check the following video: 228 - 229 -[[https:~~/~~/www.youtube.com/watch?v=Id4lKichauU>>https://www.youtube.com/watch?v=Id4lKichauU]] 230 - 231 -{{code language="Lua"}} 232 -local tempBit = 0 233 -local tempWord = 0 234 - 235 -local https = require("https") 236 -local json = require("json") 237 -local ltn12 = require("ltn12") 238 - 239 -local SID = 'AC1703bd710ffa98006d2bcc0b********' 240 -local Token = 'd3c11897623c39e538b20263ec19****' 241 - 242 -local twilioPhoneNumber = '+14155238886' 243 -local receiverPhoneNumber = '+8615880018277' 244 - 245 -local b='ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/' 246 -function encodingBase64(data) 247 - return ((data:gsub('.', function(x) 248 - local r,b='',x:byte() 249 - for i=8,1,-1 do r=r..(b%2^i-b%2^(i-1)>0 and '1' or '0') end 250 - return r; 251 - end)..'0000'):gsub('%d%d%d?%d?%d?%d?', function(x) 252 - if (#x < 6) then return '' end 253 - local c=0 254 - for i=1,6 do c=c+(x:sub(i,i)=='1' and 2^(6-i) or 0) end 255 - return b:sub(c+1,c+1) 256 - end)..({ '', '==', '=' })[#data%3+1]) 257 -end 258 - 259 -function encodeUrl(str) 260 - str = string.gsub(str, "([^%w%.%- ])", function(c) 261 - return string.format("%%%02X", string.byte(c)) end) 262 - return string.gsub(str, " ", "+") 263 -end 264 - 265 - 266 - 267 - 268 -function requestBodySplice(message, sender, receiver) 269 - local reqBody = '' 270 - local encodeMess = encodeUrl(message) 271 - local encodeSend = encodeUrl(sender) 272 - local encodeRece = encodeUrl(receiver) 273 - --reqBody = "Body=Hello%20Wecon2&From=whatsapp%3A%2B14155238886&To=whatsapp%3A%2B8615880018277" 274 - reqBody = string.format("Body=%s&From=whatsapp:%s&To=whatsapp:%s", encodeMess, encodeSend, encodeRece) 275 - print(reqBody) 276 - return reqBody 277 -end 278 - 279 - 280 --- Send http.get request and return response result 281 -function getHttpsUrl(url,header,reqbody) 282 - local body = {} 283 - local bodyJson = json.encode(body) 284 - local result_table, code, headers, status = https.request{ 285 - method = "POST", 286 - url = url, 287 - source = ltn12.source.string(reqbody), 288 - headers = header, 289 - sink = ltn12.sink.table(body) 290 - } 291 - print("code:"..code) 292 - if code~= 200 then 293 - return 294 - else 295 - return body 296 - end 297 -end 298 - 299 -function getMessageUrl(whatsAppMessage) 300 - local auth = SID..':'..Token 301 - local url = "https://api.twilio.com/2010-04-01/Accounts/"..SID.."/Messages" 302 - --local reqMess = "message="..twilioMessage 303 - local reqMess = requestBodySplice(whatsAppMessage, twilioPhoneNumber, receiverPhoneNumber) 304 - local headers = 305 - { 306 - ["Authorization"] = "Basic "..encodingBase64(auth), 307 - ["Content-Type"] = "application/x-www-form-urlencoded", 308 - ["Content-Length"] = #reqMess 309 - } 310 - 311 - print("Get the link:"..url) 312 - getHttpsUrl(url, headers, reqMess) 313 -end 314 - 315 - 316 - 317 -function Twilio.main() 318 - --dosomething 319 - --local auth = SID..':'..Token 320 - --print(requestBodySplice("HelloWorld", twilioPhoneNumber, receiverPhoneNumber)) 321 - --print(encodingBase64(auth)) 322 - local bitValue = addr_getbit("@testBit"); 323 - local message = '' 324 - print("b=="..bitValue) 325 - if bitValue == 1 and bitValue ~= tempBit then 326 - message = 'Alarm V-Box triggered, the output is '.. bitValue 327 - getMessageUrl(message) 328 - print("Notification pushed of triggering alarm,"..bitValue) 329 - elseif bitValue == 0 and bitValue ~= tempBit then 330 - message = 'Alarm V-Box dismissed, the output is '.. bitValue 331 - getMessageUrl(message) 332 - print("Notification pushed of dismissing alarm,"..bitValue) 333 - end 334 - tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform 335 - 336 - local wordValue = addr_getword("@testWord") 337 - print("w=="..wordValue) 338 - --dosomething 339 - if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then 340 - message = 'Alarm V-Box triggered, the temperature is '.. wordValue 341 - getMessageUrl(message) 342 - print("Notification pushed of triggering alarm,"..wordValue) 343 - elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then 344 - message = 'Alarm V-Box dismissed, the temperature is '.. wordValue 345 - getMessageUrl(message) 346 - print("Notification pushed of dismissing alarm,"..wordValue) 347 - end 348 - tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform 349 -end 350 -{{/code}} 351 - 352 352 = **2 V-Box connect with third part server** = 353 353 354 354 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. ... ... @@ -367,273 +367,157 @@ 367 367 368 368 (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate 369 369 370 -(% class="wikigeneratedid" %) 371 -**✎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** == 372 372 373 -(% class="wikigeneratedid" %) 374 -Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]** 158 +This demo does not use SSL certification. Script is as below 375 375 376 - == **2.1 V-Box connect with test server(General Example)** ==160 +Demo1: 377 377 378 -{{code language="lua"}} 379 ---MQTT configuration table 380 -local MQTT_CFG={} 381 -MQTT_CFG.username = "weconsupport" 382 -MQTT_CFG.password = "123456" 383 -MQTT_CFG.netway = 0 384 -MQTT_CFG.keepalive = 60 385 -MQTT_CFG.cleansession = 1 386 ---TCP URL 387 -MQTT_URL = "tcp://mq.tongxinmao.com:1883" 388 ---Client ID 389 -MQTT_CLIENT_ID = "V-BOXH-AG" 162 +{{code language="Lua"}} 163 +-- Meta class 164 +--main 165 +function mq.main() 166 + if not mq.m then 167 + local err = "" 390 390 391 ---Generate UUID 392 -function uuid() 393 - local seed = {'e','1','2','3','4','5','6','7','8','9','a','b','c','d','e','f'} 394 - local tb = {} 395 - for i=1, 32 do 396 - table.insert(tb, seed[math.random(1,16)]) 397 - end 398 - local sid=table.concat(tb) 399 - return string.format('%s', 400 - string.sub(sid,1,32) 401 - ) 402 -end 169 + mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection 170 + if mq.m then 171 + mq.config = { 172 + username = "",-- ID 173 + password = "",-- password 174 + netway = 1, -- Ethernet connection, WIFI=1 175 + -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds. 176 + -- cleansession = 0, -- Optional, keep session 177 + } 178 + mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks 179 + local str = string.format("%s:%s", topic, msg) 180 + -- print("mqtt msg:", str) -- Print out the received topics and content 181 + end 182 + ) 183 + mq.m:on("offline", function (cause) -- Register for lost connection callbacks 184 + -- addr_setstring("@xxx", "cause"..(cause or " got nil")) 185 + end) 186 + mq.m:on("arrived", function() -- Registration for sending messages to callbacks 187 + print("msg arrived") 188 + end) 189 + else 190 + print("mqtt create failed:", err) -- Create object failed 191 + end 192 + else 193 + if mq.m:isconnected() then -- If online, post a message 194 + local phaseStatus ="unknow" 195 + if addr_getbit("@Standby")== 1 then 196 + phaseStatus = "Standby" 197 + elseif addr_getbit("@Pre-Freeze")==1 then 198 + phaseStatus= "Pre-Freeze" 199 + elseif addr_getbit("@Prepare")==1 then 200 + phaseStatus ="Prepare" 201 + elseif addr_getbit("@Primary Dry")==1 then 202 + phaseStatus = "Primary dry" 203 + elseif addr_getbit("@Secondary Dry")==1 then 204 + phaseStatus = "Secondary Dry" 205 + end 206 +-- print(addr_getbit("@Primary Dry")) 207 +------------------------------------------------------------------------------------------------------------------------- 208 + local activating ="unknow" 209 + if addr_getbit("@Compressor")==1 then 210 + activating = ",".."Compressor" 211 + end 212 + if addr_getbit("@Silicone Pump")==1 then 213 + activating = activating..",".."Silicone Pump" 214 + end 215 + if addr_getbit("@Vacuum Pump")==1 then 216 + activating = activating..",".."Vacuum Pump" 217 + end 218 + if addr_getbit("@Root Pump")==1 then 219 + activating = activating..",".."Root Pump" 220 + end 221 + if addr_getbit("@Heater")==1 then 222 + activating = activating..",".."Heater" 223 + end 224 + if addr_getbit("@Valve Silicone")==1 then 225 + activating = activating..",".."Valve Silicone" 226 + end 227 + if addr_getbit("@Valve Ice Condenser")==1 then 228 + activating = activating..",".."Valve Ice Condenser" 229 + end 230 + if addr_getbit("@Valve Vacuum Pump")==1 then 231 + activating = activating..",".."Valve Vacuum Pump" 232 + end 233 + local pr_activating =string.sub(activating,2) 234 + -- print(pr_activating) 403 403 404 404 405 ---Topic name to subscribed 406 -local SUBSCRIBE_TOPIC = 'testtopic/test/no1/123456' 407 407 408 ---Topic name to be published 409 -local PUBLISH_TOPIC = 'testtopic/test/no1/7890' 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 +------------------------------------------------------------------------------------------------------------------------- 410 410 246 + local js = {type="status", 247 + mc_name ="FD300", 248 + status=status_text, 249 + elapsed_time={ 250 + hour=addr_getword("@Elapsed Time (Hour)"), 251 + min=addr_getword("@Elapsed Time (Minute)"), 252 + sec=addr_getword("@Elapsed Time (Second)") 253 + }, 254 + phase = phaseStatus, 255 + step = addr_getword("@Step"), 256 + activating_output = pr_activating, 257 + sv=addr_getshort("@SV Silicone")/10, 258 + pv=addr_getshort("@PV Silicone")/10, 259 + product1=addr_getshort("@Product 1")/10, 411 411 412 ---real time 413 -local LAST_TIME = 0 261 + product2=addr_getshort("@Product 2")/10, 262 + product3=addr_getshort("@Product 3")/10, 263 + product4=addr_getshort("@Product 4")/10, 264 + ice1=addr_getshort("@Ice condenser 1")/10, 265 + ice2=addr_getshort("@Ice condenser 2")/10, 266 + vacuum=addr_getfloat("@Vacuum") 414 414 268 + } 269 + local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"), 270 + ODPC = addr_getbit("@B_25395#W0.01"), 271 + MTPC=addr_getbit("@B_25395#W0.02"), 272 + HTT = addr_getbit("@B_25395#W1.03"), 273 + CPC = addr_getbit("@B_25395#W0.08"), 274 + CPSP =addr_getbit("@B_25395#W1.00"), 275 + CPVP =addr_getbit("@B_25395#W0.10"), 276 + CPRP =addr_getbit("@B_25395#W0.11"), 277 + HP =addr_getbit("@B_25395#W1.01"), 278 + PP= addr_getbit("@B_25395#W1.02"), 279 + PO=addr_getbit("@B_25395#W0.07"), 280 + FSE=addr_getbit("@B_25395#W2.04"), 281 + AVVSVV=addr_getbit("@B_25395#W1.12"), 282 + ICHT=addr_getbit("@B_25395#W3.06") 283 + 284 + } 415 415 416 ---initialize mqtt 417 -function mqtt_init() 418 - print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID)) 419 - g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable 420 - if g_mq then 421 - g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages 422 - print("mqtt init success") 423 - else 424 - print("mqtt init failed:", err) 425 - end 426 -end 286 + -- ("@B_25395#CIO1.02") 287 + mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 288 + mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 289 + else 290 + local stat, err = mq.m:connect(mq.config) -- connection 291 + if stat == nil then --Determine whether to connect 292 + print("mqtt connect failed:", err) 293 + return -- Connection failed, return directly 294 + end 295 + mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics 427 427 428 --- connect to mqtt 429 -function mqtt_connect() 430 - print("mqtt connecting...") 431 - local stat, err = g_mq:connect(MQTT_CFG) 432 - if stat == nil then 433 - print("mqtt connect failed:", err) 434 - return 435 - else 436 - print("mqtt connected") 437 - end 438 - g_mq:subscribe(SUBSCRIBE_TOPIC, 0) 297 + end 298 + -- mq.m:unsubscribe("stc/test") 299 + -- mq.m:disconnect() -- close matt 300 + -- mq.m:close() -- close clase 301 + end 439 439 end 440 - 441 --- Received message callback function 442 -function mqtt_msg_callback(topic, msg) 443 - print("topic:", topic) 444 - print("msg:", msg) 445 - local objMsg = json.decode(msg) 446 - local water = objMsg.data.waterlevel 447 - local temp = objMsg.data.temperature 448 - addr_setword("@HDW20",water) 449 - addr_setword("@HDW10",temp) 450 -end 451 - 452 ---Send data (data upload to platform and encapsulate it with custom functions) 453 -function send_data() 454 - local pub_data = { 455 - timestamp = os.time(), 456 - messageId = 1, 457 - event = 'test_data', 458 - mfrs = 'V-Box', 459 - data = { 460 - id = uuid(), 461 - waterlevel = addr_getword("@HDW10"), 462 - temperature = addr_getword("@HDW20") 463 - } 464 - } 465 - return g_mq:publish(PUBLISH_TOPIC, json.encode(pub_data), 0, 0) 466 -end 467 - 468 - 469 ---main function fixed timed execution 470 -function MQTT.main() 471 - --dosomething 472 - print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main start") 473 - --determine the mqtt object whether exist 474 - if g_mq then 475 - --determine the mqtt object whether has been connected or not 476 - if g_mq:isconnected() then 477 - send_data() 478 - else 479 - --if exceed 20 sec not connect, reconnect once 480 - if os.time() - LAST_TIME > 20 then 481 - LAST_TIME = os.time() 482 - --connect to mqtt or reconnect 483 - mqtt_connect() 484 - end 485 - end 486 - else 487 - --mqtt object does not exist so create new one 488 - mqtt_init() 489 - end 490 - print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main end") 491 -end 492 492 {{/code}} 493 493 494 -== **2.2 V-Box connect with customerserver:grouprobotinfo.com** ==305 +== **2.2 V-Box connect with Azure platform** == 495 495 496 -This demo does not use SSL certification. Script is as below 497 - 498 -Demo1: 499 - 500 -{{code language="lua"}} 501 --- Meta class 502 ---main 503 -function mq.main() 504 - if not mq.m then 505 - local err = "" 506 - 507 - mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection 508 - if mq.m then 509 - mq.config = { 510 - username = "",-- ID 511 - password = "",-- password 512 - netway = 1, -- Ethernet connection, WIFI=1 513 - -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds. 514 - -- cleansession = 0, -- Optional, keep session 515 - } 516 - mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks 517 - local str = string.format("%s:%s", topic, msg) 518 - -- print("mqtt msg:", str) -- Print out the received topics and content 519 - end) 520 - mq.m:on("offline", function (cause) -- Register for lost connection callbacks 521 - -- addr_setstring("@xxx", "cause"..(cause or " got nil")) 522 - end) 523 - mq.m:on("arrived", function() -- Registration for sending messages to callbacks 524 - print("msg arrived") 525 - end) 526 - else 527 - print("mqtt create failed:", err) -- Create object failed 528 - end 529 - else 530 - if mq.m:isconnected() then -- If online, post a message 531 - local phaseStatus ="unknow" 532 - if addr_getbit("@Standby")== 1 then 533 - phaseStatus = "Standby" 534 - elseif addr_getbit("@Pre-Freeze")==1 then 535 - phaseStatus= "Pre-Freeze" 536 - elseif addr_getbit("@Prepare")==1 then 537 - phaseStatus ="Prepare" 538 - elseif addr_getbit("@Primary Dry")==1 then 539 - phaseStatus = "Primary dry" 540 - elseif addr_getbit("@Secondary Dry")==1 then 541 - phaseStatus = "Secondary Dry" 542 - end 543 - --print(addr_getbit("@Primary Dry")) 544 -------------------------------------------------------------------------------------------------------------------------- 545 - local activating ="unknow" 546 - if addr_getbit("@Compressor")==1 then 547 - activating = ",".."Compressor" 548 - end 549 - if addr_getbit("@Silicone Pump")==1 then 550 - activating = activating..",".."Silicone Pump" 551 - end 552 - if addr_getbit("@Vacuum Pump")==1 then 553 - activating = activating..",".."Vacuum Pump" 554 - end 555 - if addr_getbit("@Root Pump")==1 then 556 - activating = activating..",".."Root Pump" 557 - end 558 - if addr_getbit("@Heater")==1 then 559 - activating = activating..",".."Heater" 560 - end 561 - if addr_getbit("@Valve Silicone")==1 then 562 - activating = activating..",".."Valve Silicone" 563 - end 564 - if addr_getbit("@Valve Ice Condenser")==1 then 565 - activating = activating..",".."Valve Ice Condenser" 566 - end 567 - if addr_getbit("@Valve Vacuum Pump")==1 then 568 - activating = activating..",".."Valve Vacuum Pump" 569 - end 570 - local pr_activating =string.sub(activating,2) 571 - -- print(pr_activating) 572 - local status_text ="unknow" 573 - if addr_getbit("@Status Run")==1 then 574 - status_text = "RUNNING" 575 - else 576 - status_text = "STOP" 577 - end 578 -------------------------------------------------------------------------------------------------------------------------- 579 - local js = {type="status", 580 - mc_name ="FD300", 581 - status=status_text, 582 - elapsed_time={ 583 - hour=addr_getword("@Elapsed Time (Hour)"), 584 - min=addr_getword("@Elapsed Time (Minute)"), 585 - sec=addr_getword("@Elapsed Time (Second)") 586 - }, 587 - phase = phaseStatus, 588 - step = addr_getword("@Step"), 589 - activating_output = pr_activating, 590 - sv=addr_getshort("@SV Silicone")/10, 591 - pv=addr_getshort("@PV Silicone")/10, 592 - product1=addr_getshort("@Product 1")/10, 593 - 594 - product2=addr_getshort("@Product 2")/10, 595 - product3=addr_getshort("@Product 3")/10, 596 - product4=addr_getshort("@Product 4")/10, 597 - ice1=addr_getshort("@Ice condenser 1")/10, 598 - ice2=addr_getshort("@Ice condenser 2")/10, 599 - vacuum=addr_getfloat("@Vacuum") 600 - } 601 - local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"), 602 - ODPC = addr_getbit("@B_25395#W0.01"), 603 - MTPC=addr_getbit("@B_25395#W0.02"), 604 - HTT = addr_getbit("@B_25395#W1.03"), 605 - CPC = addr_getbit("@B_25395#W0.08"), 606 - CPSP =addr_getbit("@B_25395#W1.00"), 607 - CPVP =addr_getbit("@B_25395#W0.10"), 608 - CPRP =addr_getbit("@B_25395#W0.11"), 609 - HP =addr_getbit("@B_25395#W1.01"), 610 - PP= addr_getbit("@B_25395#W1.02"), 611 - PO=addr_getbit("@B_25395#W0.07"), 612 - FSE=addr_getbit("@B_25395#W2.04"), 613 - AVVSVV=addr_getbit("@B_25395#W1.12"), 614 - ICHT=addr_getbit("@B_25395#W3.06") 615 - } 616 - -- ("@B_25395#CIO1.02") 617 - mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 618 - mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 619 - else 620 - local stat, err = mq.m:connect(mq.config) -- connection 621 - if stat == nil then --Determine whether to connect 622 - print("mqtt connect failed:", err) 623 - return -- Connection failed, return directly 624 - end 625 - mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics 626 - 627 - end 628 - -- mq.m:unsubscribe("stc/test") 629 - -- mq.m:disconnect() -- close matt 630 - -- mq.m:close() -- close clase 631 - end 632 -end 633 -{{/code}} 634 - 635 -== **2.3 V-Box connect with Azure platform** == 636 - 637 637 In this demo,V-Box connects with Azure by SSL certification. 638 638 639 639 Video link: [[https:~~/~~/youtu.be/cdI6rIQcpMY?list=PL_Bpnb2RgaksCic9HCcVAZhU9sYwCRKzW>>https://youtu.be/cdI6rIQcpMY?list=PL_Bpnb2RgaksCic9HCcVAZhU9sYwCRKzW]] ... ... @@ -642,129 +642,137 @@ 642 642 643 643 Script is as below 644 644 645 -(% class="box infomessage" %) 646 -((( 647 -~-~-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 648 648 sprint = print 649 649 650 - ~-~-Get custom configuration parameters (vbox custom information)651 - ~-~-local CUSTOM = bns_get_config("bind")652 - ~-~-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" 653 653 654 654 655 -~-~-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) 656 656 local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg() 657 657 658 - ~-~-MQTT_CFG.username = '60a71ccbbbe12002c08f3a1a_WECON'659 - ~-~-MQTT_CFG.password='wecon123'660 - ~-~-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' 661 661 662 - ~-~-publish to topics332 +--publish to topics 663 663 local pub_RE_TOPIC = string.format('devices/wecon_02/messages/events/') 664 - ~-~-Subscribe topics334 +--Subscribe topics 665 665 local Subscribe_RE_TOPIC1 = string.format('devices/wecon_02/messages/devicebound/#') 666 666 667 - ~-~-variable337 +--variable 668 668 local last_time = 0 669 669 670 670 671 -~-~-Timing main function 341 + 342 +--Timing main function 672 672 function Azure.main() 673 673 674 - 675 - 676 - 677 - 678 - 679 - 680 - 681 - 682 - 683 - 684 - 685 - 686 - 687 - 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") 688 688 end 689 689 690 - ~-~- Initialize MQTT361 +-- Initialize MQTT 691 691 function mymqtt_init() 692 - 693 - ~-~- Create the object and declare it as a global variable694 - 695 - ~-~- Register to receive message callbacks696 - 697 - 698 - 699 - 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 700 700 end 701 701 702 - ~-~- Connect to MQTT server373 +-- Connect to MQTT server 703 703 function mymqtt_connect() 704 - 705 - 706 - 707 - 708 - 709 - 710 - 711 - 712 - 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) 713 713 end 714 714 715 - ~-~- Receive MQTT message callback function386 +-- Receive MQTT message callback function 716 716 function mymqtt_msg_callback(topic, msg) 717 - 718 - 719 - ~-~- local revData = json.decode(msg)720 - ~-~-~-~-Process topic information subscribed from the cloud721 - ~-~- if string.match(topic,Subscribe_RE_TOPIC1) then722 - ~-~-723 - 724 - ~-~- end388 + 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 725 725 end 726 726 727 - ~-~-Process the received data728 - ~-~-function setValue(revData)729 - ~-~- if revData ~~=nil then730 - ~-~-731 - ~-~-732 - ~-~-733 - ~-~- end734 - ~-~-end398 +--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 735 735 736 - ~-~-Get real-time data407 +--Get real-time data 737 737 function getData() 738 - 739 - 740 - 741 - 742 - 743 - 744 - 745 - 746 - 747 -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 748 748 749 749 750 -~-~-send data 421 + 422 +--send data 751 751 function send_Data() 752 - local pub_data = {100 753 - ~-~- services=~{~{ 754 -\\ ~-~-serviceId ='Temperature', 755 - ~-~- properties={ 756 - ~-~- value = 55 757 - ~-~- }, 758 - ~-~- }} 424 + local pub_data = {100 425 + -- services={{ 426 + 427 + --serviceId ='Temperature', 428 + -- properties={ 429 + -- value = 55 430 + -- }, 431 + -- }} 759 759 } 760 760 sprint(json.encode(pub_data)) 761 761 print("..........",pub_RE_TOPIC) 762 - 435 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) 763 763 end 764 - )))437 +{{/code}} 765 765 766 -== **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）** ==439 +== **2.3 How to configure the Huawei platform?** == 767 767 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 + 768 768 1.Register a account: [[https:~~/~~/www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ>>https://www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ]] 769 769 770 770 2.log in the Huawei IOTDA ... ... @@ -912,7 +912,7 @@ 912 912 (% style="text-align:center" %) 913 913 [[image:1624441186851-536.png||height="434" width="700" class="img-thumbnail"]] 914 914 915 -== **2. 5V-Box connect with Huawei platform** ==593 +== **2.4 V-Box connect with Huawei platform** == 916 916 917 917 In this demo,V-Box connects with Huawei by SSL certification. 918 918 ... ... @@ -1033,7 +1033,7 @@ 1033 1033 (% style="text-align:center" %) 1034 1034 [[image:1624506666650-161.png||height="547" width="1000" class="img-thumbnail"]] 1035 1035 1036 -== **2. 6V-Box connect with AWS platform** ==714 +== **2.5 V-Box connect with AWS platform** == 1037 1037 1038 1038 === **Log in AWS** === 1039 1039 ... ... @@ -1090,67 +1090,96 @@ 1090 1090 } 1091 1091 {{/code}} 1092 1092 1093 - ===**Create things**===771 +1. **Create things** 1094 1094 1095 1095 Click “Manage”~-~-->“Things”~-~-->“Create things”~-~-->“Create single thing” 1096 1096 1097 -[[image:image-20220709165402-6.png]] 1098 1098 1099 -[[image:image-20220709165402-7.png]] 776 +| 777 +| |[[image:image-20220709165402-6.png]] 1100 1100 779 +| 780 +| |[[image:image-20220709165402-7.png]] 781 + 782 +| 783 +| |[[image:image-20220709165402-8.png]] 784 + 1101 1101 Name the thing~-~-->Click “Next” 1102 1102 1103 -[[image:image-20220709165402-8.png]] 1104 1104 1105 1105 Select the way to create certificate 1106 1106 1107 -[[image:image-20220709165402-9.png]] 1108 1108 791 +| 792 +| |[[image:image-20220709165402-9.png]] 793 + 1109 1109 Select policy 1110 1110 1111 -[[image:image-20220709165402-10.png]] 1112 1112 1113 -[[image:image-20220709165402-11.png]] 797 +| 798 +| |[[image:image-20220709165402-10.png]] 1114 1114 1115 1115 1116 -=== **Test with MQTT.fx tool** === 1117 1117 802 + 803 +| 804 +| |[[image:image-20220709165402-11.png]] 805 + 806 +1. **Test with MQTT.fx tool** 807 + 1118 1118 Click “View Setting” to get the “Broker Adress” 1119 1119 1120 -[[image:image-20220709165402-13.png]] 1121 1121 1122 -[[image:image-20220709165402-12.png]] 811 +| 812 +| |[[image:image-20220709165402-12.png]] 1123 1123 1124 -Create one connection in MQTT.fx tool, set broker port as 8883. 814 +| 815 +| |[[image:image-20220709165402-13.png]] 1125 1125 1126 -[[image:image-20220709165402-14.png]] 1127 1127 818 + 819 +| 820 +| |[[image:image-20220709165402-14.png]] 821 + 822 +Create one connection in MQTT.fx tool, set broker port as 8883. 823 + 1128 1128 Upload the CA File, Client Certificate File, Client Key File 1129 1129 1130 -[[image:image-20220709165402-15.png]] 1131 1131 827 +| 828 +| |[[image:image-20220709165402-15.png]] 829 + 1132 1132 Publish message to topic “TEST” 1133 1133 1134 -[[image:image-20220709165402-17.png]] 1135 1135 1136 -Click”Test”~-~-->”MQTT test client”~-~-->”Subscrible to a topic”, to get message publish from MQTT.fx tool. 833 +| 834 +| |[[image:image-20220709165402-16.png]] 1137 1137 1138 -[[image:image-20220709173500-1.png]] 836 +| 837 +| |[[image:image-20220709165402-17.png]] 1139 1139 839 +Click”Test”~-~-->”MQTT test client”~-~-->”Subscrible to a topic”, to get message publish from MQTT.fx tool. 840 + 1140 1140 And we can also send message form AWS platform to MQTT.fx tool. 1141 1141 1142 -[[image:image-20220709165402-18.png]] 1143 1143 1144 -=== **Configurate in CloudTool** === 844 +| 845 +| |[[image:image-20220709165402-18.png]] 1145 1145 847 +1. **Configurate in CloudTool** 848 + 1146 1146 Copy the same setting in MQTT.fx to MQTT configuration 1147 1147 1148 -[[image:image-20220709165402-19.png]] 1149 1149 852 +| 853 +| |[[image:image-20220709165402-19.png]] 854 + 1150 1150 Add a lua script and copy the lua demo into it. 1151 1151 1152 -[[image:image-20220709165402-20.png]] 1153 1153 858 +| 859 +| |[[image:image-20220709165402-20.png]] 860 + 1154 1154 sprint = print 1155 1155 1156 1156 ~-~-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) ... ... @@ -1331,6 +1331,10 @@ 1331 1331 1332 1332 end 1333 1333 1041 + 1042 + 1334 1334 Get message in AWS 1335 1335 1336 -[[image:image-20220709165402-21.png]] 1045 + 1046 +| 1047 +| |[[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