@Getter
@Entity
@ToString(onlyExplicitlyIncluded = true)
@EqualsAndHashCode(onlyExplicitlyIncluded = true)
@IdClass(SpecialOperator.SpecialOperatorPK.class)
@Table(name = "SPECIAL_OPERATORS")
@Cacheable
@Cache(usage = READ_WRITE)
@NoArgsConstructor(access = PROTECTED)
public class SpecialOperator {

    @EqualsAndHashCode.Include
    @ToString.Include
    @Id
    private Provider provider;

    @EqualsAndHashCode.Include
    @ToString.Include
    @Id
    private String operatorId;

    @OneToMany(mappedBy = "operator", cascade = { PERSIST, MERGE, REMOVE }, orphanRemoval = true)
    private final Set<SpecialPricePoint> pricePoints = new HashSet<>();

    @CreationTimestamp
    @Column(name = "CREATION_DATE", nullable = false, updatable = false)
    private Instant creationDate;

    @UpdateTimestamp
    @Column(name = "MODIFICATION_DATE", nullable = false)
    private Instant modificationDate;

    public void addPricePoint(SpecialPricePoint pricePoint) {
        pricePoint.setOperator(this);
        pricePoints.add(pricePoint);
    }

    public SpecialOperator(Provider provider, String operatorId) {
        this.provider = provider;
        this.operatorId = operatorId;
    }

    @EqualsAndHashCode
    @ToString
    @Getter
    @NoArgsConstructor(access = PROTECTED)
    @AllArgsConstructor
    @Embeddable
    public static class SpecialOperatorPK implements Serializable {
        @Enumerated(EnumType.STRING)
        @Column(name = "PROVIDER_ID", nullable = false)
        Provider provider;

        @Column(name = "OPERATOR_ID", nullable = false)
        String operatorId;
    }
}

@Getter
@Entity
@EqualsAndHashCode(onlyExplicitlyIncluded = true)
@ToString(onlyExplicitlyIncluded = true)
@Table(name = "SPECIAL_OPERATOR_PRICES_POINTS")
@IdClass(SpecialPricePoint.SpecialPricePointPK.class)
@NoArgsConstructor(access = PROTECTED)
public class SpecialPricePoint {

    public SpecialPricePoint(SpecialOperator operator,
                             String wholesalePrice) {
        this.operator = operator;
        this.wholesalePrice = wholesalePrice;
    }

    @ManyToOne
    @ToString.Include
    @Setter(PACKAGE)
    @EqualsAndHashCode.Include
    @JoinColumn(name = "PROVIDER_ID", referencedColumnName = "PROVIDER_ID")
    @JoinColumn(name = "OPERATOR_ID", referencedColumnName = "OPERATOR_ID")
    @MapsId
    private SpecialOperator operator;

    @Column(name = "PRODUCT_ID")
    @Setter
    private String productId;

    @Id
    @Column(name = "PRICE_POINT", nullable = false)
    @ToString.Include
    @EqualsAndHashCode.Include
    String wholesalePrice;

    @OneToOne(cascade = { PERSIST, MERGE, REMOVE }, orphanRemoval = true)
    @JoinColumn(name = "PRODUCT_ID", referencedColumnName = "PRODUCT_ID", updatable = false, insertable = false)
    @JoinColumn(name = "PRICE_POINT",
                referencedColumnName = "WHOLESALE_PRICE_AMOUNT",
                updatable = false,
                insertable = false)
    @JoinColumn(name = "OPERATOR_ID", referencedColumnName = "OPERATOR_ID", updatable = false, insertable = false)
    @JoinColumn(name = "PROVIDER_ID", referencedColumnName = "PROVIDER_ID", updatable = false, insertable = false)
    @Cache(usage = READ_WRITE)
    private SpecialProduct product;

    public void setProduct(SpecialProduct product) {
        this.product = product;
        this.productId = product.getProductId();
        product.setWholesalePrice(this);
    }

    @Value
    @Embeddable
    @NoArgsConstructor(access = PROTECTED)
    @AllArgsConstructor
    public static class SpecialPricePointPK implements Serializable {
        @Embedded
        @NonFinal
        @AttributeOverride(name = "provider", column = @Column(name = "PROVIDER_ID", nullable = false))
        @AttributeOverride(name = "operatorId", column = @Column(name = "OPERATOR_ID", nullable = false))
        SpecialOperatorPK operator;

        @NonFinal
        String wholesalePrice;
    }
}

@Getter
@EqualsAndHashCode(onlyExplicitlyIncluded = true)
@ToString(onlyExplicitlyIncluded = true)
@NoArgsConstructor(access = PROTECTED)
@Table(name = "SPECIAL_PRODUCTS")
@Entity
@IdClass(SpecialProduct.SpecialProductPK.class)
@Cacheable
@Cache(usage = READ_WRITE)
@OptimisticLocking(type = OptimisticLockType.DIRTY)
@DynamicUpdate
public class SpecialProduct {
    public SpecialProduct(String productId,
                          SpecialPricePoint wholesalePrice) {
        this.productId = productId;
        this.wholesalePrice = wholesalePrice;
    }

    @Id
    @EqualsAndHashCode.Include

    @ToString.Include
    @Column(name = "PRODUCT_ID", nullable = false)
    private String productId;

    @Setter
    @ToString.Include
    @EqualsAndHashCode.Include
    @OneToOne(optional = false, mappedBy = "product")
    @MapsId
    private SpecialPricePoint wholesalePrice;

    @CreationTimestamp
    @Column(name = "CREATION_DATE", nullable = false, updatable = false)
    private Instant creationDate;

    @OptimisticLock(excluded = true)
    @UpdateTimestamp
    @Column(name = "MODIFICATION_DATE", nullable = false)
    private Instant modificationDate;

    @Value
    @Embeddable
    @NoArgsConstructor(access = PROTECTED)
    @AllArgsConstructor
    public static class SpecialProductPK implements Serializable {
        @Embedded
        @NonFinal
        @AttributeOverride(name = "operator.provider", column = @Column(name = "PROVIDER_ID", nullable = false))
        @AttributeOverride(name = "operator.operatorId", column = @Column(name = "OPERATOR_ID", nullable = false))
        @AttributeOverride(name = "wholesalePrice", column = @Column(name = "WHOLESALE_PRICE_AMOUNT", nullable = false))
        SpecialPricePointPK wholesalePrice;

        @NonFinal
        String productId;
    }
}

    @Test
    void shouldGetPricePoint() {
        // given
        String operatorId = "OPERATOR_1";
        Provider provider = A;
        SpecialOperator specialOperator = new SpecialOperator(provider, operatorId);
        specialOperatorService.addOperator(specialOperator);
        String wholesalePrice = "1 EUR";

        // when
        SpecialPricePoint specialPricePoint = new SpecialPricePoint(specialOperator, wholesalePrice);
        specialPricePointService.addPricePoint(specialPricePoint);

        // then
        Optional<SpecialPricePoint> pricePoint = specialPricePointService.getPricePoint(provider, operatorId, wholesalePrice);
        assertThat(pricePoint).isNotEmpty();
        assertThat(pricePoint.orElseThrow().getWholesalePrice()).isEqualTo(wholesalePrice);
    }