Merge remote-tracking branch 'origin/master'

consume/dou_shen_user_register_for_my_my_fans.go

@@ -19,7 +19,7 @@ import (
 )
 
 func DouShenUserRegisterConsumeForMyFans(queue md.MqQueue) {
-	fmt.Println(">>>>>>>>>>>>>>>>>>>>>>>>")
+	fmt.Println(">>>>>>>>>>>>DouShenUserRegisterConsumeForMyFans>>>>>>>>>>>>")
 	ch, err := rabbit.Cfg.Pool.GetChannel()
 	if err != nil {
 		logx.Error(err)
@@ -72,7 +72,7 @@ func handleDouShenUserRegisterConsumeForMyFans(msgData []byte) error {
 		return errors.New("用户暂未注册im系统")
 	}
 
-	groupName := "我的直属粉丝【x】群"
+	groupName := gimUser.Nickname + "-粉丝[1]群"
 	//3、创建群
 	resp, err := utils.GetLogicExtClient(cfg.ImLogicRpc.URL, cfg.ImLogicRpc.PORT).CreateGroup(utils.GetCtx("", utils2.Int64ToStr(gimUser.Id), "", msg.MasterId), &pb.CreateGroupReq{
 		Name:         groupName,

consume/dou_shen_user_register_for_my_my_recommender.go

@@ -16,7 +16,7 @@ import (
 )
 
 func DouShenUserRegisterConsumeForMyRecommender(queue md.MqQueue) {
-	fmt.Println(">>>>>>>>>>>>>>>>>>>>>>>>")
+	fmt.Println(">>>>>>>>>>>>DouShenUserRegisterConsumeForMyRecommender>>>>>>>>>>>>")
 	ch, err := rabbit.Cfg.Pool.GetChannel()
 	if err != nil {
 		logx.Error(err)

consume/dou_shen_user_register_for_official_consume.go

@@ -18,7 +18,7 @@ import (
 )
 
 func DouShenUserRegisterConsumeForOfficial(queue md.MqQueue) {
-	fmt.Println(">>>>>>>>>>>>>>>>>>>>>>>>")
+	fmt.Println(">>>>>>>>>>>>DouShenUserRegisterConsumeForOfficial>>>>>>>>>>>>")
 	ch, err := rabbit.Cfg.Pool.GetChannel()
 	if err != nil {
 		logx.Error(err)

consume/dou_shen_user_register_for_operation_center.go

@@ -16,7 +16,7 @@ import (
 )
 
 func DouShenUserRegisterConsumeForOperationCenter(queue md.MqQueue) {
-	fmt.Println(">>>>>>>>>>>>>>>>>>>>>>>>")
+	fmt.Println(">>>>>>>>>>>>DouShenUserRegisterConsumeForOperationCenter>>>>>>>>>>>>")
 	ch, err := rabbit.Cfg.Pool.GetChannel()
 	if err != nil {
 		logx.Error(err)

consume/md/consume_key.go

@@ -65,32 +65,33 @@ var RabbitMqQueueKeyList = []*MqQueue{
 		BindKey:        "",
 		ConsumeFunName: "ZhiosFastReturnOrderRefund",
 	},
+
 	{
 		ExchangeName:   "zhios.doushen.user.register.exchange",
-		Name:           "zhios_doushen_user_register_official",
+		Name:           "zhios_doushen_user_register_my_fans",
 		Type:           DirectQueueType,
 		IsPersistent:   false,
-		RoutKey:        "official",
-		BindKey:        "official",
-		ConsumeFunName: "DouShenUserRegisterConsumeForOfficial",
+		RoutKey:        "my_fans",
+		BindKey:        "my_fans",
+		ConsumeFunName: "DouShenUserRegisterConsumeForMyFans",
 	},
 	{
 		ExchangeName:   "zhios.doushen.user.register.exchange",
 		Name:           "zhios_doushen_user_register_operation_center",
 		Type:           DirectQueueType,
 		IsPersistent:   false,
-		RoutKey:        "official",
-		BindKey:        "official",
-		ConsumeFunName: "DouShenUserRegisterConsumeForOfficial",
+		RoutKey:        "operation_center",
+		BindKey:        "operation_center",
+		ConsumeFunName: "DouShenUserRegisterConsumeForOperationCenter",
 	},
 	{
 		ExchangeName:   "zhios.doushen.user.register.exchange",
-		Name:           "zhios_doushen_user_register_official",
+		Name:           "zhios_doushen_user_register_my_recommender",
 		Type:           DirectQueueType,
 		IsPersistent:   false,
-		RoutKey:        "official",
-		BindKey:        "official",
-		ConsumeFunName: "DouShenUserRegisterConsumeForOfficial",
+		RoutKey:        "my_recommender",
+		BindKey:        "my_recommender",
+		ConsumeFunName: "DouShenUserRegisterConsumeForMyRecommender",
 	},
 	{
 		ExchangeName:   "zhios.doushen.user.register.exchange",