fix: 数据库中的 ID 错误

src/controllers/ForwardController.ts

@@ -4,7 +4,6 @@ import ForwardService from '../services/ForwardService';
 import forwardPairs from '../providers/forwardPairs';
 import { Friend, Group, GroupMessageEvent, PrivateMessageEvent } from 'oicq';
 import db from '../providers/db';
-import helper from '../helpers/forwardHelper';
 import { Api } from 'telegram';
 
 export default class ForwardController {
@@ -34,7 +33,7 @@ export default class ForwardController {
       // 更新数据库
       await db.message.create({
         data: {
-          qqRoomId: helper.getRoomId(pair.qq),
+          qqRoomId: pair.qqRoomId,
           qqSenderId: event.sender.user_id,
           time: event.time,
           brief: event.raw_message,
@@ -58,7 +57,7 @@ export default class ForwardController {
       // 更新数据库
       await db.message.create({
         data: {
-          qqRoomId: helper.getRoomId(pair.qq),
+          qqRoomId: pair.qqRoomId,
           qqSenderId: qqMessage.sender.user_id,
           time: qqMessage.time,
           brief: qqMessage.raw_message,

src/helpers/forwardHelper.ts

@@ -37,15 +37,6 @@ export default {
       .replace(/</g, '&lt;')
       .replace(/>/g, '&gt;'),
 
-  getRoomId(room: Friend | Group) {
-    if (room instanceof Friend) {
-      return room.user_id;
-    }
-    else {
-      return room.group_id;
-    }
-  },
-
   processJson(json: string) {
     const jsonObj = JSON.parse(json);
     if (jsonObj.app === 'com.tencent.mannounce') {

src/providers/forwardPairs.ts

@@ -33,7 +33,7 @@ export class Pair {
       where: { id: this.dbId },
       data: { tgChatId: Number(value.id) },
     })
-      .then(() => log.info(`出现了到超级群组到转换: ${value.id}`));
+      .then(() => log.info(`出现了到超级群组的转换: ${value.id}`));
   }
 }
 

src/services/ForwardService.ts

@@ -95,7 +95,7 @@ export default class ForwardService {
               message = `文件: ${elem.name}\n` +
                 `大小: ${helper.hSize(elem.size)}`;
               const dbEntry = await db.file.create({
-                data: { fileId: elem.fid, roomId: helper.getRoomId(pair.qq), info: message },
+                data: { fileId: elem.fid, roomId: pair.qqRoomId, info: message },
               });
               button = Button.url('⏬ 获取下载地址',
                 `https://t.me/${this.tgBot.me.username}?start=file-${dbEntry.id}`);
@@ -160,7 +160,7 @@ export default class ForwardService {
         try {
           const quote = await db.message.findFirst({
             where: {
-              qqRoomId: helper.getRoomId(pair.qq),
+              qqRoomId: pair.qqRoomId,
               seq: event.source.seq,
               rand: event.source.rand,
             },