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)

Method Summary

Methods

Modifier and Type	Method and Description
void	cancelSubscription(DefaultSubscriptionBase subscription, SubscriptionBaseEvent cancelEvent, InternalCallContext context, int seqId)
void	cancelSubscriptions(List<DefaultSubscriptionBase> subscriptions, List<SubscriptionBaseEvent> cancelEvents, InternalCallContext context)
void	changePlan(DefaultSubscriptionBase subscription, List<SubscriptionBaseEvent> changeEvents, InternalCallContext context)
void	createNextPhaseEvent(DefaultSubscriptionBase subscription, SubscriptionBaseEvent nextPhase, InternalCallContext context)
void	createSubscription(DefaultSubscriptionBase subscription, List<SubscriptionBaseEvent> initialEvents, InternalCallContext context)
SubscriptionBaseBundle	createSubscriptionBundle(DefaultSubscriptionBaseBundle bundle, 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)
Map<UUID,List<SubscriptionBaseEvent>>	getEventsForBundle(UUID bundleId, InternalTenantContext context)
List<SubscriptionBaseEvent>	getEventsForSubscription(UUID subscriptionId, 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, InternalTenantContext context)
Map<UUID,List<SubscriptionBase>>	getSubscriptionsForAccount(InternalTenantContext context)
void	migrate(UUID accountId, AccountMigrationData accountData, InternalCallContext context)
void	recreateSubscription(DefaultSubscriptionBase subscription, List<SubscriptionBaseEvent> recreateEvents, InternalCallContext context)
void	repair(UUID accountId, UUID bundleId, List<SubscriptionDataRepair> inRepair, InternalCallContext context)
Pagination<SubscriptionBundleModelDao>	searchSubscriptionBundles(String searchKey, Long offset, Long limit, InternalTenantContext context)
void	transfer(UUID srcAccountId, UUID destAccountId, AccountMigrationData.BundleMigrationData 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, 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)

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)

Specified by:

getBaseSubscription in interface SubscriptionDao

getSubscriptionFromId

public SubscriptionBase getSubscriptionFromId(UUID subscriptionId,
                                     InternalTenantContext context)

Specified by:

getSubscriptionFromId in interface SubscriptionDao

getSubscriptions

public List<SubscriptionBase> getSubscriptions(UUID bundleId,
                                      InternalTenantContext context)

Specified by:

getSubscriptions in interface SubscriptionDao

getSubscriptionsForAccount

public Map<UUID,List<SubscriptionBase>> getSubscriptionsForAccount(InternalTenantContext context)

Specified by:

getSubscriptionsForAccount in interface SubscriptionDao

updateChargedThroughDate

public void updateChargedThroughDate(DefaultSubscriptionBase subscription,
                            InternalCallContext context)

Specified by:

updateChargedThroughDate in interface SubscriptionDao

createNextPhaseEvent

public void createNextPhaseEvent(DefaultSubscriptionBase subscription,
                        SubscriptionBaseEvent nextPhase,
                        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

getEventsForBundle

public Map<UUID,List<SubscriptionBaseEvent>> getEventsForBundle(UUID bundleId,
                                                       InternalTenantContext context)

Specified by:

getEventsForBundle 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

recreateSubscription

public void recreateSubscription(DefaultSubscriptionBase subscription,
                        List<SubscriptionBaseEvent> recreateEvents,
                        InternalCallContext context)

Specified by:

recreateSubscription in interface SubscriptionDao

cancelSubscriptions

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

Specified by:

cancelSubscriptions in interface SubscriptionDao

cancelSubscription

public void cancelSubscription(DefaultSubscriptionBase subscription,
                      SubscriptionBaseEvent cancelEvent,
                      InternalCallContext context,
                      int seqId)

Specified by:

cancelSubscription 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> changeEvents,
              InternalCallContext context)

Specified by:

changePlan in interface SubscriptionDao

migrate

public void migrate(UUID accountId,
           AccountMigrationData accountData,
           InternalCallContext context)

Specified by:

migrate in interface SubscriptionDao

repair

public void repair(UUID accountId,
          UUID bundleId,
          List<SubscriptionDataRepair> inRepair,
          InternalCallContext context)

Specified by:

repair in interface SubscriptionDao

transfer

public void transfer(UUID srcAccountId,
            UUID destAccountId,
            AccountMigrationData.BundleMigrationData 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