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