Changes for page 2 Script
Last modified by Devin Chen on 2025/06/06 14:03
From version 17.1
edited by Jim(Forgotten)
on 2022/07/09 17:47
on 2022/07/09 17:47
Change comment:
There is no comment for this version
Summary
-
Page properties (2 modified, 0 added, 0 removed)
Details
- Page properties
-
- Author
-
... ... @@ -1,1 +1,1 @@ 1 -XWiki. Jim1 +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 ... ... @@ -135,7 +135,210 @@ 135 135 end 136 136 {{/code}} 137 137 138 +== **1.6 LINE Notify** == 138 138 140 +This example shows how to use the LINE Notify to send message into LINE group. When monitoring bit "@test" changes, it will trigger and send the message. Please replace with your own Token. 141 + 142 +{{code}} 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 "@test" 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 + 139 139 = **2 V-Box connect with third part server** = 140 140 141 141 V-Box have two mode.One is for V-Net,User need to use WECON server to store data.We call this V-NET platform. ... ... @@ -154,149 +154,280 @@ 154 154 155 155 (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate 156 156 157 -== **2.1 V-Box connect with customer server:grouprobotinfo.com** == 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. 158 158 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 + 159 159 This demo does not use SSL certification. Script is as below 160 160 161 161 Demo1: 162 162 163 -(% class="box infomessage" %) 164 -((( 165 -~-~- Meta class 166 -~-~-main 490 +{{code language="lua"}} 491 +-- Meta class 492 +--main 167 167 function mq.main() 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) 494 + if not mq.m then 495 + local err = "" 236 236 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) 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 -~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-- 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 -\\ ~-~- ("@B_25395#CIO1.02") 282 - mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 283 - mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 284 - else 285 - local stat, err = mq.m:connect(mq.config) ~-~- connection 286 - if stat == nil then ~-~-Determine whether to connect 287 - print("mqtt connect failed:", err) 288 - return ~-~- Connection failed, return directly 289 - end 290 - mq.m:subscribe("mqtt-v-box-epsilon", 0)~-~- Subscribe to topics 291 -\\ end 292 - ~-~- mq.m:unsubscribe("stc/test") 293 - ~-~- mq.m:disconnect() ~-~- close matt 294 - ~-~- mq.m:close() ~-~- close clase 295 - end 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 296 296 end 297 - )))631 +{{/code}} 298 298 299 -== **2. 2V-Box connect with Azure platform** ==633 +== **2.3 V-Box connect with Azure platform** == 300 300 301 301 In this demo,V-Box connects with Azure by SSL certification. 302 302 ... ... @@ -427,7 +427,7 @@ 427 427 end 428 428 ))) 429 429 430 -== **2. 3How to configure the Huawei platform?(✎Note: Huawei IOT DA function is only in China area.If you want this function,you need to use chinese mobile to register)** ==764 +== **2.4 How to configure the Huawei platform?(✎Note: Huawei IOT DA function is only in China area.If you want this function,you need to use chinese mobile to register)** == 431 431 432 432 1.Register a account: [[https:~~/~~/www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ>>https://www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ]] 433 433 ... ... @@ -576,7 +576,7 @@ 576 576 (% style="text-align:center" %) 577 577 [[image:1624441186851-536.png||height="434" width="700" class="img-thumbnail"]] 578 578 579 -== **2. 4V-Box connect with Huawei platform** ==913 +== **2.5 V-Box connect with Huawei platform** == 580 580 581 581 In this demo,V-Box connects with Huawei by SSL certification. 582 582 ... ... @@ -697,7 +697,7 @@ 697 697 (% style="text-align:center" %) 698 698 [[image:1624506666650-161.png||height="547" width="1000" class="img-thumbnail"]] 699 699 700 -== **2. 5V-Box connect with AWS platform** ==1034 +== **2.6 V-Box connect with AWS platform** == 701 701 702 702 === **Log in AWS** === 703 703