mtfosbot/model/opay_donate_list.go

61 lines
1.5 KiB
Go
Raw Permalink Normal View History

2018-09-07 08:33:37 +00:00
package model
2018-09-17 13:46:59 +00:00
import (
2018-09-18 15:54:36 +00:00
"database/sql"
2018-09-17 13:46:59 +00:00
"time"
"github.com/jmoiron/sqlx"
)
2018-09-07 08:33:37 +00:00
// OpayDonateList - struct
type OpayDonateList struct {
OpayID string `db:"opayid" cc:"opayid"`
DonateID string `db:"donate_id" cc:"donate_id"`
Price int `db:"price" cc:"price"`
Text string `db:"text" cc:"text"`
2018-09-17 13:46:59 +00:00
Name string `db:"name" cc:"name"`
2018-09-07 08:33:37 +00:00
Ctime time.Time `db:"ctime" cc:"ctime"`
Mtime time.Time `db:"mtime" cc:"ctime"`
}
2018-09-17 13:46:59 +00:00
2018-09-18 15:54:36 +00:00
// SumChannelDonatePriceSinceTime -
func SumChannelDonatePriceSinceTime(twitch string, t time.Time) (i int, err error) {
query := `select sum(list.price) as total from "public"."opay_donate_list" list
left join "public"."twitch_channel" tw
on tw.opayid = list.opayid
where
tw.opayid != ''
and tw.id = $1
and list.ctime >= $2
group by list.opayid`
row := x.QueryRowx(query, twitch, t)
err = row.Scan(&i)
if err == sql.ErrNoRows {
return 0, nil
}
if err != nil {
return 0, err
}
return
}
2018-09-17 13:46:59 +00:00
// GetDonateListWithIDs -
func GetDonateListWithIDs(ids []string) (ls []*OpayDonateList, err error) {
if len(ids) == 0 {
return
}
s, i, err := sqlx.In(`select * from "public"."opay_donate_list" where "donate_id" in (?)`, ids)
if err != nil {
return
}
s = x.Rebind(s)
err = x.Select(&ls, s, i...)
return
}
// InsertData -
func (p *OpayDonateList) InsertData() (err error) {
_, err = x.NamedExec(`insert into "public"."opay_donate_list" ("opayid", "donate_id", "price", "text", "name") values (:opayid, :donate_id, :price, :text, :name)`, p)
return
}