This commit is contained in:
parent
9ee3119e61
commit
81d7ff3d69
|
@ -109,10 +109,12 @@ func InitNotifSender(_DefaultNotification *logic.Notification, _DefaultNotifBcst
|
|||
nids = append(nids, notification.GetId())
|
||||
|
||||
// 广播通知
|
||||
err = _DefaultNotifBcstCenter.BcstNotifs(ctx, nids, notification.GetObjType(), notification.ObjMids)
|
||||
if err != nil {
|
||||
logger.Error("通知广播失败:%v", err)
|
||||
continue
|
||||
if notification.GetPushTime() == consts.Notification_PushTime_Instant {
|
||||
err = _DefaultNotifBcstCenter.BcstNotifs(ctx, nids, notification.GetObjType(), notification.ObjMids)
|
||||
if err != nil {
|
||||
logger.Error("通知广播失败:%v", err)
|
||||
continue
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue