薇星幻海
1108 lines
92 KiB
JavaScript
1108 lines
92 KiB
JavaScript
/* YianLearningEngine: 读取网页实际目录、控制原生播放器并协调已授权的学习任务。 */
|
||
(function (root, factory) {
|
||
'use strict';
|
||
const api = factory(root);
|
||
if (typeof module === 'object' && module.exports) module.exports = api;
|
||
root.YianLearningEngine = api;
|
||
})(typeof window !== 'undefined' ? window : globalThis, function (root) {
|
||
'use strict';
|
||
|
||
const TERMINAL = ['completed', 'skipped', 'failed', 'expanded'];
|
||
const ACTIVE = ['loading', 'playing', 'quiz', 'answering', 'waitingSubmit', 'waitingLease', 'retrying'];
|
||
const MODES = ['video', 'videoQuiz', 'exam', 'all'];
|
||
const LEASE_MS = 18000;
|
||
const SESSION_KEY = 'session.v1';
|
||
const CONTROL_KEY = 'control.v1';
|
||
const POLICY_KEYS = ['manualConfirmIncomplete', 'autoContinuePlayback', 'resumePlaybackOnReturn', 'skipSingleAttemptQuiz'];
|
||
|
||
function clean(value) { return String(value == null ? '' : value).replace(/[\u200b-\u200d\ufeff]/g, '').replace(/\s+/g, ' ').trim(); }
|
||
function clone(value) { return JSON.parse(JSON.stringify(value)); }
|
||
function hash(value) { let h = 2166136261; for (const c of String(value)) { h ^= c.charCodeAt(0); h = Math.imul(h, 16777619); } return (h >>> 0).toString(36); }
|
||
function token() { return root.crypto && root.crypto.randomUUID ? root.crypto.randomUUID() : Date.now().toString(36) + Math.random().toString(36).slice(2); }
|
||
function safeURL(value, base) {
|
||
try { const url = new URL(value, base); return url.origin === 'http://10.119.67.7' && url.pathname.startsWith('/clientcn/') ? url : null; } catch (_) { return null; }
|
||
}
|
||
function canonical(value) { try { const u = new URL(value); u.hash = ''; return u.href; } catch (_) { return String(value || ''); } }
|
||
function examIdentity(value) {
|
||
try { const url = new URL(value); const match = url.pathname.match(/^\/clientcn\/(?:exam|examtest)\/([^/]+)(?:\/questions)?\/?$/); return match ? url.origin + ':exam:' + match[1] : ''; } catch (_) { return ''; }
|
||
}
|
||
function visible(node) {
|
||
if (!node || node.closest('[hidden],[aria-hidden="true"],.ant-modal-hidden')) return false;
|
||
for (let n = node; n && n.nodeType === 1; n = n.parentElement) {
|
||
if (n.style && (n.style.display === 'none' || n.style.visibility === 'hidden')) return false;
|
||
if (n.isConnected && n.ownerDocument.defaultView && n.ownerDocument.defaultView.getComputedStyle) {
|
||
const style = n.ownerDocument.defaultView.getComputedStyle(n);
|
||
if (style.display === 'none' || style.visibility === 'hidden') return false;
|
||
}
|
||
}
|
||
return true;
|
||
}
|
||
function textAt(doc, selectors) { for (const selector of selectors.split(',')) { const node = doc.querySelector(selector); if (node && clean(node.textContent)) return clean(node.textContent); } return ''; }
|
||
function number(value) { const n = Number(value); return Number.isFinite(n) && n >= 0 ? n : null; }
|
||
function seconds(value) {
|
||
const text = clean(value); let total = 0; let matched = false;
|
||
const clock = text.match(/(?:^|\s)(\d{1,3}):(\d{2})(?::(\d{2}))?(?:$|\s)/);
|
||
if (clock) return clock[3] == null ? Number(clock[1]) * 60 + Number(clock[2]) : Number(clock[1]) * 3600 + Number(clock[2]) * 60 + Number(clock[3]);
|
||
for (const entry of [[/(\d+(?:\.\d+)?)小时/, 3600], [/(\d+(?:\.\d+)?)分钟/, 60], [/(\d+(?:\.\d+)?)分(?!钟)/, 60], [/(\d+(?:\.\d+)?)秒/, 1]]) {
|
||
const m = text.match(entry[0]); if (m) { total += Number(m[1]) * entry[1]; matched = true; }
|
||
}
|
||
return matched ? total : null;
|
||
}
|
||
function nodeURL(node, url) {
|
||
const own = node.matches('[href],[data-task-url],[routerlink]') ? node : node.querySelector('a[href],[data-task-url],[routerlink]');
|
||
if (!own) return '';
|
||
const raw = own.getAttribute('href') || own.getAttribute('data-task-url') || own.getAttribute('routerlink');
|
||
if (!raw || /^(?:javascript:|#|\[|\{)/i.test(raw)) return '';
|
||
const resolved = safeURL(raw, url); return resolved ? resolved.href : '';
|
||
}
|
||
function isComplete(node) {
|
||
if (!node) return false;
|
||
if (node.matches('[data-is-learned="true"],[data-learned="true"],[data-completed="true"]')) return true;
|
||
if (node.querySelector('[data-is-learned="true"],[data-completed="true"]')) return true;
|
||
if (node.matches('.map_activity_content_info_completed') || node.querySelector('.map_activity_content_info_completed')) return true;
|
||
// 原站未完成图标也含 en_courseware_finished，必须排除 noFinished。
|
||
if (Array.from(node.querySelectorAll('.en_courseware_finished')).some(n => !n.classList.contains('en_courseware_noFinished'))) return true;
|
||
const explicit = node.querySelector('[data-learning-status],.courseware_finished_status,.learning-status');
|
||
return Boolean(explicit && /^(?:已完成|学习完成|已学完|完成)$/.test(clean(explicit.textContent)));
|
||
}
|
||
function titleOf(doc) {
|
||
const exact = textAt(doc, '[data-course-title],.course-courseware-other-top-left');
|
||
if (exact) return exact;
|
||
const header = doc.querySelector('.pc_course_left_top_header');
|
||
if (header) {
|
||
const copy = header.cloneNode(true); copy.querySelectorAll('.pc_course_left_top_header_info,.course-courseware,.course-courseware-playdefult').forEach(n => n.remove());
|
||
const title = clean(copy.textContent).replace(/(?:学习时长|发布时间|学习计划)[\s\S]*$/, '').trim(); if (title) return title;
|
||
}
|
||
const exam = doc.querySelector('.examdetail_header');
|
||
if (exam) return clean(exam.textContent).split(/已答|正确率|得分[：:]/)[0].trim();
|
||
return textAt(doc, '[data-course-title],.pc_examtest_title,.top_map_title,h1') || clean(doc.title) || '未命名任务';
|
||
}
|
||
function quizOf(doc) {
|
||
const portal = Array.from(doc.querySelectorAll('.question-modal-pc .question_box,.question-modal-pc .answer_box')).find(visible);
|
||
if (portal) return portal.closest('.question-modal-pc');
|
||
return Array.from(doc.querySelectorAll('app-question-modal,[data-learning-quiz]')).find(node => visible(node) && Boolean(node.querySelector('.pc_examtest_content,[app-exam-question],input[type="radio"],input[type="checkbox"],[data-question],.question-content,.question_content') || clean(node.textContent))) || null;
|
||
}
|
||
function playbackPromptOf(doc) {
|
||
// 原站 ngx-bootstrap 将模板放在 body portal，app-dialog-box 自身可能为空。
|
||
const bodies = Array.from(doc.querySelectorAll('.modal-dialog.dialog_box .modal-body,[role="dialog"] .modal-body'))
|
||
.filter(node => visible(node) && /^是否继续上次播放的位置[？?]$/.test(clean(node.textContent)));
|
||
const candidates = [];
|
||
for (const body of bodies) {
|
||
const container = body.closest('.modal-content,[role="dialog"]'); if (!container) continue;
|
||
if (candidates.some(item => item.container === container)) continue;
|
||
const buttons = Array.from(container.querySelectorAll('.modal-footer button')).filter(node => visible(node) && !node.disabled && node.getAttribute('aria-disabled') !== 'true');
|
||
const keep = buttons.filter(node => clean(node.textContent) === '继续播放');
|
||
const restart = buttons.filter(node => clean(node.textContent) === '重新开始');
|
||
candidates.push({ container, body, button: keep.length === 1 && restart.length === 1 ? keep[0] : null });
|
||
}
|
||
return candidates.length ? candidates.length === 1 ? candidates[0] : { ambiguous: true } : null;
|
||
}
|
||
function courseCoverOf(doc) {
|
||
const buttons = Array.from(doc.querySelectorAll('app-course .course-courseware-playdefult > span'))
|
||
.filter(node => visible(node) && clean(node.textContent) === '开始学习' && !node.matches('[disabled],[aria-disabled="true"]'));
|
||
return buttons.length === 1 ? buttons[0] : null;
|
||
}
|
||
function completionRequirements(text) {
|
||
text = clean(text);
|
||
const time = text.match(/观看课件时长达到\s*([\d.\s小时分钟秒]+)/);
|
||
const progress = text.match(/观看视频进度\s*(\d+(?:\.\d+)?)\s*%/);
|
||
if (!time && !progress) return null;
|
||
return { text: text.slice(0, 500), requiredSeconds: time ? seconds(time[1]) : null,
|
||
requiredProgress: progress && Number(progress[1]) <= 100 ? Number(progress[1]) : null,
|
||
requiresExam: /完成考试答题/.test(text), requiresPass: /及格通过/.test(text) };
|
||
}
|
||
function describePage(doc, url) {
|
||
const current = canonical(url || doc.URL);
|
||
const video = Array.from(doc.querySelectorAll('app-course-courseware-video video,app-video-base video,video[data-learning-video],video')).find(visible) || null;
|
||
const kind = doc.querySelector('app-examtest') ? 'paper' : video ? 'video' : doc.querySelector('app-examdetail') ? 'exam' : doc.querySelector('app-learning-map-activity-list') ? 'map' : doc.querySelector('app-course') ? 'course' : 'unknown';
|
||
const active = doc.querySelector('.cn_courseware_img.active,[data-courseware-id][aria-current="true"]');
|
||
const explicit = doc.querySelector('[data-account-id]');
|
||
return { kind, url: current, title: titleOf(doc), accountId: explicit ? clean(explicit.getAttribute('data-account-id')) : '',
|
||
coursewareTitle: active ? clean((active.querySelector('p') || active).textContent) : '',
|
||
video, activeCourseware: active, quiz: quizOf(doc), platformComplete: isComplete(active) || Boolean(doc.querySelector('app-course-courseware-video[data-is-learned="true"]')),
|
||
learnedSeconds: active ? seconds(clean((active.querySelector('.menu_courseware_left') || active).textContent)) : null,
|
||
requiredSeconds: active && active.hasAttribute('data-required-seconds') ? number(active.getAttribute('data-required-seconds')) : null,
|
||
hidden: doc.visibilityState === 'hidden' };
|
||
}
|
||
function discoverTasks(doc, url) {
|
||
const page = describePage(doc, url); const tasks = []; const seen = new Set();
|
||
function add(node, kind, selector, index, parentId, subIndex) {
|
||
const explicitId = node.getAttribute('data-task-id') || node.getAttribute('data-courseware-id') || node.getAttribute('data-course-id') || node.getAttribute('data-exam-id') || node.id;
|
||
const targetURL = nodeURL(node, page.url);
|
||
let title = clean((node.querySelector('.activity_name,p,[data-task-title]') || node).textContent);
|
||
if (node.matches('.cn_courseware_img')) title = clean((node.querySelector(':scope > p') || node.querySelector('p') || node).textContent);
|
||
const identity = targetURL ? canonical(targetURL) : explicitId ? page.url + ':' + explicitId : page.url + ':' + selector + ':' + index + (subIndex > 0 ? ':exam:' + subIndex : '');
|
||
const id = kind + ':' + hash(identity); if (seen.has(id)) return;
|
||
seen.add(id);
|
||
const locked = node.matches('[disabled],[aria-disabled="true"],[data-locked="true"],.locked') || Boolean(node.querySelector('[data-locked="true"]'));
|
||
tasks.push({ id, kind, title: title || kind, url: targetURL, pageUrl: page.url, selector, index, identity: explicitId || '', parentId: parentId || '',
|
||
status: isComplete(node) ? 'completed' : locked ? 'waiting' : 'pending', reason: locked ? '网站尚未开放此任务，等待前置条件' : '',
|
||
progress: isComplete(node) ? 1 : 0, duration: number(node.getAttribute('data-duration')), locked, retryCount: 0, lastRefreshAt: 0 });
|
||
return tasks[tasks.length - 1];
|
||
}
|
||
const mapNodes = doc.querySelectorAll('app-learning-map-activity-list .activity_content');
|
||
mapNodes.forEach((node, i) => {
|
||
const label = clean((node.querySelector('.acitvity_other_info') || node).textContent);
|
||
add(node, /考试/.test(label) ? 'exam' : 'course', 'app-learning-map-activity-list .activity_content', i);
|
||
});
|
||
const chapterNodes = doc.querySelectorAll('app-course .cn_courseware_img,[data-courseware-id]');
|
||
chapterNodes.forEach((node, i) => {
|
||
const icon = clean((node.querySelector('.cn_courseware_img_icon') || node).textContent);
|
||
const task = add(node, /视频/.test(icon) || node.getAttribute('data-kind') === 'video' ? 'video' : 'unsupported', 'app-course .cn_courseware_img,[data-courseware-id]', i);
|
||
if (task && task.kind === 'unsupported' && task.status !== 'completed') { task.status = 'skipped'; task.reason = '暂未适配此非视频课件'; }
|
||
node.querySelectorAll('.related_test,[data-related-exam]').forEach((exam, j) => {
|
||
const examTask = add(exam, 'exam', 'app-course .cn_courseware_img,[data-courseware-id]', i, task && task.id, j);
|
||
if (examTask) { examTask.selector = 'app-course .cn_courseware_img,[data-courseware-id]'; examTask.subSelector = '.related_test,[data-related-exam]'; examTask.subIndex = j; examTask.id += ':exam:' + j; examTask.requiresParent = exam.getAttribute('data-requires-complete') === 'true'; }
|
||
});
|
||
});
|
||
doc.querySelectorAll('a[href],[data-task-url]').forEach((node, i) => {
|
||
const kind = node.getAttribute('data-kind'); const u = nodeURL(node, page.url);
|
||
if (!u || node.closest('.activity_content,.cn_courseware_img,[data-courseware-id]')) return;
|
||
let inferred = /\/exam\//.test(u) ? 'exam' : /\/(?:course|courseware)\//.test(u) ? 'course' : '';
|
||
if (['video', 'exam', 'course'].includes(kind)) inferred = kind;
|
||
if (inferred) add(node, inferred, 'a[href],[data-task-url]', i);
|
||
});
|
||
if ((page.kind === 'exam' || page.kind === 'paper') && !tasks.some(t => t.kind === 'exam' && canonical(t.url || t.pageUrl) === page.url)) {
|
||
tasks.unshift({ id: 'exam:' + hash(page.url), kind: 'exam', title: page.title, url: page.url, pageUrl: page.url, current: true, status: 'pending', progress: 0, retryCount: 0 });
|
||
}
|
||
if (page.video && !tasks.some(t => t.kind === 'video' && doc.querySelectorAll(t.selector || ':not(*)')[t.index] === page.activeCourseware)) {
|
||
tasks.unshift({ id: 'video:' + hash(page.url + ':' + (page.video.id || 'player')), kind: 'video', title: page.coursewareTitle || page.title, url: page.url, pageUrl: page.url, current: true,
|
||
status: page.platformComplete ? 'completed' : 'pending', progress: page.platformComplete ? 1 : 0, retryCount: 0, lastRefreshAt: 0 });
|
||
}
|
||
return tasks;
|
||
}
|
||
function preflightTopic(doc, snapshot, associations, task, explicitTask) {
|
||
// 兼容控制器公开调用 (document, url, snapshot, associations, task)。
|
||
if (typeof snapshot === 'string') { snapshot = associations; associations = task; task = explicitTask; }
|
||
snapshot = snapshot || {}; associations = associations || {};
|
||
const title = clean(task && task.title || titleOf(doc));
|
||
const records = snapshot.records || snapshot.bank && snapshot.bank.records || [];
|
||
const declared = snapshot.courses || snapshot.themes || snapshot.bank && snapshot.bank.courses || [];
|
||
const available = Array.from(new Set((declared.length ? declared : records).map(c => clean(typeof c === 'string' ? c : c.course || c.name)).filter(Boolean)));
|
||
const explicit = associations[task && task.id] || associations[title];
|
||
const list = (Array.isArray(explicit) ? explicit : explicit ? [explicit] : []).map(clean).filter(Boolean);
|
||
if (list.length) {
|
||
const missing = list.filter(c => !available.includes(c));
|
||
return missing.length ? { status: 'missing', title, courses: [], candidates: available, reason: '明确关联的题库主题不存在：' + missing.join('、') } : { status: 'matched', title, courses: list, candidates: list, reason: '使用用户明确确认的主题关联' };
|
||
}
|
||
if (!available.length) return { status: 'missing', title, courses: [], candidates: [], reason: '统一题库为空或没有可用课程/主题' };
|
||
const exact = available.filter(c => c === title || c === clean(snapshot.course));
|
||
if (exact.length) return { status: 'matched', title, courses: exact, candidates: exact, reason: '考试主题与题库课程完全对应' };
|
||
const candidates = available.filter(c => c.length >= 2 && (title.includes(c) || c.includes(title))).slice(0, 20);
|
||
return { status: candidates.length ? 'waiting' : 'missing', title, courses: [], candidates, reason: candidates.length ? '仅发现相似主题，请先明确关联，暂不自动开考' : '未发现对应题库主题，已跳过自动开考；可在题库栏建立明确关联' };
|
||
}
|
||
|
||
function create(options) {
|
||
options = options || {};
|
||
const now = options.now || Date.now;
|
||
const storage = options.storage || { get: async () => null, set: async () => {} };
|
||
const owner = options.ownerId || token(); let initialized = false; let initializing = null; let destroyed = false; let busy = false; let generation = 0;
|
||
let session = null; let activeTaskId = ''; let pageKey = ''; let saveSignature = ''; let pendingQuiz = null; let worker = null;
|
||
let lastTime = null; let lastAdvancedAt = now(); let attemptedAt = 0; let playStarted = false;
|
||
let interactionAt = -Infinity; let lastAutoPlayAt = -Infinity; let manualVideoPause = false; let watchedDocument = null;
|
||
let visibilityPlayback = null; let returnResumeRequested = false; let pageAway = false; let playbackPromptClick = null;
|
||
let sharedPaused = false;
|
||
let requirementProbe = null;
|
||
let logSequence = 0; let leaseBanner = null;
|
||
let manualConfirmRevision = 0; let pendingManualConfirm = null;
|
||
let policySessionId = '', policyReadSerial = 0;
|
||
const authoritativePolicies = new Set(), policyAppliedReads = new Map(), policyLocalWrites = new Map();
|
||
const config = { mode: 'all', execution: 'sequential', rate: 1, answerInterval: 4, minSubmitMinutes: 6, manualConfirmIncomplete: true, autoContinuePlayback: true, resumePlaybackOnReturn: true, skipSingleAttemptQuiz: true, associations: {}, stallSeconds: 60, recoverySeconds: 15, maxRefreshes: 3, minRefreshSeconds: 30, videoPaused: false, examPaused: false };
|
||
const state = { status: 'idle', mode: 'all', execution: 'sequential', rate: 1, answerInterval: 4, minSubmitMinutes: 6, manualConfirmIncomplete: true, autoContinuePlayback: true, resumePlaybackOnReturn: true, skipSingleAttemptQuiz: true, tasks: [], total: 0, completed: 0, skipped: 0, waiting: 0, failed: 0, etaSeconds: null, video: null, exam: null, logs: [], message: '先识别当前学习计划，再开始本轮任务' };
|
||
|
||
function snapshot() {
|
||
const given = typeof options.getSnapshot === 'function' ? options.getSnapshot() || {} : {};
|
||
return Object.assign({ document: root.document, url: root.location ? root.location.href : '', courses: [] }, given);
|
||
}
|
||
function onInteraction(event) {
|
||
if (event.isTrusted && event.target && event.target.closest && event.target.closest('video,.xgplayer')) interactionAt = now();
|
||
}
|
||
function onRequirementHover(event) {
|
||
// 用户移动鼠标后，共用提示框可能已显示另一行的条件，不能归到旧请求。
|
||
if (event.isTrusted && requirementProbe && !requirementProbe.icon.contains(event.target)) requirementProbe = null;
|
||
}
|
||
function onVideoPause(event) {
|
||
if (event.target && event.target.tagName === 'VIDEO' && !pageAway && watchedDocument?.visibilityState !== 'hidden' && interactionAt > lastAutoPlayAt && now() - interactionAt < 2000) {
|
||
manualVideoPause = true; visibilityPlayback = null; returnResumeRequested = false;
|
||
}
|
||
}
|
||
function rememberPlayback() {
|
||
const snap = snapshot(); if (!snap.document || !safeURL(snap.url, snap.url)) return;
|
||
const task = state.tasks.find(t => t.id === activeTaskId); const page = describePage(snap.document, snap.url);
|
||
if (state.status !== 'running' || config.videoPaused || manualVideoPause || !task || task.kind !== 'video'
|
||
|| !['loading', 'playing', 'retrying'].includes(task.status) || !page.video || page.quiz || playbackPromptOf(snap.document) || page.video.ended || page.platformComplete) return;
|
||
if (!visibilityPlayback && (playStarted || !page.video.paused)) visibilityPlayback = { taskId: task.id, url: page.url, video: page.video, generation };
|
||
lastAdvancedAt = now(); attemptedAt = 0;
|
||
}
|
||
function onPageHidden() { pageAway = true; rememberPlayback(); }
|
||
function onPageReturn() {
|
||
if (watchedDocument && watchedDocument.visibilityState === 'hidden') return;
|
||
pageAway = false; lastAdvancedAt = now(); attemptedAt = 0;
|
||
returnResumeRequested = Boolean(visibilityPlayback && config.resumePlaybackOnReturn);
|
||
// 仍走正常调度、租约和弹题检查，事件本身不直接点击或播放。
|
||
root.setTimeout(() => { if (!destroyed) tick().catch(() => {}); }, 0);
|
||
}
|
||
function onVisibilityChange() {
|
||
if (watchedDocument && watchedDocument.visibilityState === 'hidden') onPageHidden(); else onPageReturn();
|
||
}
|
||
function notify() {
|
||
Object.assign(state, { mode: config.mode, execution: config.execution, rate: config.rate, answerInterval: config.answerInterval, minSubmitMinutes: config.minSubmitMinutes, videoPaused: config.videoPaused, examPaused: config.examPaused });
|
||
for (const key of POLICY_KEYS) state[key] = config[key];
|
||
const counted = state.tasks.filter(t => t.status !== 'expanded' && allows(t.kind));
|
||
state.total = counted.length; state.completed = counted.filter(t => t.status === 'completed').length;
|
||
state.skipped = counted.filter(t => t.status === 'skipped').length; state.waiting = counted.filter(t => t.status === 'waiting').length; state.failed = counted.filter(t => t.status === 'failed').length;
|
||
state.leaseWaiting = counted.filter(t => t.status === 'waitingLease').length;
|
||
const todo = counted.filter(t => !TERMINAL.includes(t.status));
|
||
const estimates = todo.map(t => {
|
||
if (['waiting', 'waitingLease'].includes(t.status) || t.kind === 'course' || t.kind === 'unsupported') return null;
|
||
if (t.kind === 'video') {
|
||
const v = state.video && state.video.taskId === t.id ? state.video : t;
|
||
if (!(v.duration > 0)) return null;
|
||
const playback = Math.max(0, v.duration - (v.currentTime || 0)) / (v.actualRate || config.rate);
|
||
// 播放时长已知仍不能推定平台学习条件，未知条件须明确显示未知。
|
||
if (v.requiredSeconds == null || v.learnedSeconds == null) return null;
|
||
return Math.max(playback, Math.max(0, v.requiredSeconds - v.learnedSeconds));
|
||
}
|
||
const e = state.exam && state.exam.taskId === t.id ? state.exam : null;
|
||
if (!e || e.total == null || ['waiting', 'paused', 'unknown'].includes(e.stage || e.status)) return null;
|
||
const elapsed = e.elapsedSeconds != null ? e.elapsedSeconds : e.enteredAt != null ? (now() - e.enteredAt) / 1000 : null;
|
||
if (elapsed == null && e.waitSeconds == null) return null;
|
||
return Math.max(0, (e.total - (e.verified || 0)) * config.answerInterval, e.waitSeconds != null ? e.waitSeconds : config.minSubmitMinutes * 60 - elapsed);
|
||
});
|
||
state.etaSeconds = estimates.some(e => e == null) ? null : config.execution === 'parallel' ? Math.max(0, ...['video', 'exam'].map(kind => estimates.reduce((n, e, i) => n + (todo[i].kind === kind ? e : 0), 0))) : estimates.reduce((n, e) => n + e, 0);
|
||
if (typeof options.onState === 'function') options.onState(clone(state));
|
||
}
|
||
function log(level, message, task, details, event) {
|
||
const record = { id: owner + ':' + (++logSequence), time: now(), level: ['info', 'warn', 'error'].includes(level) ? level : 'info', event: event || 'learning.message', message: String(message), task: task && task.title || '', taskId: task && task.id || '', details: details || {} };
|
||
state.logs.push(record);
|
||
if (typeof options.onLog === 'function') { try { options.onLog(clone(record)); } catch (_) {} }
|
||
state.logs = state.logs.slice(-500); notify();
|
||
}
|
||
function taskState(task, status, reason) {
|
||
const changed = task.status !== status || task.reason !== (reason || ''); task.status = status; task.reason = reason || '';
|
||
if (task.kind === 'video' && state.video?.taskId === task.id) state.video.message = task.reason;
|
||
if (changed) log(status === 'waiting' || status === 'failed' ? 'warn' : 'info', reason || status, task, { kind: task.kind, status }, 'task.state');
|
||
}
|
||
function allows(kind) { return kind === 'course' || kind === 'unsupported' || kind === 'video' && config.mode !== 'exam' || kind === 'exam' && (config.mode === 'exam' || config.mode === 'all'); }
|
||
function account(snap, page) { return clean(snap.accountId || page.accountId || ''); }
|
||
function readExamAttempt(task, snap, page) {
|
||
const scope = snap.document.querySelector('app-examdetail,app-examtest,.pc_examtest');
|
||
const live = root.YianAttemptPolicy?.read(scope) || { known: false, blocked: false, count: null, reason: '', signature: '[]' };
|
||
if (!['exam', 'paper'].includes(page.kind)) return live;
|
||
const taskURL = task && (task.examPaperURL || task.url || task.pageUrl);
|
||
const sameExam = taskURL && examIdentity(taskURL) && examIdentity(taskURL) === examIdentity(page.url);
|
||
if (task && task.kind === 'exam' && (canonical(taskURL) === page.url || sameExam)) {
|
||
if (live.known) { task.attemptPolicy = clone(live); task.attemptPolicyURL = page.url; }
|
||
// 同一任务从详情进入试卷后，次数提示可能不再显示；保留已核对的证据。
|
||
else if (task.attemptPolicy && (task.attemptPolicyURL === page.url || sameExam)) return clone(task.attemptPolicy);
|
||
}
|
||
return live;
|
||
}
|
||
function getAttemptPolicy() {
|
||
const snap = snapshot(); if (!snap.document) return { known: false, blocked: false, count: null, reason: '', signature: '[]' };
|
||
return readExamAttempt(state.tasks.find(t => t.id === activeTaskId), snap, describePage(snap.document, snap.url));
|
||
}
|
||
async function persist() {
|
||
if (!session) return;
|
||
session.config = clone(config); session.tasks = clone(state.tasks); session.logs = clone(state.logs); session.activeTaskId = activeTaskId; session.updatedAt = now();
|
||
// 执行器只写自己领取的任务检查点，主协调器合并，避免并行页面覆盖整份清单。
|
||
if (worker) {
|
||
const own = state.tasks.find(t => t.id === (activeTaskId || worker.taskId));
|
||
if (own) await storage.set('task:' + session.id + ':' + own.id, clone(own));
|
||
return;
|
||
}
|
||
const currentControl = await storage.get(CONTROL_KEY);
|
||
if (currentControl && currentControl.sessionId !== session.id) return;
|
||
await syncPolicies(currentControl); session.config = clone(config);
|
||
const signature = JSON.stringify([session.tasks, session.config, session.activeTaskId, session.status, session.accountId, session.planId, session.bankVersion]);
|
||
if (signature !== saveSignature) { await storage.set(SESSION_KEY, clone(session)); saveSignature = signature; }
|
||
}
|
||
async function release() {
|
||
for (const kind of ['video', 'exam']) {
|
||
const key = 'lease:' + kind; const lease = await storage.get(key);
|
||
if (lease && lease.owner === owner) { await storage.set(key, null); log('info', '已释放' + (kind === 'video' ? '视频/课程' : '考试') + '执行权', null, lease, 'lease.released'); }
|
||
}
|
||
}
|
||
function waitForLease(task, lease, reason) {
|
||
const previous = task.leaseWait;
|
||
task.leaseWait = { previousStatus: previous?.previousStatus || (task.status === 'waitingLease' ? 'pending' : task.status), previousReason: previous ? previous.previousReason : task.reason || '', lastLoggedAt: previous?.lastLoggedAt,
|
||
since: previous?.since == null ? now() : previous.since, kind: task.kind === 'course' ? 'video' : task.kind,
|
||
owner: lease?.owner || '', taskId: lease?.taskId || '', expires: Number(lease?.expires) || 0, pageUrl: lease?.pageUrl || '', reason };
|
||
if (!previous && activeTaskId === task.id) {
|
||
// 等待执行权期间取消本页旧动作；重新领取后仍须按当前页面重验。
|
||
if (task.kind === 'video') {
|
||
const snap = snapshot(); const video = snap.document && describePage(snap.document, snap.url).video;
|
||
if (video) video.pause(); playStarted = false; lastTime = null; attemptedAt = 0; lastAdvancedAt = now();
|
||
if (state.video) state.video.status = 'waitingLease';
|
||
}
|
||
if (task.kind === 'exam' && task.examRequested && task.leaseWait.previousStatus !== 'waiting') {
|
||
task.examNeedsRecheck = true;
|
||
if (typeof options.onExamPause === 'function') options.onExamPause('本页已失去考试执行权，停止旧自动作答并等待重新核验');
|
||
}
|
||
}
|
||
const secondsLeft = Math.max(0, Math.ceil((task.leaseWait.expires - now()) / 1000));
|
||
const holder = lease?.title || lease?.taskId || '另一页面任务';
|
||
const message = reason === 'control' ? '正在重新核对全局任务状态，暂不操作当前页面'
|
||
: '等待' + (task.leaseWait.kind === 'exam' ? '考试' : '视频/课程') + '执行权：' + holder + '由另一个页面处理，约 ' + secondsLeft + ' 秒后检查；执行权释放后自动继续';
|
||
taskState(task, 'waitingLease', '同类任务由另一个页面处理，自动等待并重试');
|
||
state.message = message; leaseBanner = { taskId: task.id, message };
|
||
if (!previous || previous.owner !== task.leaseWait.owner || previous.taskId !== task.leaseWait.taskId || previous.reason !== reason || now() - (previous.lastLoggedAt || 0) >= 15000) {
|
||
task.leaseWait.lastLoggedAt = now();
|
||
log('info', message, task, Object.assign({ ownOwner: owner }, task.leaseWait), 'lease.wait');
|
||
}
|
||
}
|
||
function acquiredLease(task) {
|
||
if (!task.leaseWait) return;
|
||
const waited = task.leaseWait;
|
||
if (task.status === 'waitingLease') { task.status = waited.previousStatus || 'pending'; task.reason = waited.previousReason || ''; }
|
||
delete task.leaseWait;
|
||
if (leaseBanner?.taskId === task.id) {
|
||
if (state.message === leaseBanner.message) state.message = '已取得' + (task.kind === 'exam' ? '考试' : '视频/课程') + '执行权，正在继续任务';
|
||
leaseBanner = null;
|
||
}
|
||
log('info', '等待结束，已取得执行权并重新核对任务', task, { waitedMs: Math.max(0, now() - waited.since), kind: waited.kind, previousOwner: waited.owner }, 'lease.resumed');
|
||
}
|
||
async function claim(task) {
|
||
const kind = task.kind === 'course' ? 'video' : task.kind;
|
||
if (kind !== 'video' && kind !== 'exam') return true;
|
||
async function acquire() {
|
||
const key = 'lease:' + kind; const lease = await storage.get(key);
|
||
const shared = await storage.get(CONTROL_KEY);
|
||
if (shared && (shared.sessionId !== session.id || shared.status !== 'running')) { waitForLease(task, null, 'control'); return false; }
|
||
if (lease && lease.owner !== owner && lease.sessionId === session.id && lease.expires > now()) { waitForLease(task, lease, 'busy'); return false; }
|
||
if (lease && lease.expires <= now()) log('info', '原执行权已到期，重新领取任务', task, lease, 'lease.expired');
|
||
const wanted = { owner, taskId: task.id, title: task.title, pageUrl: canonical(snapshot().url), sessionId: session.id, expires: now() + LEASE_MS, updatedAt: now() };
|
||
await storage.set(key, wanted);
|
||
// GM存储无CAS；延后回读并在每次动作前复核。支持Web Locks时同源标签领取是互斥的。
|
||
if (!(root.navigator && root.navigator.locks)) await new Promise(resolve => root.setTimeout(resolve, 25));
|
||
const saved = await storage.get(key);
|
||
if (!saved || saved.owner !== owner || saved.taskId !== task.id || saved.sessionId !== session.id) { waitForLease(task, saved, 'race'); return false; }
|
||
acquiredLease(task); log('info', '已取得' + (kind === 'exam' ? '考试' : '视频/课程') + '执行权', task, wanted, 'lease.acquired'); return true;
|
||
}
|
||
return root.navigator && root.navigator.locks ? root.navigator.locks.request('yian-learning-' + kind, acquire) : acquire();
|
||
}
|
||
async function heartbeat(task) {
|
||
const key = 'lease:' + (task.kind === 'course' ? 'video' : task.kind); const lease = await storage.get(key);
|
||
if (!lease || lease.owner !== owner || lease.taskId !== task.id || lease.sessionId !== session.id) return false;
|
||
const shared = await storage.get(CONTROL_KEY); if (shared && (shared.sessionId !== session.id || shared.status !== 'running')) return false;
|
||
if (lease.expires <= now()) log('info', '本页原执行权已到期，核对所有者后恢复', task, lease, 'lease.renewed');
|
||
lease.expires = now() + LEASE_MS; lease.updatedAt = now(); lease.pageUrl = canonical(snapshot().url); lease.title = task.title;
|
||
await storage.set(key, lease); return true;
|
||
}
|
||
function mergeTasks(tasks, parent) {
|
||
tasks.forEach(task => {
|
||
if (parent && task.id !== parent.id && task.kind !== 'course') task.parentCourse = parent.id;
|
||
const current = state.tasks.find(t => t.id === activeTaskId);
|
||
const conflictingExam = current && task.kind === 'exam' && examIdentity(current.examPaperURL || current.url || current.pageUrl)
|
||
&& examIdentity(task.url || task.pageUrl) && examIdentity(current.examPaperURL || current.url || current.pageUrl) !== examIdentity(task.url || task.pageUrl);
|
||
// 开考前详情路由与试卷路由不同；同一已授权转场不再生成第二场考试。
|
||
const alias = task.current && current && current.kind === task.kind &&
|
||
(task.kind === 'exam' && !conflictingExam && (current.enterClickedAt || current.examLinkClickedAt || current.navigationRequestedAt) && task.title === current.title
|
||
&& (!current.examPaperURL || current.examPaperURL === task.url)
|
||
&& (!current.enterClickedAt || now() - current.enterClickedAt < 60000 || current.examPaperURL === task.url)
|
||
|| task.kind === 'video' && task.title === current.title);
|
||
const old = state.tasks.find(t => t.id === task.id || task.identity && t.kind === task.kind && t.identity === task.identity
|
||
|| task.current && task.kind === t.kind && task.url && (canonical(t.examPaperURL || t.url) === canonical(task.url)
|
||
|| task.kind === 'exam' && examIdentity(t.examPaperURL || t.url || t.pageUrl) && examIdentity(t.examPaperURL || t.url || t.pageUrl) === examIdentity(task.url))) || (alias ? current : null);
|
||
if (!old) state.tasks.push(task);
|
||
else {
|
||
if (alias && task.url) old.url = task.url;
|
||
if (task.current && task.kind === 'exam' && /\/questions\/?$/.test(new URL(task.url).pathname)) old.examPaperURL = task.url;
|
||
if (task.status === 'completed') {
|
||
old.status = 'completed'; old.progress = 1; old.reason = '平台确认已完成';
|
||
if (old.kind === 'video' && state.video?.taskId === old.id) Object.assign(state.video, { platformComplete: true, status: 'completed', message: old.reason });
|
||
}
|
||
}
|
||
});
|
||
}
|
||
function resolveNode(task, snap) {
|
||
if (canonical(snap.url) !== canonical(task.pageUrl) || !task.selector) return null;
|
||
let node = snap.document.querySelectorAll(task.selector)[task.index];
|
||
if (node && task.subSelector) node = node.querySelectorAll(task.subSelector)[task.subIndex];
|
||
if (!node || !visible(node)) return null;
|
||
const actualId = node.getAttribute('data-task-id') || node.getAttribute('data-courseware-id') || node.getAttribute('data-course-id') || node.getAttribute('data-exam-id') || node.id;
|
||
if (task.identity && actualId !== task.identity) return null;
|
||
const title = clean((node.querySelector('.activity_name,:scope > p,[data-task-title]') || node).textContent);
|
||
if (!task.identity && title !== task.title) return null;
|
||
return node;
|
||
}
|
||
function readRequirements(task, node, doc) {
|
||
if (!node || task.requirements) return task.requirements || null;
|
||
const icon = node.querySelector('.courseware_finished_status .en_courseware_noFinished');
|
||
if (!icon || !visible(icon)) return null;
|
||
if (requirementProbe && (requirementProbe.node !== node || requirementProbe.doc !== doc)) {
|
||
requirementProbe.icon.dispatchEvent(new root.MouseEvent('mouseleave', { bubbles: false }));
|
||
requirementProbe = null;
|
||
}
|
||
if (requirementProbe) {
|
||
const tips = Array.from(doc.querySelectorAll('.completion-tooltip')).filter(t => visible(t) && clean(t.textContent));
|
||
const requirements = tips.length === 1 ? completionRequirements(tips[0].textContent) : null;
|
||
if (requirements || now() - requirementProbe.at > 1500) {
|
||
icon.dispatchEvent(new root.MouseEvent('mouseleave', { bubbles: false }));
|
||
icon.dispatchEvent(new root.MouseEvent('mouseout', { bubbles: true }));
|
||
requirementProbe = null; task.requirementsRead = true;
|
||
if (requirements) {
|
||
task.requirements = requirements;
|
||
log('info', '课件完成条件：' + requirements.text, task, requirements, 'course.requirements');
|
||
}
|
||
}
|
||
} else if (!task.requirementsRead) {
|
||
// 橙色图标只是未完成；实际观看/考试条件由网页 hover 提示给出。
|
||
const existing = Array.from(doc.querySelectorAll('.completion-tooltip')).some(t => visible(t) && clean(t.textContent));
|
||
if (!existing) {
|
||
requirementProbe = { node, icon, doc, at: now() };
|
||
icon.dispatchEvent(new root.MouseEvent('mouseenter', { bubbles: false }));
|
||
icon.dispatchEvent(new root.MouseEvent('mouseover', { bubbles: true }));
|
||
}
|
||
}
|
||
return task.requirements || null;
|
||
}
|
||
function linkedExams(task) { return state.tasks.filter(t => t.kind === 'exam' && t.parentId === task.id); }
|
||
async function canAct(task, snap, epoch) {
|
||
const locallyPaused = () => task.kind === 'exam' ? config.examPaused : config.videoPaused;
|
||
if (epoch !== generation || state.status !== 'running' || locallyPaused()) return false;
|
||
if (!await heartbeat(task)) return false;
|
||
const latest = snapshot();
|
||
const livePage = describePage(latest.document, latest.url);
|
||
const samePage = latest.document === snap.document && canonical(latest.url) === canonical(snap.url)
|
||
&& (!snap.guardTitle || livePage.title === snap.guardTitle)
|
||
&& livePage.activeCourseware === snap.guardActive && livePage.video === snap.guardVideo
|
||
&& latest.document.querySelector('app-course,app-learning-map-activity-list') === snap.guardRoot
|
||
&& (!snap.guardTaskNode || resolveNode(task, latest) === snap.guardTaskNode);
|
||
if (!samePage && epoch === generation && state.status === 'running' && !locallyPaused()) taskState(task, 'waiting', '点击前课程或目录已变化，请核对当前任务后继续');
|
||
return epoch === generation && state.status === 'running' && !locallyPaused() && samePage;
|
||
}
|
||
function guardedSnapshot(snap, page) {
|
||
return Object.assign({}, snap, { guardTitle: page.title, guardActive: page.activeCourseware,
|
||
guardVideo: page.video, guardRoot: snap.document.querySelector('app-course,app-learning-map-activity-list') });
|
||
}
|
||
async function courseTick(task, snap, page, epoch) {
|
||
snap = guardedSnapshot(snap, page);
|
||
if (config.videoPaused || task.status === 'waiting') return;
|
||
if (page.kind === 'map' && canonical(task.pageUrl) === page.url && task.courseEntrySourceURL !== page.url) {
|
||
const node = resolveNode(task, snap);
|
||
snap.guardTaskNode = node;
|
||
const button = node && (node.querySelector('.map_activity_content_info_top') || node);
|
||
if (!button) { taskState(task, 'waiting', '返回学习地图后找不到原课程入口，请核对目录后继续'); return; }
|
||
if (isComplete(node)) { task.progress = 1; taskState(task, 'completed', '平台已确认该课程完成，跳过此入口'); activeTaskId = ''; await release(); return; }
|
||
await persist();
|
||
await storage.set('transition.v1', { sessionId: session.id, taskId: task.id, sourceURL: page.url, targetURL: task.url || '', title: task.title, accountId: account(snap, page), expires: now() + 60000 });
|
||
if (!await canAct(task, snap, epoch) || !snap.document.documentElement.contains(button) || !visible(button)) return;
|
||
task.courseEntrySourceURL = page.url; task.courseEntryClickedAt = now(); task.navigationRequestedAt = now();
|
||
log('info', '已返回学习地图，通过原课程入口进入下一任务', task, { pageUrl: page.url }, 'course.next');
|
||
button.click(); return;
|
||
}
|
||
if (now() - task.navigationRequestedAt > 15000) taskState(task, 'waiting', '课程入口尚未进入目标课程，请检查网站前置条件后继续');
|
||
}
|
||
function initialize() {
|
||
if (initialized) return Promise.resolve();
|
||
if (initializing) return initializing;
|
||
initializing = initializeWork().then(() => { initialized = true; }).finally(() => { initializing = null; });
|
||
return initializing;
|
||
}
|
||
async function initializeWork() {
|
||
const snap = snapshot(); if (!snap.document) return;
|
||
watchedDocument = snap.document; watchedDocument.addEventListener('pointerdown', onInteraction, true); watchedDocument.addEventListener('keydown', onInteraction, true); watchedDocument.addEventListener('pause', onVideoPause, true);
|
||
watchedDocument.addEventListener('visibilitychange', onVisibilityChange, true);
|
||
watchedDocument.addEventListener('mouseover', onRequirementHover, true);
|
||
if (watchedDocument.defaultView) { watchedDocument.defaultView.addEventListener('blur', onPageHidden); watchedDocument.defaultView.addEventListener('focus', onPageReturn); }
|
||
const page = describePage(snap.document, snap.url);
|
||
const saved = await storage.get(SESSION_KEY);
|
||
const marker = new URL(snap.url || 'http://invalid').hash.match(/(?:^#|&)__yian_worker=([^&]+)/);
|
||
const recover = await storage.get('recover:' + canonical(snap.url));
|
||
const transition = await storage.get('transition.v1');
|
||
if (saved && Array.isArray(saved.tasks)) {
|
||
const identityOK = (!saved.accountId || saved.accountId === account(snap, page)) && (!saved.planId || !snap.planId || saved.planId === snap.planId) && (!saved.bankVersion || !snap.bankVersion || saved.bankVersion === snap.bankVersion);
|
||
if (identityOK) {
|
||
session = saved; Object.assign(config, saved.config || {}); state.tasks = saved.tasks; state.logs = Array.isArray(saved.logs) ? saved.logs.slice(-500) : []; activeTaskId = saved.activeTaskId || '';
|
||
for (const task of state.tasks) if (task.status === 'waiting' && task.reason === '另一个页面正在处理同类任务，避免重复领取') {
|
||
task.status = 'waitingLease'; task.leaseWait = { previousStatus: 'pending', previousReason: '', since: now() };
|
||
}
|
||
if (marker) {
|
||
const request = await storage.get('worker:' + marker[1]);
|
||
const control = await storage.get(CONTROL_KEY);
|
||
if (request && control && request.sessionId === session.id && request.url === canonical(snap.url) && request.expires > now() && ['running', 'paused'].includes(control.status)) {
|
||
worker = request; activeTaskId = request.taskId; state.status = control.status; sharedPaused = control.status === 'paused'; request.owner = owner; request.confirmedAt = now(); await storage.set('worker:' + marker[1], request);
|
||
}
|
||
}
|
||
if (!worker) {
|
||
const sharedControl = await storage.get(CONTROL_KEY);
|
||
const targetOK = transition && transition.sessionId === session.id && transition.expires > now() && transition.accountId === account(snap, page) &&
|
||
(transition.targetURL ? transition.targetURL === page.url : transition.sourceURL !== page.url && transition.title === page.title && ['course', 'video', 'exam', 'paper'].includes(page.kind));
|
||
const controlled = sharedControl && sharedControl.status === 'running' && (recover && recover.sessionId === session.id && recover.taskId === activeTaskId && recover.expires > now() && recover.accountId === account(snap, page) || targetOK);
|
||
if (targetOK) {
|
||
activeTaskId = transition.taskId;
|
||
const arriving = state.tasks.find(t => t.id === activeTaskId);
|
||
if (arriving?.kind === 'course' && canonical(arriving.pageUrl) === transition.sourceURL) {
|
||
arriving.courseEntrySourceURL = transition.sourceURL; arriving.courseEntryClickedAt = now();
|
||
}
|
||
if (transition.workerNonce && sharedControl && sharedControl.status === 'running') {
|
||
const request = await storage.get('worker:' + transition.workerNonce);
|
||
if (request && request.sessionId === session.id && request.taskId === activeTaskId) { worker = request; worker.owner = owner; worker.confirmedAt = now(); await storage.set('worker:' + worker.nonce, worker); }
|
||
}
|
||
await storage.set('transition.v1', null);
|
||
}
|
||
if (controlled) { state.status = 'running'; session.status = 'running'; await storage.set('recover:' + canonical(snap.url), null); log('info', '已核对脚本恢复标记，继续同一视频任务'); }
|
||
else { state.status = 'paused'; session.status = 'paused'; state.message = '已恢复上次任务清单，人工刷新后默认暂停；点击继续重新核对'; }
|
||
}
|
||
} else { state.message = '账号、学习计划或题库版本已变化，未恢复旧任务'; log('warn', state.message); }
|
||
}
|
||
if (worker && session) { const checkpoint = await storage.get('task:' + session.id + ':' + activeTaskId); const task = state.tasks.find(t => t.id === activeTaskId); if (checkpoint && task) Object.assign(task, checkpoint); }
|
||
// 完整导航/受控刷新后的播放器需要新的加载窗口，不能沿用旧页的超时。
|
||
if (state.status === 'running') {
|
||
const restored = state.tasks.find(t => t.id === activeTaskId);
|
||
if (restored) { restored.openedAt = now(); delete restored.coverClickedAt; }
|
||
}
|
||
if (session) await syncPolicies(await storage.get(CONTROL_KEY));
|
||
mergeTasks(discoverTasks(snap.document, snap.url)); notify();
|
||
}
|
||
function syncManualConfirmation(shared) {
|
||
if (!session || !shared || shared.sessionId !== session.id || !shared.config || pendingManualConfirm) return;
|
||
const revision = Number(shared.manualConfirmRevision) || 0;
|
||
if (revision < manualConfirmRevision) return;
|
||
for (const key of POLICY_KEYS) if (!authoritativePolicies.has(key) && typeof shared.config[key] === 'boolean') { config[key] = shared.config[key]; state[key] = config[key]; }
|
||
manualConfirmRevision = revision; session.config = Object.assign({}, session.config);
|
||
for (const key of POLICY_KEYS) session.config[key] = config[key];
|
||
}
|
||
function ensurePolicySession() {
|
||
const id = session?.id || '';
|
||
if (policySessionId === id) return;
|
||
policySessionId = id; authoritativePolicies.clear(); policyAppliedReads.clear(); policyLocalWrites.clear();
|
||
}
|
||
function policyKey(key, id) { return 'policy:' + (id || session.id) + ':' + key; }
|
||
async function syncPolicies(shared) {
|
||
if (!session) return;
|
||
ensurePolicySession();
|
||
syncManualConfirmation(shared);
|
||
const id = session.id, serial = ++policyReadSerial;
|
||
const writes = new Map(POLICY_KEYS.map(key => [key, policyLocalWrites.get(key) || 0]));
|
||
const records = await Promise.all(POLICY_KEYS.map(key => storage.get(policyKey(key, id))));
|
||
if (!session || session.id !== id || destroyed) return;
|
||
records.forEach((record, index) => {
|
||
const key = POLICY_KEYS[index];
|
||
if (!record || record.sessionId !== id || typeof record.value !== 'boolean'
|
||
|| pendingManualConfirm?.values && key in pendingManualConfirm.values
|
||
|| (policyLocalWrites.get(key) || 0) !== writes.get(key)
|
||
|| serial < (policyAppliedReads.get(key) || 0)) return;
|
||
// 独立键是共享策略的权威值；旧 control 全量快照不能覆盖它。
|
||
authoritativePolicies.add(key); policyAppliedReads.set(key, serial);
|
||
config[key] = record.value; state[key] = record.value;
|
||
});
|
||
session.config = Object.assign({}, session.config);
|
||
for (const key of POLICY_KEYS) session.config[key] = config[key];
|
||
}
|
||
async function control(status, force, explicitWorkerAction, manualPatch) {
|
||
if (!session || worker && !explicitWorkerAction) return;
|
||
const controlEpoch = generation, controlSessionId = session.id;
|
||
ensurePolicySession();
|
||
const current = await storage.get(CONTROL_KEY);
|
||
if (!force && current && current.sessionId !== session.id) return;
|
||
const sameSession = current && current.sessionId === session.id;
|
||
if (manualPatch) {
|
||
if (sameSession && current.config) for (const key of POLICY_KEYS) {
|
||
if (!(key in manualPatch.values) && !authoritativePolicies.has(key) && typeof current.config[key] === 'boolean') config[key] = current.config[key];
|
||
}
|
||
Object.assign(config, manualPatch.values);
|
||
manualConfirmRevision = Math.max(manualConfirmRevision, sameSession ? Number(current.manualConfirmRevision) || 0 : 0) + 1;
|
||
const id = session.id;
|
||
await Promise.all(Object.entries(manualPatch.values).map(async ([key, value]) => {
|
||
authoritativePolicies.add(key);
|
||
await storage.set(policyKey(key, id), { sessionId: id, value, revision: manualConfirmRevision, updatedAt: now(), owner });
|
||
}));
|
||
}
|
||
await syncPolicies(current);
|
||
// 策略通过独立键发布，不将旧 control 快照写回，避免覆盖另一页刚发出的暂停。
|
||
if (manualPatch && sameSession || controlEpoch !== generation || session?.id !== controlSessionId) return;
|
||
const sharedConfig = clone(worker && sameSession ? current.config : config);
|
||
for (const key of POLICY_KEYS) sharedConfig[key] = config[key];
|
||
// 设置修改只发布策略，不得把另一页已经暂停的任务重新改成 running。
|
||
await storage.set(CONTROL_KEY, { sessionId: session.id, status: manualPatch && sameSession ? current.status : status, config: sharedConfig,
|
||
manualConfirmRevision, updatedAt: now(), owner: worker && sameSession ? current.owner : owner });
|
||
}
|
||
async function configure(patch, restoreOptions) {
|
||
await initialize(); patch = patch || {};
|
||
if (restoreOptions?.restore === true && session) {
|
||
await syncPolicies(await storage.get(CONTROL_KEY));
|
||
// 普通设置快照可能来自另一个标签的旧全量写回；重载只恢复尚无权威记录的策略。
|
||
patch = Object.assign({}, patch);
|
||
for (const key of POLICY_KEYS) if (authoritativePolicies.has(key)) delete patch[key];
|
||
}
|
||
const wasRunning = state.status === 'running';
|
||
const previousVideoPaused = config.videoPaused, previousExamPaused = config.examPaused;
|
||
if (patch.retryDelaySeconds != null) patch = Object.assign({}, patch, { recoverySeconds: patch.retryDelaySeconds });
|
||
if (patch.maxRefresh != null) patch = Object.assign({}, patch, { maxRefreshes: patch.maxRefresh });
|
||
const modeChanged = patch.mode && patch.mode !== config.mode || patch.execution && patch.execution !== config.execution;
|
||
if (MODES.includes(patch.mode)) config.mode = patch.mode;
|
||
if (['sequential', 'parallel'].includes(patch.execution)) config.execution = patch.execution;
|
||
for (const key of ['rate', 'answerInterval', 'minSubmitMinutes', 'stallSeconds', 'recoverySeconds', 'maxRefreshes', 'minRefreshSeconds']) {
|
||
if (Number.isFinite(Number(patch[key]))) config[key] = Math.max(key === 'rate' ? 0.25 : key === 'answerInterval' || key === 'minSubmitMinutes' ? 0 : 1, Number(patch[key]));
|
||
}
|
||
config.rate = Math.min(2, config.rate); config.maxRefreshes = Math.min(3, Math.floor(config.maxRefreshes));
|
||
if (patch.associations && typeof patch.associations === 'object') config.associations = clone(patch.associations);
|
||
if (typeof patch.videoPaused === 'boolean') config.videoPaused = patch.videoPaused;
|
||
if (typeof patch.examPaused === 'boolean') config.examPaused = patch.examPaused;
|
||
if (!previousVideoPaused && config.videoPaused || !previousExamPaused && config.examPaused) generation++;
|
||
const localResumed = previousVideoPaused && patch.videoPaused === false || previousExamPaused && patch.examPaused === false;
|
||
if (localResumed && state.status === 'running') {
|
||
const active = state.tasks.find(t => t.id === activeTaskId);
|
||
if (active && (active.kind === 'exam' ? previousExamPaused && !config.examPaused : previousVideoPaused && !config.videoPaused)) {
|
||
active.status = 'pending'; active.reason = ''; activeTaskId = '';
|
||
if (active.kind === 'exam' && active.examRequested) active.examNeedsRecheck = true;
|
||
}
|
||
}
|
||
const policies = Object.fromEntries(POLICY_KEYS.filter(key => typeof patch[key] === 'boolean').map(key => [key, patch[key]]));
|
||
const manualPatch = Object.keys(policies).length ? { values: policies } : null;
|
||
if (manualPatch) {
|
||
ensurePolicySession(); pendingManualConfirm = manualPatch; Object.assign(config, policies);
|
||
for (const key of Object.keys(policies)) policyLocalWrites.set(key, (policyLocalWrites.get(key) || 0) + 1);
|
||
}
|
||
if (patch.clearLogs) state.logs = [];
|
||
if (modeChanged && wasRunning) await pause('执行模式已改变，请核对任务后继续');
|
||
if (config.videoPaused) { const snap = snapshot(); const v = snap.document && describePage(snap.document, snap.url).video; if (v) v.pause(); }
|
||
if (config.examPaused && typeof options.onExamPause === 'function') options.onExamPause('考试任务已局部暂停');
|
||
try { await control(state.status, false, Boolean(manualPatch), manualPatch); }
|
||
finally { if (pendingManualConfirm === manualPatch) pendingManualConfirm = null; }
|
||
await persist(); notify(); return getState();
|
||
}
|
||
async function start() {
|
||
await initialize(); if (destroyed) return getState();
|
||
const snap = snapshot(); const page = describePage(snap.document, snap.url);
|
||
if (!safeURL(snap.url, snap.url)) { state.status = 'paused'; state.message = '当前页面不在已授权站点目录'; notify(); return getState(); }
|
||
const previous = session;
|
||
config.videoPaused = false; config.examPaused = false;
|
||
session = { id: token(), accountId: account(snap, page), planId: snap.planId || page.url, bankVersion: snap.bankVersion || '', status: 'running', createdAt: now(), tasks: [], config: clone(config), logs: clone(state.logs) };
|
||
state.tasks = []; activeTaskId = ''; worker = null; saveSignature = ''; mergeTasks(discoverTasks(snap.document, snap.url));
|
||
// 全新一轮不沿用旧执行状态，但保留平台本身已完成标记。
|
||
if (previous) await release();
|
||
visibilityPlayback = null; returnResumeRequested = false;
|
||
state.status = 'running'; sharedPaused = false; state.message = '正在按当前模式核对任务'; generation++; await control('running', true); await persist(); log('info', '开始本轮学习：' + config.mode + ' / ' + config.execution);
|
||
return tick();
|
||
}
|
||
async function pause(reason) {
|
||
await initialize(); const pauseEpoch = ++generation; visibilityPlayback = null; returnResumeRequested = false; state.status = 'paused'; sharedPaused = false; state.message = reason || '已暂停全部任务；网站考试倒计时仍会继续';
|
||
if (session) session.status = 'paused'; const snap = snapshot(); const page = snap.document && describePage(snap.document, snap.url); if (page && page.video) page.video.pause();
|
||
if (typeof options.onExamPause === 'function') options.onExamPause(state.message);
|
||
await control('paused', false, true);
|
||
if (pauseEpoch !== generation || state.status !== 'paused') return getState();
|
||
// 暂停写入完成后才接受远端“继续”；使写入期间读到旧 running 的轮询失效。
|
||
sharedPaused = true; generation++;
|
||
await release(); await persist(); log('info', state.message); return getState();
|
||
}
|
||
async function resume() {
|
||
await initialize(); if (!session) return start();
|
||
const snap = snapshot(); const page = describePage(snap.document, snap.url);
|
||
if (session.accountId && session.accountId !== account(snap, page) || session.bankVersion && snap.bankVersion && session.bankVersion !== snap.bankVersion) {
|
||
state.message = '账号或题库版本已变化，请开始新一轮任务'; state.status = 'paused'; notify(); return getState();
|
||
}
|
||
state.tasks.filter(t => (t.status === 'waiting' || ACTIVE.includes(t.status) || ['waitingPlatform', 'waitingExam'].includes(t.status)) && !t.locked).forEach(t => { t.status = 'pending'; t.reason = ''; t.examRequested = false; });
|
||
config.videoPaused = false; config.examPaused = false;
|
||
generation++; visibilityPlayback = null; returnResumeRequested = false; state.status = 'running'; sharedPaused = false; session.status = 'running'; activeTaskId = ''; playStarted = false; attemptedAt = 0; lastTime = null; lastAdvancedAt = now();
|
||
await control('running', false, true); await persist(); log('info', '继续任务，重新核验页面实际状态'); return tick();
|
||
}
|
||
async function stop() {
|
||
await pause('已停止本轮；保留网站已发生的学习和作答记录'); state.status = 'stopped'; if (session) session.status = 'stopped'; await control('stopped'); await persist(); notify(); return getState();
|
||
}
|
||
async function activate(task, snap, page) {
|
||
const epoch = generation;
|
||
snap = guardedSnapshot(snap, page);
|
||
if (task.kind === 'exam' ? config.examPaused : config.videoPaused) return false;
|
||
if (task.locked) { taskState(task, 'waiting', '网站尚未开放此任务'); return false; }
|
||
if (task.requiresParent && task.parentId) { const parent = state.tasks.find(t => t.id === task.parentId); if (parent && parent.status !== 'completed') return false; }
|
||
if (task.kind === 'exam') {
|
||
task.preflight = preflightTopic(snap.document, snap, config.associations, task);
|
||
if (task.preflight.status !== 'matched') { taskState(task, task.preflight.status === 'missing' ? 'skipped' : 'waiting', task.preflight.reason); return false; }
|
||
}
|
||
if (!(await claim(task))) return false;
|
||
if (epoch !== generation || state.status !== 'running') return false;
|
||
activeTaskId = task.id; playStarted = false; attemptedAt = 0; lastTime = null; lastAdvancedAt = now(); manualVideoPause = false; visibilityPlayback = null; returnResumeRequested = false;
|
||
task.openedAt = now(); delete task.coverClickedAt; delete task.courseEntrySourceURL; delete task.courseEntryClickedAt;
|
||
const onPage = canonical(task.url || task.pageUrl) === page.url;
|
||
const isCurrentVideo = task.kind === 'video' && page.video && (task.current || resolveNode(task, snap) === page.activeCourseware);
|
||
const isCurrentExam = task.kind === 'exam' && ['exam', 'paper'].includes(page.kind) && onPage;
|
||
if (isCurrentVideo || isCurrentExam) { taskState(task, 'loading', '已领取当前页面任务'); return true; }
|
||
const node = resolveNode(task, snap);
|
||
snap.guardTaskNode = node;
|
||
taskState(task, 'loading', '正在通过网页现有入口打开任务');
|
||
task.navigationRequestedAt = now();
|
||
await persist();
|
||
const targetURL = task.url || (canonical(task.pageUrl) !== page.url ? task.pageUrl : '');
|
||
await storage.set('transition.v1', { sessionId: session.id, taskId: task.id, workerNonce: worker && worker.nonce || '', sourceURL: page.url, title: task.title, targetURL: canonical(targetURL), accountId: account(snap, page), expires: now() + 60000 });
|
||
if (node) {
|
||
let button = node.matches('.activity_content') && node.querySelector('.map_activity_content_info_top') || node;
|
||
// 默认封面会打开首个课件；后续课件必须点击自己的目录行，防止重播已完成首项。
|
||
const first = snap.document.querySelector('app-course .cn_courseware_img,[data-courseware-id]');
|
||
const cover = task.kind === 'video' && !page.video && !page.activeCourseware && node === first ? courseCoverOf(snap.document) : null;
|
||
if (cover) button = cover;
|
||
if (!await canAct(task, snap, epoch)) return 'deferred';
|
||
if (!snap.document.documentElement.contains(button) || !visible(button)) { taskState(task, 'waiting', '原任务按钮已变化，请核对页面后继续'); return 'deferred'; }
|
||
if (cover) task.coverClickedAt = now();
|
||
if (task.kind === 'course') { task.courseEntrySourceURL = page.url; task.courseEntryClickedAt = now(); }
|
||
if (task.kind === 'exam') task.examLinkClickedAt = now();
|
||
if (cover) log('info', '点击封面“开始学习”，等待网页创建播放器', task, {}, 'video.coverStart');
|
||
button.click(); return true;
|
||
}
|
||
if (!await canAct(task, snap, epoch)) return 'deferred';
|
||
if (task.url && typeof options.navigate === 'function' && safeURL(task.url, snap.url)) { await options.navigate(task.url); return true; }
|
||
if (canonical(task.pageUrl) !== page.url && safeURL(task.pageUrl, snap.url) && typeof options.navigate === 'function') { await options.navigate(task.pageUrl); return true; }
|
||
taskState(task, 'waiting', '找不到原任务入口，请打开该课程后继续'); activeTaskId = ''; await release(); return false;
|
||
}
|
||
async function videoTick(task, snap, page, epoch) {
|
||
snap = guardedSnapshot(snap, page);
|
||
if (config.videoPaused) { if (page.video) page.video.pause(); taskState(task, 'waiting', '视频任务已局部暂停'); return; }
|
||
const node = resolveNode(task, snap) || (task.current ? page.activeCourseware : null);
|
||
if (!task.current) snap.guardTaskNode = node;
|
||
if (!task.current && canonical(task.pageUrl) !== page.url && !node) {
|
||
if (now() - task.openedAt > 15000) taskState(task, 'waiting', '尚未返回课件所在课程，请核对网站跳转后继续');
|
||
return;
|
||
}
|
||
if (page.activeCourseware && !task.current && (node ? node !== page.activeCourseware : task.title !== clean((page.activeCourseware.querySelector(':scope > p') || page.activeCourseware).textContent))) {
|
||
if (now() - task.openedAt <= 15000) return;
|
||
taskState(task, 'waiting', '当前选中课件与已领取任务不同，请核对后继续'); return;
|
||
}
|
||
const requirements = readRequirements(task, node, snap.document);
|
||
const learnedSeconds = node ? seconds(clean((node.querySelector('.menu_courseware_left') || node).textContent)) : page.learnedSeconds;
|
||
const requiredSeconds = requirements?.requiredSeconds ?? page.requiredSeconds;
|
||
const exams = linkedExams(task);
|
||
const ended = page.video && (page.video.ended || Number.isFinite(page.video.duration) && page.video.duration > 0 && page.video.currentTime >= page.video.duration - 0.05);
|
||
const watchedTime = requirements?.requiredSeconds != null && learnedSeconds != null && learnedSeconds >= requirements.requiredSeconds;
|
||
const examsDone = exams.length && exams.every(t => t.status === 'completed');
|
||
const canHandoff = watchedTime || requirements?.requiredSeconds == null && ended;
|
||
if (!page.platformComplete && !page.quiz && !playbackPromptOf(snap.document) && !manualVideoPause
|
||
&& requirements?.requiresExam && exams.length && (canHandoff || task.examHandoff)) {
|
||
task.examHandoff = true;
|
||
state.video = { taskId: task.id, title: task.title, currentTime: page.video?.currentTime || task.currentTime || 0,
|
||
duration: page.video && Number.isFinite(page.video.duration) ? page.video.duration : task.duration,
|
||
learnedSeconds, requiredSeconds, requirements: requirements.text, platformComplete: false,
|
||
status: examsDone ? 'waitingPlatform' : 'waitingExam', retryCount: task.retryCount || 0 };
|
||
if (!allows('exam')) {
|
||
taskState(task, 'waiting', '课件还要求关联考试；当前仅处理视频/课中题，请切换“视频＋考试”或人工完成关联考试'); return;
|
||
}
|
||
if (!examsDone) {
|
||
if (page.video) page.video.pause();
|
||
taskState(task, 'waitingExam', watchedTime ? '平台记录已达到观看时长要求，转入关联考试后再核对整体完成' : '视频已到末尾，转入关联考试；整体完成仍等待平台确认');
|
||
activeTaskId = ''; state.message = task.reason; await release(); return;
|
||
}
|
||
taskState(task, 'waitingPlatform', '关联考试已确认提交，等待课程目录的真实完成标记'); return;
|
||
}
|
||
if (!page.video) {
|
||
if (page.quiz) { taskState(task, 'waiting', '当前课中题尚未处理，等待网页恢复播放器后继续'); return; }
|
||
const first = snap.document.querySelector('app-course .cn_courseware_img,[data-courseware-id]');
|
||
const cover = courseCoverOf(snap.document);
|
||
if (cover && !task.coverClickedAt && (page.activeCourseware ? page.activeCourseware === node : node && node === first)) {
|
||
if (!await canAct(task, snap, epoch) || !snap.document.documentElement.contains(cover) || !visible(cover)) return;
|
||
task.coverClickedAt = now(); task.openedAt = now();
|
||
log('info', '点击封面“开始学习”，等待网页创建播放器', task, {}, 'video.coverStart');
|
||
cover.click(); return;
|
||
}
|
||
if (task.openedAt == null) task.openedAt = now();
|
||
if (now() - task.openedAt > 15000) taskState(task, 'waiting', '播放器未加载或自动播放需要用户操作');
|
||
return;
|
||
}
|
||
const video = page.video;
|
||
if (page.platformComplete) {
|
||
state.video = { taskId: task.id, title: task.title, currentTime: Number.isFinite(video.currentTime) ? video.currentTime : 0,
|
||
duration: Number.isFinite(video.duration) ? video.duration : null, actualRate: video.playbackRate,
|
||
learnedSeconds: page.learnedSeconds, requiredSeconds: page.requiredSeconds, platformComplete: true,
|
||
background: page.hidden, status: 'completed', retryCount: task.retryCount || 0 };
|
||
task.progress = 1; taskState(task, 'completed', '平台已确认课件学习完成'); activeTaskId = ''; await release(); return;
|
||
}
|
||
const popup = page.quiz;
|
||
const currentTime = Number.isFinite(video.currentTime) ? video.currentTime : 0; const duration = Number.isFinite(video.duration) && video.duration > 0 ? video.duration : null;
|
||
state.video = { taskId: task.id, title: task.title, currentTime, duration, actualRate: video.playbackRate, learnedSeconds, requiredSeconds, requirements: requirements?.text || '', platformComplete: false, background: page.hidden, status: 'playing', retryCount: task.retryCount || 0 };
|
||
Object.assign(task, { currentTime, duration, learnedSeconds, requiredSeconds, progress: duration ? Math.min(1, currentTime / duration) : 0 });
|
||
const playbackPrompt = playbackPromptOf(snap.document);
|
||
if (playbackPrompt && !popup) {
|
||
lastAdvancedAt = now(); attemptedAt = 0; visibilityPlayback = null; returnResumeRequested = false; state.video.status = 'waiting';
|
||
if (manualVideoPause || !config.autoContinuePlayback || playbackPrompt.ambiguous || !playbackPrompt.button) {
|
||
taskState(task, 'waiting', manualVideoPause ? '用户已暂停，请手动选择续播并继续任务' : !config.autoContinuePlayback ? '自动续播已关闭，请在网页选择继续播放或重新开始后继续任务' : '续播弹窗无法唯一确认，请人工选择后继续'); return;
|
||
}
|
||
if (playbackPromptClick && playbackPromptClick.container === playbackPrompt.container) {
|
||
if (now() - playbackPromptClick.at > 15000) taskState(task, 'waiting', '已选择继续播放，但网页弹窗未关闭，请人工检查');
|
||
return;
|
||
}
|
||
if (epoch !== generation || state.status !== 'running' || config.videoPaused || !config.autoContinuePlayback) return;
|
||
playbackPromptClick = { container: playbackPrompt.container, at: now() }; playStarted = false; lastTime = null;
|
||
taskState(task, 'loading', '已选择继续上次位置，等待网页恢复播放器'); playbackPrompt.button.click(); return;
|
||
}
|
||
if (!playbackPrompt) playbackPromptClick = null;
|
||
if (popup) {
|
||
visibilityPlayback = null; returnResumeRequested = false;
|
||
video.pause(); lastAdvancedAt = now(); attemptedAt = 0; playStarted = false;
|
||
if (config.mode === 'video') { taskState(task, 'waiting', '仅视频模式遇到强制课中题，请人工完成后继续'); state.video.status = 'waiting'; return; }
|
||
taskState(task, 'quiz', '正在核对课中题完整文字'); state.video.status = 'quiz';
|
||
if (typeof options.solveQuiz !== 'function') { taskState(task, 'waiting', '缺少此课中题结构适配，请人工处理；不会猜选或刷新'); return; }
|
||
if (pendingQuiz) return;
|
||
pendingQuiz = popup;
|
||
try {
|
||
const result = await options.solveQuiz(popup, { task: clone(task), answerInterval: config.answerInterval, skipSingleAttemptQuiz: config.skipSingleAttemptQuiz, document: snap.document });
|
||
if (epoch !== generation || state.status !== 'running') return;
|
||
if (!result || result.status !== 'completed' || result.verified !== true || quizOf(snap.document)) taskState(task, 'waiting', result && result.reason || '课中题尚未确认提交成功，请人工核对后继续');
|
||
else { taskState(task, 'playing', '课中题已核验且弹题已关闭，继续视频'); lastAdvancedAt = now(); }
|
||
} catch (error) { if (epoch === generation) { log('error', '课中题处理发生异常', task, { errorName: error.name, error: error.message, stack: error.stack }, 'quiz.error'); taskState(task, 'waiting', '课中题处理失败：' + error.message); } }
|
||
finally { pendingQuiz = null; }
|
||
return;
|
||
}
|
||
if (manualVideoPause) { taskState(task, 'waiting', '用户已在播放器主动暂停，请点击继续恢复任务'); state.video.status = 'waiting'; return; }
|
||
if (video.ended || duration && currentTime >= duration - 0.05) { taskState(task, 'waitingPlatform', '视频已播放到末尾，等待平台确认学习完成'); state.video.status = 'waitingPlatform'; attemptedAt = 0; return; }
|
||
if ((page.hidden || pageAway) && video.paused && (playStarted || visibilityPlayback)) {
|
||
rememberPlayback(); lastAdvancedAt = now(); attemptedAt = 0;
|
||
state.video.status = 'backgroundPaused'; taskState(task, 'playing', '网站在后台暂停播放，等待切回页面后恢复'); return;
|
||
}
|
||
if (returnResumeRequested) {
|
||
const previous = visibilityPlayback; returnResumeRequested = false; visibilityPlayback = null;
|
||
if (previous && previous.taskId === task.id && previous.url === page.url && previous.video === video && previous.generation === epoch && config.resumePlaybackOnReturn) {
|
||
lastAdvancedAt = now(); attemptedAt = 0; lastTime = null;
|
||
if (video.paused) { playStarted = false; taskState(task, 'playing', '已切回页面，正在继续原播放位置'); }
|
||
}
|
||
} else if (visibilityPlayback && !page.hidden && !pageAway && video.paused && !config.resumePlaybackOnReturn) {
|
||
state.video.status = 'waiting'; taskState(task, 'waiting', '切回页面自动恢复已关闭，请手动播放后继续任务'); return;
|
||
}
|
||
if (!Number.isFinite(video.playbackRate) || Math.abs(video.playbackRate - config.rate) > 0.01) { try { video.playbackRate = config.rate; } catch (_) {} }
|
||
state.video.actualRate = video.playbackRate;
|
||
if (Math.abs(video.playbackRate - config.rate) > 0.01) state.video.rateMessage = '网站未接受所选倍速，当前实际 ' + video.playbackRate + 'X';
|
||
if (!playStarted) {
|
||
playStarted = true;
|
||
lastAutoPlayAt = now();
|
||
try { const promise = video.play(); if (promise && promise.catch) await promise; }
|
||
catch (error) { log('warn', '播放器启动失败', task, { errorName: error?.name, error: String(error?.message || error || '未知播放错误'), currentTime, rate: video.playbackRate }, 'video.playFailed'); taskState(task, 'waiting', '浏览器拒绝自动播放，请手动播放后继续'); state.video.status = 'waiting'; return; }
|
||
if (epoch !== generation || state.status !== 'running') { video.pause(); return; }
|
||
lastAdvancedAt = now();
|
||
}
|
||
if (lastTime === null || Math.abs(currentTime - lastTime) > 0.01) { lastTime = currentTime; lastAdvancedAt = now(); attemptedAt = 0; taskState(task, 'playing', page.hidden ? '页面在后台，按真实播放与平台记录跟踪' : '视频播放中'); return; }
|
||
if (!attemptedAt && now() - lastAdvancedAt >= config.stallSeconds * 1000) {
|
||
attemptedAt = now(); taskState(task, 'retrying', '播放进度长时间未变化，先尝试续播');
|
||
try { await video.play(); } catch (error) { log('warn', '播放器续播失败', task, { errorName: error?.name, error: String(error?.message || error || '未知播放错误'), currentTime, rate: video.playbackRate }, 'video.resumeFailed'); taskState(task, 'waiting', '续播被浏览器拒绝，请人工操作'); }
|
||
return;
|
||
}
|
||
if (attemptedAt && now() - attemptedAt >= config.recoverySeconds * 1000) {
|
||
if ((task.retryCount || 0) >= config.maxRefreshes) { taskState(task, 'failed', '已达到本课件最多 ' + config.maxRefreshes + ' 次恢复上限，请人工处理'); state.video.status = 'failed'; return; }
|
||
if (task.lastRefreshAt && now() - task.lastRefreshAt < config.minRefreshSeconds * 1000) return;
|
||
if (!await heartbeat(task) || epoch !== generation || state.status !== 'running') return;
|
||
task.retryCount = (task.retryCount || 0) + 1; task.lastRefreshAt = now(); taskState(task, 'retrying', '视频续播失败，保存检查点后刷新当前视频页（' + task.retryCount + '/' + config.maxRefreshes + '）');
|
||
await persist();
|
||
await storage.set('recover:' + page.url, { sessionId: session.id, taskId: task.id, accountId: account(snap, page), expires: now() + 60000 });
|
||
if (typeof options.reload === 'function') await options.reload(); else if (root.location && canonical(root.location.href) === page.url) root.location.reload();
|
||
attemptedAt = 0; lastAdvancedAt = now();
|
||
}
|
||
}
|
||
async function observeExamState(task, readOnly) {
|
||
// 仅观察已经交给本场控制器的考试，避免将旧场次结果附到尚未开考的任务。
|
||
if (!task.examRequested) return;
|
||
const exam = typeof options.getExamState === 'function' ? options.getExamState() : null;
|
||
if (!exam) return;
|
||
state.exam = Object.assign({ taskId: task.id, title: task.title }, clone(exam));
|
||
state.exam.total = exam.total == null && exam.details ? exam.details.length : exam.total;
|
||
state.exam.verified = exam.verifiedCount == null ? exam.verified : exam.verifiedCount;
|
||
const stage = exam.stage || exam.status;
|
||
if (stage === 'completed' || stage === 'submitted' || exam.submitted === true && exam.confirmed === true) { task.progress = 1; taskState(task, 'completed', '网站已确认本场考试提交完成'); activeTaskId = ''; await release(); }
|
||
else if (!readOnly && ['waiting', 'paused', 'failed', 'unknown', 'awaitingAttempt'].includes(stage)) taskState(task, 'waiting', exam.reason || exam.message || '考试等待人工处理');
|
||
else if (!readOnly && stage === 'waitingSubmit') taskState(task, 'waitingSubmit', exam.reason || '已核验，等待最早交卷时间');
|
||
}
|
||
async function examTick(task, snap, page) {
|
||
if (['exam', 'paper'].includes(page.kind)) {
|
||
const sourceURL = task.examPaperURL || task.url || task.pageUrl;
|
||
const sameURL = canonical(sourceURL) === page.url || examIdentity(sourceURL) && examIdentity(sourceURL) === examIdentity(page.url);
|
||
if (!sameURL) { taskState(task, 'waiting', '当前考试与已领取任务的地址不同，请核对后开始新一轮'); return; }
|
||
if (page.kind === 'paper' && task.enterClickedAt && !task.examPaperURL && page.title === task.title) task.examPaperURL = page.url;
|
||
}
|
||
const attempts = readExamAttempt(task, snap, page);
|
||
if (task.examRequested && task.examNeedsRecheck) {
|
||
await observeExamState(task, true);
|
||
if (task.status === 'completed') return;
|
||
}
|
||
if (config.skipSingleAttemptQuiz && attempts.blocked && !task.examRequested) {
|
||
state.exam = { taskId: task.id, title: task.title, stage: 'waiting', requiresManualSubmission: true, message: attempts.reason };
|
||
taskState(task, 'waiting', attempts.reason); return;
|
||
}
|
||
// 人工交卷后仍需接收网站确认；等待/局部暂停期间不得重新开考或启动答题。
|
||
if (task.status === 'waiting' || config.examPaused) {
|
||
await observeExamState(task, true);
|
||
if (task.status !== 'completed' && config.examPaused) taskState(task, 'waiting', '考试任务已局部暂停');
|
||
return;
|
||
}
|
||
if (!['exam', 'paper'].includes(page.kind)) {
|
||
const node = resolveNode(task, snap);
|
||
if (node && !task.examLinkClickedAt) {
|
||
task.examLinkClickedAt = now(); taskState(task, 'loading', '通过课程目录的原始关联考试入口打开考试'); await persist();
|
||
await storage.set('transition.v1', { sessionId: session.id, taskId: task.id, workerNonce: worker && worker.nonce || '', sourceURL: page.url, targetURL: '', title: task.title, accountId: account(snap, page), expires: now() + 60000 });
|
||
node.click();
|
||
} else if (task.examLinkClickedAt && now() - task.examLinkClickedAt > 15000) taskState(task, 'waiting', '关联考试入口未进入考试，请核对网站限制');
|
||
return;
|
||
}
|
||
task.preflight = preflightTopic(snap.document, snap, config.associations, task);
|
||
if (task.preflight.status !== 'matched') { taskState(task, task.preflight.status === 'missing' ? 'skipped' : 'waiting', task.preflight.reason); return; }
|
||
if (page.kind === 'exam') {
|
||
const blockers = Array.from(snap.document.querySelectorAll('.exam_qrcode_box,[data-auth-required],.ant-modal-wrap')).filter(node => visible(node) && /人脸|身份验证|考前须知|登录/.test(clean(node.textContent)));
|
||
if (blockers.length) { taskState(task, 'waiting', '考试需要身份验证或阅读须知，请人工完成后继续'); return; }
|
||
if (task.enterClickedAt) { if (now() - task.enterClickedAt > 15000) taskState(task, 'waiting', '开考页面未进入试卷，请人工检查限制或提示'); return; }
|
||
const buttons = Array.from(snap.document.querySelectorAll('.examdetail_button')).filter(node => visible(node) && !node.matches('[disabled],[aria-disabled="true"]') && /^(?:开始答题|继续答题|开始考试|继续考试)$/.test(clean(node.textContent)));
|
||
if (buttons.length !== 1) { taskState(task, 'waiting', '找不到唯一有效的正常开考入口，请人工进入试卷'); return; }
|
||
task.enterClickedAt = now(); taskState(task, 'loading', '主题预检通过，通过网页正常按钮进入考试'); await persist();
|
||
await storage.set('transition.v1', { sessionId: session.id, taskId: task.id, workerNonce: worker && worker.nonce || '', sourceURL: page.url, targetURL: '', title: task.title, accountId: account(snap, page), expires: now() + 60000 });
|
||
buttons[0].click(); return;
|
||
}
|
||
if (!task.examRequested || task.examNeedsRecheck || task.examPage !== page.kind) {
|
||
task.examPage = page.kind; taskState(task, 'answering', '考试主题已确认，交给答题与交卷控制器');
|
||
if (typeof options.onExamStart === 'function') {
|
||
const accepted = await options.onExamStart({ task: clone(task), preflight: clone(task.preflight), document: snap.document, page: page.kind, config: clone(config) });
|
||
task.examRequested = accepted !== false;
|
||
if (accepted !== false) task.examNeedsRecheck = false;
|
||
if (accepted === false) { if (!task.readyWaitAt) task.readyWaitAt = now(); if (now() - task.readyWaitAt > 15000) taskState(task, 'waiting', '试卷未完整加载，请人工核对后继续'); }
|
||
}
|
||
else taskState(task, 'waiting', '考试控制器尚未接入，请人工处理');
|
||
}
|
||
await observeExamState(task, false);
|
||
}
|
||
async function parallelTick(snap, page) {
|
||
if (config.execution !== 'parallel' || worker || !session) return;
|
||
const local = state.tasks.find(t => t.id === activeTaskId); const opposite = local && local.kind === 'exam' ? 'video' : 'exam';
|
||
for (const t of state.tasks) {
|
||
const checkpoint = await storage.get('task:' + session.id + ':' + t.id);
|
||
if (checkpoint) Object.assign(t, checkpoint);
|
||
if (t.workerNonce) {
|
||
const status = await storage.get('worker:' + t.workerNonce);
|
||
if (status && status.confirmedAt && status.owner && (!status.heartbeatAt || now() - status.heartbeatAt < LEASE_MS)) {
|
||
if (status.video && (!local || local.kind !== 'video')) state.video = clone(status.video);
|
||
if (status.exam && (!local || local.kind !== 'exam')) state.exam = clone(status.exam);
|
||
}
|
||
}
|
||
}
|
||
const requested = state.tasks.find(t => t.workerNonce && !TERMINAL.includes(t.status));
|
||
if (requested) {
|
||
const request = await storage.get('worker:' + requested.workerNonce);
|
||
if (request && request.confirmedAt && request.owner && (!request.heartbeatAt || now() - request.heartbeatAt < LEASE_MS)) {
|
||
requested.status = request.status || 'loading'; state.message = '并行执行器已确认启动：最多一个视频和一场考试';
|
||
if (request.video && (!local || local.kind !== 'video')) state.video = clone(request.video);
|
||
if (request.exam && (!local || local.kind !== 'exam')) state.exam = clone(request.exam);
|
||
}
|
||
else if (!request || request.expires <= now()) { taskState(requested, 'waiting', '另一个页面未确认启动，可能被浏览器拦截；请打开任务后继续'); }
|
||
else state.message = '正在等待另一执行页面确认，尚未开始并行';
|
||
return;
|
||
}
|
||
if (!local || !['video', 'exam'].includes(local.kind)) return;
|
||
const next = state.tasks.find(t => t.kind === opposite && t.status === 'pending' && allows(t.kind) && !t.locked && (!t.requiresParent || !t.parentId || state.tasks.find(p => p.id === t.parentId && p.status === 'completed')));
|
||
if (!next) return;
|
||
if (next.kind === 'exam') { next.preflight = preflightTopic(snap.document, snap, config.associations, next); if (next.preflight.status !== 'matched') { taskState(next, next.preflight.status === 'missing' ? 'skipped' : 'waiting', next.preflight.reason); return; } }
|
||
// Angular目录没有href时，先打开已经访问过的真实课程URL，再在工作页点击原目录节点。
|
||
const targetURL = next.url || next.selector && next.pageUrl || '';
|
||
if (!targetURL || !safeURL(targetURL, snap.url)) { taskState(next, 'waiting', '并行任务缺少网页真实链接或可恢复目录，请在另一页面打开对应任务'); return; }
|
||
if (typeof options.openWorker !== 'function') { taskState(next, 'waiting', '当前环境不能创建受控执行页面，请人工打开任务'); return; }
|
||
const nonce = token(); const url = new URL(targetURL); url.hash = (url.hash ? url.hash.slice(1) + '&' : '') + '__yian_worker=' + nonce;
|
||
next.workerNonce = nonce; next.status = 'loading';
|
||
await storage.set('worker:' + nonce, { nonce, sessionId: session.id, taskId: next.id, url: canonical(targetURL), expires: now() + 30000 }); await persist();
|
||
try { const opened = await options.openWorker(url.href); if (opened === false || opened === null) taskState(next, 'waiting', '并行页面被浏览器拦截，请人工打开任务'); else log('info', '已请求打开执行页面，等待其心跳确认', next); }
|
||
catch (_) { taskState(next, 'waiting', '并行页面打开失败，请人工处理'); }
|
||
}
|
||
async function tick() {
|
||
if (destroyed) return getState();
|
||
// 课中题异步处理期间仍响应另一标签页的全局暂停，不能等整段答题结束。
|
||
if (busy) {
|
||
if (await observeControl()) return getState();
|
||
const task = state.tasks.find(t => t.id === activeTaskId);
|
||
if (state.status === 'running' && task && !await heartbeat(task)) {
|
||
// 弹题等待中的旧异步流程必须立即失效，getActive 随状态变更阻止后续提交。
|
||
generation++; state.status = 'paused'; sharedPaused = false;
|
||
state.message = '当前任务租约已失效或被另一执行器领取，旧答题流程已暂停';
|
||
if (session) session.status = 'paused';
|
||
const snap = snapshot(); const page = snap.document && describePage(snap.document, snap.url);
|
||
if (page && page.video) page.video.pause();
|
||
if (state.video) state.video.status = 'waiting';
|
||
if (options.onExamPause) options.onExamPause(state.message);
|
||
taskState(task, 'waiting', state.message); await release(); notify();
|
||
}
|
||
return getState();
|
||
}
|
||
busy = true; const epoch = generation;
|
||
try {
|
||
await initialize(); const snap = snapshot(); if (!snap.document) return getState();
|
||
const page = describePage(snap.document, snap.url);
|
||
if (!safeURL(snap.url, snap.url)) { if (state.status === 'running') await pause('离开已授权站点，任务已暂停'); return getState(); }
|
||
if (session) {
|
||
const controlValue = await storage.get(CONTROL_KEY);
|
||
if (epoch !== generation) return getState();
|
||
if (await observeControl(controlValue)) return getState();
|
||
if (worker && controlValue && controlValue.sessionId === session.id && controlValue.config) {
|
||
const sharedConfig = Object.assign({}, controlValue.config); for (const key of POLICY_KEYS) delete sharedConfig[key];
|
||
Object.assign(config, sharedConfig);
|
||
}
|
||
if (session.accountId && session.accountId !== account(snap, page) || session.bankVersion && snap.bankVersion && session.bankVersion !== snap.bankVersion) { await pause('账号或题库版本改变，已暂停旧任务'); return getState(); }
|
||
}
|
||
if (pageKey !== page.url) { pageKey = page.url; playStarted = false; lastTime = null; attemptedAt = 0; lastAdvancedAt = now(); visibilityPlayback = null; returnResumeRequested = false; playbackPromptClick = null; requirementProbe = null; }
|
||
let task = state.tasks.find(t => t.id === activeTaskId);
|
||
if (task && task.kind === 'course' && ['course', 'video'].includes(page.kind)) {
|
||
const arrived = task.url ? canonical(task.url) === page.url
|
||
: task.courseEntryClickedAt != null && task.title === page.title && page.url !== canonical(task.pageUrl) && page.url !== task.courseEntrySourceURL;
|
||
if (arrived) { task.visitedCourseURL = page.url; mergeTasks(discoverTasks(snap.document, snap.url), task); taskState(task, 'expanded', '已读取课程目录；课件须逐一等待平台确认完成'); activeTaskId = ''; await release(); task = null; }
|
||
// 跳转是异步的，仍在原课程时等待，不把原目录挂到下一课程名下。
|
||
} else mergeTasks(discoverTasks(snap.document, snap.url));
|
||
if (state.status !== 'running') { await persist(); notify(); return getState(); }
|
||
if (task && TERMINAL.includes(task.status)) { activeTaskId = ''; await release(); task = null; }
|
||
if (!task) {
|
||
const candidates = state.tasks.filter(t => (['pending', 'waitingLease'].includes(t.status)
|
||
|| t.status === 'waitingExam' && linkedExams(t).length && linkedExams(t).every(e => e.status === 'completed'))
|
||
&& allows(t.kind) && (!worker || t.id === worker.taskId));
|
||
// 当前页面的实际课件优先；顺序执行先完成可用视频，再处理关联考试。
|
||
function rank(t) { return (canonical(t.pageUrl) === page.url ? 0 : 10) + (t.kind === 'video' ? 0 : t.kind === 'exam' ? 1 : 2); }
|
||
candidates.sort((a, b) => rank(a) - rank(b));
|
||
const blockedKinds = new Set();
|
||
for (const next of candidates) {
|
||
const kind = next.kind === 'course' ? 'video' : next.kind; if (blockedKinds.has(kind)) continue;
|
||
const activated = await activate(next, snap, page);
|
||
if (activated) { task = next; if (activated === 'deferred') task = null; break; }
|
||
if (next.status === 'waitingLease') { blockedKinds.add(kind); if (config.execution === 'sequential') break; }
|
||
}
|
||
}
|
||
if (task && epoch === generation) {
|
||
const held = await heartbeat(task) || await claim(task);
|
||
if (held) {
|
||
acquiredLease(task);
|
||
if (task.status !== 'waiting' && task.kind === 'video') await videoTick(task, snap, page, epoch);
|
||
else if (task.kind === 'exam') await examTick(task, snap, page);
|
||
else if (task.kind === 'course') await courseTick(task, snap, page, epoch);
|
||
}
|
||
}
|
||
if (epoch === generation) await parallelTick(snap, page);
|
||
if (worker && session) { const request = await storage.get('worker:' + worker.nonce); if (request) { const own = task || state.tasks.find(t => t.id === worker.taskId); request.heartbeatAt = now(); request.status = own && own.status || 'idle'; request.video = state.video; request.exam = state.exam; await storage.set('worker:' + worker.nonce, request); } }
|
||
const remaining = state.tasks.filter(t => allows(t.kind) && !TERMINAL.includes(t.status));
|
||
if (!task && !remaining.length) { state.status = state.tasks.length ? 'finished' : 'waiting'; state.message = state.tasks.length ? '本轮调度结束；请检查完成、跳过及失败清单' : '当前页面没有可识别的任务，请打开学习地图、课程或试卷'; if (session) session.status = state.status; await control(state.status); }
|
||
else if (!task && remaining.every(t => t.status === 'waiting')) { state.message = '剩余任务等待人工处理；确认后点击继续'; }
|
||
await persist(); notify(); return getState();
|
||
} catch (error) { state.message = '学习调度异常：' + error.message; state.status = 'paused'; if (session) session.status = 'paused'; await control('paused'); await release(); log('error', state.message, null, { errorName: error.name, error: error.message, stack: error.stack }, 'learning.error'); return getState(); }
|
||
finally { busy = false; }
|
||
}
|
||
async function observeControl(value) {
|
||
if (!session) return false;
|
||
const controlEpoch = generation;
|
||
const shared = value === undefined ? await storage.get(CONTROL_KEY) : value;
|
||
await syncPolicies(shared);
|
||
if (controlEpoch !== generation) return true;
|
||
if (state.status !== 'running' && !sharedPaused) return false;
|
||
if (sharedPaused && shared && shared.sessionId === session.id && shared.status === 'running') {
|
||
sharedPaused = false; generation++; state.status = 'running'; session.status = 'running'; state.message = '已收到继续全部任务，重新核验当前页面'; playStarted = false; manualVideoPause = false; attemptedAt = 0; lastTime = null; lastAdvancedAt = now();
|
||
const active = state.tasks.find(t => t.id === activeTaskId); if (active) { active.examRequested = false; if (active.status === 'waiting') active.status = 'pending'; }
|
||
notify(); return false;
|
||
}
|
||
if (!shared || shared.sessionId === session.id && shared.status === 'running') return false;
|
||
if (state.status !== 'running') return false;
|
||
generation++; state.status = shared.status === 'stopped' && shared.sessionId === session.id ? 'stopped' : 'paused'; sharedPaused = shared.sessionId === session.id && shared.status === 'paused';
|
||
state.message = shared.sessionId !== session.id ? '另一页面已开始新一轮任务，旧执行器已停止' : '全局任务已暂停；网站考试倒计时仍会继续';
|
||
const snap = snapshot(); const page = snap.document && describePage(snap.document, snap.url); if (page && page.video) page.video.pause();
|
||
if (options.onExamPause) options.onExamPause(state.message); await release(); notify(); return true;
|
||
}
|
||
function getState() { return clone(state); }
|
||
function clearLogs() { state.logs = []; notify(); persist().catch(() => {}); }
|
||
function destroy() {
|
||
destroyed = true; generation++;
|
||
if (watchedDocument) {
|
||
watchedDocument.removeEventListener('pointerdown', onInteraction, true); watchedDocument.removeEventListener('keydown', onInteraction, true); watchedDocument.removeEventListener('pause', onVideoPause, true);
|
||
watchedDocument.removeEventListener('visibilitychange', onVisibilityChange, true);
|
||
watchedDocument.removeEventListener('mouseover', onRequirementHover, true);
|
||
if (watchedDocument.defaultView) { watchedDocument.defaultView.removeEventListener('blur', onPageHidden); watchedDocument.defaultView.removeEventListener('focus', onPageReturn); }
|
||
}
|
||
if (typeof options.onExamPause === 'function') options.onExamPause('学习控制器已退出'); release().catch(() => {});
|
||
}
|
||
return { configure, start, pause, resume, stop, tick, getState, getAttemptPolicy, destroy, log, clearLogs };
|
||
}
|
||
return { create, describePage, discoverTasks, preflightTopic };
|
||
});
|