ScarFec42..py

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

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

# Funzione per calcolare la differenza in giorni tra due date
def differenza_giorni(data_iniziale, data_finale):
    d1 = datetime.strptime(data_iniziale, "%d%m%Y")
    d2 = datetime.strptime(data_finale, "%d%m%Y")
    return (d2 - d1).days

# Funzione per dividere il periodo in trimestri
def divide_in_trimestri(data_iniziale, data_finale):
    d1 = datetime.strptime(data_iniziale, "%d%m%Y")
    d2 = datetime.strptime(data_finale, "%d%m%Y")
    trimestri = []
    while d1 < d2:
        fine_trimestre = d1 + timedelta(days=90)
        if fine_trimestre > d2:
            fine_trimestre = d2
        trimestri.append((d1.strftime("%d%m%Y"), fine_trimestre.strftime("%d%m%Y")))
        d1 = fine_trimestre + timedelta(days=1)
    return trimestri

# 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 scaricaemesse(tipo):
    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/'+data_iniziale_trimestre+'/al/'+data_finale_trimestre+'/ricerca/ricezione?v=' + unixTime(), headers = headers)
    elif tipo == 2:     
         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/'+data_iniziale_trimestre+'/al/'+data_finale_trimestre+'/ricerca/emissione?v=' + unixTime(), headers = headers)

    with open('fe_ricevute_'+ cfcliente +'_tipo'+ str(tipo) +'.json', 'wb') as f:
        f.write(r.content)
        
    puts(colored.red('Inizio a scaricare le fatture PASSIVE ricevute per tipo '+ colored.green(str(tipo))))
    path = r'FattureRicevute_' + 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 +'_tipo'+ str(tipo) +'.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 data_iniziale_trimestre ' + 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
        with open('output_fatture.txt', 'a') as file:
            print('Trimestri', trimestri, file=file)
            print('Totale fatture PASSIVE RICEVUTE scaricate: ', numero_fatture_ricevute , ' e notifiche ' , numero_notifiche_ricevute, file=file)
        
    
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
    trimestri = divide_in_trimestri(Dal, Al)# funione he divide in trimestri
    print(trimestri)
    for trimestre in trimestri:
        data_iniziale_trimestre, data_finale_trimestre = trimestre
        print(trimestre)
        print(f"Elaborazione del periodo data_iniziale_trimestre {data_iniziale_trimestre} al {data_finale_trimestre}")
        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/'+data_iniziale_trimestre+'/al/'+data_finale_trimestre+'?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 data_iniziale_trimestre ' + 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.find("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)
            with open('output_fatture.txt', 'a') as file:
                print('Totale fatture messe a disposizione scaricate: ', numero_fatture_disposizione, cfcliente, file=file)




            #===============================================================================================
            # 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('X1 Scarico il json delle fatture ricevute per data ricezione per la partita IVA ' + cfcliente)
                 scaricaemesse(1)
            else:     
                 print('X2 Scarico il json delle fatture ricevute per data di emissione e ricezione per la partita IVA ' + cfcliente)
                 scaricaemesse(2)
                 scaricaemesse(1)
            
            
            

        #=============# 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/'+data_iniziale_trimestre+'/al/'+data_finale_trimestre+'?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'FattureRicevute_' + 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)
            with open('output_fatture.txt', 'a') as file:

                print('Per il cliente: ', cfcliente, file=file )
                print('Totale fatture TRANSFRONTALIERE RICEVUTE scaricate: ', numero_fatture, file=file)
                print('Totale notifiche scaricate per le fatture TRAN ricevute: ', numero_notifiche, file=file)


        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/'+data_iniziale_trimestre+'/al/'+data_finale_trimestre+'?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)
        with open('output_fatture.txt', 'a') as file:
            print('Per il cliente: ', cfcliente, file=file)
            print('Totale fatture EMESSE scaricate: ', numero_fatture, file = file)


        #========================================================================================
        # 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/'+data_iniziale_trimestre+'/al/'+data_finale_trimestre+'?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')
            with open('output_fatture.txt', 'a') as file:
                print('Per il cliente: ', cfcliente, file= file)
                print('Totale fatture trasfrontaliere scaricate: ', numero_fatture, file = file)
                print('Totale notifiche scaricate: ', numero_notifiche, file = file)

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

sys.exit()