Subversion Repositories SmartDukaan

package com.spice.profitmandi.dao.entity.fofo;

import javax.persistence.Column;

import javax.persistence.Entity;

import javax.persistence.Id;

import javax.persistence.Table;

import java.io.Serializable;

import java.math.BigDecimal;

import java.math.RoundingMode;

import java.time.LocalDate;

import java.time.LocalDateTime;

/**

 * Current investment snapshot for one partner, maintained by the 2-minute sweep.

 *

 * <p>All the fast-moving columns are written in a single pass so that coupled terms can never be

 * read at different vintages. Wallet and utilised are coupled (an advance payment swept to a loan

 * moves both); in-stock and aged-Apple are coupled (the aged units are a subset of stock). Mixing

 * vintages between any such pair double-counts the money that moved between them.

 *

 * <p>{@link #getBaseValue()} is the single number the credit-limit tier consumes. The sweep

 * compares it at 2dp against the stored value to decide whether a partner's limit needs

 * recomputing, so it must never carry raw double noise.

 */

@Entity

@Table(name = "fofo.partner_investment")

public class PartnerInvestment implements Serializable {

    private static final long serialVersionUID = 1L;

    /** Money is rounded to paise everywhere; base_value is a comparison key, not an accumulator. */

    public static final int MONEY_SCALE = 2;

    @Id

    @Column(name = "fofo_id")

    private int fofoId;

    @Column(name = "wallet_amount")

    private BigDecimal walletAmount = BigDecimal.ZERO;

    /** Gross stock value; the live-demo haircut is applied by {@link #getNetInStockAmount()}. */

    @Column(name = "in_stock_gross_amount")

    private BigDecimal inStockGrossAmount = BigDecimal.ZERO;

    @Column(name = "unbilled_amount")

    private BigDecimal unbilledAmount = BigDecimal.ZERO;

    @Column(name = "grn_pending_amount")

    private BigDecimal grnPendingAmount = BigDecimal.ZERO;

    @Column(name = "activated_stock_amount")

    private BigDecimal activatedStockAmount = BigDecimal.ZERO;

    @Column(name = "activated_grn_pending_amount")

    private BigDecimal activatedGrnPendingAmount = BigDecimal.ZERO;

    @Column(name = "return_in_transit_amount")

    private BigDecimal returnInTransitAmount = BigDecimal.ZERO;

    @Column(name = "utilized_amount")

    private BigDecimal utilizedAmount = BigDecimal.ZERO;

    @Column(name = "aged_apple_stock_amount")

    private BigDecimal agedAppleStockAmount = BigDecimal.ZERO;

    /** Unit count behind {@link #agedAppleStockAmount}; maintained on the same daily cycle. */

    @Column(name = "aged_apple_qty")

    private int agedAppleQty;

    @Column(name = "demo_excluded_amount")

    private BigDecimal demoExcludedAmount = BigDecimal.ZERO;

    @Column(name = "aged_refreshed_on")

    private LocalDate agedRefreshedOn;

    @Column(name = "total_investment")

    private BigDecimal totalInvestment = BigDecimal.ZERO;

    @Column(name = "base_value")

    private BigDecimal baseValue = BigDecimal.ZERO;

    @Column(name = "snapshot_timestamp")

    private LocalDateTime snapshotTimestamp;

    public PartnerInvestment() {

    }

    public PartnerInvestment(int fofoId) {

        this.fofoId = fofoId;

    }

    private static BigDecimal scaled(BigDecimal value) {

        return (value == null ? BigDecimal.ZERO : value).setScale(MONEY_SCALE, RoundingMode.HALF_UP);

    }

    /**

     * Recomputes {@code totalInvestment} and {@code baseValue} from the component columns.

     *

     * <p>Mirrors PartnerDailyInvestment.getTotalInvestment() less the aged-Apple haircut, then less

     * utilisation — the same chain PartnerLimitHelper.getSuggestedAmount() applies before the tier

     * multiply. Keeping it here means the limit never has to re-derive it from separate reads.

     */

    public void recalculate() {

        BigDecimal total = scaled(walletAmount)

                .add(getNetInStockAmount())

                .add(scaled(unbilledAmount))

                .add(scaled(grnPendingAmount))

                .add(scaled(returnInTransitAmount))

                .subtract(scaled(activatedStockAmount))

                .subtract(scaled(activatedGrnPendingAmount));

        this.totalInvestment = scaled(total);

        this.baseValue = scaled(this.totalInvestment

                .subtract(scaled(agedAppleStockAmount))

                .subtract(scaled(utilizedAmount)));

    }

    /** True when the base has moved enough to matter, i.e. at all once rounded to paise. */

    public boolean baseDiffersFrom(PartnerInvestment other) {

        if (other == null) {

            return true;

        }

        return scaled(this.baseValue).compareTo(scaled(other.baseValue)) != 0;

    }

    public int getFofoId() {

        return fofoId;

    }

    public void setFofoId(int fofoId) {

        this.fofoId = fofoId;

    }

    public BigDecimal getWalletAmount() {

        return walletAmount;

    }

    public void setWalletAmount(BigDecimal walletAmount) {

        this.walletAmount = scaled(walletAmount);

    }

    public BigDecimal getInStockGrossAmount() {

        return inStockGrossAmount;

    }

    public void setInStockGrossAmount(BigDecimal inStockGrossAmount) {

        this.inStockGrossAmount = scaled(inStockGrossAmount);

    }

    /**

     * Stock as investment counts it: gross less live-demo units held past 90 days.

     *

     * <p>This is what {@code InventoryService.getTotalAmountInStock()} returns and what both

     * original investment paths assigned to {@code PartnerDailyInvestment.inStockAmount} — which is

     * why {@code getTotalInvestment()} carries no separate demo term. Derived rather than stored so

     * that the daily demo refresh flows through to stock and base with nothing to keep in sync.

     */

    public BigDecimal getNetInStockAmount() {

        return scaled(scaled(inStockGrossAmount).subtract(scaled(demoExcludedAmount)));

    }

    public BigDecimal getUnbilledAmount() {

        return unbilledAmount;

    }

    public void setUnbilledAmount(BigDecimal unbilledAmount) {

        this.unbilledAmount = scaled(unbilledAmount);

    }

    public BigDecimal getGrnPendingAmount() {

        return grnPendingAmount;

    }

    public void setGrnPendingAmount(BigDecimal grnPendingAmount) {

        this.grnPendingAmount = scaled(grnPendingAmount);

    }

    public BigDecimal getActivatedStockAmount() {

        return activatedStockAmount;

    }

    public void setActivatedStockAmount(BigDecimal activatedStockAmount) {

        this.activatedStockAmount = scaled(activatedStockAmount);

    }

    public BigDecimal getActivatedGrnPendingAmount() {

        return activatedGrnPendingAmount;

    }

    public void setActivatedGrnPendingAmount(BigDecimal activatedGrnPendingAmount) {

        this.activatedGrnPendingAmount = scaled(activatedGrnPendingAmount);

    }

    public BigDecimal getReturnInTransitAmount() {

        return returnInTransitAmount;

    }

    public void setReturnInTransitAmount(BigDecimal returnInTransitAmount) {

        this.returnInTransitAmount = scaled(returnInTransitAmount);

    }

    public BigDecimal getUtilizedAmount() {

        return utilizedAmount;

    }

    public void setUtilizedAmount(BigDecimal utilizedAmount) {

        this.utilizedAmount = scaled(utilizedAmount);

    }

    public BigDecimal getAgedAppleStockAmount() {

        return agedAppleStockAmount;

    }

    public void setAgedAppleStockAmount(BigDecimal agedAppleStockAmount) {

        this.agedAppleStockAmount = scaled(agedAppleStockAmount);

    }

    public int getAgedAppleQty() {

        return agedAppleQty;

    }

    public void setAgedAppleQty(int agedAppleQty) {

        this.agedAppleQty = agedAppleQty;

    }

    public BigDecimal getDemoExcludedAmount() {

        return demoExcludedAmount;

    }

    public void setDemoExcludedAmount(BigDecimal demoExcludedAmount) {

        this.demoExcludedAmount = scaled(demoExcludedAmount);

    }

    public LocalDate getAgedRefreshedOn() {

        return agedRefreshedOn;

    }

    public void setAgedRefreshedOn(LocalDate agedRefreshedOn) {

        this.agedRefreshedOn = agedRefreshedOn;

    }

    public BigDecimal getTotalInvestment() {

        return totalInvestment;

    }

    public void setTotalInvestment(BigDecimal totalInvestment) {

        this.totalInvestment = scaled(totalInvestment);

    }

    public BigDecimal getBaseValue() {

        return baseValue;

    }

    public void setBaseValue(BigDecimal baseValue) {

        this.baseValue = scaled(baseValue);

    }

    public LocalDateTime getSnapshotTimestamp() {

        return snapshotTimestamp;

    }

    public void setSnapshotTimestamp(LocalDateTime snapshotTimestamp) {

        this.snapshotTimestamp = snapshotTimestamp;

    }

    @Override

    public String toString() {

        return "PartnerInvestment{fofoId=" + fofoId

                + ", wallet=" + walletAmount

                + ", inStockGross=" + inStockGrossAmount

                + ", inStockNet=" + getNetInStockAmount()

                + ", unbilled=" + unbilledAmount

                + ", grnPending=" + grnPendingAmount

                + ", activatedStock=" + activatedStockAmount

                + ", activatedGrnPending=" + activatedGrnPendingAmount

                + ", agedApple=" + agedAppleStockAmount

                + ", demoExcluded=" + demoExcludedAmount

                + ", utilised=" + utilizedAmount

                + ", total=" + totalInvestment

                + ", base=" + baseValue

                + ", at=" + snapshotTimestamp + '}';

    }

}