Compare commits

..

1 commit

Author SHA1 Message Date
374caf8a56
Add file migration 2022-12-31 17:59:42 +01:00
3 changed files with 28 additions and 36 deletions

View file

@ -11,41 +11,34 @@ import main.models
def move_files(apps, schema_editor):
Invoice = apps.get_model("main", "Invoice")
Snapshot = apps.get_model("main", "Snapshot")
db_alias = schema_editor.connection.alias
for invoice in Invoice.objects.all():
print(f"Invoice {invoice.pk}")
if invoice.file is None:
invoice.delete()
continue
try:
for invoice in Invoice.objects.using(db_alias).all():
initial_path = pathlib.Path(invoice.file.path)
except ValueError:
invoice.delete()
continue
if invoice.file is None or not initial_path.exists():
print(f"!!! Path {initial_path} does not exist")
invoice.delete()
continue
prev_file = invoice.file.path
invoice.file.save(main.models.get_path(invoice, None), invoice.file)
pathlib.Path(prev_file).unlink()
for snapshot in Snapshot.objects.filter(file__isnull=False):
print(f"Snapshot {snapshot.pk}")
try:
initial_path = pathlib.Path(snapshot.file.path)
except ValueError:
snapshot.file = None
snapshot.save()
continue
if not initial_path.exists():
print(f"!!! Path {initial_path} does not exist")
snapshot.file = None
invoice.file = None
invoice.save()
return
_name = main.models.get_path(invoice, None)
print(settings.MEDIA_ROOT)
new_path = pathlib.Path(settings.MEDIA_ROOT, _name)
new_path.parent.mkdir(mode=0o750, parents=True, exist_ok=True)
initial_path.rename(new_path)
invoice.file.name = str(_name)
invoice.save()
for snapshot in Snapshot.objects.using(db_alias).filter(file__isnull=False):
initial_path = pathlib.Path(snapshot.file.path)
if not initial_path.exists():
invoice.file = None
invoice.save()
return
_name = main.models.get_path(snapshot, None)
new_path = pathlib.Path(settings.MEDIA_ROOT, _name)
new_path.parent.mkdir(mode=0o750, parents=True, exist_ok=True)
initial_path.rename(new_path)
snapshot.file.name = str(_name)
snapshot.save()
continue
prev_file = snapshot.file.path
snapshot.file.save(main.models.get_path(snapshot, None), snapshot.file)
pathlib.Path(prev_file).unlink()
class Migration(migrations.Migration):

View file

@ -279,12 +279,11 @@ class Invoice(CustomModel):
Transaction, on_delete=models.CASCADE, editable=False
)
def save(self, *args, **kwargs):
def save(self):
if Invoice.objects.filter(id=self.id).exists():
_prever = Invoice.objects.get(id=self.id)
if _prever.file and _prever.file != self.file:
pathlib.Path(_prever.file.path).unlink(missing_ok=True)
super().save(*args, **kwargs)
def __str__(self):
if hasattr(self, "transaction"):

View file

@ -340,7 +340,7 @@ class SearchView(TransactionListView):
return super().get_context_data(**kwargs) | {"search": self.kwargs["search"]}
class MediaView(LoginRequiredMixin, View):
class MediaView(View):
def get(self, request, *args, **kwargs):
_username = kwargs.get("username")
_path = kwargs.get("path")