wip: transacao

src/bigquery/entities/transacao.bq-entity.ts → src/bigquery/entities/transacao.bigquery-entity.ts

@@ -1,4 +1,4 @@
-export class BqTransacao {
+export class BigqueryTransacao {
   id: number;
   data: Date;
   hora: number;
@@ -7,8 +7,10 @@ export class BqTransacao {
   datetime_captura: Date;
   modo: string;
   id_consorcio: string;
+  /** Nome do consórcio */
   consorcio: string;
   id_operadora: string;
+  /** Nome da operadora */
   operadora: string;
   servico: string;
   sentido: string;

src/bigquery/interfaces/bq-find-transacao-by.interface.ts

@@ -5,5 +5,5 @@ export interface IBqFetchTransacao {
   limit?: number;
   offset?: number;
   getToday?: boolean;
-  previousDays?: boolean;
+  previousDaysOnly?: boolean;
 }

src/bigquery/interfaces/bq-get-week-transacao-by.interface.ts

@@ -0,0 +1,3 @@
+export interface IBqGetWeekTransacao {
+  cpfCnpj: string;
+}

src/bigquery/repositories/bq-transacao.repository.service.spec.ts → src/bigquery/repositories/bigquery-transacao.repository.spec.ts

@@ -2,16 +2,16 @@ import { Provider } from '@nestjs/common';
 import { Test, TestingModule } from '@nestjs/testing';
 import { BigqueryService } from 'src/bigquery/bigquery.service';
 import { SettingsService } from 'src/settings/settings.service';
-import { BqTransacaoRepositoryService } from './bq-transacao.repository.service';
+import { BigqueryTransacaoRepository } from './bigquery-transacao.repository';
 import { ConfigService } from '@nestjs/config';
 import { resolve } from 'path';
 import { config } from 'dotenv';
 import { BigqueryEnvironment } from 'src/settings/enums/bigquery-env.enum';
 import { SettingEntity } from 'src/settings/entities/setting.entity';
 
-describe('BqTransacaoRepositoryService', () => {
+describe('BigqueryTransacaoRepositoryService', () => {
   let settingsService: SettingsService;
-  let bqTransacaoRepository: BqTransacaoRepositoryService;
+  let bqTransacaoRepository: BigqueryTransacaoRepository;
   const mockBqGoogleCredentials = () => ({
     'google.clientApiType': process.env.GOOGLE_CLIENT_API_TYPE,
     'google.clientApiProjectId': process.env.GOOGLE_CLIENT_API_PROJECT_ID,
@@ -51,14 +51,14 @@ describe('BqTransacaoRepositoryService', () => {
     const module: TestingModule = await Test.createTestingModule({
       providers: [
         BigqueryService,
-        BqTransacaoRepositoryService,
+        BigqueryTransacaoRepository,
         settingsServiceMock,
         configServiceMock,
       ],
     }).compile();
 
     settingsService = module.get(SettingsService);
-    bqTransacaoRepository = module.get(BqTransacaoRepositoryService);
+    bqTransacaoRepository = module.get(BigqueryTransacaoRepository);
   });
 
   afterEach(() => {

src/bigquery/repositories/bq-transacao.repository.service.ts → src/bigquery/repositories/bigquery-transacao.repository.ts

@@ -6,15 +6,15 @@ import { TRIntegrationTypeMap } from 'src/ticket-revenues/maps/ticket-revenues.m
 import { isCpfOrCnpj } from 'src/utils/cpf-cnpj';
 import { QueryBuilder } from 'src/utils/query-builder/query-builder';
 import { BQSInstances, BigqueryService } from '../bigquery.service';
-import { BqTransacao } from '../entities/transacao.bq-entity';
+import { BigqueryTransacao } from '../entities/transacao.bigquery-entity';
 import { IBqFetchTransacao } from '../interfaces/bq-find-transacao-by.interface';
 import { BqTsansacaoTipoIntegracaoMap } from '../maps/bq-transacao-tipo-integracao.map';
 import { BqTransacaoTipoPagamentoMap } from '../maps/bq-transacao-tipo-pagamento.map';
 import { BqTransacaoTipoTransacaoMap } from '../maps/bq-transacao-tipo-transacao.map';
 
 @Injectable()
-export class BqTransacaoRepositoryService {
-  private logger: Logger = new Logger('BqTransacaoRepositoryService', {
+export class BigqueryTransacaoRepository {
+  private logger: Logger = new Logger('BigqueryTransacaoRepository', {
     timestamp: true,
   });
 
@@ -25,14 +25,15 @@ export class BqTransacaoRepositoryService {
 
   public async findTransacaoBy(
     filter?: IBqFetchTransacao,
-  ): Promise<BqTransacao[]> {
-    const transacoes: BqTransacao[] = (await this.fetchTransacao(filter)).data;
+  ): Promise<BigqueryTransacao[]> {
+    const transacoes: BigqueryTransacao[] = (await this.fetchTransacao(filter))
+      .data;
     return transacoes;
   }
 
   private async fetchTransacao(
     args?: IBqFetchTransacao,
-  ): Promise<{ data: BqTransacao[]; countAll: number }> {
+  ): Promise<{ data: BigqueryTransacao[]; countAll: number }> {
     const qArgs = await this.getQueryArgs(args);
     const query =
       `
@@ -80,7 +81,7 @@ export class BqTransacaoRepositoryService {
 
     const count: number = queryResult[0].count;
     // Remove unwanted keys and remove last item (all null if empty)
-    let transacoes: BqTransacao[] = queryResult.map((i) => {
+    let transacoes: BigqueryTransacao[] = queryResult.map((i) => {
       delete i.status;
       delete i.count;
       return i;
@@ -147,7 +148,7 @@ export class BqTransacaoRepositoryService {
         `DATE(t.datetime_processamento) <= DATE('${endDate}')`,
       );
     }
-    if (args?.previousDays === true) {
+    if (args?.previousDaysOnly === true) {
       queryBuilder.pushAND(
         'DATE(t.datetime_processamento) > DATE(t.datetime_transacao)',
       );
@@ -202,8 +203,8 @@ export class BqTransacaoRepositoryService {
   /**
    * Convert id or some values into desired string values
    */
-  private mapBqTransacao(transacoes: BqTransacao[]): BqTransacao[] {
-    return transacoes.map((item: BqTransacao) => {
+  private mapBqTransacao(transacoes: BigqueryTransacao[]): BigqueryTransacao[] {
+    return transacoes.map((item: BigqueryTransacao) => {
       const tipo_transacao = item.tipo_transacao;
       const tipo_pagamento = item.tipo_pagamento;
       const tipo_integracao = item.tipo_integracao;

src/bigquery/services/bigquery-transacao.service.ts

@@ -0,0 +1,27 @@
+import { Injectable, Logger } from '@nestjs/common';
+import { nextFriday } from 'date-fns';
+import { getPaymentWeek } from 'src/utils/payment-date-utils';
+import { BigqueryTransacao } from '../entities/transacao.bigquery-entity';
+import { BigqueryTransacaoRepository } from '../repositories/bigquery-transacao.repository';
+
+@Injectable()
+export class BigqueryTransacaoService {
+  private logger: Logger = new Logger('BigqueryTransacaoService', {
+    timestamp: true,
+  });
+
+  constructor(
+    private readonly bigqueryTransacaoRepository: BigqueryTransacaoRepository,
+  ) {}
+
+  /**
+   * Get data from current payment week (from thu to wed)
+   */
+  public async getTransacaoOfCurrentWeek(): Promise<BigqueryTransacao[]> {
+    const paymentWeek = getPaymentWeek(nextFriday(new Date()));
+    return this.bigqueryTransacaoRepository.findTransacaoBy({
+      startDate: paymentWeek.startDate,
+      endDate: paymentWeek.endDate,
+    });
+  }
+}

src/cnab/dto/save-cliente-favorecido.dto.ts

@@ -0,0 +1,69 @@
+import { IsNotEmpty, ValidateIf } from 'class-validator';
+
+function isCreate(object: SaveClienteFavorecidoDto): boolean {
+  return object.id_cliente_favorecido === undefined;
+}
+
+export class SaveClienteFavorecidoDto {
+  id_cliente_favorecido?: number;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  nome?: string;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  cpf_cnpj?: string;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  cod_banco?: string;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  agencia?: string;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  dv_agencia?: string;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  conta_corrente?: string;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  dv_conta_corrente?: string;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  logradouro?: string;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  numero?: string;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  complemento?: string;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  bairro?: string;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  cidade?: string;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  cep?: string;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  complemento_cep?: string;
+
+  @ValidateIf(isCreate)
+  @IsNotEmpty()
+  uf?: string;
+}

src/cnab/entity/cliente-favorecido.entity.ts

@@ -59,4 +59,12 @@ export class ClienteFavorecido extends EntityHelper {
 
   @Column({ type: String, unique: false, nullable: true, length: 2 })
   uf: string;
+
+  public getLogInfo(showName?: boolean): string {
+    if (showName === undefined) {
+      showName = false;
+    }
+    const response = `#${this.cpf_cnpj}` + showName ? ` '${this.nome}'` : '';
+    return response;
+  }
 }