#!/usr/bin/env python3 # -*- coding: utf-8 -*- # Copyright (C) 2013-2025 Étienne Loks # This program is free software: you can redistribute it and/or modify # it under the terms of the GNU Affero General Public License as # published by the Free Software Foundation, either version 3 of the # License, or (at your option) any later version. # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU Affero General Public License for more details. # You should have received a copy of the GNU Affero General Public License # along with this program. If not, see . # See the file COPYING for details. import sys from django.core.management.base import BaseCommand from django.apps import apps APPS = ['ishtar_common', 'archaeological_operations', 'archaeological_context_records', 'archaeological_finds', 'archaeological_warehouse'] class Command(BaseCommand): args = '' help = 'Process pending update of cached labels and geo position' def add_arguments(self, parser): parser.add_argument( '--quiet', dest='quiet', action='store_true', help='Quiet output') def handle(self, *args, **options): quiet = options['quiet'] for app in APPS: if not quiet: print("* app: {}".format(app)) for model in apps.get_app_config(app).get_models(): if model.__name__.startswith('Historical'): continue if not bool( [True for k in model._meta.get_fields() if k.name == "need_update"]): continue msg = "-> processing {}: ".format(model._meta.verbose_name) q = model.objects.filter(need_update=True) ln = q.count() for idx, obj_id in enumerate(q.values('pk').all()): obj = model.objects.get(pk=obj_id['pk']) obj.skip_history_when_saving = True obj._no_move = True cmsg = "\r{} {}/{}".format(msg, idx + 1, ln) if not quiet: sys.stdout.write(cmsg) sys.stdout.flush() obj.save() if not quiet and ln: sys.stdout.write("\n")