B2B网络软件

标题: 日志分级落盘配置持久化任务调度 [打印本页]

---

作者: YYPOST群发软件    时间: 1 小时前
标题: 日志分级落盘配置持久化任务调度

日志分级落盘配置持久化任务调度

1. // =====================================================================
   
2. //  例子5：日志分级落盘 + 配置持久化 + 任务调度（真机可直接运行）
   
3. //  作用：把脚本从"能跑"升级到"能长期跑、出问题能查"——
   
4. //        · 日志分级 + 自动分卷，跑一晚上也不会把文件撑爆
   
5. //        · 配置写文件，杀掉脚本重开还能接着上次的参数跑
   
6. //        · 定时启动、限时结束、轮次休息、优雅停止（随时刹车不丢数据）
   
7. //        · 统计上报：成功/失败计数 + 断网缓存补报
   
8. //  引擎：ES5 / Rhino
   
9. // =====================================================================
   
10. 
    
11. // ---------------- 一、路径与配置 ----------------
    
12. var BASE = "/sdcard/AIWROK/技巧5_任务调度";
    
13. var LOG_DIR = BASE + "/日志";
    
14. var CONF_FILE = BASE + "/配置.ini";
    
15. var QUEUE_FILE = BASE + "/待上报队列.txt";
    
16. var STAT_FILE = BASE + "/统计.txt";
    
17. var STOP_FILE = "/sdcard/AIWROK/STOP_ALL";   // 建这个文件 = 优雅停止
    
18. var PAUSE_FILE = BASE + "/PAUSE";            // 建这个文件 = 暂停
    
19. 
    
20. var CFG = {
    
21.     // 定时任务：到点才开工（24小时制，如 "09:30"）；留空 = 立即开始
    
22.     startTime: "",
    
23.     // 限时：最多跑多少分钟，到点自动收工（防跑一夜）
    
24.     maxMinutes: 2,
    
25.     // 轮次：总共跑几轮，每轮之间休息多少秒
    
26.     rounds: 5,
    
27.     restMinSec: 5,
    
28.     restMaxSec: 12,
    
29.     // 日志分卷：单个日志文件超过多少行就切新文件
    
30.     logMaxLines: 200,
    
31.     // 上报地址（没有服务器就留空，脚本会自动跳过上报）
    
32.     reportUrl: "",
    
33.     deviceTag: "",
    
34.     // 目标APP：快手（刷视频）
    
35.     targetPkg: "com.smile.gifmaker",
    
36.     // 短视频翻页参数：必须一次完整快速长滑，分段曲线只会导致画面抖动不翻页
    
37.     videoSwipeMinMs: 220,
    
38.     videoSwipeMaxMs: 380,
    
39.     stayMinMs: 2000,        // 每轮看完视频停留
    
40.     stayMaxMs: 5000,
    
41.     verifySwipe: true,      // 翻页后截图比对，确认真的换了视频
    
42.     finishGoHome: false     // 跑完停在快手，不回桌面
    
43. };
    
44. 
    
45. function rand(a, b) { return Math.floor(a + Math.random() * (b - a + 1)); }
    
46. function rSleep(a, b) { sleep.millisecond(rand(a, b)); }
    
47. function dirOf(p) { var i = p.lastIndexOf("/"); return i > 0 ? p.substring(0, i) : p; }
    
48. 
    
49. // 返回键多通道：实测部分设备 auto 对象没有 pressBack
    
50. function pressBackSafe() {
    
51.     try { if (auto.back) { auto.back(); return true; } } catch (e) {}
    
52.     try { if (device.pressBack) { device.pressBack(); return true; } } catch (e) {}
    
53.     try { if (gesture.back) { gesture.back(); return true; } } catch (e) {}
    
54.     try { if (auto.pressBack) { auto.pressBack(); return true; } } catch (e) {}
    
55.     return false;
    
56. }
    
57. function ts() {
    
58.     try { return time.now(); } catch (e) {
    
59.         var d = new Date();
    
60.         return d.getFullYear() + "-" + (d.getMonth() + 1) + "-" + d.getDate() + " " + d.getHours() + ":" + d.getMinutes() + ":" + d.getSeconds();
    
61.     }
    
62. }
    
63. 
    
64. // ---------------- 二、日志系统 ----------------
    
65. var LOG_BUF = [];
    
66. var LOG_LINES = 0;
    
67. var LOG_NOW = "";
    
68. 
    
69. function ensureDirs() {
    
70.     try { file.createFloder(BASE); } catch (e) {}
    
71.     try { file.createFloder(LOG_DIR); } catch (e) {}
    
72. }
    
73. 
    
74. function flushLog(force) {
    
75.     if (LOG_BUF.length === 0) return;
    
76.     if (!force && LOG_BUF.length < 5) return; // 攒够再写，减少 IO
    
77.     try {
    
78.         if (!LOG_NOW) LOG_NOW = LOG_DIR + "/run_" + new Date().getTime() + ".log";
    
79.         txt.writeTxt(LOG_NOW, LOG_BUF.join("\n") + "\n", true);
    
80.         LOG_BUF = [];
    
81.     } catch (e) {}
    
82. }
    
83. 
    
84. // 分级日志：D 调试 / I 信息 / W 警告 / E 错误
    
85. function logD(s) { writeLog("D", s); }
    
86. function logI(s) { writeLog("I", s); }
    
87. function logW(s) { writeLog("W", s); }
    
88. function logE(s) { writeLog("E", s); }
    
89. 
    
90. function writeLog(level, s) {
    
91.     var line = ts() + " [" + level + "] " + s;
    
92.     try { printl(line); } catch (e) {}
    
93.     LOG_BUF.push(line);
    
94.     LOG_LINES++;
    
95.     // 分卷：超过上限就换新文件（长期跑的必备）
    
96.     if (LOG_LINES >= CFG.logMaxLines) {
    
97.         flushLog(true);
    
98.         LOG_LINES = 0;
    
99.         LOG_NOW = LOG_DIR + "/run_" + new Date().getTime() + ".log";
    
100.         logI("日志分卷，新文件: " + LOG_NOW);
     
101.     } else {
     
102.         flushLog(false);
     
103.     }
     
104. }
     
105. 
     
106. // ---------------- 三、配置持久化 ----------------
     
107. // 技巧：config 读写会自动建文件；读的时候一定给默认值，防止首次运行取到空
     
108. function saveConfig() {
     
109.     try {
     
110.         config.setConfig(CONF_FILE, "rounds", "" + CFG.rounds);
     
111.         config.setConfig(CONF_FILE, "maxMinutes", "" + CFG.maxMinutes);
     
112.         config.setConfig(CONF_FILE, "startTime", CFG.startTime);
     
113.         // 注意：targetPkg 不写入配置！否则上次跑的设置页会被记住，
     
114.         // 下次把代码改成快手也会被旧配置覆盖回去（已实测踩坑）
     
115.         config.setConfig(CONF_FILE, "lastRun", ts());
     
116.         config.setConfig(CONF_FILE, "runTimes", "" + (parseInt(getConf("runTimes", "0"), 10) + 1));
     
117.         logI("配置已保存: " + CONF_FILE);
     
118.     } catch (e) { logW("配置保存失败: " + (e.message || e)); }
     
119. }
     
120. 
     
121. function getConf(key, defVal) {
     
122.     try {
     
123.         var v = config.getConfig(CONF_FILE, key, defVal);
     
124.         if (v === null || v === undefined || v === "") return defVal;
     
125.         return v;
     
126.     } catch (e) { return defVal; }
     
127. }
     
128. 
     
129. function loadConfig() {
     
130.     try {
     
131.         CFG.rounds = parseInt(getConf("rounds", "" + CFG.rounds), 10);
     
132.         CFG.maxMinutes = parseInt(getConf("maxMinutes", "" + CFG.maxMinutes), 10);
     
133.         CFG.startTime = getConf("startTime", CFG.startTime);
     
134.         // targetPkg 一律以代码里的为准，绝不被旧配置覆盖
     
135.         // （历史配置里存过 com.android.settings，导致改成快手后仍打开设置页）
     
136.         logI("配置已加载，历史运行次数=" + getConf("runTimes", "0"));
     
137.     } catch (e) {}
     
138. }
     
139. 
     
140. function resetConfig() {
     
141.     try { file.delete(CONF_FILE); logI("配置已重置"); } catch (e) {}
     
142. }
     
143. 
     
144. // ---------------- 四、优雅停止 / 暂停 ----------------
     
145. function shouldStop() { try { return file.isExists(STOP_FILE); } catch (e) { return false; } }
     
146. function shouldPause() { try { return file.isExists(PAUSE_FILE); } catch (e) { return false; } }
     
147. 
     
148. // 暂停时原地打转，删掉 PAUSE 文件就继续（调试脚本神器）
     
149. function waitIfPaused() {
     
150.     var guard = 0;
     
151.     while (shouldPause() && !shouldStop() && guard < 600) {
     
152.         if (guard === 0) logW("已暂停（删除 " + PAUSE_FILE + " 继续）");
     
153.         sleep.millisecond(1000);
     
154.         guard++;
     
155.     }
     
156.     if (guard > 0) logI("恢复运行");
     
157. }
     
158. 
     
159. // ---------------- 五、定时任务 ----------------
     
160. // 等到 startTime 才开工；返回 false 表示被停止
     
161. function waitForStartTime() {
     
162.     // 配置文件可能读回空白字符，统一清洗后再判断，避免空值误触发定时等待
     
163.     try { CFG.startTime = String(CFG.startTime || "").replace(/\s/g, ""); } catch (e) { CFG.startTime = ""; }
     
164.     if (!CFG.startTime) return true;
     
165.     logI("定时模式，等待到 " + CFG.startTime + " 开工");
     
166.     var guard = 0;
     
167.     while (guard < 3600 * 12) { // 最多等 12 小时
     
168.         if (shouldStop()) return false;
     
169.         var now = "";
     
170.         try { now = time.now(); } catch (e) { now = ""; }
     
171.         // time.now() 一般形如 2026-09-09 09:30:12，取中间 hh:mm
     
172.         var hm = now.substring(11, 16);
     
173.         if (now.indexOf(CFG.startTime) >= 0 || hm === CFG.startTime) {
     
174.             logI("到点开工");
     
175.             return true;
     
176.         }
     
177.         if (guard % 300 === 0) logD("等待中，当前 " + now);
     
178.         sleep.millisecond(1000);
     
179.         guard++;
     
180.     }
     
181.     return true;
     
182. }
     
183. 
     
184. // ---------------- 六、统计与上报 ----------------
     
185. var STAT = { ok: 0, fail: 0, skip: 0, startMs: 0 };
     
186. 
     
187. function statAdd(key) {
     
188.     if (key === "ok") STAT.ok++;
     
189.     else if (key === "fail") STAT.fail++;
     
190.     else STAT.skip++;
     
191. }
     
192. 
     
193. // 上报：有网直接发，没网写队列，等有网再补报（防止数据丢）
     
194. function reportLine(obj) {
     
195.     if (!CFG.reportUrl) return; // 没配地址就直接跳过
     
196.     var body = "";
     
197.     try { body = JSON.stringify(obj); } catch (e) { body = "" + obj; }
     
198.     try {
     
199.         var r = http.json(CFG.reportUrl, body);
     
200.         if (r) { logD("上报成功"); return; }
     
201.         throw new Error("空响应");
     
202.     } catch (e) {
     
203.         logW("上报失败，入队缓存: " + (e.message || e));
     
204.         try { txt.writeTxt(QUEUE_FILE, body + "\n", true); } catch (e2) {}
     
205.     }
     
206. }
     
207. 
     
208. // 补报队列（联网后调用一次即可）
     
209. function flushQueue() {
     
210.     if (!CFG.reportUrl) return;
     
211.     var content = "";
     
212.     try { content = txt.readFileSdcard(QUEUE_FILE); } catch (e) { return; }
     
213.     if (!content) return;
     
214.     var lines = content.split("\n");
     
215.     var left = [];
     
216.     for (var i = 0; i < lines.length; i++) {
     
217.         var ln = lines[i];
     
218.         if (!ln) continue;
     
219.         try {
     
220.             http.json(CFG.reportUrl, ln);
     
221.             logI("补报成功一条");
     
222.         } catch (e) {
     
223.             left.push(ln);
     
224.         }
     
225.     }
     
226.     try {
     
227.         file.delete(QUEUE_FILE);
     
228.         if (left.length > 0) txt.writeTxt(QUEUE_FILE, left.join("\n") + "\n", true);
     
229.         logI("补报完成，剩余 " + left.length + " 条");
     
230.     } catch (e) {}
     
231. }
     
232. 
     
233. function saveStat() {
     
234.     var s = "开始:" + ts() + " 成功:" + STAT.ok + " 失败:" + STAT.fail +
     
235.             " 跳过:" + STAT.skip + " 耗时(分):" +
     
236.             Math.round((new Date().getTime() - STAT.startMs) / 60000);
     
237.     try { txt.writeTxt(STAT_FILE, s + "\n", true); } catch (e) {}
     
238.     logI("统计: " + s);
     
239. }
     
240. 
     
241. // ---------------- 六点五、快手刷视频相关工具 ----------------
     
242. function sw() { try { return screen.getScreenWidth(); } catch (e) { return 1080; } }
     
243. function sh() { try { return screen.getScreenHeight(); } catch (e) { return 1920; } }
     
244. 
     
245. // 前台包名多通道（该设备 getTopPackName 会返回空）
     
246. function topPkg() {
     
247.     try { var t1 = app.getTopPackName(); if (t1) return t1; } catch (e) {}
     
248.     try { var t2 = app.getTopPackNameV2(); if (t2) return t2; } catch (e) {}
     
249.     try { var t3 = auto.getTopPackName(); if (t3) return t3; } catch (e) {}
     
250.     var act = "";
     
251.     try { act = "" + app.getCurrentActivity(); } catch (e) {
     
252.         try { act = "" + app.getAgentCurrenAcitvity(); } catch (e2) { act = ""; }
     
253.     }
     
254.     if (act && act.indexOf("/") > 0) return act.substring(0, act.indexOf("/"));
     
255.     return act || "";
     
256. }
     
257. 
     
258. function isInstalled(pkg) {
     
259.     try { var v = app.getVerName(pkg); if (v) return true; } catch (e) {}
     
260.     try { var n = app.getAppName(pkg); if (n) return true; } catch (e) {}
     
261.     return false;
     
262. }
     
263. 
     
264. // 确保快手在前台，不在就拉起来
     
265. var _launched = false;
     
266. function ensureForeground() {
     
267.     var top = topPkg();
     
268.     if (top === CFG.targetPkg) { _launched = true; return true; }
     
269.     // 该设备前台API取不到包名时不要每轮重启APP：只保证首轮拉起过即可
     
270.     if (!top && _launched) return true;
     
271.     logI("拉起快手（当前前台=" + (top || "空") + "）");
     
272.     try { app.openApp(CFG.targetPkg); } catch (e) {
     
273.         try { app.startApp(CFG.targetPkg); } catch (e2) {}
     
274.     }
     
275.     sleep.millisecond(4000);
     
276.     _launched = true;
     
277.     return true;
     
278. }
     
279. 
     
280. // 短视频翻页：一次完整快速长滑（不能分段，否则只抖不翻）
     
281. function onceSwipe(x1, y1, x2, y2, durMs) {
     
282.     try { auto.swip(x1, y1, x2, y2, durMs, 0); }
     
283.     catch (e) { try { auto.swipe(x1, y1, x2, y2, durMs); } catch (e2) {} }
     
284. }
     
285. 
     
286. function shotFingerprint() {
     
287.     try {
     
288.         var b = screen.screenShotFull().toBase64();
     
289.         if (!b) return "";
     
290.         return b.substring(0, 200) + "|" + b.substring(b.length - 200) + "|" + b.length;
     
291.     } catch (e) { return ""; }
     
292. }
     
293. 
     
294. // 返回 true = 确认翻到新视频
     
295. function swipeUpWithVerify() {
     
296.     var before = shotFingerprint();
     
297.     var w = sw(), h = sh();
     
298.     var x = rand(Math.round(w * 0.35), Math.round(w * 0.65));
     
299.     var y1 = Math.round(h * (0.78 + Math.random() * 0.07));
     
300.     var y2 = Math.round(h * (0.12 + Math.random() * 0.08));
     
301.     var dur = rand(CFG.videoSwipeMinMs, CFG.videoSwipeMaxMs);
     
302.     onceSwipe(x, y1, x + rand(-12, 12), y2, dur);
     
303.     logI("翻页上滑 起点y=" + y1 + " 终点y=" + y2 + " 距离" + (y1 - y2) + "px 耗时" + dur + "ms");
     
304.     sleep.millisecond(700);
     
305.     var after = shotFingerprint();
     
306.     if (before && after && before === after) {
     
307.         logW("画面无变化，补一次强滑");
     
308.         onceSwipe(Math.round(w / 2), Math.round(h * 0.88), Math.round(w / 2), Math.round(h * 0.08), 250);
     
309.         sleep.millisecond(900);
     
310.         var after2 = shotFingerprint();
     
311.         return after2 && after2 !== before;
     
312.     }
     
313.     return true;
     
314. }
     
315. 
     
316. // ---------------- 七、业务任务：快手刷视频一轮 ----------------
     
317. function doOneRound(idx) {
     
318.     logI("---- 第 " + idx + " 轮开始 ----");
     
319. 
     
320.     ensureForeground();
     
321. 
     
322.     // 翻页（带校验）
     
323.     var ok;
     
324.     if (CFG.verifySwipe) ok = swipeUpWithVerify();
     
325.     else { swipeUpWithVerify(); ok = true; }
     
326. 
     
327.     if (ok) { statAdd("ok"); logI("本轮结果: 翻页成功"); }
     
328.     else { statAdd("fail"); logW("本轮结果: 翻页失败"); }
     
329. 
     
330.     // 停留观看（分段 sleep，随时能响应停止信号）
     
331.     var stay = rand(CFG.stayMinMs, CFG.stayMaxMs);
     
332.     logI("停留观看 " + stay + "ms");
     
333.     var secs = Math.round(stay / 1000);
     
334.     for (var s = 0; s < secs; s++) {
     
335.         if (shouldStop()) break;
     
336.         sleep.millisecond(1000);
     
337.     }
     
338. 
     
339.     logI("---- 第 " + idx + " 轮结束 ----");
     
340. }
     
341. 
     
342. // ---------------- 八、调度主循环 ----------------
     
343. function main() {
     
344.     ensureDirs();
     
345.     logI("===== 例子5 日志配置与任务调度 开始 =====");
     
346. 
     
347.     // 1) 读配置（第二次运行会沿用上次的参数）
     
348.     loadConfig();
     
349. 
     
350.     // 2) 设备标识
     
351.     try { CFG.deviceTag = "" + device.getModel(); } catch (e) { CFG.deviceTag = "未知设备"; }
     
352.     logI("设备: " + CFG.deviceTag);
     
353. 
     
354.     // 3) 目标APP检查 + 启动
     
355.     var vName = "", aName = "";
     
356.     try { vName = app.getVerName(CFG.targetPkg); } catch (e) {}
     
357.     try { aName = app.getAppName(CFG.targetPkg); } catch (e) {}
     
358.     logI("目标APP: " + CFG.targetPkg + " 应用名=" + (aName || "取不到") + " 版本=" + (vName || "取不到"));
     
359.     if (!isInstalled(CFG.targetPkg)) logW("安装检测未确认（可能误报），仍尝试启动");
     
360.     ensureForeground();
     
361. 
     
362.     // 4) 定时等待
     
363.     if (!waitForStartTime()) { logW("等待期间被停止"); return; }
     
364. 
     
365.     STAT.startMs = new Date().getTime();
     
366.     var deadline = STAT.startMs + CFG.maxMinutes * 60 * 1000;
     
367. 
     
368.     // 4) 主循环：轮次 + 限时 + 停止/暂停
     
369.     for (var i = 1; i <= CFG.rounds; i++) {
     
370.         if (shouldStop()) { logW("检测到停止文件，提前收工"); break; }
     
371.         if (new Date().getTime() > deadline) { logW("到达限时，自动收工"); break; }
     
372. 
     
373.         waitIfPaused();
     
374.         if (shouldStop()) break;
     
375. 
     
376.         doOneRound(i);
     
377. 
     
378.         // 每轮上报一次
     
379.         reportLine({ device: CFG.deviceTag, round: i, ok: STAT.ok, fail: STAT.fail, time: ts() });
     
380.         saveConfig();
     
381. 
     
382.         // 轮次间休息（最后一轮不用休）
     
383.         if (i < CFG.rounds) {
     
384.             var rest = rand(CFG.restMinSec, CFG.restMaxSec);
     
385.             logI("休息 " + rest + " 秒");
     
386.             for (var s = 0; s < rest; s++) {
     
387.                 if (shouldStop()) break;
     
388.                 sleep.millisecond(1000);
     
389.             }
     
390.         }
     
391.     }
     
392. 
     
393.     // 5) 收尾：默认停在快手（刷视频不要回桌面）
     
394.     if (CFG.finishGoHome) {
     
395.         try { auto.home(); } catch (e) {}
     
396.         logI("已回桌面");
     
397.     } else {
     
398.         logI("收尾：停在 " + CFG.targetPkg + " 不退出");
     
399.     }
     
400. 
     
401.     // 6) 补报 + 统计落盘
     
402.     flushQueue();
     
403.     saveStat();
     
404.     flushLog(true);
     
405. 
     
406.     var msg = "调度结束 成功" + STAT.ok + " 失败" + STAT.fail;
     
407.     logI("===== " + msg + " =====");
     
408.     try { toast.show(msg); } catch (e) {}
     
409. }
     
410. 
     
411. main();
     

复制代码

---

欢迎光临 B2B网络软件 (http://bbs.niubt.cn/)

Powered by Discuz! X3.2