org.killbill.billing.subscription.engine.dao

Class DefaultSubscriptionDao

java.lang.Object

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

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

All Implemented Interfaces:

SubscriptionDao, EntityDao<SubscriptionBundleModelDao,SubscriptionBaseBundle,org.killbill.billing.entitlement.api.SubscriptionApiException>

public class DefaultSubscriptionDao
extends EntityDaoBase<SubscriptionBundleModelDao,SubscriptionBaseBundle,org.killbill.billing.entitlement.api.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.killbill.clock.Clock clock, AddonUtils addonUtils, org.killbill.notificationq.api.NotificationQueueService notificationQueueService, org.killbill.bus.api.PersistentBus eventBus, CatalogService catalogService, CacheControllerDispatcher cacheControllerDispatcher, NonEntityDao nonEntityDao, InternalCallContextFactory internalCallContextFactory)

Method Summary

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

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

checkEntityAlreadyExists, create, createAndRefresh, get, getAll, getById, getByRecordId, getCount, 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,
                                      org.killbill.clock.Clock clock,
                                      AddonUtils addonUtils,
                                      org.killbill.notificationq.api.NotificationQueueService notificationQueueService,
                                      org.killbill.bus.api.PersistentBus eventBus,
                                      CatalogService catalogService,
                                      CacheControllerDispatcher cacheControllerDispatcher,
                                      NonEntityDao nonEntityDao,
                                      InternalCallContextFactory internalCallContextFactory)

Method Detail

generateAlreadyExistsException

protected org.killbill.billing.entitlement.api.SubscriptionApiException generateAlreadyExistsException(SubscriptionBundleModelDao entity,
                                                                                                       InternalCallContext context)

Specified by:

generateAlreadyExistsException in class EntityDaoBase<SubscriptionBundleModelDao,SubscriptionBaseBundle,org.killbill.billing.entitlement.api.SubscriptionApiException>

getSubscriptionBundlesForAccountAndKey

public List<SubscriptionBaseBundle> getSubscriptionBundlesForAccountAndKey(UUID accountId,
                                                                           String bundleKey,
                                                                           InternalTenantContext context)

Specified by:

getSubscriptionBundlesForAccountAndKey in interface SubscriptionDao

getSubscriptionBundleForAccount

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

Specified by:

getSubscriptionBundleForAccount in interface SubscriptionDao

getSubscriptionBundleFromId

public SubscriptionBaseBundle getSubscriptionBundleFromId(UUID bundleId,
                                                          InternalTenantContext context)

Specified by:

getSubscriptionBundleFromId in interface SubscriptionDao

getSubscriptionBundlesForKey

public List<SubscriptionBaseBundle> getSubscriptionBundlesForKey(String bundleKey,
                                                                 InternalTenantContext context)

Specified by:

getSubscriptionBundlesForKey in interface SubscriptionDao

searchSubscriptionBundles

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

Specified by:

searchSubscriptionBundles in interface SubscriptionDao

getNonAOSubscriptionIdsForKey

public Iterable<UUID> getNonAOSubscriptionIdsForKey(String bundleKey,
                                                    InternalTenantContext context)

Specified by:

getNonAOSubscriptionIdsForKey in interface SubscriptionDao

createSubscriptionBundle

public SubscriptionBaseBundle createSubscriptionBundle(DefaultSubscriptionBaseBundle bundle,
                                                       InternalCallContext context)

Specified by:

createSubscriptionBundle in interface SubscriptionDao

getAccountIdFromSubscriptionId

public UUID getAccountIdFromSubscriptionId(UUID subscriptionId,
                                           InternalTenantContext context)

Specified by:

getAccountIdFromSubscriptionId in interface SubscriptionDao

getBaseSubscription

public SubscriptionBase getBaseSubscription(UUID bundleId,
                                            InternalTenantContext context)
                                     throws CatalogApiException

Specified by:

getBaseSubscription in interface SubscriptionDao

Throws:

CatalogApiException

getSubscriptionFromId

public SubscriptionBase getSubscriptionFromId(UUID subscriptionId,
                                              InternalTenantContext context)
                                       throws CatalogApiException

Specified by:

getSubscriptionFromId in interface SubscriptionDao

Throws:

CatalogApiException

getSubscriptions

public List<SubscriptionBase> getSubscriptions(UUID bundleId,
                                               List<SubscriptionBaseEvent> dryRunEvents,
                                               InternalTenantContext context)
                                        throws CatalogApiException

Specified by:

getSubscriptions in interface SubscriptionDao

Throws:

CatalogApiException

getSubscriptionsForAccount

public Map<UUID,List<SubscriptionBase>> getSubscriptionsForAccount(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(UUID eventId,
                                          InternalTenantContext context)

Specified by:

getEventById in interface SubscriptionDao

getEventsForSubscription

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

Specified by:

getEventsForSubscription in interface SubscriptionDao

getFutureEventsForAccount

public Iterable<SubscriptionBaseEvent> getFutureEventsForAccount(InternalTenantContext context)

Specified by:

getFutureEventsForAccount in interface SubscriptionDao

getPendingEventsForSubscription

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

Specified by:

getPendingEventsForSubscription in interface SubscriptionDao

createSubscription

public void createSubscription(DefaultSubscriptionBase subscription,
                               List<SubscriptionBaseEvent> initialEvents,
                               InternalCallContext context)

Specified by:

createSubscription in interface SubscriptionDao

createSubscriptionsWithAddOns

public void createSubscriptionsWithAddOns(List<SubscriptionBaseWithAddOns> subscriptions,
                                          Map<UUID,List<SubscriptionBaseEvent>> initialEventsMap,
                                          InternalCallContext context)

Specified by:

createSubscriptionsWithAddOns in interface SubscriptionDao

cancelSubscriptionsOnBasePlanEvent

public void cancelSubscriptionsOnBasePlanEvent(DefaultSubscriptionBase subscription,
                                               SubscriptionBaseEvent event,
                                               List<DefaultSubscriptionBase> subscriptions,
                                               List<SubscriptionBaseEvent> cancelEvents,
                                               InternalCallContext context)

Specified by:

cancelSubscriptionsOnBasePlanEvent in interface SubscriptionDao

notifyOnBasePlanEvent

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

Specified by:

notifyOnBasePlanEvent in interface SubscriptionDao

cancelSubscriptions

public void cancelSubscriptions(List<DefaultSubscriptionBase> subscriptions,
                                List<SubscriptionBaseEvent> cancelEvents,
                                InternalCallContext context)

Specified by:

cancelSubscriptions in interface SubscriptionDao

uncancelSubscription

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

Specified by:

uncancelSubscription in interface SubscriptionDao

changePlan

public void changePlan(DefaultSubscriptionBase subscription,
                       List<SubscriptionBaseEvent> originalInputChangeEvents,
                       List<DefaultSubscriptionBase> subscriptionsToBeCancelled,
                       List<SubscriptionBaseEvent> cancelEvents,
                       InternalCallContext context)

Specified by:

changePlan in interface SubscriptionDao

transfer

public void transfer(UUID srcAccountId,
                     UUID destAccountId,
                     BundleTransferData bundleTransferData,
                     List<TransferCancelData> transferCancelData,
                     InternalCallContext fromContext,
                     InternalCallContext toContext)

Specified by:

transfer in interface SubscriptionDao

updateBundleExternalKey

public void updateBundleExternalKey(UUID bundleId,
                                    String externalKey,
                                    InternalCallContext context)

Specified by:

updateBundleExternalKey in interface SubscriptionDao

createBCDChangeEvent

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

Specified by:

createBCDChangeEvent in interface SubscriptionDao