1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
-- LuaTools需要PROJECT和VERSION这两个信息
PROJECT = "smsdemo"
VERSION = "1.0.0"
log.info("main", PROJECT, VERSION)
-- 引入必要的库文件(lua编写), 内部库不需要require
sys = require("sys")
require "sysplus" -- http库需要这个sysplus
if wdt then
--添加硬狗防止程序卡死，在支持的设备上启用这个功能
wdt.init(9000)--初始化watchdog设置为9s
sys.timerLoopStart(wdt.feed, 3000)--3s喂一次狗
end
log.info("main", "sms demo")
--运营商给的dns经常抽风，手动指定
socket.setDNS(nil, 1, "119.29.29.29")
socket.setDNS(nil, 2, "223.5.5.5")
--缓存消息
local buff = {}
-- bark_url 不支持 https（我不会改，有请大佬）, 官方 api 好像强制https，
bark_url = "http://api.day.app/push"
bark_key = "换成你自己的"
-- 辅助发送http请求, 因为http库需要在task里运行
function http_post(url, headers, body)
sys.taskInit(function()
for i=1,10 do
local code, headers, body = http.request("POST", url, headers, body).wait()
log.info("resp", code)
log.info("body", body)
if code == 200 then
break
end
sys.wait(5000)
end
end)
end
function sms_handler(num, txt)
-- num 手机号码
-- txt 文本内容
log.info("sms", num, txt, txt:toHex())
-- http演示1, 发json
local body = json.encode({
title=num,
body=txt,
device_key=bark_key
})
local headers = {}
headers["Content-Type"] = "application/json"
log.info("json", body)
http_post(bark_url, headers, body)
end
--订阅短信消息
sys.subscribe("SMS_INC",function(phone,data)
--来新消息了
log.info("notify","got sms",phone,data)
table.insert(buff,{phone,data})
sys.publish("SMS_ADD")--推个事件
end)
--------------------------------------------------------------------
-- 接收短信, 支持多种方式, 选一种就可以了
-- 1. 设置回调函数
--sms.setNewSmsCb(sms_handler)
-- 2. 订阅系统消息
--sys.subscribe("SMS_INC", sms_handler)
-- 3. 在task里等着
sys.taskInit(function()
while true do
print("ww",collectgarbage("count"))
while #buff > 0 do--把消息读完
collectgarbage("collect")--防止内存不足
local sms = table.remove(buff,1)
sms_handler(sms[1], sms[2])
end
log.info("notify","wait for a new sms~")
print("zzz",collectgarbage("count"))
sys.waitUntil("SMS_ADD")
end
end)
-------------------------------------------------------------------
-- 发送短信, 直接调用sms.send就行, 是不是task无所谓
-- sys.taskInit(function()
-- sys.wait(10000)
-- -- 中移动卡查短信
-- -- sms.send("+8610086", "301")
-- -- 联通卡查话费
-- sms.send("10010", "101")
-- end)
-- 用户代码已结束---------------------------------------------
-- 结尾总是这一句
sys.run()
-- sys.run()之后后面不要加任何语句!!!!!
|
