service

Documentation

Index

• func AccountCharge(ctx context.Context, req *pay_business.AccountChargeRequest) (retCode int)
• func CreateAccount(ctx context.Context, req *pay_business.CreateAccountRequest) (accountCode string, retCode int)
• func FindAccount(ctx context.Context, req *pay_business.FindAccountRequest) (result []*pay_business.AccountEntry, retCode int)
• func GetTradeUUID(ctx context.Context, req *pay_business.GetTradeUUIDRequest) (tradeUUID string, retCode int)
• func TradePay(ctx context.Context, req *pay_business.TradePayRequest) (payId string, retCode int)
• type PushMsgTag
• type PushNoticeService
  • func NewPushNoticeService(server *queue.MachineryQueue, tag PushMsgTag) *PushNoticeService
  • func (p *PushNoticeService) GetTaskState(taskId string) (*tasks.TaskState, error)
  • func (p *PushNoticeService) PushMessage(ctx context.Context, args interface{}) (string, int)

Functions

func AccountCharge

func AccountCharge(ctx context.Context, req *pay_business.AccountChargeRequest) (retCode int)

func CreateAccount

func CreateAccount(ctx context.Context, req *pay_business.CreateAccountRequest) (accountCode string, retCode int)

func FindAccount

func FindAccount(ctx context.Context, req *pay_business.FindAccountRequest) (result []*pay_business.AccountEntry, retCode int)

func GetTradeUUID

func GetTradeUUID(ctx context.Context, req *pay_business.GetTradeUUIDRequest) (tradeUUID string, retCode int)

func TradePay

func TradePay(ctx context.Context, req *pay_business.TradePayRequest) (payId string, retCode int)

Types

type PushMsgTag

type PushMsgTag struct {
	DeliveryTag    string
	DeliveryErrTag string
	RetryCount     int
	RetryTimeout   int
}

type PushNoticeService

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

func NewPushNoticeService

func NewPushNoticeService(server *queue.MachineryQueue, tag PushMsgTag) *PushNoticeService

func (*PushNoticeService) GetTaskState

func (p *PushNoticeService) GetTaskState(taskId string) (*tasks.TaskState, error)

func (*PushNoticeService) PushMessage

func (p *PushNoticeService) PushMessage(ctx context.Context, args interface{}) (string, int)