dao

package
v0.0.0-...-83adff0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 6, 2020 License: GPL-3.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultOrderPSize   = 20        //默认每页数量
	DefaultOrderOrderBy = "id desc" //默认排序

)

订单相关常量

Variables

This section is empty.

Functions

func LogX 

func LogX(ctx context.Context, args interface{}, res interface{}, err error, ld ...log.D)

LogX 记录日志，args:请求参数 res:正常返回 err:错误返回 ld:更多日志项

Types

type Dao 

type Dao struct {
	// contains filtered or unexported fields
}

Dao 数据操作层结构体

func New 

func New(c *conf.Config) (d *Dao)

New 根据配置文件 生成一个 Dao struct

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 

func (d *Dao) AddCacheOrderSKUs(ctx context.Context, skus map[int64][]*model.OrderSKU) (err error)

AddCacheOrderSKUs 增加订单sku缓存

func (*Dao) AddCacheOrders 

func (d *Dao) AddCacheOrders(ctx context.Context, req *model.OrderMainQuerier, res []*model.OrderMain) (err error)

AddCacheOrders 设置订单基础信息缓存

func (*Dao) AddCachePromo 

func (d *Dao) AddCachePromo(c context.Context, promoID int64, promo *model.Promotion) (err error)

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 

func (d *Dao) AddCacheStocks(c context.Context, stocks map[int64]int64, isLocked bool) (err error)

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 

func (d *Dao) AddCacheTicketsByID(c context.Context, tickets map[int64]*model.Ticket) (err error)

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 

func (d *Dao) AddOrderLog(c context.Context, oi *v1.OrderLog) (cnt int64, err error)

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) AddStockLog 

func (d *Dao) AddStockLog()

AddStockLog TxAddStockLog

func (*Dao) BeginTx 

func (d *Dao) BeginTx(c context.Context) (conn *sql.Tx, err error)

BeginTx 开启事务

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 

func (d *Dao) CachePromo(c context.Context, promoID int64) (res *model.Promotion, err error)

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) Close 

func (d *Dao) Close() (err error)

Close 关闭redis 和 db 连接

func (*Dao) CreatePromo 

func (d *Dao) CreatePromo(c context.Context, promo *model.Promotion) (id int64, err error)

CreatePromo create user promo order

func (*Dao) DatabusPub 

func (d *Dao) DatabusPub(ctx context.Context, action string, data interface{}) error

DatabusPub 向databus发布消息

func (*Dao) DelCacheOrders 

func (d *Dao) DelCacheOrders(ctx context.Context, req *model.OrderMainQuerier)

DelCacheOrders 删除订单相关缓存，如果是新增或删除订单，要删除这个uid的订单列表缓存

func (*Dao) DelCachePromo 

func (d *Dao) DelCachePromo(c context.Context, promoID int64)

DelCachePromo delete promo cache

func (*Dao) DelCachePromoGroup 

func (d *Dao) DelCachePromoGroup(c context.Context, groupID int64)

DelCachePromoGroup delete promo group cache

func (*Dao) DelCachePromoOrder 

func (d *Dao) DelCachePromoOrder(c context.Context, orderID int64)

DelCachePromoOrder delete promo order cache

func (*Dao) DelCachePromoOrders 

func (d *Dao) DelCachePromoOrders(c context.Context, groupID int64)

DelCachePromoOrders delete promo orders cache

func (*Dao) DelCacheSku 

func (d *Dao) DelCacheSku(c context.Context, skuID int64) (err error)

DelCacheSku 删除 skuId => sku 缓存

func (*Dao) DelTicketCache 

func (d *Dao) DelTicketCache(c context.Context, tickets ...*model.Ticket) (err error)

DelTicketCache 删除单张电子票全部 cache

func (*Dao) GetOrder 

func (d *Dao) GetOrder(c context.Context, oid uint64) (res []*model.OrderInfo, err error)

GetOrder 检查订单是否存在

func (*Dao) GetOrderLogCnt 

func (d *Dao) GetOrderLogCnt(c context.Context, OID int64) (cnt int64, err error)

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 

func (d *Dao) GetUserCards(ctx context.Context, mids []int64) (*acc.CardsReply, error)

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) HasOrder 

func (d *Dao) HasOrder(c context.Context, oi *model.DistOrderArg) (has bool, err error)

HasOrder 检查订单是否存在

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 

func (d *Dao) InsertOrder(c context.Context, oi *model.DistOrderArg) (lastID int64, err error)

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 

func (d *Dao) OrderCount(c context.Context, id *model.OrderMainQuerier) (res int64, err error)

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) OrderID 

func (d *Dao) OrderID(ctx context.Context, n int) ([]int64, error)

OrderID 获取订单号的方法

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) Ping 

func (d *Dao) Ping(c context.Context) (err error)

Ping ping 方法

func (*Dao) Promo 

func (d *Dao) Promo(c context.Context, id int64) (res *model.Promotion, err error)

Promo get data from cache if miss will call source method, then add to cache.

func (*Dao) PromoGroup 

func (d *Dao) PromoGroup(c context.Context, id int64) (res *model.PromotionGroup, err error)

PromoGroup get data from cache if miss will call source method, then add to cache.

func (*Dao) PromoOrder 

func (d *Dao) PromoOrder(c context.Context, id int64) (res *model.PromotionOrder, err error)

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 

func (d *Dao) PromoOrders(c context.Context, id int64) (res []*model.PromotionOrder, err error)

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) RawPromo 

func (d *Dao) RawPromo(c context.Context, promoID int64) (res *model.Promotion, err error)

RawPromo get promo info from db

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) RedisDecr 

func (d *Dao) RedisDecr(c context.Context, key string, num int) (err error)

RedisDecr 指定 key 减去 num

func (*Dao) RedisDecrExist 

func (d *Dao) RedisDecrExist(c context.Context, key string, num int64) (err error)

RedisDecrExist 当 key 存在时 给 key 减去指定数值 key 不存在时不做操作

func (*Dao) RedisDel 

func (d *Dao) RedisDel(c context.Context, key ...interface{}) (err error)

RedisDel del keys

func (*Dao) RedisSetnx 

func (d *Dao) RedisSetnx(c context.Context, key string, val interface{}, ttl int64) (err error)

RedisSetnx setnx

func (*Dao) SkuByItemID 

func (d *Dao) SkuByItemID(c context.Context, id int64) (res map[string]*model.SKUStock, err error)

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 

func (d *Dao) SkuItemCacheDel(c context.Context, itemID int64) (err error)

SkuItemCacheDel 删除 itemId => sku 缓存

func (*Dao) Stock 

func (d *Dao) Stock(c context.Context, skuID int64) (stock *model.SKUStock, err error)

Stock 查询库存信息

func (*Dao) StockCacheDecr 

func (d *Dao) StockCacheDecr(c context.Context, skuID int64, total int64) (err error)

StockCacheDecr 减库存缓存

func (*Dao) StockCacheDel 

func (d *Dao) StockCacheDel(c context.Context, skuID int64) (err error)

StockCacheDel 删除库存缓存

func (*Dao) StockDecr 

func (d *Dao) StockDecr(c context.Context, skuID int64, num int64) (affected int64, err error)

StockDecr 减库存 DB

func (*Dao) StockLock 

func (d *Dao) StockLock(c context.Context, skuID int64, cnt int64) (err error)

StockLock lock stock

func (*Dao) StockLockedCacheDecr 

func (d *Dao) StockLockedCacheDecr(c context.Context, skuID int64, total int64) (err error)

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 

func (d *Dao) TicketsByID(c context.Context, keys []int64) (res map[int64]*model.Ticket, err error)

TicketsByID get data from cache if miss will call source method, then add to cache.

func (*Dao) TicketsByOrderID 

func (d *Dao) TicketsByOrderID(c context.Context, id int64) (res []*model.Ticket, err error)

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 

func (d *Dao) TxAddStockInsert(tx *xsql.Tx, stocks ...*model.SKUStock) (affected int64, err error)

TxAddStockInsert 插入 stock 数据

func (*Dao) TxAddStockLog 

func (d *Dao) TxAddStockLog(tx *xsql.Tx, stockLogs ...*model.SKUStockLog) (err error)

TxAddStockLog 添加库存操作日志

func (*Dao) TxInsertOrderDetails 

func (d *Dao) TxInsertOrderDetails(tx *xsql.Tx, orders []*model.OrderDetail) (cnt int64, err error)

TxInsertOrderDetails 写入orderDetail表

func (*Dao) TxInsertOrderSKUs 

func (d *Dao) TxInsertOrderSKUs(tx *xsql.Tx, orders []*model.OrderSKU) (cnt int64, err error)

TxInsertOrderSKUs 增加订单Sku

func (*Dao) TxInsertOrders 

func (d *Dao) TxInsertOrders(tx *xsql.Tx, orders []*model.OrderMain) (cnt int64, err error)

TxInsertOrders 插入订单表，返回成功行数

func (*Dao) TxStockDecr 

func (d *Dao) TxStockDecr(tx *xsql.Tx, skuID int64, num int64) (affected int64, err error)

TxStockDecr 减库存 DB

func (*Dao) TxStockIncr 

func (d *Dao) TxStockIncr(tx *xsql.Tx, skuID int64, count int64) (affected int64, err error)

TxStockIncr 增加库存

func (*Dao) TxStockLock 

func (d *Dao) TxStockLock(tx *xsql.Tx, skuID int64, cnt int64) (affected int64, err error)

TxStockLock lock stock with tx

func (*Dao) TxStockLockedDecr 

func (d *Dao) TxStockLockedDecr(tx *xsql.Tx, skuID int64, count int64) (affected int64, err error)

TxStockLockedDecr 减去锁定库存

func (*Dao) TxStockLogRollBack 

func (d *Dao) TxStockLogRollBack(tx *xsql.Tx, stockLogID int64) (affected int64, err error)

TxStockLogRollBack 回滚操作日志

func (*Dao) TxStockReset 

func (d *Dao) TxStockReset(tx *xsql.Tx, stock *model.SKUStock) (affected int64, err error)

TxStockReset 重置库存

func (*Dao) TxStockUnlock 

func (d *Dao) TxStockUnlock(tx *xsql.Tx, skuID int64, count int64) (affected int64, err error)

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 

func (d *Dao) UpdateDetailBuyer(c context.Context, req *rpc.UpBuyerRequest) (num int64, err error)

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 

func (d *Dao) UpdatePromo(c context.Context, arg *model.Promotion) (num int64, err error)

UpdatePromo 更新拼团

func (*Dao) UpdatePromoOrderStatus 

func (d *Dao) UpdatePromoOrderStatus(c context.Context, orderID int64, status int16) (number int64, err error)

UpdatePromoOrderStatus update promo order status

func (*Dao) UpdateTicketStatus 

func (d *Dao) UpdateTicketStatus(c context.Context, status int16, ticketID ...int64) (err error)

UpdateTicketStatus 更新票状态

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.