diff --git a/apps/wpm/tasks.py b/apps/wpm/tasks.py
index 83229a53..c19fc430 100644
--- a/apps/wpm/tasks.py
+++ b/apps/wpm/tasks.py
@@ -12,7 +12,7 @@ from django.db.models import Sum
 from apps.wpm.services import make_sflogs
 from apps.wpm.models import SfLog, StLog, StSfLog
 from django.utils.timezone import localtime
-
+from django.db.models import F
 
 @shared_task(base=CustomTask)
 def make_sflogs_simple(days=2):
@@ -91,4 +91,13 @@ def cal_shut_hour(stlogId: str):
 
 
 @shared_task(base=CustomTask)
-def cal_enstat_when_pcoal_val_change():
+def cal_enstat_when_pcoal_val_change(sflogId):
+    from apps.enm.models import EnStat
+    sflog = SfLog.objects.get(id=sflogId)
+    mgroup = sflog.mgroup
+    pcoal_val = sflog.pcoal_val
+    year_s, month_s, day_s = sflog.get_ymd
+    enstats = EnStat.objects.filter(mgroup__name='回转窑')
+    for enstat in enstats:
+        if type in ['hour_s', 'sflog', 'day_s']:
+            pass