update: 优化阿里云的demo

demo/aliyun/main.lua

@@ -2,43 +2,41 @@ PROJECT = "aliyundemo"
 VERSION = "1.0.0"
 local sys = require "sys"
 local libfota = require("libfota")
-require "aliyun"
+local aliyun = require "aliyun"
 
 --根据自己的服务器修改以下参数
+--新版已经合并, 没有了地域, 1883同时兼容加密和非加密通信，非加密会下线
+-- 阿里云资料：https://help.aliyun.com/document_detail/147356.htm?spm=a2c4g.73742.0.0.4782214ch6jkXb#section-rtu-6kn-kru
 tPara = {
- Registration = false,           --是否是预注册 已预注册为false  true or false,
- DeviceName = "", --设备名称
- ProductKey = "",     --产品key
- ProductSecret = "",  --产品secret
- DeviceSecret = "", --设备secret
- InstanceId = "iot-你的实例id",   --如果没有注册需要填写实例id，在实例详情页面
- --新版已经合并, 没有了地域, 1883同时兼容加密和非加密通信，非加密会下线  阿里云资料：https://help.aliyun.com/document_detail/147356.htm?spm=a2c4g.73742.0.0.4782214ch6jkXb#section-rtu-6kn-kru
- mqtt_port = 1883,                 --mqtt端口
- mqtt_isssl = true,                --是否使用ssl加密连接，true为无证书最简单的加密
+    Registration = false,           --是否是预注册 已预注册为false  true or false,
+    DeviceName = "dht11", --设备名称
+    ProductKey = "k0ti3QNOFaH",     --产品key
+    ProductSecret = "",  --产品secret,已经预注册就不需要填
+    DeviceSecret = "62a17dfe2192526f90bc5fad7cd951fc", --设备secret
+    InstanceId = "iot-06z00hmbog1v175",   --如果没有注册需要填写实例id，在实例详情页面
+    mqtt_port = 1883,                --    mqtt端口
+    mqtt_isssl = false,                --是否使用ssl加密连接，true为无证书最简单的加密
  }
 
  -- 统一联网函数
 sys.taskInit(function()
-    local device_id = mcu.unique_id():toHex()
     -----------------------------
     -- 统一联网函数, 可自行删减
     ----------------------------
     if wlan and wlan.connect then
         -- wifi 联网, ESP32系列均支持
-        local ssid = "kfyy123"
-        local password = "kfyy123456"
+        local ssid = "luatos1234"
+        local password = "12341234"
         log.info("wifi", ssid, password)
         -- TODO 改成自动配网
-        -- LED = gpio.setup(12, 0, gpio.PULLUP)
         wlan.init()
         wlan.setMode(wlan.STATION) -- 默认也是这个模式,不调用也可以
-        device_id = wlan.getMac()
         wlan.connect(ssid, password, 1)
     elseif mobile then
         -- Air780E/Air600E系列
         --mobile.simid(2) -- 自动切换SIM卡
         -- LED = gpio.setup(27, 0, gpio.PULLUP)
-        device_id = mobile.imei()
+        -- device_id = mobile.imei()
     elseif w5500 then
         -- w5500 以太网, 当前仅Air105支持
         w5500.init(spi.HSPI_0, 24000000, pin.PC14, pin.PC01, pin.PC00)
@@ -57,7 +55,7 @@ sys.taskInit(function()
     end
     -- 默认都等到联网成功
     sys.waitUntil("IP_READY")
-    sys.publish("net_ready", device_id)
+    sys.publish("net_ready")
 end)
 
  --阿里云客户端是否处于连接状态
@@ -74,7 +72,7 @@ local publishCnt = 1
 返回值：无
 ]]
 local function publishTestCb(result,para)
-    log.info("testALiYun.publishTestCb",result,para)
+    log.info("aliyun", "发布后的反馈", result,para)
     sys.timerStart(publishTest,20000)
     publishCnt = publishCnt+1
 end
@@ -84,6 +82,7 @@ function publishTest()
     if sConnected then
         --注意：在此处自己去控制payload的内容编码，aLiYun库中不会对payload的内容做任何编码转换
         -- aliyun.publish(topic,qos,payload,cbFnc,cbPara)
+        log.info("aliyun", "上行数据")
         aliyun.publish("/"..tPara.ProductKey.."/"..tPara.DeviceName.."/user/get",1,"LUATOS_CESHI",publishTestCb,"publishTest_"..publishCnt)
     end
 end
@@ -92,15 +91,17 @@ end
 -- @string topic，UTF8编码的消息主题
 -- @string payload，原始编码的消息负载
 local function rcvCbFnc(topic,payload,qos,retain,dup)
-    log.info("testALiYun.rcvCbFnc",topic,payload,qos,retain,dup)
+    log.info("aliyun", "收到下行数据", topic,payload,qos,retain,dup)
 end
 
 --- 连接结果的处理函数
 -- @bool result，连接结果，true表示连接成功，false或者nil表示连接失败
 local function connectCbFnc(result)
-    log.info("testALiYun.connectCbFnc",result)
+    log.info("aliyun","连接结果", result)
     sConnected = result
     if result then
+        sys.publish("aliyun_ready")
+        log.info("aliyun", "连接成功")
         --订阅主题
         --根据自己的项目需要订阅主题，下面注释掉的一行代码中的主题是非法的，所以不能打开，一旦打开，会导致订阅失败
         --订阅OTA主题
@@ -130,13 +131,13 @@ local function connectCbFnc(result)
         end
         if not tPara.Registration then
             if Secret == nil then
-                log.info("掉电重连")
+                log.info("aliyun","掉线重连")
             else
                 fskv.set("deviceSecret",aliyun.getDeviceSecret())
             end
         else
             if Token == nil and Clid == nil then
-                log.info("掉电重连")
+                log.info("aliyun","掉线重连")
             else
                 fskv.set("deviceToken",aliyun.getDeviceToken())
                 fskv.set("clientid",aliyun.getClientid())
@@ -147,6 +148,8 @@ local function connectCbFnc(result)
         aliyun.on("receive",rcvCbFnc)
         --PUBLISH消息测试
         publishTest()
+    else
+        log.warn("aliyun", "连接失败")
     end
 end
 
@@ -154,9 +157,9 @@ aliyun.on("connect",connectCbFnc)
 
 --根据掉电不消失的kv文件区来储存的deviceSecret,clientid,deviceToken来判断是进行正常连接还是掉电重连
 sys.taskInit(function()
-    local _, device_id = sys.waitUntil("net_ready")
+    sys.waitUntil("net_ready")
     socket.sntp()
-    sys.wait(500)
+    sys.waitUntil("NTP_UPDATE", 2000)
     log.info("已联网", "开始初始化aliyun库")
     fskv.init()
     local name = fskv.get("DeviceName")
@@ -191,20 +194,40 @@ sys.taskInit(function()
     end
 end)
 
-
---[[
-函数名：verRpt
-功能  ：上报固件版本号给云端
-参数  ：无
-返回值：无
-]]
 function verRpt()
-    log.info("aliyunOta.verRpt")
-    -- aliyun.publish(topic,qos,payload,cbFnc,cbPara)
+    log.info("aliyun", "上报版本信息", _G.VERSION)
     aliyun.publish("/ota/device/inform/"..tPara.ProductKey.."/"..tPara.DeviceName,1,"{\"id\":1,\"params\":{\"version\":\"".._G.VERSION.."\"}}")
 end
 
+-- 低功耗演示
+sys.taskInit(function()
+    sys.waitUntil("aliyun_ready")
+    log.info("aliyun.pm", "阿里云已经连接成功, 5秒后请求进入低功耗模式, USB功能会断开")
+    sys.wait(5000)
+    local bsp = rtos.bsp():upper()
+    -- 进入低功耗模式
+    if bsp == "EC618" then
+        log.info("aliyun.pm", "EC618方案进入低功耗模式")
+        -- gpio.setup(23,nil)
+        -- gpio.close(33)
+        pm.power(pm.USB, false)
+        pm.force(pm.LIGHT)
+    elseif bsp == "EC718P" or bsp == "EC718PV" then
+        log.info("aliyun.pm", "EC718P/EC718PV方案进入低功耗模式")
+        pm.power(pm.USB, false)
+        pm.force(pm.LIGHT)
+    elseif bsp == "AIR101" or bsp == "AIR601" or bsp == "AIR103" then
+        log.info("aliyun.pm", "XT804方案进入低功耗模式")
+        while 1 do
+            pm.dtimerStart(0, 30000)
+            pm.request(pm.LIGHT)
+            sys.wait(30000)
+        end
+    end
+    
+end)
+
 -- 用户代码已结束---------------------------------------------
 -- 结尾总是这一句
 sys.run()
--- sys.run()之后后面不要加任何语句!!!!!
+-- sys.run()之后后面不要加任何语句!!!!!