|
|
|
@ -231,11 +231,7 @@ func (c *ConsumerHandler) Push2Group(ctx context.Context, groupID string, msg *s
|
|
|
|
|
log.ZDebug(ctx, "Get group msg from msg_transfer and push msg", "msg", msg.String(), "groupID", groupID)
|
|
|
|
|
defer func(duration time.Time) {
|
|
|
|
|
t := time.Since(duration)
|
|
|
|
|
if t.Seconds() > 1 {
|
|
|
|
|
log.ZWarn(ctx, "Get group msg from msg_transfer and push msg end", nil, "msg", msg.String(), "groupID", groupID, "time cost", t)
|
|
|
|
|
} else {
|
|
|
|
|
log.ZDebug(ctx, "Get group msg from msg_transfer and push msg end", "msg", msg.String(), "groupID", groupID, "time cost", t)
|
|
|
|
|
}
|
|
|
|
|
log.ZWarn(ctx, "Get group msg from msg_transfer and push msg end", nil, "msg", msg.String(), "groupID", groupID, "time cost", t)
|
|
|
|
|
}(time.Now())
|
|
|
|
|
var pushToUserIDs []string
|
|
|
|
|
if err = c.webhookBeforeGroupOnlinePush(ctx, &c.config.WebhooksConfig.BeforeGroupOnlinePush, groupID, msg,
|
|
|
|
|