Subversion Repositories SmartDukaan

package com.spice.profitmandi.service;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.dao.entity.inventory.SalesTargets;

import com.spice.profitmandi.dao.model.*;

import org.springframework.stereotype.Service;

import java.time.LocalDate;

import java.util.List;

@Service

public interface RbmTargetService {

    List<WarehouseRbmTargetModel> getWarehouseWiseRbmMonthlyTarget();

    List<WarehouseRbmTargetModel> getWarehouseWiseRbmMonthlyTarget(LocalDate monthStart);

    List<MTDAchievedTargetModel> getDateWiseAchievedTargetOfRbm(LocalDate startDate, LocalDate endDate);

    List<MTDAchievedTargetModel> getDateWiseAchievedTargetOfRbm(LocalDate startDate, LocalDate endDate, LocalDate targetMonthStart);

    List<WarehouseMobileStockByMovementModel> getWarehouseMobileStockByMovement();

    List<SoldCatalogsReportModel> getCatalogSoldReport(LocalDate startDate, LocalDate endDate);

    int getWorkingDaysCount(LocalDate startDate);

    List<TodayAchievedMovementModel> getMovementWiseAchievementByDate(LocalDate startDate, LocalDate endDate);

    List<RbmBrandSoldModel> getBrandsSoldByRbm(int authId, int warehouseId, LocalDate startDate, LocalDate endDate);

    List<RbmBrandPartnerCountModel> getBrandPartnerCountByRbm(int authId, int warehouseId, LocalDate startDate, LocalDate endDate);

    List<WarehouseBuyingByMovementModel> getWarehouseBuyingByMovement(int warehouseId, LocalDate startDate, LocalDate endDate);

    /**

     * Opening stock value per movement class for a warehouse at the start of a period.

     * Used by the RBM DRR drill-down "Warehouse Flow" table to contextualise the

     * period's buying/selling ratio against stock that already existed before the

     * period.

     *

     * @param warehouseId warehouse whose opening we want

     * @param asOfDate    the period start; everything received before this date

     *                    and everything sold before this date contribute

     */

    List<WarehouseOpeningByMovementModel> getWarehouseOpeningByMovement(int warehouseId, LocalDate asOfDate);

    /**

     * Daily writer for Sales-hierarchy targets (mirrors {@link #setMovementWiseRbmTargets}).

     * Reads today's persisted RBM snapshots from inventory.rbm_targets, rolls them up per

     * (sales_auth_id × warehouse_id) for every active Sales person whose downline contains

     * at least one RBM, and inserts one row per (sales, warehouse) into inventory.sales_targets.

     * Intended to run once daily via the cron flag {@code pushSalesTargets},

     * chained after {@code pushRbmTargets}.

     */

    void setSalesTargets();

    /**

     * Same as {@link #setSalesTargets()} but for a specific date — reads that

     * day's persisted RBM snapshots and writes Sales snapshots stamped to that

     * day. Useful for backfilling missed cron runs or seeding local/staging

     * data without needing today's RBM snapshot.

     */

    void setSalesTargetsForDate(LocalDate date);

    List<SalesTargets> getSalesTargetsByDates(LocalDate startDate, LocalDate endDate);

    /**

     * Historical snapshot writer for Sales-hierarchy achievement (mirrors

     * {@link #setMovementWiseRbmAchievement}). Rolls up today's live order

     * ACH into one row per (Sales person × warehouse) and persists to

     * {@code inventory.sales_achievements} for later reconciliation.

     * The DRR dashboard reads ACH LIVE from orders — this table is audit only.

     */

    void setSalesAchievements();

    /**

     * Dated variant of {@link #setSalesAchievements()} for backfill.

     */

    void setSalesAchievementsForDate(LocalDate date);

    /**

     * Per-(auth × warehouse) live achievement for a specific Sales-hierarchy role

     * (category 4, escalation L1..L6) in a date range. Direct query — no RBM roll-up.

     */

    List<SalesHierarchyAchievedByMovementModel> getSalesAchievementByRole(

            int categoryId, String escalationType, LocalDate startDate, LocalDate endDate);

    /**

     * Monthly target per (auth × warehouse) for a specific Sales-hierarchy role,

     * looked up for the month of {@code refDate}. Sum of

     * {@code fofo.monthly_target.purchase} across each Sales person's assigned partners.

     */

    List<SalesHierarchyMonthlyTargetModel> getSalesMonthlyTargetByRole(

            int categoryId, String escalationType, LocalDate refDate);

    /**

     * Distinct-partner rolled-up ACH per warehouse for a set of Sales-hierarchy

     * auth_ids (RSM/NSM's downline). Dedupes partners across positions so overlapping

     * assignments don't double-count.

     */

    List<com.spice.profitmandi.dao.model.SalesDownlineAchievedByMovementModel>

    getSalesDownlineAchievement(java.util.Collection<Integer> authIds, LocalDate startDate, LocalDate endDate);

    /**

     * Distinct-partner rolled-up monthly target per warehouse for a set of

     * Sales-hierarchy auth_ids. Same dedup guarantee as

     * {@link #getSalesDownlineAchievement}.

     */

    List<com.spice.profitmandi.dao.model.SalesDownlineMonthlyTargetModel>

    getSalesDownlineMonthlyTarget(java.util.Collection<Integer> authIds, LocalDate refDate);

    /**

     * Brand × movement-status sold by a set of Sales-hierarchy auth_ids in one

     * warehouse × date range. Works for both single-person views (pass one

     * authId) and RSM/NSM roll-ups (pass self + full downline). Dedupes

     * partners via SELECT DISTINCT.

     */

    List<com.spice.profitmandi.dao.model.SalesHierarchyBrandSoldModel>

    getSalesBrandsSold(java.util.Collection<Integer> authIds, int warehouseId, LocalDate startDate, LocalDate endDate);

    /**

     * Distinct partner count per brand for the same Sales-hierarchy auth_ids

     * set. Used for the "N partners" badge in the drill-down brand mix.

     */

    List<com.spice.profitmandi.dao.model.SalesHierarchyBrandPartnerCountModel>

    getSalesBrandPartnerCount(java.util.Collection<Integer> authIds, int warehouseId, LocalDate startDate, LocalDate endDate);

    List<RbmTargetAndAchievementsModel> getRbmTargetsAndAchievemnts(LocalDate startDate, LocalDate endDate);

    List<RbmArrViewModel> getRbmTodayArr(LocalDate todayDate) throws Exception;

    List<RbmArrViewModel> getRbmTodayArr() throws Exception;

    void setMovementWiseRbmTargets();

    void setMovementWiseRbmAchievement();

    List<Sold15daysOldAgingModel> getAgingSale(LocalDate startDate, LocalDate endDate);

    List<Our15DaysOldAgingStock> our15DaysAgingStock();

    List<WarehouseAgingStockModel> getWarehouseWiseAgingStock();

    List<RbmBilledFofoIdsModel> getDateWiseBilledFofoIdByRbm(LocalDate startDate, LocalDate endDate);

    List<RbmWeeklyBillingModel> getWeeklyBillingDataForMonth(LocalDate monthStart, LocalDate monthEnd);

    List<RbmWeeklyBillingModel> getWeeklyBillingDataForMonth(LocalDate monthStart, LocalDate monthEnd, LocalDate targetMonthStart);

    double calculateFofoIdTodayTarget(int fofoId, double secondryMtd, LocalDate date);

    long getRemainingDaysInMonth(LocalDate date);

    List<RbmCallTargetModel> getRbmCallTargetModels() throws Exception;

    List<RbmCallTargetModel> getRbmCallTargetModels(LocalDate queryDate) throws Exception;

    List<OutOfSequenceDetailModel> getOutOfSequenceDetails(int authId);

    List<CalledPartnerDetailModel> getCalledPartnerDetails(int authId) throws ProfitMandiBusinessException;

    List<CalledPartnerDetailModel> getCalledPartnerDetails(int authId, LocalDate date) throws ProfitMandiBusinessException;

    List<List<String>> getRbmCallTargetRawDataByAuthId(int authId) throws Exception;

    List<List<String>> getAllCallDataByDate(LocalDate date) throws Exception;

    List<List<String>> getAllRbmCallTargetRawData() throws Exception;

}