网络API数据库定时器股票行情定时采集入库

群发软件

网络API数据库定时器股票行情定时采集入库









https://www.yuque.com/aiwork/nba2pr/omtx2y4ssig1mtrr

1. /**
   
2. * 案例15：股票行情定时采集入库(纯 printl 日志版,输出到 H5 日志终端)
   
3. *
   
4. * 仿照全网经典实用案例"股票价格监控/盯盘报警"，转换成 AIWROK 实现：
   
5. *   okHttp 请求免费行情接口(东方财富公开 JSON 接口，UTF-8，无需Key)
   
6. *   → 解析最新价/涨跌幅 → SQLite 入库(price_records 表)
   
7. *   → 采集结果逐条完整打印(由 LogBridge 打进 H5 终端,紫色主题,教学演示更漂亮)
   
8. *
   
9. * 与前面案例的本质区别：全程不找图、不点击、不依赖无障碍/代理模式，
   
10. * 也没有悬浮窗，是"网络API + 数据库 + 定时器"型自动化，手机放着后台长期跑即可。
    
11. *
    
12. * 这种采集方式的优势：
    
13. * 1. 行情数据持续落库，回看历史波动、做二次分析(均价/振幅/自选股排序)都方便；
    
14. * 2. 换 mysql 模式后数据进局域网/公网数据库，电脑、其他手机、后端 API 都能远程调用同一份数据；
    
15. * 3. 报警逻辑与采集分离：脚本只管采和存，规则改配置区数字即可，不用动逻辑。
    
16. */
    
17. 
    
18. // ========== 配置区(改这里) ==========
    
19. var 自选股列表 = [
    
20.     { secid: "1.601318", 名称: "中国平安" },   // 1=沪市 0=深市
    
21.     { secid: "1.600036", 名称: "招商银行" },
    
22.     { secid: "0.300750", 名称: "宁德时代" }
    
23. ];
    
24. var 采集间隔秒 = 30;            // 每 30 秒采一轮(录像教学用;长期挂机可改回 60)
    
25. var 报警涨跌阈值 = 2.0;         // |涨跌幅| >= 2% 触发报警(日志打 ⚠)
    
26. var SQLite路径 = "/sdcard/股票行情.db";
    
27. var 表名 = "price_records";
    
28. 
    
29. // ========== 全局变量顶部声明 ==========
    
30. var gStop = false;
    
31. var 数据库连接 = null;
    
32. var 数据库可用 = false;
    
33. var 累计入库条数 = 0;
    
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. // 建表(存在则跳过)：code/name/price/change_pct/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.             "code TEXT, name TEXT, price REAL, change_pct REAL, collected_at INTEGER)";
    
60.         数据库连接.execSQL(sql);
    
61.         printl("[DB] ✅ 表已就绪: " + 表名);
    
62.     } catch (e) {
    
63.         printl("[DB] ⚠ 建表失败: " + e);
    
64.         数据库可用 = false;
    
65.     }
    
66. }
    
67. 
    
68. // 单只股票一轮行情入库
    
69. function dbInsertQuote(code, name, price, changePct) {
    
70.     if (!数据库可用) return false;
    
71.     try {
    
72.         var stmt = 数据库连接.compileStatement("INSERT INTO " + 表名 +
    
73.             " (code, name, price, change_pct, collected_at) VALUES (?,?,?,?,?)");
    
74.         stmt.bindString(1, "" + code);
    
75.         stmt.bindString(2, "" + name);
    
76.         stmt.bindDouble(3, price);
    
77.         stmt.bindDouble(4, changePct);
    
78.         stmt.bindLong(5, time.nowStamp());   // nowStamp=毫秒数字;time.now()是格式化字符串不能bindLong
    
79.         stmt.executeInsert();
    
80.         stmt.close();
    
81.         return true;
    
82.     } catch (e) {
    
83.         printl("[DB] ❌ 入库失败: " + e);
    
84.         return false;
    
85.     }
    
86. }
    
87. 
    
88. function dbClose() {
    
89.     if (数据库可用 && 数据库连接 != null) {
    
90.         try { 数据库连接.close(); } catch (e) {}
    
91.         数据库连接 = null;
    
92.     }
    
93. }
    
94. 
    
95. // 拉取一轮行情：返回数组 [{code,名称,价格,涨跌幅}]，失败返回 null
    
96. function 拉取行情() {
    
97.     var secids = "";
    
98.     for (var i = 0; i < 自选股列表.length; i++) {
    
99.         if (i > 0) secids = secids + ",";
    
100.         secids = secids + 自选股列表[i].secid;
     
101.     }
     
102.     var url = "http://push2.eastmoney.com/api/qt/ulist.np/get?fltt=2&secids=" +
     
103.         secids + "&fields=f2,f3,f12,f14";
     
104. 
     
105.     try {
     
106.         printl("📡 正在请求行情接口(自选股 " + 自选股列表.length + " 只)...");
     
107.         var http = new okHttp();
     
108.         http.setTimeOut(5000, 8000, 5000);   // 必须设超时，防网络挂死(踩坑经验)
     
109.         printl("📡 等待接口返回(最长8秒)...");
     
110.         var text = "" + http.get(url);
     
111.         printl("📡 接口已返回,开始解析 JSON...");
     
112.         var obj = JSON.parse(text);
     
113.         if (!obj || !obj.data || !obj.data.diff) {
     
114.             printl("[API] ⚠ 接口无数据(可能停牌/休市字段为空): " + text.substring(0, 120));
     
115.             return null;
     
116.         }
     
117.         var diff = obj.data.diff;
     
118.         var 结果 = [];
     
119.         for (var j = 0; j < diff.length; j++) {
     
120.             var 项 = diff[j];
     
121.             var 价格 = parseFloat(项.f2);
     
122.             var 涨跌 = parseFloat(项.f3);
     
123.             if (isNaN(价格)) 价格 = 0;      // "-" 停牌时按 0 处理
     
124.             if (isNaN(涨跌)) 涨跌 = 0;
     
125.             结果.push({ code: "" + 项.f12, 名称: "" + 项.f14, 价格: 价格, 涨跌幅: 涨跌 });
     
126.         }
     
127.         printl("✅ 解析完成,共取到 " + 结果.length + " 只股票行情");
     
128.         return 结果;
     
129.     } catch (e) {
     
130.         printl("[API] ❌ 拉取失败: " + e);
     
131.         return null;
     
132.     }
     
133. }
     
134. 
     
135. // 逐条完整打印采集结果(演示用:代码/名称/现价/涨跌幅/涨跌方向)
     
136. function 打印采集结果(行情数组) {
     
137.     printl("📋 本轮采集结果(共 " + 行情数组.length + " 只):");
     
138.     for (var i = 0; i < 行情数组.length; i++) {
     
139.         var s = 行情数组[i];
     
140.         var 符号 = s.涨跌幅 >= 0 ? "+" : "";
     
141.         var 方向 = s.涨跌幅 > 0 ? "🔺涨" : (s.涨跌幅 < 0 ? "🔻跌" : "➖平");
     
142.         printl("   [" + (i + 1) + "] " + s.名称 + "(" + s.code + ") 现价 " +
     
143.             s.价格.toFixed(2) + " 元 涨跌幅 " + 符号 + s.涨跌幅.toFixed(2) + "% " + 方向);
     
144.     }
     
145. }
     
146. 
     
147. // 报警检查：任一股票 |涨跌幅| 超阈值就打 ⚠(与采集/打印分离,改阈值只动配置区)
     
148. function 检查报警(行情数组) {
     
149.     var 有报警 = false;
     
150.     for (var i = 0; i < 行情数组.length; i++) {
     
151.         var s = 行情数组[i];
     
152.         if (Math.abs(s.涨跌幅) >= 报警涨跌阈值) {
     
153.             有报警 = true;
     
154.             var 符号 = s.涨跌幅 >= 0 ? "+" : "";
     
155.             printl("⚠ 报警：" + s.名称 + "(" + s.code + ") 现价 " + s.价格.toFixed(2) +
     
156.                 " 涨跌幅 " + 符号 + s.涨跌幅.toFixed(2) + "% 超过阈值 " + 报警涨跌阈值 + "%");
     
157.         }
     
158.     }
     
159.     if (!有报警) {
     
160.         printl("🔕 报警检查:全部股票 |涨跌幅| < " + 报警涨跌阈值 + "%,无报警");
     
161.     }
     
162. }
     
163. 
     
164. // ========== 主流程 ==========
     
165. printl("===== 案例15 股票行情定时采集入库 启动 =====");
     
166. 
     
167. // 步骤0：连库建表
     
168. dbConnect();
     
169. dbEnsureTable();
     
170. printl("⚙ 配置:自选股 " + 自选股列表.length + " 只 · 采集间隔 " + 采集间隔秒 +
     
171.     " 秒 · 报警阈值 |涨跌幅| >= " + 报警涨跌阈值 + "%");
     
172. 
     
173. // 停止按钮清理(顺序：先置标志，stopAllRuning 放最后)
     
174. event.onStopBtnEvent(function () {
     
175.     gStop = true;
     
176.     dbClose();
     
177.     runTime.stopAllRuning();
     
178. });
     
179. 
     
180. // 步骤1：定时循环采集
     
181. var 轮次 = 0;
     
182. while (!gStop) {
     
183.     轮次++;
     
184.     printl("\n---- 第 " + 轮次 + " 轮采集 ----");
     
185. 
     
186.     var 行情数组 = 拉取行情();
     
187.     if (行情数组 != null && 行情数组.length > 0) {
     
188.         // 1) 逐条完整打印采集结果(演示重点:能看到每只股票的原始数据)
     
189.         打印采集结果(行情数组);
     
190. 
     
191.         // 2) 入库
     
192.         var 本轮入库 = 0;
     
193.         printl("💾 开始逐条写入数据库(表: " + 表名 + ")...");
     
194.         for (var k = 0; k < 行情数组.length; k++) {
     
195.             var q = 行情数组[k];
     
196.             if (dbInsertQuote(q.code, q.名称, q.价格, q.涨跌幅)) {
     
197.                 本轮入库++;
     
198.                 累计入库条数++;
     
199.                 printl("   ✓ 已入库 [" + 本轮入库 + "/" + 行情数组.length + "] " +
     
200.                     q.名称 + "(" + q.code + ") 现价 " + q.价格.toFixed(2) +
     
201.                     " 涨跌幅 " + q.涨跌幅.toFixed(2) + "%");
     
202.             } else {
     
203.                 printl("   ✗ 入库失败: " + q.名称 + "(" + q.code + ")");
     
204.             }
     
205.         }
     
206.         printl("[DB] 本轮入库 " + 本轮入库 + " 条 | 累计 " + 累计入库条数 + " 条 | 库文件: " + SQLite路径);
     
207. 
     
208.         // 3) 报警检查
     
209.         检查报警(行情数组);
     
210.     } else {
     
211.         printl("⚠ 本轮无数据，跳过入库(" + time.StampToTime(time.nowStamp()) + ")");
     
212.     }
     
213. 
     
214.     // 分片等待下一轮:每 5 秒打一条进度日志(画面不空,方便观察/录像)
     
215.     printl("⏳ 本轮全部完成," + 采集间隔秒 + " 秒后自动开始下一轮");
     
216.     var 剩余 = 采集间隔秒;
     
217.     while (剩余 > 0 && !gStop) {
     
218.         var 步长 = 剩余 >= 5 ? 5 : 剩余;
     
219.         printl("⏳ 等待下一轮...剩余 " + 剩余 + " 秒(期间脚本在待机,到点自动拉行情→入库)");
     
220.         sleep.second(秒 = 步长);
     
221.         剩余 = 剩余 - 步长;
     
222.     }
     
223. }
     
224. 
     
225. dbClose();
     
226. printl("===== 流程结束：共 " + 轮次 + " 轮，累计入库 " + 累计入库条数 + " 条 =====");
     

复制代码