From 0aa1afee7a75342b02385cd6dcdb4d5d8b75cc17 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=89=8B=E7=93=9C=E4=B8=80=E5=8D=81=E9=9B=AA?= Date: Tue, 22 Apr 2025 12:14:19 +0800 Subject: [PATCH] feat --- src/onebot/index.ts | 7 +- src/onebot/network/plugin.ts | 2 +- src/plugin/index.ts | 149 ++++++++++++++++++++++++++++++++++- 3 files changed, 150 insertions(+), 8 deletions(-) diff --git a/src/onebot/index.ts b/src/onebot/index.ts index 4fb0089c..d932e1a5 100644 --- a/src/onebot/index.ts +++ b/src/onebot/index.ts @@ -50,6 +50,7 @@ import { import { OB11Message } from './types'; import { IOB11NetworkAdapter } from '@/onebot/network/adapter'; import { OB11HttpSSEServerAdapter } from './network/http-server-sse'; +import { OB11PluginAdapter } from './network/plugin'; //OneBot实现类 export class NapCatOneBot11Adapter { @@ -113,9 +114,9 @@ export class NapCatOneBot11Adapter { //创建NetWork服务 // 注册Plugin 如果需要基于NapCat进行快速开发 - // this.networkManager.registerAdapter( - // new OB11PluginAdapter('myPlugin', this.core, this,this.actions) - // ); + this.networkManager.registerAdapter( + new OB11PluginAdapter('myPlugin', this.core, this,this.actions) + ); for (const key of ob11Config.network.httpServers) { if (key.enable) { this.networkManager.registerAdapter( diff --git a/src/onebot/network/plugin.ts b/src/onebot/network/plugin.ts index 717276d9..030aa8e2 100644 --- a/src/onebot/network/plugin.ts +++ b/src/onebot/network/plugin.ts @@ -22,7 +22,7 @@ export class OB11PluginAdapter extends IOB11NetworkAdapter { onEvent(event: T) { if (event.post_type === 'message') { - plugin_onmessage(this.config.name, this.core, this.obContext, event as OB11Message, this.actions, this).then().catch(); + plugin_onmessage(this.config.name, this.core, this.obContext, event as OB11Message, this.actions, this).then().catch(console.log); } } diff --git a/src/plugin/index.ts b/src/plugin/index.ts index 484a58b5..78e9ded4 100644 --- a/src/plugin/index.ts +++ b/src/plugin/index.ts @@ -2,10 +2,151 @@ import { NapCatOneBot11Adapter, OB11Message } from '@/onebot'; import { NapCatCore } from '@/core'; import { ActionMap } from '@/onebot/action'; import { OB11PluginAdapter } from '@/onebot/network/plugin'; +import { RequestUtil } from '@/common/request'; -export const plugin_onmessage = async (adapter: string, _core: NapCatCore, _obCtx: NapCatOneBot11Adapter, message: OB11Message, action: ActionMap, instance: OB11PluginAdapter) => { - if (message.raw_message === 'ping') { - const ret = await action.get('send_group_msg')?.handle({ group_id: String(message.group_id), message: 'pong' }, adapter, instance.config); - console.log(ret); +// 用户绑定的TapTap ID存储 +const userBindTapMap = new Map(); + +/** + * 发送消息工具函数 + */ +const sendMessage = async ( + message: OB11Message, + action: ActionMap, + content: string +) => { + if (message.message_type === 'private') { + await action.get('send_msg')?._handle({ + user_id: message.user_id.toString(), + message: content, + }); + } else { + await action.get('send_msg')?._handle({ + group_id: message.group_id?.toString(), + message: content, + }); } }; + +/** + * 插件消息处理函数 + */ +export const plugin_onmessage = async ( + _adapter: string, + _core: NapCatCore, + _obCtx: NapCatOneBot11Adapter, + message: OB11Message, + action: ActionMap, + _instance: OB11PluginAdapter +) => { + if (message.raw_message.startsWith('/1999 绑定')) { + const tap_id = message.raw_message.slice(8).trim(); + + if (tap_id.length === 0) { + await sendMessage(message, action, '请输入正确的 TapTap ID'); + return; + } + + userBindTapMap.set(message.user_id.toString(), tap_id); + await sendMessage(message, action, `绑定成功，TapTap ID: ${tap_id}`); + } + if (message.raw_message.startsWith('/1999 查询')) { + const tap_id = userBindTapMap.get(message.user_id.toString()); + + if (!tap_id) { + await sendMessage(message, action, '请先绑定 TapTap ID'); + return; + } + + const userInfo = await get_user(tap_id); + let x = JSON.stringify(userInfo, null, 2); + _core.context.logger.log(x); + const user_1999_name = userInfo.data.list[0].basic_module.name; + const user_1999_role_id = userInfo.data.list[0].basic_module.role_id; + + const user_1999_character_num = userInfo.data.list[0].basic_module.custom_items[0].value; + const user_1999_login_day = userInfo.data.list[0].basic_module.custom_items[1].value; + const user_1999_raindrops = userInfo.data.list[0].basic_module.custom_items[2].value; + const user_1999_start_day = userInfo.data.list[1].episode_module.custom_items[0].value; + const user_1999_progress = userInfo.data.list[1].episode_module.custom_items[1].value; + const user_1999_sleepwalking = userInfo.data.list[1].episode_module.custom_items[2].value; + const msg = `REVERSE.1999\n` + + `昵称: ${user_1999_name}\n` + + `角色ID: ${user_1999_role_id}\n` + + `角色数量: ${user_1999_character_num}\n` + + `登录天数: ${user_1999_login_day}\n` + + `雨滴数量: ${user_1999_raindrops}\n` + + `你何时睁眼看这个世界: ${user_1999_start_day}\n` + + `你在哪一幕: ${user_1999_progress}\n` + + `人工梦游: ${user_1999_sleepwalking}`; + + await sendMessage(message, action, msg); + } + if (message.raw_message.startsWith('/1999 心相')) { + const tap_id = userBindTapMap.get(message.user_id.toString()); + + if (!tap_id) { + await sendMessage(message, action, '请先绑定 TapTap ID'); + return; + } + + const userInfo = await get_user(tap_id); + let x = JSON.stringify(userInfo, null, 2); + _core.context.logger.log(x); + const user_1999_name = userInfo.data.list[0].basic_module.name; + const user_1999_role_id = userInfo.data.list[0].basic_module.role_id; + + const user_1999_msg = userInfo.data.list[3].weapon_module.list.map((item: { name: string; level: number }) => item.name + ": LV." + item.level).join('\n'); + const msg = `REVERSE.1999\n` + + `昵称: ${user_1999_name}\n` + + `角色ID: ${user_1999_role_id}\n` + + `=====>心相<=====\n` + + user_1999_msg + + await sendMessage(message, action, msg); + } + if (message.raw_message.startsWith('/1999 角色')) { + const tap_id = userBindTapMap.get(message.user_id.toString()); + + if (!tap_id) { + await sendMessage(message, action, '请先绑定 TapTap ID'); + return; + } + + const userInfo = await get_user(tap_id); + let x = JSON.stringify(userInfo, null, 2); + _core.context.logger.log(x); + const user_1999_name = userInfo.data.list[0].basic_module.name; + const user_1999_role_id = userInfo.data.list[0].basic_module.role_id; + + const user_1999_msg = userInfo.data.list[2].character_module.list.map((item: { name: string; level: number }) => item.name + ": LV." + item.level).join('\n'); + const msg = `REVERSE.1999\n` + + `昵称: ${user_1999_name}\n` + + `角色ID: ${user_1999_role_id}\n` + + `=====>角色<=====\n` + + user_1999_msg + + await sendMessage(message, action, msg); + } +}; + +/** + * 获取用户游戏记录信息 + * @param tap_id TapTap用户ID + * @returns 用户游戏记录信息 + */ +export async function get_user(tap_id: string): Promise { + try { + const params = new URLSearchParams({ + 'app_id': '221062', + 'user_id': tap_id, + 'X-UA': 'V=1&PN=WebApp&LANG=zh_CN&VN_CODE=102&VN=0.1.0&LOC=CN&PLT=Android&DS=Android&UID=00e000ee-00e0-0e0e-ee00-f0c95d8ca115&VID=444444444&OS=Android&OSV=14.0.1' + }); + + const url = `https://www.taptap.cn/webapiv2/game-record/v1/detail-by-user?${params.toString()}`; + return await RequestUtil.HttpGetJson(url, 'GET'); + } catch (error) { + console.error('获取用户游戏记录失败:', error); + throw error; + } +} \ No newline at end of file