org.killbill.billing.subscription.engine.dao

Class DefaultSubscriptionDao

java.lang.Object

org.killbill.billing.util.entity.dao.EntityDaoBase<SubscriptionBundleModelDao,SubscriptionBaseBundle,SubscriptionApiException>

org.killbill.billing.subscription.engine.dao.DefaultSubscriptionDao

All Implemented Interfaces:

SubscriptionDao, EntityDao<SubscriptionBundleModelDao,SubscriptionBaseBundle,SubscriptionApiException>

public class DefaultSubscriptionDao
extends EntityDaoBase<SubscriptionBundleModelDao,SubscriptionBaseBundle,SubscriptionApiException>
implements SubscriptionDao

Field Summary

Fields inherited from class org.killbill.billing.util.entity.dao.EntityDaoBase

paginationHelper, transactionalSqlDao

Constructor Summary

Constructors

Constructor and Description
DefaultSubscriptionDao(org.skife.jdbi.v2.IDBI dbi, org.skife.jdbi.v2.IDBI roDbi, org.killbill.clock.Clock clock, AddonUtils addonUtils, org.killbill.notificationq.api.NotificationQueueService notificationQueueService, org.killbill.bus.api.PersistentBus eventBus, CacheControllerDispatcher cacheControllerDispatcher, NonEntityDao nonEntityDao, InternalCallContextFactory internalCallContextFactory)

Method Summary

Modifier and Type	Method and Description
void	cancelSubscriptions(java.util.List<DefaultSubscriptionBase> subscriptions, java.util.List<SubscriptionBaseEvent> cancelEvents, Catalog catalog, InternalCallContext context)
void	cancelSubscriptionsOnBasePlanEvent(DefaultSubscriptionBase subscription, SubscriptionBaseEvent event, java.util.List<DefaultSubscriptionBase> subscriptions, java.util.List<SubscriptionBaseEvent> cancelEvents, Catalog catalog, InternalCallContext context)
void	changePlan(DefaultSubscriptionBase subscription, java.util.List<SubscriptionBaseEvent> originalInputChangeEvents, java.util.List<DefaultSubscriptionBase> subscriptionsToBeCancelled, java.util.List<SubscriptionBaseEvent> cancelEvents, Catalog catalog, InternalCallContext context)
void	createBCDChangeEvent(DefaultSubscriptionBase subscription, SubscriptionBaseEvent bcdEvent, Catalog catalog, InternalCallContext context)
void	createNextPhaseEvent(DefaultSubscriptionBase subscription, SubscriptionBaseEvent readyPhaseEvent, SubscriptionBaseEvent nextPhaseEvent, InternalCallContext context)
SubscriptionBaseBundle	createSubscriptionBundle(DefaultSubscriptionBaseBundle bundle, Catalog catalog, boolean renameCancelledBundleIfExist, InternalCallContext context)
java.util.List<SubscriptionBaseEvent>	createSubscriptionsWithAddOns(java.util.List<SubscriptionBaseWithAddOns> subscriptions, java.util.Map<java.util.UUID,java.util.List<SubscriptionBaseEvent>> initialEventsMap, Catalog catalog, InternalCallContext context)
protected SubscriptionApiException	generateAlreadyExistsException(SubscriptionBundleModelDao entity, InternalCallContext context)
SubscriptionBase	getBaseSubscription(java.util.UUID bundleId, Catalog catalog, InternalTenantContext context)
java.util.UUID	getBundleIdFromSubscriptionId(java.util.UUID subscriptionId, InternalTenantContext context)
SubscriptionBaseEvent	getEventById(java.util.UUID eventId, InternalTenantContext context)
java.util.List<SubscriptionBaseEvent>	getEventsForSubscription(java.util.UUID subscriptionId, InternalTenantContext context)
java.lang.Iterable<java.util.UUID>	getNonAOSubscriptionIdsForKey(java.lang.String bundleKey, InternalTenantContext context)
java.util.List<SubscriptionBaseEvent>	getPendingEventsForSubscription(java.util.UUID subscriptionId, InternalTenantContext context)
java.util.List<SubscriptionBaseBundle>	getSubscriptionBundleForAccount(java.util.UUID accountId, InternalTenantContext context)
SubscriptionBaseBundle	getSubscriptionBundleFromId(java.util.UUID bundleId, InternalTenantContext context)
SubscriptionBaseBundle	getSubscriptionBundlesForAccountAndKey(java.util.UUID accountId, java.lang.String bundleKey, InternalTenantContext context)
java.util.List<SubscriptionBaseBundle>	getSubscriptionBundlesForKey(java.lang.String bundleKey, InternalTenantContext context)
SubscriptionBase	getSubscriptionFromId(java.util.UUID subscriptionId, Catalog catalog, InternalTenantContext context)
java.util.List<DefaultSubscriptionBase>	getSubscriptions(java.util.UUID bundleId, java.util.List<SubscriptionBaseEvent> dryRunEvents, Catalog catalog, InternalTenantContext context)
java.util.Map<java.util.UUID,java.util.List<DefaultSubscriptionBase>>	getSubscriptionsForAccount(Catalog catalog, InternalTenantContext context)
void	notifyOnBasePlanEvent(DefaultSubscriptionBase subscription, SubscriptionBaseEvent event, Catalog catalog, InternalCallContext context)
Pagination<SubscriptionBundleModelDao>	searchSubscriptionBundles(java.lang.String searchKey, java.lang.Long offset, java.lang.Long limit, InternalTenantContext context)
void	transfer(java.util.UUID srcAccountId, java.util.UUID destAccountId, BundleTransferData bundleTransferData, java.util.List<TransferCancelData> transferCancelData, Catalog catalog, InternalCallContext fromContext, InternalCallContext toContext)
void	uncancelSubscription(DefaultSubscriptionBase subscription, java.util.List<SubscriptionBaseEvent> uncancelEvents, InternalCallContext context)
void	undoChangePlan(DefaultSubscriptionBase subscription, java.util.List<SubscriptionBaseEvent> undoChangePlanEvents, InternalCallContext context)
void	updateBundleExternalKey(java.util.UUID bundleId, java.lang.String externalKey, InternalCallContext context)
void	updateChargedThroughDate(DefaultSubscriptionBase subscription, InternalCallContext context)

Methods inherited from class org.killbill.billing.util.entity.dao.EntityDaoBase

checkEntityAlreadyExists, create, create, createAndRefresh, get, getAll, getById, getByRecordId, getCount, getCreateEntitySqlDaoTransactionWrapper, getCreateEntitySqlDaoTransactionWrapper, getNaturalOrderingColumns, getRecordId, postBusEventFromTransaction, test

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.killbill.billing.util.entity.dao.EntityDao

create, get, getAll, getById, getByRecordId, getCount, getRecordId, test

Constructor Detail

DefaultSubscriptionDao

@Inject
public DefaultSubscriptionDao(org.skife.jdbi.v2.IDBI dbi,
                                      @Named(value="main-ro")
                                      org.skife.jdbi.v2.IDBI roDbi,
                                      org.killbill.clock.Clock clock,
                                      AddonUtils addonUtils,
                                      org.killbill.notificationq.api.NotificationQueueService notificationQueueService,
                                      org.killbill.bus.api.PersistentBus eventBus,
                                      CacheControllerDispatcher cacheControllerDispatcher,
                                      NonEntityDao nonEntityDao,
                                      InternalCallContextFactory internalCallContextFactory)

Method Detail

generateAlreadyExistsException

protected SubscriptionApiException generateAlreadyExistsException(SubscriptionBundleModelDao entity,
                                                                  InternalCallContext context)

Specified by:

generateAlreadyExistsException in class EntityDaoBase<SubscriptionBundleModelDao,SubscriptionBaseBundle,SubscriptionApiException>

getSubscriptionBundlesForAccountAndKey

public SubscriptionBaseBundle getSubscriptionBundlesForAccountAndKey(java.util.UUID accountId,
                                                                     java.lang.String bundleKey,
                                                                     InternalTenantContext context)

Specified by:

getSubscriptionBundlesForAccountAndKey in interface SubscriptionDao

getSubscriptionBundleForAccount

public java.util.List<SubscriptionBaseBundle> getSubscriptionBundleForAccount(java.util.UUID accountId,
                                                                              InternalTenantContext context)

Specified by:

getSubscriptionBundleForAccount in interface SubscriptionDao

getSubscriptionBundleFromId

public SubscriptionBaseBundle getSubscriptionBundleFromId(java.util.UUID bundleId,
                                                          InternalTenantContext context)

Specified by:

getSubscriptionBundleFromId in interface SubscriptionDao

getSubscriptionBundlesForKey

public java.util.List<SubscriptionBaseBundle> getSubscriptionBundlesForKey(java.lang.String bundleKey,
                                                                           InternalTenantContext context)

Specified by:

getSubscriptionBundlesForKey in interface SubscriptionDao

searchSubscriptionBundles

public Pagination<SubscriptionBundleModelDao> searchSubscriptionBundles(java.lang.String searchKey,
                                                                        java.lang.Long offset,
                                                                        java.lang.Long limit,
                                                                        InternalTenantContext context)

Specified by:

searchSubscriptionBundles in interface SubscriptionDao

getNonAOSubscriptionIdsForKey

public java.lang.Iterable<java.util.UUID> getNonAOSubscriptionIdsForKey(java.lang.String bundleKey,
                                                                        InternalTenantContext context)

Specified by:

getNonAOSubscriptionIdsForKey in interface SubscriptionDao

createSubscriptionBundle

public SubscriptionBaseBundle createSubscriptionBundle(DefaultSubscriptionBaseBundle bundle,
                                                       Catalog catalog,
                                                       boolean renameCancelledBundleIfExist,
                                                       InternalCallContext context)
                                                throws SubscriptionBaseApiException

Specified by:

createSubscriptionBundle in interface SubscriptionDao

Throws:

SubscriptionBaseApiException

getBaseSubscription

public SubscriptionBase getBaseSubscription(java.util.UUID bundleId,
                                            Catalog catalog,
                                            InternalTenantContext context)
                                     throws CatalogApiException

Specified by:

getBaseSubscription in interface SubscriptionDao

Throws:

CatalogApiException

getSubscriptionFromId

public SubscriptionBase getSubscriptionFromId(java.util.UUID subscriptionId,
                                              Catalog catalog,
                                              InternalTenantContext context)
                                       throws CatalogApiException

Specified by:

getSubscriptionFromId in interface SubscriptionDao

Throws:

CatalogApiException

getBundleIdFromSubscriptionId

public java.util.UUID getBundleIdFromSubscriptionId(java.util.UUID subscriptionId,
                                                    InternalTenantContext context)

Specified by:

getBundleIdFromSubscriptionId in interface SubscriptionDao

getSubscriptions

public java.util.List<DefaultSubscriptionBase> getSubscriptions(java.util.UUID bundleId,
                                                                java.util.List<SubscriptionBaseEvent> dryRunEvents,
                                                                Catalog catalog,
                                                                InternalTenantContext context)
                                                         throws CatalogApiException

Specified by:

getSubscriptions in interface SubscriptionDao

Throws:

CatalogApiException

getSubscriptionsForAccount

public java.util.Map<java.util.UUID,java.util.List<DefaultSubscriptionBase>> getSubscriptionsForAccount(Catalog catalog,
                                                                                                        InternalTenantContext context)
                                                                                                 throws CatalogApiException

Specified by:

getSubscriptionsForAccount in interface SubscriptionDao

Throws:

CatalogApiException

updateChargedThroughDate

public void updateChargedThroughDate(DefaultSubscriptionBase subscription,
                                     InternalCallContext context)

Specified by:

updateChargedThroughDate in interface SubscriptionDao

createNextPhaseEvent

public void createNextPhaseEvent(DefaultSubscriptionBase subscription,
                                 SubscriptionBaseEvent readyPhaseEvent,
                                 SubscriptionBaseEvent nextPhaseEvent,
                                 InternalCallContext context)

Specified by:

createNextPhaseEvent in interface SubscriptionDao

getEventById

public SubscriptionBaseEvent getEventById(java.util.UUID eventId,
                                          InternalTenantContext context)

Specified by:

getEventById in interface SubscriptionDao

getEventsForSubscription

public java.util.List<SubscriptionBaseEvent> getEventsForSubscription(java.util.UUID subscriptionId,
                                                                      InternalTenantContext context)

Specified by:

getEventsForSubscription in interface SubscriptionDao

getPendingEventsForSubscription

public java.util.List<SubscriptionBaseEvent> getPendingEventsForSubscription(java.util.UUID subscriptionId,
                                                                             InternalTenantContext context)

Specified by:

getPendingEventsForSubscription in interface SubscriptionDao

createSubscriptionsWithAddOns

public java.util.List<SubscriptionBaseEvent> createSubscriptionsWithAddOns(java.util.List<SubscriptionBaseWithAddOns> subscriptions,
                                                                           java.util.Map<java.util.UUID,java.util.List<SubscriptionBaseEvent>> initialEventsMap,
                                                                           Catalog catalog,
                                                                           InternalCallContext context)

Specified by:

createSubscriptionsWithAddOns in interface SubscriptionDao

cancelSubscriptionsOnBasePlanEvent

public void cancelSubscriptionsOnBasePlanEvent(DefaultSubscriptionBase subscription,
                                               SubscriptionBaseEvent event,
                                               java.util.List<DefaultSubscriptionBase> subscriptions,
                                               java.util.List<SubscriptionBaseEvent> cancelEvents,
                                               Catalog catalog,
                                               InternalCallContext context)

Specified by:

cancelSubscriptionsOnBasePlanEvent in interface SubscriptionDao

notifyOnBasePlanEvent

public void notifyOnBasePlanEvent(DefaultSubscriptionBase subscription,
                                  SubscriptionBaseEvent event,
                                  Catalog catalog,
                                  InternalCallContext context)

Specified by:

notifyOnBasePlanEvent in interface SubscriptionDao

cancelSubscriptions

public void cancelSubscriptions(java.util.List<DefaultSubscriptionBase> subscriptions,
                                java.util.List<SubscriptionBaseEvent> cancelEvents,
                                Catalog catalog,
                                InternalCallContext context)

Specified by:

cancelSubscriptions in interface SubscriptionDao

uncancelSubscription

public void uncancelSubscription(DefaultSubscriptionBase subscription,
                                 java.util.List<SubscriptionBaseEvent> uncancelEvents,
                                 InternalCallContext context)

Specified by:

uncancelSubscription in interface SubscriptionDao

undoChangePlan

public void undoChangePlan(DefaultSubscriptionBase subscription,
                           java.util.List<SubscriptionBaseEvent> undoChangePlanEvents,
                           InternalCallContext context)

Specified by:

undoChangePlan in interface SubscriptionDao

changePlan

public void changePlan(DefaultSubscriptionBase subscription,
                       java.util.List<SubscriptionBaseEvent> originalInputChangeEvents,
                       java.util.List<DefaultSubscriptionBase> subscriptionsToBeCancelled,
                       java.util.List<SubscriptionBaseEvent> cancelEvents,
                       Catalog catalog,
                       InternalCallContext context)

Specified by:

changePlan in interface SubscriptionDao

transfer

public void transfer(java.util.UUID srcAccountId,
                     java.util.UUID destAccountId,
                     BundleTransferData bundleTransferData,
                     java.util.List<TransferCancelData> transferCancelData,
                     Catalog catalog,
                     InternalCallContext fromContext,
                     InternalCallContext toContext)

Specified by:

transfer in interface SubscriptionDao

updateBundleExternalKey

public void updateBundleExternalKey(java.util.UUID bundleId,
                                    java.lang.String externalKey,
                                    InternalCallContext context)

Specified by:

updateBundleExternalKey in interface SubscriptionDao

createBCDChangeEvent

public void createBCDChangeEvent(DefaultSubscriptionBase subscription,
                                 SubscriptionBaseEvent bcdEvent,
                                 Catalog catalog,
                                 InternalCallContext context)

Specified by:

createBCDChangeEvent in interface SubscriptionDao