diff --git a/apps/enm/tasks.py b/apps/enm/tasks.py
index fa8712f5..a34f0616 100644
--- a/apps/enm/tasks.py
+++ b/apps/enm/tasks.py
@@ -536,9 +536,9 @@ def cal_enstat(type, sflogId, mgroupId, year, month, day, hour, year_s, month_s,
                         sum=Sum("pcoal_coal_consume")
                     )["sum"]
                 elif type == "month_s":
-                    enstat.pcoal_coal_consume = EnStat.objects.filter(type="sflog", mgroup=enstat.mgroup, year_s=year_s, month_s=month_s).aggregate(sum=Sum("pcoal_coal_consume"))["sum"]
+                    enstat.pcoal_coal_consume = EnStat.objects.filter(type="day_s", mgroup=enstat.mgroup, year_s=year_s, month_s=month_s).aggregate(sum=Sum("pcoal_coal_consume"))["sum"]
                 elif type == "year_s":
-                    enstat.pcoal_coal_consume = EnStat.objects.filter(type="sflog", mgroup=enstat.mgroup, year_s=year_s).aggregate(sum=Sum("pcoal_coal_consume"))["sum"]
+                    enstat.pcoal_coal_consume = EnStat.objects.filter(type="month_s", mgroup=enstat.mgroup, year_s=year_s).aggregate(sum=Sum("pcoal_coal_consume"))["sum"]
 
                 if enstat.pcoal_coal_consume is None:
                     enstat.pcoal_coal_consume = 0