tg_admin_server/app/service/admin/tg/tglog.ts

import BaseService from '../../base';

export default class Tglog extends BaseService {
  /**
   * 分页加载日志信息
   */
  async send_page(page: number, count: number) {
    // return await this.getRepo().admin.tg.TgBotSendLog.find({
    //   order: {
    //     id: 'DESC',
    //   },
    //   take: count,
    //   skip: page * count,
    // });
    return await this.getRepo().admin.tg.TgBotSendLog.createQueryBuilder('log')
      .leftJoinAndSelect('tg_bot', 'bot', 'bot.botId = log.botId')
      .leftJoinAndSelect('tg_group', 'group', 'group.groupId = log.groupId')
      .select([
        'log.botId',
        'log.groupId',
        'log.text',
        'log.createTime',
        'log.updateTime',
        'bot.name',
        'group.name',
      ])
      .orderBy('log.id', 'DESC')
      .skip((page) * count)
      .take(count)
      .getRawMany();
  }
  async receive_page(page: number, count: number) {
    // return await this.getRepo().admin.tg.TgMessage.find({
    //   order: {
    //     id: 'DESC',
    //   },
    //   take: count,
    //   skip: page * count,
    // });
    return await this.getRepo().admin.tg.TgMessage.createQueryBuilder('msg')
      .leftJoinAndSelect('tg_bot', 'bot', 'bot.botId = msg.botId')
      .select([
        'msg.botId',
        'msg.chatId',
        'msg.chatTitle',
        'msg.fromUserId',
        'msg.fromName',
        'msg.text',
        'msg.sentTime',
        'msg.createTime',
        'msg.updateTime',
        'bot.name',
      ])
      .orderBy('msg.id', 'DESC')
      .skip((page) * count)
      .take(count)
      .getRawMany();
  }
  async receive_count() {
    return await this.getRepo().admin.tg.TgMessage.count();
  }
  async send_count() {
    return await this.getRepo().admin.tg.TgBotSendLog.count();
  }
}