import { Provide } from '@midwayjs/core';
import { BaseService, CoolCommException } from '@cool-midway/core';
import { InjectEntityModel } from '@midwayjs/typeorm';
import { Repository } from 'typeorm';
import { OperationTradeRecordEntity } from '../entity/traderecord';

/**
 * 交易记录服务
 */
@Provide()
export class OperationTradeRecordService extends BaseService {
  @InjectEntityModel(OperationTradeRecordEntity)
  tradeRecordEntity: Repository<OperationTradeRecordEntity>;


  /**
   * 导入Excel数据
   * @param fileInfo 文件信息
   * @param dataList 解析后的数组
   */
  async importData(list: any[]) {
    if (!list || list.length === 0) {
      throw new Error('导入数据不能为空');
    }
    // 使用 TypeORM 的 save 方法批量插入
    await this.tradeRecordEntity.save(list);

  }
}