LuatOS/module/Air8101/demo/fota2/self_server/customer_srv_fota.lua

--[[
@module  air_srv_fota
@summary 使用自建服务器远程升级功能模块
@version 1.0
@date    2025.08.12
@author  孟伟
@usage
实现远程升级功能，具体流程如下：
1、接收 CUSTOMER_SRV_FOTA 系统消息，触发升级；
2、判断网卡是否连接成功；
3、初始化fota2模块；
4、调用fota2模块的升级函数;
5、根据升级结果进行处理；
]]


--加在libfota2扩展库
libfota2 = require "libfota2"

-- 循环打印版本号, 方便看版本号变化, 非必须
function get_version()
    log.info("降功耗 找合宙")
    log.info("fota", "脚本版本号", VERSION, "core版本号", rtos.version())
end

sys.timerLoopStart(get_version, 3000)

-- fota升级标志：true 表示当前正有 FOTA 流程在跑
local fota_running = false

-- 升级结果的回调函数
-- 功能:获取fota的回调函数
-- 参数:
-- result:number类型
--   0表示成功
--   1表示连接失败
--   2表示url错误
--   3表示服务器断开
--   4表示接收报文错误
--   5缺少必要的PROJECT_KEY参数
local function fota_cb(ret)
    log.info("fota", ret)
    -- fota结束，无论成功还是失败，都释放fota_running标志
    fota_running = false

    if ret == 0 then
        log.info("升级包下载成功,重启模块")
        rtos.reboot()
    elseif ret == 1 then
        log.info("连接失败", "请检查url拼写或服务器配置(是否为内网)")
    elseif ret == 2 then
        log.info("url错误", "检查url拼写")
    elseif ret == 3 then
        log.info("服务器断开", "检查服务器白名单配置")
    elseif ret == 4 then
        log.error("FOTA 失败",
            "原因可能有：\n" ..
            "1) 服务器返回 200/206 但报文体为空(0 字节）—— 通常是升级包文件缺失或 URL 指向空文件；\n" ..
            "2) 服务器返回 4xx/5xx 等异常状态码 —— 请确认升级包已上传、URL 正确、鉴权信息有效；\n" ..
            "3) 已经是最新版本，无需升级")
    elseif ret == 5 then
        log.info("缺少必要的PROJECT_KEY参数")
    else
        log.info("不是上面几种情况 ret为", ret)
    end
end


-- 使用第三方服务器，配置ota_opts参数
--[[
-- opts参数说明, 所有参数都是可选的
-- 1. opts.url string 升级所需要的URL, 若使用合宙iot平台,则不需要填
-- 2. opts.version string 版本号, 默认是 BSP版本号.x.z格式
-- 3. opts.timeout int 请求超时时间, 默认300000毫秒,单位毫秒
-- 4. opts.project_key string 合宙IOT平台的项目key, 默认取全局变量PRODUCT_KEY. 自建服务器不用填
-- 5. opts.imei string 设备识别码, 默认取IMEI(Cat.1模块)或WLAN MAC地址(wifi模块)或MCU唯一ID
-- 6. opts.firmware_name string 固件名称,默认是 _G.PROJECT.. "_LuatOS-SoC_" .. rtos.bsp()
-- 7. opts.server_cert string 服务器证书, 默认不使用
-- 8. opts.client_cert string 客户端证书, 默认不使用
-- 9. opts.client_key string 客户端私钥, 默认不使用
-- 10. opts.client_password string 客户端私钥口令, 默认不使用
-- 11. opts.method string 请求方法, 默认是GET
-- 12. opts.headers table 额外添加的请求头,默认不需要
-- 13. opts.body string 额外添加的请求body,默认不需要
]]
local opts = {
    url = "",
    -- 合宙IOT平台的默认升级URL, 不填就是这个默认值
    -- 如果是自建的OTA服务器, 则需要填写正确的URL, 例如 http://192.168.1.5:8000/update
    -- 如果自建OTA服务器,且url包含全部参数,不需要额外添加参数, 请在url前面添加 ###
    -- 如果不加###，则默认会上传如下参数
    -- 1. opts.version string 版本号, 默认是 BSP版本号.x.z格式
    -- 2. opts.timeout int 请求超时时间, 默认300000毫秒,单位毫秒
    -- 3. opts.project_key string 合宙IOT平台的项目key, 默认取全局变量PRODUCT_KEY. 自建服务器不用填
    -- 4. opts.imei string 设备识别码, 默认取IMEI(Cat.1模块)或WLAN MAC地址(wifi模块)或MCU唯一ID
    -- 5. opts.firmware_name string 底层版本号

    -- 请求的版本号, 合宙IOT有一套版本号体系,不传就是合宙规则, 自建服务器的话当然是自行约定版本号了
    version = ""
    -- 其他更多参数, 请查阅libfota2的文档 https://docs.openluat.com/osapi/ext/libfota2/
}


local function air_fota_func(data)
    -- 如果当前时间点设置的默认网卡还没有连接成功，一直在这里循环等待
    while not socket.adapter(socket.dft()) do
        log.warn("fota_task_func", "wait IP_READY", socket.dft())
        -- 在此处阻塞等待默认网卡连接成功的消息"IP_READY"
        -- 或者等待1秒超时退出阻塞等待状态;
        -- 注意：此处的1000毫秒超时不要修改的更长；
        -- 因为当使用libnetif.set_priority_order配置多个网卡连接外网的优先级时，会隐式的修改默认使用的网卡
        -- 当libnetif.set_priority_order的调用时序和此处的socket.adapter(socket.dft())判断时序有可能不匹配
        -- 此处的1秒，能够保证，即使时序不匹配，也能1秒钟退出阻塞状态，再去判断socket.adapter(socket.dft())
        sys.waitUntil("IP_READY", 1000)
    end
    -- 检测到了IP_READY消息
    log.info("fota_task_func", "recv IP_READY", socket.dft())
    while true do
        -- 阻塞等待外部事件："CUSTOMER_SRV_FOTA"
        local result, data = sys.waitUntil("CUSTOMER_SRV_FOTA")
        if result then
            log.info("接收到数据", "date", #data)

            if fota_running then
                log.warn("fota_task", "FOTA 正在运行，跳过本次请求")
            else
                -- 标记FOTA正在运行
                -- 注意：这里只是标记，实际的FOTA流程还没有开始
                opts.url = data.url
                opts.version = data.version
                fota_running = true
                log.info("开始检查升级")
                libfota2.request(fota_cb, opts)
            end
        end
    end
end
-- 初始化FOTA任务
sys.taskInit(air_fota_func)