313 lines
12 KiB
JavaScript
313 lines
12 KiB
JavaScript
// ==UserScript==
|
|
// @name MCBBS自动售卖机
|
|
// @namespace https://miaowoo.cc/
|
|
// @version 0.8.2
|
|
// @description 自动售卖道具
|
|
// @author MiaoWoo
|
|
// @match https://www.mcbbs.net/home.php?mod=magic**
|
|
// @grant none
|
|
// ==/UserScript==
|
|
/* global jq */
|
|
(async function () {
|
|
let store = window.localStorage
|
|
const lastOrderKey = 'circlebox:lastorder'
|
|
let params = 0
|
|
let checkTimes = 0
|
|
let stock = 0
|
|
let messagetext = undefined
|
|
let storeUsername = undefined
|
|
let gateway = "https://s.yumc.pw"
|
|
async function sleep(time) {
|
|
return new Promise((resolve, reject) => setTimeout(resolve, time))
|
|
}
|
|
function createMenu() {
|
|
let master = document.createElement('a')
|
|
master.href = "/home.php?mod=magic&action=mybox&nodeType=master"
|
|
master.innerText = "售卖机主节点"
|
|
let slave = document.createElement('a')
|
|
slave.href = "/home.php?mod=magic&action=mybox&nodeType=slave"
|
|
slave.innerText = "售卖机子节点"
|
|
let masterLi = document.createElement('li')
|
|
masterLi.append(master)
|
|
let slaveLi = document.createElement('li')
|
|
slaveLi.append(slave)
|
|
let tbn = document.getElementsByClassName('tbn')[0].children[1]
|
|
tbn.append(masterLi)
|
|
tbn.append(slaveLi)
|
|
}
|
|
async function main() {
|
|
params = location.href.split('?')[1].split('&').map(s => s.split('=')).reduce((pre, cur, index) => { pre[cur[0]] = cur[1]; return pre }, {})
|
|
let errorh1 = document.getElementsByTagName('h1')[0]
|
|
if (errorh1 && errorh1.innerText.startsWith(50)) {
|
|
return refresh()
|
|
}
|
|
setTimeout(refresh, 600000)
|
|
let taskId = setTimeout(refresh, 60000)
|
|
createMenu()
|
|
if (!params.nodeType) { return console.log('nodeType is undefined skip...') }
|
|
if (!params.action) { return refresh() }
|
|
console.log(params)
|
|
try {
|
|
storeUsername = document.getElementsByClassName('username')[0].innerText
|
|
messagetext = document.getElementById('messagetext')
|
|
if (messagetext) {
|
|
updateStatus(messagetext.innerText)
|
|
return
|
|
} else {
|
|
updateStatus('')
|
|
}
|
|
clearTimeout(taskId)
|
|
switch (params.nodeType) {
|
|
case "master":
|
|
master(params)
|
|
break
|
|
case "slave":
|
|
slave(params)
|
|
break
|
|
}
|
|
} catch (ex) {
|
|
await sleep(1500)
|
|
refresh()
|
|
}
|
|
}
|
|
async function master(params) {
|
|
switch (params.action || "shop") {
|
|
case "shop":
|
|
await shopAction(params)
|
|
break
|
|
case "mybox":
|
|
stock = await updateStock()
|
|
await myboxAction(params)
|
|
break
|
|
case "log":
|
|
await logAction(params)
|
|
break
|
|
}
|
|
}
|
|
async function slave(params) {
|
|
switch (params.action || "shop") {
|
|
case "shop":
|
|
case "log":
|
|
refresh()
|
|
break
|
|
case "mybox":
|
|
stock = await updateStock()
|
|
await needReplenishment()
|
|
break
|
|
}
|
|
}
|
|
async function heartbeat() {
|
|
return fetch('https://kuma.yumc.pw/api/push/D611iEI4zy?status=up&msg=OK&ping=').then(r=>r.json()).catch(e=>console.log(e))
|
|
}
|
|
async function needReplenishment() {
|
|
let timeoutTask = setTimeout(() => { refresh() }, 120000)
|
|
if (stock == 0) { return }
|
|
let result = await fetch(gateway + '/mcbbs/needReplenishment').then(r => r.json())
|
|
if (result.code != 200) {
|
|
if (++checkTimes > 5) { return refresh() }
|
|
clearTimeout(timeoutTask)
|
|
return setTimeout(() => needReplenishment(), 2000)
|
|
}
|
|
let masterInfo = result.data
|
|
sendItem(() => window.showWindow('magics', 'home.php?mod=magic&action=mybox&operation=give&magicid=32', 'get', 0), masterInfo.username, masterInfo.amount || stock)
|
|
}
|
|
async function refresh() {
|
|
try {
|
|
await fetch('/api/mobile/index.php?version=4&module=credit')
|
|
location.href = '/home.php?mod=magic&action=mybox&nodeType=' + params.nodeType
|
|
} catch (error) {
|
|
setTimeout(refresh, 5000)
|
|
}
|
|
}
|
|
async function shopAction() {
|
|
await sendOrderAction(() => window.showWindow('magics', 'home.php?mod=magic&action=shop&operation=give&mid=mcbbs_mcserver_plus:serverBump'), true)
|
|
}
|
|
async function myboxAction() {
|
|
await sendOrderAction(() => window.showWindow('magics', 'home.php?mod=magic&action=mybox&operation=give&magicid=32', 'get', 0))
|
|
}
|
|
async function updateStock() {
|
|
let serverBump = document.getElementById('magic_mcbbs_mcserver_plus:serverBump')
|
|
let stock = 0
|
|
if (serverBump) {
|
|
stock = serverBump.nextElementSibling.nextElementSibling.children[0].innerText
|
|
}
|
|
await fetch(gateway + `/mcbbs/updateStock/username/${storeUsername}/stock/${stock}`).then(r => r.json())
|
|
return stock
|
|
}
|
|
async function updateStatus(message) {
|
|
await fetch(gateway + `/mcbbs/updateStatus/username/${storeUsername}/message/${message}`).then(r => r.json())
|
|
}
|
|
async function lowStockNotify(stock, order_id, goods_amount) {
|
|
await fetch(gateway + `/mcbbs/lowStockNotify/username/${storeUsername}/stock/${stock}/order_id/${order_id}/goods_amount/${goods_amount}`).then(r => r.json())
|
|
}
|
|
async function clearOrderCache(order_id) {
|
|
await fetch(gateway + '/mcbbs/clearOrderCache/order_id/' + order_id).then(r => r.json())
|
|
}
|
|
async function handleLowStock(order, stock) {
|
|
if (order.allowAutoBuy) {
|
|
await clearOrderCache(order.order_id)
|
|
await sleep(1500)
|
|
location.href = '/home.php?mod=magic&action=shop&nodeType=' + params.nodeType
|
|
} else {
|
|
await lowStockNotify(stock, order.order_id, order.goods_amount)
|
|
}
|
|
}
|
|
async function sendItem(openFn, usernameValue, amountValue) {
|
|
try { openFn() } catch (ex) { }
|
|
amountValue = Math.min(stock, amountValue)
|
|
let username = undefined
|
|
let count = 0
|
|
while ((username = jq('#selectedusername')[0]) == undefined) {
|
|
if (count > 5) {
|
|
console.log('检测窗口超时!')
|
|
return false
|
|
}
|
|
await sleep(800)
|
|
count++
|
|
}
|
|
username.value = usernameValue
|
|
let amount = username.parentNode.parentNode.nextElementSibling.childNodes[3].childNodes[0]
|
|
amount.value = amountValue
|
|
let remark = username.parentNode.parentNode.nextElementSibling.nextElementSibling.childNodes[3].childNodes[0]
|
|
remark.value = `子节点补货 补货账号: ${storeUsername} 补货数量: ${amountValue}`
|
|
await sleep(300)
|
|
jq('#operatesubmit').click()
|
|
await sleep(500)
|
|
jq('#fwin_dialog_submit').click()
|
|
let info = ''
|
|
let error = ''
|
|
while ((info = jq('.alert_info').text()) == '') {
|
|
if (count > 3) {
|
|
error = jq('#ntcwin').text()
|
|
break
|
|
}
|
|
await sleep(800)
|
|
count++
|
|
}
|
|
if (error && error.startsWith('抱歉，对方道具包容量不足')) {
|
|
amountValue = error.replace(/[^0-9]/ig, "")
|
|
if (amountValue == 0) {
|
|
return refresh()
|
|
}
|
|
await sleep(200)
|
|
amount.value = amountValue
|
|
remark.value = `子节点补货 补货账号: ${storeUsername} 补货数量: ${amountValue}`
|
|
await sleep(300)
|
|
jq('#operatesubmit').click()
|
|
await sleep(500)
|
|
jq('#fwin_dialog_submit').click()
|
|
}
|
|
await sleep(800)
|
|
refresh()
|
|
}
|
|
async function sendOrderAction(openFn, back = false) {
|
|
heartbeat()
|
|
let timeoutTask = setTimeout(() => { refresh() }, 45000)
|
|
let count = 0
|
|
if (stock < 50) {
|
|
setTimeout(() => { refresh() }, 15000)
|
|
}
|
|
document.getElementById('scbar_txt').value = "订单 第"+(checkTimes+1)+"次 检查中..."
|
|
let result = await fetch(gateway + '/mcbbs/needSendOrder').then(r => r.json())
|
|
if (result.code != 200) {
|
|
if (checkTimes++ > 10 || back) {
|
|
refresh()
|
|
}
|
|
clearTimeout(timeoutTask)
|
|
return setTimeout(() => sendOrderAction(openFn), 2000)
|
|
}
|
|
let order = result.data
|
|
if (store.getItem(lastOrderKey) == order.order_id) {
|
|
let finish = await fetch(gateway + '/mcbbs/updateOrder', {
|
|
method: "POST",
|
|
headers: {
|
|
'Accept': 'application/json',
|
|
'Content-Type': 'application/json'
|
|
},
|
|
body: JSON.stringify({
|
|
"order_id": order.order_id,
|
|
"status": 2,
|
|
"remark": "当前订单可能重复发货 如未到帐 请联系管理员!"
|
|
})
|
|
}).then(r => r.json())
|
|
return
|
|
}
|
|
try { openFn() } catch (ex) { }
|
|
if (!order || !order.order_id) { return setTimeout(() => sendOrderAction(openFn), 2000) }
|
|
console.log(`开始发送订单 ${order.order_id}`)
|
|
let username = undefined
|
|
while ((username = jq('#selectedusername')[0]) == undefined) {
|
|
if (count > 8) {
|
|
console.log('检测窗口超时!')
|
|
if (!back) { await handleLowStock(order, stock) }
|
|
return
|
|
}
|
|
await sleep(800)
|
|
count++
|
|
}
|
|
username.value = order.reciver_name
|
|
let amount = username.parentNode.parentNode.nextElementSibling.childNodes[3].childNodes[0]
|
|
amount.value = order.goods_amount
|
|
let remark = username.parentNode.parentNode.nextElementSibling.nextElementSibling.childNodes[3].childNodes[0]
|
|
remark.value = `圈云盒子 自动发货订单: ${order.order_id} 物品: ${order.goods_name} 数量: ${order.goods_amount} 发货账号: ${storeUsername}`
|
|
await sleep(300)
|
|
jq('#operatesubmit').click()
|
|
await sleep(500)
|
|
jq('#fwin_dialog_submit').click()
|
|
let info = ''
|
|
let error = ''
|
|
while ((info = jq('.alert_info').text()) == '') {
|
|
if (count > 8) {
|
|
error = jq('#ntcwin').text()
|
|
break
|
|
}
|
|
await sleep(800)
|
|
count++
|
|
}
|
|
if (error == "抱歉，操作数量不合法") {
|
|
if (order.goods_amount > stock) {
|
|
error = `发货账号: ${storeUsername} 库存 ${stock} 不足 ${order.goods_amount} 已通知管理员(QQ: 502647092) 请等待...`
|
|
}
|
|
await handleLowStock(order, stock)
|
|
}
|
|
try {
|
|
if (!info && !error) {
|
|
store.setItem(lastOrderKey, order.order_id)
|
|
}
|
|
let finish = await fetch(gateway + '/mcbbs/updateOrder', {
|
|
method: "POST",
|
|
headers: {
|
|
'Accept': 'application/json',
|
|
'Content-Type': 'application/json'
|
|
},
|
|
body: JSON.stringify({
|
|
"order_id": order.order_id,
|
|
"status": error ? 3 : 2,
|
|
"remark": info || error || "未获取到结果!"
|
|
})
|
|
}).then(r => r.json())
|
|
console.log(finish)
|
|
} catch (ex) {
|
|
console.log(ex)
|
|
} finally {
|
|
await sleep(800)
|
|
refresh()
|
|
}
|
|
}
|
|
async function logAction(params) {
|
|
switch (params.operation) {
|
|
case "givelog":
|
|
await givelogOperation()
|
|
break
|
|
}
|
|
}
|
|
async function givelogOperation() {
|
|
let logs = jq('table.dt').children().children().map((index, item) => {
|
|
let line = jq(item).text().split('\n').filter(f => f)
|
|
return line.join(' ')
|
|
}).splice(1)//去除第一行无效数据
|
|
console.log(logs)
|
|
}
|
|
main()
|
|
})()
|