ScarFec3.py

## Licenza Libera progetto originario di Claudio Pizzillo
## Modifiche e riadattamenti da Salvatore Crapanzano
## 01/08/23 Altre modifiche da Uzirox## 
## V. 3.5.2 del 21-01-2024  - Intermediari e Diretto e Studio Associato
## 

import subprocess
import requests
from requests.packages.urllib3.exceptions import InsecureRequestWarning
requests.packages.urllib3.disable_warnings(InsecureRequestWarning)
import re
import time
from datetime import timedelta, datetime, tzinfo, timezone
import sys
import pytz
import json
import os
import shutil
from clint.textui import colored, puts
from tqdm import *

# funzizone di decodifica file P7m
def decrypt_p7m_files(input_dir, output_dir):
    """
    Decripta i file .p7m nella directory specificata e salva i file decriptati
    nella directory di output specificata.

    Args:
    input_dir (str): La directory contenente i file .p7m da decriptare.
    output_dir (str): La directory dove verranno salvati i file decriptati.
    """
    # Verifica se la directory di input esiste e se è una directory
    if not os.path.exists(input_dir) or not os.path.isdir(input_dir):
        print(f"La directory di input {input_dir} non esiste o non è una directory.")
        return

    # Crea la directory di output se non esiste
    if not os.path.exists(output_dir):
        os.makedirs(output_dir)

    # Controlla se ci sono file nella directory di input
    if not os.listdir(input_dir):
        print(f"Nessun file trovato in {input_dir}.")
        return

    # Itera sui file nella directory di input
    for filename in os.listdir(input_dir):
        if filename.endswith(".p7m"):
            file_path_p7m = os.path.join(input_dir, filename)
            split_filename = filename.split(sep=".")
            file_name_decrypted = f"{output_dir}/{split_filename[0]}.{split_filename[1]}"

            # Costruisce il comando per la decriptazione
            command = (f"openssl cms -decrypt -verify -inform DER -in \"{file_path_p7m}\" -noverify -out \"{file_name_decrypted}\"")
            print(command)
            try:
                # Esegue il comando
                subprocess.run(command, shell=True, check=True)
                print(f"Decriptazione e verifica di {filename} completate con successo.")
            except subprocess.CalledProcessError as e:
                print(f"Si è verificato un errore durante l'esecuzione del comando per {filename}.")
                print("Errore:", e)
        if filename.endswith(".xml") and not filename.endswith("_metadato.xml"):
            file_path = os.path.join(input_dir, filename)
            shutil.copy(file_path, output_dir)
# Esempio di utilizzo: funzione
# decrypt_p7m_files('/percorso/alla/directory/input', '/percorso/alla/directory/output')


    
def unixTime():
    dt = datetime.now(tz=pytz.utc)
    return str(int(dt.timestamp() * 1000))
try:
    if len(sys.argv) < 10:
        print('Utilizzo: fec.py(fec.exe) CodiceFiscale/CodiceEntratel PIN Password PartitaIVA DataDal DataAl FOL/ENT')
        print('Esempio: TXXXXXX PIN PASSWORD COD_FISCALE 01012023 31032023 CF_CLIENTE PIVA_CLIENTE {1/2} [A-V-T')
        sys.exit()

    profilo = 1 # Impostare il profilo Delega diretta codice 1, Me stesso 2, Studio Associato Default
    CF = sys.argv[1]
    PIN = sys.argv[2]
    Password  = sys.argv[3]
    cfstudio  = sys.argv[4]
    Dal = sys.argv[5]
    Al = sys.argv[6]
    cfcliente = sys.argv[7]
    pivadiretta = sys.argv[8]
    tipo = int(sys.argv[9]) # 1 per data di ricezione 2 (QUALSIASI VALORE DIVERSA DA 1) per data di emissione
    VenOAcq = sys.argv[10]  # "v" per sole vendite, "a" per soli acquisti, ALTRIMENTI T per tutti e due

    s = requests.Session()
    s.headers.update({'User-Agent': 'Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/72.0.3626.119 Safari/537.36'})
    s.headers.update({'Connection': 'keep-alive'})

    cookie_obj1 = requests.cookies.create_cookie(domain='ivaservizi.agenziaentrate.gov.it',name='LFR_SESSION_STATE_20159',value='expired')
    s.cookies.set_cookie(cookie_obj1)
    cookie_obj2 = requests.cookies.create_cookie(domain='ivaservizi.agenziaentrate.gov.it',name='LFR_SESSION_STATE_10811916',value=unixTime())
    s.cookies.set_cookie(cookie_obj2)
    r = s.get('https://ivaservizi.agenziaentrate.gov.it/portale/web/guest', verify=False)

    if r.status_code == 200:
        puts(colored.yellow('Collegamento alla homepage. Avvio.'))
    else:
        puts(colored.red('Collegamento alla homepage non riuscito: uscita.'))
        sys.exit()
    cookieJar = s.cookies

    print('Effettuo il login')
    payload = {'_58_saveLastPath': 'false', '_58_redirect' : '', '_58_doActionAfterLogin': 'false', '_58_login': CF , '_58_pin': PIN, '_58_password': Password}    
    r = s.post('https://ivaservizi.agenziaentrate.gov.it/portale/home?p_p_id=58&p_p_lifecycle=1&p_p_state=normal&p_p_mode=view&p_p_col_id=column-1&p_p_col_pos=3&p_p_col_count=4&_58_struts_action=%2Flogin%2Flogin', data=payload)
    cookieJar = s.cookies

    liferay = re.findall(r"Liferay.authToken = '.*';", r.text)[0]
    p_auth = liferay.replace("Liferay.authToken = '","")
    p_auth = p_auth.replace("';", "")

    r = s.get('https://ivaservizi.agenziaentrate.gov.it/dp/api?v=' + unixTime())
# controlla fase di login 
    if r.status_code == 200:
        puts(colored.yellow('Login riuscito. Con credenzilali ENTRATEL'))
    else:
        puts(colored.red('Login non riuscito: uscita.')) 
        sys.exit()

    
    cookieJar = s.cookies

    print('Seleziono il tipo di incarico')
    if profilo == 1:
    # Delega Diretta
                payload = {'cf_inserito': cfcliente};
                r = s.post('https://ivaservizi.agenziaentrate.gov.it/portale/scelta-utenza-lavoro?p_auth='+ p_auth + '&p_p_id=SceltaUtenzaLavoro_WAR_SceltaUtenzaLavoroportlet&p_p_lifecycle=1&p_p_state=normal&p_p_mode=view&p_p_col_id=column-1&p_p_col_count=1&_SceltaUtenzaLavoro_WAR_SceltaUtenzaLavoroportlet_javax.portlet.action=delegaDirettaAction', data=payload);
                payload = {'cf_inserito': cfcliente, 'sceltapiva' : pivadiretta};    
                r = s.post('https://ivaservizi.agenziaentrate.gov.it/portale/scelta-utenza-lavoro?p_auth='+ p_auth + '&p_p_id=SceltaUtenzaLavoro_WAR_SceltaUtenzaLavoroportlet&p_p_lifecycle=1&p_p_state=normal&p_p_mode=view&p_p_col_id=column-1&p_p_col_count=1&_SceltaUtenzaLavoro_WAR_SceltaUtenzaLavoroportlet_javax.portlet.action=delegaDirettaAction', data=payload);
    # Me stesso
    elif profilo == 2:
                payload = {'sceltaincarico': cfstudio + '-000', 'tipoincaricante' : 'incDiretto'};
                r = s.post('https://ivaservizi.agenziaentrate.gov.it/portale/scelta-utenza-lavoro?p_auth='+ p_auth + '&p_p_id=SceltaUtenzaLavoro_WAR_SceltaUtenzaLavoroportlet&p_p_lifecycle=1&p_p_state=normal&p_p_mode=view&p_p_col_id=column-1&p_p_col_count=1&_SceltaUtenzaLavoro_WAR_SceltaUtenzaLavoroportlet_javax.portlet.action=meStessoAction', data=payload)
                payload = {'sceltaincarico': cfstudio + '-000', 'tipoincaricante' : 'incDiretto', 'sceltapiva' : pivadiretta};    
                r = s.post('https://ivaservizi.agenziaentrate.gov.it/portale/scelta-utenza-lavoro?p_auth='+ p_auth + '&p_p_id=SceltaUtenzaLavoro_WAR_SceltaUtenzaLavoroportlet&p_p_lifecycle=1&p_p_state=normal&p_p_mode=view&p_p_col_id=column-1&p_p_col_count=1&_SceltaUtenzaLavoro_WAR_SceltaUtenzaLavoroportlet_javax.portlet.action=meStessoAction', data=payload);
    # Login per STUDIO ASSOCIATO
    else:
                payload = {'sceltaincarico': cfstudio + '-000', 'tipoincaricante' : 'incDelega', 'cf_inserito': cfcliente};
                r = s.post('https://ivaservizi.agenziaentrate.gov.it/portale/scelta-utenza-lavoro?p_auth='+ p_auth + '&p_p_id=SceltaUtenzaLavoro_WAR_SceltaUtenzaLavoroportlet&p_p_lifecycle=1&p_p_state=normal&p_p_mode=view&p_p_col_id=column-1&p_p_col_count=1&_SceltaUtenzaLavoro_WAR_SceltaUtenzaLavoroportlet_javax.portlet.action=incarichiAction', data=payload);
                payload = {'sceltaincarico': cfstudio + '-000', 'tipoincaricante' : 'incDelega', 'cf_inserito': cfcliente, 'sceltapiva' : pivadiretta};
                r = s.post('https://ivaservizi.agenziaentrate.gov.it/portale/scelta-utenza-lavoro?p_auth='+ p_auth + '&p_p_id=SceltaUtenzaLavoro_WAR_SceltaUtenzaLavoroportlet&p_p_lifecycle=1&p_p_state=normal&p_p_mode=view&p_p_col_id=column-1&p_p_col_count=1&_SceltaUtenzaLavoro_WAR_SceltaUtenzaLavoroportlet_javax.portlet.action=incarichiAction', data=payload);

    print('Aderisco al servizio')
    r = s.get('https://ivaservizi.agenziaentrate.gov.it/ser/api/fatture/v1/ul/me/adesione/stato/')
# ADERISCO AL SERVIZIO - NA CAMURRIA!
    if r.status_code == 200:
        puts(colored.yellow('Adesione riuscita ai servizi AdE.'))
    else:
        puts(colored.red('Adesione ai servizi AdE non riuscita: uscita.')) 
        sys.exit()
    
    cookieJar = s.cookies 

    headers_token = {'x-xss-protection': '1; mode=block',
               'strict-transport-security': 'max-age=16070400; includeSubDomains',
               'x-content-type-options': 'nosniff',
               'x-frame-options': 'deny'}
    r = s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/sc/tokenB2BCookie/get?v='+unixTime() , headers = headers_token )
    if r.status_code == 200:
        puts(colored.yellow('B2B Cookie ottenuto'))
    else:
        puts(colored.red('B2B Cookie non ottenuto: uscita.')) 
        sys.exit()
    cookieJar = s.cookies
    tokens = r.headers

    xb2bcookie = r.headers.get('x-b2bcookie')
    xtoken = r.headers.get('x-token')

    s.headers.update({'Host': 'ivaservizi.agenziaentrate.gov.it'})
    s.headers.update({'Referer': 'https://ivaservizi.agenziaentrate.gov.it/cons/cons-web/?v=' + unixTime()})
    s.headers.update({'Accept': 'application/json, text/plain, */*'})
    s.headers.update({'Accept-Encoding': 'gzip, deflate, br'})
    s.headers.update({'Accept-Language': 'it-IT,it;q=0.9,en-US;q=0.8,en;q=0.7,fr;q=0.6'})
    s.headers.update({'DNT': '1'})
    s.headers.update({'X-XSS-Protection': '1; mode=block'})
    s.headers.update({'Strict-Transport-Security': 'max-age=16070400; includeSubDomains'})
    s.headers.update({'X-Content-Type-Options': 'nosniff'})
    s.headers.update({'X-Frame-Options': 'deny'})
    s.headers.update({'x-b2bcookie': xb2bcookie})
    s.headers.update({'x-token': xtoken})

    headers = {'Host': 'ivaservizi.agenziaentrate.gov.it',
               'referer': 'https://ivaservizi.agenziaentrate.gov.it/cons/cons-web/?v=' + unixTime(),
               'accept': 'application/json, text/plain, */*',
               'accept-encoding': 'gzip, deflate, br',
               'accept-language': 'it-IT,it;q=0.9,en-US;q=0.8,en;q=0.7,fr;q=0.6',
               'DNT': '1',
               'x-xss-protection': '1; mode=block',
               'strict-transport-security': 'max-age=16070400; includeSubDomains',
               'x-content-type-options': 'nosniff',
               'x-frame-options': 'deny',
               'x-b2bcookie': xb2bcookie,
               'x-token': xtoken,
               'User-Agent': 'Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/72.0.3626.119 Safari/537.36'}
    print('Accetto le condizioni')
    r = s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/disclaimer/accetta?v='+unixTime() , headers = headers_token )
    cookieJar = s.cookies


    if VenOAcq != "V":
        #===============================================================================================
        # FATTURE MESSE A DISPOSIZIONE
        #===============================================================================================
        print('Scarico il json delle fatture ricevute e messe a disposizione per la partita IVA ' + cfcliente)
        r = s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/fe/mc/dal/'+Dal+'/al/'+Al+'?v=' + unixTime(), headers = headers)
        if r.status_code == 200:
            puts(colored.yellow('Lista ottenuta FATTURE A DISPOSIZIONE. Potrebbe essere vuota!'))
        else:
            puts(colored.red('Lista FATTURE A DISPOSIZIONE non ottenuta: uscita.')) 
            sys.exit()


        with open('fe_ricevute_disposizione_' + cfcliente + '.json', 'wb') as f:
            f.write(r.content)
            print('Inizio a scaricare le fatture ricevute e messe a disposizione!')
        path = r'FatturePassive_' + cfcliente
        if not os.path.exists(path):
            os.makedirs(path)
        with open('fe_ricevute_disposizione_'+ cfcliente +'.json') as data_file:    
            data = json.load(data_file)
            #print('Inizio a scaricare ' + str(data['totaleFatture']) + ' fatture dal ' + data['dataRicercaDa'] + ' al ' + data['dataRicercaA'] + ' per un massimo di ' + str(data['limiteBloccoTotaleFatture']) + ' fatture scaricabili.')#
            numero_fatture_disposizione = 0
            numero_notifiche_disposizione = 0
            for fattura in data['fatture']:
                fatturaFile = fattura['tipoInvio']+fattura['idFattura']
                r = s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/fatture/file/'+fatturaFile+'?tipoFile=FILE_FATTURA&download=1&v='+unixTime() , headers = headers_token )
                if r.status_code == 200:
                    numero_fatture = numero_fatture + 1
                    d = r.headers['content-disposition']
                    fname = re.findall("filename=(.+)", d)
                    print('Downloading ' + fname[0])
                    print('Totale fatture messe a disposizione scaricate: ', numero_fatture_disposizione)
                    with open(path + '/' + fname[0], 'wb') as f:
                        f.write(r.content)              
        print('Totale fatture messe a disposizione scaricate: ', numero_fatture_disposizione)




        #===============================================================================================
        # FATTURE PASSIVE RICEVUTE
        #===============================================================================================
        if tipo == 1:
        # r = s.get('https://ivaservizi.agenziaentrate.gov.it/ser/api/monitoraggio/v1/monitoraggio/fatture/?v='+unixTime()+'&idFiscCedente=&idFiscDestinatario=&idFiscEmittente=&idFiscTrasmittente=&idSdi=&perPage=10&start=1&statoFile=&tipoFattura=EMESSA')
             print('Scarico il json delle fatture ricevute per data ricezione per la partita IVA ' + cfcliente)
             r = s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/fe/ricevute/dal/'+Dal+'/al/'+Al+'/ricerca/ricezione?v=' + unixTime(), headers = headers)
        else:     
             print('Scarico il json delle fatture ricevute per data di emissione per la partita IVA ' + cfcliente)
             r = s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/fe/ricevute/dal/'+Dal+'/al/'+Al+'/ricerca/emissione?v=' + unixTime(), headers = headers)

        with open('fe_ricevute_'+ cfcliente +'.json', 'wb') as f:
            f.write(r.content)
            
        print('Inizio a scaricare le fatture PASSIVE ricevute')
        path = r'FatturePassive_' + cfcliente
        pathp7m = path + '_p7m'
        if not os.path.exists(path):
            os.makedirs(path)
        if not os.path.exists(path):
            os.makedirs(pathp7m)

        with open('fe_ricevute_'+ cfcliente +'.json') as data_file:    
            data = json.load(data_file)
            numero_fatture_ricevute = 0
            numero_notifiche_ricevute = 0
            print('Inizio a scaricare ' + str(data['totaleFatture']) + ' fatture PASSIVE ricevute dal ' + data['dataRicercaDa'] + ' al ' + data['dataRicercaA'] + ' per un massimo di ' + str(data['limiteBloccoTotaleFatture']) + ' fatture scaricabili.')
            for fattura in data['fatture']:
                fatturaFile = fattura['tipoInvio']+fattura['idFattura']
                with s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/fatture/file/'+fatturaFile+'?tipoFile=FILE_FATTURA&download=1&v='+unixTime(), headers = headers_token , stream = True) as r:
                    if r.status_code == 200:
                        numero_fatture_ricevute = numero_fatture_ricevute + 1
                        r.raise_for_status()
                        total_size = int(r.headers.get('content-length', 0))
                        d = r.headers['content-disposition']
                        fname = re.findall("filename=(.+)", d)
                        with open(path + '/' + fname[0], 'wb') as f:
                            f.write(r.content)
                            fmetadato = re.findall("filename=(.+)", d)
                            with open(path + '/' + fname[0], 'wb') as f:
                                pbar = tqdm(total=total_size, unit='B', unit_divisor=1024, unit_scale=True, ascii=True)
                                pbar.set_description('Scarico la fattura: ' + fname[0])
                                for chunk in r.iter_content(chunk_size=1024):
                                    if chunk:  
                                        f.write(chunk)
                                        pbar.update(len(chunk))
                                pbar.close()
                with s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/fatture/file/'+fatturaFile+'?tipoFile=FILE_METADATI&download=1&v='+unixTime(), headers = headers_token , stream = True) as r:
                    if r.status_code == 200:
                        numero_notifiche_ricevute = numero_notifiche_ricevute + 1
                        r.raise_for_status()
                        total_size = int(r.headers.get('content-length', 0))
                        d = r.headers['content-disposition'] # viene commentato per evitare di duplicare file metadato, nome originale
                        fname = re.findall("filename=(.+)", d)
                        print('Downloading metadati nome originale = ' + fname[0])
                        print('Downloading metadati rinominato col nome fattura = ' + fmetadato[0] + '_metadato.xml')
                        print('Totale notifiche scaricate: ', numero_notifiche_ricevute)
                        with open(path + '/' + fmetadato[0] + '_metadato.xml', 'wb') as f:
                            f.write(r.content)                
                            with open(path + '/' + fname[0], 'wb') as f:
                                pbar = tqdm(total=total_size, unit='B', unit_divisor=1024, unit_scale=True, ascii=True)
                                pbar.set_description('Sto scaricando ->' + fname[0])
                                for chunk in r.iter_content(chunk_size=1024):
                                    if chunk:  
                                        f.write(chunk)
                                        pbar.update(len(chunk))
                                pbar.close()                
            decrypt_p7m_files(path, pathp7m)# decodifica fattura p7m e copia in dir p7m
            print('Totale fatture PASSIVE RICEVUTE scaricate: ', numero_fatture_ricevute , ' e notifiche ' , numero_notifiche_ricevute)


    #=============# FATTURE TRANSFRONTALIERE RICEVUTE=======#
        print('Scarico il json delle fatture  Transfrontaliere Ricevute per la Partita IVA ' + cfcliente)
        r = s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/ft/ricevute/dal/'+Dal+'/al/'+Al+'?v=' + unixTime(), headers = headers)

        with open('fe_ricevutetr_'+ cfcliente +'.json', 'wb') as f:
            f.write(r.content)
            
        print('Inizio a scaricare le fatture transfrontaliere ricevute')
        path = r'FatturePassive_' + cfcliente
        if not os.path.exists(path):
            os.makedirs(path)
        with open('fe_ricevutetr_'+ cfcliente +'.json') as data_file:    
            data = json.load(data_file)
            numero_fatture = 0
            numero_notifiche = 0
            for fattura in data['fatture']:
                fatturaFile = fattura['tipoInvio']+fattura['idFattura']
                r = s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/fatture/file/'+fatturaFile+'?tipoFile=FILE_FATTURA&download=1&v='+unixTime() , headers = headers_token )
                if r.status_code == 200:
                    numero_fatture = numero_fatture + 1
                    d = r.headers['content-disposition']
                    fname = re.findall("filename=(.+)", d)
                    print('Downloading ' + fname[0])
                    print('Totale Transfrontaliere fatture scaricate: ', numero_fatture)
                    with open(path + '/' + fname[0], 'wb') as f:
                        f.write(r.content)
                        fmetadato = re.findall("filename=(.+)", d)
                r = s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/fatture/file/'+fatturaFile+'?tipoFile=FILE_METADATI&download=1&v='+unixTime() , headers = headers_token )
                if r.status_code == 200:
                    numero_notifiche = numero_notifiche + 1
                    # d = r.headers['content-disposition']
                    fname = re.findall("filename=(.+)", d)
                    print('Downloading metadati = ' + fname[0])
                    print('Downloading metadati rinominato = ' + fmetadato[0] + '_metadato.xml')
                    print('Totale notifiche scaricate: ', numero_notifiche)
                    with open(path + '/' + fmetadato[0] + '_metadato.xml', 'wb') as f:
                        f.write(r.content)                
        print('Totale fatture Ricevute TRAN ricevute scaricate: ', numero_fatture)
        print('Totale notifiche scaricate fatture TRAN ricevute: ', numero_notifiche)

        print('Per il cliente: ', cfcliente)
        print('Totale fatture TRANSFRONTALIERE RICEVUTE scaricate: ', numero_fatture)


    if VenOAcq != "A":
    #========================================================================================
    # FATTURE EMESSE
    #========================================================================================
        print('Scarico il json delle fatture Emesse per la Partita IVA ' + cfcliente)
        r = s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/fe/emesse/dal/'+Dal+'/al/'+Al+'?v=' + unixTime(), headers = headers)

        with open('fe_emesse_'+ cfcliente +'.json', 'wb') as f:
            f.write(r.content)
            
        print('Inizio a scaricare le fatture emesse')
        path = r'FattureEmesse_' + cfcliente
        # DA QUI
        with open('fe_emesse_'+ cfcliente +'.json') as data_file:    
            data = json.load(data_file)
            numero_fatture = 0
            numero_notifiche = 0
            for fattura in data['fatture']:
                fatturaFile = fattura['tipoInvio']+fattura['idFattura']
                idInviofile = fattura['fileDownload']['idInvio']
                datafatturajson = fattura['dataFattura']
                datafatturaAAAAMMDD = datetime.strptime(datafatturajson, "%Y-%m-%d")
                strdatafatturaGGMMAAAA = datetime.strftime(datafatturaAAAAMMDD, "%m/%d/%Y")
                filejsonindinvio = 'fatturaID'+idInviofile+'.json'
                r = s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/fatture/file/'+fatturaFile+'?tipoFile=FILE_FATTURA&download=1&v='+unixTime() , headers = headers_token )
                if r.status_code == 200:
                    numero_fatture = numero_fatture + 1
                    d = r.headers['content-disposition']
                    fname = re.findall("filename=(.+)", d)
                    print('Downloading ' + fname[0])
                    print('Totale fatture scaricate: ', numero_fatture)
                    pathsub = r'FattureEmesse_' + cfcliente + '_' + str(numero_fatture)
                    if not os.path.exists(path):
                         os.makedirs(path)
                    with open(path + '/' + fname[0], 'wb') as f:
                        f.write(r.content)
                        fmetadato = re.findall("filename=(.+)", d)
                        r = s.get('https://ivaservizi.agenziaentrate.gov.it/ser/api/monitoraggio/v1/monitoraggio/fatture/dettaglio/?v='+unixTime()+'&idSdi='+idInviofile+'&operatore=e', headers = headers_token )
                # filejsonindinvio = json.dumps(dict(requests.get('https://ivaservizi.agenziaentrate.gov.it/ser/api/monitoraggio/v1/monitoraggio/fatture/dettaglio/?v='+unixTime()+'&idSdi='+idInviofile+'&operatore=e').headers_token))
                if r.status_code == 200:
                    filejsonindinvio = 'fatturaID'+idInviofile+'.json'
                with open(filejsonindinvio, 'wb') as fj:
                    fj.write(r.content)
                    print('Scarico file json della fattura emessa: '+'fatturaID'+idInviofile+'.json')
                with open(filejsonindinvio) as dati:
                    print(dati)
                    datajson = json.load(dati)
                    if datajson['elencoNotifiche'] == []:
                        print('No Data!')
                    else:
                        for idSDIelenco in datajson['elencoNotifiche'] :
                            print('ID Invio:' + str(idSDIelenco['id']))
                            print('nome:' + str(idSDIelenco['nome']))
                            print('Data UNIX' + str(idSDIelenco['dataConsegna']))
                        for idSDIelenco in datajson['elencoNotifiche']:
                            tipettofile = str(idSDIelenco['nome'])
                            if tipettofile == "File dei metadati":
                                 print("No Data!")
                            else:
                                idSDIinvio = idSDIelenco['id']
                                stridSDIinvio = str(idSDIinvio)
                                r = s.get('https://ivaservizi.agenziaentrate.gov.it/ser/api/monitoraggio/v1/monitoraggio/fatture/notifiche/'+stridSDIinvio+'/download/' , headers = headers_token)
                                if r.status_code == 200:
                                     d = r.headers['content-disposition']
                                     fname = re.findall("filename=(.+)", d)
                                     with open(path + '/' + fname[0], 'wb') as f:
                                         f.write(r.content)

        # FINO A QUI
        if not os.path.exists(path):
            os.makedirs(path)
        with open('fe_emesse_'+ cfcliente +'.json') as data_file:    
            data = json.load(data_file)
            numero_fatture = 0
            numero_notifiche = 0
            for fattura in data['fatture']:
                fatturaFile = fattura['tipoInvio']+fattura['idFattura']
                r = s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/fatture/file/'+fatturaFile+'?tipoFile=FILE_FATTURA&download=1&v='+unixTime() , headers = headers_token )
                if r.status_code == 200:
                    numero_fatture = numero_fatture + 1
                    d = r.headers['content-disposition']
                    fname = re.findall("filename=(.+)", d)
                    print('Downloading ' + fname[0])
                    print('Totale fatture EMESSE scaricate: ', numero_fatture)
                    with open(path + '/' + fname[0], 'wb') as f:
                        f.write(r.content)             
        print('Per il cliente: ', cfcliente)
        print('Totale fatture EMESSE scaricate: ', numero_fatture)


    #========================================================================================
    # FATTURE TRANSFRONTALIERE EMESSE
    #========================================================================================
        print('Scarico il json delle fatture  Transfrontaliere Emesse per la Partita IVA ' + cfcliente)
        r = s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/ft/emesse/dal/'+Dal+'/al/'+Al+'?v=' + unixTime(), headers = headers)

        with open('fe_emessetr_'+ cfcliente +'.json', 'wb') as f:
            f.write(r.content)
            
        print('Inizio a scaricare le fatture transfrontaliere emesse')
        path = r'FattureEmesse_' + cfcliente
        if not os.path.exists(path):
            os.makedirs(path)
# DA QUI 
        with open('fe_emessetr_'+ cfcliente +'.json') as data_file:    
            data = json.load(data_file)
            numero_fatture = 0
            numero_notifiche = 0
            for fattura in data['fatture']:
                fatturaFile = fattura['tipoInvio']+fattura['idFattura']
                idInviofile = fattura['fileDownload']['idInvio']
                datafatturajson = fattura['dataFattura']
                datafatturaAAAAMMDD = datetime.strptime(datafatturajson, "%Y-%m-%d")
                strdatafatturaGGMMAAAA = datetime.strftime(datafatturaAAAAMMDD, "%m/%d/%Y")
                filejsonindinvio = 'fatturaID'+idInviofile+'.json'
                r = s.get('https://ivaservizi.agenziaentrate.gov.it/cons/cons-services/rs/fatture/file/'+fatturaFile+'?tipoFile=FILE_FATTURA&download=1&v='+unixTime() , headers = headers_token )
                if r.status_code == 200:
                    numero_fatture = numero_fatture + 1
                    d = r.headers['content-disposition']
                    fname = re.findall("filename=(.+)", d)
                    print('Downloading ' + fname[0])
                    print('Totale fatture scaricate: ', numero_fatture)
                    pathsub = r'FattureEmesse_' + cfcliente + '_' + str(numero_fatture)
                    if not os.path.exists(path):
                         os.makedirs(path)
                    with open(path + '/' + fname[0], 'wb') as f:
                        f.write(r.content)
                        fmetadato = re.findall("filename=(.+)", d)
                        r = s.get('https://ivaservizi.agenziaentrate.gov.it/ser/api/monitoraggio/v1/monitoraggio/fatture/dettaglio/?v='+unixTime()+'&idSdi='+idInviofile+'&operatore=e', headers = headers_token )
                # filejsonindinvio = json.dumps(dict(requests.get('https://ivaservizi.agenziaentrate.gov.it/ser/api/monitoraggio/v1/monitoraggio/fatture/dettaglio/?v='+unixTime()+'&idSdi='+idInviofile+'&operatore=e').headers_token))
                if r.status_code == 200:
                    filejsonindinvio = 'fatturaID'+idInviofile+'.json'
                with open(filejsonindinvio, 'wb') as fj:
                    fj.write(r.content)
                    print('Scarico file json della fattura emessa: '+'fatturaID'+idInviofile+'.json')
                with open(filejsonindinvio) as dati:
                    print(dati)
                    datajson = json.load(dati)
                    if datajson['elencoNotifiche'] == []:
                        print('No Data123!')
                    else:
                        for idSDIelenco in datajson['elencoNotifiche'] :
                            print('ID Invio:' + str(idSDIelenco['id']))
                            print('nome:' + str(idSDIelenco['nome']))
                            print('Data UNIX' + str(idSDIelenco['dataConsegna']))
                        for idSDIelenco in datajson['elencoNotifiche']:
                            tipettofile = str(idSDIelenco['nome'])
                            if tipettofile == "File dei metadati":
                                 print("Ho Scaricato correttamente il file metadati!")
                            else:
                                idSDIinvio = idSDIelenco['id']
                                stridSDIinvio = str(idSDIinvio)
                                r = s.get('https://ivaservizi.agenziaentrate.gov.it/ser/api/monitoraggio/v1/monitoraggio/fatture/notifiche/'+stridSDIinvio+'/download/' , headers = headers_token)
                                if r.status_code == 200:
                                     d = r.headers['content-disposition']
                                     fname = re.findall("filename=(.+)", d)
                                     with open(path + '/' + fname[0], 'wb') as f:
                                         f.write(r.content)
                #os.system('cls')
        print('Per il cliente: ', cfcliente)
        print('Totale fatture trasfrontaliere scaricate: ', numero_fatture)
        print('Totale notifiche scaricate: ', numero_notifiche)

except KeyboardInterrupt:
    print("Programma INTERROTTO manualmente!")

sys.exit()