Documentation ¶
Index ¶
- Constants
- func LogX(ctx context.Context, args interface{}, res interface{}, err error, ld ...log.D)
- type Dao
- func (d *Dao) AddCacheGetSKUs(c context.Context, skuMap map[int64]*model.SKUStock, withNewStock bool) (err error)
- func (d *Dao) AddCacheOrderCount(ctx context.Context, req *model.OrderMainQuerier, res int64) (err error)
- func (d *Dao) AddCacheOrderDetails(ctx context.Context, orders map[int64]*model.OrderDetail) (err error)
- func (d *Dao) AddCacheOrderPayCharges(ctx context.Context, chs map[int64]*model.OrderPayCharge) (err error)
- func (d *Dao) AddCacheOrderSKUs(ctx context.Context, skus map[int64][]*model.OrderSKU) (err error)
- func (d *Dao) AddCacheOrders(ctx context.Context, req *model.OrderMainQuerier, res []*model.OrderMain) (err error)
- func (d *Dao) AddCachePromo(c context.Context, promoID int64, promo *model.Promotion) (err error)
- func (d *Dao) AddCachePromoGroup(c context.Context, groupID int64, group *model.PromotionGroup) (err error)
- func (d *Dao) AddCachePromoOrder(c context.Context, orderID int64, promoOrder *model.PromotionOrder) (err error)
- func (d *Dao) AddCachePromoOrders(c context.Context, groupID int64, promoOrders []*model.PromotionOrder) (err error)
- func (d *Dao) AddCacheSkuByItemID(c context.Context, itemID int64, stocks map[string]*model.SKUStock) (err error)
- func (d *Dao) AddCacheStocks(c context.Context, stocks map[int64]int64, isLocked bool) (err error)
- func (d *Dao) AddCacheTicketSend(c context.Context, tsMap map[int64]*model.TicketSend, TIDType string) (err error)
- func (d *Dao) AddCacheTicketsByID(c context.Context, tickets map[int64]*model.Ticket) (err error)
- func (d *Dao) AddCacheTicketsByOrderID(c context.Context, orderID int64, tickets []*model.Ticket) (err error)
- func (d *Dao) AddCacheTicketsByScreen(c context.Context, screenID int64, tickets []*model.Ticket, UID int64) (err error)
- func (d *Dao) AddOrderLog(c context.Context, oi *v1.OrderLog) (cnt int64, err error)
- func (d *Dao) AddPromoGroup(c context.Context, promoID int64, groupID int64, uid int64, orderCount int64, ...) (id int64, err error)
- func (d *Dao) AddPromoOrder(c context.Context, promoID int64, groupID int64, orderID int64, isMaster int16, ...) (id int64, err error)
- func (d *Dao) AddStockLog()
- func (d *Dao) BeginTx(c context.Context) (conn *sql.Tx, err error)
- func (d *Dao) CacheGetSKUs(c context.Context, skuIds []int64, withNewStock bool) (skuMap map[int64]*model.SKUStock, err error)
- func (d *Dao) CacheOrderCount(ctx context.Context, req *model.OrderMainQuerier) (cnt int64, err error)
- func (d *Dao) CacheOrderDetails(ctx context.Context, oids []int64) (orders map[int64]*model.OrderDetail, err error)
- func (d *Dao) CacheOrderPayCharges(ctx context.Context, oids []int64) (chs map[int64]*model.OrderPayCharge, err error)
- func (d *Dao) CacheOrderSKUs(ctx context.Context, oids []int64) (skus map[int64][]*model.OrderSKU, err error)
- func (d *Dao) CacheOrders(ctx context.Context, req *model.OrderMainQuerier) (orders []*model.OrderMain, err error)
- func (d *Dao) CachePromo(c context.Context, promoID int64) (res *model.Promotion, err error)
- func (d *Dao) CachePromoGroup(c context.Context, groupID int64) (res *model.PromotionGroup, err error)
- func (d *Dao) CachePromoOrder(c context.Context, orderID int64) (res *model.PromotionOrder, err error)
- func (d *Dao) CachePromoOrders(c context.Context, groupID int64) (res []*model.PromotionOrder, err error)
- func (d *Dao) CacheSkuByItemID(c context.Context, itemID int64) (stocks map[string]*model.SKUStock, err error)
- func (d *Dao) CacheStocks(c context.Context, keys []int64, isLocked bool) (res map[int64]int64, err error)
- func (d *Dao) CacheTicketSend(c context.Context, IDs []int64, TIDType string) (res map[int64]*model.TicketSend, err error)
- func (d *Dao) CacheTicketsByID(c context.Context, ticketID []int64) (res map[int64]*model.Ticket, err error)
- func (d *Dao) CacheTicketsByOrderID(c context.Context, orderID int64) (res []*model.Ticket, err error)
- func (d *Dao) CacheTicketsByScreen(c context.Context, screenID int64, UID int64) (res []*model.Ticket, err error)
- func (d *Dao) Close() (err error)
- func (d *Dao) CreatePromo(c context.Context, promo *model.Promotion) (id int64, err error)
- func (d *Dao) DatabusPub(ctx context.Context, action string, data interface{}) error
- func (d *Dao) DelCacheOrders(ctx context.Context, req *model.OrderMainQuerier)
- func (d *Dao) DelCachePromo(c context.Context, promoID int64)
- func (d *Dao) DelCachePromoGroup(c context.Context, groupID int64)
- func (d *Dao) DelCachePromoOrder(c context.Context, orderID int64)
- func (d *Dao) DelCachePromoOrders(c context.Context, groupID int64)
- func (d *Dao) DelCacheSku(c context.Context, skuID int64) (err error)
- func (d *Dao) DelTicketCache(c context.Context, tickets ...*model.Ticket) (err error)
- func (d *Dao) GetOrder(c context.Context, oid uint64) (res []*model.OrderInfo, err error)
- func (d *Dao) GetOrderLogCnt(c context.Context, OID int64) (cnt int64, err error)
- func (d *Dao) GetOrderLogList(c context.Context, OID int64, index int64, size int64, orderBy string) (res []*v1.OrderLog, err error)
- func (d *Dao) GetPromoList(c context.Context, where string, index int64, size int64) (res []*model.Promotion, err error)
- func (d *Dao) GetSKUs(c context.Context, keys []int64, withNewStock bool) (res map[int64]*model.SKUStock, err error)
- func (d *Dao) GetUserCards(ctx context.Context, mids []int64) (*acc.CardsReply, error)
- func (d *Dao) GetUserGroupDoing(c context.Context, promoID int64, uid int64, status int16) (res *model.PromotionGroup, err error)
- func (d *Dao) GroupOrdersByStatus(c context.Context, groupID int64, status int16) (res []*model.PromotionOrder, err error)
- func (d *Dao) HasOrder(c context.Context, oi *model.DistOrderArg) (has bool, err error)
- func (d *Dao) HasPromoOfSKU(c context.Context, skuID int64, beginTime int64, endTime int64) (num int64, err error)
- func (d *Dao) InsertOrder(c context.Context, oi *model.DistOrderArg) (lastID int64, err error)
- func (d *Dao) ItemBillInfo(ctx context.Context, itemIDs []int64, scIDs []int64, tkIDs []int64) (*itemv1.BillReply, error)
- func (d *Dao) OperatePromo(c context.Context, promoID int64, fromStatus int16, toStatus int16) (num int64, err error)
- func (d *Dao) OrderCount(c context.Context, id *model.OrderMainQuerier) (res int64, err error)
- func (d *Dao) OrderDetails(c context.Context, keys []int64) (res map[int64]*model.OrderDetail, err error)
- func (d *Dao) OrderID(ctx context.Context, n int) ([]int64, error)
- func (d *Dao) OrderPayCharges(c context.Context, keys []int64) (res map[int64]*model.OrderPayCharge, err error)
- func (d *Dao) OrderSKUs(c context.Context, keys []int64) (res map[int64][]*model.OrderSKU, err error)
- func (d *Dao) Orders(c context.Context, id *model.OrderMainQuerier) (res []*model.OrderMain, err error)
- func (d *Dao) Ping(c context.Context) (err error)
- func (d *Dao) Promo(c context.Context, id int64) (res *model.Promotion, err error)
- func (d *Dao) PromoGroup(c context.Context, id int64) (res *model.PromotionGroup, err error)
- func (d *Dao) PromoOrder(c context.Context, id int64) (res *model.PromotionOrder, err error)
- func (d *Dao) PromoOrderByStatus(c context.Context, promoID int64, groupID int64, uid int64, status int16) (res *model.PromotionOrder, err error)
- func (d *Dao) PromoOrderDoing(c context.Context, promoID int64, groupID int64, uid int64) (res *model.PromotionOrder, err error)
- func (d *Dao) PromoOrders(c context.Context, id int64) (res []*model.PromotionOrder, err error)
- func (d *Dao) RawBoughtCount(ctx context.Context, uid string, itemID int64, skuIDs []int64) (cnt int64, err error)
- func (d *Dao) RawGetSKUs(c context.Context, skuIds []int64, withNewStock bool) (skuMap map[int64]*model.SKUStock, err error)
- func (d *Dao) RawGetSettleOrders(ctx context.Context, bt time.Time, et time.Time, id int64, size int) (res *model.SettleOrders, offset int64, err error)
- func (d *Dao) RawGetSettleRefunds(ctx context.Context, bt time.Time, et time.Time, id int64, size int) (res *model.SettleOrders, offset int64, err error)
- func (d *Dao) RawOrderCount(ctx context.Context, req *model.OrderMainQuerier) (cnt int64, err error)
- func (d *Dao) RawOrderDetails(ctx context.Context, oids []int64) (orders map[int64]*model.OrderDetail, err error)
- func (d *Dao) RawOrderPayCharges(ctx context.Context, oids []int64) (chs map[int64]*model.OrderPayCharge, err error)
- func (d *Dao) RawOrderSKUs(ctx context.Context, oids []int64) (skus map[int64][]*model.OrderSKU, err error)
- func (d *Dao) RawOrders(ctx context.Context, req *model.OrderMainQuerier) (orders []*model.OrderMain, err error)
- func (d *Dao) RawPromo(c context.Context, promoID int64) (res *model.Promotion, err error)
- func (d *Dao) RawPromoGroup(c context.Context, groupID int64) (res *model.PromotionGroup, err error)
- func (d *Dao) RawPromoOrder(c context.Context, orderID int64) (res *model.PromotionOrder, err error)
- func (d *Dao) RawPromoOrders(c context.Context, groupID int64) (res []*model.PromotionOrder, err error)
- func (d *Dao) RawSkuByItemID(c context.Context, itemID int64) (stocks map[string]*model.SKUStock, err error)
- func (d *Dao) RawSkuByItemSpecs(c context.Context, itemID int64, specs string) (stock *model.SKUStock, err error)
- func (d *Dao) RawStocks(c context.Context, keys []int64, isLocked bool) (res map[int64]int64, err error)
- func (d *Dao) RawTicketSend(c context.Context, IDs []int64, TIDType string) (res map[int64]*model.TicketSend, err error)
- func (d *Dao) RawTicketsByID(c context.Context, ticketID []int64) (res map[int64]*model.Ticket, err error)
- func (d *Dao) RawTicketsByOrderID(c context.Context, orderID int64) (res []*model.Ticket, err error)
- func (d *Dao) RawTicketsByScreen(c context.Context, screenID int64, UID int64) (res []*model.Ticket, err error)
- func (d *Dao) RedisDecr(c context.Context, key string, num int) (err error)
- func (d *Dao) RedisDecrExist(c context.Context, key string, num int64) (err error)
- func (d *Dao) RedisDel(c context.Context, key ...interface{}) (err error)
- func (d *Dao) RedisSetnx(c context.Context, key string, val interface{}, ttl int64) (err error)
- func (d *Dao) SkuByItemID(c context.Context, id int64) (res map[string]*model.SKUStock, err error)
- func (d *Dao) SkuByItemSpecs(c context.Context, itemID int64, specs string) (stock *model.SKUStock, err error)
- func (d *Dao) SkuItemCacheDel(c context.Context, itemID int64) (err error)
- func (d *Dao) Stock(c context.Context, skuID int64) (stock *model.SKUStock, err error)
- func (d *Dao) StockCacheDecr(c context.Context, skuID int64, total int64) (err error)
- func (d *Dao) StockCacheDel(c context.Context, skuID int64) (err error)
- func (d *Dao) StockDecr(c context.Context, skuID int64, num int64) (affected int64, err error)
- func (d *Dao) StockLock(c context.Context, skuID int64, cnt int64) (err error)
- func (d *Dao) StockLockedCacheDecr(c context.Context, skuID int64, total int64) (err error)
- func (d *Dao) StockLogs(c context.Context, opType int16, srcID int64, skuIDs ...int64) (stockLogs []*model.SKUStockLog, err error)
- func (d *Dao) Stocks(c context.Context, keys []int64, isLocked bool) (res map[int64]int64, err error)
- func (d *Dao) TicketSend(c context.Context, keys []int64, TIDType string) (res map[int64]*model.TicketSend, err error)
- func (d *Dao) TicketsByID(c context.Context, keys []int64) (res map[int64]*model.Ticket, err error)
- func (d *Dao) TicketsByOrderID(c context.Context, id int64) (res []*model.Ticket, err error)
- func (d *Dao) TicketsByScreen(c context.Context, id int64, UID int64) (res []*model.Ticket, err error)
- func (d *Dao) TxAddPromoGroup(c context.Context, tx *xsql.Tx, promoID int64, groupID int64, uid int64, ...) (id int64, err error)
- func (d *Dao) TxAddPromoOrder(c context.Context, tx *xsql.Tx, promoID int64, groupID int64, orderID int64, ...) (id int64, err error)
- func (d *Dao) TxAddStockInsert(tx *xsql.Tx, stocks ...*model.SKUStock) (affected int64, err error)
- func (d *Dao) TxAddStockLog(tx *xsql.Tx, stockLogs ...*model.SKUStockLog) (err error)
- func (d *Dao) TxInsertOrderDetails(tx *xsql.Tx, orders []*model.OrderDetail) (cnt int64, err error)
- func (d *Dao) TxInsertOrderSKUs(tx *xsql.Tx, orders []*model.OrderSKU) (cnt int64, err error)
- func (d *Dao) TxInsertOrders(tx *xsql.Tx, orders []*model.OrderMain) (cnt int64, err error)
- func (d *Dao) TxStockDecr(tx *xsql.Tx, skuID int64, num int64) (affected int64, err error)
- func (d *Dao) TxStockIncr(tx *xsql.Tx, skuID int64, count int64) (affected int64, err error)
- func (d *Dao) TxStockLock(tx *xsql.Tx, skuID int64, cnt int64) (affected int64, err error)
- func (d *Dao) TxStockLockedDecr(tx *xsql.Tx, skuID int64, count int64) (affected int64, err error)
- func (d *Dao) TxStockLogRollBack(tx *xsql.Tx, stockLogID int64) (affected int64, err error)
- func (d *Dao) TxStockReset(tx *xsql.Tx, stock *model.SKUStock) (affected int64, err error)
- func (d *Dao) TxStockUnlock(tx *xsql.Tx, skuID int64, count int64) (affected int64, err error)
- func (d *Dao) TxUpdateGroupOrderCount(c context.Context, tx *xsql.Tx, step int64, groupID int64, skuCount int64) (number int64, err error)
- func (d *Dao) TxUpdateGroupStatus(c context.Context, tx *xsql.Tx, groupID int64, oldStatus int16, ...) (number int64, err error)
- func (d *Dao) TxUpdatePromoBuyerCount(c context.Context, tx *xsql.Tx, promoID int64, count int64) (number int64, err error)
- func (d *Dao) TxUpdatePromoOrderGroupIDAndStatus(c context.Context, tx *xsql.Tx, orderID int64, groupID int64, status int16) (number int64, err error)
- func (d *Dao) TxUpdatePromoOrderStatus(c context.Context, tx *xsql.Tx, orderID int64, status int16) (number int64, err error)
- func (d *Dao) UpdateDetailBuyer(c context.Context, req *rpc.UpBuyerRequest) (num int64, err error)
- func (d *Dao) UpdateDetailDelivery(c context.Context, arg *_type.OrderDeliver, orderID int64) (num int64, err error)
- func (d *Dao) UpdateGroupStatusAndOrderCount(c context.Context, groupID int64, step int64, oldStatus int16, newStatus int16) (number int64, err error)
- func (d *Dao) UpdatePromo(c context.Context, arg *model.Promotion) (num int64, err error)
- func (d *Dao) UpdatePromoOrderStatus(c context.Context, orderID int64, status int16) (number int64, err error)
- func (d *Dao) UpdateTicketStatus(c context.Context, status int16, ticketID ...int64) (err error)
Constants ¶
const ( DefaultOrderPSize = 20 //默认每页数量 DefaultOrderOrderBy = "id desc" //默认排序 )
订单相关常量
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Dao ¶
type Dao struct {
// contains filtered or unexported fields
}
Dao 数据操作层结构体
func (*Dao) AddCacheGetSKUs ¶
func (d *Dao) AddCacheGetSKUs(c context.Context, skuMap map[int64]*model.SKUStock, withNewStock bool) (err error)
AddCacheGetSKUs .
func (*Dao) AddCacheOrderCount ¶
func (d *Dao) AddCacheOrderCount(ctx context.Context, req *model.OrderMainQuerier, res int64) (err error)
AddCacheOrderCount 设置订单数目缓存
func (*Dao) AddCacheOrderDetails ¶
func (d *Dao) AddCacheOrderDetails(ctx context.Context, orders map[int64]*model.OrderDetail) (err error)
AddCacheOrderDetails 增加订单详细缓存
func (*Dao) AddCacheOrderPayCharges ¶
func (d *Dao) AddCacheOrderPayCharges(ctx context.Context, chs map[int64]*model.OrderPayCharge) (err error)
AddCacheOrderPayCharges 增加订单流水缓存
func (*Dao) AddCacheOrderSKUs ¶
AddCacheOrderSKUs 增加订单sku缓存
func (*Dao) AddCacheOrders ¶
func (d *Dao) AddCacheOrders(ctx context.Context, req *model.OrderMainQuerier, res []*model.OrderMain) (err error)
AddCacheOrders 设置订单基础信息缓存
func (*Dao) AddCachePromo ¶
AddCachePromo add promo info into cache
func (*Dao) AddCachePromoGroup ¶
func (d *Dao) AddCachePromoGroup(c context.Context, groupID int64, group *model.PromotionGroup) (err error)
AddCachePromoGroup add promo group info into cache
func (*Dao) AddCachePromoOrder ¶
func (d *Dao) AddCachePromoOrder(c context.Context, orderID int64, promoOrder *model.PromotionOrder) (err error)
AddCachePromoOrder add promo order info into cache
func (*Dao) AddCachePromoOrders ¶
func (d *Dao) AddCachePromoOrders(c context.Context, groupID int64, promoOrders []*model.PromotionOrder) (err error)
AddCachePromoOrders add promo orders info into cache
func (*Dao) AddCacheSkuByItemID ¶
func (d *Dao) AddCacheSkuByItemID(c context.Context, itemID int64, stocks map[string]*model.SKUStock) (err error)
AddCacheSkuByItemID 添加 itemId => sku 缓存
func (*Dao) AddCacheStocks ¶
AddCacheStocks skuID => stock 加入缓存
func (*Dao) AddCacheTicketSend ¶
func (d *Dao) AddCacheTicketSend(c context.Context, tsMap map[int64]*model.TicketSend, TIDType string) (err error)
AddCacheTicketSend .
func (*Dao) AddCacheTicketsByID ¶
AddCacheTicketsByID .
func (*Dao) AddCacheTicketsByOrderID ¶
func (d *Dao) AddCacheTicketsByOrderID(c context.Context, orderID int64, tickets []*model.Ticket) (err error)
AddCacheTicketsByOrderID 通过 order_id 获取 tickets 写缓存
func (*Dao) AddCacheTicketsByScreen ¶
func (d *Dao) AddCacheTicketsByScreen(c context.Context, screenID int64, tickets []*model.Ticket, UID int64) (err error)
AddCacheTicketsByScreen 通过 screen_id user_id 获取 tickets
func (*Dao) AddOrderLog ¶
AddOrderLog 添加订单日志
func (*Dao) AddPromoGroup ¶
func (d *Dao) AddPromoGroup(c context.Context, promoID int64, groupID int64, uid int64, orderCount int64, status int16, expireAt int64) (id int64, err error)
AddPromoGroup add promo group into db
func (*Dao) AddPromoOrder ¶
func (d *Dao) AddPromoOrder(c context.Context, promoID int64, groupID int64, orderID int64, isMaster int16, uid int64, status int16, skuID int64, ctime int64) (id int64, err error)
AddPromoOrder create user promo order
func (*Dao) CacheGetSKUs ¶
func (d *Dao) CacheGetSKUs(c context.Context, skuIds []int64, withNewStock bool) (skuMap map[int64]*model.SKUStock, err error)
CacheGetSKUs 根据 skuID 获取 sku withNewStock 是否获取最新库存信息
func (*Dao) CacheOrderCount ¶
func (d *Dao) CacheOrderCount(ctx context.Context, req *model.OrderMainQuerier) (cnt int64, err error)
CacheOrderCount 从缓存获取订单数目
func (*Dao) CacheOrderDetails ¶
func (d *Dao) CacheOrderDetails(ctx context.Context, oids []int64) (orders map[int64]*model.OrderDetail, err error)
CacheOrderDetails 从缓存获取订单详细
func (*Dao) CacheOrderPayCharges ¶
func (d *Dao) CacheOrderPayCharges(ctx context.Context, oids []int64) (chs map[int64]*model.OrderPayCharge, err error)
CacheOrderPayCharges 从缓存获取订单流水
func (*Dao) CacheOrderSKUs ¶
func (d *Dao) CacheOrderSKUs(ctx context.Context, oids []int64) (skus map[int64][]*model.OrderSKU, err error)
CacheOrderSKUs 获取订单sku缓存
func (*Dao) CacheOrders ¶
func (d *Dao) CacheOrders(ctx context.Context, req *model.OrderMainQuerier) (orders []*model.OrderMain, err error)
CacheOrders 从缓存获取订单基础信息
func (*Dao) CachePromo ¶
CachePromo get promo info from cache
func (*Dao) CachePromoGroup ¶
func (d *Dao) CachePromoGroup(c context.Context, groupID int64) (res *model.PromotionGroup, err error)
CachePromoGroup get promo group info from cache
func (*Dao) CachePromoOrder ¶
func (d *Dao) CachePromoOrder(c context.Context, orderID int64) (res *model.PromotionOrder, err error)
CachePromoOrder get promo order info from cache
func (*Dao) CachePromoOrders ¶
func (d *Dao) CachePromoOrders(c context.Context, groupID int64) (res []*model.PromotionOrder, err error)
CachePromoOrders get promo orders info from cache
func (*Dao) CacheSkuByItemID ¶
func (d *Dao) CacheSkuByItemID(c context.Context, itemID int64) (stocks map[string]*model.SKUStock, err error)
CacheSkuByItemID 根据 itemID 获取 sku 缓存
func (*Dao) CacheStocks ¶
func (d *Dao) CacheStocks(c context.Context, keys []int64, isLocked bool) (res map[int64]int64, err error)
CacheStocks 获取 skuID => stock 库存缓存
func (*Dao) CacheTicketSend ¶
func (d *Dao) CacheTicketSend(c context.Context, IDs []int64, TIDType string) (res map[int64]*model.TicketSend, err error)
CacheTicketSend .
func (*Dao) CacheTicketsByID ¶
func (d *Dao) CacheTicketsByID(c context.Context, ticketID []int64) (res map[int64]*model.Ticket, err error)
CacheTicketsByID .
func (*Dao) CacheTicketsByOrderID ¶
func (d *Dao) CacheTicketsByOrderID(c context.Context, orderID int64) (res []*model.Ticket, err error)
CacheTicketsByOrderID 通过 order_id 获取 tickets 取缓存
func (*Dao) CacheTicketsByScreen ¶
func (d *Dao) CacheTicketsByScreen(c context.Context, screenID int64, UID int64) (res []*model.Ticket, err error)
CacheTicketsByScreen 通过 screen_id user_id 获取 tickets
func (*Dao) CreatePromo ¶
CreatePromo create user promo order
func (*Dao) DatabusPub ¶
DatabusPub 向databus发布消息
func (*Dao) DelCacheOrders ¶
func (d *Dao) DelCacheOrders(ctx context.Context, req *model.OrderMainQuerier)
DelCacheOrders 删除订单相关缓存,如果是新增或删除订单,要删除这个uid的订单列表缓存
func (*Dao) DelCachePromo ¶
DelCachePromo delete promo cache
func (*Dao) DelCachePromoGroup ¶
DelCachePromoGroup delete promo group cache
func (*Dao) DelCachePromoOrder ¶
DelCachePromoOrder delete promo order cache
func (*Dao) DelCachePromoOrders ¶
DelCachePromoOrders delete promo orders cache
func (*Dao) DelCacheSku ¶
DelCacheSku 删除 skuId => sku 缓存
func (*Dao) DelTicketCache ¶
DelTicketCache 删除单张电子票全部 cache
func (*Dao) GetOrderLogCnt ¶
GetOrderLogCnt 获取订单日志条数
func (*Dao) GetOrderLogList ¶
func (d *Dao) GetOrderLogList(c context.Context, OID int64, index int64, size int64, orderBy string) (res []*v1.OrderLog, err error)
GetOrderLogList 获取订单日志列表
func (*Dao) GetPromoList ¶
func (d *Dao) GetPromoList(c context.Context, where string, index int64, size int64) (res []*model.Promotion, err error)
GetPromoList 获取拼团列表
func (*Dao) GetSKUs ¶
func (d *Dao) GetSKUs(c context.Context, keys []int64, withNewStock bool) (res map[int64]*model.SKUStock, err error)
GetSKUs get data from cache if miss will call source method, then add to cache.
func (*Dao) GetUserCards ¶
GetUserCards 获取用户卡片信息
func (*Dao) GetUserGroupDoing ¶
func (d *Dao) GetUserGroupDoing(c context.Context, promoID int64, uid int64, status int16) (res *model.PromotionGroup, err error)
GetUserGroupDoing 获取用户正在进行中的拼团信息
func (*Dao) GroupOrdersByStatus ¶
func (d *Dao) GroupOrdersByStatus(c context.Context, groupID int64, status int16) (res []*model.PromotionOrder, err error)
GroupOrdersByStatus 根据groupid和status获取活动订单
func (*Dao) HasPromoOfSKU ¶
func (d *Dao) HasPromoOfSKU(c context.Context, skuID int64, beginTime int64, endTime int64) (num int64, err error)
HasPromoOfSKU 判断skuID是否有正在上架的拼团活动
func (*Dao) InsertOrder ¶
InsertOrder 同步订单到分销表方法
func (*Dao) ItemBillInfo ¶
func (d *Dao) ItemBillInfo(ctx context.Context, itemIDs []int64, scIDs []int64, tkIDs []int64) (*itemv1.BillReply, error)
ItemBillInfo 获取商品信息
func (*Dao) OperatePromo ¶
func (d *Dao) OperatePromo(c context.Context, promoID int64, fromStatus int16, toStatus int16) (num int64, err error)
OperatePromo 修改拼团活动状态
func (*Dao) OrderCount ¶
OrderCount get data from cache if miss will call source method, then add to cache.
func (*Dao) OrderDetails ¶
func (d *Dao) OrderDetails(c context.Context, keys []int64) (res map[int64]*model.OrderDetail, err error)
OrderDetails get data from cache if miss will call source method, then add to cache.
func (*Dao) OrderPayCharges ¶
func (d *Dao) OrderPayCharges(c context.Context, keys []int64) (res map[int64]*model.OrderPayCharge, err error)
OrderPayCharges get data from cache if miss will call source method, then add to cache.
func (*Dao) OrderSKUs ¶
func (d *Dao) OrderSKUs(c context.Context, keys []int64) (res map[int64][]*model.OrderSKU, err error)
OrderSKUs get data from cache if miss will call source method, then add to cache.
func (*Dao) Orders ¶
func (d *Dao) Orders(c context.Context, id *model.OrderMainQuerier) (res []*model.OrderMain, err error)
Orders get data from cache if miss will call source method, then add to cache.
func (*Dao) PromoGroup ¶
PromoGroup get data from cache if miss will call source method, then add to cache.
func (*Dao) PromoOrder ¶
PromoOrder get data from cache if miss will call source method, then add to cache.
func (*Dao) PromoOrderByStatus ¶
func (d *Dao) PromoOrderByStatus(c context.Context, promoID int64, groupID int64, uid int64, status int16) (res *model.PromotionOrder, err error)
PromoOrderByStatus get user promo order by status
func (*Dao) PromoOrderDoing ¶
func (d *Dao) PromoOrderDoing(c context.Context, promoID int64, groupID int64, uid int64) (res *model.PromotionOrder, err error)
PromoOrderDoing get user promo order where status in unpaid and paid
func (*Dao) PromoOrders ¶
PromoOrders get data from cache if miss will call source method, then add to cache.
func (*Dao) RawBoughtCount ¶
func (d *Dao) RawBoughtCount(ctx context.Context, uid string, itemID int64, skuIDs []int64) (cnt int64, err error)
RawBoughtCount 按照票种获取用户已购的订单票数
func (*Dao) RawGetSKUs ¶
func (d *Dao) RawGetSKUs(c context.Context, skuIds []int64, withNewStock bool) (skuMap map[int64]*model.SKUStock, err error)
RawGetSKUs .
func (*Dao) RawGetSettleOrders ¶
func (d *Dao) RawGetSettleOrders(ctx context.Context, bt time.Time, et time.Time, id int64, size int) (res *model.SettleOrders, offset int64, err error)
RawGetSettleOrders 获取待结算订单
func (*Dao) RawGetSettleRefunds ¶
func (d *Dao) RawGetSettleRefunds(ctx context.Context, bt time.Time, et time.Time, id int64, size int) (res *model.SettleOrders, offset int64, err error)
RawGetSettleRefunds 获取待结算退款订单
func (*Dao) RawOrderCount ¶
func (d *Dao) RawOrderCount(ctx context.Context, req *model.OrderMainQuerier) (cnt int64, err error)
RawOrderCount 从db获取用户订单数目,当查询条件仅有uid时生效,否则返回0
func (*Dao) RawOrderDetails ¶
func (d *Dao) RawOrderDetails(ctx context.Context, oids []int64) (orders map[int64]*model.OrderDetail, err error)
RawOrderDetails 从db获取订单详细
func (*Dao) RawOrderPayCharges ¶
func (d *Dao) RawOrderPayCharges(ctx context.Context, oids []int64) (chs map[int64]*model.OrderPayCharge, err error)
RawOrderPayCharges 从db获取订单流水
func (*Dao) RawOrderSKUs ¶
func (d *Dao) RawOrderSKUs(ctx context.Context, oids []int64) (skus map[int64][]*model.OrderSKU, err error)
RawOrderSKUs 从db获取订单的sku
func (*Dao) RawOrders ¶
func (d *Dao) RawOrders(ctx context.Context, req *model.OrderMainQuerier) (orders []*model.OrderMain, err error)
RawOrders 从db查询用户订单信息,包括以下情况 * 按照订单号查询 * 按照uid查分页 * 按照uid+商品id+状态查询列表
func (*Dao) RawPromoGroup ¶
func (d *Dao) RawPromoGroup(c context.Context, groupID int64) (res *model.PromotionGroup, err error)
RawPromoGroup 根据id获取拼团信息
func (*Dao) RawPromoOrder ¶
func (d *Dao) RawPromoOrder(c context.Context, orderID int64) (res *model.PromotionOrder, err error)
RawPromoOrder get promo order info from db
func (*Dao) RawPromoOrders ¶
func (d *Dao) RawPromoOrders(c context.Context, groupID int64) (res []*model.PromotionOrder, err error)
RawPromoOrders get promo orders info from db
func (*Dao) RawSkuByItemID ¶
func (d *Dao) RawSkuByItemID(c context.Context, itemID int64) (stocks map[string]*model.SKUStock, err error)
RawSkuByItemID 根据规格获取 sku
func (*Dao) RawSkuByItemSpecs ¶
func (d *Dao) RawSkuByItemSpecs(c context.Context, itemID int64, specs string) (stock *model.SKUStock, err error)
RawSkuByItemSpecs 根据 itemID 和规格获取单个 sku
func (*Dao) RawStocks ¶
func (d *Dao) RawStocks(c context.Context, keys []int64, isLocked bool) (res map[int64]int64, err error)
RawStocks skuID => stock 缓存回源
func (*Dao) RawTicketSend ¶
func (d *Dao) RawTicketSend(c context.Context, IDs []int64, TIDType string) (res map[int64]*model.TicketSend, err error)
RawTicketSend .
func (*Dao) RawTicketsByID ¶
func (d *Dao) RawTicketsByID(c context.Context, ticketID []int64) (res map[int64]*model.Ticket, err error)
RawTicketsByID .
func (*Dao) RawTicketsByOrderID ¶
func (d *Dao) RawTicketsByOrderID(c context.Context, orderID int64) (res []*model.Ticket, err error)
RawTicketsByOrderID 通过 order_id 获取 tickets
func (*Dao) RawTicketsByScreen ¶
func (d *Dao) RawTicketsByScreen(c context.Context, screenID int64, UID int64) (res []*model.Ticket, err error)
RawTicketsByScreen 通过 screen_id user_id 获取 tickets
func (*Dao) RedisDecrExist ¶
RedisDecrExist 当 key 存在时 给 key 减去指定数值 key 不存在时不做操作
func (*Dao) RedisSetnx ¶
RedisSetnx setnx
func (*Dao) SkuByItemID ¶
SkuByItemID get data from cache if miss will call source method, then add to cache.
func (*Dao) SkuByItemSpecs ¶
func (d *Dao) SkuByItemSpecs(c context.Context, itemID int64, specs string) (stock *model.SKUStock, err error)
SkuByItemSpecs 通过 itemID specs 获取单个 sku
func (*Dao) SkuItemCacheDel ¶
SkuItemCacheDel 删除 itemId => sku 缓存
func (*Dao) StockCacheDecr ¶
StockCacheDecr 减库存缓存
func (*Dao) StockCacheDel ¶
StockCacheDel 删除库存缓存
func (*Dao) StockLockedCacheDecr ¶
StockLockedCacheDecr 减锁定库存缓存
func (*Dao) StockLogs ¶
func (d *Dao) StockLogs(c context.Context, opType int16, srcID int64, skuIDs ...int64) (stockLogs []*model.SKUStockLog, err error)
StockLogs 查询库存操作记录
func (*Dao) Stocks ¶
func (d *Dao) Stocks(c context.Context, keys []int64, isLocked bool) (res map[int64]int64, err error)
Stocks get data from cache if miss will call source method, then add to cache.
func (*Dao) TicketSend ¶
func (d *Dao) TicketSend(c context.Context, keys []int64, TIDType string) (res map[int64]*model.TicketSend, err error)
TicketSend get data from cache if miss will call source method, then add to cache.
func (*Dao) TicketsByID ¶
TicketsByID get data from cache if miss will call source method, then add to cache.
func (*Dao) TicketsByOrderID ¶
TicketsByOrderID get data from cache if miss will call source method, then add to cache.
func (*Dao) TicketsByScreen ¶
func (d *Dao) TicketsByScreen(c context.Context, id int64, UID int64) (res []*model.Ticket, err error)
TicketsByScreen get data from cache if miss will call source method, then add to cache.
func (*Dao) TxAddPromoGroup ¶
func (d *Dao) TxAddPromoGroup(c context.Context, tx *xsql.Tx, promoID int64, groupID int64, uid int64, orderCount int64, status int16, expireAt int64) (id int64, err error)
TxAddPromoGroup add promo group into db
func (*Dao) TxAddPromoOrder ¶
func (d *Dao) TxAddPromoOrder(c context.Context, tx *xsql.Tx, promoID int64, groupID int64, orderID int64, isMaster int16, uid int64, status int16, skuID int64, ctime int64) (id int64, err error)
TxAddPromoOrder create user promo order
func (*Dao) TxAddStockInsert ¶
TxAddStockInsert 插入 stock 数据
func (*Dao) TxAddStockLog ¶
TxAddStockLog 添加库存操作日志
func (*Dao) TxInsertOrderDetails ¶
TxInsertOrderDetails 写入orderDetail表
func (*Dao) TxInsertOrderSKUs ¶
TxInsertOrderSKUs 增加订单Sku
func (*Dao) TxInsertOrders ¶
TxInsertOrders 插入订单表,返回成功行数
func (*Dao) TxStockDecr ¶
TxStockDecr 减库存 DB
func (*Dao) TxStockIncr ¶
TxStockIncr 增加库存
func (*Dao) TxStockLock ¶
TxStockLock lock stock with tx
func (*Dao) TxStockLockedDecr ¶
TxStockLockedDecr 减去锁定库存
func (*Dao) TxStockLogRollBack ¶
TxStockLogRollBack 回滚操作日志
func (*Dao) TxStockReset ¶
TxStockReset 重置库存
func (*Dao) TxStockUnlock ¶
TxStockUnlock 解锁库存(减去锁定库存增加库存)
func (*Dao) TxUpdateGroupOrderCount ¶
func (d *Dao) TxUpdateGroupOrderCount(c context.Context, tx *xsql.Tx, step int64, groupID int64, skuCount int64) (number int64, err error)
TxUpdateGroupOrderCount 更新拼团的人数
func (*Dao) TxUpdateGroupStatus ¶
func (d *Dao) TxUpdateGroupStatus(c context.Context, tx *xsql.Tx, groupID int64, oldStatus int16, newStatus int16) (number int64, err error)
TxUpdateGroupStatus 更新拼团状态
func (*Dao) TxUpdatePromoBuyerCount ¶
func (d *Dao) TxUpdatePromoBuyerCount(c context.Context, tx *xsql.Tx, promoID int64, count int64) (number int64, err error)
TxUpdatePromoBuyerCount 更新活动的购买人数
func (*Dao) TxUpdatePromoOrderGroupIDAndStatus ¶
func (d *Dao) TxUpdatePromoOrderGroupIDAndStatus(c context.Context, tx *xsql.Tx, orderID int64, groupID int64, status int16) (number int64, err error)
TxUpdatePromoOrderGroupIDAndStatus update promo order groupid and status
func (*Dao) TxUpdatePromoOrderStatus ¶
func (d *Dao) TxUpdatePromoOrderStatus(c context.Context, tx *xsql.Tx, orderID int64, status int16) (number int64, err error)
TxUpdatePromoOrderStatus update promo order status
func (*Dao) UpdateDetailBuyer ¶
UpdateDetailBuyer 更新购买人信息
func (*Dao) UpdateDetailDelivery ¶
func (d *Dao) UpdateDetailDelivery(c context.Context, arg *_type.OrderDeliver, orderID int64) (num int64, err error)
UpdateDetailDelivery 更新配送信息
func (*Dao) UpdateGroupStatusAndOrderCount ¶
func (d *Dao) UpdateGroupStatusAndOrderCount(c context.Context, groupID int64, step int64, oldStatus int16, newStatus int16) (number int64, err error)
UpdateGroupStatusAndOrderCount 更新拼团状态和人数
func (*Dao) UpdatePromo ¶
UpdatePromo 更新拼团