Criação de transferência em lotes pelo PIX

.github/workflows/pypi.yml

@@ -19,7 +19,7 @@ jobs:
     - name: Set up Poetry
       uses: Gr1N/setup-poetry@v7
       with:
-        poetry-version: 1.1.8
+        poetry-version: 1.4.2
 
     - name: Install dependencies
       run: |

.github/workflows/tests.yml

@@ -24,7 +24,7 @@ jobs:
       - name: Set up Poetry
         uses: Gr1N/setup-poetry@v7
         with:
-          poetry-version: 1.1.8
+          poetry-version: 1.4.2
 
       - name: Install dependencies
         run: |
@@ -52,7 +52,7 @@ jobs:
       - name: Set up Poetry
         uses: Gr1N/setup-poetry@v7
         with:
-          poetry-version: 1.1.8
+          poetry-version: 1.4.2
 
       - name: Install dependencies
         run: |
@@ -79,7 +79,7 @@ jobs:
       - name: Set up Poetry
         uses: Gr1N/setup-poetry@v7
         with:
-          poetry-version: 1.1.8
+          poetry-version: 1.4.2
 
       - name: Install dependencies
         run: |

bb_wrapper/models/pagamentos.py

@@ -56,11 +56,12 @@ class TransferenciaPIX(BaseModel):
     valor: float
     chave: str
     formaIdentificacao: Optional[TipoChavePIX]
-    dddTelefone: Optional[int]
-    telefone: Optional[int]
+    descricaoPagamento: Optional[str]
+    dddTelefone: Optional[str]
+    telefone: Optional[str]
     email: Optional[str]
-    cpf: Optional[int]
-    cnpj: Optional[int]
+    cpf: Optional[str]
+    cnpj: Optional[str]
     identificacaoAleatoria: Optional[str]
 
     # noinspection PyMethodParameters
@@ -74,23 +75,25 @@ def _set_data(cls, values):
         from ..services.pix import PixService
 
         key = values.get("chave")
-
         key_type = PixService().identify_key_type(key)
-        values["formaIdentificacao"] = key_type
+        values["formaIdentificacao"] = key_type.value
 
         if key_type == TipoChavePIX.telefone:
-            values["dddTelefone"] = int(key[:2])
-            values["telefone"] = int(key[2:])
+            values["dddTelefone"] = key[:2]
+            values["telefone"] = key[2:]
         elif key_type == TipoChavePIX.email:
+            PixService().verify_email(key)
             values["email"] = key
         elif key_type == TipoChavePIX.uuid:
             values["identificacaoAleatoria"] = key
         elif key_type == TipoChavePIX.documento:
             key_value = cpfcnpj.clear_punctuation(key)
-            if len(key_value) == 1:
-                values["cpf"] = int(key_value)
+            if len(key_value) == 11:
+                values["cpf"] = key_value
             else:
-                values["cnpj"] = int(key_value)
+                values["cnpj"] = key_value
+
+        values.pop("chave")
         return values
 
 

bb_wrapper/services/__init__.py

@@ -4,6 +4,7 @@
 from .barcode import BarcodeService
 from .mod import ModService  # noqa: F401
 from .pixcode import PixCodeService  # noqa: F401
+from .pix import PixService  # noqa: F401
 
 
 parse_unicode_to_alphanumeric = UnicodeService().parse_unicode_to_alphanumeric

bb_wrapper/services/document.py

@@ -1,4 +1,5 @@
 from pycpfcnpj import cpfcnpj
+from bb_wrapper.models.perfis import TipoInscricaoEnum
 
 
 class DocumentoService:
@@ -12,9 +13,9 @@ def identifica_tipo(self, documento):
         """
         documento = self.valida(documento)
         if len(documento) == 11:
-            return 1
+            return TipoInscricaoEnum.cpf
         else:
-            return 2
+            return TipoInscricaoEnum.cnpj
 
     def valida(self, documento):
         """

bb_wrapper/services/pix.py

@@ -1,4 +1,5 @@
 import uuid
+import re
 
 from pycpfcnpj import cpfcnpj
 
@@ -36,7 +37,7 @@ def identify_key_type(self, key: str):
 
         # 4
         try:
-            is_uuid = uuid.UUID(key)
+            is_uuid = bool(uuid.UUID(key))
         except ValueError:
             is_uuid = False
 
@@ -52,3 +53,14 @@ def identify_key_type(self, key: str):
             return TipoChavePIX.uuid
         else:
             raise ValueError("Tipo de chave não identificado")
+
+    def verify_email(self, email: str, raise_exception=True):
+        regex = re.compile(
+            r"([A-Za-z0-9]+[.-_])*[A-Za-z0-9]+@[A-Za-z0-9-]+(\.[A-Z|a-z]{2,})+"
+        )
+
+        is_email_valid = re.fullmatch(regex, email)
+
+        if raise_exception and not is_email_valid:
+            raise ValueError("Email inválido!")
+        return is_email_valid

bb_wrapper/wrapper/pagamento_lote.py

@@ -6,6 +6,7 @@
     LoteData,
     LoteTransferenciaData,
     LiberarPagamentos,
+    TransferenciaPIX,
 )
 from ..services.document import DocumentoService
 from ..services.barcode import BarcodeService
@@ -16,7 +17,8 @@ class PagamentoLoteBBWrapper(BaseBBWrapper):
     Wrapper da API Pagamentos em Lote
     """
 
-    SCOPE = "pagamentos-lote.lotes-requisicao pagamentos-lote.transferencias-info pagamentos-lote.transferencias-requisicao pagamentos-lote.cancelar-requisicao pagamentos-lote.devolvidos-info pagamentos-lote.lotes-info pagamentos-lote.pagamentos-guias-sem-codigo-barras-info pagamentos-lote.pagamentos-info pagamentos-lote.pagamentos-guias-sem-codigo-barras-requisicao pagamentos-lote.pagamentos-codigo-barras-info pagamentos-lote.boletos-requisicao pagamentos-lote.guias-codigo-barras-info pagamentos-lote.guias-codigo-barras-requisicao pagamentos-lote.transferencias-pix-info pagamentos-lote.transferencias-pix-requisicao pagamentos-lote.pix-info pagamentos-lote.boletos-info"  # noqa
+    SCOPE = "pagamentos-lote.lotes-requisicao pagamentos-lote.transferencias-info pagamentos-lote.transferencias-requisicao pagamentos-lote.cancelar-requisicao pagamentos-lote.devolvidos-info pagamentos-lote.lotes-info pagamentos-lote.pagamentos-guias-sem-codigo-barras-info pagamentos-lote.pagamentos-info pagamentos-lote.pagamentos-guias-sem-codigo-barras-requisicao pagamentos-lote.pagamentos-codigo-barras-info pagamentos-lote.boletos-requisicao pagamentos-lote.guias-codigo-barras-info pagamentos-lote.guias-codigo-barras-requisicao pagamentos-lote.boletos-info pagamentos-lote.transferencias-pix-requisicao pagamentos-lote.transferencias-pix-info pagamentos-lote.pix-info"  # noqa
+
     BASE_PROD_ADDITION = "-ip"
     BASE_DOMAIN = ".bb.com.br/pagamentos-lote/v1"
 
@@ -481,3 +483,78 @@ def consultar_pagamento_tributo(self, _id):
         response = self._get(url)
 
         return response
+
+    ################
+    #     PIX      #
+    ################
+
+    def _criar_dados_transferencia_pix(
+        self,
+        n_requisicao,
+        agencia,
+        conta,
+        dv_conta,
+        data_transferencia,
+        valor_transferencia,
+        chave,
+        descricao,
+        tipo_pagamento,
+    ):
+        lote_data = {
+            "numeroRequisicao": n_requisicao,
+            "agenciaDebito": agencia,
+            "contaCorrenteDebito": conta,
+            "digitoVerificadorContaCorrente": dv_conta,
+            "tipoPagamento": tipo_pagamento,
+        }
+
+        transferencia_data = {
+            "data": data_transferencia,
+            "valor": valor_transferencia,
+            "descricaoPagamento": descricao,
+            "chave": chave,
+        }
+        transferencia_data = TransferenciaPIX(**transferencia_data).dict()
+        return {**lote_data, "listaTransferencias": [transferencia_data]}
+
+    def criar_transferencia_pix(
+        self,
+        n_requisicao,
+        agencia,
+        conta,
+        dv_conta,
+        data_transferencia,
+        valor_transferencia,
+        chave,
+        descricao="",
+        tipo_pagamento=128,
+    ):
+        """
+        Efetua pagamentos em lote via tranferência PIX
+
+        Args:
+            n_requisicao: Nº da requisição a ser utilizado. Deve ser único
+            agencia: Agência da conta de origem do pagamento
+            conta: Nº da conta de origem do pagamento
+            dv_conta: DV da conta de origem do pagamento
+            tipo_pagamento: Tipo de pagamento a ser feito (126, 127 ou 128)
+            data_transferencia: Data do pagamento. No formato "ddmmyyyy"
+            valor_transferencia: Valor do pagamento
+            chave: Valor corresponde a chave que sera usada para tranferência # noqa: E501
+            descricao: Campo de uso livre pelo cliente
+        """
+        data = self._criar_dados_transferencia_pix(
+            n_requisicao,
+            agencia,
+            conta,
+            dv_conta,
+            data_transferencia,
+            valor_transferencia,
+            chave,
+            descricao,
+            tipo_pagamento,
+        )
+        url = self._construct_url("lotes-transferencias-pix")
+        response = self._post(url, data)
+
+        return response

examples/lotes_pagamento/data/transferencia_pix_chave_aleatoria.json

@@ -0,0 +1,35 @@
+{
+  "numeroRequisicao": 921347,
+  "estadoRequisicao": 1,
+  "quantidadeTransferencias": 1,
+  "valorTransferencias": 15.5,
+  "quantidadeTransferenciasValidas": 1,
+  "valorTransferenciasValidas": 15.5,
+  "listaTransferencias": [
+    {
+      "identificadorPagamento": 90921347731030000,
+      "data": 19042023,
+      "valor": 15.5,
+      "documentoDebito": 0,
+      "documentoCredito": 0,
+      "descricaoPagamento": "nova transferencia",
+      "descricaoPagamentoInstantaneo": "",
+      "formaIdentificacao": 4,
+      "dddTelefone": 0,
+      "telefone": 0,
+      "email": "",
+      "cpf": 0,
+      "cnpj": 0,
+      "identificacaoAleatoria": "d14d32de-b3b9-4c31-9f89-8df2cec92c50",
+      "numeroCOMPE": 0,
+      "numeroISPB": 0,
+      "tipoConta": 0,
+      "agencia": 0,
+      "conta": 0,
+      "digitoVerificadorConta": "",
+      "contaPagamento": "",
+      "indicadorMovimentoAceito": "S",
+      "erros": []
+    }
+  ]
+}

examples/lotes_pagamento/data/transferencia_pix_cpf.json

@@ -0,0 +1,35 @@
+{
+  "numeroRequisicao": 9221347,
+  "estadoRequisicao": 1,
+  "quantidadeTransferencias": 1,
+  "valorTransferencias": 7999.99,
+  "quantidadeTransferenciasValidas": 1,
+  "valorTransferenciasValidas": 7999.99,
+  "listaTransferencias": [
+    {
+      "identificadorPagamento": 99221347731030000,
+      "data": 20042023,
+      "valor": 7999.99,
+      "documentoDebito": 0,
+      "documentoCredito": 0,
+      "descricaoPagamento": "transferencia CPF",
+      "descricaoPagamentoInstantaneo": "",
+      "formaIdentificacao": 3,
+      "dddTelefone": 0,
+      "telefone": 0,
+      "email": "",
+      "cpf": 28779295827,
+      "cnpj": 0,
+      "identificacaoAleatoria": "",
+      "numeroCOMPE": 0,
+      "numeroISPB": 0,
+      "tipoConta": 0,
+      "agencia": 0,
+      "conta": 0,
+      "digitoVerificadorConta": "",
+      "contaPagamento": "",
+      "indicadorMovimentoAceito": "S",
+      "erros": []
+    }
+  ]
+}

examples/lotes_pagamento/transferencia_pix_chave_aleatoria.py

@@ -0,0 +1,31 @@
+import os
+from datetime import date
+
+from examples.utils import dump_response
+
+from bb_wrapper.wrapper import PagamentoLoteBBWrapper
+
+c = PagamentoLoteBBWrapper(cert=("./certs/cert.pem", "./certs/key.pem"))
+
+
+today = date.today()
+bb_fmt = "%d%m%Y"
+
+
+lote_data = {
+    "n_requisicao": 921347,
+    "agencia": 1607,
+    "conta": 99738672,
+    "dv_conta": "X",
+}
+
+transferencia_data = {
+    "descricao": "nova transferencia",
+    "data_transferencia": today.strftime(bb_fmt),
+    "valor_transferencia": 15.50,
+    "forma_id": 4,
+    "chave_aleatoria": "d14d32de-b3b9-4c31-9f89-8df2cec92c50",
+}
+
+response = c.criar_transferencia_pix(**lote_data, **transferencia_data)
+dump_response(response, os.path.realpath(__file__))

examples/lotes_pagamento/transferencia_pix_cpf.py

@@ -0,0 +1,30 @@
+import os
+from datetime import date
+
+from examples.utils import dump_response
+
+from bb_wrapper.wrapper import PagamentoLoteBBWrapper
+
+c = PagamentoLoteBBWrapper(cert=("./certs/cert.pem", "./certs/key.pem"))
+
+
+today = date.today()
+bb_fmt = "%d%m%Y"
+
+
+lote_data = {
+    "n_requisicao": 9222347,
+    "agencia": 1607,
+    "conta": 99738672,
+    "dv_conta": "X",
+}
+
+transferencia_data = {
+    "descricao": "transferencia CPF",
+    "data_transferencia": today.strftime(bb_fmt),
+    "valor_transferencia": 7999.99,
+    "chave": "28779295827",
+}
+
+response = c.criar_transferencia_pix(**lote_data, **transferencia_data)
+dump_response(response, os.path.realpath(__file__))