低功耗

-- LuaTools需要PROJECT和VERSION这两个信息
PROJECT = "socket_low_power"
VERSION = "1.0"
PRODUCT_KEY = "123" --换成自己的
-- sys库是标配
_G.sys = require("sys")
_G.sysplus = require("sysplus")
log.style(1)

require "normal" --常规模式
--require "low_power_dissipation" --低功耗模式
-- require "ultra_low_power" --超低功耗模式(PSM+模式)

-- 用户代码已结束---------------------------------------------
-- 结尾总是这一句
sys.run()
-- sys.run()之后后面不要加任何语句!!!!!

-- netlab.luatos.com上打开TCP，然后修改IP和端口号，自动回复netlab下发的数据，自收自发测试

local server_ip = "112.125.89.8"
local server_port = 44204

local rxbuf = zbuff.create(8192)

sys.subscribe("IP_READY", function(ip, adapter)
    log.info("mobile", "IP_READY", ip, (adapter or -1) == socket.LWIP_GP)
    sys.publish("net_ready")
end)

local function netCB(netc, event, param)
    if param ~= 0 then
        sys.publish("socket_disconnect")
        return
    end
    if event == socket.LINK then
    elseif event == socket.ON_LINE then
        socket.tx(netc, "hello,luatos!")
    elseif event == socket.EVENT then
        socket.rx(netc, rxbuf)
        socket.wait(netc)
        if rxbuf:used() > 0 then
            log.info("收到", rxbuf:toStr(0,rxbuf:used()):toHex())
            log.info("发送", rxbuf:used(), "bytes")
            socket.tx(netc, rxbuf)
        end
        rxbuf:del()
    elseif event == socket.TX_OK then
        socket.wait(netc)
        log.info("发送完成")
    elseif event == socket.CLOSED then
        sys.publish("socket_disconnect")
    end
end

local function socketTask()
    sys.waitUntil("net_ready")
    log.info("联网成功，准备链接服务器")
    pm.power(pm.WORK_MODE,0) --进入常规模式
    local netc = socket.create(nil, netCB)
    socket.debug(netc, true)
    socket.config(netc, nil, nil, nil, 300, 5, 6)   --开启TCP保活，防止长时间无数据交互被运营商断线
    while true do
        log.info("开始链接服务器")
        local succ, result = socket.connect(netc, server_ip, server_port)
        if not succ then
            log.info("未知错误，5秒后重连")
        else
            log.info("链接服务器成功")
            local result, msg = sys.waitUntil("socket_disconnect")
        end
        log.info("服务器断开了，5秒后重连")
        socket.close(netc)
        log.info(rtos.meminfo("sys"))
        sys.wait(5000)
    end
end

function socketDemo()
    sys.taskInit(socketTask)
end

socketDemo()

-- LuaTools需要PROJECT和VERSION这两个信息
PROJECT = "socket_low_power"
VERSION = "1.0"
PRODUCT_KEY = "123" --换成自己的
-- sys库是标配
_G.sys = require("sys")
_G.sysplus = require("sysplus")
log.style(1)

--require "normal" --常规模式
require "low_power_dissipation" --低功耗模式
-- require "ultra_low_power" --超低功耗模式(PSM+模式)

-- 用户代码已结束---------------------------------------------
-- 结尾总是这一句
sys.run()
-- sys.run()之后后面不要加任何语句!!!!!

local server_ip = "112.125.89.8"
local server_port = 44204
local is_udp = flase--用户根据自己实际情况选择
--是UDP服务器就赋值为true，是TCP服务器就赋值为flase
--这里选择UDP服务器的原因是UDP服务器比TCP服务器功耗低
--如果用户对数据的丢包率有极为苛刻的要求，最好不要选择UDP

local Heartbeat_interval = 5 -- 发送数据的间隔时间，单位分钟

-- 数据内容  
local heart_data = string.rep("1234567890", 10)
local rxbuf = zbuff.create(8192)

local function netCB(netc, event, param)
    if param ~= 0 then
        sys.publish("socket_disconnect")
        return
    end
    if event == socket.LINK then
    elseif event == socket.ON_LINE then
        -- 链接上服务器以后发送的第一包数据是 hello,luatos
        socket.tx(netc, "hello,luatos!")

    elseif event == socket.EVENT then
        socket.rx(netc, rxbuf)
        socket.wait(netc)
        if rxbuf:used() > 0 then
            log.info("收到", rxbuf:toStr(0, rxbuf:used()), "数据长度", rxbuf:used())
        end
        rxbuf:del()
    elseif event == socket.TX_OK then
        socket.wait(netc)
        log.info("发送完成")
    elseif event == socket.CLOSED then
        sys.publish("socket_disconnect")
    end
end

local function socketTask()
    local netc = socket.create(nil, netCB) --创建一个链接
    socket.debug(netc, true)--开启socket层的debug日志，方便寻找问题
    socket.config(netc, nil, is_udp, nil, 300, 5, 6)  --配置链接的参数
    while true do
        --真正去链接服务器
        local succ, result = socket.connect(netc, server_ip, server_port)
        --链接成功后循环发送数据
        while succ do
            local Heartbeat_interval = Heartbeat_interval * 60 * 1000
            sys.wait(Heartbeat_interval)
            socket.tx(netc, heart_data)
        end
        --链接不成功5S重连一次
        if not succ then
            log.info("未知错误，5秒后重连")
            uart.write(1, "未知错误，5秒后重连")
        else
            local result, msg = sys.waitUntil("socket_disconnect")
        end
        log.info("服务器断开了，5秒后重连")
        uart.write(1, "服务器断开了，5秒后重连")
        socket.close(netc)
        sys.wait(5000)
    end
end

function socketDemo()

    --配置GPIO以达到最低功耗的目的
    gpio.setup(23, nil)
    gpio.close(33) -- 如果功耗偏高，开始尝试关闭WAKEUPPAD1
    gpio.close(35) -- 这里pwrkey接地才需要，不接地通过按键控制的不需要

    --关闭USB以后可以降低约150ua左右的功耗，如果不需要USB可以关闭
    pm.power(pm.USB, false)

     --进入低功耗长连接模式
    pm.power(pm.WORK_MODE, 1)

    sys.taskInit(socketTask)

end

sys.taskInit(socketDemo)

-- LuaTools需要PROJECT和VERSION这两个信息
PROJECT = "socket_low_power"
VERSION = "1.0"
PRODUCT_KEY = "123" --换成自己的
-- sys库是标配
_G.sys = require("sys")
_G.sysplus = require("sysplus")
log.style(1)

--require "normal" --常规模式
require "low_power_dissipation" --低功耗模式
-- require "ultra_low_power" --超低功耗模式(PSM+模式)

-- 用户代码已结束---------------------------------------------
-- 结尾总是这一句
sys.run()
-- sys.run()之后后面不要加任何语句!!!!!

-- 测试服务器可以使用https://netlab.luatos.com/
local server_ip = "112.125.89.8"
local server_port = 44204 -- 端口号换成自己的
local period = 5 * 60 * 1000 -- 5分钟唤醒一次

--相比于TCP的三次握手四次挥手，UDP更省电，但是可能会出现丢包现象，对数据稳定性要求较高的，还是使用TCP稳妥
local is_dup = false 

local reason, slp_state = pm.lastReson() -- 获取唤醒原因
log.info("wakeup state", pm.lastReson())
local libnet = require "libnet"

local d1Name = "D1_TASK"
local function netCB(msg)
    log.info("未处理消息", msg[1], msg[2], msg[3], msg[4])
end

local function testTask(ip, port)
    local txData
    --如果是开机唤醒的，给服务器发的数据为normal wakeup
    --如果是底层定时器唤醒的，给服务器发的数据为timer wakeup
    --如果是wakeup脚或者GPIO脚唤醒的，给服务器发的数据为pad wakeup
    --如果是串口唤醒的，给服务器发的数据为uart1 wakeup
    if reason == 0 then
        txData = "normal wakeup"
    elseif reason == 1 then
        txData = "timer wakeup"
    elseif reason == 2 then
        txData = "pad wakeup"
    elseif reason == 3 then
        txData = "uart1 wakeup"
    end

    if slp_state > 0 then
        mobile.flymode(0, false) -- 退出飞行模式，进入psm+前进入飞行模式，唤醒后需要主动退出
    end

    gpio.close(32)

    local netc, needBreak
    local result, param, is_err
    netc = socket.create(nil, d1Name)
    socket.debug(netc, false)
    socket.config(netc) -- demo用TCP服务器，目前需要在用极致功耗模式时先断开服务器
    local retry = 0
    while retry < 3 do
        log.info(rtos.meminfo("sys"))
        result = libnet.waitLink(d1Name, 0, netc)
        result = libnet.connect(d1Name, 5000, netc, ip, port)
        if result then
            log.info("服务器连上了")
            result, param = libnet.tx(d1Name, 15000, netc, txData)
            if not result then
                log.info("服务器断开了", result, param)
                break
            else
                needBreak = true
            end
        else
            log.info("服务器连接失败")
        end
        libnet.close(d1Name, 5000, netc)
        retry = retry + 1
        if needBreak then
            break
        end
    end

    uart.setup(1, 9600) -- 配置uart1，外部唤醒用

    -- 配置GPIO达到最低功耗
    gpio.setup(23, nil)
    gpio.close(35) -- 这里pwrkey接地才需要，不接地通过按键控制的不需要
    gpio.setup(32, function() -- 配置wakeup中断，外部唤醒用
        log.info("gpio")
    end, gpio.PULLUP, gpio.FALLING)

    pm.dtimerStart(3, period) -- 启动深度休眠定时器
    mobile.flymode(0, true) -- 进低功耗模式前先进飞行模式，避免因为网络波动导致的意外唤醒或功耗异常
    pm.power(pm.WORK_MODE, 3) -- 进入极致功耗模式

    sys.wait(15000) -- demo演示唤醒时间是五分钟，如果15s后模块重启，则说明进入极致功耗模式失败，
    log.info("进入极致功耗模式失败，尝试重启")
    rtos.reboot()
end
sysplus.taskInitEx(testTask, d1Name, netCB, server_ip, server_port)

--链接成功后循环发送数据
        while succ do
            local Heartbeat_interval = Heartbeat_interval * 60 * 1000
            sys.wait(Heartbeat_interval)
            socket.tx(netc, heart_data)
            --在这里加上下面那一段
        end

local rsrp_data = mobile.rsrp()--当前信号质量
local cid = mobile.eci()--当前小区ID
uart.write(1,  "当前RSRP：" .. rsrp_data .. "  当前小区ID:" .. cid)
uart.write(1, "\r\n当前服务小区的其他信息" .. json.encode(mobile.scell()))

local buff = zbuff.create(40)
buff[0] = 3 --band3
buff[1] = 5 --band5
buff[2] = 8 --band8
buff[3] = 40 --band40
mobile.setBand(buff, 4) --设置使用的band一共4个，为3,5,8,40

local buff = zbuff.create(40)
buff[0] = 3 --band3
mobile.setBand(buff, 1) --设置使用的band为band3