コードで学ぶCQRS〜DDD実践のためのきほん〜

class Payment(
    val receiptNumber: ReceiptNumber,
    private val paymentDateTime: PaymentDateTime,
    private val paymentMember: PaymentMember,
    private val companyCode: MemberCompanyCode,
    private val shopCode: ShopCode,
    private val couponCode: CouponCode?,
    private val paymentMethod: List<PaymentMethod>,
    private val paymentPurchase: List<PaymentPurchase>
) {
    init {
        if (paymentMethod.sumOf { it.paymentAmount.value } != paymentPurchase.sumOf { it.goodsPrice.value }) throw IllegalArgumentException("支払金額と購入金額が不整合です")
    }
    ・・・・
}



class PaymentMethod private constructor(
    val paymentMethodCode: PaymentMethodCode,
    val paymentAmount: PaymentAmount,
    private val grantPoint: Point
) {
    companion object {
        private const val PAYMENT_METHOD_POINT_RATE = 0.05
        fun create(
            paymentMethodCode: PaymentMethodCode,
            paymentAmount: PaymentAmount
        ): PaymentMethod {
            val grantPoint = floor(paymentAmount.value * PAYMENT_METHOD_POINT_RATE).toInt()

            return PaymentMethod(
                paymentMethodCode,
                paymentAmount,
                Point(grantPoint)
            )
        }
        ・・・・
}



class PaymentPurchase private constructor(
    val memberCompanyGoodsCode: MemberCompanyGoodsCode,
    private val purchaseQuantity: PurchaseQuantity,
    val goodsPrice: GoodsPrice,
    private val grantPoint: Point
) {
    companion object {
        private const val PAYMENT_PURCHASE_POINT_RATE = 0.05
        fun create(
            memberCompanyGoodsCode: MemberCompanyGoodsCode,
            purchaseQuantity: PurchaseQuantity,
            goodsPrice: GoodsPrice
        ): PaymentPurchase {
            val grantPoint = floor(purchaseQuantity.value * goodsPrice.value * PAYMENT_PURCHASE_POINT_RATE).toInt()

            return PaymentPurchase(
                memberCompanyGoodsCode,
                purchaseQuantity,
                goodsPrice,
                Point(grantPoint)
            )
        }
        ・・・
}



class PaymentMember(
    val memberCode: MemberCode,
    private val usePoints: Point = Point(0),
    private val remainingPoints: Point
) {

    fun usePoints(point: Point): PaymentMember {
        if (remainingPoints.value < point.value) throw IllegalArgumentException("ポイントが不足しています")
        return PaymentMember(memberCode, point, Point(remainingPoints.value - point.value))
    }
    ・・・
}

interface IListPointLogByMemberQueryService {

    data class Dto(
        val items: List<Item>
    ) {
        data class Item(
            val memberCode: MemberCode,
            val pointLogType: PointLogType,
            val transferPoints: Point
        )
    }

    enum class PointLogType {
        USE, ADD
    }

    fun list(memberCode: MemberCode): Dto
}



@Service
class ListPointLogByMemberQueryService(private val dslContext: DSLContext) : IListPointLogByMemberQueryService {

    override fun list(memberCode: MemberCode): IListPointLogByMemberQueryService.Dto {
        val resultRecords = dslContext.selectFrom(POINT_TRANSACTION_LOG)
            .where(
                POINT_TRANSACTION_LOG.RECEIPT_NUMBER.`in`(
                    dslContext.select(
                        PAYMENT.RECEIPT_NUMBER
                    )
                        .from(PAYMENT)
                        .where(PAYMENT.MEMBER_CODE.eq(memberCode.value.toInt()))
                        .fetch()
                )
            )
            .fetch()
        return convertToDto(resultRecords)
    }

    private fun convertToDto(records: Result<Record>): IListPointLogByMemberQueryService.Dto {
        val items = records.map {
            IListPointLogByMemberQueryService.Dto.Item(
                memberCode = MemberCode(it[POINT_TRANSACTION_LOG.RECEIPT_NUMBER].toString()),
                pointLogType = IListPointLogByMemberQueryService.PointLogType.valueOf(it[POINT_TRANSACTION_LOG.POINT_LOG_TYPE]),
                transferPoints = Point(it[POINT_TRANSACTION_LOG.TRANSACTION_POINTS])
            )
        }
        return IListPointLogByMemberQueryService.Dto(items)
    }
}