From edac22b701d40bb87b1a1f5f0a77d434ee36321b Mon Sep 17 00:00:00 2001 From: caoqianming Date: Tue, 18 Feb 2025 10:51:31 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20cal=5Fmaterial=5Fcount=20=E6=94=B9?= =?UTF-8?q?=E4=B8=BA=E5=90=8C=E6=AD=A5=E6=89=A7=E8=A1=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/inm/services.py | 2 +- apps/wpm/services.py | 5 +++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/apps/inm/services.py b/apps/inm/services.py index 58b8d048..f52d870f 100644 --- a/apps/inm/services.py +++ b/apps/inm/services.py @@ -223,7 +223,7 @@ class InmService: """ # 统计物料数量 m_ids = MIOItem.objects.filter(mio=instance).values_list('material_id', flat=True) - MyThread(target=cal_material_count, args=(m_ids, ), daemon=True).start() + cal_material_count(m_ids) @classmethod def update_inm(cls, instance: MIO, is_reverse: bool = False): diff --git a/apps/wpm/services.py b/apps/wpm/services.py index 5b2ff402..13f95968 100644 --- a/apps/wpm/services.py +++ b/apps/wpm/services.py @@ -21,6 +21,7 @@ from datetime import timedelta from apps.wpmw.models import Wpr, WprDefect from ..qm.models import Defect, Ftest from django.db.models import Count, Q +from apps.utils.tasks import ctask_run myLogger = logging.getLogger('log') @@ -322,7 +323,7 @@ def mlog_submit(mlog: Mlog, user: User, now: Union[datetime.datetime, None]): cal_mtask_progress_from_mlog(mlog) # 更新物料数量 - MyThread(target=cal_material_count_from_mlog,args=(mlog,)).start() + cal_material_count_from_mlog(mlog) # 触发批次统计分析 if mlog.batch: @@ -497,7 +498,7 @@ def mlog_revert(mlog: Mlog, user: User, now: Union[datetime.datetime, None]): cal_mtask_progress_from_mlog(mlog) # 更新物料数量 - MyThread(target=cal_material_count_from_mlog,args=(mlog,)).start() + cal_material_count_from_mlog(mlog) # 触发批次统计分析 if mlog.batch: