You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
115 lines
3.6 KiB
115 lines
3.6 KiB
package dao |
|
|
|
import ( |
|
"context" |
|
"fmt" |
|
|
|
"go-common/app/admin/main/growup/model" |
|
|
|
"go-common/library/database/sql" |
|
"go-common/library/log" |
|
"go-common/library/xstr" |
|
) |
|
|
|
// TradeDao . r/w |
|
type TradeDao interface { |
|
AddGoods(c context.Context, fields string, values string) (int64, error) |
|
UpdateGoods(c context.Context, set string, where string, IDs []int64) (int64, error) |
|
GoodsCount(c context.Context, where string) (int64, error) |
|
GoodsList(c context.Context, where string, from, limit int) ([]*model.GoodsInfo, error) |
|
OrderList(c context.Context, where string, from, limit int) ([]*model.OrderInfo, error) |
|
OrderCount(c context.Context, where string) (int64, error) |
|
} |
|
|
|
const ( |
|
_addGoodsSQL = "INSERT INTO creative_goods(%s) VALUES %s" |
|
_updateGoodsSQL = "UPDATE creative_goods SET %s WHERE id in (%s)" |
|
_listGoodsSQL = "SELECT id,goods_type,ex_product_id,ex_resource_id,is_display,display_on_time,discount FROM creative_goods WHERE %s ORDER By id DESC LIMIT ?,?" |
|
_listOrderSQL = "SELECT mid, order_no, order_time, goods_id, goods_type, goods_name, goods_price, goods_cost FROM creative_order WHERE %s ORDER BY order_time DESC LIMIT ?,?" |
|
_countOrderSQL = "SELECT count(id) FROM creative_order WHERE %s" |
|
_countGoodsSQL = "SELECT count(id) FROM creative_goods WHERE %s" |
|
) |
|
|
|
// AddGoods . |
|
func (d *Dao) AddGoods(c context.Context, fields string, values string) (int64, error) { |
|
rows, err := d.rddb.Exec(c, fmt.Sprintf(_addGoodsSQL, fields, values)) |
|
if err != nil { |
|
log.Error("d.AddGoods db.Exec err(%v)", err) |
|
return 0, err |
|
} |
|
return rows.RowsAffected() |
|
} |
|
|
|
// UpdateGoods . |
|
func (d *Dao) UpdateGoods(c context.Context, set string, where string, IDs []int64) (int64, error) { |
|
s := _updateGoodsSQL |
|
if where != "" { |
|
s = s + " AND " + where |
|
} |
|
rows, err := d.rddb.Exec(c, fmt.Sprintf(s, set, xstr.JoinInts(IDs))) |
|
if err != nil { |
|
log.Error("d.UpdateGoods db.Exec err(%v)", err) |
|
return 0, err |
|
} |
|
return rows.RowsAffected() |
|
} |
|
|
|
// GoodsList . |
|
func (d *Dao) GoodsList(c context.Context, where string, from, limit int) (res []*model.GoodsInfo, err error) { |
|
res = make([]*model.GoodsInfo, 0) |
|
rows, err := d.rddb.Query(c, fmt.Sprintf(_listGoodsSQL, where), from, limit) |
|
if err != nil { |
|
log.Error("d.GoodsList db.Query err(%v)", err) |
|
return |
|
} |
|
defer rows.Close() |
|
for rows.Next() { |
|
m := new(model.GoodsInfo) |
|
if err = rows.Scan(&m.ID, &m.GoodsType, &m.ProductID, &m.ResourceID, &m.IsDisplay, &m.DisplayOnTime, &m.Discount); err != nil { |
|
log.Error("d.GoodsList rows.Scan err(%v)", err) |
|
return nil, err |
|
} |
|
res = append(res, m) |
|
} |
|
err = rows.Err() |
|
return |
|
} |
|
|
|
// GoodsCount . |
|
func (d *Dao) GoodsCount(c context.Context, where string) (total int64, err error) { |
|
err = d.rddb.QueryRow(c, fmt.Sprintf(_countGoodsSQL, where)).Scan(&total) |
|
if err == sql.ErrNoRows { |
|
err = nil |
|
} |
|
return |
|
} |
|
|
|
// OrderCount . |
|
func (d *Dao) OrderCount(c context.Context, where string) (total int64, err error) { |
|
err = d.rddb.QueryRow(c, fmt.Sprintf(_countOrderSQL, where)).Scan(&total) |
|
if err == sql.ErrNoRows { |
|
err = nil |
|
} |
|
return |
|
} |
|
|
|
// OrderList . |
|
func (d *Dao) OrderList(c context.Context, where string, from, limit int) (res []*model.OrderInfo, err error) { |
|
res = make([]*model.OrderInfo, 0) |
|
rows, err := d.rddb.Query(c, fmt.Sprintf(_listOrderSQL, where), from, limit) |
|
if err != nil { |
|
log.Error("d.OrderList db.Query err(%v)", err) |
|
return |
|
} |
|
defer rows.Close() |
|
for rows.Next() { |
|
v := new(model.OrderInfo) |
|
if err = rows.Scan(&v.MID, &v.OrderNo, &v.OrderTime, &v.GoodsID, &v.GoodsType, &v.GoodsName, &v.GoodsPrice, &v.GoodsCost); err != nil { |
|
log.Error("d.OrderList rows.Scan err(%v)", err) |
|
return |
|
} |
|
res = append(res, v) |
|
} |
|
err = rows.Err() |
|
return |
|
}
|
|
|