diff --git a/app/hdl/institutional_management/egg_energy/hdl_basic.go b/app/hdl/institutional_management/egg_energy/hdl_basic.go
index 3b06e67..71be716 100644
--- a/app/hdl/institutional_management/egg_energy/hdl_basic.go
+++ b/app/hdl/institutional_management/egg_energy/hdl_basic.go
@@ -1,14 +1,17 @@
 package egg_energy
 
 import (
+	"applet/app/cfg"
 	"applet/app/db"
 	"applet/app/e"
 	md "applet/app/md/institutional_management/egg_energy"
 	"applet/app/utils"
 	"code.fnuoos.com/EggPlanet/egg_models.git/src/implement"
 	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	rule "code.fnuoos.com/EggPlanet/egg_system_rules.git"
 	"code.fnuoos.com/EggPlanet/egg_system_rules.git/rule/egg_energy/enum"
 	md2 "code.fnuoos.com/EggPlanet/egg_system_rules.git/rule/egg_energy/md"
+	"code.fnuoos.com/EggPlanet/egg_system_rules.git/rule/egg_energy/svc"
 	"errors"
 	"fmt"
 	"github.com/gin-gonic/gin"
@@ -524,8 +527,18 @@ func UpdateEggEnergyCoreData(c *gin.Context) {
 		return
 	}
 
-	coreDataDb := implement.NewEggEnergyCoreDataDb(db.Db)
-	session := db.Db.NewSession()
+	engine := db.Db
+	coreDataDb := implement.NewEggEnergyCoreDataDb(engine)
+	rule.Init(cfg.RedisAddr)
+	_, cb, err := svc.GetEggEnergyCoreData(engine)
+	if err != nil {
+		return
+	}
+	if cb != nil {
+		defer cb() // 释放锁
+	}
+
+	session := engine.NewSession()
 	defer session.Close()
 
 	m := model.EggEnergyCoreData{