From 8e09b93ad89367a9c2b19116c302b5f5a3f0cff8 Mon Sep 17 00:00:00 2001 From: Mizore Date: Tue, 31 Jan 2023 17:52:15 +0800 Subject: [PATCH] =?UTF-8?q?:sparkles:=20=E6=9B=B4=E6=8D=A2=E5=9F=BA?= =?UTF-8?q?=E7=AB=99=E5=AE=9A=E4=BD=8D=E6=96=B9=E5=BC=8F,=20=E5=88=A0?= =?UTF-8?q?=E9=99=A4=E5=BC=80=E6=9C=BA=E5=85=88=E5=9F=BA=E7=AB=99=E5=AE=9A?= =?UTF-8?q?=E4=BD=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- script/lbsLoc.lua | 356 --------------------------------------- script/main.lua | 17 +- script/util_location.lua | 198 ++++++++++++++++++---- 3 files changed, 166 insertions(+), 405 deletions(-) delete mode 100644 script/lbsLoc.lua diff --git a/script/lbsLoc.lua b/script/lbsLoc.lua deleted file mode 100644 index b422f2e..0000000 --- a/script/lbsLoc.lua +++ /dev/null @@ -1,356 +0,0 @@ ---[[ -@module lbsLoc -@summary lbsLoc 发送基站定位请求 -@version 1.0 -@date 2022.12.16 -@author luatos -@usage ---注意:因使用了sys.wait()所有api需要在协程中使用 ---用法实例 -PRODUCT_KEY = "VmhtOb81EgZau6YyuuZJzwF6oUNGCbXi" -local lbsLoc = require("lbsLoc") -local function reqLbsLoc() - lbsLoc.request(getLocCb) -end --- 功能:获取基站对应的经纬度后的回调函数 --- 参数:-- result：number类型，0表示成功，1表示网络环境尚未就绪，2表示连接服务器失败，3表示发送数据失败，4表示接收服务器应答超时，5表示服务器返回查询失败；为0时，后面的5个参数才有意义 - -- lat：string类型，纬度，整数部分3位，小数部分7位，例如031.2425864 - -- lng：string类型，经度，整数部分3位，小数部分7位，例如121.4736522 - -- addr：目前无意义 - -- time：string类型或者nil，服务器返回的时间，6个字节，年月日时分秒，需要转为十六进制读取 - -- 第一个字节：年减去2000，例如2017年，则为0x11 - -- 第二个字节：月，例如7月则为0x07，12月则为0x0C - -- 第三个字节：日，例如11日则为0x0B - -- 第四个字节：时，例如18时则为0x12 - -- 第五个字节：分，例如59分则为0x3B - -- 第六个字节：秒，例如48秒则为0x30 - -- locType：numble类型或者nil，定位类型，0表示基站定位成功，255表示WIFI定位成功 -function getLocCb(result, lat, lng, addr, time, locType) - log.info("testLbsLoc.getLocCb", result, lat, lng) - -- 获取经纬度成功 - if result == 0 then - log.info("服务器返回的时间", time:toHex()) - log.info("定位类型,基站定位成功返回0", locType) - end - sys.timerStart(lbsLoc,20000) -end -reqLbsLoc() -]] - -local lbsLoc = {} -local d1Name = "D1_TASKL" ---- 阻塞等待网卡的网络连接上，只能用于任务函数中 --- @string 任务标志 --- @int 超时时间，如果==0或者空，则没有超时一致等待 --- @... 其他参数和socket.linkup一致 --- @return 失败或者超时返回false 成功返回true -local function waitLink(taskName, timeout, ...) - local is_err, result = socket.linkup(...) - if is_err then - return false - end - if not result then - result = sys_wait(taskName, socket.LINK, timeout) - else - return true - end - if type(result) == 'table' and result[2] == 0 then - return true - else - return false - end -end - ---- 阻塞等待IP或者域名连接上，如果加密连接还要等握手完成，只能用于任务函数中 --- @string 任务标志 --- @int 超时时间，如果==0或者空，则没有超时一致等待 --- @... 其他参数和socket.connect一致 --- @return 失败或者超时返回false 成功返回true -local function connect(taskName,timeout, ... ) - local is_err, result = socket.connect(...) - if is_err then - return false - end - if not result then - result = sys_wait(taskName, socket.ON_LINE, timeout) - else - return true - end - if type(result) == 'table' and result[2] == 0 then - return true - else - return false - end -end - ---- 阻塞等待数据发送完成，只能用于任务函数中 --- @string 任务标志 --- @int 超时时间，如果==0或者空，则没有超时一致等待 --- @... 其他参数和socket.tx一致 --- @return --- @boolean 失败或者超时返回false，缓冲区满了或者成功返回true --- @boolean 缓存区是否满了 -local function tx(taskName,timeout, ...) - local is_err, is_full, result = socket.tx(...) - if is_err then - return false, is_full - end - if is_full then - return true, true - end - if not result then - result = sys_wait(taskName, socket.TX_OK, timeout) - else - return true, is_full - end - if type(result) == 'table' and result[2] == 0 then - return true, false - else - return false, is_full - end -end - ---- 阻塞等待新的网络事件或者特定事件，只能用于任务函数中 --- @string 任务标志 --- @int 超时时间，如果==0或者空，则没有超时一致等待 --- @... 其他参数和socket.wait一致 --- @return --- @boolean 网络异常返回false，其他返回true --- @table or boolean 超时返回false，有新的数据到返回true，被其他事件退出的，返回接收到的事件 -local function wait(taskName,timeout, netc) - local is_err, result = socket.wait(netc) - if is_err then - return false,false - end - if not result then - result = sys_wait(taskName, socket.EVENT, timeout) - else - return true,true - end - if type(result) == 'table' then - if result[2] == 0 then - return true, true - else - return false, false - end - else - return true, false - end -end - ---- ASCII字符串 转化为 BCD编码格式字符串(仅支持数字) --- @string inStr 待转换字符串 --- @number destLen 转换后的字符串期望长度，如果实际不足，则填充F --- @return string data,转换后的字符串 --- @usage -local function numToBcdNum(inStr,destLen) - local l,t,num = string.len(inStr or ""),{} - - destLen = destLen or (inStr:len()+1)/2 - - for i=1,l,2 do - num = tonumber(inStr:sub(i,i+1),16) - - if i==l then - num = 0xf0+num - else - num = (num%0x10)*0x10 + (num-(num%0x10))/0x10 - end - - table.insert(t,num) - end - - local s = string.char(unpack(t)) - - l = string.len(s) - if l < destLen then - s = s .. string.rep("\255",destLen-l) - elseif l > destLen then - s = string.sub(s,1,destLen) - end - - return s -end - ---- BCD编码格式字符串 转化为 号码ASCII字符串(仅支持数字) --- @string num 待转换字符串 --- @return string data,转换后的字符串 --- @usage -local function bcdNumToNum(num) - local byte,v1,v2 - local t = {} - - for i=1,num:len() do - byte = num:byte(i) - v1,v2 = bit.band(byte,0x0f),bit.band(bit.rshift(byte,4),0x0f) - - if v1 == 0x0f then break end - table.insert(t,v1) - - if v2 == 0x0f then break end - table.insert(t,v2) - end - - return table.concat(t) -end - - -local function netCB(msg) - log.info("未处理消息", msg[1], msg[2], msg[3], msg[4]) -end - - -local function enCellInfo(s) - local ret,t,mcc,mnc,lac,ci,rssi,k,v,m,n,cntrssi = "",{} - for k,v in pairs(s) do - mcc,mnc,lac,ci,rssi = v.mcc,v.mnc,v.tac,v.cid,((v.rsrq + 144) >31) and 31 or (v.rsrq + 144) - local handle = nil - for k,v in pairs(t) do - if v.lac == lac and v.mcc == mcc and v.mnc == mnc then - if #v.rssici < 8 then - table.insert(v.rssici,{rssi=rssi,ci=ci}) - end - handle = true - break - end - end - if not handle then - table.insert(t,{mcc=mcc,mnc=mnc,lac=lac,rssici={{rssi=rssi,ci=ci}}}) - end - log.info("rssi、mcc、mnc、lac、ci", rssi,mcc,mnc,lac,ci) - end - for k,v in pairs(t) do - ret = ret .. pack.pack(">HHb",v.lac,v.mcc,v.mnc) - for m,n in pairs(v.rssici) do - cntrssi = bit.bor(bit.lshift(((m == 1) and (#v.rssici-1) or 0),5),n.rssi) - ret = ret .. pack.pack(">bi",cntrssi,n.ci) - end - end - return string.char(#t)..ret -end - -local function enWifiInfo(tWifi) - local ret,cnt,k,v = "",0 - if tWifi then - for k,v in pairs(tWifi) do - log.info("lbsLoc.enWifiInfo",k,v) - ret = ret..pack.pack("Ab",(k:gsub(":","")):fromHex(),(v<0) and (v+255) or v) - cnt = cnt+1 - end - end - return string.char(cnt)..ret -end - -local function enMuid() --获取模块MUID - local muid = mobile.muid() - return string.char(muid:len())..muid -end - -local function trans(str) - local s = str - if str:len()<10 then - s = str..string.rep("0",10-str:len()) - end - - return s:sub(1,3).."."..s:sub(4,10) -end - - -local function taskClient(cbFnc, reqAddr, timeout, productKey, host, port,reqTime, reqWifi) - while mobile.status() == 0 do - if not sys.waitUntil("IP_READY", timeout) then return cbFnc(1) end - end - local retryCnt = 0 - local reqStr = pack.pack("bAbAAAAA", productKey:len(), productKey, - (reqAddr and 2 or 0) + (reqTime and 4 or 0) + 8 +(reqWifi and 16 or 0) + 32, "", - numToBcdNum(mobile.imei()), enMuid(), - enCellInfo(mobile.getCellInfo()), - enWifiInfo(reqWifi)) - log.info("reqStr", reqStr:toHex()) - local rx_buff = zbuff.create(17) - -- sys.wait(5000) - while true do - netc = socket.create(nil, d1Name) -- 创建socket对象 - if not netc then cbFnc(6) return end -- 创建socket失败 - socket.debug(netc, false) - socket.config(netc, nil, true, nil) - waitLink(d1Name, 0, netc) - local result = connect(d1Name, 15000, netc, host, port) - if result then - while true do - log.info(" lbsloc socket_service connect true") - local result, _ = tx(d1Name, 0, netc, reqStr) ---发送数据 - if result then - wait(d1Name, timeout - 100, netc) - local is_err, param, _, _ = socket.rx(netc, rx_buff) -- 接收数据 - log.info("是否接收和数据长度", not is_err, param) - if not is_err then -- 如果接收成功 - socket.close(netc) -- 关闭连接 - socket.release(netc) - local read_buff = rx_buff:toStr(0, param) - rx_buff:clear() - log.info("lbsLoc receive", read_buff:toHex()) - if read_buff:len() >= 11 and(read_buff:byte(1) == 0 or read_buff:byte(1) == 0xFF) then - local locType = read_buff:byte(1) - cbFnc(0, trans(bcdNumToNum(read_buff:sub(2, 6))), - trans(bcdNumToNum(read_buff:sub(7, 11))), reqAddr and - read_buff:sub(13, 12 + read_buff:byte(12)) or nil, - read_buff:sub(reqAddr and (13 + read_buff:byte(12)) or 12, -1), - locType) - else - log.warn("lbsLoc.query", "根据基站查询经纬度失败") - if read_buff:byte(1) == 2 then - log.warn("lbsLoc.query","main.lua中的PRODUCT_KEY和此设备在iot.openluat.com中所属项目的ProductKey必须一致，请去检查") - else - log.warn("lbsLoc.query","基站数据库查询不到所有小区的位置信息") - log.warn("lbsLoc.query","在trace中向上搜索encellinfo，然后在电脑浏览器中打开http://bs.openluat.com/，手动查找encellinfo后的所有小区位置") - log.warn("lbsLoc.query","如果手动可以查到位置，则服务器存在BUG，直接向技术人员反映问题") - log.warn("lbsLoc.query","如果手动无法查到位置，则基站数据库还没有收录当前设备的小区位置信息，向技术人员反馈，我们会尽快收录") - end - cbFnc(5) - end - return - else - socket.close(netc) - socket.release(netc) - retryCnt = retryCnt+1 - if retryCnt>=3 then return cbFnc(4) end - break - end - else - socket.close(netc) - socket.release(netc) - retryCnt = retryCnt+1 - if retryCnt>=3 then return cbFnc(3) end - break - end - end - else - socket.close(netc) - socket.release(netc) - retryCnt = retryCnt + 1 - if retryCnt >= 3 then return cbFnc(2) end - end - end -end - - ---[[ -发送基站/WIFI定位请求（仅支持中国区域的位置查询） -@api lbsLoc.request(cbFnc,reqAddr,timeout,productKey,host,port,reqTime,reqWifi) -@function cbFnc 用户回调函数，回调函数的调用形式为：cbFnc(result,lat,lng,addr,time,locType) -@bool reqAddr 是否请求服务器返回具体的位置字符串信息，目前此功能不完善，参数可以传nil -@number timeout 请求超时时间，单位毫秒，默认20000毫秒 -@string productKey IOT网站上的产品证书，如果在main.lua中定义了PRODUCT_KEY变量，则此参数可以传nil -@string host 服务器域名，此参数可选，目前仅lib中agps.lua使用此参数。应用脚本可以直接传nil -@string port 服务器端口，此参数可选，目前仅lib中agps.lua使用此参数。应用脚本可以直接传nil -@bool reqTime 是否需要服务器返回时间信息，true返回，false或者nil不返回，此参数可选，目前仅lib中agps.lua使用此参数。应用脚本可以直接传nil -@table reqWifi 搜索到的WIFI热点信息(MAC地址和信号强度)，如果传入了此参数，后台会查询WIFI热点对应的经纬度，此参数格式如下： -{["1a:fe:34:9e:a1:77"] = -63,["8c:be:be:2d:cd:e9"] = -81,["20:4e:7f:82:c2:c4"] = -70,} -@return nil -]] -function lbsLoc.request(cbFnc,reqAddr,timeout,productKey,host,port,reqTime,reqWifi) - sysplus.taskInitEx(taskClient, d1Name, netCB, cbFnc,reqAddr or nil,timeout or 20000,productKey or _G.PRODUCT_KEY,host or "bs.openluat.com",port or "12411",reqTime,reqWifi) -end - -return lbsLoc \ No newline at end of file diff --git a/script/main.lua b/script/main.lua index 72ec711..9ab88e7 100644 --- a/script/main.lua +++ b/script/main.lua @@ -20,8 +20,8 @@ end socket.setDNS(nil, 1, "119.29.29.29") socket.setDNS(nil, 2, "223.5.5.5") --- 设置 SIM 自动恢复, 搜索小区信息间隔, 最大搜索时间 -mobile.setAuto(1000 * 10, 1000 * 60, 1000 * 5) +-- 设置 SIM 自动恢复(单位: 毫秒), 搜索小区信息间隔(单位: 毫秒), 最大搜索时间(单位: 秒) +mobile.setAuto(1000 * 10) -- POWERKEY local button_last_press_time, button_last_release_time = 0, 0 @@ -78,15 +78,6 @@ sys.taskInit( util_netled.init() - -- 开机基站定位 - util_location.getCoord( - function() - log.info("publish", "COORD_INIT_DONE") - sys.publish("COORD_INIT_DONE") - end - ) - sys.waitUntil("COORD_INIT_DONE", 1000 * 20) - -- 开机通知 if config.BOOT_NOTIFY then util_notify.send("#BOOT") @@ -98,8 +89,8 @@ sys.taskInit( end -- 定时基站定位 - if config.LOCATION_INTERVAL and config.LOCATION_INTERVAL >= 1000 * 10 then - sys.timerLoopStart(util_location.getCoord, config.LOCATION_INTERVAL) + if config.LOCATION_INTERVAL and config.LOCATION_INTERVAL >= 1000 * 30 then + sys.timerLoopStart(util_location.refresh, config.LOCATION_INTERVAL, 30) end -- 电源键短按发送测试通知 diff --git a/script/util_location.lua b/script/util_location.lua index 337fbf2..69531a7 100644 --- a/script/util_location.lua +++ b/script/util_location.lua @@ -1,50 +1,176 @@ -local lbsLoc = require "lbsLoc" - local util_location = {} -local last_lat, last_lng = 0, 0 -local last_time = 0 +-- 基站定位接口类型, 支持 openluat 和 cellocation +local api_type = "openluat" --- 获取坐标 -function util_location.getCoord(callback, type, wifi, timeout) - local is_callback = callback ~= nil - if callback == nil then - callback = function() +local cache = { + cell_info_raw = {}, + cell_info_formatted = "", + lbs_data = { + lat = 0, + lng = 0 + } +} + +--- 格式化经纬度 (保留小数点后 6 位, 去除末尾的 0) +-- @param value 经纬度 +-- @return 格式化后的经纬度 +local function formatCoord(value) + local str = string.format("%.6f", tonumber(value) or 0) + str = str:gsub("%.?0+$", "") + return tonumber(str) +end + +--- 生成地图链接 +-- @param lat 纬度 +-- @param lng 经度 +-- @return 地图链接 or "" +local function getMapLink(lat, lng) + lat, lng = lat or 0, lng or 0 + local map_link = "" + if lat ~= 0 and lng ~= 0 then + map_link = "http://apis.map.qq.com/uri/v1/marker?coord_type=1&marker=title:+;coord:" .. lat .. "," .. lng + end + log.debug("util_location.getMapLink", map_link) + return map_link +end + +--- 格式化基站信息 +-- @param cell_info_raw 基站信息 +-- @return 格式化后的基站信息 +local function formatCellInfo(cell_info_raw) + if api_type == "openluat" then + local cell_info_arr = {} + for i, v in ipairs(cell_info_raw) do + table.insert(cell_info_arr, {mcc = v.mcc, mnc = v.mnc, lac = v.tac, ci = v.cid, rxlevel = v.rsrp, hex = 10}) end + local cell_info_json = json.encode(cell_info_arr) + log.debug("util_location.formatCellInfo", api_type .. ":", cell_info_json) + return cell_info_json + end + + if api_type == "cellocation" then + local str = "" + for i, v in ipairs(cell_info_raw) do + str = str .. (i == 1 and "" or ";") + str = str .. v.mcc .. "," .. v.mnc .. "," .. v.tac .. "," .. v.cid .. "," .. v.rsrp + end + log.debug("util_location.formatCellInfo", api_type .. ":", str) + return str + end +end + +--- 获取基站信息 +-- @return 基站信息 or "" +local function getCellInfo() + local cell_info_formatted = formatCellInfo(mobile.getCellInfo()) + cache.cell_info_formatted = cell_info_formatted + return cell_info_formatted +end + +--- 刷新基站信息 +-- @param timeout 超时时间(单位: 秒) +function util_location.refreshCellInfo(timeout) + log.info("util_location.refreshCellInfo", "start") + if cache.is_req_cell_info_running then + log.info("util_location.refreshCellInfo", "running, wait...") + else + cache.is_req_cell_info_running = true + mobile.reqCellInfo(timeout or 30) -- 单位: 秒 + end + sys.waitUntil("CELL_INFO_UPDATE") + cache.is_req_cell_info_running = false + log.info("util_location.refreshCellInfo", "end") +end + +--- 刷新基站定位信息 +-- @param timeout 超时时间(单位: 秒) +-- @return 刷新成功返回 true +function util_location.refresh(timeout, is_refresh_cell_info_disabled) + timeout = type(timeout) == "number" and timeout * 1000 or nil + + local openluat = function(cell_info_formatted) + local lbs_api = "http://bs.openluat.com/get_gpss" + local header = { + ["Content-Type"] = "application/x-www-form-urlencoded" + } + local body = "data=" .. cell_info_formatted + local code, headers, body = util_http.fetch(timeout, "POST", lbs_api, header, body) + log.info("util_location.refresh", api_type .. ":", "code:", code, "body:", body) + + if code ~= 200 or body == nil or body == "" then + return + end + + local lbs_data = json.decode(body) or {} + local status, lat, lng = lbs_data.status, lbs_data.lat, lbs_data.lng + + if status ~= 0 or lat == nil or lng == nil or lat == "" or lng == "" then + return + end + + return lat, lng + end + + local cellocation = function(cell_info_formatted) + local lbs_api = "http://api.cellocation.com:83/loc/?output=json&cl=" .. cell_info_formatted + local code, headers, body = util_http.fetch(timeout, "GET", lbs_api) + log.info("util_location.refresh", api_type .. ":", "code:", code, "body:", body) + + if code ~= 200 or body == nil or body == "" then + return + end + + local lbs_data = json.decode(body) or {} + local errcode, lat, lng = lbs_data.errcode, lbs_data.lat, lbs_data.lon + if errcode ~= 0 or lat == nil or lng == nil or lat == "0.0" or lng == "0.0" then + return + end + + return lat, lng end sys.taskInit( function() - local current_time = os.time() - if not is_callback then - if current_time - last_time < 30 then - log.info("util_location.getCoord", "距离上次定位时间太短", current_time - last_time) - return - end - sys.wait(2000) + if not is_refresh_cell_info_disabled then + util_location.refreshCellInfo(timeout) + end + local old_cell_info_formatted = cache.cell_info_formatted + local cell_info_formatted = getCellInfo() + + if cell_info_formatted == old_cell_info_formatted then + log.info("util_location.refresh", api_type .. ":", "cell_info 无变化, 不重新请求") + return + end + + local lat, lng + if api_type == "openluat" then + lat, lng = openluat(cell_info_formatted) + elseif api_type == "cellocation" then + lat, lng = cellocation(cell_info_formatted) + end + if lat and lng then + cache.lbs_data = {lat, lng} end - last_time = current_time - lbsLoc.request( - function(result, lat, lng, addr, time, locType) - log.info("util_location.getCoord", result, lat, lng, locType) - if result == 0 and lat and lng then - last_lat, last_lng = lat, lng - return callback(lat, lng) - end - return callback(last_lat, last_lng) - end, - nil, - timeout, - "v32xEAKsGTIEQxtqgwCldp5aPlcnPs3K", - nil, - nil, - nil, - wifi - ) end ) - - return last_lat, last_lng end +--- 获取位置信息 +-- @return lat +-- @return lng +-- @return map_link +function util_location.get() + local lat, lng = unpack(cache.lbs_data) + lat, lng = formatCoord(lat), formatCoord(lng) + return lat, lng, getMapLink(lat, lng) +end + +sys.subscribe( + "CELL_INFO_UPDATE", + function() + log.debug("EVENT.CELL_INFO_UPDATE") + end +) + return util_location