update

consume/egg_canal_invite_user_nums_consume_test.go

@@ -0,0 +1,17 @@
+package consume
+
+import (
+	rule "code.fnuoos.com/EggPlanet/egg_system_rules.git/rule/egg_energy"
+	"code.fnuoos.com/go_rely_warehouse/zyos_go_es.git/es"
+	"fmt"
+	"testing"
+)
+
+func TestExistOrDefaultUserEggScore(t *testing.T) {
+	es.Init("http://123.57.140.192:9200/", "elastic", "fnuo123")
+	err := rule.ExistOrDefaultUserEggScore(2)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+}

consume/md/consume_key.go

@@ -169,7 +169,7 @@ var RabbitMqQueueKeyList = []*MqQueue{
 		Name:           "egg_canal_invite_user_nums_queue",
 		Type:           DirectQueueType,
 		IsPersistent:   false,
-		RoutKey:        "egg_canal_invite_user_nums",
+		RoutKey:        "user_relate",
 		BindKey:        "",
 		ConsumeFunName: "EggCanalInviteUserNumsConsume",
 	},
@@ -178,7 +178,7 @@ var RabbitMqQueueKeyList = []*MqQueue{
 		Name:           "egg_canal_violate_nums_queue",
 		Type:           DirectQueueType,
 		IsPersistent:   false,
-		RoutKey:        "egg_canal_violate_nums",
+		RoutKey:        "user_tag_records",
 		BindKey:        "",
 		ConsumeFunName: "EggCanalViolateNumsConsume",
 	},
@@ -205,7 +205,7 @@ var RabbitMqQueueKeyList = []*MqQueue{
 		Name:           "egg_canal_person_add_activity_value_queue",
 		Type:           DirectQueueType,
 		IsPersistent:   false,
-		RoutKey:        "egg_canal_person_add_activity_value",
+		RoutKey:        "egg_canal_user_virtual_coin_flow",
 		BindKey:        "",
 		ConsumeFunName: "EggCanalPersonAddActivityValueConsume",
 	},