75 lines
3.5 KiB
TypeScript
75 lines
3.5 KiB
TypeScript
import toThousands from "../utils/toThousands";
|
||
import Log from "../../class/Log";
|
||
import Alert from "../../class/utils/Alert";
|
||
import WuhuConfig from "../../class/WuhuConfig";
|
||
|
||
// 价格监视handle
|
||
export default function priceWatcherHandle(isPDA: boolean, PDA_APIKey: string) {
|
||
let priceTemp = {};
|
||
let intervalId = window.setInterval(() => {
|
||
const price_conf = WuhuConfig.get('priceWatcher');
|
||
const apikey = isPDA ? PDA_APIKey : localStorage.getItem('APIKey');
|
||
if (!apikey || (price_conf['pt'] === -1 && price_conf['xan'] === -1)) {
|
||
Log.warn('价格监视关闭，无apikey或设置未打开');
|
||
window.clearInterval(intervalId);
|
||
return;
|
||
}
|
||
if (price_conf['pt'] !== -1) priceWatcherPt(apikey, price_conf['pt'], priceTemp).then();
|
||
if (price_conf['xan'] !== -1) priceWatcherXan(apikey, price_conf['xan'], priceTemp).then();
|
||
}, 10000)
|
||
}
|
||
|
||
// pt价格监视
|
||
async function priceWatcherPt(apikey, lower_price, priceWatcher) {
|
||
if (!priceWatcher['watch-pt-lower-id']) priceWatcher['watch-pt-lower-id'] = [];
|
||
const res = await window.fetch('https://api.torn.com/market/?selections=pointsmarket&key=' + apikey);
|
||
const obj = await res.json();
|
||
if (obj['pointsmarket']) {
|
||
// 过滤低于价格的物品出售id
|
||
const lower_arr = [];
|
||
let low = Infinity;
|
||
Object.keys(obj['pointsmarket']).forEach(key => {
|
||
if (obj['pointsmarket'][key]['cost'] <= lower_price) {
|
||
lower_arr.push(key);
|
||
if (obj['pointsmarket'][key]['cost'] < low) low = obj['pointsmarket'][key]['cost'];
|
||
}
|
||
});
|
||
if (lower_arr.length === 0) return;
|
||
// 将id与之前存在的比较，不相同时发送通知
|
||
if (JSON.stringify(priceWatcher['watch-pt-lower-id']) !== JSON.stringify(lower_arr)) {
|
||
priceWatcher['watch-pt-lower-id'] = lower_arr;
|
||
new Alert(`PT新低价：$${ toThousands(low) }( < $${ toThousands(lower_price) }) - <a href="/pmarket.php" target="_blank">点击转跳</a>`, {
|
||
timeout: 6,
|
||
sysNotify: true,
|
||
sysNotifyClick: () => window.open('https://www.torn.com/pmarket.php'),
|
||
});
|
||
}
|
||
} else {
|
||
// 查询出错了
|
||
Log.error('pt查询出错了')
|
||
}
|
||
}
|
||
|
||
// xan价格监视
|
||
async function priceWatcherXan(apikey, lower_price, priceWatcher) {
|
||
// 初始化记录上一个条目的id，避免重复发送通知
|
||
if (!priceWatcher['watch-xan-lower-id']) priceWatcher['watch-xan-lower-id'] = '';
|
||
const res = await window.fetch('https://api.torn.com/market/206?selections=bazaar&key=' + apikey);
|
||
const obj = await res.json();
|
||
if (obj['bazaar']) {
|
||
const lowest_item = obj['bazaar'][0]
|
||
if (lowest_item['cost'] <= lower_price) {
|
||
if (priceWatcher['watch-xan-lower-id'] !== lowest_item['ID']) {
|
||
priceWatcher['watch-xan-lower-id'] = lowest_item['ID'];
|
||
new Alert(`XAN新低价：$${ toThousands(lowest_item['cost']) }( < $${ toThousands(lower_price) }) - <a href="/imarket.php#/p=shop&step=shop&type=&searchname=Xanax" target="_blank">点击转跳</a>`, {
|
||
timeout: 6,
|
||
sysNotify: true,
|
||
sysNotifyClick: () => window.open('https://www.torn.com/imarket.php#/p=shop&step=shop&type=&searchname=Xanax')
|
||
});
|
||
}
|
||
}
|
||
} else {
|
||
// 查询出错了
|
||
Log.error('xan查询出错了')
|
||
}
|
||
} |