汇率监控/盯盘报汇率定时采集入库

群发软件

汇率监控/盯盘报汇率定时采集入库

1. /**
   
2. * 案例17：汇率定时采集入库(纯 printl 日志版,输出到 H5 日志终端)
   
3. *
   
4. * 经典实用案例"汇率监控/盯盘报警"，转换成 AIWROK 实现：
   
5. *   okHttp 请求 open.er-api.com 免费汇率接口(https 纯 JSON，无需注册、无需Key)
   
6. *   → 一次请求拿到全球160+币种对人民币的牌价 → 挑自选币种换算成"1外币=X元"
   
7. *   → SQLite 入库(rate_records 表) → 采集结果逐条完整打印到 H5 终端
   
8. *
   
9. * 案例15(股票)+案例16(天气)+案例17(汇率) 凑齐"API+数据库+定时器"监控三件套，
   
10. * 全程不找图、不点击、无悬浮窗，手机后台长期挂机即可。
    
11. *
    
12. * 选 er-api 接口的原因：
    
13. * 1. 完全免费、不用申请 Key，返回标准 JSON，最适合教学演示；
    
14. * 2. 一次请求返回所有币种(以人民币为基准)，本地挑币种换算，比逐币种请求省流量；
    
15. * 3. 官方免费档每天更新一次，教学演示够用；长期挂机建议间隔调大(如 3600 秒)。
    
16. *
    
17. * 新知识点(对比案例15/16)：
    
18. * - 接口返回的是"1元=多少外币"(USD 0.14)，演示里取倒数换算成"1外币=多少元"(7.14)，
    
19. *   这就是"数据加工"：入库前先按业务口径转换，回看时不用每次再算；
    
20. * - 报警从"绝对值差"升级为"百分比波动"：外币间波动率可比，绝对差价不可比。
    
21. */
    
22. 
    
23. // ========== 配置区(改这里) ==========
    
24. var 自选币种列表 = [
    
25.     { code: "USD", 名称: "美元" },
    
26.     { code: "EUR", 名称: "欧元" },
    
27.     { code: "JPY", 名称: "日元" },
    
28.     { code: "GBP", 名称: "英镑" },
    
29.     { code: "HKD", 名称: "港币" }
    
30. ];
    
31. var 采集间隔秒 = 30;            // 每 30 秒采一轮(录像教学用;该接口每日更新,长期挂机改 3600)
    
32. var 报警波动阈值 = 0.5;         // 与上一轮汇率波动 |百分比| >= 0.5% 触发报警
    
33. var SQLite路径 = "/sdcard/汇率监测.db";
    
34. var 表名 = "rate_records";
    
35. 
    
36. // ========== 全局变量顶部声明 ==========
    
37. var gStop = false;
    
38. var 数据库连接 = null;
    
39. var 数据库可用 = false;
    
40. var 累计入库条数 = 0;
    
41. var 上一轮汇率 = {};            // { "USD": 7.14, ... } 首轮为空对象,不报波动
    
42. 
    
43. // ========== importClass 只能放最外层 ==========
    
44. importClass(android.database.sqlite.SQLiteDatabase);
    
45. importClass(java.io.File);
    
46. 
    
47. // ========== 工具函数(先定义后调用) ==========
    
48. 
    
49. // 连接 SQLite(零配置；如需远程库可仿照案例14扩展 mysql 分支)
    
50. function dbConnect() {
    
51.     try {
    
52.         数据库连接 = SQLiteDatabase.openOrCreateDatabase(new File(SQLite路径), null);
    
53.         数据库可用 = true;
    
54.         printl("[DB] ✅ SQLite 已打开: " + SQLite路径);
    
55.     } catch (e) {
    
56.         数据库可用 = false;
    
57.         printl("[DB] ⚠ 打开失败(本轮只打印不入库): " + e);
    
58.     }
    
59. }
    
60. 
    
61. // 建表(存在则跳过)：code/name/rate_cny/collected_at
    
62. function dbEnsureTable() {
    
63.     if (!数据库可用) return;
    
64.     try {
    
65.         var sql = "CREATE TABLE IF NOT EXISTS " + 表名 + " (" +
    
66.             "id INTEGER PRIMARY KEY AUTOINCREMENT," +
    
67.             "code TEXT, name TEXT, rate_cny REAL, collected_at INTEGER)";
    
68.         数据库连接.execSQL(sql);
    
69.         printl("[DB] ✅ 表已就绪: " + 表名);
    
70.     } catch (e) {
    
71.         printl("[DB] ⚠ 建表失败: " + e);
    
72.         数据库可用 = false;
    
73.     }
    
74. }
    
75. 
    
76. // 单币种一轮汇率入库(rateCny = 1单位外币合多少人民币)
    
77. function dbInsertRate(code, name, rateCny) {
    
78.     if (!数据库可用) return false;
    
79.     try {
    
80.         var stmt = 数据库连接.compileStatement("INSERT INTO " + 表名 +
    
81.             " (code, name, rate_cny, collected_at) VALUES (?,?,?,?)");
    
82.         stmt.bindString(1, "" + code);
    
83.         stmt.bindString(2, "" + name);
    
84.         stmt.bindDouble(3, rateCny);
    
85.         stmt.bindLong(4, time.nowStamp());   // nowStamp=毫秒数字;time.now()是格式化字符串不能bindLong
    
86.         stmt.executeInsert();
    
87.         stmt.close();
    
88.         return true;
    
89.     } catch (e) {
    
90.         printl("[DB] ❌ 入库失败: " + e);
    
91.         return false;
    
92.     }
    
93. }
    
94. 
    
95. function dbClose() {
    
96.     if (数据库可用 && 数据库连接 != null) {
    
97.         try { 数据库连接.close(); } catch (e) {}
    
98.         数据库连接 = null;
    
99.     }
    
100. }
     
101. 
     
102. // 拉取一轮汇率：一次请求拿全部币种,返回数组 [{code,名称,汇率(1外币=X元)}]，失败返回 null
     
103. function 拉取汇率() {
     
104.     var url = "https://open.er-api.com/v6/latest/CNY";   // 以人民币为基准,一次拿全球币种
     
105. 
     
106.     try {
     
107.         printl("📡 正在请求汇率接口(基准 CNY,自选币种 " + 自选币种列表.length + " 个)...");
     
108.         var http = new okHttp();
     
109.         http.setTimeOut(5000, 8000, 5000);   // 必须设超时，防网络挂死(踩坑经验)
     
110.         printl("📡 等待接口返回(最长8秒)...");
     
111.         var text = "" + http.get(url);
     
112.         printl("📡 接口已返回,开始解析 JSON...");
     
113.         var obj = JSON.parse(text);
     
114.         if (!obj || obj.result !== "success" || !obj.rates) {
     
115.             printl("[API] ⚠ 接口异常: " + text.substring(0, 120));
     
116.             return null;
     
117.         }
     
118.         var 结果 = [];
     
119.         for (var i = 0; i < 自选币种列表.length; i++) {
     
120.             var 币 = 自选币种列表[i];
     
121.             var 正向 = parseFloat(obj.rates[币.code]);   // 1元人民币 = 正向 个外币
     
122.             if (isNaN(正向) || 正向 <= 0) {
     
123.                 printl("⚠ 接口无 " + 币.名称 + "(" + 币.code + ") 牌价,跳过");
     
124.                 continue;
     
125.             }
     
126.             var 反向 = 1 / 正向;                          // 1个外币 = 反向 元人民币(入库口径)
     
127.             结果.push({ code: 币.code, 名称: 币.名称, 汇率: 反向 });
     
128.         }
     
129.         printl("✅ 解析完成,共取到 " + 结果.length + " 个币种汇率(牌价更新时间: " +
     
130.             obj.time_last_update_utc + ")");
     
131.         return 结果;
     
132.     } catch (e) {
     
133.         printl("[API] ❌ 拉取失败: " + e);
     
134.         return null;
     
135.     }
     
136. }
     
137. 
     
138. // 逐条完整打印采集结果(演示用:每个币种的正向/反向牌价都打出来)
     
139. function 打印采集结果(汇率数组) {
     
140.     printl("📋 本轮采集结果(共 " + 汇率数组.length + " 个币种):");
     
141.     for (var i = 0; i < 汇率数组.length; i++) {
     
142.         var r = 汇率数组[i];
     
143.         printl("   [" + (i + 1) + "] " + r.名称 + "(" + r.code + ") 1 " + r.code +
     
144.             " = " + r.汇率.toFixed(4) + " 元  |  1 元 = " + (1 / r.汇率).toFixed(4) + " " + r.code);
     
145.     }
     
146. }
     
147. 
     
148. // 报警检查：与上一轮比波动百分比超阈值就打 ⚠(外币间波动率可比,不用绝对差)
     
149. function 检查报警(汇率数组) {
     
150.     var 有报警 = false;
     
151.     for (var i = 0; i < 汇率数组.length; i++) {
     
152.         var r = 汇率数组[i];
     
153.         var 旧值 = 上一轮汇率[r.code];
     
154.         if (旧值 != null && 旧值 > 0) {
     
155.             var 波动 = (r.汇率 - 旧值) / 旧值 * 100;
     
156.             if (Math.abs(波动) >= 报警波动阈值) {
     
157.                 有报警 = true;
     
158.                 var 符号 = 波动 >= 0 ? "+" : "";
     
159.                 printl("⚠ 报警：" + r.名称 + "(" + r.code + ") 波动 " + 符号 + 波动.toFixed(3) +
     
160.                     "%(" + 旧值.toFixed(4) + " → " + r.汇率.toFixed(4) + "),阈值 " + 报警波动阈值 + "%");
     
161.             }
     
162.         }
     
163.         上一轮汇率[r.code] = r.汇率;   // 记录本轮,供下一轮对比
     
164.     }
     
165.     if (!有报警) {
     
166.         printl("🔕 报警检查:全部币种波动 |百分比| < " + 报警波动阈值 + "%,无报警(首轮无对比基准)");
     
167.     }
     
168. }
     
169. 
     
170. // ========== 主流程 ==========
     
171. printl("===== 案例17 汇率定时采集入库 启动 =====");
     
172. 
     
173. // 步骤0：连库建表
     
174. dbConnect();
     
175. dbEnsureTable();
     
176. printl("⚙ 配置:自选币种 " + 自选币种列表.length + " 个 · 采集间隔 " + 采集间隔秒 +
     
177.     " 秒 · 报警阈值 波动 >= " + 报警波动阈值 + "%");
     
178. 
     
179. // 停止按钮清理(顺序：先置标志，stopAllRuning 放最后)
     
180. event.onStopBtnEvent(function () {
     
181.     gStop = true;
     
182.     dbClose();
     
183.     runTime.stopAllRuning();
     
184. });
     
185. 
     
186. // 步骤1：定时循环采集
     
187. var 轮次 = 0;
     
188. while (!gStop) {
     
189.     轮次++;
     
190.     printl("\n---- 第 " + 轮次 + " 轮采集 ----");
     
191. 
     
192.     var 汇率数组 = 拉取汇率();
     
193.     if (汇率数组 != null && 汇率数组.length > 0) {
     
194.         // 1) 逐条完整打印采集结果(演示重点:正反两个口径的牌价全打出来)
     
195.         打印采集结果(汇率数组);
     
196. 
     
197.         // 2) 入库
     
198.         var 本轮入库 = 0;
     
199.         printl("💾 开始逐条写入数据库(表: " + 表名 + ")...");
     
200.         for (var k = 0; k < 汇率数组.length; k++) {
     
201.             var q = 汇率数组[k];
     
202.             if (dbInsertRate(q.code, q.名称, q.汇率)) {
     
203.                 本轮入库++;
     
204.                 累计入库条数++;
     
205.                 printl("   ✓ 已入库 [" + 本轮入库 + "/" + 汇率数组.length + "] " +
     
206.                     q.名称 + "(" + q.code + ") 1 " + q.code + " = " + q.汇率.toFixed(4) + " 元");
     
207.             } else {
     
208.                 printl("   ✗ 入库失败: " + q.名称 + "(" + q.code + ")");
     
209.             }
     
210.         }
     
211.         printl("[DB] 本轮入库 " + 本轮入库 + " 条 | 累计 " + 累计入库条数 + " 条 | 库文件: " + SQLite路径);
     
212. 
     
213.         // 3) 报警检查
     
214.         检查报警(汇率数组);
     
215.     } else {
     
216.         printl("⚠ 本轮无数据，跳过入库(" + time.StampToTime(time.nowStamp()) + ")");
     
217.     }
     
218. 
     
219.     // 分片等待下一轮:每 5 秒打一条进度日志(画面不空,方便观察/录像)
     
220.     printl("⏳ 本轮全部完成," + 采集间隔秒 + " 秒后自动开始下一轮");
     
221.     var 剩余 = 采集间隔秒;
     
222.     while (剩余 > 0 && !gStop) {
     
223.         var 步长 = 剩余 >= 5 ? 5 : 剩余;
     
224.         printl("⏳ 等待下一轮...剩余 " + 剩余 + " 秒(期间脚本在待机,到点自动拉汇率→入库)");
     
225.         sleep.second(秒 = 步长);
     
226.         剩余 = 剩余 - 步长;
     
227.     }
     
228. }
     
229. 
     
230. dbClose();
     
231. printl("===== 流程结束：共 " + 轮次 + " 轮，累计入库 " + 累计入库条数 + " 条 =====");
     

复制代码