1234567891011121314151617181920212223242526272829303132 |
- package archive
- import (
- "context"
- "fmt"
- "go-common/library/log"
- )
- const (
- _consumerOnlineSQL = "SELECT uid FROM task_consumer WHERE uid IN (%s) AND state=1"
- )
- //ConsumerOnline get online task_consumer
- func (d *Dao) ConsumerOnline(c context.Context, uids string) (ids []int64, err error) {
- rows, err := d.db.Query(c, fmt.Sprintf(_consumerOnlineSQL, uids))
- if err != nil {
- log.Error("d.db.Query(%s, %v) error(%v)", _consumerOnlineSQL, uids, err)
- return
- }
- defer rows.Close()
- for rows.Next() {
- var id int64
- if err = rows.Scan(&id); err != nil {
- log.Error("rows.Scan error(%v)", err)
- return
- }
- ids = append(ids, id)
- }
- return
- }
|