update

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,