Atualizações dos registros do SPED EFD Contribuições e ICMS_IPI.

requeriments.txt

@@ -1,3 +1,4 @@
 coveralls==0.5
 six==1.9.0
 pytest==2.6.4
+cchardet==2.1.5

setup.py

@@ -50,7 +50,7 @@ def run_tests(self):
         'Programming Language :: Python :: 3.6',
     ],
     keywords='sped fiscal contábil contabilidade receita federal',
-    install_requires=['six'],
+    install_requires=['six','cchardet'],
     tests_require=['pytest'],
     extras_require={
         'dev': ['pylint>=1.9.1'],

sped/__init__.py

@@ -7,4 +7,4 @@
 from .escrituracao import Escrituracao
 
 
-__version__ = '1.0.2'
+__version__ = '1.0.3'

sped/arquivos.py

@@ -1,12 +1,11 @@
 # -*- coding: utf-8 -*-
 
-
+import re
 from collections import OrderedDict
 from io import StringIO
 
 from .registros import RegistroIndefinido
 
-
 class ArquivoDigital(object):
     registros = None
     blocos = None
@@ -19,31 +18,55 @@ def __init__(self):
         self._registro_encerramento = self.registro_encerramento()
         self._blocos = OrderedDict()
 
-    def readfile(self, filename):
-        with open(filename) as spedfile:
-            for line in [line.rstrip('\r\n') for line in spedfile]:
-                self.read_registro(line.decode('utf8'))
+    def readfile(self, filename, codificacao='utf-8', verbose=None):
+        sucesso = False
+        with open(filename, 'r', encoding=codificacao) as spedfile: # encoding='utf-8', 'latin-1'
+            for line in [line.strip() for line in spedfile]:
+                # a simple way to remove multiple spaces in a string
+                line = re.sub('\s{2,}', ' ', line)
+                # Em algumas EFDs foram encontrados registros digitados incorretamente em minúsculo.
+                # Por exemplo, o registro 'c491' deve ser corrigido para 'C491'.
+                line = line[:6].upper() + line[6:] # line = '|c491|...' --> '|C491|...'
+                regt = self.read_registro(line)
+                # Verificar se foi lido o arquivo SPED até a última linha válida que contém o registro '9999'.
+                if regt.__class__ == self.__class__.registro_encerramento:
+                    sucesso = True
+                    break
+        if not sucesso:
+            raise RuntimeError(u"\nOcorreu uma falha ao ler o arquivo: '%s'.\n" % filename)
+        elif verbose:
+            print(u"O arquivo SPED '%s' foi lido com sucesso.\n" % filename)
 
     def read_registro(self, line):
         reg_id = line.split('|')[1]
-
+        
         try:
-            registro_class = getattr(self.__class__.registros,
-                                     'Registro' + reg_id)
+            registro_class = getattr(self.__class__.registros, 'Registro' + reg_id)
         except AttributeError:
-            raise RuntimeError(u"Arquivo inválido para EFD - PIS/COFINS")
+            raise RuntimeError(u"Arquivo inválido para EFD - PIS/COFINS. Registro: %s" % reg_id)
 
         registro = registro_class(line)
+        bloco_id = reg_id[0]
+        bloco = self._blocos[bloco_id]
 
         if registro.__class__ == self.__class__.registro_abertura:
+			# Atualizar o registro de abertura 0000
             self._registro_abertura = registro
         elif registro.__class__ == self.__class__.registro_encerramento:
+			# Atualizar o registro de encerramento 9999
             self._registro_encerramento = registro
+        elif registro.__class__ == bloco.registro_abertura.__class__:
+			# Atualizar os registros de abertura: 0001, A001, C001, ...
+            bloco.registro_abertura = registro           
+        elif registro.__class__ == bloco.registro_encerramento.__class__:
+			# Atualizar os registros de encerramento: 0990, A990, C990, ...
+            bloco.registro_encerramento = registro
         else:
-            bloco_id = reg_id[0]
-            bloco = self._blocos[bloco_id]
+			# Adicionar novos registros a cada linha obtida de filename
             bloco.add(registro)
 
+        return registro
+
     def write_to(self, buff):
         buff.write(self._registro_abertura.as_line() + u'\r\n')
         reg_count = 2

sped/blocos.py

@@ -2,7 +2,6 @@
 
 from .registros import Registro
 
-
 class Bloco(object):
     def __init__(self, nome=''):
         self._nome = nome
@@ -14,20 +13,15 @@ def __repr__(self):
 
     @property
     def abertura(self):
-        # Define o indicador de movimento ou dados
         return self.registro_abertura
 
     @property
     def encerramento(self):
-        # Define a quantidade de registros
         return self.registro_encerramento
 
     @property
     def registros(self):
         return [self.abertura] + self._registros + [self.encerramento]
 
     def add(self, registro):
-        # Não adiciona o registro de abertura e fechamento
-        if not registro.__class__ == self.registro_abertura.__class__ and \
-           not registro.__class__ == self.registro_encerramento.__class__:
-            self._registros.append(registro)
+        self._registros.append(registro)

sped/campos.py

@@ -1,6 +1,5 @@
 # -*- coding: utf-8 -*-
 
-
 import re
 
 from datetime import date
@@ -188,6 +187,8 @@ def get(self, registro):
         return datetime.strptime(valor, '%d%m%Y').date()
 
     def set(self, registro, valor):
+        # https://stackoverflow.com/questions/19887353/attributeerror-str-object-has-no-attribute-strftime
+        valor = datetime.strptime(valor, '%d%m%Y')
         if isinstance(valor, date):
             super().set(registro, valor.strftime('%d%m%Y'))
         elif not valor:
@@ -275,3 +276,33 @@ def validar(valor):
         if len(valor) == 11:
             return CampoCPF.validar(valor)
         return False
+
+
+# Fonte: 'NFe Manual_de_Orientacao_Contribuinte_v_6.00.pdf', pg 144.
+# 5.4 Cálculo do Dígito Verificador da Chave de Acesso da NF-e
+class CampoChaveEletronica(Campo):
+    @staticmethod
+    def validar(valor):
+        if not re.search('^\d{44}$', str(valor)):
+            return False
+
+        chave = [int(digito) for digito in valor]
+        multiplicadores = [4, 3, 2] + [9, 8, 7, 6, 5, 4, 3, 2] * 5 + [0]
+
+        soma = sum([chave[i] * multiplicadores[i] for i in range(44)])
+
+        resto_da_divisao = soma % 11
+        digito_verificador = 11 - resto_da_divisao
+
+        if digito_verificador >= 10:
+            digito_verificador = 0
+
+        if chave[-1] != digito_verificador:
+            return False
+
+        # dentro da chave eletrônica há o CNPJ do emitente
+        # que também será verificado
+        cnpj = str(valor)[6:20]
+
+        return CampoCNPJ.validar(cnpj)
+