ref prices fix

This commit is contained in:
Kseninia Mikhaylova 2025-03-20 13:20:02 +03:00
parent 52b5342483
commit 339bfd390f
4 changed files with 6 additions and 7 deletions

View File

@ -8,4 +8,4 @@ def update_calcmodel_prices():
""" """
Задача для обновления цен в модели. Задача для обновления цен в модели.
""" """
update_ref1c_prices.delay("CalcModelRef1CConnection", "calc") update_ref1c_prices.delay("CalcModelRef1CConnection")

View File

@ -82,13 +82,12 @@ def fetch_price_from_1c(ref_key):
@shared_task @shared_task
def update_ref1c_prices(model_name, connection_field, ref1c_field="ref1c"): def update_ref1c_prices(model_name, ref1c_field="ref1c"):
""" """
Универсальная периодическая задача для обновления цен в любой модели, Универсальная периодическая задача для обновления цен в любой модели,
связанной с Ref1C через указанные поля. связанной с Ref1C через указанные поля.
:param model_name: Имя модели (например, 'SkamejkaConnection'). :param model_name: Имя модели (например, 'SkamejkaConnection').
:param connection_field: Поле связи с основной моделью (например, 'calc').
:param ref1c_field: Поле связи с Ref1C (по умолчанию 'ref1c'). :param ref1c_field: Поле связи с Ref1C (по умолчанию 'ref1c').
""" """
from django.apps import apps from django.apps import apps

View File

@ -4,7 +4,7 @@ from django.contrib import messages
from global_data.models import Ref1C from global_data.models import Ref1C
from .models import SkamejkaCalc, SkamejkaConnection from .models import SkamejkaCalc, SkamejkaConnection
from .tasks import update_skamejka_prices from .tasks import update_calcmodel_prices
class SkamejkaConnectionInline(admin.TabularInline): class SkamejkaConnectionInline(admin.TabularInline):
""" """
@ -61,7 +61,7 @@ class SkamejkaConnectionAdmin(admin.ModelAdmin):
def update_all_prices(self, request, queryset): def update_all_prices(self, request, queryset):
try: try:
# Запускаем задачу Celery для обновления всех цен # Запускаем задачу Celery для обновления всех цен
task = update_skamejka_prices.delay() task = update_calcmodel_prices.delay()
self.message_user( self.message_user(
request, request,
f"Задача на обновление всех цен отправлена. ID задачи: {task.id}", f"Задача на обновление всех цен отправлена. ID задачи: {task.id}",

View File

@ -2,8 +2,8 @@ from celery import shared_task
from mns.utils import update_ref1c_prices from mns.utils import update_ref1c_prices
@shared_task @shared_task
def update_skamejka_prices(): def update_calcmodel_prices():
""" """
Задача для обновления цен в модели SkamejkaConnection. Задача для обновления цен в модели SkamejkaConnection.
""" """
update_ref1c_prices.delay("SkamejkaConnection", "calc") update_ref1c_prices.delay("SkamejkaConnection")