diff --git a/internal/rpc/group/callback.go b/internal/rpc/group/callback.go index 28212c829..90dc63af0 100644 --- a/internal/rpc/group/callback.go +++ b/internal/rpc/group/callback.go @@ -20,6 +20,7 @@ func callbackBeforeCreateGroup(req *pbGroup.CreateGroupReq) cbApi.CommonCallback log.NewDebug(req.OperationID, utils.GetSelfFuncName(), req.String()) commonCallbackReq := &cbApi.CallbackBeforeCreateGroupReq{ CallbackCommand: constant.CallbackBeforeCreateGroupCommand, + OperationID: req.OperationID, GroupInfo: *req.GroupInfo, InitMemberList: req.InitMemberList, } @@ -88,6 +89,7 @@ func CallbackBeforeMemberJoinGroup(operationID string, groupMember *db.GroupMemb log.NewDebug(operationID, "args: ", *groupMember) callbackReq := cbApi.CallbackBeforeMemberJoinGroupReq{ CallbackCommand: constant.CallbackBeforeMemberJoinGroupCommand, + OperationID: operationID, GroupID: groupMember.GroupID, UserID: groupMember.UserID, Ex: groupMember.Ex, diff --git a/pkg/call_back_struct/group.go b/pkg/call_back_struct/group.go index 93651b34f..33a18d9c0 100644 --- a/pkg/call_back_struct/group.go +++ b/pkg/call_back_struct/group.go @@ -7,6 +7,7 @@ import ( type CallbackBeforeCreateGroupReq struct { CallbackCommand string `json:"callbackCommand"` + OperationID string `json:"operationID"` commonPb.GroupInfo InitMemberList []*group.GroupAddMemberInfo `json:"initMemberList"` } @@ -30,6 +31,7 @@ type CallbackBeforeCreateGroupResp struct { type CallbackBeforeMemberJoinGroupReq struct { CallbackCommand string `json:"callbackCommand"` + OperationID string `json:"operationID"` GroupID string `json:"groupID"` UserID string `json:"userID"` Ex string `json:"ex"`