From 616ed7e8acab94ad982f2a1ba593317e73b78d59 Mon Sep 17 00:00:00 2001
From: shenjiachi <shenjiachi@fnuoos.com>
Date: Thu, 14 Nov 2024 19:29:22 +0800
Subject: [PATCH] update

---
 consume/egg_energy_fund_data_consume.go | 2 +-
 consume/init.go                         | 2 ++
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/consume/egg_energy_fund_data_consume.go b/consume/egg_energy_fund_data_consume.go
index b257b5e..2386474 100644
--- a/consume/egg_energy_fund_data_consume.go
+++ b/consume/egg_energy_fund_data_consume.go
@@ -42,7 +42,7 @@ func EggEnergyDealFundDataConsume(queue md.MqQueue) {
 	for {
 		res, ok = <-delivery
 		if ok == true {
-			err = handleEggEnergyStartLevelDividendConsume(res.Body)
+			err = handleEggEnergyDealFundDataConsume(res.Body)
 			if err != nil {
 				fmt.Println("EggEnergyDealFundDataConsume_ERR:::::", err.Error())
 				utils2.FilePutContents("EggEnergyDealFundDataConsume_ERR", utils2.SerializeStr(map[string]interface{}{
diff --git a/consume/init.go b/consume/init.go
index 6fcc1f1..82c78d5 100644
--- a/consume/init.go
+++ b/consume/init.go
@@ -18,6 +18,8 @@ func Init() {
 // 增加消费任务队列
 func initConsumes() {
 	jobs[consumeMd.EggEnergyStartLevelDividendFunName] = EggEnergyStartLevelDividendConsume
+	jobs[consumeMd.EggEnergyDealPlatformRevenueDataFunName] = EggEnergyDealPlatformRevenueDataConsume
+	jobs[consumeMd.EggEnergyDealFundDataFunName] = EggEnergyDealFundDataConsume
 }
 
 func Run() {