add: 新的turnkey, Air780EG + 腾讯连连, 当前位置/历史轨迹/电子围栏

script/turnkey/air780eg_gnss_qcloud/README.md

@@ -0,0 +1,9 @@
+# Air780EG + 腾讯连连小程序
+
+## 使用条件
+
+硬件条件: Air780EG 或 Air780E + Air530H, 或春节内测开发板
+
+## 固件要求
+
+若使用 Air780EG, 需要更改UART2的定义到GPIO12/13

script/turnkey/air780eg_gnss_qcloud/main.lua

@@ -0,0 +1,230 @@
+-- LuaTools需要PROJECT和VERSION这两个信息
+PROJECT = "gnsstest"
+VERSION = "1.0.1"
+
+--[[
+Air780EG 对接 腾讯连连
+]]
+
+-- sys库是标配
+local sys = require("sys")
+require("sysplus")
+
+local gps_uart_id = 2
+local mqttc = nil
+
+---------------------------------------------------------------------
+--[[
+使用本代码需要自行调整下列配置参数:
+1. qcloud_pid 项目id
+2. qcloud_dev 默认是使用设备的IMEI,如果自定义了名字,改成固定的
+3. qcloud_key 设备密钥,在页面新建设备后,设备详情中可以查看到
+4. qcloud_host 默认值就是最常见的配置,一般不需要修改
+5. qcloud_port 密钥登录模式,只需要非加密的1883端口
+]]
+local qcloud_pid = "JTWPP5SPLA"
+local qcloud_dev = mobile.imei()
+local qcloud_key = "mZE56wmoBFG3J3gG7xvTsg=="
+local qcloud_host = qcloud_pid .. ".iotcloud.tencentdevices.com"
+local qcloud_port = 1883
+---------------------------------------------------------------------
+
+-- libgnss库初始化
+libgnss.clear() -- 清空数据,兼初始化
+
+-- LED和ADC初始化
+LED_GNSS = 24
+LED_VBAT = 26
+gpio.setup(LED_GNSS, 0) -- GNSS定位成功灯
+gpio.setup(LED_VBAT, 0) -- 低电压警告灯
+adc.open(adc.CH_VBAT)
+-- adc.open(adc.CH_CPU)
+
+-- 串口初始化
+uart.setup(gps_uart_id, 115200)
+
+function exec_agnss()
+    local url = "http://download.openluat.com/9501-xingli/HXXT_GPS_BDS_AGNSS_DATA.dat"
+    if http then
+        -- AGNSS 已调通
+        while 1 do
+            local code, headers, body = http.request("GET", url).wait()
+            log.info("gnss", "AGNSS", code, body and #body or 0)
+            if code == 200 and body and #body > 1024 then
+                for offset = 1, #body, 512 do
+                    log.info("gnss", "AGNSS", "write >>>", #body:sub(offset, offset + 511))
+                    uart.write(gps_uart_id, body:sub(offset, offset + 511))
+                    -- sys.waitUntil("UART2_SEND", 100)
+                    sys.wait(100) -- 等100ms反而更成功
+                end
+                -- sys.waitUntil("UART2_SEND", 1000)
+                io.writeFile("/6228.bin", body)
+                break
+            end
+            sys.wait(60 * 1000)
+        end
+    end
+    sys.wait(20)
+    -- "$AIDTIME,year,month,day,hour,minute,second,millisecond"
+    local date = os.date("!*t")
+    if date.year > 2022 then
+        local str = string.format("$AIDTIME,%d,%d,%d,%d,%d,%d,000", date["year"], date["month"], date["day"],
+            date["hour"], date["min"], date["sec"])
+        log.info("gnss", str)
+        uart.write(gps_uart_id, str .. "\r\n")
+        sys.wait(20)
+    end
+    -- 读取之前的位置信息
+    local gnssloc = io.readFile("/gnssloc")
+    if gnssloc then
+        str = "$AIDPOS," .. gnssloc
+        log.info("POS", str)
+        uart.write(gps_uart_id, str .. "\r\n")
+        str = nil
+        gnssloc = nil
+    else
+        -- TODO 发起基站定位
+        uart.write(gps_uart_id, "$AIDPOS,3432.70,N,10885.25,E,1.0\r\n")
+    end
+end
+
+function upload_stat()
+    -- if mqttc == nil or not mqttc:ready() then return end
+    local cell = mobile.getCellInfo()
+    local rmc = libgnss.getRmc(2)
+    local params = {
+        networkType = 5
+    }
+    if libgnss.isFix() then
+        params["GPS_Info"]  = {
+            longitude = rmc.lng,
+            latitude = rmc.lat
+        }
+    end
+    if mqttc and mqttc:ready() then
+        local topic = "$thing/up/property/" .. qcloud_pid .. "/" .. qcloud_dev
+        local payload = json.encode({
+            method = "report",
+            clientToken = "123",
+            params = params
+        })
+        mqttc:publish(topic, payload, 1)
+    end
+end
+
+
+sys.taskInit(function()
+    -- Air780EG默认波特率是115200
+    log.info("GPS", "start")
+    pm.power(pm.GPS, true)
+    -- 调试日志,可选
+    libgnss.debug(true)
+    sys.wait(200) -- GPNSS芯片启动需要时间,大概150ms
+    -- 绑定uart,底层自动处理GNSS数据
+    -- 这里延后到设置命令发送完成后才开始处理数据,之前的数据就不上传了
+    libgnss.bind(gps_uart_id)
+    exec_agnss()
+end)
+
+-- 订阅GNSS状态编码
+sys.subscribe("GNSS_STATE", function(event, ticks)
+    -- event取值有 
+    -- FIXED 定位成功
+    -- LOSE  定位丢失
+    -- ticks是事件发生的时间,一般可以忽略
+    local onoff = libgnss.isFix() and 1 or 0
+    log.info("GNSS", "LED", onoff)
+    gpio.set(LED_GNSS, onoff)
+    log.info("gnss", "state", event, ticks)
+    if event == "FIXED" then
+        local locStr = libgnss.locStr()
+        log.info("gnss", "locStr", locStr)
+        if locStr then
+            io.writeFile("/gnssloc", locStr)
+        end
+        upload_stat()
+    end
+end)
+
+-- mqtt 上传任务
+sys.taskInit(function()
+    sys.waitUntil("IP_READY", 15000)
+    mqttc = mqtt.create(nil, qcloud_host, qcloud_port) -- mqtt客户端创建
+    sys.wait(500) -- 等一下网络时间
+
+    local client_id, user, passwd = iotauth.qcloud(qcloud_pid, qcloud_dev, qcloud_key)
+    log.info("params", qcloud_pid, qcloud_dev, qcloud_key)
+    log.info("ret", client_id, user, passwd)
+    mqttc:auth(client_id, user, passwd) -- mqtt三元组配置
+    log.info("mqtt", client_id, user, passwd)
+    mqttc:keepalive(300) -- 默认值240s
+    mqttc:autoreconn(true, 3000) -- 自动重连机制
+
+    mqttc:on(function(mqtt_client, event, data, payload) -- mqtt回调注册
+        -- 用户自定义代码，按event处理
+        -- log.info("mqtt", "event", event, mqtt_client, data, payload)
+        if event == "conack" then -- mqtt成功完成鉴权后的消息
+            sys.publish("mqtt_conack") -- 小写字母的topic均为自定义topic
+            -- 属性下发与属性上报响应
+            mqtt_client:subscribe("$thing/down/property/" .. qcloud_pid .. "/" .. qcloud_dev)
+            -- 事件上报响应
+            mqtt_client:subscribe("$thing/event/property/" .. qcloud_pid .. "/" .. qcloud_dev)
+            -- 应用调用设备行为
+            mqtt_client:subscribe("$thing/action/property/" .. qcloud_pid .. "/" .. qcloud_dev)
+            -- OTA 下行
+            mqtt_client:subscribe("$ota/update/" .. qcloud_pid .. "/" .. qcloud_dev)
+            -- 	RRPC消息下行
+            mqtt_client:subscribe("$rrpc/rxd/" .. qcloud_pid .. "/" .. qcloud_dev .. "/+")
+            -- 广播消息下行
+            mqtt_client:subscribe("$broadcast/rxd/" .. qcloud_pid .. "/" .. qcloud_dev .. "/+")
+            upload_stat()
+        elseif event == "recv" then -- 服务器下发的数据
+            log.info("mqtt", "downlink", "topic", data, "payload", payload)
+        elseif event == "sent" then -- publish成功后的事件
+            log.info("mqtt", "sent", "pkgid", data)
+        end
+    end)
+
+    -- 发起连接之后，mqtt库会自动维护链接，若连接断开，默认会自动重连
+    mqttc:connect()
+    sys.waitUntil("mqtt_conack")
+    log.info("mqtt连接成功")
+    sys.timerLoopStart(upload_stat, 6 * 1000)
+    while true do
+        sys.wait(60*1000)
+    end
+    mqttc:close()
+    mqttc = nil
+end)
+
+sys.taskInit(function()
+    while 1 do
+        sys.wait(3600 * 1000) -- 一小时检查一次
+        local fixed, time_fixed = libgnss.isFix()
+        if not fixed then
+            exec_agnss()
+        end
+    end
+end)
+
+-- 低电压报警
+sys.taskInit(function()
+    while 1 do
+        local vbat = adc.get(adc.CH_VBAT)
+        log.info("vbat", vbat)
+        if vbat < 3400 then
+            gpio.set(LED_VBAT, 1)
+            sys.wait(100)
+            gpio.set(LED_VBAT, 0)
+            sys.wait(900)
+            -- TODO 上报低电压事件
+        else
+            sys.wait(1000)
+        end
+    end
+end)
+
+-- 用户代码已结束---------------------------------------------
+-- 结尾总是这一句
+sys.run()
+-- sys.run()之后后面不要加任何语句!!!!!