Changes for page 2 Script
Last modified by Devin Chen on 2025/06/06 14:03
Summary
-
Page properties (1 modified, 0 added, 0 removed)
-
Attachments (0 modified, 0 added, 1 removed)
Details
- Page properties
-
- 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.04 Lua Script.01 Lua Functions.WebHome]] 17 17 18 18 == **1.2 Arithmetic** == 19 19 ... ... @@ -70,12 +70,6 @@ 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,313 +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 - 353 -== **1.8 How to parse value from HTTP response body** == 354 - 355 -This example use [[https:~~/~~/www.weatherapi.com/>>https://www.weatherapi.com/]] as example, to show how to parse value from HTTP response body. When we input the city name into address "@HDW5050": 356 - 357 -(% style="text-align:center" %) 358 -[[image:InputHTTPparameter.png]] 359 - 360 -Then the response body would be like as following: 361 - 362 -{{code language="json"}} 363 -{ 364 - "location": { 365 - "name": "Madrid", 366 - "region": "Madrid", 367 - "country": "Spain", 368 - "lat": 40.4, 369 - "lon": -3.68, 370 - "tz_id": "Europe/Madrid", 371 - "localtime_epoch": 1669022636, 372 - "localtime": "2022-11-21 10:23" 373 - }, 374 - "current": { 375 - "last_updated_epoch": 1669022100, 376 - "last_updated": "2022-11-21 10:15", 377 - "temp_c": 13.0, 378 - "temp_f": 55.4, 379 - "is_day": 1, 380 - "condition": { 381 - "text": "Partly cloudy", 382 - "icon": "//cdn.weatherapi.com/weather/64x64/day/116.png", 383 - "code": 1003 384 - }, 385 - "wind_mph": 11.9, 386 - "wind_kph": 19.1, 387 - "wind_degree": 210, 388 - "wind_dir": "SSW", 389 - "pressure_mb": 1015.0, 390 - "pressure_in": 29.97, 391 - "precip_mm": 0.0, 392 - "precip_in": 0.0, 393 - "humidity": 88, 394 - "cloud": 75, 395 - "feelslike_c": 10.8, 396 - "feelslike_f": 51.4, 397 - "vis_km": 10.0, 398 - "vis_miles": 6.0, 399 - "uv": 3.0, 400 - "gust_mph": 22.1, 401 - "gust_kph": 35.6 402 - } 403 -} 404 -{{/code}} 405 - 406 -(% class="wikigeneratedid" %) 407 -So we decode json into lua object to assign the value into addresses HDW6060(temperature), HDW7070(humidity) the code example like follows: 408 - 409 -{{code language="lua"}} 410 -local APIkey = '70faaecf926b4341b1974006221711' 411 - 412 - 413 -local http = require("socket.http") 414 -local json = require("json") 415 - 416 --- Send http.get request and return response result 417 -function getHttpsUrl(url) 418 - local result_table, code, headers, status = http.request(url) 419 - print("code:"..code) 420 - if code~= 200 then 421 - return 422 - else 423 - return result_table 424 - end 425 -end 426 - 427 -function sendAPI(key, city) 428 - local url = "http://api.weatherapi.com/v1/current.json?key="..key.."&q="..city.."&aqi=no" 429 - --local url = 'http://v-box.net' 430 - --local url = 'https://www.google.com/' 431 - --http://api.weatherapi.com/v1/current.json?key=70faaecf926b4341b1974006221711&q=Barcelona&aqi=no 432 - print("Get the link:"..url) 433 - local body = getHttpsUrl(url) 434 - --print(body) 435 - local jsonBody = json.decode(body) 436 - --print(jsonBody["current"]["temp_c"]) 437 - --print(type(jsonBody["current"]["temp_c"])) 438 - --print(type(jsonBody["current"]["humidity"])) 439 - addr_setfloat("@HDW6060", jsonBody["current"]["temp_c"]) 440 - addr_setword("@HDW7070", jsonBody["current"]["humidity"]) 441 -end 442 - 443 - 444 -function Weather.main() 445 - local cityName = addr_getstring("@HDW5050",6) 446 - print("cityName: "..cityName) 447 - sendAPI(APIkey, cityName) 448 -end 449 -{{/code}} 450 - 451 451 = **2 V-Box connect with third part server** = 452 452 453 453 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. ... ... @@ -466,273 +466,157 @@ 466 466 467 467 (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate 468 468 469 -(% class="wikigeneratedid" %) 470 -**✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool. 157 +== **2.1 V-Box connect with customer server:grouprobotinfo.com** == 471 471 472 -(% class="wikigeneratedid" %) 473 -Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]** 159 +This demo does not use SSL certification. Script is as below 474 474 475 - == **2.1 V-Box connect with test server(General Example)** ==161 +Demo1: 476 476 477 477 {{code language="lua"}} 478 ---MQTT configuration table 479 -local MQTT_CFG={} 480 -MQTT_CFG.username = "weconsupport" 481 -MQTT_CFG.password = "123456" 482 -MQTT_CFG.netway = 0 483 -MQTT_CFG.keepalive = 60 484 -MQTT_CFG.cleansession = 1 485 ---TCP URL 486 -MQTT_URL = "tcp://mq.tongxinmao.com:1883" 487 ---Client ID 488 -MQTT_CLIENT_ID = "V-BOXH-AG" 164 +-- Meta class 165 +--main 166 +function mq.main() 167 + if not mq.m then 168 + local err = "" 489 489 490 ---Generate UUID 491 -function uuid() 492 - local seed = {'e','1','2','3','4','5','6','7','8','9','a','b','c','d','e','f'} 493 - local tb = {} 494 - for i=1, 32 do 495 - table.insert(tb, seed[math.random(1,16)]) 496 - end 497 - local sid=table.concat(tb) 498 - return string.format('%s', 499 - string.sub(sid,1,32) 500 - ) 501 -end 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) 502 502 503 503 504 ---Topic name to subscribed 505 -local SUBSCRIBE_TOPIC = 'testtopic/test/no1/123456' 506 506 507 ---Topic name to be published 508 -local PUBLISH_TOPIC = 'testtopic/test/no1/7890' 239 + local status_text ="unknow" 240 + if addr_getbit("@Status Run")==1 then 241 + status_text = "RUNNING" 242 + else 243 + status_text = "STOP" 244 + end 245 +------------------------------------------------------------------------------------------------------------------------- 509 509 247 + local js = {type="status", 248 + mc_name ="FD300", 249 + status=status_text, 250 + elapsed_time={ 251 + hour=addr_getword("@Elapsed Time (Hour)"), 252 + min=addr_getword("@Elapsed Time (Minute)"), 253 + sec=addr_getword("@Elapsed Time (Second)") 254 + }, 255 + phase = phaseStatus, 256 + step = addr_getword("@Step"), 257 + activating_output = pr_activating, 258 + sv=addr_getshort("@SV Silicone")/10, 259 + pv=addr_getshort("@PV Silicone")/10, 260 + product1=addr_getshort("@Product 1")/10, 510 510 511 ---real time 512 -local LAST_TIME = 0 262 + product2=addr_getshort("@Product 2")/10, 263 + product3=addr_getshort("@Product 3")/10, 264 + product4=addr_getshort("@Product 4")/10, 265 + ice1=addr_getshort("@Ice condenser 1")/10, 266 + ice2=addr_getshort("@Ice condenser 2")/10, 267 + vacuum=addr_getfloat("@Vacuum") 513 513 269 + } 270 + local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"), 271 + ODPC = addr_getbit("@B_25395#W0.01"), 272 + MTPC=addr_getbit("@B_25395#W0.02"), 273 + HTT = addr_getbit("@B_25395#W1.03"), 274 + CPC = addr_getbit("@B_25395#W0.08"), 275 + CPSP =addr_getbit("@B_25395#W1.00"), 276 + CPVP =addr_getbit("@B_25395#W0.10"), 277 + CPRP =addr_getbit("@B_25395#W0.11"), 278 + HP =addr_getbit("@B_25395#W1.01"), 279 + PP= addr_getbit("@B_25395#W1.02"), 280 + PO=addr_getbit("@B_25395#W0.07"), 281 + FSE=addr_getbit("@B_25395#W2.04"), 282 + AVVSVV=addr_getbit("@B_25395#W1.12"), 283 + ICHT=addr_getbit("@B_25395#W3.06") 514 514 515 ---initialize mqtt 516 -function mqtt_init() 517 - print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID)) 518 - g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable 519 - if g_mq then 520 - g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages 521 - print("mqtt init success") 522 - else 523 - print("mqtt init failed:", err) 524 - end 525 -end 285 + } 526 526 527 --- connect to mqtt 528 -function mqtt_connect() 529 - print("mqtt connecting...") 530 - local stat, err = g_mq:connect(MQTT_CFG) 531 - if stat == nil then 532 - print("mqtt connect failed:", err) 533 - return 534 - else 535 - print("mqtt connected") 536 - end 537 - g_mq:subscribe(SUBSCRIBE_TOPIC, 0) 538 -end 287 + -- ("@B_25395#CIO1.02") 288 + mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 289 + mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 290 + else 291 + local stat, err = mq.m:connect(mq.config) -- connection 292 + if stat == nil then --Determine whether to connect 293 + print("mqtt connect failed:", err) 294 + return -- Connection failed, return directly 295 + end 296 + mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics 539 539 540 --- Received message callback function 541 -function mqtt_msg_callback(topic, msg) 542 - print("topic:", topic) 543 - print("msg:", msg) 544 - local objMsg = json.decode(msg) 545 - local water = objMsg.data.waterlevel 546 - local temp = objMsg.data.temperature 547 - addr_setword("@HDW20",water) 548 - addr_setword("@HDW10",temp) 298 + end 299 + -- mq.m:unsubscribe("stc/test") 300 + -- mq.m:disconnect() -- close matt 301 + -- mq.m:close() -- close clase 302 + end 549 549 end 550 - 551 ---Send data (data upload to platform and encapsulate it with custom functions) 552 -function send_data() 553 - local pub_data = { 554 - timestamp = os.time(), 555 - messageId = 1, 556 - event = 'test_data', 557 - mfrs = 'V-Box', 558 - data = { 559 - id = uuid(), 560 - waterlevel = addr_getword("@HDW10"), 561 - temperature = addr_getword("@HDW20") 562 - } 563 - } 564 - return g_mq:publish(PUBLISH_TOPIC, json.encode(pub_data), 0, 0) 565 -end 566 - 567 - 568 ---main function fixed timed execution 569 -function MQTT.main() 570 - --dosomething 571 - print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main start") 572 - --determine the mqtt object whether exist 573 - if g_mq then 574 - --determine the mqtt object whether has been connected or not 575 - if g_mq:isconnected() then 576 - send_data() 577 - else 578 - --if exceed 20 sec not connect, reconnect once 579 - if os.time() - LAST_TIME > 20 then 580 - LAST_TIME = os.time() 581 - --connect to mqtt or reconnect 582 - mqtt_connect() 583 - end 584 - end 585 - else 586 - --mqtt object does not exist so create new one 587 - mqtt_init() 588 - end 589 - print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main end") 590 -end 591 591 {{/code}} 592 592 593 -== **2.2 V-Box connect with customerserver:grouprobotinfo.com** ==306 +== **2.2 V-Box connect with Azure platform** == 594 594 595 -This demo does not use SSL certification. Script is as below 596 - 597 -Demo1: 598 - 599 -{{code language="lua"}} 600 --- Meta class 601 ---main 602 -function mq.main() 603 - if not mq.m then 604 - local err = "" 605 - 606 - mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection 607 - if mq.m then 608 - mq.config = { 609 - username = "",-- ID 610 - password = "",-- password 611 - netway = 1, -- Ethernet connection, WIFI=1 612 - -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds. 613 - -- cleansession = 0, -- Optional, keep session 614 - } 615 - mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks 616 - local str = string.format("%s:%s", topic, msg) 617 - -- print("mqtt msg:", str) -- Print out the received topics and content 618 - end) 619 - mq.m:on("offline", function (cause) -- Register for lost connection callbacks 620 - -- addr_setstring("@xxx", "cause"..(cause or " got nil")) 621 - end) 622 - mq.m:on("arrived", function() -- Registration for sending messages to callbacks 623 - print("msg arrived") 624 - end) 625 - else 626 - print("mqtt create failed:", err) -- Create object failed 627 - end 628 - else 629 - if mq.m:isconnected() then -- If online, post a message 630 - local phaseStatus ="unknow" 631 - if addr_getbit("@Standby")== 1 then 632 - phaseStatus = "Standby" 633 - elseif addr_getbit("@Pre-Freeze")==1 then 634 - phaseStatus= "Pre-Freeze" 635 - elseif addr_getbit("@Prepare")==1 then 636 - phaseStatus ="Prepare" 637 - elseif addr_getbit("@Primary Dry")==1 then 638 - phaseStatus = "Primary dry" 639 - elseif addr_getbit("@Secondary Dry")==1 then 640 - phaseStatus = "Secondary Dry" 641 - end 642 - --print(addr_getbit("@Primary Dry")) 643 -------------------------------------------------------------------------------------------------------------------------- 644 - local activating ="unknow" 645 - if addr_getbit("@Compressor")==1 then 646 - activating = ",".."Compressor" 647 - end 648 - if addr_getbit("@Silicone Pump")==1 then 649 - activating = activating..",".."Silicone Pump" 650 - end 651 - if addr_getbit("@Vacuum Pump")==1 then 652 - activating = activating..",".."Vacuum Pump" 653 - end 654 - if addr_getbit("@Root Pump")==1 then 655 - activating = activating..",".."Root Pump" 656 - end 657 - if addr_getbit("@Heater")==1 then 658 - activating = activating..",".."Heater" 659 - end 660 - if addr_getbit("@Valve Silicone")==1 then 661 - activating = activating..",".."Valve Silicone" 662 - end 663 - if addr_getbit("@Valve Ice Condenser")==1 then 664 - activating = activating..",".."Valve Ice Condenser" 665 - end 666 - if addr_getbit("@Valve Vacuum Pump")==1 then 667 - activating = activating..",".."Valve Vacuum Pump" 668 - end 669 - local pr_activating =string.sub(activating,2) 670 - -- print(pr_activating) 671 - local status_text ="unknow" 672 - if addr_getbit("@Status Run")==1 then 673 - status_text = "RUNNING" 674 - else 675 - status_text = "STOP" 676 - end 677 -------------------------------------------------------------------------------------------------------------------------- 678 - local js = {type="status", 679 - mc_name ="FD300", 680 - status=status_text, 681 - elapsed_time={ 682 - hour=addr_getword("@Elapsed Time (Hour)"), 683 - min=addr_getword("@Elapsed Time (Minute)"), 684 - sec=addr_getword("@Elapsed Time (Second)") 685 - }, 686 - phase = phaseStatus, 687 - step = addr_getword("@Step"), 688 - activating_output = pr_activating, 689 - sv=addr_getshort("@SV Silicone")/10, 690 - pv=addr_getshort("@PV Silicone")/10, 691 - product1=addr_getshort("@Product 1")/10, 692 - 693 - product2=addr_getshort("@Product 2")/10, 694 - product3=addr_getshort("@Product 3")/10, 695 - product4=addr_getshort("@Product 4")/10, 696 - ice1=addr_getshort("@Ice condenser 1")/10, 697 - ice2=addr_getshort("@Ice condenser 2")/10, 698 - vacuum=addr_getfloat("@Vacuum") 699 - } 700 - local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"), 701 - ODPC = addr_getbit("@B_25395#W0.01"), 702 - MTPC=addr_getbit("@B_25395#W0.02"), 703 - HTT = addr_getbit("@B_25395#W1.03"), 704 - CPC = addr_getbit("@B_25395#W0.08"), 705 - CPSP =addr_getbit("@B_25395#W1.00"), 706 - CPVP =addr_getbit("@B_25395#W0.10"), 707 - CPRP =addr_getbit("@B_25395#W0.11"), 708 - HP =addr_getbit("@B_25395#W1.01"), 709 - PP= addr_getbit("@B_25395#W1.02"), 710 - PO=addr_getbit("@B_25395#W0.07"), 711 - FSE=addr_getbit("@B_25395#W2.04"), 712 - AVVSVV=addr_getbit("@B_25395#W1.12"), 713 - ICHT=addr_getbit("@B_25395#W3.06") 714 - } 715 - -- ("@B_25395#CIO1.02") 716 - mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 717 - mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 718 - else 719 - local stat, err = mq.m:connect(mq.config) -- connection 720 - if stat == nil then --Determine whether to connect 721 - print("mqtt connect failed:", err) 722 - return -- Connection failed, return directly 723 - end 724 - mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics 725 - 726 - end 727 - -- mq.m:unsubscribe("stc/test") 728 - -- mq.m:disconnect() -- close matt 729 - -- mq.m:close() -- close clase 730 - end 731 -end 732 -{{/code}} 733 - 734 -== **2.3 V-Box connect with Azure platform** == 735 - 736 736 In this demo,V-Box connects with Azure by SSL certification. 737 737 738 738 Video link: [[https:~~/~~/youtu.be/cdI6rIQcpMY?list=PL_Bpnb2RgaksCic9HCcVAZhU9sYwCRKzW>>https://youtu.be/cdI6rIQcpMY?list=PL_Bpnb2RgaksCic9HCcVAZhU9sYwCRKzW]] ... ... @@ -862,7 +862,7 @@ 862 862 end 863 863 ))) 864 864 865 -== **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)** ==437 +== **2.3 How to configure the Huawei platform?(✎Note: Huawei IOT DA function is only in China area.If you want this function,you need to use chinese mobile to register)** == 866 866 867 867 1.Register a account: [[https:~~/~~/www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ>>https://www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ]] 868 868 ... ... @@ -1011,7 +1011,7 @@ 1011 1011 (% style="text-align:center" %) 1012 1012 [[image:1624441186851-536.png||height="434" width="700" class="img-thumbnail"]] 1013 1013 1014 -== **2. 5V-Box connect with Huawei platform** ==586 +== **2.4 V-Box connect with Huawei platform** == 1015 1015 1016 1016 In this demo,V-Box connects with Huawei by SSL certification. 1017 1017 ... ... @@ -1132,7 +1132,7 @@ 1132 1132 (% style="text-align:center" %) 1133 1133 [[image:1624506666650-161.png||height="547" width="1000" class="img-thumbnail"]] 1134 1134 1135 -== **2. 6V-Box connect with AWS platform** ==707 +== **2.5 V-Box connect with AWS platform** == 1136 1136 1137 1137 === **Log in AWS** === 1138 1138
- InputHTTPparameter.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.Hunter - Size
-
... ... @@ -1,1 +1,0 @@ 1 -17.9 KB - Content