update

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{}{

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() {