コードで学ぶ集約とリポジトリの関係〜DDD実践のためのきほん〜

はじめに

今回はポイント管理システムをテーマに

DDD×クリーンアーキテクチャでサンプルコードを作ったので、

それを使いながら、

集約とリポジトリの関係

についてまとめました。

集約とリポジトリのサンプルコード

今回テーマにしているポイントシステムでは、

店舗からレシート情報とカード、ポイント利用などを連携され、

付与ポイントの加算、ポイント利用の減算、

クーポンの発行とクーポン利用によるポイント付与率の制御ができる

ポイント管理システムを想定しています。

ポイント管理システムのイメージ図

まずは支払登録ユースケースを実現する際に登場する、

支払集約について考えてみましょう。

支払時には購入品、支払手段単位で付与ポイントを算出。

会員がポイントを利用すると会員の残ポイント減算。

を行う必要がある想定です。

支払集約ルート

class Payment(
    val receiptNumber: ReceiptNumber,
    private val paymentDate: PaymentDate,
    private val paymentAmount: PaymentAmount,
    private val paymentMember: PaymentMember,
    private val shopCode: ShopCode,
    private val couponCode: CouponCode?,
    private val paymentMethod: List<PaymentMethod>,
    private val paymentPurchase: List<PaymentPurchase>
) {
    init {
        if (paymentAmount.value != paymentMethod.sumOf { it.paymentAmount.value }) throw IllegalArgumentException("支払金額が不正です")
        if (paymentAmount.value != paymentPurchase.sumOf { it.goodsPrice.value }) throw IllegalArgumentException("支払金額が不正です")
    }
}

支払登録ユースケースは支払は必ずPaymentの単位で取り扱います。

それによって、

支払手段の合計金額と最終的な支払金額の整合性が取れない、

支払手段が外から自由に更新できて最終的な支払金額の整合性が取れない。

などが防げます。

次に支払をデータベースへ永続化する

リポジトリのサンプルコードを見てみましょう。

支払リポジトリ

interface IPaymentRepository {
    fun save(payment: Payment)
}

    @Transactional
    override fun save(payment: Payment) {
        val dataModel = payment.getDataModel()
        dslContext.insertInto(PAYMENT, PAYMENT.RECEIPT_NUMBER, PAYMENT.MEMBER_CODE, PAYMENT.AFFILIATE_COMPANY_CODE, PAYMENT.STORE_CODE, PAYMENT.USED_POINT)
            .values(dataModel.receiptNumber, dataModel.paymentMember.memberCode, dataModel.companyCode, dataModel.shopCode, dataModel.paymentMember.usePoints)

        dataModel.paymentMethod.forEach {
            dslContext.insertInto(PAYMENT_METHOD_DETAIL, PAYMENT_METHOD_DETAIL.RECEIPT_NUMBER, PAYMENT_METHOD_DETAIL.PAYMENT_METHOD_CODE, PAYMENT_METHOD_DETAIL.PAYMENT_AMOUNT, PAYMENT_METHOD_DETAIL.GIVEN_POINT)
                .values(dataModel.receiptNumber, it.paymentMethodCode, it.paymentMethodAmount, it.grantPoint)
        }

        dataModel.paymentPurchase.forEach {
            dslContext.insertInto(PURCHASE_PRODUCT_DETAIL, PURCHASE_PRODUCT_DETAIL.RECEIPT_NUMBER, PURCHASE_PRODUCT_DETAIL.AFFILIATE_COMPANY_CODE, PURCHASE_PRODUCT_DETAIL.PURCHASE_COUNT, PURCHASE_PRODUCT_DETAIL.PRODUCT_UNIT_PRICE, PURCHASE_PRODUCT_DETAIL.GIVEN_POINT)
                .values(dataModel.receiptNumber, dataModel.companyCode, it.purchaseQuantity, it.goodsPrice, it.grantPoint)
        }

        dslContext.update(MEMBER).set(MEMBER.POINT_BALANCE, dataModel.paymentMember.remainingPoints).where(MEMBER.MEMBER_CODE.eq(dataModel.paymentMember.memberCode))
    }

支払を登録する際は、

購入品と支払方法、

支払時の付与ポイント、利用ポイント

をセットで登録し、

会員の残ポイントの更新も行う必要があります。

これらどれか1つだけ登録や更新に失敗した状態で永続化すると、

支払登録の整合性が崩れることになるのです。