wishpal_ironfan
/
service
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

by Robin at 20241202

This commit is contained in:
Robin 2024-12-02 19:10:39 +08:00
parent 376e151d32
commit ae5aa3eb87
2 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
app/mix/service/logic/notif_bcst.go
View File

@ -24,7 +24,8 @@ func NewNotifBcst(store *dao.Store) (a *NotifBcst) {
func (p *NotifBcst) OpCreate(ctx *gin.Context, notifBcst *dbstruct.NotifBcst) error {
notifBcst.Id = idgenerator.GenNotifBcstId()
// 只有批量推送的时候有可能碰撞，用obj_type防止碰撞
notifBcst.Id = idgenerator.GenNotifBcstId() + notifBcst.ObjType
notifBcst.Ct = time.Now().Unix()
notifBcst.Ut = time.Now().Unix()
notifBcst.DelFlag = consts.Exist

5
app/mix/service/notif_bcst_center.go
View File

@ -26,6 +26,11 @@ func NewNotifBcstCenter() *NotifBcstCenter {
// 对外接口
func (s *NotifBcstCenter) BcstNotifs(ctx *gin.Context, nids []int64, objType int64, objMids []int64) error {
if len(nids) == 0 || len(objMids) == 0 {
return nil
}
var err error
switch objType {
case consts.Notification_ObjType_AllStreamer: