// ==UserScript== // @name [银河奶牛]自动计算购买材料 // @name:zh-CN [银河奶牛]自动计算购买材料 // @name:en MWI-AutoBuyer // @namespace http://tampermonkey.net/ // @version 2.2.1 // @description 自动计算制造、烹饪、房屋等所需材料，一键购买缺少的材料(Automatically calculate the required material quantities and purchase needed materials with one click.) // @description:en Automatically calculate the required material quantities and purchase needed materials with one click. // @author XIxixi297 // @license CC-BY-NC-SA-4.0 // @match https://www.milkywayidle.com/* // @match https://test.milkywayidle.com/* // @icon https://www.google.com/s2/favicons?sz=64&domain=milkywayidle.com // @grant none // @run-at document-start // @downloadURL none // ==/UserScript== (function () { 'use strict'; let scriptInjected = false; let mooketMode = false; // 标记是否使用Mooket接口模式 const AUTO_BUY_SCRIPT = ` (function () { 'use strict'; // 语言配置 const LANG = (navigator.language || 'en').toLowerCase().includes('zh') ? { directBuyButton: '直接购买（左一）', bidOrderButton: '求购订单（右一）', directBuyButtonActive: '⏳ 购买中...', bidOrderButtonActive: '📋 提交中...', missingPrefix: '缺:', noMaterialsNeeded: '材料充足！', startDirectPurchasing: '开始直接购买', startBidOrdering: '开始提交求购订单', purchased: '已购买', orderSubmitted: '订单已提交', purchaseFailed: '购买失败', orderFailed: '订单提交失败', purchaseComplete: '购买完成！', orderComplete: '订单提交完成！', purchaseError: '购买出错，请检查控制台', wsNotAvailable: 'WebSocket日志查看器未可用，请确保已启用', waitingForLogger: '等待WebSocket日志查看器...', loggerReady: 'WebSocket日志查看器已就绪！', requestFailed: '请求失败', requestTimeout: '请求超时', allPurchasesFailed: '所有购买都失败了，请检查控制台', allOrdersFailed: '所有订单都失败了，请检查控制台', purchaseSuccess: '成功购买', orderSuccess: '成功提交', materials: '种材料', each: '个' } : { directBuyButton: 'Buy from WTS', bidOrderButton: 'New Buy Listing', directBuyButtonActive: '⏳ Buying...', bidOrderButtonActive: '📋 Submitting...', missingPrefix: 'Need:', noMaterialsNeeded: 'All materials sufficient!', startDirectPurchasing: 'Start direct purchasing', startBidOrdering: 'Start submitting bid orders', purchased: 'Purchased', orderSubmitted: 'Order submitted', purchaseFailed: 'Purchase failed', orderFailed: 'Order submit failed', purchaseComplete: 'Purchase completed!', orderComplete: 'Orders submitted!', purchaseError: 'Purchase error, check console', wsNotAvailable: 'WebSocket logger not available, ensure it is enabled', waitingForLogger: 'Waiting for WebSocket logger...', loggerReady: 'WebSocket logger ready!', requestFailed: 'Request failed', requestTimeout: 'Request timeout', allPurchasesFailed: 'All purchases failed, check console', allOrdersFailed: 'All orders failed, check console', purchaseSuccess: 'Successfully purchased', orderSuccess: 'Successfully submitted', materials: 'materials', each: '' }; const SELECTORS = { production: { container: '.SkillActionDetail_regularComponent__3oCgr', input: '.Input_input__2-t98', requirements: '.SkillActionDetail_itemRequirements__3SPnA', upgradeSelector: '.SkillActionDetail_upgradeItemSelectorInput__2mnS0', nameDiv: '.SkillActionDetail_name__3erHV', inventoryCount: '.SkillActionDetail_inventoryCount__tHmPD', inputCount: '.SkillActionDetail_inputCount__1rdrn' }, house: { container: '.HousePanel_modalContent__3AwPH', requirements: '.HousePanel_itemRequirements__1qFjZ', headerDiv: '.HousePanel_header__3QdpP', inventoryCount: '.HousePanel_inventoryCount__YxePN', inputCount: '.HousePanel_inputCount__26GPq' } }; // 工具函数 function getCountById(id) { const targetId = \`/items/\${id}\`; const container = document.querySelector('.Inventory_inventory__17CH2'); if (!container?.lastChild) return 0; const items = container.lastChild.querySelectorAll(".Item_item__2De2O.Item_clickable__3viV6"); for (let item of items) { try { const reactKey = Object.keys(item).find(key => key.startsWith('__reactProps')); if (!reactKey) continue; const itemHrid = item[reactKey].children[0][1]._owner.memoizedProps.itemHrid; if (itemHrid === targetId) { return item[reactKey].children[0][1]._owner.memoizedProps.count; } } catch (e) { continue; } } return 0; } function parseNumber(text) { if (!text) return 0; const match = text.match(/^([\\d,]+(?:\\.\\d+)?)\\s*([KMB])$/i); if (!match) return parseInt(text.replace(/[^\\d]/g, ''), 10) || 0; let num = parseFloat(match[1].replace(/,/g, '')); const multipliers = { K: 1000, M: 1000000, B: 1000000000 }; return Math.floor(num * (multipliers[match[2].toUpperCase()] || 1)); } function extractItemId(svgElement) { const useElement = svgElement?.querySelector('use'); const href = useElement?.getAttribute('href'); const match = href?.match(/#(.+)$/); return match ? match[1] : null; } // PostMessage API class PostMessageAPI { constructor() { this.pendingRequests = new Map(); this.requestIdCounter = 1; this.setupMessageListener(); } setupMessageListener() { window.addEventListener('message', (event) => { if (event.origin !== window.location.origin) return; const message = event.data; if (message.type === 'ws_response') { const pendingRequest = this.pendingRequests.get(message.requestId); if (pendingRequest) { this.pendingRequests.delete(message.requestId); clearTimeout(pendingRequest.timeout); pendingRequest[message.success ? 'resolve' : 'reject']( message.success ? message.data : new Error(message.error || LANG.requestFailed) ); } } else if (message.type === 'ws_ready') { this.checkAPI(); } }); } async sendRequest(action, data = {}, timeout = 30000) { const requestId = \`req_\${this.requestIdCounter++}_\${Date.now()}\`; return new Promise((resolve, reject) => { const timeoutId = setTimeout(() => { this.pendingRequests.delete(requestId); reject(new Error(\`\${LANG.requestTimeout}: \${action}\`)); }, timeout); this.pendingRequests.set(requestId, { resolve, reject, timeout: timeoutId }); window.postMessage({ type: 'ws_request', action, data, requestId }, window.location.origin); }); } async checkAPI() { try { return await this.sendRequest('check_api', {}, 5000); } catch { return { available: false }; } } async batchDirectPurchase(items, delayBetween = 800) { return await this.sendRequest('batch_direct_purchase', { items, delayBetween }); } async batchBidOrder(items, delayBetween = 800) { return await this.sendRequest('batch_bid_order', { items, delayBetween }); } } // 通知系统 class Toast { constructor() { this.container = document.createElement('div'); Object.assign(this.container.style, { position: 'fixed', top: '20px', left: '50%', transform: 'translateX(-50%)', zIndex: '10000', pointerEvents: 'none' }); document.body.appendChild(this.container); } show(message, type = 'info', duration = 3000) { const toast = document.createElement('div'); toast.textContent = message; const colors = { info: '#2196F3', success: '#4CAF50', warning: '#FF9800', error: '#F44336' }; Object.assign(toast.style, { background: colors[type], color: 'white', padding: '12px 24px', borderRadius: '6px', marginBottom: '10px', fontSize: '14px', fontWeight: '500', opacity: '0', transform: 'translateY(-20px)', transition: 'all 0.3s ease', boxShadow: '0 4px 12px rgba(0,0,0,0.3)' }); this.container.appendChild(toast); setTimeout(() => Object.assign(toast.style, { opacity: '1', transform: 'translateY(0)' }), 10); setTimeout(() => { Object.assign(toast.style, { opacity: '0', transform: 'translateY(-20px)' }); setTimeout(() => toast.remove(), 300); }, duration); } } // 材料计算器 class MaterialCalculator { static async calculateRequirements(type) { const selectors = SELECTORS[type]; const container = document.querySelector(selectors.container); if (!container) return []; const requirements = []; let productionQuantity = 1; if (type === 'production') { const input = document.querySelector(selectors.input); productionQuantity = parseInt(input?.value) || 0; } // 计算普通材料需求 const requirementsContainer = container.querySelector(selectors.requirements); if (requirementsContainer) { const materialContainers = requirementsContainer.querySelectorAll('.Item_itemContainer__x7kH1'); const inventoryCounts = requirementsContainer.querySelectorAll(selectors.inventoryCount); const inputCounts = requirementsContainer.querySelectorAll(selectors.inputCount); for (let i = 0; i < materialContainers.length; i++) { const nameElement = materialContainers[i].querySelector('.Item_name__2C42x'); const svgElement = materialContainers[i].querySelector('svg[aria-label]'); if (!nameElement || !svgElement) continue; const materialName = nameElement.textContent.trim(); const itemId = extractItemId(svgElement); const currentStock = getCountById(itemId); let totalNeeded = 0; if (type === 'production') { const consumptionMatch = inputCounts[i]?.textContent.match(/\\d+\\.?\\d*/); const consumptionPerUnit = consumptionMatch ? parseFloat(consumptionMatch[0]) : 0; totalNeeded = Math.ceil(productionQuantity * consumptionPerUnit); } else { const neededMatch = inputCounts[i]?.textContent.match(/\\/\\s*([\\d,]+(?:\\.\\d+)?[KMB]?)\\s*/); if (neededMatch) { totalNeeded = parseNumber(neededMatch[1]); } } const supplementNeeded = Math.max(0, totalNeeded - currentStock); requirements.push({ materialName, itemId, supplementNeeded, totalNeeded, currentStock, index: i, type: 'material' }); } } // 计算升级物品需求（仅production类型） if (type === 'production') { const upgradeContainer = container.querySelector(selectors.upgradeSelector); if (upgradeContainer) { const upgradeItem = upgradeContainer.querySelector('.Item_item__2De2O'); let materialName = '升级物品'; let itemId = null; let currentStock = 0; const totalNeeded = productionQuantity; if (upgradeItem) { const svgElement = upgradeItem.querySelector('svg[aria-label]'); if (svgElement) { const itemName = svgElement.getAttribute('aria-label'); const extractedId = extractItemId(svgElement); if (itemName && extractedId) { materialName = itemName; itemId = extractedId; currentStock = getCountById(itemId); } } // 从React props获取升级物品信息 if (!itemId) { try { const reactKey = Object.keys(upgradeItem).find(key => key.startsWith('__reactProps')); if (reactKey && upgradeItem[reactKey]) { const reactProps = upgradeItem[reactKey]; if (reactProps.children && reactProps.children[0] && reactProps.children[0][1]) { const ownerProps = reactProps.children[0][1]._owner?.memoizedProps; if (ownerProps && ownerProps.itemHrid && ownerProps.itemHrid !== '/items/empty') { itemId = ownerProps.itemHrid.replace('/items/', ''); materialName = ownerProps.name || itemId; currentStock = getCountById(itemId); } } } } catch (e) { console.warn('[调试] 无法从React props获取升级物品信息:', e); } } } const supplementNeeded = itemId ? Math.max(0, totalNeeded - currentStock) : 0; requirements.push({ materialName, itemId, supplementNeeded, totalNeeded, currentStock, index: 0, type: 'upgrade' }); } } return requirements; } } //WHAT? (()=> { const toast = new Toast(); const k = 'ArrowUp,ArrowUp,ArrowDown,ArrowDown,ArrowLeft,ArrowRight,ArrowLeft,ArrowRight,b,a'.split(','); const p = []; const f = e => { p.push(e.key); if (p.length > k.length) p.shift(); if (k.every((v, i) => v === p[i])) { removeEventListener('keydown', f); toast.show('Keep this between us. Shhh...', 'success', 7000); } }; addEventListener('keydown', f); })(); // UI管理器 class UIManager { constructor() { this.toast = new Toast(); this.postMessageAPI = new PostMessageAPI(); this.observer = null; this.loggerReady = false; this.checkLoggerAndInit(); } async checkLoggerAndInit() { const checkAPI = async () => { try { const result = await this.postMessageAPI.checkAPI(); if (result.available && result.ws_ready) { this.loggerReady = true; console.log(\`%c[MWI-AutoBuyer] \${LANG.loggerReady}\`, 'color: #4CAF50; font-weight: bold;'); this.initObserver(); return true; } return result.available ? false : false; } catch { return false; } }; if (!(await checkAPI())) { console.log(\`[MWI-AutoBuyer] \${LANG.waitingForLogger}\`); const pollAPI = async () => { if (await checkAPI()) return; setTimeout(pollAPI, 2000); }; setTimeout(pollAPI, 3000); } } createButton(text, onClick, isBidOrder = false) { const btn = document.createElement("button"); btn.textContent = text; const bgColor = isBidOrder ? 'var(--color-market-sell)' : 'var(--color-market-buy)'; const hoverColor = isBidOrder ? 'var(--color-market-sell-hover)' : 'var(--color-market-buy-hover)'; Object.assign(btn.style, { padding: '0 6px', backgroundColor: bgColor, color: '#000', border: 'none', borderRadius: '4px', cursor: 'pointer', fontSize: '13px', fontWeight: '600', transition: 'all 0.2s ease', fontFamily: '"Roboto"', textAlign: 'center', userSelect: 'none', display: 'flex', alignItems: 'center', justifyContent: 'center', height: '24px', lineHeight: '14px', minWidth: 'auto', overflow: 'hidden', width: '100%' }); ['mouseenter', 'mouseleave'].forEach((event, index) => { btn.addEventListener(event, () => { btn.style.backgroundColor = index ? bgColor : hoverColor; }); }); btn.addEventListener("click", async () => { if (!this.loggerReady) { console.error(LANG.wsNotAvailable); return; } btn.disabled = true; btn.textContent = isBidOrder ? LANG.bidOrderButtonActive : LANG.directBuyButtonActive; Object.assign(btn.style, { backgroundColor: "var(--color-disabled)", cursor: "not-allowed" }); try { await onClick(); } catch (error) { this.toast.show(\`\${LANG.purchaseError}: \${error.message}\`, 'error'); } finally { btn.disabled = false; btn.textContent = text; Object.assign(btn.style, { backgroundColor: bgColor, cursor: "pointer" }); } }); return btn; } createInfoSpan() { const span = document.createElement("span"); span.textContent = \`\${LANG.missingPrefix}0\`; Object.assign(span.style, { fontSize: '12px', fontWeight: 'bold', padding: '2px 6px', borderRadius: '3px', whiteSpace: 'nowrap', minWidth: '60px', textAlign: 'center' }); return span; } async updateInfoSpans(type) { const requirements = await MaterialCalculator.calculateRequirements(type); const className = type === 'production' ? 'material-info-span' : 'house-material-info-span'; const upgradeClassName = 'upgrade-info-span'; const materialSpans = document.querySelectorAll(\`.\${className}\`); const materialRequirements = requirements.filter(req => req.type === 'material'); materialSpans.forEach((span, index) => { if (materialRequirements[index]) { const needed = materialRequirements[index].supplementNeeded; span.textContent = \`\${LANG.missingPrefix}\${needed}\`; span.style.color = needed > 0 ? '#ff6b6b' : 'var(--color-text-dark-mode)'; } }); const upgradeSpan = document.querySelector(\`.\${upgradeClassName}\`); const upgradeRequirement = requirements.find(req => req.type === 'upgrade'); if (upgradeSpan) { if (upgradeRequirement) { const needed = upgradeRequirement.supplementNeeded; upgradeSpan.textContent = \`\${LANG.missingPrefix}\${needed}\`; upgradeSpan.style.color = needed > 0 ? '#ff6b6b' : 'var(--color-text-dark-mode)'; } else { upgradeSpan.textContent = \`\${LANG.missingPrefix}0\`; upgradeSpan.style.color = 'var(--color-text-dark-mode)'; } } } async purchaseFlow(type, isBidOrder = false) { if (!this.loggerReady) { this.toast.show(LANG.wsNotAvailable, 'error'); return; } const requirements = await MaterialCalculator.calculateRequirements(type); const needToBuy = requirements.filter(item => { const isValidItem = item.itemId && item.itemId !== 'coin' && item.itemId !== '/items/coin' && item.supplementNeeded > 0; if (!isValidItem) return false; return true; }); if (needToBuy.length === 0) { this.toast.show(LANG.noMaterialsNeeded, 'info'); return; } const itemList = needToBuy.map(item => \`\${item.materialName}: \${item.supplementNeeded}\${LANG.each}\` ).join(', '); const startMessage = isBidOrder ? \`\${LANG.startBidOrdering} \${needToBuy.length} \${LANG.materials}: \${itemList} \` : \`\${LANG.startDirectPurchasing} \${needToBuy.length} \${LANG.materials}: \${itemList}\`; this.toast.show(startMessage, 'info'); try { const purchaseItems = needToBuy.map(item => { let itemHrid = item.itemId; if (!itemHrid.startsWith('/items/')) { itemHrid = \`/items/\${itemHrid}\`; } return { itemHrid: itemHrid, quantity: item.supplementNeeded, materialName: item.materialName }; }); const results = isBidOrder ? await this.postMessageAPI.batchBidOrder(purchaseItems, 800) : await this.postMessageAPI.batchDirectPurchase(purchaseItems, 800); let successCount = 0; results.forEach(result => { if (result.success) { successCount++; const successMessage = isBidOrder ? LANG.orderSubmitted : LANG.purchased; this.toast.show( \`\${successMessage} \${result.item.materialName || result.item.itemHrid} x\${result.item.quantity}\`, 'success' ); } else { const errorMessage = isBidOrder ? LANG.orderFailed : LANG.purchaseFailed; this.toast.show( \`\${errorMessage} \${result.item.materialName || result.item.itemHrid}: \${result.error}\`, 'error' ); } }); if (successCount > 0) { const completeMessage = isBidOrder ? LANG.orderComplete : LANG.purchaseComplete; const successType = isBidOrder ? LANG.orderSuccess : LANG.purchaseSuccess; this.toast.show( \`\${completeMessage} \${successType} \${successCount}/\${needToBuy.length} \${LANG.materials}\`, 'success', 5000 ); setTimeout(() => this.updateInfoSpans(type), 2000); } else { const allFailedMessage = isBidOrder ? LANG.allOrdersFailed : LANG.allPurchasesFailed; this.toast.show(allFailedMessage, 'error'); } } catch (error) { this.toast.show(\`\${LANG.purchaseError}: \${error.message}\`, 'error'); } } initObserver() { if (this.observer) return; this.observer = new MutationObserver(() => { this.setupUI('production'); this.setupUI('house'); }); this.observer.observe(document.body, { childList: true, subtree: true }); document.addEventListener('input', (e) => { if (e.target.classList.contains('Input_input__2-t98')) { setTimeout(() => this.updateInfoSpans('production'), 100); } }); document.addEventListener('click', (e) => { if (e.target.closest('.ItemSelector_itemSelector__2eTV6')) { setTimeout(() => this.updateInfoSpans('production'), 100); } }); this.setupUI('production'); this.setupUI('house'); } setupUI(type) { const config = { production: { className: 'material-info-span', gridCols: 'auto min-content auto auto', buttonParent: 'nameDiv', buttonStyle: { marginLeft: '10px' } }, house: { className: 'house-material-info-span', gridCols: 'auto auto auto 120px', buttonParent: 'headerDiv', buttonStyle: { flex: '1' } } }; const selectors = SELECTORS[type]; const conf = config[type]; document.querySelectorAll(selectors.container).forEach(panel => { const dataAttr = type === 'production' ? 'buttonInserted' : 'autoBuyButtonInserted'; const modifiedAttr = type === 'production' ? 'modified' : 'houseModified'; if (panel.dataset[dataAttr]) return; const requirements = panel.querySelector(selectors.requirements); if (!requirements) return; panel.dataset[dataAttr] = "true"; // 设置普通材料UI if (!requirements.dataset[modifiedAttr]) { requirements.dataset[modifiedAttr] = "true"; requirements.style.gridTemplateColumns = conf.gridCols; requirements.querySelectorAll('.Item_itemContainer__x7kH1').forEach(item => { if (item.nextSibling?.classList?.contains(conf.className)) return; const span = this.createInfoSpan(); span.className = conf.className; item.parentNode.insertBefore(span, item.nextSibling); }); } // 设置升级物品UI（仅production类型） if (type === 'production') { const upgradeContainer = panel.querySelector(selectors.upgradeSelector); if (upgradeContainer && !upgradeContainer.dataset.upgradeModified) { upgradeContainer.dataset.upgradeModified = "true"; if (!upgradeContainer.querySelector('.upgrade-info-span')) { const upgradeSpan = this.createInfoSpan(); upgradeSpan.className = 'upgrade-info-span'; upgradeContainer.appendChild(upgradeSpan); } } } setTimeout(() => this.updateInfoSpans(type), 100); // 添加购买按钮 const parentDiv = panel.querySelector(selectors[conf.buttonParent]); if (parentDiv && !parentDiv.parentNode.querySelector('.buy-buttons-container')) { const buttonContainer = document.createElement('div'); buttonContainer.className = 'buy-buttons-container'; buttonContainer.style.display = 'flex'; buttonContainer.style.gap = '8px'; buttonContainer.style.justifyContent = 'center'; buttonContainer.style.alignItems = 'center'; if (type === 'house') { buttonContainer.style.width = 'fit-content'; buttonContainer.style.margin = '0 auto'; buttonContainer.style.maxWidth = '280px'; buttonContainer.style.minWidth = '260px'; } const directBuyBtn = this.createButton(LANG.directBuyButton, () => this.purchaseFlow(type, false), false); const bidOrderBtn = this.createButton(LANG.bidOrderButton, () => this.purchaseFlow(type, true), true); Object.assign(directBuyBtn.style, { flex: '1' }); Object.assign(bidOrderBtn.style, { flex: '1' }); buttonContainer.appendChild(directBuyBtn); buttonContainer.appendChild(bidOrderBtn); if (type === 'production') { Object.assign(buttonContainer.style, conf.buttonStyle); parentDiv.parentNode.insertBefore(buttonContainer, parentDiv.nextSibling); } else { parentDiv.parentNode.insertBefore(buttonContainer, parentDiv); } } }); } } new UIManager(); })(); `; // WebSocket 拦截和 API 设置 function setupWebSocketAndAPI() { // Mooket 接口检测函数 const isMooketAPIAvailable = () => { if (!window.mwi) { return false; } if (!window.mwi.MWICoreInitialized) { return false; } if (!window.mwi.game) { return false; } return true; }; window.wsInstances = []; window.currentWS = null; window.wsMessageListeners = new Set(); window.wsRequestHandlers = new Map(); window.wsPurchaseQueue = []; window.wsMarketDataCache = new Map(); // 设置原生 WebSocket 拦截 setupOriginalWebSocketMode(); // PostMessage 处理器 window.addEventListener('message', async (event) => { if (event.origin !== window.location.origin || event.data?.type !== 'ws_request') return; const { action, data, requestId } = event.data; try { let result; switch (action) { case 'check_api': result = { available: true, ws_ready: mooketMode ? isMooketAPIAvailable() : !!window.currentWS, mode: mooketMode ? 'Mooket接口' : 'WebSocket' }; break; case 'get_market_data': result = await handleGetMarketData(data); break; case 'direct_purchase': result = await handleDirectPurchase(data); break; case 'batch_direct_purchase': result = await handleBatchDirectPurchase(data); break; case 'bid_order': result = await handleBidOrder(data); break; case 'batch_bid_order': result = await handleBatchBidOrder(data); break; default: throw new Error(`未知的操作: ${action}`); } window.postMessage({ type: 'ws_response', action, success: true, data: result, requestId }, window.location.origin); } catch (error) { window.postMessage({ type: 'ws_response', action, success: false, error: error.message, requestId }, window.location.origin); } }); // 市场数据处理 async function handleGetMarketData({ itemHrid, useCache = true }) { const fullItemHrid = itemHrid.startsWith('/items/') ? itemHrid : `/items/${itemHrid}`; if (useCache && window.wsMarketDataCache.has(fullItemHrid)) { const cached = window.wsMarketDataCache.get(fullItemHrid); if (Date.now() - cached.timestamp < 60000) { return cached.data; } } // 优先使用Mooket接口模式（如果可用） if (mooketMode && isMooketAPIAvailable()) { console.log('[调试] 使用Mooket接口模式获取市场数据'); return new Promise((resolve, reject) => { const timeout = setTimeout(() => reject(new Error('获取市场数据超时')), 8000); const responseHandler = (obj) => { if (obj.marketItemOrderBooks?.itemHrid === fullItemHrid) { clearTimeout(timeout); // 缓存数据 window.wsMarketDataCache.set(fullItemHrid, { data: obj.marketItemOrderBooks, timestamp: Date.now() }); resolve(obj.marketItemOrderBooks); } }; // 注册一次性监听器 const onceHandler = (obj) => { responseHandler(obj); window.removeEventListener('MWI_market_item_order_books_updated', onceHandler); }; window.addEventListener('MWI_market_item_order_books_updated', (e) => onceHandler(e.detail)); // 请求市场数据 try { window.mwi.game.handleGetMarketItemOrderBooks(fullItemHrid); } catch (error) { clearTimeout(timeout); reject(new Error(`Mooket接口请求失败: ${error.message}`)); } }); } else { // 使用原始WebSocket模式 console.log('[调试] 使用WebSocket模式获取市场数据'); return new Promise((resolve, reject) => { if (!window.currentWS || window.currentWS.readyState !== WebSocket.OPEN) { reject(new Error('WebSocket连接不可用')); return; } const timeout = setTimeout(() => reject(new Error('获取市场数据超时')), 8000); const responseHandler = (responseData) => { if (responseData.type === 'market_item_order_books_updated' && responseData.marketItemOrderBooks?.itemHrid === fullItemHrid) { clearTimeout(timeout); cleanup(); window.wsMarketDataCache.set(fullItemHrid, { data: responseData.marketItemOrderBooks, timestamp: Date.now() }); resolve(responseData.marketItemOrderBooks); } }; const cleanup = () => { const handlers = window.wsRequestHandlers.get('market_item_order_books_updated'); if (handlers) { handlers.delete(responseHandler); if (handlers.size === 0) { window.wsRequestHandlers.delete('market_item_order_books_updated'); } } }; if (!window.wsRequestHandlers.has('market_item_order_books_updated')) { window.wsRequestHandlers.set('market_item_order_books_updated', new Set()); } window.wsRequestHandlers.get('market_item_order_books_updated').add(responseHandler); window.currentWS.send(JSON.stringify({ type: "get_market_item_order_books", getMarketItemOrderBooksData: { itemHrid: fullItemHrid } })); }); } } // 直接购买处理 async function handleDirectPurchase({ itemHrid, quantity }) { const marketData = await handleGetMarketData({ itemHrid }); const priceAnalysis = analyzeMarketPrice(marketData, quantity); const result = await executeDirectPurchase(itemHrid, quantity, priceAnalysis.maxPrice); return { success: true, result }; } // 求购订单处理 async function handleBidOrder({ itemHrid, quantity }) { const marketData = await handleGetMarketData({ itemHrid }); const priceAnalysis = analyzeBidPrice(marketData, quantity); const result = await executeBidOrder(itemHrid, quantity, priceAnalysis.maxPrice); return { success: true, result }; } // 批量处理函数 async function handleBatchDirectPurchase({ items, delayBetween = 800 }) { const results = []; for (let i = 0; i < items.length; i++) { try { const result = await handleDirectPurchase(items[i]); results.push({ item: items[i], ...result }); } catch (error) { results.push({ item: items[i], success: false, error: error.message }); } if (i < items.length - 1 && delayBetween > 0) { await new Promise(resolve => setTimeout(resolve, delayBetween)); } } return results; } async function handleBatchBidOrder({ items, delayBetween = 800 }) { const results = []; for (let i = 0; i < items.length; i++) { try { const result = await handleBidOrder(items[i]); results.push({ item: items[i], ...result }); } catch (error) { results.push({ item: items[i], success: false, error: error.message }); } if (i < items.length - 1 && delayBetween > 0) { await new Promise(resolve => setTimeout(resolve, delayBetween)); } } return results; } // 执行购买操作 async function executeDirectPurchase(itemHrid, quantity, price, enhancementLevel = 0) { const fullItemHrid = itemHrid.startsWith('/items/') ? itemHrid : `/items/${itemHrid}`; if (mooketMode && isMooketAPIAvailable()) { console.log('[调试] 使用Mooket接口模式执行购买'); return new Promise((resolve, reject) => { const timeout = setTimeout(() => reject(new Error('购买超时')), 15000); const successHandler = (obj) => { if (obj.message === 'infoNotification.buyOrderCompleted') { clearTimeout(timeout); resolve(obj); window.removeEventListener('MWI_info', onceSuccessHandler); window.removeEventListener('MWI_error', onceErrorHandler); } }; const errorHandler = (obj) => { clearTimeout(timeout); reject(new Error(obj.message || '购买失败')); window.removeEventListener('MWI_info', onceSuccessHandler); window.removeEventListener('MWI_error', onceErrorHandler); }; const onceSuccessHandler = (e) => successHandler(e.detail); const onceErrorHandler = (e) => errorHandler(e.detail); window.addEventListener('MWI_info', onceSuccessHandler); window.addEventListener('MWI_error', onceErrorHandler); try { window.mwi.game.handlePostMarketOrder(false, fullItemHrid, enhancementLevel, quantity, price, true); } catch (error) { clearTimeout(timeout); window.removeEventListener('MWI_info', onceSuccessHandler); window.removeEventListener('MWI_error', onceErrorHandler); reject(new Error(`Mooket接口购买请求失败: ${error.message}`)); } }); } else { // 使用原始WebSocket模式 console.log('[调试] 使用WebSocket模式执行购买'); return new Promise((resolve, reject) => { if (!window.currentWS || window.currentWS.readyState !== WebSocket.OPEN) { reject(new Error('WebSocket连接不可用')); return; } const timeout = setTimeout(() => reject(new Error('购买超时')), 15000); window.currentWS.send(JSON.stringify({ type: "post_market_order", postMarketOrderData: { isSell: false, itemHrid: fullItemHrid, enhancementLevel, quantity, price, isInstantOrder: true } })); const checkResult = () => { const recent = window.wsPurchaseQueue.filter(item => Date.now() - item.timestamp < 15000); const completed = recent.find(item => item.type === 'purchase_completed'); const error = recent.find(item => item.type === 'error'); if (completed) { clearTimeout(timeout); resolve(completed.data); } else if (error) { clearTimeout(timeout); reject(new Error(error.data.message || '购买失败')); } else { setTimeout(checkResult, 200); } }; checkResult(); }); } } async function executeBidOrder(itemHrid, quantity, price, enhancementLevel = 0) { const fullItemHrid = itemHrid.startsWith('/items/') ? itemHrid : `/items/${itemHrid}`; if (mooketMode && isMooketAPIAvailable()) { try { window.mwi.game.handlePostMarketOrder(false, fullItemHrid, enhancementLevel, quantity, price, false); return { message: '订单已提交' }; } catch (error) { throw new Error(`Mooket接口求购订单失败: ${error.message}`); } } else { // 原始WebSocket模式 return new Promise((resolve, reject) => { if (!window.currentWS || window.currentWS.readyState !== WebSocket.OPEN) { reject(new Error('WebSocket连接不可用')); return; } window.currentWS.send(JSON.stringify({ type: "post_market_order", postMarketOrderData: { isSell: false, itemHrid: fullItemHrid, enhancementLevel, quantity, price, isInstantOrder: false } })); resolve({ message: '订单已提交' }); }); } } // 价格分析函数 function analyzeMarketPrice(marketData, neededQuantity) { const asks = marketData.orderBooks?.[0]?.asks; if (!asks?.length) throw new Error('没有可用的卖单'); let cumulativeQuantity = 0; let targetPrice = 0; for (const ask of asks) { const availableFromThisOrder = Math.min(ask.quantity, neededQuantity - cumulativeQuantity); cumulativeQuantity += availableFromThisOrder; targetPrice = ask.price; if (cumulativeQuantity >= neededQuantity) break; } if (cumulativeQuantity < neededQuantity) { throw new Error(`市场库存不足。可用: ${cumulativeQuantity}, 需要: ${neededQuantity}`); } return { maxPrice: targetPrice, availableQuantity: cumulativeQuantity }; } function analyzeBidPrice(marketData, neededQuantity) { const bids = marketData.orderBooks?.[0]?.bids; if (!bids?.length) throw new Error('没有可用的买单'); const targetPrice = bids[0].price; return { maxPrice: targetPrice, availableQuantity: neededQuantity }; } // 消息分发 function dispatchMessage(data, direction) { window.wsMessageListeners.forEach(listener => { try { listener(data, direction); } catch (e) { } }); if (data.type && window.wsRequestHandlers.has(data.type)) { window.wsRequestHandlers.get(data.type).forEach(handler => { try { handler(data); } catch (e) { } }); } // 缓存处理 if (data.type === 'market_item_order_books_updated') { const itemHrid = data.marketItemOrderBooks?.itemHrid; if (itemHrid) { window.wsMarketDataCache.set(itemHrid, { data: data.marketItemOrderBooks, timestamp: Date.now() }); setTimeout(() => { const cached = window.wsMarketDataCache.get(itemHrid); if (cached && Date.now() - cached.timestamp > 300000) { window.wsMarketDataCache.delete(itemHrid); } }, 300000); } } if (data.type === 'info' && data.message === 'infoNotification.buyOrderCompleted') { window.wsPurchaseQueue.push({ type: 'purchase_completed', data, timestamp: Date.now() }); } if (data.type === 'error') { window.wsPurchaseQueue.push({ type: 'error', data, timestamp: Date.now() }); } } // 原生 WebSocket 模式设置（立即设置，确保拦截） function setupOriginalWebSocketMode() { console.log('[调试] 设置原生 WebSocket 拦截'); const OriginalWebSocket = window.WebSocket; window.WebSocket = new Proxy(OriginalWebSocket, { construct(target, args) { const ws = new target(...args); window.wsInstances.push(ws); window.currentWS = ws; const originalSend = ws.send; ws.send = function (data) { try { dispatchMessage(JSON.parse(data), 'send'); } catch (e) { } return originalSend.call(this, data); }; ws.addEventListener("message", (event) => { try { dispatchMessage(JSON.parse(event.data), 'receive'); } catch (e) { } }); ws.addEventListener("open", () => { console.log('[调试] WebSocket连接已建立'); if (window.wsInstances.length === 1 && !scriptInjected) { setTimeout(async () => { try { await injectLocalScript(); console.info('%c[MWI-AutoBuyer] 界面注入成功', 'color: #4CAF50; font-weight: bold;'); } catch (error) { console.error('%c[MWI-AutoBuyer] 界面注入失败:', 'color: #F44336; font-weight: bold;', error); } }, 1000); } window.postMessage({ type: 'ws_ready', detail: { ws, url: args[0] } }, window.location.origin); }); ws.addEventListener("close", () => { const index = window.wsInstances.indexOf(ws); if (index > -1) window.wsInstances.splice(index, 1); if (window.currentWS === ws) { window.currentWS = window.wsInstances[window.wsInstances.length - 1] || null; } }); return ws; } }); } // Mooket接口检测和模式切换 const checkAndSwitchToMooket = () => { if (!mooketMode && isMooketAPIAvailable()) { console.info('%c[MWI-AutoBuyer] 检测到Mooket接口可用，切换到Mooket接口模式', 'color: #2196F3; font-weight: bold;'); mooketMode = true; return true; } return false; }; // 监听 Mooket 初始化事件 window.addEventListener('MWICoreInitialized', () => { console.info('%c[MWI-AutoBuyer] 收到Mooket接口初始化事件', 'color: #2196F3; font-weight: bold;'); checkAndSwitchToMooket(); }); window.clearWSCache = () => { window.wsMarketDataCache.clear(); window.wsPurchaseQueue.length = 0; return true; }; } // 注入脚本 function injectLocalScript() { if (scriptInjected) return Promise.resolve(); return new Promise((resolve, reject) => { try { const script = document.createElement('script'); script.type = 'text/javascript'; script.textContent = AUTO_BUY_SCRIPT; (document.head || document.documentElement).appendChild(script); scriptInjected = true; resolve(); } catch (error) { reject(error); } }); } setupWebSocketAndAPI(); })();