代码拉取完成，页面将自动刷新
create = {}
libnet = require "libnet"
dtulib=require "dtulib"
local datalink, defChan = {}, 1
-- 定时采集任务的参数
local interval, samptime = {0, 0, 0}, {0, 0, 0}
-- 获取经纬度
local lat, lng = 0, 0
-- 无网络重启时间，飞行模式启动时间
local rstTim, flyTim = 300000, 300000
local output,input={},{}
function getDatalink(cid)
if tonumber(cid) then
return datalink[cid]
else
return datalink[defChan]
end
end
function setchannel(cid)
defChan = tonumber(cid) or 1
return cid
end
function getTimParam()
return interval, samptime
end
---------------------------------------------------------- DTU的网络任务部分 ----------------------------------------------------------
local function conver(str)
if str:match("function(.+)end") then return loadstring(str:match("function(.+)end"))() end
local hex = str:sub(1, 2):lower() == "0x"
str = hex and str:sub(3, -1) or str
local tmp = str:split("|")
for v = 1, #tmp do
if tmp[v]:lower() == "sn" then tmp[v] = hex and (mobile.sn():toHex()) or mobile.sn() end
if tmp[v]:lower() == "imei" then tmp[v] = hex and (mobile.imei():toHex()) or mobile.imei() end
if tmp[v]:lower() == "muid" then tmp[v] = hex and (mobile.muid():toHex()) or mobile.muid() end
if tmp[v]:lower() == "imsi" then tmp[v] = hex and (mobile.imsi():toHex()) or mobile.imsi() end
if tmp[v]:lower() == "iccid" then tmp[v] = hex and (mobile.iccid():toHex()) or mobile.iccid() end
if tmp[v]:lower() == "csq" then tmp[v] = hex and string.format("%02X", mobile.rssi()) or tostring(mobile.rssi()) end
end
return hex and (table.concat(tmp):fromHex()) or table.concat(tmp)
end
--登陆报文
local function loginMsg(str)
if tonumber(str) == 0 then
return nil
elseif tonumber(str) == 1 then
return json.encode({csq = mobile.rssi(), imei = mobile.imei(), iccid = mobile.iccid(), ver = _G.VERSION})
elseif tonumber(str) == 2 then
return tostring(mobile.rssi()):fromHex() .. (mobile.imei() .. "0"):fromHex() .. mobile.iccid():fromHex()
elseif type(str) == "string" and #str ~= 0 then
return conver(str)
else
return nil
end
end
function socketrecv(timeout,msg,msgNoResume,prot,socketOutput,socketInput)
-- local r,data,param=sys.waitUntil(msg,timeout)
local co=coroutine.running()
if msg then
subMessage=function (data)
if not msgNoResume then
if data then table.insert(socketOutput,data) end
end
coroutine.resume(co,0xAA)
end
sys.subscribe(msg,subMessage)
end
if msg and #socketOutput>0 then
sys.publish(msg,false)
end
if #socketInput==0 then
if timeout and timeout>0 then
local r,s=sys.wait(timeout)
if r==nil then
return "timeout"
elseif r==0xAA then
local dat=table.concat(socketOutput)
socketOutput={}
else
log.info("走到这里来了3")
return r, s
end
end
end
end
---------------------------------------------------------- SOKCET 服务 ----------------------------------------------------------
local function tcpTask(cid, pios, reg, convert, passon, upprot, dwprot, prot, ping, timeout, addr, port, uid, gap, report, intervalTime, ssl, login)
log.info("进入到tcp里面了")
cid, prot, timeout, uid = tonumber(cid) or 1, prot:upper(), tonumber(timeout) or 120, tonumber(uid) or 1
if not ping or ping == "" then ping = "0x00" end
if tonumber(intervalTime) then sys.timerLoopStart(sys.publish, tonumber(intervalTime) * 1000, "AUTO_SAMPL_" .. uid) end
local dwprotFnc = dwprot and dwprot[cid] and dwprot[cid] ~= "" and loadstring(dwprot[cid]:match("function(.+)end"))
local upprotFnc = upprot and upprot[cid] and upprot[cid] ~= "" and loadstring(upprot[cid]:match("function(.+)end"))
local tx_buff = zbuff.create(1024)
local rx_buff = zbuff.create(1024)
local idx = 0
dName="SOCKET"..cid
netc=socket.create(nil,dName)
while true do
if mobile.status()~=1 and not sys.waitUntil("IP_READY", rstTim) then
dtulib.restart("网络初始化失败！")
end
log.info("进到循环里面来了")
log.info("mem.lua", rtos.meminfo())
log.info("mem.sys", rtos.meminfo("sys"))
log.info("prot",prot)
log.info("ping",addr)
local isUdp=prot=="TCP"and false or true
local isSsl=ssl and true or false
log.info("DNAME",dName,isUdp,isSsl,addr,prot,ping,port)
socket.config(netc,nil,isUdp,isSsl)
result = libnet.waitLink(dName, 0, netc)
result=libnet.connect(dName,timeout,netc,addr,port)
if result then
log.info("登陆成功了")
-- 登陆报文
datalink[cid] = true
if login or loginMsg(reg) then socket.tx(netc,login or loginMsg(reg)) end
interval[uid], samptime[uid] = tonumber(gap) or 0, tonumber(report) or 0
local outputSocket={}
while true do
log.info(",passon",passon,",cid",cid,",UID",uid)
local subMessage=function (data)
if data then table.insert(outputSocket,data)
sys_send(dName,socket.EVENT,0)
end
end
sys.subscribe("NET_SENT_RDY_" .. (passon and cid or uid),subMessage)
local result, param = libnet.wait(dName, timeout * 1000, netc)
if param == false then
local result, param = libnet.tx(d1Name,nil, netc, conver(ping))
if not result then break end
end
if not result then
log.info("服务器断开了", result, param)
break
end
-- local result, data, param = c:recv(timeout * 1000, "NET_SENT_RDY_" .. (passon and cid or uid))
--local result, data, param = c:recv(timeout * 1000, "NET_SENT_RDY_2")
local is_err, param, _, _ = socket.rx(netc, rx_buff)
if is_err then
log.info("服务器断开了", is_err, param, ip, port)
break
end
if rx_buff:used() > 0 then
log.info("收到服务器数据，长度", rx_buff:used())
local data=rx_buff:toStr(0,#rx_buff)
if data:sub(1, 5) == "rrpc," or data:sub(1, 7) == "config," then
local res, msg = pcall(userapi, data, pios)
if not res then log.error("远程查询的API错误:", msg) end
if convert == 0 and upprotFnc then -- 转换为用户自定义报文
res, msg = pcall(upprotFnc, msg)
if not res then log.error("数据流模版错误:", msg) end
end
if not socket.tx(netc,msg) then break end
elseif convert == 1 then -- 转换HEX String
sys.publish("NET_RECV_WAIT_" .. uid, uid, (data:fromHex()))
elseif convert == 0 and dwprotFnc then -- 转换用户自定义报文
local res, msg = pcall(dwprotFnc, data)
if not res or not msg then
log.error("数据流模版错误:", msg)
else
sys.publish("NET_RECV_WAIT_" .. uid, uid, res and msg or data)
end
else -- 默认不转换
sys.publish("NET_RECV_WAIT_" .. uid, uid, data)
end
-- uart.tx(uart_id, rx_buff)
rx_buff:del()
end
tx_buff:copy(nil,table.concat(outputSocket))
if tx_buff:used() > 0 then
local data=tx_buff:toStr(0,#tx_buff)
if convert == 1 then -- 转换为Hex String 报文
local result, param = libnet.tx(d1Name,nil, netc, data:toHex())
if not result then
if passon then
sys.publish("UART_SENT_RDY_" .. uid, uid, "SEND_ERROR\r\n")
end
break
end
elseif convert == 0 and upprotFnc then -- 转换为用户自定义报文
local res, msg = pcall(upprotFnc, data)
if not res or not msg then
log.error("数据流模版错误:", msg)
else
local result, param = libnet.tx(d1Name,nil, netc, res and msg or data)
if not result then if passon then sys.publish("UART_SENT_RDY_" .. uid, uid, "SEND_ERROR\r\n") end break end
end
else -- 默认不转换
local result, param = libnet.tx(d1Name,nil, netc, data)
if not result then if passon then sys.publish("UART_SENT_RDY_" .. uid, uid, "SEND_ERROR\r\n") end break end
end
if passon then sys.publish("UART_SENT_RDY_" .. uid, uid, "SEND_OK\r\n") end
else
break
end
tx_buff:del()
if tx_buff:len() > 1024 then
tx_buff:resize(1024)
end
if rx_buff:len() > 1024 then
rx_buff:resize(1024)
end
log.info("RESULT",result,",DATA",data,",PARAM",param,",passon",passon,",cid",cid,",UID",uid)
end
else
log.info("登陆失败了")
end
libnet.close(d1Name, 5000, netc)
datalink[cid] = false
sys.wait((2 * idx) * 1000)
idx = (idx > 9) and 1 or (idx + 1)
end
end
---------------------------------------------------------- MQTT 服务 ----------------------------------------------------------
local function listTopic(str, addImei, ProductKey, deviceName)
local topics = str:split(";")
if #topics == 1 and (not addImei or addImei == "") then
topics[1] = topics[1]:sub(-1, -1) == "/" and topics[1] .. mobile.imei() or topics[1] .. "/" .. mobile.imei()
else
local tmp = {}
for i = 1, #topics, 2 do
tmp = topics[i]:split("/")
for v = 1, #tmp do
if tmp[v]:lower() == "imei" then tmp[v] = mobile.imei() end
if tmp[v]:lower() == "muid" then tmp[v] = mobile.muid() end
if tmp[v]:lower() == "imsi" then tmp[v] = mobile.imsi() end
if tmp[v]:lower() == "iccid" then tmp[v] = mobile.iccid() end
if tmp[v]:lower() == "productid" or tmp[v]:lower()=="{pid}" then tmp[v] = ProductKey end
if tmp[v]:lower() == "SN" then tmp[v] = hex and (mobile.sn():toHex()) or mobile.sn() end
if tmp[v]:lower() == "messageid" or tmp[v]:lower() == "${messageid}" then tmp[v] = "+" end
if tmp[v]:lower() == "productkey" or tmp[v]:lower() == "${productkey}" or tmp[v]:lower() == "${yourproductkey}" then tmp[v] = ProductKey end
if tmp[v]:lower() == "devicename" or tmp[v]:lower() == "${devicename}" or tmp[v]:lower() == "${yourdevicename}" or tmp[v]:lower()=="{device-name}"then tmp[v] = deviceName end
end
topics[i] = table.concat(tmp, "/")
log.info("订阅或发布主题:", i, topics[i])
end
end
return topics
end
local function mqttTask(cid, pios, reg, convert, passon, upprot, dwprot, keepAlive, timeout, addr, port, usr, pwd, cleansession, sub, pub, qos, retain, uid,clientID, addImei, ssl, will,idAddImei,prTopic,cert)
cid, keepAlive, timeout, uid = tonumber(cid) or 1, tonumber(keepAlive) or 300, tonumber(timeout), tonumber(uid)
cleansession, qos, retain = tonumber(cleansession) or 0, tonumber(qos) or 0, tonumber(retain) or 0
prTopic=prTopic and prTopic or ""
log.info("CLIENTID",clientID)
log.info("ADDIMEI",addImei)
log.info("ADDIMEI!",type(addImei))
log.info("IDADDIMEI",idAddImei)
if idAddImei=="1" then
log.info("为1，进到这里了")
clientID = (clientID == "" or not clientID) and mobile.imei() or clientID
log.info("CLIENTID2",clientID)
else
log.info("为空，进到这里了")
clientID =(clientID == "" or not clientID) and mobile.imei() or mobile.imei()..clientID
log.info("CLIENTID3",clientID)
end
log.info("SUB1",sub)
if timeout then sys.timerLoopStart(sys.publish, timeout * 1000, "AUTO_SAMPL_" .. uid) end
if type(sub) == "string" then
sub = listTopic(sub, addImei)
local topics = {}
for i = 1, #sub do
topics[sub[i]] = tonumber(sub[i + 1]) or qos
end
sub = topics
end
for key, value in pairs(sub) do
log.info("key",key,value)
end
if type(pub) == "string" then pub = listTopic(pub, addImei) end
local dwprotFnc = dwprot and dwprot[cid] and dwprot[cid] ~= "" and loadstring(dwprot[cid]:match("function(.+)end"))
local upprotFnc = upprot and upprot[cid] and upprot[cid] ~= "" and loadstring(upprot[cid]:match("function(.+)end"))
if not will or will == "" then will = nil else will = {qos = 1, retain = 0, topic = will, payload = mobile.imei()} end
log.info("MQTT HOST:PORT", addr, port)
log.info("MQTT clientID,user,pwd", clientID, conver(usr), conver(pwd))
local idx = 0
while true do
local messageId = false
if mobile.status()~=1 and not sys.waitUntil("IP_READY", rstTim) then
dtulib.restart("网络初始化失败!") end
log.info("CONVER1",conver(usr))
log.info("CONVER1",conver(pwd))
log.info("CLIENTID",clientID)
log.info("keepAlive",keepAlive)
log.info("CLEANSESSION",cleansession)
local mqttc=mqtt.create(nil,addr, port,ssl == "tcp_ssl" and true or false)
--是否为ssl加密连接,默认不加密,true为无证书最简单的加密，table为有证书的加密
mqttc:auth(clientID,conver(usr),conver(pwd))
mqttc:keepalive(keepAlive)
mqttc:connect()
-- local mqttc = mqtt.client(clientID, keepAlive, conver(usr), conver(pwd), cleansession, will, "3.1.1")
log.info("ADDR",addr)
log.info("PORT",port)
log.info("SSL",ssl)
mqttc:on(function(mqtt_client, event, data, payload) --mqtt回调注册
-- 用户自定义代码，按event处理
log.info("mqtt", "event", event, mqtt_client, data, payload)
if event =="conack" then
sys.publish("mqtt_conack")
elseif event == "recv" then -- 服务器下发的数据
log.info("mqtt", "downlink", "topic", data, "payload", payload)
sys.publish("NET_SENT_RDY_" .. (passon and cid or uid),"recv",data,payload)
-- 这里继续加自定义的业务处理逻辑
elseif event == "sent" then -- publish成功后的事件
log.info("mqtt", "sent", "pkgid", data)
end
end)
local conres=sys.waitUntil("mqtt_conack",30000)
if mqttc:ready() and conres then
log.info("mqtt连接成功")
datalink[cid] = true
-- 初始化订阅主题
log.info("sub1",sub[1])
log.info("pub1",pub[1])
log.info("qos1",qos)
-- sub="$thing/down/property/U0VQYMYVW6/a5"
-- qos=1
-- local topic1 = "/luatos/1"
-- local topic2 = "/luatos/2"
-- local topic3 = "/luatos/3"
--sub1={["/luatos/1234567"]=1,["/luatos/12345678"]=2}
if mqttc:subscribe(sub,qos)then
--local a=mqttc:subscribe(topic3,1)
log.info("A的",a)
log.info("mqtt订阅成功")
--mqttc:publish(pub, "hello,server", qos)
if loginMsg(reg) then mqttc:publish(pub[1], loginMsg(reg), tonumber(pub[2]) or qos, retain) end
-- if loginMsg(reg) then mqttc:publish(sub, "hello,server", 1) end
while true do
--local r, packet, param = mqttc:receive((timeout or 180) * 1000, "NET_SENT_RDY_" .. (passon and cid or uid))
local ret, topic, data, payload = sys.waitUntil("NET_SENT_RDY_" .. (passon and cid or uid), (timeout or 180)*1000)
log.info("RET",ret,topic,data,payload)
if ret and topic~="recv" then
if convert == 1 then -- 转换为Hex String 报文
if not mqttc:publish(pub[1], (topic:toHex()), tonumber(pub[2]) or qos, retain) then if passon then sys.publish("UART_SENT_RDY_" .. uid, uid, "SEND_ERROR\r\n") end break end
elseif convert == 0 and upprotFnc then -- 转换为用户自定义报文
local res, msg, index = pcall(upprotFnc, topic)
if not res or not msg then
log.error("数据流模版错误:", msg)
else
index = tonumber(index) or 1
local pub_topic = (pub[index]:sub(-1, -1) == "+" and messageId) and pub[index]:sub(1, -2) .. messageId or pub[index]
log.info("-----发布的主题:", pub_topic)
if not mqttc:publish(pub_topic, res and msg or topic, tonumber(pub[index + 1]) or qos, retain) then if passon then sys.publish("UART_SENT_RDY_" .. uid, uid, "SEND_ERROR\r\n") end break end
end
else
local pub_topic = (pub[1]:sub(-1, -1) == "+" and messageId) and pub[1]:sub(1, -2) .. messageId or pub[1]
log.info("-----发布的主题:", pub_topic)
if not mqttc:publish(pub_topic, topic, tonumber(pub[2]) or qos, retain) then if passon then sys.publish("UART_SENT_RDY_" .. uid, uid, "SEND_ERROR\r\n") end break end
end
messageId = false
if passon then sys.publish("UART_SENT_RDY_" .. uid, uid, "SEND_OK\r\n") end
log.info('The client actively reports status information.')
elseif ret and topic=="recv" then
log.info("接收到了一条消息")
messageId = data:match(".+/rrpc/request/(%d+)")
log.info("MESSAGE",messageId)
log.info("RET2",ret,topic,data,payload)
-- 这里执行用户自定义的指令
if payload:sub(1, 5) == "rrpc," or payload:sub(1, 7) == "config," then
log.info("进到这里了1")
local res, msg = pcall(userapi, payload, pios)
if not res then log.error("远程查询的API错误:", msg) end
if convert == 0 and upprotFnc then -- 转换为用户自定义报文
res, msg = pcall(upprotFnc, msg)
if not res then log.error("数据流模版错误:", msg) end
end
if not mqttc:publish(pub[1], msg, tonumber(pub[2]) or qos, retain) then
break
end
elseif convert == 1 then -- 转换为HEX String
log.info("进到这里了2")
sys.publish("UART_SENT_RDY_" .. uid, uid, (payload:fromHex()))
elseif convert == 0 and dwprotFnc then -- 转换用户自定义报文
log.info("进到这里了3")
local res, msg = pcall(dwprotFnc, payload, data)
if not res or not msg then
log.error("数据流模版错误:", msg)
else
if prTopic=="1" then
sys.publish("UART_SENT_RDY_" .. uid, uid, res and ("[+MSUB:"..data..","..#msg..","..msg.."]")or ("[+MSUB:"..data..","..#payload..","..payload.."]"))
else
sys.publish("UART_SENT_RDY_" .. uid, uid, res and msg or payload)
end
-- sys.publish("UART_SENT_RDY_" .. uid, uid, res and msg or payload)
end
else -- 默认不转换
log.info("prTopic",prTopic,"UART_SENT_RDY_" .. uid)
if prTopic=="1" then
log.info("prTopic1",prTopic,"UART_SENT_RDY_" .. uid)
sys.publish("UART_SENT_RDY_" .. uid, uid, ("[+MSUB:"..data..","..#payload..","..payload.."]"))
else
log.info("prTopic2",prTopic,"UART_SENT_RDY_" .. uid)
sys.publish("UART_SENT_RDY_" .. uid, uid, payload)
end
--sys.publish("UART_SENT_RDY_" .. uid, uid, payload)
end
else
log.warn('The MQTTServer connection is broken.')
break
end
-- elseif packet == 'timeout' then
-- -- sys.publish("AUTO_SAMPL_" .. uid)
-- log.debug('The client timeout actively reports status information.')
-- elseif packet == ("NET_SENT_RDY_" .. (passon and cid or uid)) then
-- end
end
else
log.info("订阅失败")
end
else
log.info("连接服务器失败")
end
datalink[cid] = false
mqttc:disconnect()
sys.wait((2 * idx) * 1000)
idx = (idx > 9) and 1 or (idx + 1)
end
end
---------------------------------------------------------- OneNet 云服务器 ----------------------------------------------------------
-- onenet新版 mqtt 协议支持
local function oneNet_mqtt(cid, pios, reg, convert, passon, upprot, dwprot, keepAlive, timeout, addr, port, productId, productSecret, deviceName,sub,pub,cleansession, qos, retain, uid)
cid, keepAlive, timeout, uid = tonumber(cid) or 1, tonumber(keepAlive) or 300, tonumber(timeout), tonumber(uid)
cleansession, qos, retain= tonumber(cleansession) or 0, tonumber(qos) or 0, tonumber(retain) or 0
if timeout then sys.timerLoopStart(sys.publish, timeout * 1000, "AUTO_SAMPL_" .. uid) end
local clinentId,username,password=iotauth.onenet(productId,productSecret,deviceName)
local dwprotFnc = dwprot and dwprot[cid] and dwprot[cid] ~= "" and loadstring(dwprot[cid]:match("function(.+)end"))
local upprotFnc = upprot and upprot[cid] and upprot[cid] ~= "" and loadstring(upprot[cid]:match("function(.+)end"))
local idx = 0
if type(sub) ~= "string" or sub == "" then
sub = "$sys/" .. productId .. "/" .. deviceName .. "/thing/property/post"
else
sub = listTopic(sub, "addImei", productId, deviceName)
local topics = {}
for i = 1, #sub do
topics[sub[i]] = tonumber(sub[i + 1]) or qos
end
sub = topics
end
if type(pub) ~= "string" or pub == "" then
pub = "$sys/" .. productId .. "/" .. deviceName .. "/thing/property/post/reply"
else
pub = listTopic(pub, "addImei", productId, deviceName)
end
mqttTask(cid, pios, reg, convert, passon, upprot, dwprot, keepAlive, timeout, addr, port, username, password, cleansession, sub, pub, qos, retain, uid,clinentId, addImei, ssl, will,"1")
end
---------------------------------------------------------- 阿里IOT云 ----------------------------------------------------------
local alikey = "/alikey.cnf"
-- 处理表的RFC3986编码
local function getOneSecret(RegionId, ProductKey, ProductSecret)
-- if io.exists(alikey) then
-- local dat, res, err = json.decode(io.readFile(alikey))
-- if res then
-- return dat.data.deviceName, dat.data.deviceSecret
-- end
-- end
local random = os.time()
local data = "deviceName" .. mobile.imei() .. "productKey" .. ProductKey .. "random" .. random
local sign = crypto.hmac_md5(data,ProductSecret)
local body = "productKey=" .. ProductKey .. "&deviceName=" .. mobile.imei() .. "&random=" .. random .. "&sign=" .. sign .. "&signMethod=HmacMD5"
for i = 1, 3 do
local code, head, body = http.request("POST", "https://iot-auth." .. RegionId .. ".aliyuncs.com/auth/register/device",nil,body)
if tonumber(code) == 200 and body then
local dat, result, errinfo = json.decode(body)
if result and dat.message and dat.data then
io.writeFile(alikey, body)
return dat.data.deviceName, dat.data.deviceSecret
end
else
if io.exists(alikey) then
local dat, res, err = json.decode(io.readFile(alikey))
if res then
return dat.data.deviceName, dat.data.deviceSecret
end
end
end
log.warn("阿里云查询请求失败:", code, body)
sys.wait(5000)
end
end
-- 一机一密方案，所有方案最终都会到这里执行
local function aliyunOmok(cid, pios, reg, convert, passon, upprot, dwprot, keepAlive, timeout, RegionId, ProductKey, deviceSecret, deviceName, ver, cleansession, qos, uid, sub, pub)
cid, keepAlive, timeout, uid = tonumber(cid) or 1, tonumber(keepAlive) or 300, tonumber(timeout), tonumber(uid)
cleansession, qos = tonumber(cleansession) or 0, tonumber(qos) or 0
local data = "clientId" .. mobile.iccid() .. "deviceName" .. deviceName .. "productKey" .. ProductKey
local usr = deviceName .. "&" .. ProductKey
local pwd = crypto.hmac_sha1(data, deviceSecret)
local clientID = mobile.iccid() .. "|securemode=3,signmethod=hmacsha1|"
local addr = ProductKey .. ".iot-as-mqtt." .. RegionId .. ".aliyuncs.com"
local port = 1883
if type(sub) ~= "string" or sub == "" then
sub = ver:lower() == "basic" and "/" .. ProductKey .. "/" .. deviceName .. "/get" or "/" .. ProductKey .. "/" .. deviceName .. "/user/get"
else
sub = listTopic(sub, "addImei", ProductKey, deviceName)
local topics = {}
for i = 1, #sub do
topics[sub[i]] = tonumber(sub[i + 1]) or qos
end
sub = topics
end
if type(pub) ~= "string" or pub == "" then
pub = ver:lower() == "basic" and "/" .. ProductKey .. "/" .. deviceName .. "/update" or "/" .. ProductKey .. "/" .. deviceName .. "/user/update"
else
pub = listTopic(pub, "addImei", ProductKey, deviceName)
end
local dwprotFnc = dwprot and dwprot[cid] and dwprot[cid] ~= "" and loadstring(dwprot[cid]:match("function(.+)end"))
local upprotFnc = upprot and upprot[cid] and upprot[cid] ~= "" and loadstring(upprot[cid]:match("function(.+)end"))
mqttTask(cid, pios, reg, convert, passon, upprot, dwprot, keepAlive, timeout, addr, port, usr, pwd, cleansession, sub, pub, qos, retain, uid,clientID, "addImei", ssl, will,"1")
end
-- 一型一密认证方案
local function aliyunOtok(cid, pios, reg, convert, passon, upprot, dwprot, keepAlive, timeout, RegionId, ProductKey, ProductSecret, ver, cleansession, qos, uid, sub, pub)
local deviceName, deviceSecret = getOneSecret(RegionId, ProductKey, ProductSecret)
if not deviceName or not deviceSecret then
log.error("阿里云注册失败:", ProductKey, ProductSecret)
return
end
log.warn("一型一密动态注册返回三元组:", deviceName ~= nil, deviceSecret ~= nil)
aliyunOmok(cid, pios, reg, convert, passon, upprot, dwprot, keepAlive, timeout, RegionId, ProductKey, deviceSecret, deviceName, ver, cleansession, qos, uid, sub, pub)
end
---------------------------------------------------------- 腾讯IOT云 ----------------------------------------------------------
function txiot(cid, pios, reg, convert, passon, upprot, dwprot, keepAlive, timeout, Region, ProductId, SecretId, SecretKey, sub, pub, cleansession, qos, uid)
if not io.exists("/qqiot.dat") then
local version = "2018-06-14"
local data = {ProductId = ProductId, DeviceName = mobile.imei()}
local timestamp = os.time()
local head = {
["X-TC-Action"] = "CreateDevice",
["X-TC-Timestamp"] = timestamp,
["X-TC-Version"] = "2018-06-14",
["X-TC-Region"] = (not Region or Region == "") and "ap-guangzhou" or Region,
["Content-Type"] = "application/json",
Authorization = "TC3-HMAC-SHA256 Credential=" .. SecretId .. "/"
}
local SignedHeaders = "content-type;host"
local CanonicalRequest = "POST\n/\n\ncontent-type:application/json\nhost:iotcloud.tencentcloudapi.com\n\n" .. SignedHeaders .. "\n" .. crypto.sha256(json.encode(data)):lower()
local c = os.date("!*t")
local date = string.format("%04d-%02d-%02d", c.year, c.month, c.day)
local CredentialScope = date .. "/iotcloud/tc3_request"
local StringToSign = "TC3-HMAC-SHA256\n" .. timestamp .. "\n" .. CredentialScope .. "\n" .. crypto.sha256(CanonicalRequest):lower()
local SecretDate = crypto.hmac_sha256(date, "TC3" .. SecretKey):fromHex()
local SecretService = crypto.hmac_sha256("iotcloud", SecretDate):fromHex()
local SecretSigning = crypto.hmac_sha256("tc3_request", SecretService):fromHex()
local Signature = crypto.hmac_sha256(StringToSign, SecretSigning):lower()
head.Authorization = head.Authorization .. CredentialScope .. ",SignedHeaders=" .. SignedHeaders .. ",Signature=" .. Signature
for i = 1, 3 do
local code, head, body = http.request("POST", "https://iotcloud.tencentcloudapi.com",head,data)
if body then
local dat, result, errinfo = json.decode(body)
if result then
if not dat.Response.Error then
io.writeFile("/qqiot.dat", body)
-- log.info("腾讯云注册设备成功:", body)
else
log.info("腾讯云注册设备失败:", body)
end
break
end
end
sys.wait(5000)
end
end
if not io.exists("/qqiot.dat") then
log.warn("腾讯云设备注册失败或不存在设备信息!")
return
end
if type(sub) ~= "string" or sub == "" then
sub = ProductId .. "/" .. mobile.imei() .. "/control"
else
sub = listTopic(sub, "addImei", ProductId, mobile.imei())
local topics = {}
for i = 1, #sub do
topics[sub[i]] = tonumber(sub[i + 1]) or qos
end
sub = topics
end
if type(pub) ~= "string" or pub == "" then
pub = ProductId .. "/" .. mobile.imei() .. "/event"
else
pub = listTopic(pub, "addImei", ProductId, mobile.imei())
end
local dat = json.decode(io.readFile("/qqiot.dat"))
local clientID = ProductId .. mobile.imei()
local connid = rtos.tick()
local expiry = tostring(os.time() + 3600)
local usr = string.format("%s;12010126;%s;%s", clientID, connid, expiry)
local raw_key = crypto.base64_decode(dat.Response.DevicePsk)
local pwd = crypto.hmac_sha256(usr, raw_key):lower() .. ";hmacsha256"
local addr, port = "iotcloud-mqtt.gz.tencentdevices.com", 1883
mqttTask(cid, pios, reg, convert, passon, upprot, dwprot, keepAlive, timeout, addr, port, usr, pwd, cleansession, sub, pub, qos, retain, uid,clientID, addImei, ssl, will,"1")
end
---------------------------------------------------------------------------------------------------------------------------------------------------
local function serBack(body,head)
-- body
log.info("testHttp.serBack",head,body)
local dat, result, errinfo = json.decode(body)
if result then
if dat.code==0 then
io.writeFile("/qqiot.dat", body)
log.info("腾讯云注册设备成功:", body)
else
log.info("腾讯云设备注册失败:", body)
end
enrol_end = true
end
end
function dev_txiotnew(cid, pios, reg, convert, passon, upprot, dwprot, keepAlive, timeout, Region, deviceName, ProductId, ProductSecret, sub, pub, cleansession, qos, uid)
enrol_end = false
if not io.exists("/qqiot.dat") then
local nonce=math.random(1,100)
--local version = "2018-06-14"
--local data = {ProductId = ProductId, DeviceName = misc.getImei()}
deviceName=deviceName~="" and deviceName or mobile.imei()
local timestamp = os.time()
local data = "deviceName="..deviceName.."&nonce="..nonce.."&productId="..ProductId.."×tamp="..timestamp
log.info("deviceNAME",deviceName)
local hmac_sha1_data = crypto.hmac_sha1(data,ProductSecret):lower()
local signature = crypto.base64_encode(hmac_sha1_data)
local tx_body = {
deviceName=deviceName,
nonce=nonce,
productId=ProductId,
timestamp=timestamp,
signature=signature,
}
local tx_body_json = json.encode(tx_body)
http.request("POST","https://ap-guangzhou.gateway.tencentdevices.com/register/dev",{["Content-Type"]="application/json; charset=UTF-8"},tx_body_json)
.cb(function(code, headers, body)
-- body
log.info("testHttp.serBack",head,body)
local dat, result, errinfo = json.decode(body)
if result then
if dat.code==0 then
io.writeFile("/qqiot.dat", body)
log.info("腾讯云注册设备成功:", body)
else
log.info("腾讯云设备注册失败:", body)
end
enrol_end = true
end
end)
--http.request("POST","https://ap-guangzhou.gateway.tencentdevices.com/register/dev",nil,{["Content-Type"]="application/json; charset=UTF-8"},tx_body_json,30000,serBack)
while not enrol_end do sys.wait(100) end
end
if not io.exists("/qqiot.dat") then
log.warn("腾讯云设备注册失败或不存在设备信息!")
return
end
local dat = json.decode(io.readFile("/qqiot.dat"))
local clientID = ProductId .. deviceName --生成 MQTT 的 clientid 部分, 格式为 ${productid}${devicename}
local connid = math.random(10000,99999)
local expiry = tostring(os.time() + 3600)
local usr = string.format("%s;12010126;%s;%s", clientID, connid, expiry) --生成 MQTT 的 username 部分, 格式为 ${clientid};${sdkappid};${connid};${expiry}
local payload = json.decode(crypto.aes_decrypt("CBC","ZERO",crypto.base64_decode(dat.payload),string.sub(ProductSecret,1,16),"0000000000000000"))
local pwd
log.info("CLIENTID",clientID)
log.info("user",usr)
if payload.encryptionType==2 then
local raw_key = crypto.base64_decode(payload.psk) --生成 MQTT 的 设备密钥 部分
pwd = crypto.hmac_sha256(usr, raw_key):lower() .. ";hmacsha256" --根据物联网通信平台规则生成 password 字段
log.info("PWD",pwd)
elseif payload.encryptionType==1 then
io.writeFile("/client.crt", payload.clientCert)
io.writeFile("/client.key", payload.clientKey)
ssl="tcp_ssl"
end
log.info("SECRETID",deviceName)
log.info("productid",ProductId)
log.info("SecretKey",ProductKey)
local addr, port = ProductId..".iotcloud.tencentdevices.com", 1883
log.info("ADDR",addr)
if type(sub) ~= "string" or sub == "" then
sub = ProductId .. "/" .. mobilie.imei() .. "/control"
else
sub = listTopic(sub, "addImei", ProductId, mobile.imei())
local topics = {}
for i = 1, #sub do
topics[sub[i]] = tonumber(sub[i + 1]) or qos
end
sub = topics
end
if type(pub) ~= "string" or pub == "" then
pub = ProductId .. "/" .. mobile.imei() .. "/event"
else
pub = listTopic(pub, "addImei", ProductId, mobile.imei())
end
log.info("sub",sub)
log.info("pub",pub)
log.info("qos",qos)
mqttTask(cid, pios, reg, convert, passon, upprot, dwprot, keepAlive, timeout, addr, port, usr, pwd, cleansession, sub, pub, qos, retain, uid,clientID, addImei, ssl, will,"1",cert)
log.info("腾讯云新版连接方式开启")
end
---------------------------------------------------------- 参数配置,任务转发，线程守护主进程----------------------------------------------------------
function connect(pios, conf, reg, convert, passon, upprot, dwprot,webProtect,protectContent)
local flyTag = false
if mobile.status()~=1 and not sys.waitUntil("IP_READY", rstTim) then
dtulib.restart("网络初始化失败!") end
sys.waitUntil("DTU_PARAM_READY", 120000)
if webProtect==nil or protectContent==nil then
webProtect="1"
log.info("这里赋值了")
end
-- 自动创建透传任务并填入参数
for k, v in pairs(conf or {}) do
-- log.info("Task parameter information:", k, pios, reg, convert, passon, upprot, dwprot, unpack(v))
if v[1] and (v[1]:upper() == "TCP" or v[1]:upper() == "UDP") then
log.warn("----------------------- TCP/UDP is start! --------------------------------------")
log.info("webProtect",webProtect,protectContent[1])
sys.taskInit(tcpTask, k, pios, reg, convert, passon, upprot, dwprot, unpack(v))
elseif v[1] and v[1]:upper() == "MQTT" then
log.warn("----------------------- MQTT is start! --------------------------------------")
log.info("VVVVVVV1",v[18])
log.info("UNPACK1", unpack(v))
log.info("UNPACK", unpack(v, 2))
log.info("KKKK", k)
log.info("PIOS", pios)
log.info("REG", reg)
log.info("convert", convert)
log.info("passon", passon)
log.info("upprot", upprot)
log.info("dwprot", dwprot)
sys.taskInit(mqttTask, k, pios, reg, convert, passon, upprot, dwprot, unpack(v, 2))
elseif v[1] and v[1]:upper() == "HTTP" then
log.warn("----------------------- HTTP is start! --------------------------------------")
sys.taskInit(function(cid, convert, passon, upprot, dwprot, uid, method, url, timeout, way, dtype, basic, headers, iscode, ishead, isbody)
cid, timeout, uid = tonumber(cid) or 1, tonumber(timeout) or 30, tonumber(uid) or 1
way, dtype = tonumber(way) or 1, tonumber(dtype) or 1
local dwprotFnc = dwprot and dwprot[cid] and dwprot[cid] ~= "" and loadstring(dwprot[cid]:match("function(.+)end"))
local upprotFnc = upprot and upprot[cid] and upprot[cid] ~= "" and loadstring(upprot[cid]:match("function(.+)end"))
while true do
datalink[cid] = socket.isReady()
local result, msg = sys.waitUntil("NET_SENT_RDY_" .. (passon and cid or uid))
if result and msg then
if convert == 1 then -- 转换为Hex String 报文
msg = msg:toHex()
elseif convert == 0 and upprotFnc then -- 转换为用户自定义报文
local res, dat = pcall(upprotFnc, msg)
if not res or not msg then log.error("数据流模版错误:", msg) end
msg = res and dat or msg
end
if passon then sys.publish("UART_SENT_RDY_" .. uid, uid, "SEND_OK\r\n") end
local code, head, body = dtulib.request(method:upper(), url,timeout*1000,way == 0 and msg or nil, way == 1 and msg or nil, dtype, basic, headers)
local headstr = ""
if type(head) == "table" then
for k, v in pairs(head) do headstr = headstr .. k .. ": " .. v .. "\r\n" end
else
headstr = head
end
if convert == 1 then -- 转换HEX String
local str = (tonumber(iscode) ~= 1 and code .. "\r\n" or "") .. (tonumber(ishead) ~= 1 and headstr or "") .. (tonumber(isbody) ~= 1 and body and (body:fromHex()) or "")
sys.publish("NET_RECV_WAIT_" .. uid, uid, str)
elseif convert == 0 and dwprotFnc then -- 转换用户自定义报文
local res, code, head, body = pcall(dwprotFnc, code, head, body)
if not res or not msg then
log.error("数据流模版错误:", msg)
else
local str = (tonumber(iscode) ~= 1 and code .. "\r\n" or "") .. (tonumber(ishead) ~= 1 and headstr or "") ~= 1 .. (tonumber(isbody) ~= 1 and body or "")
sys.publish("NET_RECV_WAIT_" .. uid, uid, res and str or code)
end
else -- 默认不转换
sys.publish("NET_RECV_WAIT_" .. uid, uid, (tonumber(iscode) ~= 1 and code .. "\r\n" or "") .. (tonumber(ishead) ~= 1 and headstr or "") .. (tonumber(isbody) ~= 1 and body or ""))
end
end
sys.wait(100)
end
datalink[cid] = false
end, k, convert, passon, upprot, dwprot, unpack(v, 2))
elseif v[1] and v[1]:upper() == "ONENET" then
log.warn("----------------------- OneNET is start! --------------------------------------")
sys.taskInit(oneNet_mqtt, k, pios, reg, convert, passon, upprot, dwprot, unpack(v, 3))
elseif v[1] and v[1]:upper() == "ALIYUN" then
log.warn("----------------------- Aliyun iot is start! --------------------------------------")
while not ntp.isEnd() do sys.wait(1000) end
if v[2]:upper() == "OTOK" then -- 一型一密
sys.taskInit(aliyunOtok, k, pios, reg, convert, passon, upprot, dwprot, unpack(v, 3))
elseif v[2]:upper() == "OMOK" then -- 一机一密
sys.taskInit(aliyunOmok, k, pios, reg, convert, passon, upprot, dwprot, unpack(v, 3))
end
elseif v[1] and v[1]:upper() == "TXIOT" then
log.warn("----------------------- tencent iot is start! --------------------------------------")
log.info("UNPACK1", unpack(v))
log.info("UNPACK", unpack(v, 2))
log.info("KKKK", k)
log.info("PIOS", pios)
log.info("REG", reg)
log.info("convert", convert)
log.info("passon", passon)
log.info("upprot", upprot)
log.info("dwprot", dwprot)
while not ntp.isEnd() do sys.wait(1000) end
sys.taskInit(txiot, k, pios, reg, convert, passon, upprot, dwprot, unpack(v, 2))
elseif v[1] and v[1]:upper() == "TXIOTNEW" then
log.warn("----------------------- tencent iot is start! --------------------------------------")
log.info("UNPACK1", unpack(v))
log.info("UNPACK", unpack(v, 2))
log.info("KKKK", k)
log.info("PIOS", pios)
log.info("REG", reg)
log.info("convert", convert)
log.info("passon", passon)
log.info("upprot", upprot)
log.info("dwprot", dwprot)
while not ntp.isEnd() do sys.wait(1000) end
sys.taskInit(dev_txiotnew, k, pios, reg, convert, passon, upprot, dwprot, unpack(v, 2))
end
end
-- 守护进程
log.info("webProtect",webProtect,protectContent[1])
log.info("守护线程")
--sys.timerStart(sys.restart, rstTim, "Server connection failed")
--sys.timerStart(sys.restart, 60000, "Server connection failed")
log.info("webProtect",webProtect,protectContent[1])
for i=1,#conf do
if webProtect=="1" then
if conf[i][1]~=nil then
log.info("守护全部线程",i)
sys.timerStart(dtulib.restart, rstTim, "Server connection failed"..i)
end
else
if protectContent[i]==1 and conf[tonumber(i)][1]~=nil then
sys.timerStart(dtulib.restart, rstTim, "Server connection failed"..i)
end
end
end
log.info("开启了")
while true do
--log.info("守护在循环")
log.info("webProtect",webProtect,protectContent)
-- 这里是网络正常,但是链接服务器失败重启
for i=1,#conf do
if webProtect=="1" then
if conf[i][1]~=nil and datalink[tonumber(i)] then
sys.timerStart(dtulib.restart, rstTim, "Server connection failed"..i)
end
else
if protectContent[i]==1 and conf[tonumber(i)][1]~=nil and datalink[tonumber(i)] then
sys.timerStart(dtulib.restart, rstTim, "Server connection failed"..i)
end
end
end
sys.wait(5000)
end
end
-- NTP同步失败强制重启
-- local tid = sys.timerStart(function()
-- net.switchFly(true)
-- sys.timerStart(net.switchFly, 5000, false)
-- end, flyTim)
sys.subscribe("IP_READY", function()
-- sys.timerStop(tid)
log.info("---------------------- 网络注册已成功 ----------------------")
end)
return {
getDatalink = getDatalink,
setchannel = setchannel,
getTimParam = getTimParam,
connect=connect
}
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。