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,39 +36,46 @@ 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 - timer = timer + 1 50 - addr_setword("@Timer",timer) 50 + timer = timer + 1 51 + addr_setword("@Timer",timer) 51 51 else 52 - timer = 0 53 - addr_setword("@Timer",timer) 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 - if tag == 0 then 58 - send_sms_ira("19859254700","alarm trigger") 59 - addr_setbit("@Tag",1) 60 - end 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 70 70 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. 71 71 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 + 72 72 {{code language="Lua"}} 73 73 local tempBit = 0 74 74 local tempWord = 0 ... ... @@ -134,7 +134,214 @@ 134 134 end 135 135 {{/code}} 136 136 144 +== **1.6 LINE Notify** == 137 137 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 + 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,157 +153,273 @@ 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** == 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. 157 157 158 -This demo does not use SSL certification. Script is as below 373 +(% class="wikigeneratedid" %) 374 +Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]** 159 159 160 - Demo1:376 +== **2.1 V-Box connect with test server(General Example)** == 161 161 162 -{{code language="Lua"}} 163 --- Meta class 164 ---main 165 -function mq.main() 166 - if not mq.m then 167 - local err = "" 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" 168 168 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) 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 235 235 236 236 405 +--Topic name to subscribed 406 +local SUBSCRIBE_TOPIC = 'testtopic/test/no1/123456' 237 237 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 -------------------------------------------------------------------------------------------------------------------------- 408 +--Topic name to be published 409 +local PUBLISH_TOPIC = 'testtopic/test/no1/7890' 245 245 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, 260 260 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") 412 +--real time 413 +local LAST_TIME = 0 267 267 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 - } 285 285 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 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 296 296 297 - end 298 - -- mq.m:unsubscribe("stc/test") 299 - -- mq.m:disconnect() -- close matt 300 - -- mq.m:close() -- close clase 301 - end 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) 302 302 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 303 303 {{/code}} 304 304 305 -== **2.2 V-Box connect with Azure platform** ==494 +== **2.2 V-Box connect with customer server:grouprobotinfo.com** == 306 306 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 + 307 307 In this demo,V-Box connects with Azure by SSL certification. 308 308 309 309 Video link: [[https:~~/~~/youtu.be/cdI6rIQcpMY?list=PL_Bpnb2RgaksCic9HCcVAZhU9sYwCRKzW>>https://youtu.be/cdI6rIQcpMY?list=PL_Bpnb2RgaksCic9HCcVAZhU9sYwCRKzW]] ... ... @@ -312,137 +312,129 @@ 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 645 +(% class="box infomessage" %) 646 +((( 647 +~-~-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" 650 +~-~-Get custom configuration parameters (vbox custom information) 651 +~-~-local CUSTOM = bns_get_config("bind") 652 +~-~-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) 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) 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' 658 +~-~-MQTT_CFG.username = '60a71ccbbbe12002c08f3a1a_WECON' 659 +~-~-MQTT_CFG.password='wecon123' 660 +~-~-MQTT_CLIENTID = '60a71ccbbbe12002c08f3a1a_WECON_0_0_2021052110usernxame:60a71ccbbbe12002c08f3a1a_WECONpassword:a0a951581855aa8e0262129da6cf1b43f2c0ecfac4fa56117fc5a20c90be169a' 331 331 332 ---publish to topics 662 +~-~-publish to topics 333 333 local pub_RE_TOPIC = string.format('devices/wecon_02/messages/events/') 334 ---Subscribe topics 664 +~-~-Subscribe topics 335 335 local Subscribe_RE_TOPIC1 = string.format('devices/wecon_02/messages/devicebound/#') 336 336 337 ---variable 667 +~-~-variable 338 338 local last_time = 0 339 339 340 340 341 - 342 ---Timing main function 671 +~-~-Timing main function 343 343 function Azure.main() 344 344 345 - 346 - 347 - 348 - 349 - 350 - 351 - 352 - 353 - 354 - 355 - 356 - 357 - 358 - 674 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main start") 675 + if g_mq then 676 + if g_mq:isconnected() then 677 + send_Data() 678 + else 679 + if os.time() - last_time > 20 then 680 + last_time = os.time() 681 + mymqtt_connect() 682 + end 683 + end 684 + else 685 + mymqtt_init() 686 + end 687 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main end") 359 359 end 360 360 361 --- Initialize MQTT 690 +~-~- Initialize MQTT 362 362 function mymqtt_init() 363 - 364 - 365 - 366 - 367 - 368 - 369 - 370 - 692 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) 693 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable 694 + if g_mq then 695 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks 696 + sprint("mqtt init success") 697 + else 698 + sprint("mqtt init failed:", err) 699 + end 371 371 end 372 372 373 --- Connect to MQTT server 702 +~-~- Connect to MQTT server 374 374 function mymqtt_connect() 375 - 376 - 377 - 378 - 379 - 380 - 381 - 382 - 383 - 704 + sprint("mqtt connecting...") 705 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) 706 + if stat == nil then 707 + sprint("mqtt connect failed:", err) 708 + return 709 + else 710 + sprint("mqtt connected") 711 + end 712 + g_mq:subscribe(Subscribe_RE_TOPIC1, 0) 384 384 end 385 385 386 --- Receive MQTT message callback function 715 +~-~- 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 - 717 + print("topic:",topic) 718 + print("revdata:",msg) 719 + ~-~- local revData = json.decode(msg) 720 + ~-~- if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud 721 +~-~- if string.match(topic,Subscribe_RE_TOPIC1) then 722 + ~-~- print("topi11:",topic) 723 + setValue(revData) 724 + ~-~- end 396 396 end 397 397 398 ---Process the received data 399 ---function setValue(revData) 400 - 401 - 402 - 403 - 404 - 405 ---end 727 +~-~-Process the received data 728 +~-~-function setValue(revData) 729 + ~-~- if revData ~~=nil then 730 + ~-~- for i,v in pairs(revData) do 731 + ~-~- print("Data received：",i,v) 732 + ~-~- end 733 + ~-~- end 734 +~-~-end 406 406 407 ---Get real-time data 736 +~-~-Get real-time data 408 408 function getData() 409 - 410 - 411 - 412 - 413 - 414 - 415 - 416 - 417 - 418 -end 738 + local jdata = {} 739 + local addr = bns_get_alldata() 740 + print(json.encode(addr)) 741 + for i,v in pairs(addr) do 742 + if v[2] == 1 then 743 + jdata[v[3]] = v[4] 744 + end 745 + end 746 + return jdata 747 +end 419 419 420 420 421 - 422 ---send data 750 +~-~-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 - -- }} 752 + local pub_data = {100 753 + ~-~- services=~{~{ 754 +\\ ~-~-serviceId ='Temperature', 755 + ~-~- properties={ 756 + ~-~- value = 55 757 + ~-~- }, 758 + ~-~- }} 432 432 } 433 433 sprint(json.encode(pub_data)) 434 434 print("..........",pub_RE_TOPIC) 435 - 762 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) 436 436 end 437 -{{/code}} 438 - 439 -== **2.3 How to configure the Huawei platform?** == 440 - 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 444 ))) 445 445 766 +== **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）** == 767 + 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 448 448 2.log in the Huawei IOTDA ... ... @@ -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** ==915 +== **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** ==1036 +== **2.6 V-Box connect with AWS platform** == 715 715 716 716 === **Log in AWS** === 717 717 ... ... @@ -768,99 +768,67 @@ 768 768 } 769 769 {{/code}} 770 770 771 - 1.**Create things**1093 +=== **Create things** === 772 772 773 773 Click “Manage”~-~-->“Things”~-~-->“Create things”~-~-->“Create single thing” 774 774 1097 +[[image:image-20220709165402-6.png]] 775 775 776 -| 777 -| |[[image:image-20220709165402-6.png]] 1099 +[[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 1103 +[[image:image-20220709165402-8.png]] 787 787 788 788 Select the way to create certificate 789 789 1107 +[[image:image-20220709165402-9.png]] 790 790 791 -| 792 -| |[[image:image-20220709165402-9.png]] 793 - 794 794 Select policy 795 795 1111 +[[image:image-20220709165402-10.png]] 796 796 797 -| 798 -| |[[image:image-20220709165402-10.png]] 1113 +[[image:image-20220709165402-11.png]] 799 799 800 800 1116 +=== **Test with MQTT.fx tool** === 801 801 802 - 803 - 804 -| 805 -| |[[image:image-20220709165402-11.png]] 806 - 807 - 808 -1. **Test with MQTT.fx tool** 809 - 810 810 Click “View Setting” to get the “Broker Adress” 811 811 1120 +[[image:image-20220709165402-13.png]] 812 812 813 -| 814 -| |[[image:image-20220709165402-12.png]] 1122 +[[image:image-20220709165402-12.png]] 815 815 816 -| 817 -| |[[image:image-20220709165402-13.png]] 818 - 819 - 820 - 821 - 822 -| 823 -| |[[image:image-20220709165402-14.png]] 824 - 825 825 Create one connection in MQTT.fx tool, set broker port as 8883. 826 826 1126 +[[image:image-20220709165402-14.png]] 1127 + 827 827 Upload the CA File, Client Certificate File, Client Key File 828 828 1130 +[[image:image-20220709165402-15.png]] 829 829 830 -| 831 -| |[[image:image-20220709165402-15.png]] 832 - 833 833 Publish message to topic “TEST” 834 834 1134 +[[image:image-20220709165402-17.png]] 835 835 836 -| 837 -| |[[image:image-20220709165402-16.png]] 838 - 839 -| 840 -| |[[image:image-20220709165402-17.png]] 841 - 842 842 Click”Test”~-~-->”MQTT test client”~-~-->”Subscrible to a topic”, to get message publish from MQTT.fx tool. 843 843 1138 +[[image:image-20220709173500-1.png]] 1139 + 844 844 And we can also send message form AWS platform to MQTT.fx tool. 845 845 1142 +[[image:image-20220709165402-18.png]] 846 846 847 -| 848 -| |[[image:image-20220709165402-18.png]] 1144 +=== **Configurate in CloudTool** === 849 849 850 -1. **Configurate in CloudTool** 851 - 852 852 Copy the same setting in MQTT.fx to MQTT configuration 853 853 1148 +[[image:image-20220709165402-19.png]] 854 854 855 -| 856 -| |[[image:image-20220709165402-19.png]] 857 - 858 858 Add a lua script and copy the lua demo into it. 859 859 1152 +[[image:image-20220709165402-20.png]] 860 860 861 -| 862 -| |[[image:image-20220709165402-20.png]] 863 - 864 864 sprint = print 865 865 866 866 ~-~-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) ... ... @@ -1041,10 +1041,6 @@ 1041 1041 1042 1042 end 1043 1043 1044 - 1045 - 1046 1046 Get message in AWS 1047 1047 1048 - 1049 -| 1050 -| |[[image:image-20220709165402-21.png]] 1336 +[[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