百度热搜榜定时采集入库关键词监控/排名变动

群发软件

百度热搜榜定时采集入库关键词监控/排名变动

1. /**
   
2. * 案例18：百度热搜榜定时采集入库 + 关键词监控/排名变动报警(纯 printl 日志版,输出到 H5 日志终端)
   
3. *
   
4. * 经典实用案例"热搜榜监控+关键词盯盘提醒"，转换成 AIWROK 实现：
   
5. *   okHttp 请求百度热搜公开 JSON 接口(top.baidu.com/api/board，无需Key)
   
6. *   → 取 Top N 榜单(标题/排名/热度) → SQLite 入库(hot_records 表) → 逐条完整打印到 H5 终端
   
7. *
   
8. * 案例15/16/17 是"数值监控"(价格/温度/汇率)，本案例换成"文本榜单监控"，
   
9. * 三个新知识点：
   
10. * 1. okHttp.setHeader("User-Agent", ...)：部分公开接口会校验 UA，这是第一次用到请求头；
    
11. * 2. 关键词命中报警：标题包含监控词(如"AI")就打 ⚠ 并附链接，做舆情/盯盘提醒的雏形；
    
12. * 3. 排名变动对比：用对象存上一轮榜单，本轮逐个对比出 新上榜/上升/下降/掉榜，
    
13. *    这是"有状态采集"——脚本记得上一轮数据才能算变化，和前面纯数值入库不同。
    
14. *
    
15. * 接口实测说明(电脑直连验证过)：
    
16. *   https://top.baidu.com/api/board?platform=pc&tab=realtime 返回 50 条,
    
17. *   data.cards[0].content[i] 含 word(标题)/index(排名)/hotScore(热度)/desc(摘要)/url(链接)。
    
18. */
    
19. 
    
20. // ========== 配置区(改这里) ==========
    
21. var 监控关键词列表 = ["AI", "小米", "微信"];   // 命中任一关键词就打 ⚠ 报警(改这里盯你自己的词)
    
22. var 取榜单条数 = 10;                          // 每轮取前 10 条(演示打印量刚好)
    
23. var 排名变动阈值 = 2;                         // 排名比上一轮变动 >= 2 位提示 ↑/↓
    
24. var 采集间隔秒 = 30;                          // 每 30 秒采一轮(录像教学用;长期挂机可改 300)
    
25. var SQLite路径 = "/sdcard/热搜榜.db";
    
26. var 表名 = "hot_records";
    
27. 
    
28. // ========== 全局变量顶部声明 ==========
    
29. var gStop = false;
    
30. var 数据库连接 = null;
    
31. var 数据库可用 = false;
    
32. var 累计入库条数 = 0;
    
33. var 上一轮榜单 = {};            // { "标题": 排名 } 首轮为空对象,不做变动对比
    
34. 
    
35. // ========== importClass 只能放最外层 ==========
    
36. importClass(android.database.sqlite.SQLiteDatabase);
    
37. importClass(java.io.File);
    
38. 
    
39. // ========== 工具函数(先定义后调用) ==========
    
40. 
    
41. // 连接 SQLite(零配置；如需远程库可仿照案例14扩展 mysql 分支)
    
42. function dbConnect() {
    
43.     try {
    
44.         数据库连接 = SQLiteDatabase.openOrCreateDatabase(new File(SQLite路径), null);
    
45.         数据库可用 = true;
    
46.         printl("[DB] ✅ SQLite 已打开: " + SQLite路径);
    
47.     } catch (e) {
    
48.         数据库可用 = false;
    
49.         printl("[DB] ⚠ 打开失败(本轮只打印不入库): " + e);
    
50.     }
    
51. }
    
52. 
    
53. // 建表(存在则跳过)：rank/word/hot_score/collected_at
    
54. function dbEnsureTable() {
    
55.     if (!数据库可用) return;
    
56.     try {
    
57.         var sql = "CREATE TABLE IF NOT EXISTS " + 表名 + " (" +
    
58.             "id INTEGER PRIMARY KEY AUTOINCREMENT," +
    
59.             "rank INTEGER, word TEXT, hot_score INTEGER, collected_at INTEGER)";
    
60.         数据库连接.execSQL(sql);
    
61.         printl("[DB] ✅ 表已就绪: " + 表名);
    
62.     } catch (e) {
    
63.         printl("[DB] ⚠ 建表失败: " + e);
    
64.         数据库可用 = false;
    
65.     }
    
66. }
    
67. 
    
68. // 单条榜单入库
    
69. function dbInsertHot(rank, word, hotScore) {
    
70.     if (!数据库可用) return false;
    
71.     try {
    
72.         var stmt = 数据库连接.compileStatement("INSERT INTO " + 表名 +
    
73.             " (rank, word, hot_score, collected_at) VALUES (?,?,?,?)");
    
74.         stmt.bindLong(1, rank);
    
75.         stmt.bindString(2, "" + word);
    
76.         stmt.bindLong(3, hotScore);
    
77.         stmt.bindLong(4, time.nowStamp());   // nowStamp=毫秒数字;time.now()是格式化字符串不能bindLong
    
78.         stmt.executeInsert();
    
79.         stmt.close();
    
80.         return true;
    
81.     } catch (e) {
    
82.         printl("[DB] ❌ 入库失败: " + e);
    
83.         return false;
    
84.     }
    
85. }
    
86. 
    
87. function dbClose() {
    
88.     if (数据库可用 && 数据库连接 != null) {
    
89.         try { 数据库连接.close(); } catch (e) {}
    
90.         数据库连接 = null;
    
91.     }
    
92. }
    
93. 
    
94. // 拉取一轮热搜榜：返回数组 [{排名,标题,热度,链接}]，失败返回 null
    
95. function 拉取热搜() {
    
96.     var url = "https://top.baidu.com/api/board?platform=pc&tab=realtime";
    
97. 
    
98.     try {
    
99.         printl("📡 正在请求百度热搜接口(实时榜)...");
    
100.         var http = new okHttp();
     
101.         http.setTimeOut(5000, 8000, 5000);   // 必须设超时，防网络挂死(踩坑经验)
     
102.         // 新知识点：setHeader 带浏览器 UA,公开接口常校验 UA(本接口实测不带也通,带上更稳)
     
103.         http.setHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0 Safari/537.36");
     
104.         printl("📡 等待接口返回(最长8秒)...");
     
105.         var text = "" + http.get(url);
     
106.         printl("📡 接口已返回,开始解析 JSON...");
     
107.         var obj = JSON.parse(text);
     
108.         if (!obj || !obj.success || !obj.data || !obj.data.cards || !obj.data.cards[0] || !obj.data.cards[0].content) {
     
109.             printl("[API] ⚠ 接口结构异常: " + text.substring(0, 120));
     
110.             return null;
     
111.         }
     
112.         var 全部 = obj.data.cards[0].content;
     
113.         var 取数 = 取榜单条数;
     
114.         if (取数 > 全部.length) 取数 = 全部.length;
     
115.         var 结果 = [];
     
116.         for (var i = 0; i < 取数; i++) {
     
117.             var 项 = 全部[i];
     
118.             var 热度 = parseInt(项.hotScore);
     
119.             if (isNaN(热度)) 热度 = 0;
     
120.             结果.push({ 排名: i + 1, 标题: "" + 项.word, 热度: 热度, 链接: "" + 项.url });
     
121.         }
     
122.         printl("✅ 解析完成,榜单共 " + 全部.length + " 条,本轮取前 " + 结果.length + " 条");
     
123.         return 结果;
     
124.     } catch (e) {
     
125.         printl("[API] ❌ 拉取失败: " + e);
     
126.         return null;
     
127.     }
     
128. }
     
129. 
     
130. // 逐条完整打印采集结果(演示用:排名/标题/热度全打出来)
     
131. function 打印采集结果(榜单数组) {
     
132.     printl("📋 本轮采集结果(百度热搜 Top " + 榜单数组.length + "):");
     
133.     for (var i = 0; i < 榜单数组.length; i++) {
     
134.         var s = 榜单数组[i];
     
135.         printl("   [" + s.排名 + "] " + s.标题 + " | 热度 " + s.热度);
     
136.     }
     
137. }
     
138. 
     
139. // 关键词命中报警：标题包含任一监控词就打 ⚠ 并附链接(舆情/盯盘提醒雏形)
     
140. function 检查关键词(榜单数组) {
     
141.     var 命中数 = 0;
     
142.     for (var i = 0; i < 榜单数组.length; i++) {
     
143.         var s = 榜单数组[i];
     
144.         for (var k = 0; k < 监控关键词列表.length; k++) {
     
145.             var kw = 监控关键词列表[k];
     
146.             if (s.标题.indexOf(kw) >= 0) {
     
147.                 命中数++;
     
148.                 printl("⚠ 报警：关键词「" + kw + "」上榜! [" + s.排名 + "] " + s.标题);
     
149.                 printl("   🔗 " + s.链接);
     
150.             }
     
151.         }
     
152.     }
     
153.     if (命中数 === 0) {
     
154.         printl("🔕 关键词检查:Top " + 榜单数组.length + " 未命中监控词(" + 监控关键词列表.join("/") + ")");
     
155.     }
     
156. }
     
157. 
     
158. // 排名变动对比：与上一轮榜单比,算出新上榜/上升/下降/掉榜(有状态采集)
     
159. function 检查排名变动(榜单数组) {
     
160.     var 本轮集合 = {};
     
161.     for (var i = 0; i < 榜单数组.length; i++) {
     
162.         var s = 榜单数组[i];
     
163.         本轮集合[s.标题] = s.排名;
     
164.         var 旧排名 = 上一轮榜单[s.标题];
     
165.         if (旧排名 == null) {
     
166.             printl("🆕 新上榜：[" + s.排名 + "] " + s.标题);
     
167.         } else {
     
168.             var 变动 = 旧排名 - s.排名;   // 正数=名次前进
     
169.             if (变动 >= 排名变动阈值) {
     
170.                 printl("📈 上升：[" + 旧排名 + "→" + s.排名 + "] " + s.标题);
     
171.             } else if (-变动 >= 排名变动阈值) {
     
172.                 printl("📉 下降：[" + 旧排名 + "→" + s.排名 + "] " + s.标题);
     
173.             }
     
174.         }
     
175.     }
     
176.     // 掉榜检测:上一轮有、本轮没有
     
177.     for (var 词 in 上一轮榜单) {
     
178.         if (本轮集合[词] == null) {
     
179.             printl("🚪 掉榜：" + 词);
     
180.         }
     
181.     }
     
182.     上一轮榜单 = 本轮集合;   // 本轮存为下一轮对比基准
     
183. }
     
184. 
     
185. // ========== 主流程 ==========
     
186. printl("===== 案例18 百度热搜定时采集入库 启动 =====");
     
187. 
     
188. // 步骤0：连库建表
     
189. dbConnect();
     
190. dbEnsureTable();
     
191. printl("⚙ 配置:取前 " + 取榜单条数 + " 条 · 监控词(" + 监控关键词列表.join("/") + ") · 排名变动阈值 " +
     
192.     排名变动阈值 + " 位 · 采集间隔 " + 采集间隔秒 + " 秒");
     
193. 
     
194. // 停止按钮清理(顺序：先置标志，stopAllRuning 放最后)
     
195. event.onStopBtnEvent(function () {
     
196.     gStop = true;
     
197.     dbClose();
     
198.     runTime.stopAllRuning();
     
199. });
     
200. 
     
201. // 步骤1：定时循环采集
     
202. var 轮次 = 0;
     
203. while (!gStop) {
     
204.     轮次++;
     
205.     printl("\n---- 第 " + 轮次 + " 轮采集 ----");
     
206. 
     
207.     var 榜单数组 = 拉取热搜();
     
208.     if (榜单数组 != null && 榜单数组.length > 0) {
     
209.         // 1) 逐条完整打印采集结果(演示重点:榜单标题全打出来)
     
210.         打印采集结果(榜单数组);
     
211. 
     
212.         // 2) 入库
     
213.         var 本轮入库 = 0;
     
214.         printl("💾 开始逐条写入数据库(表: " + 表名 + ")...");
     
215.         for (var k = 0; k < 榜单数组.length; k++) {
     
216.             var q = 榜单数组[k];
     
217.             if (dbInsertHot(q.排名, q.标题, q.热度)) {
     
218.                 本轮入库++;
     
219.                 累计入库条数++;
     
220.                 printl("   ✓ 已入库 [" + 本轮入库 + "/" + 榜单数组.length + "] [" + q.排名 + "] " + q.标题);
     
221.             } else {
     
222.                 printl("   ✗ 入库失败: " + q.标题);
     
223.             }
     
224.         }
     
225.         printl("[DB] 本轮入库 " + 本轮入库 + " 条 | 累计 " + 累计入库条数 + " 条 | 库文件: " + SQLite路径);
     
226. 
     
227.         // 3) 关键词报警 + 排名变动对比
     
228.         检查关键词(榜单数组);
     
229.         if (轮次 === 1) {
     
230.             printl("ℹ 首轮已记录榜单基准,从第 2 轮起显示 新上榜/上升/下降/掉榜");
     
231.         }
     
232.         检查排名变动(榜单数组);
     
233.     } else {
     
234.         printl("⚠ 本轮无数据，跳过入库(" + time.StampToTime(time.nowStamp()) + ")");
     
235.     }
     
236. 
     
237.     // 分片等待下一轮:每 5 秒打一条进度日志(画面不空,方便观察/录像)
     
238.     printl("⏳ 本轮全部完成," + 采集间隔秒 + " 秒后自动开始下一轮");
     
239.     var 剩余 = 采集间隔秒;
     
240.     while (剩余 > 0 && !gStop) {
     
241.         var 步长 = 剩余 >= 5 ? 5 : 剩余;
     
242.         printl("⏳ 等待下一轮...剩余 " + 剩余 + " 秒(期间脚本在待机,到点自动拉热搜→入库→对比排名)");
     
243.         sleep.second(秒 = 步长);
     
244.         剩余 = 剩余 - 步长;
     
245.     }
     
246. }
     
247. 
     
248. dbClose();
     
249. printl("===== 流程结束：共 " + 轮次 + " 轮，累计入库 " + 累计入库条数 + " 条 =====");
     

复制代码