From 2d30d33c8905511a50f7f46e1f7999d9e7106180 Mon Sep 17 00:00:00 2001
From: dengbiao <dengbiao@fnuoos.com>
Date: Tue, 24 Dec 2024 11:57:26 +0800
Subject: [PATCH] update

---
 consume/egg_energy_team_assistance_consume.go | 3 +--
 consume/md/consume_key.go                     | 2 +-
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/consume/egg_energy_team_assistance_consume.go b/consume/egg_energy_team_assistance_consume.go
index 28f5865..0ada410 100644
--- a/consume/egg_energy_team_assistance_consume.go
+++ b/consume/egg_energy_team_assistance_consume.go
@@ -29,7 +29,7 @@ func EggEnergyTeamAssistanceConsume(queue md.MqQueue) {
 	//1、将自己绑定到交换机上
 	ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey)
 	//2、取出数据进行消费
-	ch.Qos(2)
+	ch.Qos(10)
 	delivery := ch.Consume(queue.Name, false)
 
 	egg_system_rules.Init(cfg.RedisAddr)
@@ -56,7 +56,6 @@ func EggEnergyTeamAssistanceConsume(queue md.MqQueue) {
 }
 
 func handleEggEnergyTeamAssistanceDataConsume(msgData []byte) error {
-	return nil
 	time.Sleep(time.Duration(10) * time.Millisecond) //休眠100毫秒
 	// 1.解析mq中queue的数据结构体
 	var msg *md2.EggEnergyTeamAssistanceReq
diff --git a/consume/md/consume_key.go b/consume/md/consume_key.go
index 9eac960..2e998b8 100644
--- a/consume/md/consume_key.go
+++ b/consume/md/consume_key.go
@@ -274,7 +274,7 @@ var RabbitMqQueueKeyList = []*MqQueue{
 	},
 	{
 		ExchangeName:   "egg.energy",
-		Name:           "egg_energy_team_assistance",
+		Name:           "egg_energy_team_assistance_back",
 		Type:           DirectQueueType,
 		IsPersistent:   false,
 		RoutKey:        "egg_energy_team_assistance",