DengBiao 1 rok temu
rodzic
commit
1e07926e2f
5 zmienionych plików z 17 dodań i 16 usunięć
  1. +2
    -2
      consume/dou_shen_user_register_for_my_my_fans.go
  2. +1
    -1
      consume/dou_shen_user_register_for_my_my_recommender.go
  3. +1
    -1
      consume/dou_shen_user_register_for_official_consume.go
  4. +1
    -1
      consume/dou_shen_user_register_for_operation_center.go
  5. +12
    -11
      consume/md/consume_key.go

+ 2
- 2
consume/dou_shen_user_register_for_my_my_fans.go Wyświetl plik

@@ -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,


+ 1
- 1
consume/dou_shen_user_register_for_my_my_recommender.go Wyświetl plik

@@ -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)


+ 1
- 1
consume/dou_shen_user_register_for_official_consume.go Wyświetl plik

@@ -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)


+ 1
- 1
consume/dou_shen_user_register_for_operation_center.go Wyświetl plik

@@ -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)


+ 12
- 11
consume/md/consume_key.go Wyświetl plik

@@ -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",


Ładowanie…
Anuluj
Zapisz