diff --git a/apps/wpm/services.py b/apps/wpm/services.py
index 430b9a97..d998ca3c 100644
--- a/apps/wpm/services.py
+++ b/apps/wpm/services.py
@@ -390,7 +390,7 @@ def mlog_submit(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
     ana_batch_thread(xbatches)
 
     # 触发单个统计
-    xnumbers = list(Mlogbw.objects.filter(mlogb__mlog=mlog, ftest__isnull=False).values_list('number', flat=True))
+    xnumbers = list(Mlogbw.objects.filter(mlogb__mlog=mlog, ftest__isnull=False, number__isnull=False).values_list('number', flat=True))
     ana_wpr_thread(xnumbers, mlog.mgroup)
 
 
@@ -607,8 +607,8 @@ def mlog_revert(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
     ana_batch_thread(xbatches)
 
     # 触发单个统计
-    xnumbers = list(Mlogbw.objects.filter(mlogb__mlog=mlog, ftest__isnull=False).values_list('number', flat=True))
-    ana_wpr_thread(xnumbers)
+    xnumbers = list(Mlogbw.objects.filter(mlogb__mlog=mlog, ftest__isnull=False, number__isnull=False).values_list('number', flat=True))
+    ana_wpr_thread(xnumbers, mlog.mgroup)
 
 def cal_mtask_progress_from_mlog(mlog:Mlog):
     """