diff --git a/apps/enm/tasks.py b/apps/enm/tasks.py
index dde29813..30114e86 100644
--- a/apps/enm/tasks.py
+++ b/apps/enm/tasks.py
@@ -178,7 +178,7 @@ def cal_mpointstat_hour(mpointId: str, year: int, month: int, day: int, hour: in
                 ms_hour_s.save()
 
                 # 开始往上计算
-                sum_dict_sflog_s = MpointStat.objects.filter(type="hour_s", mpoint=mpoint, year_s=year_s, month_s=month_s, day_s=day_s).aggregate(sum=Sum("val"))
+                sum_dict_sflog_s = MpointStat.objects.filter(type="hour_s", mpoint=mpoint, year_s=year_s, month_s=month_s, day_s=day_s, sflog=sflog).aggregate(sum=Sum("val"))
                 params_sflog_s = {"type": "sflog", "mpoint": mpoint, "sflog": sflog, "year_s": year_s, "month_s": month_s, "day_s": day_s, "mgroup": mgroup}
                 ms_sflog_s, _ = MpointStat.objects.get_or_create(**params_sflog_s, defaults=params_sflog_s)
                 ms_sflog_s.val = sum_dict_sflog_s["sum"]