feat

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(
+        this.networkManager.registerAdapter(
-        //     new OB11PluginAdapter('myPlugin', this.core, this,this.actions)
+            new OB11PluginAdapter('myPlugin', this.core, this,this.actions)
-        // );
+        );
         for (const key of ob11Config.network.httpServers) {
             if (key.enable) {
                 this.networkManager.registerAdapter(

src/onebot/network/plugin.ts

@@ -22,7 +22,7 @@ export class OB11PluginAdapter extends IOB11NetworkAdapter<PluginConfig> {
 
     onEvent<T extends OB11EmitEventContent>(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);
         }
     }
 

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) => {
+// 用户绑定的TapTap ID存储
-    if (message.raw_message === 'ping') {
+const userBindTapMap = new Map<string, string>();
-        const ret = await action.get('send_group_msg')?.handle({ group_id: String(message.group_id), message: 'pong' }, adapter, instance.config);
+
-        console.log(ret);
+/**
+ * 发送消息工具函数
+ */
+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<any> {
+    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;
+    }
+}