获取所有订阅
()
| 195 | |
| 196 | // 获取所有订阅 |
| 197 | func (d *db) getAllSubscribes() (subs []serverSubscribe, err error) { |
| 198 | if d == nil { |
| 199 | return nil, errDBConn |
| 200 | } |
| 201 | subs = []serverSubscribe{} |
| 202 | if err = d.sdb.Find(&subs).Error; err != nil { |
| 203 | // logrus.Errorln(logPrefix+"getAllSubscribes ERROR: ", err) |
| 204 | return |
| 205 | } |
| 206 | return |
| 207 | } |
| 208 | |
| 209 | // 获取渠道对应的订阅列表 |
| 210 | func (d *db) getSubscribesByTarget(targetID, targetType int64) (subs []serverSubscribe, err error) { |