G31_luatide_proj/longLinkSocketDahua.lua

module(...,package.seeall)

require"socket"
require"nvm"
require"utils"

--调度中心服务器信息
local ddzxIpDahua,ddzxTcpPortDahua = nvm.get("ddzxIpDahua"),nvm.get("ddzxTcpPortDahua")
local rfidBufferMaxCountDahua = nvm.get("rfidBufferMaxCountDahua") or 50
local rfidReportIntervalDahua = nvm.get("rfidReportIntervalDahua") or 60
local ddzxWaitRecvMsgMaxTime = 10
local qzjWaitRecvMsgMaxTime = 10

--读写器ID
local devId = nvm.get("devId") or "0000000000"
--读写器版本号
local devSn = nvm.get("devSn")

--ntp同步时间结果
local timerSyncResult = false

--长连接socket连接状态
local longLinkSocketConnState = false

--前置机服务器信息
local qzjIp,qzjTcpPort
local qzjFrameSn = 0x0000

--协议参数
--帧头
local prefix = 0xAAAA
--协议类型及协议版本
local protoVer = 0x10


--十六进制字符串反转
local function hexStrReverse(hexstr)
    local str = ""
    for i = 1, string.len(hexstr) - 1, 2 do  
        local tmpStr = string.sub(hexstr, -(i+1), -i)
        str = str .. tmpStr
    end 
    return str
end
--openMulByteReverse:开启多字节反转
local function hex2bin( hexstr, openMulByteReverse )
    --检查字符串长度
	if(hexstr:len()%2~=0) then
	    return false,"hex2str invalid input lenth"
	end
    if openMulByteReverse then
        hexstr = hexStrReverse(hexstr)
    end 
    local str = ""
    for i = 1, string.len(hexstr) - 1, 2 do  
    	local doublebytestr = string.sub(hexstr, i, i+1);  
    	local n = tonumber(doublebytestr, 16);  
    	if 0 == n then  
        	str = str .. '\00'
    	else  
        	str = str .. string.format("%c", n)
    	end
    end 
    return str
end

local function hex2str(str)
	--判断输入类型	
	if (type(str)~="string") then
	    return nil,"hex2str invalid input type"
	end
	--滤掉分隔符
	str=str:gsub("[%s%p]",""):upper()
	--检查内容是否合法
	if(str:find("[^0-9A-Fa-f]")~=nil) then
	    return nil,"hex2str invalid input content"
	end
	--检查字符串长度
	if(str:len()%2~=0) then
	    return nil,"hex2str invalid input lenth"
	end
	--拼接字符串
	local index=1
	local ret=""
	for index=1,str:len(),2 do
	    ret=ret..string.char(tonumber(str:sub(index,index+1),16))
	end
    --log.info("socketHeartbeatTask.hex2str", ret)
	return ret
end

local function getFormatTimeBin(time)
    local tClock = time and os.date("*t",time) or os.date("*t")
    local formatTimeBin = string.char(tonumber((""..tClock.year):sub(3,4)))
                            ..string.char(tClock.month)
                            ..string.char(tClock.day)
                            ..string.char(tClock.hour)
                            ..string.char(tClock.min)
                            ..string.char(tClock.sec)
    return formatTimeBin
end

local crc16Table = {
    0x0000, 0x1021, 0x2042, 0x3063, 0x4084, 0x50A5, 0x60C6, 0x70E7,
    0x8108, 0x9129, 0xA14A, 0xB16B, 0xC18C, 0xD1AD, 0xE1CE, 0xF1EF,
    0x1231, 0x0210, 0x3273, 0x2252, 0x52B5, 0x4294, 0x72F7, 0x62D6,
    0x9339, 0x8318, 0xB37B, 0xA35A, 0xD3BD, 0xC39C, 0xF3FF, 0xE3DE,
    0x2462, 0x3443, 0x0420, 0x1401, 0x64E6, 0x74C7, 0x44A4, 0x5485,
    0xA56A, 0xB54B, 0x8528, 0x9509, 0xE5EE, 0xF5CF, 0xC5AC, 0xD58D,
    0x3653, 0x2672, 0x1611, 0x0630, 0x76D7, 0x66F6, 0x5695, 0x46B4,
    0xB75B, 0xA77A, 0x9719, 0x8738, 0xF7DF, 0xE7FE, 0xD79D, 0xC7BC,
    0x48C4, 0x58E5, 0x6886, 0x78A7, 0x0840, 0x1861, 0x2802, 0x3823,
    0xC9CC, 0xD9ED, 0xE98E, 0xF9AF, 0x8948, 0x9969, 0xA90A, 0xB92B,
    0x5AF5, 0x4AD4, 0x7AB7, 0x6A96, 0x1A71, 0x0A50, 0x3A33, 0x2A12,
    0xDBFD, 0xCBDC, 0xFBBF, 0xEB9E, 0x9B79, 0x8B58, 0xBB3B, 0xAB1A,
    0x6CA6, 0x7C87, 0x4CE4, 0x5CC5, 0x2C22, 0x3C03, 0x0C60, 0x1C41,
    0xEDAE, 0xFD8F, 0xCDEC, 0xDDCD, 0xAD2A, 0xBD0B, 0x8D68, 0x9D49,
    0x7E97, 0x6EB6, 0x5ED5, 0x4EF4, 0x3E13, 0x2E32, 0x1E51, 0x0E70,
    0xFF9F, 0xEFBE, 0xDFDD, 0xCFFC, 0xBF1B, 0xAF3A, 0x9F59, 0x8F78,
    0x9188, 0x81A9, 0xB1CA, 0xA1EB, 0xD10C, 0xC12D, 0xF14E, 0xE16F,
    0x1080, 0x00A1, 0x30C2, 0x20E3, 0x5004, 0x4025, 0x7046, 0x6067,
    0x83B9, 0x9398, 0xA3FB, 0xB3DA, 0xC33D, 0xD31C, 0xE37F, 0xF35E,
    0x02B1, 0x1290, 0x22F3, 0x32D2, 0x4235, 0x5214, 0x6277, 0x7256,
    0xB5EA, 0xA5CB, 0x95A8, 0x8589, 0xF56E, 0xE54F, 0xD52C, 0xC50D,
    0x34E2, 0x24C3, 0x14A0, 0x0481, 0x7466, 0x6447, 0x5424, 0x4405,
    0xA7DB, 0xB7FA, 0x8799, 0x97B8, 0xE75F, 0xF77E, 0xC71D, 0xD73C,
    0x26D3, 0x36F2, 0x0691, 0x16B0, 0x6657, 0x7676, 0x4615, 0x5634,
    0xD94C, 0xC96D, 0xF90E, 0xE92F, 0x99C8, 0x89E9, 0xB98A, 0xA9AB,
    0x5844, 0x4865, 0x7806, 0x6827, 0x18C0, 0x08E1, 0x3882, 0x28A3,
    0xCB7D, 0xDB5C, 0xEB3F, 0xFB1E, 0x8BF9, 0x9BD8, 0xABBB, 0xBB9A,
    0x4A75, 0x5A54, 0x6A37, 0x7A16, 0x0AF1, 0x1AD0, 0x2AB3, 0x3A92,
    0xFD2E, 0xED0F, 0xDD6C, 0xCD4D, 0xBDAA, 0xAD8B, 0x9DE8, 0x8DC9,
    0x7C26, 0x6C07, 0x5C64, 0x4C45, 0x3CA2, 0x2C83, 0x1CE0, 0x0CC1,
    0xEF1F, 0xFF3E, 0xCF5D, 0xDF7C, 0xAF9B, 0xBFBA, 0x8FD9, 0x9FF8,
    0x6E17, 0x7E36, 0x4E55, 0x5E74, 0x2E93, 0x3EB2, 0x0ED1, 0x1EF0
}
    

--计算尾部校验码
local function getCrc16(packet) 
    if not packet then
        log.error("longLinkSocketDahua.getCrc16", "packet empty!!")
        return false
    end
    
    local CRC = 0XFFFF
    local tableNo = 1
    for i=1,#packet do
        tableNo = bit.band(bit.bxor( bit.rshift(CRC,8), string.byte(packet,i)), 0xFF)
		--log.info("longLinkSocketDahua.getCrc16",bit.lshift(CRC,8))
        CRC = bit.band(bit.bxor(bit.band(bit.lshift(CRC,8), 0xFFFF), crc16Table[tableNo+1]), 0xFFFF)
        --log.info("longLinkSocketDahua.getCrc16",tableNo,crc16Table[tableNo+1],CRC)
    end
    local crc16Bin = hex2bin(string.format("%04x",CRC))
    return true, crc16Bin
end


--生成报文
local function createPacket(frameSn,commandId,content) 
    if not prefix then
        log.error("longLinkSocketDahua.createPacket", "prefix empty!!")
        return false
    end
    if not protoVer then
        log.error("longLinkSocketDahua.createPacket", "protoVer empty!!")
        return false
    end
    if not devId then
        log.error("longLinkSocketDahua.createPacket", "devId empty!!")
        return false
    end
    if not frameSn then
        log.error("longLinkSocketDahua.createPacket", "frameSn empty!!")
        return false
    end
    if not commandId then
        log.error("longLinkSocketDahua.createPacket", "commandId empty!!")
        return false
    end
    if not content then
        content = ""
    end

    local packetBin = ""
    local length = #content + 10
    local prefixHexStr = string.format("%04x",prefix)
    local lengthHexStr = string.format("%04x",length)
    packetBin = hex2bin(prefixHexStr)..hex2bin(lengthHexStr)..string.char(protoVer)
                ..hex2bin(devId)..string.char(frameSn)
                ..string.char(commandId)..content
    
    local res, crc16Bin = getCrc16(packetBin:sub(3,-1))
    log.info("longLinkSocketDahua.createPacket", "packetBin hex:",packetBin:toHex(), "crc16Bin hex:",crc16Bin:toHex())
    if not res then
        log.error("longLinkSocketDahua.createPacket", "getCrc16 failed!!")
        return false
    end

    packetBin = packetBin..crc16Bin
    --log.info("longLinkSocketDahua.createPacket", "packetBin hex:",packetBin:toHex())

    return true, packetBin
end

--解析响应报文
local function parseRespPacket(packet)
    if not packet then
        log.error("longLinkSocketDahua.parseRespPacket", "packet empty!!")
        return false
    end
    if #packet < 14 then
        log.error("longLinkSocketDahua.parseRespPacket", "packet length < 14!! packet:", packet:toHex())
        return false
    end


    local prefixP = packet:sub(1,2):toHex()
    if tonumber(prefixP,16) ~= prefix then
        log.error("longLinkSocketDahua.parseRespPacket", "prefix invalid!! prefixP:", prefixP)
        return false
    end

    local length = tonumber(packet:sub(3,4):toHex(), 16)
    if #packet < length + 4 then
        log.error("longLinkSocketDahua.parseRespPacket", "packet length error!!", packet:toHex())
        return false
    end

    --crc校验
    local crc_packet = packet:sub(3,length + 2)
    local res, crc16Bin = getCrc16(crc_packet)
    if not res then
        log.error("longLinkSocketDahua.parseRespPacket", "getCrc16 failed!! crc_packet:",crc_packet:toHex())
        return false
    end

    local crc16P = packet:sub(length + 3,length + 4):toHex()
    local crc16 = crc16Bin:toHex()
    if crc16P ~= crc16 then
        log.error("longLinkSocketDahua.parseRespPacket", "crc verify failed!! crc16P:",crc16P,", crc16:",crc16)
        return false
    end
    -- AAAA 0012 10 FFC10001EC 00 52 0100202BDD0A2179 EBD7
    local contentLenP = length - 10
    local contentP = ""
    if contentLenP > 0 then
        contentP = packet:sub(13,contentLenP + 12)
    end
    if #contentP ~= contentLenP then
        log.error("longLinkSocketDahua.parseRespPacket", "contentLenP error!! contentLenP:",contentLenP,", contenLen:", #contentP)
        return false
    end

    local parseRes = {}
    local devIdP = packet:sub(6,10):toHex()
    local commandIdP = string.byte(packet,12)
    parseRes["devId"] = devIdP
    parseRes["commandId"] = commandIdP
    parseRes["frameSn"] = string.byte(packet,11)
    parseRes["length"] = length
    log.info("longLinkSocketDahua.parseRespPacket","commandIdP:",commandIdP,"contentLenP:",contentLenP)

    if commandIdP == 0x52 then --配置主控参数
        if contentLenP == 0 then
            log.error("longLinkSocketDahua.parseRespPacket", "contentLen invalid!!")
            return false
        end
        local contentTypeP = string.byte(contentP,1)
        parseRes["contentType"] = contentTypeP
        --bit7: 1--读, 0--写
        local cmdTypeP = bit.rshift(contentTypeP,7)
        parseRes["cmdType"] = cmdTypeP
        --bit6~0: 1--通讯服务器参数区, 0--统一调度服务器参数区
        local areaTypeP = bit.band(contentTypeP,0x7F)
        parseRes["areaType"] = areaTypeP

        --读取主控配置参数
        if cmdTypeP == 1 then
            return true, parseRes
        end

        local addrTypeP = string.byte(contentP,2)
        local qzjIpP = "" 
        local qzjPortP = tonumber(contentP:sub(3,4):toHex(),16) 
        if addrTypeP == 0x1 then
            qzjIpP = contentP:sub(5,-1)
        elseif addrTypeP == 0x0 then
            qzjIpP = string.byte(contentP,5).."."..string.byte(contentP,6)
                        .."."..string.byte(contentP,7).."."..string.byte(contentP,8)
        else
            log.error("longLinkSocketDahua.parseRespPacket", "addrTypeP invalid!! addrTypeP:", addrTypeP)
            return false
        end
        parseRes["qzjIp"] = qzjIpP
        parseRes["qzjPort"] = qzjPortP
        parseRes["addrType"] = addrTypeP
        qzjIp = qzjIpP
        qzjTcpPort = qzjPortP
        log.info("longLinkSocketDahua.parseRespPacket","parseRes qzjIpP:", qzjIpP, "qzjPortP:", qzjPortP)
        return true, parseRes
    elseif commandIdP == 0x01 then --校时包
        if contentLenP ~= 0x05 then
            log.error("longLinkSocketDahua.parseRespPacket", "contentLen invalid!!")
            return false
        end
        local cacheCtlP = string.byte(contentP,1)
        local serverTimeP = tonumber(contentP:sub(2,5):toHex(),16)
        parseRes["serverTime"] = serverTimeP
        return true, parseRes
    elseif commandIdP == 0x02 then --服务器确认包
        if contentLenP ~= 0x01 then
            log.error("longLinkSocketDahua.parseRespPacket", "contentLen invalid!!")
            return false
        end
        local cacheCtlP = string.byte(contentP,1)
        parseRes["cacheCtl"] = cacheCtlP
        return true, parseRes
    elseif commandIdP == 0x0A then --获取设备版本包
        return true, parseRes
    elseif commandIdP == 0x06 then --设备重启包
        return true, parseRes
    elseif commandIdP == 0x70 then --设备恢复出厂设置包
        return true, parseRes
    else
        log.error("longLinkSocketDahua.parseRespPacket","commandIdP invalid!!")
        return false
    end

end

--连接前置机主任务
sys.taskInit(
function()
    
    while true do
        log.info("longLinkSocketDahua.qzjTask","wait ON_MESSAGE_DDZX_AUTH_SUCCESS message ...")
        local res,data = sys.waitUntil("ON_MESSAGE_DDZX_AUTH_SUCCESS", 3600*1000)
        if res then
            log.info("longLinkSocketDahua.qzjTask","receive ON_MESSAGE_DDZX_AUTH_SUCCESS message")
            break
        else
            log.info("longLinkSocketDahua.qzjTask","wait ON_MESSAGE_DDZX_AUTH_SUCCESS timeout")
        end
    end

    local retryConnectCnt = 0   --失败次数统计
    while true do
        --是否获取到了分配的ip(是否连上网)
        if socket.isReady() then
            --新建一个socket对象，如果是udp只需要把tcp改成udp即可
            local socketClient = socket.tcp()
            log.info("longLinkSocketDahua.qzjTask","connect to qzjIp:", qzjIp, "qzjTcpPort:", qzjTcpPort)
            --尝试连接指定服务器
            if socketClient:connect(qzjIp,qzjTcpPort) then
                --连接成功
                log.info("longLinkSocketDahua.qzjTask","connect success")
                retryConnectCnt = 0 --失败次数清零
                longLinkSocketConnState = true

                --发送注册包
                local result,packet_data = createPacket(0,0x80,string.char(0x0)..devSn..string.char(0x0))
                if not result then
                    log.error("longLinkSocketDahua.qzjTask", "createPacket failed!!")
                else
                    if socketClient:send(packet_data, 10) then
                        log.info("longLinkSocketDahua.qzjTask","send regist success:", packet_data:toHex())
                        --等待服务端校时包(出厂前必须收到校时包才开启射频功能,出厂后可能收不到校时包)
                        local res,msg_data = socketClient:recv(qzjWaitRecvMsgMaxTime*1000)
                        if not res then
                            log.warn("longLinkSocketDahua.qzjTask","wait receive serverTime timeout!")
                        else
                            log.info("longLinkSocketDahua.qzjTask","receive serverTime msg:", msg_data:toHex())
                            local res, parseRes = parseRespPacket(msg_data)
                            if not res then
                                log.error("longLinkSocketDahua.qzjTask","parseRespPacket failed!!", msg_data:toHex())
                            else
                                if parseRes.serverTime > 0 then
                                    --需要ntp切换时区
                                    local diffTime = parseRes.serverTime - os.time()
                                    log.info("longLinkSocketDahua.qzjTask","serverTime:", parseRes.serverTime,"diffTime:", diffTime)
                                    if diffTime >= 1 or diffTime <= -1 then
                                        sys.publish("RESET_CLOCK_TIME", diffTime)
                                    end
                                end
                            end
                        end
                        --发送注册响应包
                        local result,packet_data = createPacket(0,0x82)
                        if not result then
                            log.error("longLinkSocketDahua.qzjTask", "createPacket failed!!")
                        else
                            if socketClient:send(packet_data, 10) then
                                log.info("longLinkSocketDahua.qzjTask","send regist resp success:", packet_data:toHex())
                                --通知发送标签数据任务开始工作
                                sys.publish("start_rfid_upload_task")
                                qzjFrameSn = 1
                                local r,s,p
                                while true do
                                    r, s, p = socketClient:recv(120000, "send_msg_to_server")
                                    if r then
                                        local res, parseRes = parseRespPacket(s)
                                        if not res then
                                            log.error("longLinkSocketDahua.qzjTask","parseRespPacket failed!!", s:toHex())
                                        else 
                                            log.info("longLinkSocketDahua.qzjTask","receive msg from server:", s:toHex(),", commandId:",parseRes.commandId,", frameSn:",parseRes.frameSn)
                                            if parseRes.commandId == 0xa then --响应查询版本信息
                                                local res, resp_data = createPacket(parseRes.frameSn,0x8a,devSn..string.char(0x0))
                                                if res then
                                                    log.info("longLinkSocketDahua.qzjTask","send device version info to server:", resp_data:toHex())
                                                    if not socketClient:send(resp_data) then 
                                                        log.error("longLinkSocketDahua.qzjTask","send device version info to server failed!!", resp_data:toHex())
                                                        break 
                                                    end
                                                else
                                                    log.error("longLinkSocketDahua.qzjTask","createPacket device version info failed!!")
                                                end
                                            elseif parseRes.commandId == 0x2 then
                                                sys.publish("recv_resp_msg_"..parseRes.frameSn)
                                            end
                                        end
                                    elseif s == "send_msg_to_server" then
                                        log.info("longLinkSocketDahua.qzjTask","send msg to server(30):", p:sub(1, 30):toHex())
                                        if not socketClient:send(p) then 
                                            log.error("longLinkSocketDahua.qzjTask","send msg to server failed!! data:", p:toHex())
                                            break 
                                        end
                                    elseif s == "timeout" then
                                        qzjFrameSn = (qzjFrameSn + 1 < 255) and (qzjFrameSn + 1) or 1
                                        local res, qzjHeartbeatPacket = createPacket(qzjFrameSn,0x83,string.char(0x0))
                                        if res then
                                            log.info("longLinkSocketDahua.qzjTask","send heartbeat to server:", qzjHeartbeatPacket:toHex())
                                            if not socketClient:send(qzjHeartbeatPacket) then 
                                                log.error("longLinkSocketDahua.qzjTask","send heartbeat to server failed!!", qzjHeartbeatPacket:toHex())
                                                break 
                                            end
                                        else
                                            log.error("longLinkSocketDahua.qzjTask","createPacket qzjHeartbeatPacket failed!!")
                                        end
                                        
                                    else
                                        log.error("longLinkSocketDahua.qzjTask","socket connect error!!")
                                        break
                                    end
                                end
                            else
                                log.error("longLinkSocketDahua.qzjTask","send regist resp timeout!")
                            end
                        end
                    else
                        log.error("longLinkSocketDahua.qzjTask","send regist timeout!")
                    end
                end
               
            else
                log.error("longLinkSocketDahua.qzjTask","connect fail")
                --连接失败
                retryConnectCnt = retryConnectCnt+1 --失败次数加一
            end
            socketClient:close()    --断开socket连接
            if retryConnectCnt>=5 then  --失败次数大于五次了
                link.shut()         --强制断开TCP/UDP连接
                retryConnectCnt=0   --失败次数清零
                longLinkSocketConnState = false
            else
                sys.wait(5000)
            end
            
        else
            retryConnectCnt = 0     --没连上网，失败次数清零
            longLinkSocketConnState = false
            --没连上网
            --等待网络环境准备就绪，超时时间是5分钟
            sys.waitUntil("IP_READY_IND",300000)
            --等完了还没连上？
            if not socket.isReady() then
                --进入飞行模式，20秒之后，退出飞行模式
                net.switchFly(true)
                sys.wait(20000)
                net.switchFly(false)
            end
        end
    end
end)


--等待时间同步成功消息通知
sys.subscribe("TIMER_SYNC_SUCCESS", function ( ... )
    log.info("longLinkSocketDahua.subscribe","TIMER_SYNC_SUCCESS")
    timerSyncResult = true
end)


--连接调度中心(获取前置机连接信息)
sys.taskInit(
function()
    
    while not timerSyncResult do
        log.info("longLinkSocketDahua.ddzxSocketClient","wait TIMER_SYNC_SUCCESS message ...")
        sys.wait(1000) 
    end

    while not devId do 
        log.info("longLinkSocketDahua.ddzxSocketClient","devId empty! time:", os.time())
        devId = nvm.get("devId")
        sys.wait(1000) 
    end

    while not ddzxIpDahua do 
        log.info("longLinkSocketDahua.ddzxSocketClient","ddzxIpDahua empty! time:", os.time())
        ddzxIpDahua = nvm.get("ddzxIpDahua")
        sys.wait(1000) 
    end

    while not ddzxTcpPortDahua do 
        log.info("longLinkSocketDahua.ddzxSocketClient","ddzxTcpPortDahua empty! time:", os.time())
        ddzxTcpPortDahua = nvm.get("ddzxTcpPortDahua")
        sys.wait(1000) 
    end

    if not ddzxWaitRecvMsgMaxTime then 
        ddzxWaitRecvMsgMaxTime = 10
    end
    sys.wait(10000)
    local retryConnectCnt = 0   --失败次数统计
    while true do
        --是否获取到了分配的ip(是否连上网)
        if socket.isReady() then
            --新建一个socket对象，如果是udp只需要把tcp改成udp即可
            local ddzxSocketClient = socket.tcp()
            --尝试连接指定服务器
            if ddzxSocketClient:connect(ddzxIpDahua,ddzxTcpPortDahua) then
                local result,packet_data = createPacket(0,0x88)
                if not result then
                    log.error("longLinkSocketDahua.ddzxSocketClient", "createDdzxAuthPacket failed!!")
                else
                    --连接成功
                    log.info("longLinkSocketDahua.ddzxSocketClient", "ddzxIpDahua", ddzxIpDahua, "ddzxTcpPortDahua", ddzxTcpPortDahua, "packet_data", packet_data:toHex())
                    if ddzxSocketClient:send(packet_data, 10) then
                        retryConnectCnt = 0
                        log.info("longLinkSocketDahua.ddzxSocketClient", "wait recv server message ... time:", os.time())
                        local res,ddzx_data = ddzxSocketClient:recv(ddzxWaitRecvMsgMaxTime*1000)
                        if not res then
                            log.error("longLinkSocketDahua.ddzxSocketClient", "ddzxSocketClient:recv(10000) wait timeout, time:", os.time())
                        else
                            --TODO：处理收到的数据data
                            log.info("longLinkSocketDahua.ddzxSocketClient", "receive server message, time: ", os.time(), ", message:", ddzx_data:toHex())

                            --解析数据并响应结果
                            local res,parseData = parseRespPacket(ddzx_data)
                            if not res then 
                                log.error("longLinkSocketDahua.ddzxSocketClient","parseRespPacket failed!!")
                            else
                                --回复响应包
                                local result,packet_data = createPacket(0,0xD2,hex2bin("0000"))
                                if not result then
                                    log.error("longLinkSocketDahua.ddzxSocketClient", "createPacket failed!!")
                                else
                                    if ddzxSocketClient:send(packet_data, 10) then
                                        log.info("longLinkSocketDahua.ddzxSocketClient","publish ON_MESSAGE_DDZX_AUTH_SUCCESS，task finish,wait ON_MESSAGE_DO_DDZX_TASK ...")
                                        sys.publish("ON_MESSAGE_DDZX_AUTH_SUCCESS")
                                        ddzxSocketClient:close()    --断开socket连接
                                        --进入阻塞状态，等待下一次连接调度中心的任务
                                        while true do
                                            local result,msg = sys.waitUntil("ON_MESSAGE_DO_DDZX_TASK", 3600*1000)
                                            if result then
                                                log.info("longLinkSocketDahua.ddzxSocketClient","receive ON_MESSAGE_DO_DDZX_TASK message, msg:", msg)
                                                break
                                            else
                                                log.info("longLinkSocketDahua.ddzxSocketClient","wait ON_MESSAGE_DO_DDZX_TASK timeout")
                                            end
                                        end
                                    else
                                        log.error("longLinkSocketDahua.ddzxSocketClient",">>>>>>> socket.send resp timeout!")
                                    end
                                end
                            end
                        end
                    else
                        retryConnectCnt = retryConnectCnt+1
                        log.error("longLinkSocketDahua.ddzxSocketClient",">>>>>>> socket.send failed")
                        --sys.wait(5000)
                    end
                end

            else
                log.error("longLinkSocketDahua.ddzxSocketClient","connect fail")
                --连接失败
                retryConnectCnt = retryConnectCnt+1 --失败次数加一
            end
            ddzxSocketClient:close()    --断开socket连接
            if retryConnectCnt>=5 then  --失败次数大于五次了
                link.shut()         --强制断开TCP/UDP连接
                retryConnectCnt=0   --失败次数清零
            end
            sys.wait(5000)
        else
            retryConnectCnt = 0     --没连上网，失败次数清零
            --没连上网
            --等待网络环境准备就绪，超时时间是5分钟
            sys.waitUntil("IP_READY_IND",300000)
            --等完了还没连上？
            if not socket.isReady() then
                --进入飞行模式，20秒之后，退出飞行模式
                net.switchFly(true)
                sys.wait(20000)
                net.switchFly(false)
            end
        end
    end
end)


-- 监听并上报rfid数据任务
sys.taskInit(function()
    
    --等心跳开启时，再开始上报rfid数据
    while true do
        log.info("longLinkSocketDahua.upload_dahua_rfid_info","wait start_rfid_upload_task message ...")
        local res,data = sys.waitUntil("start_rfid_upload_task", 3600*1000)
        if res then
            log.info("longLinkSocketDahua.upload_dahua_rfid_info","receive start_rfid_upload_task message")
            break
        else
            log.info("longLinkSocketDahua.upload_dahua_rfid_info","wait start_rfid_upload_task timeout")
        end
    end
    while not rfidReportIntervalDahua do 
        log.info("longLinkSocketDahua.upload_dahua_rfid_info","rfidReportIntervalDahua empty! time:", os.time())
        rfidReportIntervalDahua = nvm.get("rfidReportIntervalDahua")
        sys.wait(1000) 
    end
    --起始流水号
    local packetSn = 0
    --标签个数
    local rfidBufferCount = 0
    --数据包
    local content = ""
    while true do 
        --阻塞监听监听rfid接收数据
        local cur_time = os.time()
        local result, rfid = sys.waitUntil("pub_packet_data_dahua_rfid_info",rfidReportIntervalDahua*1000)
        if result then
            --log.info("longLinkSocketDahua.upload_dahua_rfid_info",">>>>>>>>> recv pub_packet_data_dahua_rfid_info, wait msg time(s):", os.time()-cur_time, json.encode(rfid))
            
            if type(rfid) == "table" then
                if not rfid.time then
                    log.error("longLinkSocketDahua.upload_dahua_rfid_info",">>>>>>>>> rfid.time empty! ")
                elseif not rfid.id then
                    log.error("longLinkSocketDahua.upload_dahua_rfid_info",">>>>>>>>> rfid.id empty! ")
                else
                    rfidBufferCount = (rfidBufferCount + 1 < rfidBufferMaxCountDahua) and (rfidBufferCount + 1) or 1
                    --分类信息内容
                    local categoryContent = string.char(0xe)..hex2bin(string.format("%08x",rfid.time))..string.char(0x0)
                                    ..hex2bin(rfid.id)..string.char(rfid.type)..string.char(rfid.status)
                                    ..string.char(rfid.sn)..string.char(rfid.location)
                    
                    log.info("longLinkSocketDahua.upload_dahua_rfid_info","rfid.id:",rfid.id,",rfid.time:",rfid.time,",rfidBufferCount:",rfidBufferCount)
                    --标签个数达到最大值时,组装数据包并上报
                    if rfidBufferCount >= rfidBufferMaxCountDahua then
                        packetSn = (packetSn + 1 < 0xffffff) and (packetSn + 1) or 0
                        content = string.char(rfidBufferCount)..hex2bin(string.format("%06x",packetSn))..categoryContent
                        qzjFrameSn = (qzjFrameSn + 1 < 255) and (qzjFrameSn + 1) or 1
                        local res,packetData = createPacket(qzjFrameSn,0x84,content)
                        if not res then
                            log.error("longLinkSocketDahua.upload_dahua_rfid_info", "createPacket failed!!")
                        else
                            sys.publish("send_msg_to_server", packetData)
                            local frameSn = qzjFrameSn
                            --等待服务端响应消息
                            if not sys.waitUntil("recv_resp_msg_"..frameSn, 5000) then
                                log.error("longLinkSocketDahua.upload_dahua_rfid_info", "wait recv_resp_msg_"..frameSn.." timeout!!")
                            else
                                log.info("longLinkSocketDahua.upload_dahua_rfid_info", "recv recv_resp_msg_"..frameSn)
                            end
                        end
                        --初始化
                        content = ""
                        rfidBufferCount = 0
                    else
                        content = content..categoryContent
                    end
                end 
                
            else
                log.info("longLinkSocketDahua.upload_dahua_rfid_info",">>>>>>>>> rfid error! key = ", key)
            end
            
        else
            --等待超时,就发送已接收的标签数据
            if rfidBufferCount > 0 and #content > 0 then
                packetSn = (packetSn + 1 < 0xffffff) and (packetSn + 1) or 0
                content = string.char(rfidBufferCount)..hex2bin(string.format("%06x",packetSn))..content
                qzjFrameSn = (qzjFrameSn + 1 < 255) and (qzjFrameSn + 1) or 1
                local res,packetData = createPacket(qzjFrameSn,0x84,content)
                if not res then
                    log.error("longLinkSocketDahua.upload_dahua_rfid_info", "createPacket failed!!")
                else
                    log.info("longLinkSocketDahua.upload_dahua_rfid_info","upload rfid data(30):",packetData:sub(1,30):toHex(),", qzjFrameSn:",qzjFrameSn)
                    sys.publish("send_msg_to_server", packetData)
                    local frameSn = qzjFrameSn
                    --等待服务端响应消息
                    if not sys.waitUntil("recv_resp_msg_"..frameSn, 5000) then
                        log.error("longLinkSocketDahua.upload_dahua_rfid_info", "wait recv_resp_msg_"..frameSn.." timeout!!")
                    else
                        log.info("longLinkSocketDahua.upload_dahua_rfid_info", "recv recv_resp_msg_"..frameSn)
                    end
                end
                --初始化
                content = ""
                rfidBufferCount = 0
            else
                log.info("longLinkSocketDahua.upload_dahua_rfid_info",">>>>>>>>> wait upload_dahua_rfid_info timeout")
            end
        end
    end
end)