Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03

From 32.1 to 31.1 From 50.1 to 49.1

From version 49.1

edited by Hunter
on 2023/05/06 10:09

Change comment: There is no comment for this version

To version 32.1

edited by Hunter
on 2022/11/22 14:09

Change comment: There is no comment for this version

Raw
Rendered

Summary

Page properties (1 modified, 0 added, 0 removed)

Details

Page properties

Content

@@ -447,37 +447,6 @@
  end
  {{/code}}
--== **1.9 High-Low Byte Switch** ==
--
--The following example is converting the floating number from order 1234 to order 3412, and formating output the number with 2 decimal point. About which high-low word order corresponding to which value, please refer to the [[Address Operation Table>>doc:V-BOX.V-Net.Manual.04 Lua Script.01 Lua Functions.WebHome||anchor="H2Addressoperation"]].
--
--{{code language="lua"}}
--function highLowByteSwitch(floatNumber)
--    addr_setfloat("@W_0#HDW23036",floatNumber,0,2)
--    local newFloat = addr_getfloat("@W_0#HDW23036")
--    local formattedFloat = string.format("%.2f",newFloat)
--    print("The formatted float value is the : "..formattedFloat)
--    return formattedFloat
--end
--{{/code}}
--
--== **1.10 Read 64bits Unsigned Value** ==
--
--In our built-in function library doesn't have the function for reading 64-bit unsigned format value, so the following function is for solve this. But if the number is greater 2^53, the precision will be lost. So the final result will be a little bit different from the original value.
--
--{{code language="lua"}}
--function addr_getquatra(address)
--    local highAddress = addr_newnoaddr(address,2)
--    local low32 = addr_getdword(address)
--    local high32 = addr_getdword(highAddress)
--    --print("the low number is "..low32)
--    --print("the high number is "..high32)
--    local formatVal = string.format("%64.0f",2^32*high32+low32)
--    print("the format value is ".. formatVal)
--    return formatVal
--end
--{{/code}}
--
  = **2 V-Box connect with third part server** =
  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.
@@ -496,9 +496,8 @@
  (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate
--{{info}}
++(% class="wikigeneratedid" %)
  **✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool.
--{{/info}}
  (% class="wikigeneratedid" %)
  Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]**
@@ -505,25 +505,6 @@
  == **2.1 V-Box connect with test server(General Example)** ==
--The following example is trying to publish to the topic "testtopic/test/no1/7890", and subscribe the topic "testtopic/test/no1/123456".
--
--And the JSON message is like follows:
--
--{{code language="JSON"}}
--{
-- "timestamp": 1631152760,
-- "messageId": 1,
-- "event": "test_data",
-- "mfrs": "HMI/box",
-- "data":
--  {
--   "id" : 1436217747670454274,
--   "waterlevel" : 48,
--   "temperture" : 23
--  }
--}
--{{/code}}
--
  {{code language="lua"}}
  --MQTT configuration table
  local MQTT_CFG={}
@@ -565,13 +565,9 @@
  --initialize mqtt
  function mqtt_init()
      print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID))
--    if g_mq then
--        mqtt.close() --Close mqtt object
--    end
      g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable
      if g_mq then
          g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages
--        g_mq:on("offline", mqtt_msg_offline)  -- Register a callback for offline
          print("mqtt init success")
      else
          print("mqtt init failed:", err)
@@ -591,11 +591,6 @@
      g_mq:subscribe(SUBSCRIBE_TOPIC, 0)
  end
----Offline callback function
--function mqtt_msg_offline(cause)
--    print("mqtt offline, cause:", cause)
--end
--
  -- Received message callback function
  function mqtt_msg_callback(topic, msg)
      print("topic:", topic)
@@ -634,11 +634,9 @@
          if g_mq:isconnected() then
              send_data()
          else
--            --if exceed 5 sec not connect, reconnect once
--            if os.time() - LAST_TIME > 5 then
++            --if exceed 20 sec not connect, reconnect once
++            if os.time() - LAST_TIME > 20 then
                  LAST_TIME = os.time()
--                --reinitial the mqtt object
--                mqtt_init()
                  --connect to mqtt or reconnect
                  mqtt_connect()
              end
@@ -1218,20 +1218,35 @@
  {{code language="java"}}
  {
++
    "Version": "2012-10-17",
++
    "Statement": [
++
      {
++
        "Effect": "Allow",
++
        "Action": [
++
          "iot:Connect",
++
          "iot:Publish",
++
          "iot:Subscribe",
++
          "iot:Receive",
++
          "greengrass:Discover"
++
        ],
++
        "Resource": "*"
++
      }
++
    ]
++
  }
  {{/code}}
@@ -1296,190 +1296,185 @@
  [[image:image-20220709165402-20.png]]
--{{info}}
--**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701
--{{/info}}
--
--{{code language="lua"}}
  sprint = print
----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)
++~-~-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)
  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
----publish to topics
++~-~-publish to topics
  local pub_RE_TOPIC = string.format('TEST')
----Subscribe topics
++~-~-Subscribe topics
  local Subscribe_RE_TOPIC1 = string.format('TEST')
----variable
++~-~-variable
  local last_time = 0
----Timing main function
++~-~-Timing main function
  function aws.main()
--            sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
++   sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
--            if g_mq then
++   if g_mq then
--                if g_mq:isconnected() then
++        if g_mq:isconnected() then
--                    send_Data()
++            send_Data()
--                else
++        else
--                if os.time() - last_time > 5 then
++            if os.time() - last_time > 5 then
--                    last_time = os.time()
++                last_time = os.time()
--                    mymqtt_connect()
++                mymqtt_connect()
--                end
--
              end
--            else
++        end
--                mymqtt_init()
++    else
--            end
++        mymqtt_init()
--            sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
++    end
++    sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
++
  end
++~-~- Initialize MQTT
---- Initialize MQTT
--
  function mymqtt_init()
--                sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
++    sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
--                g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID, 1) -- Create the object and declare it as a global variable, 1 means using the domain to connect
++    g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
--                if g_mq then
++    if g_mq then
--                    g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
++        g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
--                    sprint("mqtt init success")
++        sprint("mqtt init success")
--                else
++    else
--                    sprint("mqtt init failed:", err)
++        sprint("mqtt init failed:", err)
--                end
++    end
  end
---- Connect to MQTT server
++~-~- Connect to MQTT server
  function mymqtt_connect()
--                sprint("mqtt connecting...")
++    sprint("mqtt connecting...")
--                local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
++    local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
--                if stat == nil then
++    if stat == nil then
--                    sprint("mqtt connect failed:", err)
++        sprint("mqtt connect failed:", err)
--                    return
++        return
--                else
++    else
--                    sprint("mqtt connected")
++        sprint("mqtt connected")
--                end
++    end
--                g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
++    g_mq:subscribe(TEST, 0)
  end
---- Receive MQTT message callback function
++~-~- Receive MQTT message callback function
  function mymqtt_msg_callback(topic, msg)
--                print("topic:",topic)
++    print("topic:",topic)
--                print("revdata:",msg)
++    print("revdata:",msg)
--                local revData = json.decode(msg)
++    local revData = json.decode(msg)
--                print (revData)
++    print (revData)
--                if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
++ if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
--                    if string.match(topic,Subscribe_RE_TOPIC1) then
++if string.match(topic,Subscribe_RE_TOPIC1) then
--                        --if revData ~= nil then
++    ~-~-if revData ~~= nil then
--                        for k,v in pairs (revData) do
++        for k,v in pairs (revData) do
--                            print("printing revdata after kv here")
++            print("printing revdata after kv here")
--                            print (k,v)
++            print (k,v)
--                        end
++        end
--                    print ("current state is",fanstate)
++        print ("current state is",fanstate)
--                        --end
++    ~-~-end
--                    end
++end
--                end
++end
  end
++~-~-Get real-time data
----Get real-time data
--
  function getData()
--                local jdata = {}
++    local jdata = {}
--                local addr = bns_get_alldata()
++    local addr = bns_get_alldata()
--                print(json.encode(addr))
++    print(json.encode(addr))
--                for i,v in pairs(addr) do
++    for i,v in pairs(addr) do
--                    if v[2] == 1 then
++        if v[2] == 1 then
--                        jdata[v[3]] = v[4]
++           jdata[v[3]] = v[4]
--                    end
++        end
--                end
++    end
--                return jdata
++    return jdata
  end
----send data
++~-~-send data
  function send_Data()
--                local pub_data =
--                {
--                    123
--                }
++    local pub_data =
++    {
++
++123
++
++}
++
  sprint(json.encode(pub_data))
  print("..........",pub_RE_TOPIC)
--                return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
++    return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
  end
--{{/code}}
  Get message in AWS

Changes for page 2 Script

Summary

Details

Navigation

Table of Contents