LuatOS/demo/ctiot/Air302/main.lua

-- ctiot库API
-- ctiot.init() 
-- 初始化引擎，开机后只需要一次，没有参数输入输出
-- ctiot.ep(new_ep) 
-- 设置读取用户自定义EP，如果不设置，则使用IMEI，输入新的EP，同时输出当前EP，
-- 输入nil，则为读取，输入""，清除EP
-- ctiot.param(server_ip, server_port, lifetime)
-- 设置读取必要的参数，分别为服务器IP，端口和保活时间
-- 输入nil，则为读取参数
-- ctiot.connect()
-- 启动连接服务器
-- ctiot.disconnect()
-- 断开服务器
-- ctiot.write(data, mode, seq)
-- 发送数据，输入参数为数据，发送模式，发送序号
-- 发送模式为ctiot.CON, ctiot.NON, ctiot.NON_REL, ctiot.CON_REL
-- 发送序号只是一个标识，不会影响发送的数据和模式，在发送结果回调时会返回
-- ctiot.isReady()
-- 检测当前ctiot连接状态是否可以发送数据
-- 0可以，其他都不可以
PROJECT = "ctiot"
VERSION = "1.0.0"
local TAG="ctiot"
-- sys库是标配
_G.sys = require("sys")

local function cb_rx(data)
    log.info(TAG, "rx", data:toHex())
end

local function cb_dereg(error, error_code, param)
    log.info(TAG, "dereg", error, error_code, param)
end

local function cb_wakeup(error, error_code, param)
    log.info(TAG, "wakeup", error, error_code, param)
end

local function cb_fota(error, error_code, param)
    log.info(TAG, "fota", error, error_code, param)
end

local function cb_other(error, error_code, param)
    log.info(TAG, "other", error, error_code, param)
end

--sys.subscribe("CTIOT_TX", cb_tx)
sys.subscribe("CTIOT_RX", cb_rx)
--sys.subscribe("CTIOT_REG", cb_reg)
--sys.subscribe("CTIOT_DEREG", cb_dereg)
--sys.subscribe("CTIOT_WAKEUP", cb_wakeup)
sys.subscribe("CTIOT_OTHER", cb_other)
sys.subscribe("CTIOT_FOTA", cb_fota)

local function send_test()
    log.info(TAG, "test tx")
    local result, tx_error, error_code, param
    --发送的数据请按照自己的profile修改
    --发送数据，并要求服务器应答
    result, tx_error = ctiot.write(pack.pack("<bbA", 0x00,0x05, "hello"), ctiot.CON, 0)
    --发送数据，并要求服务器应答，序号为11
    --result, tx_error = ctiot.write(pack.pack("<bbA", 0x00,0x05, "hello"), ctiot.CON, 11)
    --发送数据，不需要服务器应答
    --result, tx_error = ctiot.write(pack.pack("<bbA", 0x00,0x05, "hello"), ctiot.NON, 0)
    --发送数据，不需要服务器应答，序号为23
    --result, tx_error = ctiot.write(pack.pack("<bbA", 0x00,0x05, "hello"), ctiot.NON, 23)
    --发送数据，不需要服务器应答，发送完成后立刻释放RRC，加快进入休眠的速度
    --result, tx_error = ctiot.write(pack.pack("<bbA", 0x00,0x05, "hello"), ctiot.NON_REL, 0)
    --发送数据，不需要服务器应答，发送完成后立刻释放RRC，加快进入休眠的速度，序号为56
    --result, tx_error = ctiot.write(pack.pack("<bbA", 0x00,0x05, "hello"), ctiot.NON_REL, 56)
    --发送数据，并要求服务器应答，接收到应答后立刻释放RRC，加快进入休眠的速度
    --result, tx_error = ctiot.write(pack.pack("<bbA", 0x00,0x05, "hello"), ctiot.CON_REL, 0)
    --发送数据，并要求服务器应答，接收到应答后立刻释放RRC，加快进入休眠的速度，序号为255，序号最大255
    --result, tx_error = ctiot.write(pack.pack("<bbA", 0x00,0x05, "hello"), ctiot.CON_REL, 255)
    log.info(TAG, result, tx_error)
    result, tx_error, error_code, param = sys.waitUntilExt("CTIOT_TX", 20000)
    if result then
        if not tx_error then
            log.info(TAG, "tx ok", param)
        else
            log.info(TAG, "tx fail", error_code, param)
            ctiot.disconnect()
            result, dereg_error, error_code, param = sys.waitUntilExt("CTIOT_DEREG", 30000)
            ctiot.connect()
            while true do
                result, error, error_code, param = sys.waitUntilExt("CTIOT_REG", 60000)
                if not result and error==nil then
                    log.info(TAG, "reg wait timeout")
                    break
                end
                log.info(TAG, result, error, error_code, param)
                if not error and param > 0 then
                    log.info(TAG, "reg ok")
                    isConnected = true
                    break
                end
                if error then
                    log.info(TAG, "reg fail")
                    break
                end
            end
        end
    else
        log.info(TAG, "tx no work")
    end

end

local function task()
    local inSleep = false
    local isConnected = false
    local result, error, error_code, param
    if pm.lastReson() ~= 0 then
        --如果不是自己的定时器唤醒，继续睡
        if pm.dtimerCheck(0) then
            pm.request(pm.HIB)
            return
        end
        --唤醒的不需要处理
        pm.request(pm.IDLE)
        log.info(TAG, "after", ctiot.ep(), ctiot.param())
		--一定要等待一下，否则会重启！！！
		sys.wait(1000)
    else
        --设置自定义EP，如果不设置，则使用IMEI
        --local ep="867814046436271"
        --local ep="qweasdzxcrtyfgh"
        --if ctiot.ep() ~= ep then
            --ctiot.ep(ep)
        --end
        ctiot.ep(nil)
        --设置服务器IP，端口，保活时间
        --ctiot.param("180.101.147.115", 5683, 300)
        ctiot.param("221.229.214.202", 5683, 300)
        local ip, port, keeptime = ctiot.param()
        log.info(TAG, "set param", ip, port, keeptime)
    end
	while not socket.isReady() do 
		log.info("net", "wait for network ready")
		sys.waitUntil("NET_READY", 1000)
    end

    --无论是重启还是从深度休眠唤醒，必须重新启动连接
	ctiot.connect()
	while true do
		result, error, error_code, param = sys.waitUntilExt("CTIOT_REG", 60000)
		if not result and error==nil then
			log.info(TAG, "reg wait timeout")
			break
		end
		log.info(TAG, result, error, error_code, param)
		if not error and param > 0 then
			log.info(TAG, "reg ok")
			isConnected = true
			break
		end
		if error then
			log.info(TAG, "reg fail")
			break
		end
	end


    if isConnected then
        send_test()
        --凡是不进入深度休眠的，221.229.214.202 这个IP必须在保活时间内update一下
        --ctiot.update()
        --result, error, error_code, param = sys.waitUntilExt("CTIOT_UPDATE", 60000)
    end
    -- 30秒后唤醒,发个测试数据
    if not inSleep then
        pm.dtimerStart(0, 30000)
        inSleep = true
    end
    -- 我要睡了!!! 事实上还会等几秒, 这时候服务器还能下发数据
    pm.request(pm.HIB)
    -- 退出CTIOT
    -- ctiot.dereg()
    -- result, dereg_error, error_code, param = sys.waitUntilExt("CTIOT_DEREG", 30000)
end
ctiot.init()
sys.taskInit(task)
sys.run()