|
|
|
@ -93,7 +93,7 @@ func (c *ConsumerHandler) handleMs2PsChat(ctx context.Context, msg []byte) {
|
|
|
|
|
nowSec := timeutil.GetCurrentTimestampBySecond()
|
|
|
|
|
|
|
|
|
|
if nowSec-sec > 10 {
|
|
|
|
|
log.ZWarn(ctx, "ignore push msg", nil, "msg", pbData.String(), "sec", sec, "nowSec", nowSec, "nowSec-sec", nowSec-sec)
|
|
|
|
|
log.ZWarn(ctx, "long time push msg", nil, "msg", pbData.String(), "sec", sec, "nowSec", nowSec, "nowSec-sec", nowSec-sec)
|
|
|
|
|
}
|
|
|
|
|
var err error
|
|
|
|
|
switch msgFromMQ.MsgData.SessionType {
|
|
|
|
|