cdk

Documentation

Index

• type ServiceContent
  • func NewServiceContent(env string, dao *dao.Dao, idgen *idgen.Client, cdkMaxNumber int64, ...) *ServiceContent
  • func (s *ServiceContent) CleanFrozenOrder()
  • func (s *ServiceContent) CreateCdkOrderSvc(req *types.CreateCdkOrderReq) (resp *types.CreateCdkOrderResp, err error)
  • func (s *ServiceContent) CreateCdkTypeSvc(req *types.CreateCdkTypeReq) (res *types.CreateCdkTypeResp, err error)
  • func (s *ServiceContent) CreateCdksSvc(req *types.CreateCdksReq) (res *types.CreateCdksResp, err error)
  • func (s *ServiceContent) DealCdkOrderSvc(req *types.DealCdkOrderReq) (res *types.DealCdkOrderResp, err error)
  • func (s *ServiceContent) DeleteCdkTypesSvc(req *types.DeleteCdkTypesReq) (res *types.DeleteCdkTypesResp, err error)
  • func (s *ServiceContent) DeleteCdksSvc(req *types.DeleteCdksReq) (res *types.DeleteCdksResp, err error)
  • func (s *ServiceContent) ExchangeCdksSvc(req *types.ExchangeCdksReq) (res *types.ExchangeCdksResp, err error)
  • func (s *ServiceContent) FrozenCdks(cdks []*biz.Cdk, userId string, orderId int64) error
  • func (s *ServiceContent) GetCdkTypeByCdkId(cdkId int64) (*biz.CdkType, error)
  • func (s *ServiceContent) GetCdkTypeByCoinName(coinName string) (*biz.CdkType, error)
  • func (s *ServiceContent) GetCdkTypeByCoinNameSvc(req *types.GetCdkTypeByCoinNameReq) (res *types.GetCdkTypeByCoinNameResp, err error)
  • func (s *ServiceContent) GetCdkTypes(coinName string, page, pageSize int64) ([]*biz.CdkType, int64, int64, error)
  • func (s *ServiceContent) GetCdkTypesSvc(req *types.GetCdkTypesReq) (res *types.GetCdkTypesResp, err error)
  • func (s *ServiceContent) GetCdks(cdkId int64, cdkContent string, page, pageSize int64) ([]*biz.Cdk, int64, int64, error)
  • func (s *ServiceContent) GetCdksByUserId(userId string, page, pageSize int64) ([]*biz.Cdk, int64, int64, error)
  • func (s *ServiceContent) GetCdksByUserIdSvc(req *types.GetCdksByUserIdReq) (res *types.GetCdksByUserIdResp, err error)
  • func (s *ServiceContent) GetCdksSvc(req *types.GetCdksReq) (res *types.GetCdksResp, err error)
  • func (s *ServiceContent) GetUnusedCdks(cdkId int64, number int64) ([]*biz.Cdk, error)
  • func (s *ServiceContent) ListenOrder()
  • func (s *ServiceContent) UpdateCdkTypeSvc(req *types.UpdateCdkTypeReq) (res *types.UpdateCdkTypeResp, err error)

Types

type ServiceContent

type ServiceContent struct {

	// cdk订单处理 channal
	CdkOrderMessage chan *biz.CdkOrderMessage
	CdkMaxNumber    int64
	// contains filtered or unexported fields
}

func NewServiceContent

func NewServiceContent(env string, dao *dao.Dao, idgen *idgen.Client, cdkMaxNumber int64, chainCliConfig config.Chain33Client) *ServiceContent

func (*ServiceContent) CleanFrozenOrder

func (s *ServiceContent) CleanFrozenOrder()

func (*ServiceContent) CreateCdkOrderSvc

func (s *ServiceContent) CreateCdkOrderSvc(req *types.CreateCdkOrderReq) (resp *types.CreateCdkOrderResp, err error)

CreateCdkOrderSvc 创建订单 Svc

func (*ServiceContent) CreateCdkTypeSvc

func (s *ServiceContent) CreateCdkTypeSvc(req *types.CreateCdkTypeReq) (res *types.CreateCdkTypeResp, err error)

func (*ServiceContent) CreateCdksSvc

func (s *ServiceContent) CreateCdksSvc(req *types.CreateCdksReq) (res *types.CreateCdksResp, err error)

func (*ServiceContent) DealCdkOrderSvc

func (s *ServiceContent) DealCdkOrderSvc(req *types.DealCdkOrderReq) (res *types.DealCdkOrderResp, err error)

func (*ServiceContent) DeleteCdkTypesSvc

func (s *ServiceContent) DeleteCdkTypesSvc(req *types.DeleteCdkTypesReq) (res *types.DeleteCdkTypesResp, err error)

func (*ServiceContent) DeleteCdksSvc

func (s *ServiceContent) DeleteCdksSvc(req *types.DeleteCdksReq) (res *types.DeleteCdksResp, err error)

func (*ServiceContent) ExchangeCdksSvc

func (s *ServiceContent) ExchangeCdksSvc(req *types.ExchangeCdksReq) (res *types.ExchangeCdksResp, err error)

func (*ServiceContent) FrozenCdks

func (s *ServiceContent) FrozenCdks(cdks []*biz.Cdk, userId string, orderId int64) error

FrozenCdks 冻结 cdk

func (*ServiceContent) GetCdkTypeByCdkId

func (s *ServiceContent) GetCdkTypeByCdkId(cdkId int64) (*biz.CdkType, error)

GetCdkTypeByCdkId 通过 cdkId 查询 cdkType

func (*ServiceContent) GetCdkTypeByCoinName

func (s *ServiceContent) GetCdkTypeByCoinName(coinName string) (*biz.CdkType, error)

GetCdkTypeByCoinName 通过 coinName 查询 cdkType

func (*ServiceContent) GetCdkTypeByCoinNameSvc

func (s *ServiceContent) GetCdkTypeByCoinNameSvc(req *types.GetCdkTypeByCoinNameReq) (res *types.GetCdkTypeByCoinNameResp, err error)

func (*ServiceContent) GetCdkTypes

func (s *ServiceContent) GetCdkTypes(coinName string, page, pageSize int64) ([]*biz.CdkType, int64, int64, error)

GetCdkTypes 分页查询 CdkType 列表

func (*ServiceContent) GetCdkTypesSvc

func (s *ServiceContent) GetCdkTypesSvc(req *types.GetCdkTypesReq) (res *types.GetCdkTypesResp, err error)

func (*ServiceContent) GetCdks

func (s *ServiceContent) GetCdks(cdkId int64, cdkContent string, page, pageSize int64) ([]*biz.Cdk, int64, int64, error)

GetCdks 分页查询 cdk 列表

func (*ServiceContent) GetCdksByUserId

func (s *ServiceContent) GetCdksByUserId(userId string, page, pageSize int64) ([]*biz.Cdk, int64, int64, error)

func (*ServiceContent) GetCdksByUserIdSvc

func (s *ServiceContent) GetCdksByUserIdSvc(req *types.GetCdksByUserIdReq) (res *types.GetCdksByUserIdResp, err error)

func (*ServiceContent) GetCdksSvc

func (s *ServiceContent) GetCdksSvc(req *types.GetCdksReq) (res *types.GetCdksResp, err error)

func (*ServiceContent) GetUnusedCdks

func (s *ServiceContent) GetUnusedCdks(cdkId int64, number int64) ([]*biz.Cdk, error)

GetUnusedCdks 按顺序获得未发放的 cdk

func (*ServiceContent) ListenOrder

func (s *ServiceContent) ListenOrder()

ListenOrder 监听创建订单消息队列

func (*ServiceContent) UpdateCdkTypeSvc

func (s *ServiceContent) UpdateCdkTypeSvc(req *types.UpdateCdkTypeReq) (res *types.UpdateCdkTypeResp, err error)