From 2260db4cfb79056fa5e23844b7f12584a9cf1c79 Mon Sep 17 00:00:00 2001 From: meng Date: Sat, 9 Mar 2024 21:40:15 +0800 Subject: [PATCH] =?UTF-8?q?=E7=A7=BB=E9=99=A4http=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- script/util_http.lua | 42 ---------- script/util_location.lua | 176 --------------------------------------- 2 files changed, 218 deletions(-) delete mode 100644 script/util_http.lua delete mode 100644 script/util_location.lua diff --git a/script/util_http.lua b/script/util_http.lua deleted file mode 100644 index 918d7de..0000000 --- a/script/util_http.lua +++ /dev/null @@ -1,42 +0,0 @@ -local util_http = {} - --- 用于生成 http 请求的 id -local http_count = 0 --- 记录正在运行的 http 请求数量 -local http_running_count = 0 - ---- 对 http.request 的封装 --- @param timeout 超时时间(单位: 毫秒) --- @param method 请求方法 --- @param url 请求地址 --- @param headers 请求头 --- @param body 请求体 -function util_http.fetch(timeout, method, url, headers, body) - timeout = timeout or 1000 * 25 - local opts = {timeout = timeout} - - http_count = http_count + 1 - http_running_count = http_running_count + 1 - - local id = "http_" .. http_count - local res_code, res_headers, res_body = -99, {}, "" - - util_netled.blink(50, 50) - - log.debug("util_http.fetch", "开始请求", "id:", id) - res_code, res_headers, res_body = http.request(method, url, headers, body, opts).wait() - log.debug("util_http.fetch", "请求结束", "id:", id, "code:", res_code) - - if res_code == -8 then - log.warn("util_http.fetch", "请求超时", "id:", id) - end - - http_running_count = http_running_count - 1 - if http_running_count == 0 then - util_netled.blink() - end - - return res_code, res_headers, res_body -end - -return util_http diff --git a/script/util_location.lua b/script/util_location.lua deleted file mode 100644 index 63e8820..0000000 --- a/script/util_location.lua +++ /dev/null @@ -1,176 +0,0 @@ -local util_location = {} - --- 基站定位接口类型, 支持 openluat 和 cellocation -local api_type = "openluat" - -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() - 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 - end - ) -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