|
|
|
@ -831,7 +831,8 @@ func (rpc *rpcChat) sendMsgToGroupOptimization(list []string, groupPB *pbChat.Se
|
|
|
|
|
isSend := modifyMessageByUserMessageReceiveOpt(v, groupPB.MsgData.GroupID, constant.GroupChatType, groupPB)
|
|
|
|
|
if isSend {
|
|
|
|
|
if v == "" || groupPB.MsgData.SendID == "" {
|
|
|
|
|
panic(groupPB.OperationID)
|
|
|
|
|
log.Error(msgToMQGroup.OperationID, "sendMsgToGroupOptimization userID nil ", msgToMQGroup.String())
|
|
|
|
|
continue
|
|
|
|
|
}
|
|
|
|
|
err := rpc.sendMsgToKafka(&msgToMQGroup, v, status)
|
|
|
|
|
if err != nil {
|
|
|
|
|