待发送
${item.explain ? `
说明：${escapeHtml(item.explain)}
` : ''}
${bodyHtml}
`;
}).join('');
}
function setSendStatus(text) {
const el = qs('#pbt-send-status');
if (el) el.textContent = text || '';
}
function setHistoryItemStatus(index, text, cls = '') {
const el = qs(`#pbt-history-status-${index}`);
if (!el) return;
el.className = `pbt-status ${cls}`;
el.textContent = text;
}
function getSelectedHistoryItems() {
return (state.solutionItems || [])
.filter(item => item.checked)
.sort((a, b) => Number(a.index || 0) - Number(b.index || 0));
}
async function fetchSocketToken() {
if (!state.teacherToken) {
ensureTeacherToken(true);
}
if (!state.teacherToken) {
throw new Error('没有教师 HTTP Token，无法获取 socket token。');
}
const data = await teacherGet('/apis/teacher/socket', true);
if (!data || !data.token) {
throw new Error('获取 socket token 失败：' + JSON.stringify(data).slice(0, 300));
}
state.socketToken = data.token;
log('已获取 socket token', 'success');
return state.socketToken;
}
function closeSocket() {
try {
if (state.ws && state.ws.readyState === WebSocket.OPEN) {
state.ws.send('41/sim/room-talk,');
state.ws.close();
}
} catch (_) {}
state.ws = null;
state.namespaceConnected = false;
state.ackMap.clear();
}
async function connectSocket() {
if (!state.currentRoomId) {
throw new Error('缺少当前 room_id，不能连接房间。');
}
if (!state.socketToken) {
await fetchSocketToken();
}
closeSocket();
return new Promise((resolve, reject) => {
const ws = new WebSocket(CONFIG.SOCKET_URL);
state.ws = ws;
state.namespaceConnected = false;
const timer = setTimeout(() => {
reject(new Error('WebSocket 连接超时'));
}, 15000);
ws.onopen = () => {
log('WebSocket 已打开，等待 Engine.IO open');
};
ws.onerror = () => {
clearTimeout(timer);
reject(new Error('WebSocket 连接错误'));
};
ws.onclose = () => {
state.namespaceConnected = false;
log('WebSocket 已关闭', 'warn');
};
ws.onmessage = event => {
const data = event.data;
if (typeof data === 'string' && data.startsWith('0{')) {
ws.send('40');
setTimeout(() => {
ws.send(`40/sim/room-talk,{"token":"${state.socketToken}"}`);
}, 180);
return;
}
if (data === '2') {
ws.send('3');
return;
}
if (typeof data === 'string' && data.startsWith('40/sim/room-talk,')) {
state.namespaceConnected = true;
ws.send(`42/sim/room-talk,["teacher-join-room",{"room_id":${Number(state.currentRoomId)}}]`);
clearTimeout(timer);
log(`已连接 /sim/room-talk，并加入 room_id=${state.currentRoomId}`, 'success');
resolve(true);
return;
}
if (typeof data === 'string' && data.startsWith('43/sim/room-talk,')) {
handleAck(data);
return;
}
if (typeof data === 'string' && data.startsWith('42/sim/room-talk,')) {
log('收到服务端推送事件');
}
};
});
}
function handleAck(frame) {
const match = frame.match(/^43\/sim\/room-talk,(\d+)(.*)$/);
if (!match) {
log(`收到未知 ack：${frame}`, 'warn');
return;
}
const ackId = Number(match[1]);
const payloadText = match[2] || '';
const payload = safeJsonParse(payloadText, null);
const task = state.ackMap.get(ackId);
if (!task) return;
clearTimeout(task.timer);
state.ackMap.delete(ackId);
task.resolve(payload);
}
function sendTeacherMessage({ room_id, msg_type, msg_body }) {
return new Promise((resolve, reject) => {
if (!state.ws || state.ws.readyState !== WebSocket.OPEN || !state.namespaceConnected) {
reject(new Error('WebSocket 未连接，不能发送。'));
return;
}
const ackId = state.ackSeq++;
const payload = JSON.stringify([
'teacher-send-message',
{
room_id: Number(room_id),
msg_type,
msg_body
}
]);
const frame = `42/sim/room-talk,${ackId}${payload}`;
const timer = setTimeout(() => {
state.ackMap.delete(ackId);
reject(new Error(`发送超时：ackId=${ackId}`));
}, 20000);
state.ackMap.set(ackId, {
resolve,
reject,
timer
});
state.ws.send(frame);
});
}
async function forwardSelectedSolution() {
if (state.isSending) return;
const selected = getSelectedHistoryItems();
if (!state.currentIssueId || !state.currentRoomId) {
await fetchCurrentIssueInfo({ askForToken: true });
}
if (!state.oldProblemRecord || !state.solutionItems.length) {
throw new Error('请先读取历史 issue_problems 解答。');
}
if (!selected.length) {
throw new Error('没有勾选任何要发送的解答内容。');
}
const info = state.currentIssueInfo || {};
const confirmText = [
'确认把历史解答发送给当前页面学生？',
'',
`当前学生：${info.student_name || '-'}`,
`当前 issueId：${state.currentIssueId}`,
`当前 room_id：${state.currentRoomId}`,
`历史解答 ID：${state.oldProblemId}`,
`勾选内容：${selected.length} 条`,
'',
'本次只发送勾选的历史解答内容，不发送开场提示和结尾提示。'
].join('\n');
if (!window.confirm(confirmText)) return;
state.isSending = true;
state.stopSending = false;
const sendBtn = qs('#pbt-send-btn');
const stopBtn = qs('#pbt-stop-btn');
if (sendBtn) sendBtn.disabled = true;
if (stopBtn) stopBtn.disabled = false;
try {
setSendStatus('正在连接 WebSocket...');
await connectSocket();
setSendStatus('正在发送...');
for (const item of selected) {
if (state.stopSending) {
log('用户已停止发送', 'warn');
break;
}
const index = state.solutionItems.indexOf(item);
setHistoryItemStatus(index, '发送中', 'wait');
log(`发送 #${item.index} ${item.msg_type}`);
try {
const ack = await sendTeacherMessage({
room_id: state.currentRoomId,
msg_type: item.msg_type,
msg_body: item.msg_body
});
const msgId = Array.isArray(ack) && ack[0] && ack[0].msg_id ? ack[0].msg_id : '';
setHistoryItemStatus(index, msgId ? `已发送 ${msgId}` : '已发送', 'ok');
log(`#${item.index} 已发送 ${msgId ? 'msg_id=' + msgId : ''}`, 'success');
} catch (err) {
setHistoryItemStatus(index, '发送失败', 'err');
log(`#${item.index} 发送失败：${err.message}`, 'error');
throw err;
}
await sleep(state.delayMs);
}
setSendStatus('发送完成');
log('全部发送流程结束', 'success');
} finally {
state.isSending = false;
if (sendBtn) sendBtn.disabled = false;
if (stopBtn) stopBtn.disabled = true;
closeSocket();
}
}
function boot() {
createPanel();
}
installRequestInterceptor();
ready(boot);
let lastHref = location.href;
setInterval(() => {
if (location.href === lastHref) return;
lastHref = location.href;
state.currentIssueId = null;
state.currentRoomId = null;
state.currentIssueInfo = null;
state.profile = null;
state.messages = [];
state.existingOrder = null;
state.existingProblem = null;
state.existingProblems = [];
delete state.lastTeacherResponseCache.issue;
delete state.lastTeacherResponseCache.chatMessage;
renderCurrentInfo();
log('检测到页面切换，已重置当前目标。', 'warn');
setTimeout(() => {
fetchCurrentIssueInfo().catch(err => log(err.message, 'warn'));
}, 800);
}, 1000);
})();