gd/documento/views.py

from django.shortcuts import render
from .models import *

from django.shortcuts import render
from django.http import HttpResponse,HttpResponseRedirect,FileResponse
from django.urls import reverse
from django.conf import settings

from .models import *
from .forms import *

from config.views import *
from .managefile import *
from att.views import *
from sicurezza.views import *

from datetime import datetime,timedelta
from comunicazione.views import ServizioMail

def welcome(request,utente=None):
  uu = utente
  '''
  punto di ingresso.
  vengono mostrati tutti i documenti presenti
  '''

  if not 'AdminId' in request.session or 'UserId' in request.session:
    print("Non rilevo presensa UserId e AdminId in request.session")
    return HttpResponseRedirect(reverse("login:start"))

  data = dict()
  data['HeaderTitle'] = getConfig('HeaderTitle')
  data['pane'] = "Documento"

  if not 'AziendaId' in request.session:
    print('manca azienda')
    return HttpResponseRedirect(reverse("login:start"))

  azienda = None
  data['AziendaId'] = request.session['AziendaId']
  AziendaId = request.session['AziendaId']
  print('AziendaId',AziendaId)
  azienda = Azienda.objects.get(pk=AziendaId)
  data['azienda'] = azienda

  data['AdminId'] = request.session['AdminId']
  admin = Amministratore.objects.get(pk=data['AdminId'])
  data['admin'] = admin
  print('admin',admin.id,admin.nome)

  sede = None
  if 'SedeId' in request.session:
    SedeId = request.session['SedeId']
    print('SedeId',SedeId)
    try:
      sede = Sede.objects.get(pk=SedeId)
    except Sede.DoesNotExist as dne:
      print("sede non esistente")
    data['sede'] = sede
  
  if 'UserId' in request.session:
    data['UserId'] = request.session['UserId']

  data['azienda'] = Azienda.objects.get(pk=data['AziendaId'])
  data['utenti'] = data['azienda'].utente_set.all()

  #filtro:
  # selezionare tutti gli utenti per AziendaId
  admin = Amministratore.objects.get(pk=data['AdminId'])
  data['admin'] = admin 

  azienda = Azienda.objects.get(pk=data['AziendaId'])
  data['azienda'] = azienda

  utenti = Utente.objects.filter(azienda = azienda)  
  data['utenti'] = utenti

  eol = getConfig('DocEol')
  data['eol'] = eol

  ElencoDocumenti = list()

  if utente: #visualizza i documenti per l'utente
    ElencoDocumenti = Documento.objects.filter(utente=utente).order_by("utente__nome","documento") 
  elif sede:
    tmpUtenti = sede.utente_set.all()
    for t in tmpUtenti:
      d = t.documento_set.all()
      for id in d:
        ElencoDocumenti.append(id)
  else:
    tmpUtenti = azienda.utente_set.all()
    for t in tmpUtenti:
      d = t.documento_set.all()
      for id in d:
        ElencoDocumenti.append(id)
  
  #####
  # filtro temporaneo, non mostra i documenti che iniziano per EMO
  #####
  tmp = list()
  if "DOCUMENTO.NASCONDE.EMO":
    for ed in ElencoDocumenti:
       if "emo_" not in ed.documento.lower():
         tmp.append(ed)
  else:
    tmp = ElencoDocumenti     
  print('ElencoDocumenti/tmp',len(ElencoDocumenti),len(tmp))
  data['ElencoDocumenti'] = tmp

  print('inizio sequenza permessi')
  ### permessi inizio ###
  data['permesso'] = getAMP(admin)[0]
  print('permessoi generale:',data['permesso'])

  if 'AziendaId' in data:
    print('livello azienda',getAZP(data['AziendaId'],admin)[0])
    for t in getAZP(data['AziendaId'],admin)[0]:
      if t not in data['permesso']:
        data['permesso'].append(t)
        
    if 'sede' in data:
      print('livello sede',getSEP(data['sede'],admin))
      for t in getSEP(data['sede'],admin):
        if t not in data['permesso']:
          data['permesso'].append(t)
    print('Stato permessi:',data['permesso'])
         ### permessi fine ###

  if request.method == 'POST':
    if 'indietro' in request.POST:
      print("AziendaId",request.session['AziendaId'])
      print("AdminId",request.session['AdminId'])
      return HttpResponseRedirect(reverse("azienda:welcome"))

    if 'ScaricaSelezionati' in request.POST:
      print('Premuto tasto Scarica Selezionati')
      if 'select' in request.POST:
        SelectResponse = formMultipleCheckBox(request.POST)
        SelectResponse.c(data['ElencoDocumenti'])
        print("SelectResponse",SelectResponse)

        if SelectResponse.is_valid():
          select = SelectResponse.cleaned_data.get('select')
          print('select',select,type(select))
          (pathzipfile,filePreparato) = PrepareZipFile(select)
          # scarica il file
          response = None
          with open(os.path.join(pathzipfile,filePreparato),'rb') as f:
            response =  HttpResponse(f.read(),content_type='application/zip')
            response['Content-Disposition'] = 'attachment; filename={}'.format(filePreparato)
          os.unlink(os.path.join(pathzipfile,filePreparato))
          return response

    if 'DeleteOldDocuments' in request.POST:
      print('Richiesta di eliminazione vecchi documenti')
      dods = DeleteOldDocuments(request.POST)
      if dods.is_valid():
        print('dods',dods.cleaned_data)
        print('effettuata scelta di cancellazione vecchi documenti')
        # costuire una lista dei documenti più vecchi
        limite = int(request.POST['limite'])
        print('limite',limite)
        d = datetime.now()
        r = d - timedelta(days=limite)
        print(r)
        oldDocs = Documento.objects.filter(azienda=azienda)
        oldDocs1 = oldDocs.filter(dataupload__lt=r)
        print('lista documenti',len(oldDocs1))
        for i in oldDocs1:
          print('documento',i.documento)
          delete_file(i)
          i.delete()
      data['pane'] = "Deleteold"

    if 'DeleteDocument' in request.POST and request.POST.get('DeleteDocument'):
      print('Richiesta cancellazione Documento',request.POST)
      documento = request.POST['DeleteDocument']  # perche' lo considera una lista e non un singolo valore?
      print('richiesta cancellazione documento:',documento)
      try:
        d = Documento.objects.get(pk=documento)
        delete_file(d)  #rimozione fisica del documento 
        d.delete()
      except Documento.DoesNotExist as dne:
        print('il documento non esiste')

    if "CaricaDocumentoButton" in request.POST:
      print("Premuto CaricaDocumentoButton")
      filecaricati = AdminUpload(request.POST,request.FILES)
      if filecaricati.is_valid():
        pertutti = filecaricati.cleaned_data.get('pertutti')
        print('stato -pertutti-',pertutti," ",filecaricati.cleaned_data.get('pertutti'))
        #pertutti: il documento viene messo a disposizione a tutti gli utenti, non rientra nel filtro x utente, ma solo nel filtro x azienda
     
        print('record filecaricati validi')

        comunicazione = filecaricati.cleaned_data.get('comunicazione')
        ignoraAzienda = filecaricati.cleaned_data.get('ignoraAzienda')
        if 'allegati' in filecaricati.cleaned_data and filecaricati.cleaned_data.get('allegati'):
          print('presenti documenti da allegare')
          listadocumenti = filecaricati.cleaned_data['allegati']
          print(listadocumenti)
          print(type(azienda))
          print(azienda.id)
    
          if not utente:
            if ignoraAzienda:
              listaok,listanotok = save_and_load_file_multiple(listadocumenti,request,Utente.objects.all(),azienda,sede,filecaricati.cleaned_data['descrizione'],admin.nome,pertutti,ignoraAzienda=ignoraAzienda)
            else:
              listaok,listanotok = save_and_load_file_multiple(listadocumenti,request,utenti,azienda,sede,filecaricati.cleaned_data['descrizione'],admin.nome,pertutti,ignoraAzienda=ignoraAzienda)
            data['listaok'] = listaok
            data['listanotok'] = listanotok
          else:
            u = Utente.objects.get(pk=uu)
            listaok,listanotok = save_and_load_file_single(listadocumenti,request,u,data['azienda'],data['sede'],filecaricati.cleaned_data['descrizione'],data['admin'])
          print('stato caricamenti',listaok,listanotok)
          data['listaok'] = listaok
          data['listnotok'] = listaok

          print('listaok',listaok)
          print('listanotok',listanotok)

        if comunicazione:
          ### comunicazioni ###
          sm = ServizioMail(debug=True)

          try:
            comunicazione = Comunicazione.objects.get(pk=7)
          except Comunicazione.DoesNotExist as dne:
            print("Record comunicazione inesistente",dne)
          u = Utente.objects.get(pk=uu)
          sm.set_mailfrom=comunicazione.mittente
          sm.add_to(u.mail)

          sm.set_soggetto(comunicazione.soggetto)
          sm.set_corpo(comunicazione.corpo)

          sm_data = dict()
          tmp_utente=dict() #adattamento campo utente

          tmp_utente['nome'] = u.nome
          tmp_utente['mail'] = u.mail
          tmp_utente['sito'] = getConfig('DefaultSite')
          tmp_utente['titolo'] = getConfig('HeaderTitle')
          sm_data['utente'] = tmp_utente

          sm.set_data(sm_data)
          sm.send()
        ### comunicazioni ###
      data['pane'] = "Upload"

  print("Numero documenti associati",len(ElencoDocumenti),len(data['ElencoDocumenti']))

  return render(request,'documento.welcome.html',data)

def finalize_download(request,did,uid=None):
  '''
  viene comunicato l'utente
  viene cercato il file memorizzato e viene riconsegnato 
  con il nome originale
  did: documento id
  uid: user id
  '''

  UserId = None

  if not did:
    return HttpResponseRedirect(reverse("login:start"))

  if not 'AdminId' in request.session and not 'UserId' in request.session: 
    print("Non rilevo UserId in request.session")
    return HttpResponseRedirect(reverse("login:start"))

  if 'UserId' in request.session:
    UserId = request.session['UserId']
    print('UserId in request session',UserId)
  else:
    print('UserId passed by func',uid)
    UserId = uid

  utente = Utente.objects.get(pk=UserId)
  documento = Documento.objects.get(pk=did)

  fl_completa = os.path.join(settings.BASE_DIR,getConfig('DocPath'),utente.azienda.partitaiva,utente.codicefiscale,documento.storage)
  print('path completa',fl_completa)

  if documento.storage and os.path.isfile(fl_completa):
    try:
      fl = open(fl_completa, 'rb')
    except Exception as er:
      print('errore',er)
      data=dict()
      data['errore']="File non esistente o non ancora disponibile"
      data['utente'] = utente
      data['documento'] = documento
      return render(request,'documento.error.html',data)
  else:
    print('il file non esiste in document,download')
    data=dict()
    data['errore']='File non esistente o non ancora disponibile'
    data['utente'] = utente
    data['documento'] = documento
    return render(request,'documento.error.html',data)

  mime_type, _ = mimetypes.guess_type(fl_completa)
  fl = fl_completa
  print('fl',fl,mime_type)
  response = FileResponse(open(fl,'rb'),content_type='application/pdf',as_attachment=False)
  #response['Content-Disposition'] = "attachment; filename=%s" % documento.documento
  #setNewLog(3,{'utente':utente,'documento':documento,'azienda':utente.azienda})
  setLog(3,azienda=utente.azienda,utente=utente,documento=documento)

  ### comunicazioni ###
  if len(utente.mail) > 0:
    comunicazione = None
  try: 
    comunicazione = Comunicazione.objects.get(pk=3)
  except Comunicazione.DoesNotExist as dne:
    print('comunicazione non valida',dne)
  if comunicazione:
    sm = ServizioMail(debug=True)
    sm.set_mailfrom=comunicazione.mittente
    sm.add_to(utente.mail)

    sm.set_soggetto(comunicazione.soggetto)
    sm.set_corpo(comunicazione.corpo)

    sm_data = dict()
    sm_data['utente'] = utente
    sm_data['azienda'] = utente.azienda
    sm_data['documento'] = documento
    sm.set_data(sm_data)
    sm.send()
  ### comunicazioni ###

  return response