repository

Feb 17, 2021

Changes in this version

type PaymentChannelCostMerchantRepositoryInterface

+ GetActiveForMerchant func(context.Context, string) ([]*billingpb.PaymentChannelCostMerchant, error)

Dec 3, 2020

Changes in this version

type DashboardProcessorRepositoryInterface

+ ExecuteCustomerARPPU func(ctx context.Context) (interface{}, error)

type DashboardReportProcessor

+ func (m *DashboardReportProcessor) ExecuteCustomerARPPU(ctx context.Context) (interface{}, error)

+ type MerchantDocumentRepositoryInterface interface

+ CountByMerchantId func(context.Context, string) (int64, error)

+ GetById func(context.Context, string) (*billingpb.MerchantDocument, error)

+ GetByMerchantId func(context.Context, string, int64, int64) ([]*billingpb.MerchantDocument, error)

+ Insert func(context.Context, *billingpb.MerchantDocument) error

+ func NewMerchantDocumentRepository(db mongodb.SourceInterface) MerchantDocumentRepositoryInterface

Nov 18, 2020

Changes in this version

type AccountingEntryRepositoryInterface

+ DeleteBySource func(context.Context, string, string) error

type CustomerRepositoryInterface

+ CountBy func(ctx context.Context, query bson.M) (int64, error)

+ FindBy func(ctx context.Context, query bson.M, opts ...*options.FindOptions) ([]*billingpb.Customer, error)

+ type Customers struct

+ Id string

type DashboardProcessorRepositoryInterface

+ ExecuteCustomerARPU func(ctx context.Context, customerId string) (interface{}, error)

+ ExecuteCustomerAvgTransactionsCount func(ctx context.Context, out interface{}) (interface{}, error)

+ ExecuteCustomerLTV func(ctx context.Context, out interface{}) (interface{}, error)

+ ExecuteCustomerTop20 func(ctx context.Context, out interface{}) (interface{}, error)

+ ExecuteCustomers func(ctx context.Context, out interface{}) (interface{}, error)

+ ExecuteCustomersChart func(ctx context.Context, startDate time.Time, end time.Time) (interface{}, error)

+ ExecuteCustomersCount func(ctx context.Context, out interface{}) (interface{}, error)

type DashboardReportProcessor

+ func (m *DashboardReportProcessor) ExecuteCustomerARPU(ctx context.Context, customerId string) (interface{}, error)

+ func (m *DashboardReportProcessor) ExecuteCustomerAvgTransactionsCount(ctx context.Context, i interface{}) (interface{}, error)

+ func (m *DashboardReportProcessor) ExecuteCustomerLTV(ctx context.Context, i interface{}) (interface{}, error)

+ func (m *DashboardReportProcessor) ExecuteCustomerTop20(ctx context.Context, i interface{}) (interface{}, error)

+ func (m *DashboardReportProcessor) ExecuteCustomers(ctx context.Context, i interface{}) (interface{}, error)

+ func (m *DashboardReportProcessor) ExecuteCustomersChart(ctx context.Context, startDate time.Time, end time.Time) (interface{}, error)

+ func (m *DashboardReportProcessor) ExecuteCustomersCount(ctx context.Context, i interface{}) (interface{}, error)

type DashboardRepositoryInterface

+ GetCustomerARPU func(ctx context.Context, merchantId string, customerId string) (*billingpb.DashboardAmountItemWithChart, error)

+ GetCustomersReport func(ctx context.Context, merchantId string, period string) (*billingpb.DashboardCustomerReport, error)

type OrderViewRepositoryInterface

+ GetCountBy func(ctx context.Context, filter bson.M, opts ...*options.CountOptions) (int64, error)

Sep 10, 2020

Changes in this version

type OrderRepositoryInterface

+ GetFirstPaymentForMerchant func(ctx context.Context, merchantId string) (*billingpb.Order, error)

+ GetManyBy func(ctx context.Context, filter bson.M, opts ...*options.FindOptions) ([]*billingpb.Order, error)

type OrderViewRepositoryInterface

+ GetManyBy func(ctx context.Context, filter bson.M, opts ...*options.FindOptions) ([]*billingpb.OrderViewPrivate, error)

+ GetRoyaltySummaryRoundedAmounts func(ctx context.Context, merchantId, currency string, from, to time.Time, ...) (items []*billingpb.RoyaltyReportProductSummaryItem, ...)

Aug 26, 2020

Changes in this version

type CustomerRepositoryInterface

+ FindAll func(ctx context.Context) ([]*billingpb.Customer, error)

Jul 24, 2020

Changes in this version

+ type AutoincrementRepositoryInterface interface

+ GatPayoutAutoincrementId func(ctx context.Context) (int64, error)

+ func NewAutoincrementRepository(db mongodb.SourceInterface) AutoincrementRepositoryInterface

Jul 13, 2020

Changes in this version

type OrderRepositoryInterface

+ IncludeOrdersToRoyaltyReport func(ctx context.Context, royaltyReportId string, orderIds []primitive.ObjectID) error

Jun 23, 2020

Changes in this version

+ const CollectionOrderView

+ const CollectionRoyaltyReport

+ const CollectionRoyaltyReportChanges

+ type AccountingEntryRepositoryInterface interface

+ ApplyObjectSource func(context.Context, string, string, string, string, *billingpb.AccountingEntry) (*billingpb.AccountingEntry, error)

+ BulkWrite func(context.Context, []*billingpb.AccountingEntry) error

+ FindBySource func(context.Context, string, string) ([]*billingpb.AccountingEntry, error)

+ FindByTypeCountryDates func(context.Context, string, []string, time.Time, time.Time) ([]*billingpb.AccountingEntry, error)

+ GetById func(context.Context, string) (*billingpb.AccountingEntry, error)

+ GetByObjectSource func(context.Context, string, string, string) (*billingpb.AccountingEntry, error)

+ GetByTypeWithTaxes func(context.Context, []string) ([]*billingpb.AccountingEntry, error)

+ GetCorrectionsForRoyaltyReport func(context.Context, string, string, time.Time, time.Time) ([]*billingpb.AccountingEntry, error)

+ GetDistinctBySourceId func(context.Context) ([]string, error)

+ GetRollingReserveForBalance func(context.Context, string, string, []string, time.Time) ([]*pkg.ReserveQueryResItem, error)

+ GetRollingReservesForRoyaltyReport func(context.Context, string, string, []string, time.Time, time.Time) ([]*billingpb.AccountingEntry, error)

+ MultipleInsert func(context.Context, []*billingpb.AccountingEntry) error

+ func NewAccountingEntryRepository(db mongodb.SourceInterface) AccountingEntryRepositoryInterface

+ type BankBinRepositoryInterface interface

+ GetByBin func(context.Context, int32) (*intPkg.BinData, error)

+ Insert func(context.Context, *intPkg.BinData) error

+ MultipleInsert func(context.Context, []*intPkg.BinData) error

+ func NewBankBinRepository(db mongodb.SourceInterface) BankBinRepositoryInterface

+ type CustomerRepositoryInterface interface

+ Find func(context.Context, string, *billingpb.TokenUser) (*billingpb.Customer, error)

+ GetById func(context.Context, string) (*billingpb.Customer, error)

+ Insert func(context.Context, *billingpb.Customer) error

+ Update func(context.Context, *billingpb.Customer) error

+ func NewCustomerRepository(db mongodb.SourceInterface) CustomerRepositoryInterface

+ type DashboardProcessorRepositoryInterface interface

+ ExecuteGrossRevenueAndVatReports func(context.Context, interface{}) (interface{}, error)

+ ExecuteReport func(context.Context, interface{}, ...) (interface{}, error)

+ ExecuteRevenueByCountryReport func(context.Context, interface{}) (interface{}, error)

+ ExecuteRevenueDynamicReport func(context.Context, interface{}) (interface{}, error)

+ ExecuteSalesTodayReport func(context.Context, interface{}) (interface{}, error)

+ ExecuteSourcesReport func(context.Context, interface{}) (interface{}, error)

+ ExecuteTotalTransactionsAndArpuReports func(context.Context, interface{}) (interface{}, error)

+ type DashboardReportProcessor struct

+ Cache database.CacheInterface

+ CacheExpire time.Duration

+ CacheKey string

+ Collection string

+ Db mongodb.SourceInterface

+ DbQueryFn func(ctx context.Context, receiver interface{}) (interface{}, error)

+ Errors map[string]*billingpb.ResponseErrorMessage

+ GroupBy string

+ Match bson.M

+ func (m *DashboardReportProcessor) ExecuteGrossRevenueAndVatReports(ctx context.Context, _ interface{}) (interface{}, error)

+ func (m *DashboardReportProcessor) ExecuteReport(ctx context.Context, receiver interface{}, ...) (interface{}, error)

+ func (m *DashboardReportProcessor) ExecuteRevenueByCountryReport(ctx context.Context, receiver interface{}) (interface{}, error)

+ func (m *DashboardReportProcessor) ExecuteRevenueDynamicReport(ctx context.Context, receiver interface{}) (interface{}, error)

+ func (m *DashboardReportProcessor) ExecuteSalesTodayReport(ctx context.Context, receiver interface{}) (interface{}, error)

+ func (m *DashboardReportProcessor) ExecuteSourcesReport(ctx context.Context, receiver interface{}) (interface{}, error)

+ func (m *DashboardReportProcessor) ExecuteTotalTransactionsAndArpuReports(ctx context.Context, _ interface{}) (interface{}, error)

+ type DashboardRepositoryInterface interface

+ GetBaseReport func(context.Context, string, string) (*billingpb.DashboardBaseReports, error)

+ GetMainReport func(context.Context, string, string) (*billingpb.DashboardMainReport, error)

+ GetRevenueDynamicsReport func(context.Context, string, string) (*billingpb.DashboardRevenueDynamicReport, error)

+ func NewDashboardRepository(db mongodb.SourceInterface, cache database.CacheInterface) DashboardRepositoryInterface

+ type FeedbackRepositoryInterface interface

+ GetAll func(context.Context) ([]*billingpb.PageReview, error)

+ Insert func(context.Context, *billingpb.PageReview) error

+ func NewFeedbackRepository(db mongodb.SourceInterface) FeedbackRepositoryInterface

+ type KeyProductRepositoryInterface interface

+ CountByProjectIdSku func(context.Context, string, string) (int64, error)

+ Find func(context.Context, string, string, string, string, string, int64, int64) ([]*billingpb.KeyProduct, error)

+ FindByIdsProjectId func(context.Context, []string, string) ([]*billingpb.KeyProduct, error)

+ FindCount func(context.Context, string, string, string, string, string) (int64, error)

+ GetById func(context.Context, string) (*billingpb.KeyProduct, error)

+ Update func(context.Context, *billingpb.KeyProduct) error

+ Upsert func(context.Context, *billingpb.KeyProduct) error

+ func NewKeyProductRepository(db mongodb.SourceInterface) KeyProductRepositoryInterface

+ type KeyRepositoryInterface interface

+ CancelById func(context.Context, string) (*billingpb.Key, error)

+ CountKeysByProductPlatform func(context.Context, string, string) (int64, error)

+ FindUnfinished func(context.Context) ([]*billingpb.Key, error)

+ FinishRedeemById func(context.Context, string) (*billingpb.Key, error)

+ GetById func(context.Context, string) (*billingpb.Key, error)

+ Insert func(context.Context, *billingpb.Key) error

+ ReserveKey func(context.Context, string, string, string, int32) (*billingpb.Key, error)

+ func NewKeyRepository(db mongodb.SourceInterface) KeyRepositoryInterface

+ type MerchantPaymentMethodHistoryRepositoryInterface interface

+ Insert func(context.Context, *billingpb.MerchantPaymentMethodHistory) error

+ func NewMerchantPaymentMethodHistoryRepository(db mongodb.SourceInterface) MerchantPaymentMethodHistoryRepositoryInterface

+ type MerchantPaymentTariffsInterface interface

+ Find func(context.Context, string, string, string, float64, float64) ([]*billingpb.MerchantTariffRatesPayment, error)

+ MultipleInsert func(context.Context, []*billingpb.MerchantTariffRatesPayment) error

+ func NewMerchantPaymentTariffsRepository(db mongodb.SourceInterface, cache database.CacheInterface) MerchantPaymentTariffsInterface

+ type MerchantTariffsSettingsInterface interface

+ GetByMccCode func(ctx context.Context, code string) (*billingpb.MerchantTariffRatesSettings, error)

+ Insert func(ctx context.Context, merchant *billingpb.MerchantTariffRatesSettings) error

+ func NewMerchantTariffsSettingsRepository(db mongodb.SourceInterface, cache database.CacheInterface) MerchantTariffsSettingsInterface

type MoneyBackCostMerchantRepositoryInterface

+ DeleteAndInsertMany func(ctx context.Context, merchantId string, ...) error

type OrderRepositoryInterface

+ GetByUuidAndMerchantId func(ctx context.Context, uuid string, merchantId string) (*billingpb.Order, error)

+ GetOneBy func(ctx context.Context, filter bson.M) (*billingpb.Order, error)

+ UpdateOrderView func(context.Context, []string) error

+ type OrderViewRepositoryInterface interface

+ CountTransactions func(ctx context.Context, match bson.M) (n int64, err error)

+ GetById func(context.Context, string) (*billingpb.OrderViewPublic, error)

+ GetPaylinkStat func(ctx context.Context, paylinkId, merchantId string, from, to int64) (*billingpb.StatCommon, error)

+ GetPaylinkStatByCountry func(ctx context.Context, paylinkId, merchantId string, from, to int64) (result *billingpb.GroupStatCommon, err error)

+ GetPaylinkStatByDate func(ctx context.Context, paylinkId, merchantId string, from, to int64) (result *billingpb.GroupStatCommon, err error)

+ GetPaylinkStatByReferrer func(ctx context.Context, paylinkId, merchantId string, from, to int64) (result *billingpb.GroupStatCommon, err error)

+ GetPaylinkStatByUtm func(ctx context.Context, paylinkId, merchantId string, from, to int64) (result *billingpb.GroupStatCommon, err error)

+ GetPrivateOrderBy func(ctx context.Context, id, uuid, merchantId string) (*billingpb.OrderViewPrivate, error)

+ GetPublicByOrderId func(ctx context.Context, merchantId string) (*billingpb.OrderViewPublic, error)

+ GetPublicOrderBy func(ctx context.Context, id, uuid, merchantId string) (*billingpb.OrderViewPublic, error)

+ GetRoyaltyForMerchants func(context.Context, []string, time.Time, time.Time) ([]*pkg.RoyaltyReportMerchant, error)

+ GetRoyaltySummary func(ctx context.Context, merchantId, currency string, from, to time.Time) (items []*billingpb.RoyaltyReportProductSummaryItem, ...)

+ GetTransactionsPrivate func(ctx context.Context, match bson.M, limit, offset int64) (result []*billingpb.OrderViewPrivate, err error)

+ GetTransactionsPublic func(ctx context.Context, match bson.M, limit, offset int64) (result []*billingpb.OrderViewPublic, err error)

+ GetTurnoverSummary func(context.Context, string, string, string, time.Time, time.Time) ([]*pkg.TurnoverQueryResItem, error)

+ GetVatSummary func(context.Context, string, string, bool, time.Time, time.Time) ([]*pkg.VatReportQueryResItem, error)

+ MarkIncludedToRoyaltyReport func(ctx context.Context, ordersIds []primitive.ObjectID, royaltyReportId string) error

+ func NewOrderViewRepository(db mongodb.SourceInterface) OrderViewRepositoryInterface

+ type PaylinkRepositoryInterface interface

+ Delete func(context.Context, *billingpb.Paylink) error

+ Find func(context.Context, string, string, int64, int64) ([]*billingpb.Paylink, error)

+ FindCount func(context.Context, string, string) (int64, error)

+ GetById func(context.Context, string) (*billingpb.Paylink, error)

+ GetByIdAndMerchant func(context.Context, string, string) (*billingpb.Paylink, error)

+ Insert func(context.Context, *billingpb.Paylink) error

+ Update func(context.Context, *billingpb.Paylink) error

+ UpdateTotalStat func(context.Context, *billingpb.Paylink) error

+ func NewPaylinkRepository(db mongodb.SourceInterface, cache database.CacheInterface) PaylinkRepositoryInterface

+ type PaylinkVisitRepositoryInterface interface

+ CountPaylinkVisits func(context.Context, string, int64, int64) (int64, error)

+ IncrVisits func(ctx context.Context, id string) error

+ func NewPaylinkVisitRepository(db mongodb.SourceInterface) PaylinkVisitRepositoryInterface

+ type PaymentChannelCostMerchantRepositoryInterface interface

+ Delete func(ctx context.Context, obj *billingpb.PaymentChannelCostMerchant) error

+ DeleteAndInsertMany func(ctx context.Context, merchantId string, ...) error

+ Find func(context.Context, string, string, string, string, string, string) ([]*internalPkg.PaymentChannelCostMerchantSet, error)

+ GetAllForMerchant func(context.Context, string) ([]*billingpb.PaymentChannelCostMerchant, error)

+ GetById func(context.Context, string) (*billingpb.PaymentChannelCostMerchant, error)

+ Insert func(context.Context, *billingpb.PaymentChannelCostMerchant) error

+ MultipleInsert func(context.Context, []*billingpb.PaymentChannelCostMerchant) error

+ Update func(context.Context, *billingpb.PaymentChannelCostMerchant) error

+ func NewPaymentChannelCostMerchantRepository(db mongodb.SourceInterface, cache database.CacheInterface) PaymentChannelCostMerchantRepositoryInterface

+ type PaymentChannelCostSystemRepositoryInterface interface

+ Delete func(ctx context.Context, obj *billingpb.PaymentChannelCostSystem) error

+ Find func(context.Context, string, string, string, string, string) (*billingpb.PaymentChannelCostSystem, error)

+ GetAll func(context.Context) ([]*billingpb.PaymentChannelCostSystem, error)

+ GetById func(context.Context, string) (*billingpb.PaymentChannelCostSystem, error)

+ Insert func(context.Context, *billingpb.PaymentChannelCostSystem) error

+ MultipleInsert func(context.Context, []*billingpb.PaymentChannelCostSystem) error

+ Update func(context.Context, *billingpb.PaymentChannelCostSystem) error

+ func NewPaymentChannelCostSystemRepository(db mongodb.SourceInterface, cache database.CacheInterface) PaymentChannelCostSystemRepositoryInterface

+ type PaymentMethodRepositoryInterface interface

+ Delete func(context.Context, *billingpb.PaymentMethod) error

+ FindByName func(context.Context, string, []string) ([]*billingpb.PaymentMethod, error)

+ GetAll func(ctx context.Context) ([]*billingpb.PaymentMethod, error)

+ GetByGroupAndCurrency func(ctx context.Context, isProduction bool, group string, currency string) (*billingpb.PaymentMethod, error)

+ GetById func(context.Context, string) (*billingpb.PaymentMethod, error)

+ Insert func(context.Context, *billingpb.PaymentMethod) error

+ ListByOrder func(ctx context.Context, order *billingpb.Order) ([]*billingpb.PaymentMethod, error)

+ MultipleInsert func(context.Context, []*billingpb.PaymentMethod) error

+ Update func(context.Context, *billingpb.PaymentMethod) error

+ func NewPaymentMethodRepository(db mongodb.SourceInterface, cache database.CacheInterface) PaymentMethodRepositoryInterface

+ type PaymentMinLimitSystemRepositoryInterface interface

+ GetAll func(context.Context) ([]*billingpb.PaymentMinLimitSystem, error)

+ GetByCurrency func(context.Context, string) (*billingpb.PaymentMinLimitSystem, error)

+ MultipleInsert func(context.Context, []*billingpb.PaymentMinLimitSystem) error

+ Upsert func(context.Context, *billingpb.PaymentMinLimitSystem) error

+ func NewPaymentMinLimitSystemRepository(db mongodb.SourceInterface, cache database.CacheInterface) PaymentMinLimitSystemRepositoryInterface

+ type PaymentSystemRepositoryInterface interface

+ GetById func(context.Context, string) (*billingpb.PaymentSystem, error)

+ Insert func(context.Context, *billingpb.PaymentSystem) error

+ MultipleInsert func(context.Context, []*billingpb.PaymentSystem) error

+ Update func(context.Context, *billingpb.PaymentSystem) error

+ func NewPaymentSystemRepository(db mongodb.SourceInterface, cache database.CacheInterface) PaymentSystemRepositoryInterface

+ type PayoutRepositoryInterface interface

+ Find func(ctx context.Context, merchantId string, statuses []string, ...) ([]*billingpb.PayoutDocument, error)

+ FindAll func(ctx context.Context) ([]*billingpb.PayoutDocument, error)

+ FindCount func(ctx context.Context, merchantId string, statuses []string, ...) (int64, error)

+ GetBalanceAmount func(context.Context, string, string) (float64, error)

+ GetById func(context.Context, string) (*billingpb.PayoutDocument, error)

+ GetByIdMerchantId func(context.Context, string, string) (*billingpb.PayoutDocument, error)

+ GetLast func(context.Context, string, string) (*billingpb.PayoutDocument, error)

+ Insert func(context.Context, *billingpb.PayoutDocument, string, string) error

+ Update func(context.Context, *billingpb.PayoutDocument, string, string) error

+ func NewPayoutRepository(db mongodb.SourceInterface, cache database.CacheInterface) PayoutRepositoryInterface

+ type ProductRepositoryInterface interface

+ CountByProject func(context.Context, string) (int64, error)

+ CountByProjectSku func(context.Context, string, string) (int64, error)

+ Find func(context.Context, string, string, string, string, int32, int64, int64) ([]*billingpb.Product, error)

+ FindCount func(context.Context, string, string, string, string, int32) (int64, error)

+ GetById func(context.Context, string) (*billingpb.Product, error)

+ MultipleInsert func(context.Context, []*billingpb.Product) error

+ Upsert func(ctx context.Context, product *billingpb.Product) error

+ func NewProductRepository(db mongodb.SourceInterface, cache database.CacheInterface) ProductRepositoryInterface

+ type RoyaltyReportFinance struct

+ Items []*postmarkpb.PayloadAttachment

+ type RoyaltyReportRepositoryInterface interface

+ FindByMerchantStatusDates func(ctx context.Context, merchantId string, statuses []string, ...) ([]*billingpb.RoyaltyReport, error)

+ FindCountByMerchantStatusDates func(ctx context.Context, merchantId string, statuses []string, ...) (int64, error)

+ GetAll func(ctx context.Context) ([]*billingpb.RoyaltyReport, error)

+ GetAllRoyaltyReportFinanceItems func(royaltyReportId string) []*postmarkpb.PayloadAttachment

+ GetBalanceAmount func(ctx context.Context, merchantId, currency string) (float64, error)

+ GetByAcceptedExpireWithStatus func(context.Context, time.Time, string) ([]*billingpb.RoyaltyReport, error)

+ GetById func(ctx context.Context, id string) (*billingpb.RoyaltyReport, error)

+ GetByPayoutId func(ctx context.Context, payoutId string) ([]*billingpb.RoyaltyReport, error)

+ GetByPeriod func(context.Context, time.Time, time.Time) ([]*billingpb.RoyaltyReport, error)

+ GetNonPayoutReports func(ctx context.Context, merchantId, currency string) ([]*billingpb.RoyaltyReport, error)

+ GetReportExists func(ctx context.Context, merchantId, currency string, from, to time.Time) (report *billingpb.RoyaltyReport)

+ GetRoyaltyHistoryById func(ctx context.Context, id string) ([]*billingpb.RoyaltyReportChanges, error)

+ Insert func(ctx context.Context, document *billingpb.RoyaltyReport, ip, source string) error

+ RemoveRoyaltyReportFinanceItems func(royaltyReportId string) error

+ SetRoyaltyReportFinanceItem func(royaltyReportId string, item *postmarkpb.PayloadAttachment) ([]*postmarkpb.PayloadAttachment, error)

+ Update func(ctx context.Context, document *billingpb.RoyaltyReport, ip, source string) error

+ UpdateMany func(ctx context.Context, query bson.M, set bson.M) error

+ func NewRoyaltyReportRepository(db mongodb.SourceInterface, cache database.CacheInterface) RoyaltyReportRepositoryInterface

+ type VatReportRepositoryInterface interface

+ GetByCountry func(context.Context, string, []string, int64, int64) ([]*billingpb.VatReport, error)

+ GetByCountryPeriod func(context.Context, string, time.Time, time.Time) (*billingpb.VatReport, error)

+ GetById func(context.Context, string) (*billingpb.VatReport, error)

+ GetByStatus func(context.Context, []string) ([]*billingpb.VatReport, error)

+ Insert func(context.Context, *billingpb.VatReport) error

+ Update func(context.Context, *billingpb.VatReport) error

+ func NewVatReportRepository(db mongodb.SourceInterface) VatReportRepositoryInterface

Feb 3, 2020

Changes in this version

+ const CollectionCountry

+ const CollectionMerchant

+ const CollectionOrder

+ const CollectionRefund

+ type CountryRepositoryInterface interface

+ FindByHighRisk func(ctx context.Context, isHighRiskOrder bool) (*billingpb.CountriesList, error)

+ FindByVatEnabled func(context.Context) (*billingpb.CountriesList, error)

+ GetAll func(context.Context) (*billingpb.CountriesList, error)

+ GetByIsoCodeA2 func(context.Context, string) (*billingpb.Country, error)

+ Insert func(context.Context, *billingpb.Country) error

+ IsTariffRegionSupported func(string) bool

+ MultipleInsert func(context.Context, []*billingpb.Country) error

+ Update func(context.Context, *billingpb.Country) error

+ func NewCountryRepository(db mongodb.SourceInterface, cache database.CacheInterface) CountryRepositoryInterface

+ type MerchantBalanceRepositoryInterface interface

+ CountByIdAndCurrency func(context.Context, string, string) (int64, error)

+ GetByIdAndCurrency func(context.Context, string, string) (*billingpb.MerchantBalance, error)

+ Insert func(context.Context, *billingpb.MerchantBalance) error

+ func NewMerchantBalanceRepository(db mongodb.SourceInterface, cache database.CacheInterface) MerchantBalanceRepositoryInterface

+ type MerchantRepositoryInterface interface

+ Find func(context.Context, bson.M, []string, int64, int64) ([]*billingpb.Merchant, error)

+ FindCount func(context.Context, bson.M) (int64, error)

+ GetAll func(ctx context.Context) ([]*billingpb.Merchant, error)

+ GetById func(ctx context.Context, id string) (*billingpb.Merchant, error)

+ GetByUserId func(ctx context.Context, id string) (*billingpb.Merchant, error)

+ GetCommonById func(ctx context.Context, id string) (*billingpb.MerchantCommon, error)

+ GetMerchantsWithAutoPayouts func(ctx context.Context) ([]*billingpb.Merchant, error)

+ Insert func(ctx context.Context, merchant *billingpb.Merchant) error

+ MultipleInsert func(ctx context.Context, merchants []*billingpb.Merchant) error

+ Update func(ctx context.Context, merchant *billingpb.Merchant) error

+ UpdateTariffs func(context.Context, string, *billingpb.PaymentChannelCostMerchant) error

+ Upsert func(ctx context.Context, merchant *billingpb.Merchant) error

+ func NewMerchantRepository(db mongodb.SourceInterface, cache database.CacheInterface) MerchantRepositoryInterface

+ type MoneyBackCostMerchantRepositoryInterface interface

+ Delete func(context.Context, *billingpb.MoneyBackCostMerchant) error

+ Find func(context.Context, string, string, string, string, string, string, string, int32) ([]*internalPkg.MoneyBackCostMerchantSet, error)

+ GetAllForMerchant func(context.Context, string) (*billingpb.MoneyBackCostMerchantList, error)

+ GetById func(context.Context, string) (*billingpb.MoneyBackCostMerchant, error)

+ Insert func(context.Context, *billingpb.MoneyBackCostMerchant) error

+ MultipleInsert func(context.Context, []*billingpb.MoneyBackCostMerchant) error

+ Update func(context.Context, *billingpb.MoneyBackCostMerchant) error

+ func NewMoneyBackCostMerchantRepository(db mongodb.SourceInterface, cache database.CacheInterface) MoneyBackCostMerchantRepositoryInterface

+ type MoneyBackCostSystemRepositoryInterface interface

+ Delete func(context.Context, *billingpb.MoneyBackCostSystem) error

+ Find func(context.Context, string, string, string, string, string, string, string, int32) ([]*internalPkg.MoneyBackCostSystemSet, error)

+ GetAll func(context.Context) (*billingpb.MoneyBackCostSystemList, error)

+ GetById func(context.Context, string) (*billingpb.MoneyBackCostSystem, error)

+ Insert func(context.Context, *billingpb.MoneyBackCostSystem) error

+ MultipleInsert func(context.Context, []*billingpb.MoneyBackCostSystem) error

+ Update func(context.Context, *billingpb.MoneyBackCostSystem) error

+ func NewMoneyBackCostSystemRepository(db mongodb.SourceInterface, cache database.CacheInterface) MoneyBackCostSystemRepositoryInterface

+ type NotificationRepositoryInterface interface

+ Find func(context.Context, string, string, int32, []string, int64, int64) ([]*billingpb.Notification, error)

+ FindCount func(context.Context, string, string, int32) (int64, error)

+ GetById func(context.Context, string) (*billingpb.Notification, error)

+ Insert func(context.Context, *billingpb.Notification) error

+ Update func(context.Context, *billingpb.Notification) error

+ func NewNotificationRepository(db mongodb.SourceInterface) NotificationRepositoryInterface

+ type NotifyRegionRepositoryInterface interface

+ FindByEmail func(context.Context, string) ([]*billingpb.NotifyUserNewRegion, error)

+ Insert func(context.Context, *billingpb.NotifyUserNewRegion) error

+ func NewNotifyRegionRepository(db mongodb.SourceInterface) NotifyRegionRepositoryInterface

+ type NotifySalesRepositoryInterface interface

+ FindByEmail func(context.Context, string) ([]*billingpb.NotifyUserSales, error)

+ Insert func(context.Context, *billingpb.NotifyUserSales) error

+ func NewNotifySalesRepository(db mongodb.SourceInterface) NotifySalesRepositoryInterface

+ type OperatingCompanyRepositoryInterface interface

+ Exists func(ctx context.Context, id string) bool

+ GetAll func(ctx context.Context) (result []*billingpb.OperatingCompany, err error)

+ GetById func(ctx context.Context, id string) (oc *billingpb.OperatingCompany, err error)

+ GetByPaymentCountry func(ctx context.Context, countryCode string) (oc *billingpb.OperatingCompany, err error)

+ Upsert func(ctx context.Context, oc *billingpb.OperatingCompany) (err error)

+ func NewOperatingCompanyRepository(db mongodb.SourceInterface, cache database.CacheInterface) OperatingCompanyRepositoryInterface

+ type OrderRepositoryInterface interface

+ GetById func(context.Context, string) (*billingpb.Order, error)

+ GetByProjectOrderId func(context.Context, string, string) (*billingpb.Order, error)

+ GetByRefundReceiptNumber func(context.Context, string) (*billingpb.Order, error)

+ GetByUuid func(context.Context, string) (*billingpb.Order, error)

+ Insert func(context.Context, *billingpb.Order) error

+ Update func(context.Context, *billingpb.Order) error

+ func NewOrderRepository(db mongodb.SourceInterface) OrderRepositoryInterface

+ type PriceGroupRepositoryInterface interface

+ GetAll func(context.Context) ([]*billingpb.PriceGroup, error)

+ GetById func(context.Context, string) (*billingpb.PriceGroup, error)

+ GetByRegion func(context.Context, string) (*billingpb.PriceGroup, error)

+ Insert func(context.Context, *billingpb.PriceGroup) error

+ MultipleInsert func(context.Context, []*billingpb.PriceGroup) error

+ Update func(context.Context, *billingpb.PriceGroup) error

+ func NewPriceGroupRepository(db mongodb.SourceInterface, cache database.CacheInterface) PriceGroupRepositoryInterface

+ type PriceTableRepositoryInterface interface

+ GetByRegion func(context.Context, string) (*billingpb.PriceTable, error)

+ Insert func(context.Context, *billingpb.PriceTable) error

+ func NewPriceTableRepository(db mongodb.SourceInterface) PriceTableRepositoryInterface

+ type ProjectRepositoryInterface interface

+ CountByMerchantId func(context.Context, string) (int64, error)

+ Find func(context.Context, string, string, []int32, int64, int64, []string) ([]*billingpb.Project, error)

+ FindCount func(context.Context, string, string, []int32) (int64, error)

+ GetById func(context.Context, string) (*billingpb.Project, error)

+ Insert func(context.Context, *billingpb.Project) error

+ MultipleInsert func(context.Context, []*billingpb.Project) error

+ Update func(context.Context, *billingpb.Project) error

+ func NewProjectRepository(db mongodb.SourceInterface, cache database.CacheInterface) ProjectRepositoryInterface

+ type RefundRepositoryInterface interface

+ CountByOrderUuid func(context.Context, string) (int64, error)

+ FindByOrderUuid func(context.Context, string, int64, int64) ([]*billingpb.Refund, error)

+ GetAmountByOrderId func(context.Context, string) (float64, error)

+ GetById func(context.Context, string) (*billingpb.Refund, error)

+ Insert func(context.Context, *billingpb.Refund) error

+ Update func(context.Context, *billingpb.Refund) error

+ func NewRefundRepository(db mongodb.SourceInterface) RefundRepositoryInterface

+ type TurnoverRepositoryInterface interface

+ CountAll func(context.Context) (int64, error)

+ Get func(context.Context, string, string, int) (*billingpb.AnnualTurnover, error)

+ Upsert func(context.Context, *billingpb.AnnualTurnover) error

+ func NewTurnoverRepository(db mongodb.SourceInterface, cache database.CacheInterface) TurnoverRepositoryInterface

+ type UserProfileRepositoryInterface interface

+ Add func(context.Context, *billingpb.UserProfile) error

+ GetById func(context.Context, string) (*billingpb.UserProfile, error)

+ GetByUserId func(context.Context, string) (*billingpb.UserProfile, error)

+ Update func(context.Context, *billingpb.UserProfile) error

+ Upsert func(ctx context.Context, profile *billingpb.UserProfile) error

+ func NewUserProfileRepository(db mongodb.SourceInterface) UserProfileRepositoryInterface

+ type UserRoleRepositoryInterface interface

+ AddAdminUser func(context.Context, *billingpb.UserRole) error

+ AddMerchantUser func(context.Context, *billingpb.UserRole) error

+ DeleteAdminUser func(context.Context, *billingpb.UserRole) error

+ DeleteMerchantUser func(context.Context, *billingpb.UserRole) error

+ GetAdminUserByEmail func(context.Context, string) (*billingpb.UserRole, error)

+ GetAdminUserById func(context.Context, string) (*billingpb.UserRole, error)

+ GetAdminUserByUserId func(context.Context, string) (*billingpb.UserRole, error)

+ GetMerchantOwner func(context.Context, string) (*billingpb.UserRole, error)

+ GetMerchantUserByEmail func(context.Context, string, string) (*billingpb.UserRole, error)

+ GetMerchantUserById func(context.Context, string) (*billingpb.UserRole, error)

+ GetMerchantUserByUserId func(context.Context, string, string) (*billingpb.UserRole, error)

+ GetMerchantsForUser func(context.Context, string) ([]*billingpb.UserRole, error)

+ GetSystemAdmin func(context.Context) (*billingpb.UserRole, error)

+ GetUsersForAdmin func(context.Context) ([]*billingpb.UserRole, error)

+ GetUsersForMerchant func(context.Context, string) ([]*billingpb.UserRole, error)

+ UpdateAdminUser func(context.Context, *billingpb.UserRole) error

+ UpdateMerchantUser func(context.Context, *billingpb.UserRole) error

+ func NewUserRoleRepository(db mongodb.SourceInterface, cache database.CacheInterface) UserRoleRepositoryInterface

+ type ZipCodeRepositoryInterface interface

+ CountByZip func(context.Context, string, string) (int64, error)

+ FindByZipAndCountry func(context.Context, string, string, int64, int64) ([]*billingpb.ZipCode, error)

+ GetByZipAndCountry func(context.Context, string, string) (*billingpb.ZipCode, error)

+ Insert func(context.Context, *billingpb.ZipCode) error

+ func NewZipCodeRepository(db mongodb.SourceInterface, cache database.CacheInterface) ZipCodeRepositoryInterface