From 7f9526936f59ecf7afadffd98e30752d3ab37c0d Mon Sep 17 00:00:00 2001 From: DengBiao <2319963317@qq.com> Date: Tue, 18 Apr 2023 22:46:18 +0800 Subject: [PATCH] update --- consume/dou_shen_user_register_for_official_consume.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/consume/dou_shen_user_register_for_official_consume.go b/consume/dou_shen_user_register_for_official_consume.go index 77a507e..bd64524 100644 --- a/consume/dou_shen_user_register_for_official_consume.go +++ b/consume/dou_shen_user_register_for_official_consume.go @@ -14,6 +14,7 @@ import ( "errors" "fmt" "github.com/streadway/amqp" + "strconv" "time" ) @@ -78,7 +79,7 @@ func handleDouShenUserRegisterConsumeForOfficial(msgData []byte) error { if officialGroup == nil { groupName := "官方[1]群" //3、创建群 - resp, err := utils.GetLogicExtClient(cfg.ImLogicRpc.URL, cfg.ImLogicRpc.PORT).CreateGroup(utils.GetCtx("", "11", "4", msg.MasterId), &pb.CreateGroupReq{ + resp, err := utils.GetLogicExtClient(cfg.ImLogicRpc.URL, cfg.ImLogicRpc.PORT).CreateGroup(utils.GetCtx("", strconv.FormatInt(gimUser.Id, 10), "0", msg.MasterId), &pb.CreateGroupReq{ Name: groupName, AvatarUrl: "", Introduction: "官方群", @@ -92,7 +93,7 @@ func handleDouShenUserRegisterConsumeForOfficial(msgData []byte) error { now := time.Now() _, err = db.DouShenImGroupInsert(db.Db, &model.DouShenImGroup{ Kind: 1, - Uid: 21, + Uid: int(msg.Uid), GroupId: int(resp.GroupId), IsFull: 0, Name: groupName,