sendToGroup 发送给群
(pm meta.PushMessage)
| 54 | |
| 55 | // sendToGroup 发送给群 |
| 56 | func (p *postman) sendToGroup(pm meta.PushMessage) error { |
| 57 | var ids []*meta.PushID |
| 58 | |
| 59 | group, err := p.group.get(pm.Msg.Group) |
| 60 | if err != nil { |
| 61 | return errors.Trace(err) |
| 62 | } |
| 63 | |
| 64 | //向组中每个人添加消息 |
| 65 | for _, uid := range group.Users { |
| 66 | before, err := p.user.addMessage(uid, pm.Msg.ID) |
| 67 | if err != nil { |
| 68 | return errors.Trace(err) |
| 69 | } |
| 70 | ids = append(ids, &meta.PushID{Before: before, User: uid}) |
| 71 | } |
| 72 | |
| 73 | log.Debugf("send msg:%v, ids:%v", pm, ids) |
| 74 | return p.notice.Push(pm, ids...) |
| 75 | } |
| 76 | |
| 77 | // send 分发消息 |
| 78 | // 1.检查是否存在好友关系或者群成员 |
no test coverage detected