G31_luatide_proj/httpTask.lua

module(...,package.seeall)

require"http"
require"nvm"
require "funlib"

local rfidType = nvm.get("rfidType")
local devId = nvm.get("devId")
local devSn = nvm.get("devSn")
local moduleImei = nvm.get("moduleImei")
local httpDevopsUrl = nvm.get("httpDevopsUrl")
local httpDevopsInterval = nvm.get("httpDevopsInterval")

local isHttpRequesting = false

--920设备状态 0:offline 1:online
local g91State = 0

local function cbFnc(result,prompt,head,body)
    isHttpRequesting = false
    log.info("httpTask.cbFnc","result:",result,"prompt:",prompt)
    --[[
    if result and head then
        for k,v in pairs(head) do
            log.info("httpTask.cbFnc",k..": "..v)
        end
    end
    ]]
    if result and body then
        log.info("httpTask.cbFnc","bodyLen="..body:len(), body)
        local res_config = json.decode(body)
        if not res_config then
            log.error("httpTask.cbFnc","json decode error!")
            return false
        end
        if not res_config.success then
            log.error("httpTask.cbFnc",res_config.message)
            return false
        end
        if not res_config.data then
            log.error("httpTask.cbFnc","res_config.data empty!")
            return false
        end
        if res_config.data.deviceId ~= devId then
            log.error("httpTask.cbFnc","res_config.data.deviceId ~= devId!")
            return false
        end

        local isReboot = false
        if res_config.data.httpDevopsUrl ~= "" and res_config.data.httpDevopsUrl ~= nvm.get("httpDevopsUrl") then
            if not nvm.set("httpDevopsUrl", res_config.data.httpDevopsUrl) then
                log.error("httpTask.cbFnc","nvm set httpDevopsUrl failed!")
                return false
            end
            isReboot = true
        end
        if res_config.data.errorLogReportUrl ~= "" and res_config.data.errorLogReportUrl ~= nvm.get("errorLogReportUrl") then
            if not nvm.set("errorLogReportUrl", res_config.data.errorLogReportUrl) then
                log.error("httpTask.cbFnc","nvm set errorLogReportUrl failed!")
                return false
            end
            isReboot = true
        end
        local _errorLogReportInterval = tonumber(res_config.data.errorLogReportInterval)
        if type(_errorLogReportInterval) == "number" and _errorLogReportInterval >= 30 and _errorLogReportInterval ~= nvm.get("errorLogReportInterval") then
            if not nvm.set("errorLogReportInterval", _errorLogReportInterval) then
                log.error("httpTask.cbFnc","nvm set errorLogReportInterval failed!")
                return false
            end
            isReboot = true
        end
        local _httpDevopsInterval = tonumber(res_config.data.httpDevopsInterval)
        if type(_httpDevopsInterval) == "number" and _httpDevopsInterval >= 30 and _httpDevopsInterval ~= nvm.get("httpDevopsInterval") then
            if not nvm.set("httpDevopsInterval", _httpDevopsInterval) then
                log.error("httpTask.cbFnc","nvm set httpDevopsInterval failed!")
                return false
            end
            isReboot = true
        end
        local _httpEnableParamsReport = tonumber(res_config.data.httpEnableParamsReport)
        if type(_httpEnableParamsReport) == "number" and _httpEnableParamsReport ~= nvm.get("httpEnableParamsReport") then
            if not nvm.set("httpEnableParamsReport", _httpEnableParamsReport) then
                log.error("httpTask.cbFnc","nvm set httpEnableParamsReport failed!")
                return false
            end
            isReboot = true
        end
        local _devRebootTime = res_config.data.devRebootTime
        if _devRebootTime ~= "" and _devRebootTime ~= nvm.get("devRebootTime") then
            if not string.find(_devRebootTime, "(%d%d:%d%d:%d%d)") then
                log.error("httpTask.cbFnc","devRebootTime format error!",_devRebootTime)
            else
                if not nvm.set("devRebootTime", _devRebootTime) then
                    log.error("httpTask.cbFnc","nvm set devRebootTime failed!")
                    return false
                end
                isReboot = true
            end
        end
        local _isRebootDevice = tonumber(res_config.data.isRebootDevice)
        if _isRebootDevice == 1 then
            log.info("httpTask.cbFnc","receive device reboot command")
            isReboot = true
        end
        
        local _isRestoreDevice = tonumber(res_config.data.isRestoreDevice)
        if _isRestoreDevice == 1 then
            log.info("httpTask.cbFnc","receive device restore command")
            nvm.restore()
            isReboot = true
        end
        local _isStartOta = tonumber(res_config.data.isStartOta)
        if _isStartOta == 1 then
            log.info("httpTask.cbFnc","receive device start ota command, publish message: device_command_ota_start")
            sys.publish("device_command_ota_start")
            return
        end
        local _otaCheckInterval = tonumber(res_config.data.otaCheckInterval)
        if type(_otaCheckInterval) == "number" and _otaCheckInterval >= 30 and _otaCheckInterval ~= nvm.get("otaCheckInterval") then
            if not nvm.set("otaCheckInterval", _otaCheckInterval) then
                log.error("httpTask.cbFnc","nvm set otaCheckInterval failed!")
                return false
            end
            isReboot = true
        end
        
        local _rfidRssiFilterVal = tonumber(res_config.data.rfidRssiFilterVal)
        if type(_rfidRssiFilterVal) == "number" and _rfidRssiFilterVal > 0 and _rfidRssiFilterVal ~= nvm.get("rfidRssiFilterVal") then
            if not nvm.set("rfidRssiFilterVal", _rfidRssiFilterVal) then
                log.error("httpTask.cbFnc","nvm set rfidRssiFilterVal failed!")
                return false
            end
            isReboot = true
        end
        
        local enableUploadRfid24 = tonumber(res_config.data.enableUploadRfid24)
        if type(enableUploadRfid24) == "number" and (enableUploadRfid24 == 0 or enableUploadRfid24 == 1) and enableUploadRfid24 ~= nvm.get("enableUploadRfid24") then
            if not nvm.set("enableUploadRfid24", enableUploadRfid24) then
                log.error("httpTask.cbFnc","nvm set enableUploadRfid24 failed!")
                return false
            end
            isReboot = true
        end

        if rfidType == "tiandiren" then
            if res_config.data.ddzxIp ~= ""  and res_config.data.ddzxIp ~= nvm.get("ddzxIp") then
                if not nvm.set("ddzxIp", res_config.data.ddzxIp) then
                    log.error("httpTask.cbFnc","nvm set ddzxIp failed!")
                    return false
                end
                isReboot = true
            end
            local _ddzxTcpPort = res_config.data.ddzxTcpPort
            if _ddzxTcpPort ~= "" and _ddzxTcpPort ~= nvm.get("ddzxTcpPort") then
                if not nvm.set("ddzxTcpPort", _ddzxTcpPort) then
                    log.error("httpTask.cbFnc","nvm set ddzxTcpPort failed!")
                    return false
                end
                isReboot = true
            end
            local _ddzxWaitRecvMsgMaxTime = tonumber(res_config.data.ddzxWaitRecvMsgMaxTime)
            if type(_ddzxWaitRecvMsgMaxTime) == "number" and _ddzxWaitRecvMsgMaxTime > 0 and _ddzxWaitRecvMsgMaxTime ~= nvm.get("ddzxWaitRecvMsgMaxTime") then
                if not nvm.set("ddzxWaitRecvMsgMaxTime", _ddzxWaitRecvMsgMaxTime) then
                    log.error("httpTask.cbFnc","nvm set ddzxWaitRecvMsgMaxTime failed!")
                    return false
                end
                isReboot = true
            end
            local _rfidOfflineTimeout = tonumber(res_config.data.rfidOfflineTimeout)
            if type(_rfidOfflineTimeout) == "number" and _rfidOfflineTimeout > 0 and _rfidOfflineTimeout ~= nvm.get("rfidOfflineTimeout") then
                if not nvm.set("rfidOfflineTimeout", _rfidOfflineTimeout) then
                    log.error("httpTask.cbFnc","nvm set rfidOfflineTimeout failed!")
                    return false
                end
                isReboot = true
            end
            
            local _rfidMinDiffTime = tonumber(res_config.data.rfidMinDiffTime)
            if type(_rfidMinDiffTime) == "number" and _rfidMinDiffTime > 0 and _rfidMinDiffTime ~= nvm.get("rfidMinDiffTime") then
                if not nvm.set("rfidMinDiffTime", _rfidMinDiffTime) then
                    log.error("httpTask.cbFnc","nvm set rfidMinDiffTime failed!")
                    return false
                end
                isReboot = true
            end

            local _enableFilterTdrRfid = tonumber(res_config.data.enableFilterTdrRfid)
            if type(_enableFilterTdrRfid) == "number" and (_enableFilterTdrRfid == 0 or _enableFilterTdrRfid == 1) and _enableFilterTdrRfid ~= nvm.get("enableFilterTdrRfid") then
                if not nvm.set("enableFilterTdrRfid", _enableFilterTdrRfid) then
                    log.error("httpTask.cbFnc","nvm set enableFilterTdrRfid failed!")
                    return false
                end
                isReboot = true
            end

            local _onlyDevTypeVal = res_config.data.onlyDevTypeVal
            if _onlyDevTypeVal ~= nvm.get("onlyDevTypeVal") then
                if not nvm.set("onlyDevTypeVal", _onlyDevTypeVal) then
                    log.error("httpTask.cbFnc","nvm set onlyDevTypeVal failed!")
                    return false
                end
                isReboot = true
            end
            
            local _msgQueueMaxLen = tonumber(res_config.data.msgQueueMaxLen)
            if type(_msgQueueMaxLen) == "number" and _msgQueueMaxLen > 0 and _msgQueueMaxLen ~= nvm.get("msgQueueMaxLen") then
                if not nvm.set("msgQueueMaxLen", _msgQueueMaxLen) then
                    log.error("httpTask.cbFnc","nvm set msgQueueMaxLen failed!")
                    return false
                end
                isReboot = true
            end
        elseif rfidType == "renlian" then
            if (res_config.data.enableHeartbeat == 0 or res_config.data.enableHeartbeat == 1)  and res_config.data.enableHeartbeat ~= nvm.get("enableHeartbeat") then
                if not nvm.set("enableHeartbeat", res_config.data.enableHeartbeat) then
                    log.error("httpTask.cbFnc","nvm set enableHeartbeat failed!")
                    return false
                end
                isReboot = true
            end
            if funlib.ipFormatVerify(res_config.data.heartbeatIp)  and res_config.data.heartbeatIp ~= nvm.get("heartbeatIp") then
                if not nvm.set("heartbeatIp", res_config.data.heartbeatIp) then
                    log.error("httpTask.cbFnc","nvm set heartbeatIp failed!")
                    return false
                end
                isReboot = true
            end
            
            local heartbeatTcpPort = res_config.data.heartbeatTcpPort or ""
            if heartbeatTcpPort ~= "" and heartbeatTcpPort ~= nvm.get("heartbeatTcpPort") then
                if not nvm.set("heartbeatTcpPort", heartbeatTcpPort) then
                    log.error("httpTask.cbFnc","nvm set heartbeatTcpPort failed!")
                    return false
                end
                isReboot = true
            end
            
            local heartbeatInterval = res_config.data.heartbeatInterval or 0
            if heartbeatInterval >= 10 and heartbeatInterval ~= nvm.get("heartbeatInterval") then
                if not nvm.set("heartbeatInterval", heartbeatInterval) then
                    log.error("httpTask.cbFnc","nvm set heartbeatInterval failed!")
                    return false
                end
                isReboot = true
            end

            if res_config.data.dataIp ~= ""  and res_config.data.dataIp ~= nvm.get("dataIp") then
                if not nvm.set("dataIp", res_config.data.dataIp) then
                    log.error("httpTask.cbFnc","nvm set dataIp failed!")
                    return false
                end
                isReboot = true
            end
            
            local _dataTcpPort = res_config.data.dataTcpPort
            if _dataTcpPort ~= "" and _dataTcpPort ~= nvm.get("dataTcpPort") then
                if not nvm.set("dataTcpPort", _dataTcpPort) then
                    log.error("httpTask.cbFnc","nvm set dataTcpPort failed!")
                    return false
                end
                isReboot = true
            end
    
            local _dataUdpPort = res_config.data.dataUdpPort
            if _dataUdpPort ~= "" and _dataUdpPort ~= nvm.get("dataUdpPort") then
                if not nvm.set("dataUdpPort", _dataUdpPort) then
                    log.error("httpTask.cbFnc","nvm set dataUdpPort failed!")
                    return false
                end
                isReboot = true
            end
            local _rfidEnableThrottleRlian = tonumber(res_config.data.rfidEnableThrottleRlian)
            if _rfidEnableThrottleRlian >=0 and _rfidEnableThrottleRlian ~= nvm.get("rfidEnableThrottleRlian") then
                if not nvm.set("rfidEnableThrottleRlian", _rfidEnableThrottleRlian) then
                    log.error("httpTask.cbFnc","nvm set rfidEnableThrottleRlian failed!")
                    return false
                end
                isReboot = true
            end
            local _rfidReportIntervalRlian = tonumber(res_config.data.rfidReportIntervalRlian)
            if type(_rfidReportIntervalRlian) == "number" and _rfidReportIntervalRlian >0 and _rfidReportIntervalRlian ~= nvm.get("rfidReportIntervalRlian") then
                if not nvm.set("rfidReportIntervalRlian", _rfidReportIntervalRlian) then
                    log.error("httpTask.cbFnc","nvm set rfidReportIntervalRlian failed!")
                    return false
                end
                isReboot = true
            end
            local _rfidBufferMaxCountRlian = tonumber(res_config.data.rfidBufferMaxCountRlian)
            if type(_rfidBufferMaxCountRlian) == "number" and _rfidBufferMaxCountRlian >0 and _rfidBufferMaxCountRlian ~= nvm.get("rfidBufferMaxCountRlian") then
                if not nvm.set("rfidBufferMaxCountRlian", _rfidBufferMaxCountRlian) then
                    log.error("httpTask.cbFnc","nvm set rfidBufferMaxCountRlian failed!")
                    return false
                end
                isReboot = true
            end
            local _rfidOfflineTimeoutRlian = tonumber(res_config.data.rfidOfflineTimeoutRlian)
            if type(_rfidOfflineTimeoutRlian) == "number" and _rfidOfflineTimeoutRlian >0 and _rfidOfflineTimeoutRlian ~= nvm.get("rfidOfflineTimeoutRlian") then
                if not nvm.set("rfidOfflineTimeoutRlian", _rfidOfflineTimeoutRlian) then
                    log.error("httpTask.cbFnc","nvm set rfidOfflineTimeoutRlian failed!")
                    return false
                end
                isReboot = true
            end
        elseif rfidType == "dahua" then
            if res_config.data.ddzxIpDahua ~= ""  and res_config.data.ddzxIpDahua ~= nvm.get("ddzxIpDahua") then
                if not nvm.set("ddzxIpDahua", res_config.data.ddzxIpDahua) then
                    log.error("httpTask.cbFnc","nvm set ddzxIpDahua failed!")
                    return false
                end
                isReboot = true
            end
            local _ddzxTcpPortDahua = res_config.data.ddzxTcpPortDahua
            if _ddzxTcpPortDahua ~= "" and _ddzxTcpPortDahua ~= nvm.get("ddzxTcpPortDahua") then
                if not nvm.set("ddzxTcpPortDahua", _ddzxTcpPortDahua) then
                    log.error("httpTask.cbFnc","nvm set ddzxTcpPortDahua failed!")
                    return false
                end
                isReboot = true
            end
            local _rfidBufferMaxCountDahua = tonumber(res_config.data.rfidBufferMaxCountDahua)
            if type(_rfidBufferMaxCountDahua) == "number" and _rfidBufferMaxCountDahua > 0 and _rfidBufferMaxCountDahua ~= nvm.get("rfidBufferMaxCountDahua") then
                if not nvm.set("rfidBufferMaxCountDahua", _rfidBufferMaxCountDahua) then
                    log.error("httpTask.cbFnc","nvm set rfidBufferMaxCountDahua failed!")
                    return false
                end
                isReboot = true
            end
            local _rfidReportIntervalDahua = tonumber(res_config.data.rfidReportIntervalDahua)
            if type(_rfidReportIntervalDahua) == "number" and _rfidReportIntervalDahua > 0 and _rfidReportIntervalDahua ~= nvm.get("rfidReportIntervalDahua") then
                if not nvm.set("rfidReportIntervalDahua", _rfidReportIntervalDahua) then
                    log.error("httpTask.cbFnc","nvm set rfidReportIntervalDahua failed!")
                    return false
                end
                isReboot = true
            end
        else
            log.error("httpTask.cbFnc","invalid rfidType!! rfidType:", rfidType)
            return false
        end
        

        if isReboot then
            log.info("httpTask.cbFnc","config updated, need reboot now ...")
            sys.restart("config.lua updated")
            return
        end

    end
end

local function http_heartbeat()
    local coreVersion = rtos.get_version() or ""
    local scriptVersion = _G.VERSION or ""
    local simIccid = nvm.get("simIccid") or ""
    local simImsi = nvm.get("simImsi") or ""
    local httpDevopsInterval = nvm.get("httpDevopsInterval") or ""
    local devRebootTime = nvm.get("devRebootTime") or ""
    local otaUrl = nvm.get("otaUrl") or ""
    local otaCheckInterval = nvm.get("otaCheckInterval") or ""
    local errorLogReportUrl = nvm.get("errorLogReportUrl") or ""
    local errorLogReportInterval = nvm.get("errorLogReportInterval") or ""
    local bootNum = nvm.get("bootNum") or ""
    local devModel = nvm.get("devModel") or ""
    local rfidRssiFilterVal = nvm.get("rfidRssiFilterVal") or ""
    local httpEnableParamsReport = nvm.get("httpEnableParamsReport") or 0
    local enableUploadRfid24 = nvm.get("enableUploadRfid24") or 1
    moduleImei = misc.getImei() or ""
    if not coreVersion then
        log.error("httpTask.http_heartbeat","coreVersion not existed!!")
        return false
    end
    if not scriptVersion then
        log.error("httpTask.http_heartbeat","scriptVersion not existed!!")
        return false
    end
    if not simIccid then
        log.error("httpTask.http_heartbeat","simIccid not existed!!")
        return false
    end
    if not simImsi then
        log.error("httpTask.http_heartbeat","simImsi not existed!!")
        return false
    end
    if not devId then
        log.error("httpTask.http_heartbeat","devId not existed!!")
        return false
    end
    if not devSn then
        log.error("httpTask.http_heartbeat","devSn not existed!!")
        return false
    end
    if not moduleImei then
        log.error("httpTask.http_heartbeat","moduleImei not existed!!")
        return false
    end
    if not httpDevopsUrl then
        log.error("httpTask.http_heartbeat","httpDevopsUrl not existed!!")
        return false
    end
    local ramUsed = _G.collectgarbage("count")
    local freeFlash = rtos.get_fs_free_size()
    local netRssi = net.getRssi()
    local reqUrl = ""
    if httpEnableParamsReport == 1 then
        reqUrl = httpDevopsUrl.."&deviceId="..devId.."&deviceImei="..moduleImei.."&deviceSn="..devSn.."&coreVersion="..coreVersion
                            .."&scriptVersion="..scriptVersion.."&simIccid="..simIccid.."&simImsi="..simImsi
                            .."&httpDevopsInterval="..httpDevopsInterval.."&devRebootTime="..devRebootTime
                            .."&otaUrl="..otaUrl.."&otaCheckInterval="..otaCheckInterval.."&errorLogReportUrl="..errorLogReportUrl
                            .."&errorLogReportInterval="..errorLogReportInterval.."&bootNum="..bootNum.."&devModel="..devModel
                            .."&ramUsed="..ramUsed.."&freeFlash="..freeFlash.."&netRssi="..netRssi.."&rfidRssiFilterVal="..rfidRssiFilterVal
                            .."&enableUploadRfid24="..enableUploadRfid24

        if rfidType == "tiandiren" then
            local ddzxIp = nvm.get("ddzxIp") or ""
            local ddzxTcpPort = nvm.get("ddzxTcpPort") or ""
            local ddzxWaitRecvMsgMaxTime = nvm.get("ddzxWaitRecvMsgMaxTime") or ""
            local rfidOfflineTimeout = nvm.get("rfidOfflineTimeout") or ""
            local rfidMinDiffTime = nvm.get("rfidMinDiffTime") or ""
            local msgQueueMaxLen = nvm.get("msgQueueMaxLen") or ""

            local enableFilterTdrRfid = nvm.get("enableFilterTdrRfid") or 1
            local onlyDevTypeVal = nvm.get("onlyDevTypeVal") or ""

            reqUrl = reqUrl.."&ddzxIp="..ddzxIp.."&ddzxTcpPort="..ddzxTcpPort.."&ddzxWaitRecvMsgMaxTime="..ddzxWaitRecvMsgMaxTime
            .."&rfidOfflineTimeout="..rfidOfflineTimeout.."&msgQueueMaxLen="..msgQueueMaxLen
            .."&rfidMinDiffTime="..rfidMinDiffTime.."&enableFilterTdrRfid="..enableFilterTdrRfid.."&onlyDevTypeVal="..onlyDevTypeVal
        elseif  rfidType == "renlian" then
            local enableHeartbeat = nvm.get("enableHeartbeat") or 0
            local dataIp = nvm.get("dataIp") or ""
            local dataTcpPort = nvm.get("dataTcpPort") or ""
            local dataUdpPort = nvm.get("dataUdpPort") or ""
            local heartbeatIp = nvm.get("heartbeatIp") or ""
            local heartbeatTcpPort = nvm.get("heartbeatTcpPort") or ""
            local heartbeatUdpPort = nvm.get("heartbeatUdpPort") or ""
            local heartbeatInterval = nvm.get("heartbeatInterval") or 0
            local rfidReportIntervalRlian = nvm.get("rfidReportIntervalRlian") or ""
            local rfidBufferMaxCountRlian = nvm.get("rfidBufferMaxCountRlian") or ""
            local rfidEnableThrottleRlian = nvm.get("rfidEnableThrottleRlian")
            local rfidOfflineTimeoutRlian = nvm.get("rfidOfflineTimeoutRlian") or ""
            reqUrl = reqUrl.."&dataIp="..dataIp.."&dataTcpPort="..dataTcpPort.."&dataUdpPort="..dataUdpPort
                            .."&rfidReportIntervalRlian="..rfidReportIntervalRlian.."&rfidBufferMaxCountRlian="..rfidBufferMaxCountRlian
                            .."&rfidEnableThrottleRlian="..rfidEnableThrottleRlian.."&rfidOfflineTimeoutRlian="..rfidOfflineTimeoutRlian
                            .."&g91State="..g91State.."&enableHeartbeat="..enableHeartbeat.."&heartbeatIp="..heartbeatIp.."&heartbeatTcpPort="..heartbeatTcpPort
                            .."&heartbeatInterval="..heartbeatInterval
        elseif rfidType == "dahua" then
            local ddzxIpDahua = nvm.get("ddzxIpDahua") or ""
            local ddzxTcpPortDahua = nvm.get("ddzxTcpPortDahua") or ""
            local rfidBufferMaxCountDahua = nvm.get("rfidBufferMaxCountDahua") or ""
            local rfidReportIntervalDahua = nvm.get("rfidReportIntervalDahua") or ""
            reqUrl = reqUrl.."&ddzxIpDahua="..ddzxIpDahua.."&ddzxTcpPortDahua="..ddzxTcpPortDahua.."&rfidBufferMaxCountDahua="..rfidBufferMaxCountDahua
            .."&rfidReportIntervalDahua="..rfidReportIntervalDahua
        else
            log.error("httpTask.http_heartbeat","invalid rfidType!! rfidType:", rfidType)
            return false
        end
    else
        reqUrl = httpDevopsUrl.."&deviceId="..devId.."&deviceSn="..devSn.."&coreVersion="..coreVersion.."&scriptVersion="..scriptVersion.."&bootNum="..bootNum
    end
    log.info("httpTask.http_heartbeat", "reqUrl:", reqUrl, "start httpTask, httpDevopsInterval:", httpDevopsInterval)
    isHttpRequesting = true
    http.request("GET",reqUrl,nil,nil,nil,nil,cbFnc)
end

--[[
--定时心跳任务
sys.timerLoopStart(function()
    http_heartbeat()
end, httpDevopsInterval *1000)
]]
--定时心跳任务
sys.taskInit(function()
    while true do
        if socket.isReady() then    --连上网再开始运行
            log.info("httpTask","send http heartbeat ...")
            http_heartbeat()       --等待一段时间发下次心跳
            log.info("httpTask","wait ", httpDevopsInterval, "s ...")
            sys.wait(httpDevopsInterval *1000)
        else    --没连上网别忘了延时！不然会陷入while true死循环，导致模块无法运行其他代码
            log.info("httpTask","socket have not ready,wait 1s ...")
            sys.wait(1000)          --等待1秒
        end
    end
    
end)

--920设备状态实时监测任务
sys.taskInit(function()
    while true do
        local g91OfflineTime = nvm.get("g91OfflineTime") or 600
        if sys.waitUntil("receive_920_device_info", g91OfflineTime*1000) then   
            log.info("httpTask.g91State","920 device online")
            g91State = 1
        else
            log.warn("httpTask.g91State","920 device offline!")
            g91State = 0
        end
    end
    
end)