wangfq
173dd6874f
- 来源: 合宙 LuatOS 官方仓库 air780epm 模块完整代码 - 路径: luatos/air780epm/module/Air780EPM/demo 含官方 demo(含 mqtt/mqtts/socket/uart 等) - 后续: 基于 demo 开发 UART<->MQTT 数据上报功能
149 lines
5.9 KiB
Lua
149 lines
5.9 KiB
Lua
--[[
|
|
@module ntp_test
|
|
@summary ntp_test测试功能模块
|
|
@version 1.0
|
|
@date 2025.10.24
|
|
@author 马亚丹
|
|
@usage
|
|
本demo演示的功能为：使用Air780EPM开发板，演示用ntp网络对时后,获取本地时间和UTC时间的功能
|
|
核心逻辑：
|
|
|
|
1.判断是否联网，
|
|
2.网络就绪后开始时间同步
|
|
3.时间同步成功，获取本地时间和UTC时间，按默认间隔时间循环打印获取的时间信息
|
|
4.时间同步失败，打印提醒
|
|
|
|
|
|
|
|
]]
|
|
|
|
-- 自定义NTP服务器列表，可选配置，默认使用内置的ntp服务器地址ntp.aliyun.com
|
|
local ntp_servers = {
|
|
"ntp.aliyun.com",
|
|
"ntp.ntsc.ac.cn",
|
|
"time1.cloud.tencent.com"
|
|
}
|
|
|
|
--本地时间是指:当前时区的时间，默认是东八区北京时间，可以通过rtc.timezone接口查询或者设置时区
|
|
--UTC时间是指：0时区的时间
|
|
--东八区的时间是在UTC时间的基础上增加8个小时
|
|
|
|
-- 打印时间信息的工具函数
|
|
local function print_time_details()
|
|
--设置为东3区时间
|
|
--rtc.timezone(12)
|
|
--获取东3区的时间字符串
|
|
--东3区时间字符串 Fri Oct 24 12:01:20 2025
|
|
--log.info("sntp", "东3区时间字符串", os.date())
|
|
|
|
|
|
-- 获取本地时间字符串
|
|
-- 本地时间字符串 Fri Oct 24 17:01:15 2025
|
|
log.info("sntp", "本地时间字符串", os.date())
|
|
|
|
-- 获取UTC时间字符串
|
|
-- UTC时间字符串 Fri Oct 24 09:01:15 2025
|
|
log.info("sntp", "UTC时间字符串", os.date("!%c"))
|
|
|
|
-- 格式化本地时间字符串
|
|
-- 本地时间字符串 2025-10-24 17:01:15
|
|
log.info("sntp", "格式化本地时间字符串", os.date("%Y-%m-%d %H:%M:%S"))
|
|
|
|
|
|
-- 格式化UTC时间字符串
|
|
-- UTC时间字符串 2025-10-24 09:01:15
|
|
log.info("sntp", "格式化UTC时间字符串", os.date("!%Y-%m-%d %H:%M:%S"))
|
|
|
|
|
|
-- RTC时钟原始数据（UTC时间）
|
|
local rtc_time = rtc.get()
|
|
-- RTC时钟(UTC) {"year":2025,"min":1,"hour":9,"mon":10,"sec":15,"day":24}
|
|
log.info("sntp", "RTC时钟(UTC)", json.encode(rtc_time))
|
|
|
|
|
|
-- 本地时间戳（秒级）
|
|
--本地时间戳 1761296475
|
|
log.info("sntp", "本地时间戳", os.time())
|
|
|
|
-- 获取本地时间的table
|
|
-- 本地时间结构 {"wday":6,"min":1,"yday":297,"hour":17,"isdst":false,"year":2025,"month":10,"sec":15,"day":24}
|
|
|
|
local local_struct_time = os.date("*t")
|
|
log.info("sntp", "本地时间结构", json.encode(local_struct_time))
|
|
--结构时间转时间戳 1761325275
|
|
log.info("sntp", "结构时间转时间戳", os.time(local_struct_time))
|
|
end
|
|
|
|
-- 打印高精度时间戳
|
|
local function print_high_precision_time()
|
|
local ntp_time = socket.ntptm()
|
|
if ntp_time and ntp_time.tsec then
|
|
--tm数据 {"sms":89,"tms":320,"vaild":true,"tsec":1761296475,"lms":231,"ndeley":28,"lsec":18,"ssec":1761296457}
|
|
log.info("tm数据", json.encode(ntp_time))
|
|
-- 格式化：秒.毫秒
|
|
--高精度时间戳 1761296475.320
|
|
log.info("sntp", "高精度时间戳", string.format("%u.%03d", ntp_time.tsec, ntp_time.tms))
|
|
else
|
|
log.warn("sntp", "高精度时间戳获取失败")
|
|
end
|
|
end
|
|
|
|
-- SNTP同步主逻辑
|
|
local function sntp_sync_loop()
|
|
--查看网卡适配器的联网状态是否IP_READY,true表示已经准备好可以联网了,false暂时不可以联网
|
|
while not socket.adapter(socket.dft()) do
|
|
log.warn("sntp", "wait IP_READY", socket.dft())
|
|
-- 在此处阻塞等待默认网卡连接成功的消息"IP_READY"
|
|
-- 或者等待1秒超时退出阻塞等待状态;
|
|
-- 注意：此处的1000毫秒超时不要修改的更长；
|
|
-- 因为当使用exnetif.set_priority_order配置多个网卡连接外网的优先级时，会隐式的修改默认使用的网卡
|
|
-- 当exnetif.set_priority_order的调用时序和此处的socket.adapter(socket.dft())判断时序有可能不匹配
|
|
-- 此处的1秒，能够保证，即使时序不匹配，也能1秒钟退出阻塞状态，再去判断socket.adapter(socket.dft())
|
|
sys.waitUntil("IP_READY", 1000)
|
|
end
|
|
|
|
-- 检测到了IP_READY消息，设置默认网络适配器编号
|
|
log.info("sntp", "recv IP_READY", socket.dft())
|
|
|
|
|
|
while true do
|
|
log.info("sntp", "开始同步：")
|
|
-- 方式1：使用自定义服务器列表
|
|
-- log.info("sntp", "开始同步，服务器列表：", json.encode(ntp_servers))
|
|
-- 选择自己要用的的服务器
|
|
--socket.sntp(ntp_servers[2])
|
|
|
|
-- 方式2： 使用默认的ntp服务器地址：ntp.aliyun.com
|
|
socket.sntp()
|
|
|
|
-- 等待同步结果（成功：NTP_UPDATE，失败：超时）
|
|
local sync_success = sys.waitUntil("NTP_UPDATE", 5000)
|
|
|
|
if sync_success then
|
|
--ntp同步成功之后，已经自动将系统时间设置为本地时间
|
|
--在此处的脚本中，不需要再调用任何时间设置接口去手动设置时间
|
|
--本地时间：默认为东八区北京时间,如果使用rtc.timezone(zone)设置过本地时间，则本地时间为自己设置过的时区对应的时间
|
|
-- 同步成功：打印时间信息
|
|
log.info("sntp", "时间同步成功")
|
|
print_time_details()
|
|
print_high_precision_time()
|
|
--时间同步成功
|
|
--再等待1小时再次发起下次时间同步，这里的等待时长可以按自己的需求修改。
|
|
sys.wait(3600*1000)
|
|
else
|
|
log.warn("sntp", "时间同步失败")
|
|
--时间同步失败
|
|
--再等待10秒重新发起时间同步，这里的等待时长可以按自己的需求修改。
|
|
sys.wait(10*1000)
|
|
end
|
|
end
|
|
end
|
|
|
|
-- 订阅NTP错误消息
|
|
sys.subscribe("NTP_ERROR", function(err_info)
|
|
log.error("sntp", "同步过程发生错误", err_info or "未知错误")
|
|
end)
|
|
|
|
-- 启动SNTP同步任务
|
|
sys.taskInit(sntp_sync_loop)
|