mirror of
https://github.com/lkeme/BiliHelper-personal.git
synced 2025-12-19 01:20:08 +08:00
448 lines
13 KiB
PHP
448 lines
13 KiB
PHP
<?php declare(strict_types=1);
|
||
|
||
/**
|
||
* Website: https://mudew.com/
|
||
* Author: Lkeme
|
||
* License: The MIT License
|
||
* Email: Useri@live.cn
|
||
* Updated: 2023 ~ 2024
|
||
*
|
||
* _____ _ _ _ _ _ _____ _ _____ _____ _____
|
||
* | _ \ | | | | | | | | | | | ____| | | | _ \ | ____| | _ \ & ／l、
|
||
* | |_| | | | | | | | | |_| | | |__ | | | |_| | | |__ | |_| | （ﾟ､ ｡ ７
|
||
* | _ { | | | | | | | _ | | __| | | | ___/ | __| | _ / \、ﾞ ~ヽ *
|
||
* | |_| | | | | |___ | | | | | | | |___ | |___ | | | |___ | | \ \ じしf_, )ノ
|
||
* |_____/ |_| |_____| |_| |_| |_| |_____| |_____| |_| |_____| |_| \_\
|
||
*/
|
||
|
||
use Bhp\Api\Api\X\Player\ApiPlayer;
|
||
use Bhp\Api\DynamicSvr\ApiDynamicSvr;
|
||
use Bhp\Api\Video\ApiCoin;
|
||
use Bhp\Api\Video\ApiShare;
|
||
use Bhp\Api\Video\ApiWatch;
|
||
use Bhp\Api\Video\ApiVideo;
|
||
use Bhp\Log\Log;
|
||
use Bhp\Plugin\BasePlugin;
|
||
use Bhp\Plugin\Plugin;
|
||
use Bhp\TimeLock\TimeLock;
|
||
use Bhp\User\User;
|
||
use Bhp\Util\ArrayR\ArrayR;
|
||
use Bhp\Util\Exceptions\NoLoginException;
|
||
use Bhp\Cache\Cache;
|
||
|
||
class MainSite extends BasePlugin
|
||
{
|
||
/**
|
||
* @var array|array[]
|
||
*/
|
||
protected array $records = [];
|
||
|
||
/**
|
||
* 插件信息
|
||
* @var array|string[]
|
||
*/
|
||
protected ?array $info = [
|
||
'hook' => __CLASS__, // hook
|
||
'name' => 'MainSite', // 插件名称
|
||
'version' => '0.0.1', // 插件版本
|
||
'desc' => '主站任务(观看|分享|投币)', // 插件描述
|
||
'author' => 'Lkeme',// 作者
|
||
'priority' => 1100, // 插件优先级
|
||
'cycle' => '24(小时)', // 运行周期
|
||
];
|
||
|
||
/**
|
||
* @param Plugin $plugin
|
||
*/
|
||
public function __construct(Plugin &$plugin)
|
||
{
|
||
//
|
||
TimeLock::initTimeLock();
|
||
//
|
||
Cache::initCache();
|
||
// $this::class
|
||
$plugin->register($this, 'execute');
|
||
}
|
||
|
||
/**
|
||
* 执行
|
||
* @return void
|
||
* @throws NoLoginException
|
||
*/
|
||
public function execute(): void
|
||
{
|
||
if (TimeLock::getTimes() > time() || !getEnable('main_site')) return;
|
||
// 缓存开始
|
||
$this->records = ($tmp = Cache::get('records')) ? $tmp : $this->initRecords();
|
||
//
|
||
if ($this->watchTask() && $this->shareTask() && $this->coinTask()) {
|
||
TimeLock::setTimes(TimeLock::timing(10));
|
||
} else {
|
||
TimeLock::setTimes(3600);
|
||
}
|
||
// 缓存结束
|
||
Cache::set('records', $this->records);
|
||
}
|
||
|
||
/**
|
||
* 初始化
|
||
* @return array[]
|
||
*/
|
||
protected function initRecords(): array
|
||
{
|
||
return [
|
||
'watch' => [],
|
||
'share' => [],
|
||
'coin' => [],
|
||
];
|
||
}
|
||
|
||
|
||
/**
|
||
* 获取稿件列表
|
||
* @param int $num
|
||
* @return array
|
||
*/
|
||
protected function fetchCustomArchives(int $num = 30): array
|
||
{
|
||
if (getConf('main_site.fetch_aids_mode') == 'random') {
|
||
// 随机热门稿件榜单
|
||
return $this->getTopArchives($num);
|
||
} else {
|
||
// 固定获取关注UP稿件榜单, 不足会随机补全
|
||
return $this->getFollowUpArchives($num);
|
||
}
|
||
}
|
||
|
||
|
||
/**
|
||
* 投币任务
|
||
* @param string $key
|
||
* @return bool
|
||
* @throws NoLoginException
|
||
*/
|
||
protected function coinTask(string $key = 'coin'): bool
|
||
{
|
||
if (!getConf('main_site.add_coin', false, 'bool')) return true;
|
||
// 已满6级
|
||
if (getConf('main_site.when_lv6_stop_coin', false, 'bool')) {
|
||
$userInfo = User::userNavInfo();
|
||
if ($userInfo->level_info->current_level >= 6) {
|
||
Log::notice('主站任务: 已满6级, 停止投币');
|
||
return true;
|
||
}
|
||
};
|
||
//
|
||
if (in_array($this->getKey(), $this->records[$key])) return true;
|
||
// 预计数量 失败默认0 避免损失
|
||
$estimate_num = getConf('main_site.add_coin_num', 0, 'int');
|
||
// 库存数量
|
||
$stock_num = $this->getCoinStock();
|
||
$already_num = $this->getCoinAlready();
|
||
// 实际数量 处理硬币库存少于预计数量
|
||
$actual_num = intval(min($estimate_num, $stock_num)) - $already_num;
|
||
//
|
||
Log::info("主站任务: 硬币库存 $stock_num 预投 $estimate_num 已投 $already_num 还需投币 $actual_num");
|
||
// 上限
|
||
if ($actual_num <= 0) {
|
||
Log::notice('主站任务: 今日投币上限已满');
|
||
// 插入
|
||
$this->records[$key][] = $this->getKey();
|
||
return true;
|
||
}
|
||
// 稿件列表
|
||
$aids = $this->fetchCustomArchives($actual_num);
|
||
// 从二维数组里取出aid
|
||
$aids = array_column($aids, 'aid');
|
||
//
|
||
Log::info("主站任务: 预投币稿件 " . implode(" ", $aids));
|
||
// 投币
|
||
foreach ($aids as $aid) {
|
||
$this->reward((string)$aid);
|
||
//
|
||
sleep(1);
|
||
}
|
||
// 插入
|
||
$this->records[$key][] = $this->getKey();
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 投币
|
||
* @param string $aid
|
||
* @return void
|
||
* @throws NoLoginException
|
||
*/
|
||
protected function reward(string $aid): void
|
||
{
|
||
$response = ApiCoin::coin($aid);
|
||
//
|
||
switch ($response['code']) {
|
||
case -101:
|
||
throw new NoLoginException($response['message']);
|
||
case 0:
|
||
Log::notice("主站任务: $aid 投币成功");
|
||
break;
|
||
default:
|
||
Log::warning("主站任务: $aid 投币失败 {$response['code']} -> {$response['message']}");
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 首页推荐
|
||
* @param int $num
|
||
* @param int $ps
|
||
* @return array
|
||
*/
|
||
protected function getTopArchives(int $num, int $ps = 30): array
|
||
{
|
||
$response = ApiVideo::dynamicRegion($ps);
|
||
//
|
||
if ($response['code']) {
|
||
Log::warning("主站任务: 获取首页推荐失败 {$response['code']} -> {$response['message']}");
|
||
return $this->getTopFeedRCMDArchives($num);
|
||
}
|
||
return ArrayR::toSlice($response['data']['archives'], $num);
|
||
}
|
||
|
||
/**
|
||
* 获取榜单稿件列表
|
||
* @param int $num
|
||
* @return array
|
||
*/
|
||
protected function getTopFeedRCMDArchives(int $num): array
|
||
{
|
||
$new_archives = [];
|
||
//
|
||
$response = ApiVideo::topFeedRCMD();
|
||
$archives = ArrayR::toSlice($response['data']['item'], $num);
|
||
//
|
||
foreach ($archives as $archive) {
|
||
$archive['aid'] = $archive['id'];
|
||
unset($archive['id']);
|
||
$new_archives[] = $archive;
|
||
}
|
||
return $new_archives;
|
||
}
|
||
|
||
/**
|
||
* 获取关注UP稿件列表
|
||
* @param int $num
|
||
* @return array
|
||
*/
|
||
protected function getFollowUpArchives(int $num): array
|
||
{
|
||
$archives = [];
|
||
//
|
||
$response = ApiDynamicSvr::followUpDynamic();
|
||
//
|
||
if ($response['code']) {
|
||
Log::warning("主站任务: 获取UP稿件失败 {$response['code']} -> {$response['message']}");
|
||
} else {
|
||
foreach ($response['data']['cards'] as $i => $card) {
|
||
// if ($i >= $num) break;
|
||
// JSON_ERROR_CTRL_CHAR
|
||
$temp = preg_replace('/[\x00-\x1F]/', '', $card['card']);
|
||
$archives[] = json_decode($temp, true);
|
||
}
|
||
$archives = ArrayR::toSlice($archives, $num, false);
|
||
}
|
||
// 此处补全缺失
|
||
if (($t_num = count($archives)) < $num) {
|
||
Log::warning("主站任务: 获取UP稿件数量不足，将自动补全随机稿件。");
|
||
$archives = array_merge($archives, $this->getTopArchives($num - $t_num));
|
||
}
|
||
return $archives;
|
||
}
|
||
|
||
/**
|
||
* 已投币数量
|
||
* @return int
|
||
*/
|
||
protected function getCoinAlready(): int
|
||
{
|
||
$response = ApiCoin::addLog();
|
||
//
|
||
if ($response['code'] || !isset($response['data']['list'])) {
|
||
Log::warning("主站任务: 获取已投硬币失败 {$response['code']} -> {$response['message']}");
|
||
return 0;
|
||
}
|
||
//
|
||
$logs = $response['data']['list'];
|
||
$coins = 0;
|
||
//
|
||
foreach ($logs as $log) {
|
||
$log_ux = strtotime($log['time']);
|
||
$log_date = date('Y-m-d', $log_ux);
|
||
$now_date = date('Y-m-d');
|
||
if ($log_date != $now_date) {
|
||
break;
|
||
}
|
||
if (str_contains($log['reason'], "打赏")) {
|
||
switch ($log['delta']) {
|
||
case -1:
|
||
$coins += 1;
|
||
break;
|
||
case -2:
|
||
$coins += 2;
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
return $coins;
|
||
}
|
||
|
||
/**
|
||
* 获取硬币库存
|
||
* @return int
|
||
*/
|
||
protected function getCoinStock(): int
|
||
{
|
||
// {"code":0,"status":true,"data":{"money":1707.9}}
|
||
// {"code":0,"status":true,"data":{"money":null}
|
||
$response = ApiCoin::getCoin();
|
||
//
|
||
if ($response['code'] || !isset($response['data']['money'])) {
|
||
Log::warning("主站任务: 获取硬币库存失败或者硬币为null " . json_encode($response, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE));
|
||
return 0;
|
||
}
|
||
//
|
||
return (int)$response['data']['money'];
|
||
}
|
||
|
||
/**
|
||
* 分享任务
|
||
* @param string $key
|
||
* @return bool
|
||
* @throws NoLoginException
|
||
*/
|
||
protected function shareTask(string $key = 'share'): bool
|
||
{
|
||
if (!getConf('main_site.share', false, 'bool')) return true;
|
||
//
|
||
if (in_array($this->getKey(), $this->records[$key])) return true;
|
||
//
|
||
$archives = $this->fetchCustomArchives(10);
|
||
$archive = array_pop($archives);
|
||
$aid = (string)$archive['aid'];
|
||
|
||
//
|
||
$response = ApiShare::share($aid);
|
||
switch ($response['code']) {
|
||
case -101:
|
||
throw new NoLoginException($response['message']);
|
||
case 0:
|
||
Log::notice("主站任务: $aid 分享成功");
|
||
// 插入
|
||
$this->records[$key][] = $this->getKey();
|
||
return true;
|
||
default:
|
||
Log::warning("主站任务: $aid 分享失败 {$response['code']} -> {$response['message']}");
|
||
return false;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 观看任务
|
||
* @param string $key
|
||
* @return bool
|
||
*/
|
||
protected function watchTask(string $key = 'watch'): bool
|
||
{
|
||
if (!getConf('main_site.watch', false, 'bool')) return true;
|
||
//
|
||
if (in_array($this->getKey(), $this->records[$key])) return true;
|
||
//
|
||
$archives = $this->fetchCustomArchives(10);
|
||
$archive = array_pop($archives);
|
||
//
|
||
if (isset($archive['duration']) && is_int($archive['duration'])) {
|
||
$info = $archive;
|
||
} else {
|
||
// 额外处理信息
|
||
$info = $this->getArchiveInfo((string)$archive['aid']);
|
||
if (empty($info)) return false;
|
||
}
|
||
//
|
||
$aid = (string)$info['aid'];
|
||
$cid = (string)$info['cid'];
|
||
$duration = (int)$info['duration'];
|
||
//
|
||
$response = ApiWatch::video($aid, $cid);
|
||
// == 0
|
||
if ($response['code']) {
|
||
Log::warning("主站任务: $aid 观看失败 {$response['code']} -> {$response['message']}");
|
||
return false;
|
||
}
|
||
$response = ApiWatch::heartbeat($aid, $cid, $duration);
|
||
if ($response['code']) {
|
||
Log::warning("主站任务: $aid 观看失败 {$response['code']} -> {$response['message']}");
|
||
return false;
|
||
}
|
||
sleep(5);
|
||
//
|
||
$data = [];
|
||
$data['played_time'] = $duration - 1;
|
||
$data['play_type'] = 0;
|
||
$data['start_ts'] = time();
|
||
//
|
||
$response = ApiWatch::heartbeat($aid, $cid, $duration, $data);
|
||
if ($response['code']) {
|
||
Log::warning("主站任务: $aid 观看失败 {$response['code']} -> {$response['message']}");
|
||
return false;
|
||
}
|
||
//
|
||
Log::notice("主站任务: $aid 观看成功");
|
||
// 插入
|
||
$this->records[$key][] = $this->getKey();
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 获取稿件详情/暂时不额外处理错误
|
||
* @param string $aid
|
||
* @return array
|
||
*/
|
||
protected function getArchiveInfo(string $aid): array
|
||
{
|
||
$response = ApiPlayer::pageList($aid);
|
||
//
|
||
if ($response['code'] == -404 || !isset($response['data'])) {
|
||
Log::warning("主站任务: $aid 获取稿件信息失败 {$response['code']} -> {$response['message']}");
|
||
return [];
|
||
}
|
||
$archive_info = $response['data'][0];
|
||
$archive_info['aid'] = $aid;
|
||
return $archive_info;
|
||
}
|
||
|
||
|
||
/**
|
||
* 获取随机
|
||
* @return array
|
||
*/
|
||
protected function fetchRandomAvInfos(): array
|
||
{
|
||
do {
|
||
$response = ApiVideo::newlist(mt_rand(1, 1000), 10);
|
||
} while (count($response['data']['archives']) == 0);
|
||
//
|
||
$info = $response['data']['archives'];
|
||
shuffle($info);
|
||
//
|
||
return $info;
|
||
}
|
||
|
||
|
||
/**
|
||
* @return string
|
||
*/
|
||
protected function getKey(): string
|
||
{
|
||
return substr(md5(md5(date("Y-m-d", time()))), 8, 8);
|
||
}
|
||
|
||
}
|