gd/documento/managefile.py

from django.shortcuts import render
from django.http import HttpResponse,HttpResponseRedirect,FileResponse
from django.contrib.auth.models import User
from django.urls import reverse
from django.db import IntegrityError

from .models import *
from config.views import *

from django.conf import  settings
from django.conf.urls.static import static
from django.contrib.auth import authenticate
import mimetypes
from random import randint
import csv
import time
import datetime

#pip install python-codicefiscale
from codicefiscale import codicefiscale

import os

# come sono gestiti i file nella configurazione:
# MEDIA_ROOT=os.path.join(settings.BASE_DIR,'static/upload')
# che diventa = os.path.join(settings.BASE_DIR,getConfig('DocPath'))
# inoltre devo aver fatto qualche casino oggi 9.8.24 con i copia e incolla. ho dovuto rivedere tutto il file


def delete_file(documento):
  # questo blocco rimuove fisicamente il file prima della sua rimozione logica nel db
  file_path = os.path.join(settings.BASE_DIR,getConfig('DocPath'),documento.utente.azienda.partitaiva,documento.utente.codicefiscale,documento.storage)
  print('Path completa:',file_path)
  if os.path.isfile(file_path):
    print('rimozione fisica file:',file_path)  
    try:
      os.remove(file_path)
    except OSError as ose:
      print('errore nella rimozione del file:',ose)

def download_file(request,uid):
    utente = Utenti.objects.get(pk=uid)
    file_path = os.path.join(settings.BASE_DIR,getConfig('DocPath'),documento.utente.azienda.partitaiva,documento.utente.codicefiscale,utente.storage)
    print('Path completa da Basedir:',file_path)
    if utente.storage and os.path.isfile(file_path):
      try:
        fl = open(file_path, 'rb')
      except Exception as er:
        print('errore',er)
        data=dict()
        data['errore']="File non esistente o non ancora disponibile"
        data['utente'] = utente
        return render(request,'welcome.error.html',data)
    else:
      print('il file non esiste',file_path)
      data=dict()
      data['errore']='File non esistente o non ancora disponibile'
      data['utente'] = utente
      return render(request,'welcome.error.html',data)

    mime_type, _ = mimetypes.guess_type(file_path)
    print('file',file_path,mime_type)
    response = FileResponse(open(file_path,'rb'),content_type='application/pdf',as_attachment=False)
    #response['Content-Disposition'] = "attachment; filename=%s" % u.documento
    return response
  
def upload_file(uploaded_file,utente,originale=False):
  '''
  caricamento files
  '''
  stored_file = ''.join((str(time.time()),'.saved'))
  fl_path = os.path.join(settings.BASE_DIR,getConfig('DocPath'))
  print('nome file',uploaded_file.name,stored_file)

  nomefile=None
  if originale:
    nomefile = uploaded_file.name
  else:
    nomefile = stored_file

  # vediamo se caricare o meno.
  # in questo caso, se il documento esiste gia', non lo carica.
  # come facciamo a stabilire se il documento esiste gia'?
  # fl_path = corrisponde a media.ROOT (che mi domando se non e' il caso di spostarlo nella configurazione)
  # azienda.partitaiva
  # utente.codicefiscale (prima era "record" e mi sono deciso a cambiarlo)

  try:
    print(os.path.join(fl_path,utente.azienda.partitaiva))
    os.mkdir(os.path.join(fl_path,utente.azienda.partitaiva))
  except FileExistsError as fee:
    print(os.path.join(fl_path,utente.azienda.partitaiva),"esistente")
  try:
    os.mkdir(os.path.join(fl_path,utente.azienda.partitaiva,utente.codicefiscale))
  except FileExistsError as fee:
    print(os.path.join(fl_path,utente.azienda.partitaiva,utente.codicefiscale),"esistente")

  with open(os.path.join(fl_path,utente.azienda.partitaiva,utente.codicefiscale,nomefile),'wb+') as d:
    for chunk in uploaded_file.chunks():
      d.write(chunk)

  if originale:
    return os.path.join(fl_path,utente.azienda.partitaiva,utente.codicefiscale,nomefile)
  return stored_file

def upload_file_indice(uploaded_file):
  # caricamento file indice (gestito in modo diverso)

  stored_file = ''.join((str(time.time()),'.saved'))
  fl_path = os.path.join(settings.BASE_DIR,getConfig('DocPath'),getConfig('DocPathIndex'))
  print('nome file',uploaded_file.name,stored_file)

  # verifica l'esistenza della directory
  try:
    os.mkdir(fl_path)
  except FileExistsError as fee:
    print(fl_path,"esistente")

  print('file_memorizzato',os.path.join(fl_path,stored_file))

  with open(os.path.join(fl_path,stored_file),'wb+') as d:
    for chunk in uploaded_file.chunks():
      d.write(chunk)

  return stored_file

##################################################################################
def save_and_load_file_multiple(listadocumenti,request,utente,azienda,descrizione):
  listaok = list()
  listanotok = list()
  for singolodocumento in listadocumenti:
    print('singolodocumento',singolodocumento)
    for ut in utente:
      if ut.codicefiscale.strip() in singolodocumento.name:
        print('match utente-documento')
        risultato = upload_file(singolodocumento,ut)
        documento = Documento()
        documento.dataupload = datetime.datetime.now()
        documento.utente = ut
        documento.azienda = azienda
        documento.documento = singolodocumento.name
        documento.storage = risultato
        documento.descrizione = descrizione
        try:
          documento.save()
          listaok.append(documento.documento)
        except IntegrityError as ie:
          print("problema di integrita', il file esiste",ie)
          listanotok.append(documento.documento)
  print(listaok,listanotok)
  return (listaok,listanotok)

def save_and_load_file_single(listadocumenti,request,utente,azienda,descrizione):
  listaok = list()
  listanotok = list()
  for singolodocumento in listadocumenti:
    print('singolodocumento',singolodocumento,descrizione)
    risultato = upload_file(singolodocumento,utente)
    documento = Documento()
    documento.dataupload = datetime.datetime.now()
    documento.utente = utente
    documento.azienda = azienda
    documento.documento = singolodocumento.name
    documento.storage = risultato
    documento.descrizione = descrizione
    try:
      documento.save()
      listaok.append(documento.documento)
    except IntegritiError as ie:
      print("problema di integrita', il file esiste",ie)
      listanotok.append(documento.documento)
  return (listaok,listanotok)

def save_and_load_file_indice(request,fileindice,documento):
  print('nome indice caricato',fileindice.name)

  file_memorizzato = upload_file_indice(request.FILES['indice'])

  fl_path = os.path.join(getConfig('DocPath'),getConfig('DocPathIndex'))
  
  risultato = None
  with open(os.path.join(fl_path,file_memorizzato),'rb') as ind:
    risultato = ind.read()
    risultato = risultato.decode('utf-8',errors='replace')
    if isinstance(risultato,str):
      risultato = risultato.encode('utf8')

    with open(os.path.join(fl_path,''.join((file_memorizzato,'.cvtd'))),'wb') as ind:
      ind.write(risultato)
      print('una volta convertito, passiamo oltre')
    
    with open(os.path.join(fl_path,''.join((file_memorizzato,'.cvtd'))),'rt') as ind:
        spamreader = csv.reader(ind,delimiter=';')
        errori = list()
        count = 0
        for sr in spamreader:
          salvare = False
          count +=1
          if count==1: continue
          print(count,'sr',sr,len(sr))

          '''
          rispetto a farma, questo tracciato e' diverso
            0: 0308 - BOX3 S.R.L.;
            1: Elaborazioni - Lul  Libro Unico del Lavoro lavoratore;
            2: ALESSE ANTONIO - LSSNTN63A25H501Y;
            3: DA0308_L.U.L._LAVORATORE_#_ALESSE_ANTONIO_#_LSSNTN63A25H501Y_#_06.2024_12.07.2024_10.18.43.pdf;
            4: ="06.2024";
            5: 12.07.2024 10:34:17;
            6: Cliente;
            7: 2024.07.15 11:40:33;
            8: 12.07.2024;
            9: 12.07.2024;
          '''

          if len(sr) > 1: # la lunghezza del record segnala qualcosa
            utente = None
            try:
              utente = Utente.objects.get(codicefiscale=sr[2].split(' - ')[1].strip().upper())
            except Utente.DoesNotExist as dne:
              print('Utente non trovato')
              utente = Utente()
              utente.azienda = azienda
              utente.nome = sr[2].capitalize()
              try:
                data_convertita =  datetime.datetime.strptime(sr[8], "%d.%m.%Y")
                print('data convertita',data_convertita)
                utente.datanascita = data_convertita
              except ValueError as ve:
                print(ve)
              utente.codicefiscale = sr[2].split(' - ')[1].strip().upper()
              utente.password = str(randint(100000,999999))
              utente.save()

'''
    # caricamento documenti
    if filecaricati.cleaned_data.get('allegati'):
      print('presenti documenti da allegare')
      listadocumenti = filecaricati.cleaned_data['allegati']
      print(listadocumenti)

      utenti = Utenti.objects.all()
      for singolodocumento in listadocumenti:
        print('singolodocumento',singolodocumento)
        for utente in utenti:
          if utente.codicefiscale.strip() in singolodocumento.name:
            print('match utente-documento')
            risultato = upload_file(singolodocumento,utente)
            # risultato: nome del file memorizzato (nome interno)
            # singolodocumento.name = nome del file originale

'''