logic

Documentation

Index

• type CancelOrderLogic
  • func NewCancelOrderLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CancelOrderLogic
  • func (l *CancelOrderLogic) CancelOrder(in *pb.CancelOrderReq) (*pb.OrderEmpty, error)
• type CreateOrderLogic
  • func NewCreateOrderLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CreateOrderLogic
  • func (l *CreateOrderLogic) CreateOrder(in *pb.CreateOrderReq) (*pb.OrderEmpty, error)
• type CreateOrderRevertLogic
  • func NewCreateOrderRevertLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CreateOrderRevertLogic
  • func (l *CreateOrderRevertLogic) CreateOrderRevert(in *pb.CreateOrderReq) (*pb.OrderEmpty, error)
• type GetOrderAllPendingOrderLogic
  • func NewGetOrderAllPendingOrderLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetOrderAllPendingOrderLogic
  • func (l *GetOrderAllPendingOrderLogic) GetOrderAllPendingOrder(in *pb.OrderEmpty, stream pb.OrderService_GetOrderAllPendingOrderServer) error
• type GetOrderListLogic
  • func NewGetOrderListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetOrderListLogic
  • func (l *GetOrderListLogic) GetOrderList(in *pb.GetOrderListByUserReq) (*pb.GetOrderListByUserResp, error)
• type HandleMatchResultLogic
  • func NewHandleMatchResultLogic(svcCtx *svc.ServiceContext) *HandleMatchResultLogic
  • func (l *HandleMatchResultLogic) CancelOrder(resp *matchMq.MatchResp_Cancel, storeConsumedMessageId func() error) error
  • func (l *HandleMatchResultLogic) HandleMatchResult(result *matchMq.MatchResp_MatchResult, storeConsumedMessageId func() error) error
• type OrderLogic
  • func NewOrderLogic(ctx context.Context, svcCtx *svc.ServiceContext) *OrderLogic
  • func (l *OrderLogic) Order(in *pb.CreateOrderReq) (*pb.OrderEmpty, error)

Types

type CancelOrderLogic

type CancelOrderLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewCancelOrderLogic

func NewCancelOrderLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CancelOrderLogic

func (*CancelOrderLogic) CancelOrder

func (l *CancelOrderLogic) CancelOrder(in *pb.CancelOrderReq) (*pb.OrderEmpty, error)

CancelOrder 取消订单

type CreateOrderLogic

type CreateOrderLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewCreateOrderLogic

func NewCreateOrderLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CreateOrderLogic

func (*CreateOrderLogic) CreateOrder

func (l *CreateOrderLogic) CreateOrder(in *pb.CreateOrderReq) (*pb.OrderEmpty, error)

创建订单

type CreateOrderRevertLogic

type CreateOrderRevertLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewCreateOrderRevertLogic

func NewCreateOrderRevertLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CreateOrderRevertLogic

func (*CreateOrderRevertLogic) CreateOrderRevert

func (l *CreateOrderRevertLogic) CreateOrderRevert(in *pb.CreateOrderReq) (*pb.OrderEmpty, error)

下单补偿

type GetOrderAllPendingOrderLogic

type GetOrderAllPendingOrderLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetOrderAllPendingOrderLogic

func NewGetOrderAllPendingOrderLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetOrderAllPendingOrderLogic

func (*GetOrderAllPendingOrderLogic) GetOrderAllPendingOrder

func (l *GetOrderAllPendingOrderLogic) GetOrderAllPendingOrder(in *pb.OrderEmpty, stream pb.OrderService_GetOrderAllPendingOrderServer) error

获取所有订单状态为未成交或部分成交的订单

type GetOrderListLogic

type GetOrderListLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetOrderListLogic

func NewGetOrderListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetOrderListLogic

func (*GetOrderListLogic) GetOrderList

func (l *GetOrderListLogic) GetOrderList(in *pb.GetOrderListByUserReq) (*pb.GetOrderListByUserResp, error)

GetOrderList 获取用户订单列表

type HandleMatchResultLogic

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

HandleMatchResultLogic 更新订单状态，插入撮合记录

func NewHandleMatchResultLogic

func NewHandleMatchResultLogic(svcCtx *svc.ServiceContext) *HandleMatchResultLogic

func (*HandleMatchResultLogic) CancelOrder

func (l *HandleMatchResultLogic) CancelOrder(resp *matchMq.MatchResp_Cancel, storeConsumedMessageId func() error) error

CancelOrder 取消订单

func (*HandleMatchResultLogic) HandleMatchResult

func (l *HandleMatchResultLogic) HandleMatchResult(result *matchMq.MatchResp_MatchResult, storeConsumedMessageId func() error) error

HandleMatchResult 更新订单状态，插入撮合记录

type OrderLogic

type OrderLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewOrderLogic

func NewOrderLogic(ctx context.Context, svcCtx *svc.ServiceContext) *OrderLogic

func (*OrderLogic) Order

func (l *OrderLogic) Order(in *pb.CreateOrderReq) (*pb.OrderEmpty, error)

下单。