mirror of
https://github.com/shanmiteko/LotteryAutoScript.git
synced 2026-06-04 21:01:17 +08:00
240 lines
10 KiB
JavaScript
240 lines
10 KiB
JavaScript
const Base = require('./Base');
|
|
const BiliAPI = require('./BiliAPI');
|
|
const eventBus = require('./eventBus');
|
|
const Public = require('./Public');
|
|
const GlobalVar = require("./GlobalVar.json");
|
|
const config = require("./config");
|
|
const MyStorage = require('./MyStorage');
|
|
|
|
/**
|
|
* 监视器
|
|
*/
|
|
class Monitor extends Public {
|
|
/**
|
|
* @constructor
|
|
* @param {number | string} param
|
|
*/
|
|
constructor(param) {
|
|
super();
|
|
typeof param === 'number' ? this.UID = param : this.tag_name = param;
|
|
this.tagid = 0; /* tagid初始化为默认分组 */
|
|
this.attentionList = ''; /* 转为字符串的所有关注的up主uid */
|
|
this.isAttentionErr = false;
|
|
}
|
|
/**
|
|
* 初始化
|
|
*/
|
|
async init() {
|
|
if (config.model === '00') {
|
|
Base.tooltip.log('已关闭所有转发行为');
|
|
eventBus.emit('Turn_off_the_Monitor')
|
|
return
|
|
}
|
|
this.tagid = await BiliAPI.checkMyPartition(); /* 检查关注分区 */
|
|
this.attentionList = await BiliAPI.getAttentionList(GlobalVar.myUID); /* 获取关注列表 */
|
|
await this.startLottery();
|
|
}
|
|
/**
|
|
* 启动
|
|
* @returns {Promise<boolean>}
|
|
*/
|
|
async startLottery() {
|
|
const allLottery = await this.filterLotteryInfo();
|
|
let status = 0;
|
|
if (allLottery instanceof Array) {
|
|
if (allLottery.length) {
|
|
let dyids = [];
|
|
for (const Lottery of allLottery) {
|
|
status = await this.go(Lottery);
|
|
if (!status) break
|
|
dyids.push(Lottery.dyid);
|
|
}
|
|
if (dyids.length) MyStorage.updateDyid(dyids.toString())
|
|
Base.tooltip.log('开始转发下一组动态');
|
|
} else {
|
|
status = 1;
|
|
Base.tooltip.log('无未转发抽奖');
|
|
}
|
|
} else { status = 0 }
|
|
|
|
status ? eventBus.emit('Turn_on_the_Monitor') : eventBus.emit('Turn_off_the_Monitor');
|
|
}
|
|
/**
|
|
* 抽奖配置
|
|
* @typedef {object} LotteryOptions
|
|
* @property {number[]} uid 用户标识
|
|
* @property {string} dyid 动态标识
|
|
* @property {number} type 动态类型
|
|
* @property {string} relay_chat 动态类型
|
|
* @property {string} ctrl 定位@
|
|
* @property {string} rid 评论类型
|
|
*/
|
|
/**
|
|
* @returns {Promise<LotteryOptions[] | null>}
|
|
*/
|
|
async filterLotteryInfo() {
|
|
const self = this,
|
|
protoLotteryInfo = typeof self.UID === 'number' ? await self.getLotteryInfoByUID(self.UID) : await self.getLotteryInfoByTag(self.tag_name);
|
|
let _protoLotteryInfo = [];
|
|
if (protoLotteryInfo === null) return [];
|
|
let alllotteryinfo = [];
|
|
const { model, chatmodel, maxday: _maxday, minfollower, only_followed, at_users, blockword, blacklist } = config;
|
|
const maxday = _maxday === '-1' || _maxday === '' ? Infinity : (Number(_maxday) * 86400);
|
|
for (const info of protoLotteryInfo) {
|
|
const { lottery_info_type, uids, uname, dyid, official_verify, ctrl, befilter, rid, des, type, hasOfficialLottery } = info;
|
|
/**判断是否重复 */
|
|
let isRepeat = false;
|
|
for (const i of _protoLotteryInfo) {
|
|
if (dyid === i.dyid || (des && des === i.des)) {
|
|
isRepeat = true;
|
|
break;
|
|
}
|
|
}
|
|
if (isRepeat) continue;
|
|
_protoLotteryInfo.push(info);
|
|
/**判断是转发源动态还是现动态 */
|
|
const uid = lottery_info_type === 'tag' ? uids[0] : uids[1];
|
|
const now_ts_10 = Date.now() / 1000;
|
|
let onelotteryinfo = {};
|
|
let isLottery = false;
|
|
let isSendChat = false;
|
|
let isBlock = false;
|
|
let ts = 0;
|
|
const description = typeof des === 'string' ? des : '';
|
|
for (let index = 0; index < blockword.length; index++) {
|
|
const word = blockword[index];
|
|
const reg = new RegExp(word);
|
|
isBlock = reg.test(description) ? true : false;
|
|
if (isBlock) break;
|
|
}
|
|
if (isBlock) continue;
|
|
const needAt = /(?:@|艾特)[^@|(艾特)]*?好友/.test(description);
|
|
const needTopic = /(?<=[带加上](?:话题|tag))#.*#/i.exec(description)?.[0];
|
|
const isTwoLevelRelay = /\/\/@/.test(description);
|
|
const haslottery = /[抽奖]/.test(description);
|
|
const hasGuanZhuan = /[转关].*[转关]/.test(description);
|
|
if (hasOfficialLottery && model[0] === '1') {
|
|
ts = await BiliAPI.getLotteryNotice(dyid).ts;
|
|
if (ts < 0) { alllotteryinfo = null; break }
|
|
isLottery = ts > now_ts_10 && ts < now_ts_10 + maxday;
|
|
isSendChat = chatmodel[0] === '1';
|
|
} else if (!hasOfficialLottery && model[1] === '1' && haslottery && hasGuanZhuan && !isTwoLevelRelay) {
|
|
ts = Base.getLotteryNotice(description).ts;
|
|
if (!official_verify) {
|
|
const followerNum = await BiliAPI.getUserInfo(uid);
|
|
if (followerNum < 0) { alllotteryinfo = null; break }
|
|
if (followerNum < Number(minfollower)) continue;
|
|
isLottery = !befilter && (ts === 0 || (ts > now_ts_10 && ts < now_ts_10 + maxday));
|
|
} else {
|
|
isLottery = ts === 0 || (ts > now_ts_10 && ts < now_ts_10 + maxday);
|
|
}
|
|
isSendChat = chatmodel[1] === '1';
|
|
}
|
|
if (isLottery) {
|
|
/* 判断是否关注过 */
|
|
const isFollowed = (new RegExp(uid)).test(self.attentionList);
|
|
if ((this.isAttentionErr || only_followed === '1') && !isFollowed) continue;
|
|
/* 判断是否转发过 */
|
|
const isRelay = await MyStorage.searchDyid(dyid);
|
|
/* 获取黑名单并去重合并 */
|
|
const { blacklist: remote_blacklist } = GlobalVar.remoteconfig;
|
|
const new_blacklist = remote_blacklist ?
|
|
Array.from(new Set([...blacklist.split(','), ...remote_blacklist.split(',')])).toString() : blacklist;
|
|
/* 进行判断 */
|
|
if ((new RegExp(dyid + '|' + uid)).test(new_blacklist)) continue;
|
|
onelotteryinfo.uid = [] /**初始化待关注列表 */
|
|
if (!isFollowed) onelotteryinfo.uid.push(uid);
|
|
if (!isRelay) {
|
|
onelotteryinfo.dyid = dyid;
|
|
let RandomStr = Base.getRandomStr(config.relay);
|
|
let new_ctrl = [];
|
|
if (needTopic) {
|
|
RandomStr += needTopic
|
|
}
|
|
if (needAt) {
|
|
at_users.forEach(it => {
|
|
new_ctrl.push({
|
|
data: String(it[1]),
|
|
location: RandomStr.length,
|
|
length: it[0].length + 1,
|
|
type: 1
|
|
})
|
|
RandomStr += '@' + it[0]
|
|
})
|
|
}
|
|
if (type === 1) {
|
|
/* 转发内容长度+'//'+'@'+用户名+':'+源内容 */
|
|
const addlength = RandomStr.length + 2 + uname.length + 1 + 1;
|
|
onelotteryinfo.relay_chat = RandomStr + `//@${uname}:` + des;
|
|
new_ctrl.push({
|
|
data: String(uid),
|
|
location: RandomStr.length + 2,
|
|
length: uname.length + 1,
|
|
type: 1
|
|
})
|
|
ctrl.map(item => {
|
|
item.location += addlength;
|
|
return item;
|
|
}).forEach(it => new_ctrl.push(it))
|
|
if (!(new RegExp(uids[1])).test(self.attentionList))
|
|
onelotteryinfo.uid.push(uids[1]);
|
|
} else {
|
|
onelotteryinfo.relay_chat = RandomStr;
|
|
}
|
|
onelotteryinfo.ctrl = JSON.stringify(new_ctrl);
|
|
}
|
|
/* 根据动态的类型决定评论的类型 */
|
|
onelotteryinfo.type = type === 2 ?
|
|
11 : type === 4 || type === 1 ?
|
|
17 : type === 8 ?
|
|
1 : 0;
|
|
/* 是否评论 */
|
|
if (isSendChat) onelotteryinfo.rid = rid;
|
|
if (onelotteryinfo.dyid) alllotteryinfo.push(onelotteryinfo);
|
|
}
|
|
}
|
|
return alllotteryinfo;
|
|
}
|
|
/**
|
|
* 关注转发评论
|
|
* @param {LotteryOptions} option
|
|
* @returns {Promise<number>} sucess:1 err:0
|
|
*/
|
|
async go(option) {
|
|
const { uid, dyid, type, rid, relay_chat, ctrl } = option;
|
|
if (typeof rid === 'string' && type !== 0) {
|
|
const send = () => BiliAPI.sendChat(rid, Base.getRandomStr(config.chat), type);
|
|
let [status, times] = [0, 0];
|
|
do {
|
|
if (times > 0) Base.tooltip.log('等一会儿再发送评论');
|
|
times++;
|
|
status = await send();
|
|
if (status) break;
|
|
await Base.delay(60000 * times)
|
|
} while (times < 5);
|
|
if (status === 0) return status;
|
|
}
|
|
if (!this.isAttentionErr) {
|
|
uid.forEach(async (one_uid) => {
|
|
if (typeof one_uid === 'number') {
|
|
if (await BiliAPI.autoAttention(uid) === 0) {
|
|
this.isAttentionErr = true;
|
|
return
|
|
}
|
|
await Base.delay(5000);
|
|
if (await BiliAPI.movePartition(uid, this.tagid) === 0) {
|
|
this.isAttentionErr = true;
|
|
return
|
|
}
|
|
}
|
|
})
|
|
}
|
|
if (this.isAttentionErr && uid.length !== 0) return 0;
|
|
if (await BiliAPI.autolike(dyid) === 0) return 0;
|
|
if (await BiliAPI.autoRelay(GlobalVar.myUID, dyid, relay_chat, ctrl) === 0) return 0;
|
|
await Base.delay(Number(config.wait) + Math.floor(Math.random() * 60000 - 30000));
|
|
return 1
|
|
}
|
|
}
|
|
|
|
module.exports = Monitor; |