From c9ae0b9750efad8753798c8ea2a987836b45cb1b Mon Sep 17 00:00:00 2001 From: huangjiajun <582604932@qq.com> Date: Thu, 12 Dec 2024 22:53:08 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E5=85=A5=E5=85=AC=E6=8E=92mq?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/hdl/hdl_login.go | 2 +- app/hdl/hdl_user.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/app/hdl/hdl_login.go b/app/hdl/hdl_login.go index 78ceb71..4e6e1c0 100644 --- a/app/hdl/hdl_login.go +++ b/app/hdl/hdl_login.go @@ -418,7 +418,7 @@ func commReq(c *gin.Context, req md.RegisterReq) { return } defer ch.Release() - ch.Publish(md3.EggAppExchange, utils.SerializeStr(md3.AddPublicPlatoonUserRelationCommissionReq{RecommendUid: utils.Int64ToStr(parentUid), Uid: utils.Int64ToStr(user.Id)}), md3.EggRoutKeyForAddPublicPlatoonUserRelationCommission) + ch.Publish(md3.EggAppExchange, md3.AddPublicPlatoonUserRelationCommissionReq{RecommendUid: utils.Int64ToStr(parentUid), Uid: utils.Int64ToStr(user.Id)}, md3.EggRoutKeyForAddPublicPlatoonUserRelationCommission) } //TODO::推入mq处理 ch, err := rabbit.Cfg.Pool.GetChannel() diff --git a/app/hdl/hdl_user.go b/app/hdl/hdl_user.go index ec0aa2e..bd7fc0d 100644 --- a/app/hdl/hdl_user.go +++ b/app/hdl/hdl_user.go @@ -196,7 +196,7 @@ func UserBindParent(c *gin.Context) { return } defer ch.Release() - ch.Publish(md4.EggAppExchange, utils.SerializeStr(md4.AddPublicPlatoonUserRelationCommissionReq{RecommendUid: utils.Int64ToStr(ownUser.ParentUid), Uid: utils.Int64ToStr(ownUser.Id)}), md4.EggRoutKeyForAddPublicPlatoonUserRelationCommission) + ch.Publish(md4.EggAppExchange, md4.AddPublicPlatoonUserRelationCommissionReq{RecommendUid: utils.Int64ToStr(ownUser.ParentUid), Uid: utils.Int64ToStr(ownUser.Id)}, md4.EggRoutKeyForAddPublicPlatoonUserRelationCommission) } e.OutSuc(c, "success", nil) return