加入公排mq

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

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