WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/RbmTargetServiceImpl.java

 package com.spice.profitmandi.service;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
+import com.spice.profitmandi.dao.entity.inventory.RbmTargets;
 import com.spice.profitmandi.dao.model.*;
+import com.spice.profitmandi.dao.repository.catalog.RbmTargetsRepository;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.hibernate.Session;
 import org.hibernate.SessionFactory;
 import org.hibernate.query.NativeQuery;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Component;
 import javax.persistence.TypedQuery;
 import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
 import java.util.ArrayList;
 import java.util.List;
 @Component
 public class RbmTargetServiceImpl implements RbmTargetService {
     private static final Logger LOGGER = LogManager.getLogger(RbmTargetServiceImpl.class);
     @Autowired
     SessionFactory sessionFactory;
+    @Autowired
+    RbmTargetsRepository rbmTargetsRepository;
     @Override
     public List<WarehouseRbmTargetModel> getWarehouseWiseRbmMonthlyTarget() {
         Session session = sessionFactory.getCurrentSession();
         final TypedQuery<WarehouseRbmTargetModel> typedQuerySimilar = session.createNamedQuery("RbmTarget.getWarehouseWiseMonthlyTarget", WarehouseRbmTargetModel.class);
         return typedQuerySimilar.getResultList();
+    }
     @Override
-    @Cacheable(value = "warehouseMobileStockByMovement", cacheManager = "oneDayCacheManager")
     public List<WarehouseMobileStockByMovementModel> getWarehouseMobileStockByMovement() {
         Session session = sessionFactory.getCurrentSession();
         final TypedQuery<WarehouseMobileStockByMovementModel> typedQuerySimilar = session.createNamedQuery("WarehouseStock.MovementWiseMobileStock", WarehouseMobileStockByMovementModel.class);
         return typedQuerySimilar.getResultList();
         LocalDate startDateOfMonthDay1 = LocalDate.now().withDayOfMonth(1);
         List<WarehouseRbmTargetModel> warehouseRbmTargetModels = this.getWarehouseWiseRbmMonthlyTarget();
         List<TodayAchievedMovementModel> todayAchievedMovementModels = getTodayTargetByMovement(todayDate, todayDate.plusDays(1));
-        // LOGGER.info("todayAchievedMovementModels {} ", todayAchievedMovementModels);
         List<MTDAchievedTargetModel> mtdAchievedTargetModels = getDateWiseAchievedTargetOfRbm(startDateOfMonthDay1, todayDate);
         int remainingWorkingDaysCount = getWorkingDaysCount(todayDate);
-        List<WarehouseMobileStockByMovementModel> warehouseMobileStockByMovementModels = getWarehouseMobileStockByMovement();
+        List<RbmTargets> todayRbmTargetsList = rbmTargetsRepository.selectTargetsByDates(todayDate.atStartOfDay(), todayDate.atTime(LocalTime.MAX));
-        // LOGGER.info("warehouseMobileStockByMovementModels {}",warehouseMobileStockByMovementModels);
+        LOGGER.info("todayRbmTargetsList {}", todayRbmTargetsList);
         List<RbmArrViewModel> rbmArrViewModels = new ArrayList<>();
         for (WarehouseRbmTargetModel rbmTarget : warehouseRbmTargetModels) {
-            // LOGGER.info("rbmTarget {}",rbmTarget);
             float monthlyTarget = rbmTarget.getMonthlyTarget();
             float achievedSoFar = (float) mtdAchievedTargetModels.stream()
                     .filter(x -> x.getAuthId() == rbmTarget.getAuthId() && x.getWarehouseId() == rbmTarget.getWarehouseId())
                     .mapToDouble(MTDAchievedTargetModel::getAcheivedMonthlyTarget)
                     .sum();
             float remainingTarget = monthlyTarget - achievedSoFar;
             float todayTarget = remainingWorkingDaysCount > 0 ? remainingTarget / remainingWorkingDaysCount : 0;
-            // Get the warehouse stock data
-            WarehouseMobileStockByMovementModel warehouseMobileStockByMovementModel = warehouseMobileStockByMovementModels.stream()
-                    .filter(x -> x.getWarehouseId() == rbmTarget.getWarehouseId()).findFirst().orElse(null);
-            if (warehouseMobileStockByMovementModel != null) {
-                // Total stock value for this warehouse
-                float totalStockValue = warehouseMobileStockByMovementModel.getTotalAvailabilityPrice();
-                // Calculate target allocation based on stock value proportion
-                float hidTarget = (warehouseMobileStockByMovementModel.getTotalHidCatalogPrice() / totalStockValue) * todayTarget;
-                float fastMovingTarget = (warehouseMobileStockByMovementModel.getTotalFastMovingCatalogPrice() / totalStockValue) * todayTarget;
-                float slowMovingTarget = (warehouseMobileStockByMovementModel.getTotalSlowMovingCatalogPrice() / totalStockValue) * todayTarget;
-                float eolTarget = (warehouseMobileStockByMovementModel.getTotalEolCatalogPrice() / totalStockValue) * todayTarget;
-                float otherTarget = (warehouseMobileStockByMovementModel.getTotalOtherCategoryCatalogPrice() / totalStockValue) * todayTarget;
-//                set all realated value in view model for dashboard
                 String warehouseName = ProfitMandiConstants.WAREHOUSE_MAP.getOrDefault(rbmTarget.getWarehouseId(), "Unknown");
                 TodayAchievedMovementModel todayAchievedMovementModel = todayAchievedMovementModels.stream().filter(x -> x.getAuthId() == rbmTarget.getAuthId() && x.getWarehouseId() == rbmTarget.getWarehouseId()).findFirst().get();
+            RbmTargets todayRbmTargets = todayRbmTargetsList.stream().filter(x -> x.getRbmAuthId() == rbmTarget.getAuthId() && x.getWarehouseId() == rbmTarget.getWarehouseId()).findFirst().get();
-                //  LOGGER.info("todayAchievedMovementModel {}",todayAchievedMovementModel);
+            LOGGER.info("todayRbmTargets {}", todayRbmTargets);
                 RbmArrViewModel viewModel = new RbmArrViewModel();
                 viewModel.setAuthId(rbmTarget.getAuthId());
                 viewModel.setRbmName(rbmTarget.getRbmName());
                 viewModel.setWarehouseName(warehouseName);
                 viewModel.setTodayTarget(Math.round(todayTarget));
                 viewModel.setMonthlyTarget(Math.round(monthlyTarget));
                 viewModel.setMtdAchievedTarget(Math.round(achievedSoFar));
-                viewModel.setTodayHidTarget(Math.round((hidTarget)));
+            viewModel.setTodayHidTarget(Math.round((todayRbmTargets.getHidTarget())));
-                viewModel.setTodayFastMovingTarget(Math.round(fastMovingTarget));
+            viewModel.setTodayFastMovingTarget(Math.round(todayRbmTargets.getFastMovingTarget()));
-                viewModel.setTodaySlowMovingTarget(Math.round(slowMovingTarget));
+            viewModel.setTodaySlowMovingTarget(Math.round(todayRbmTargets.getSlowMovingTarget()));
-                viewModel.setTodayEolTarget(Math.round(eolTarget));
+            viewModel.setTodayEolTarget(Math.round(todayRbmTargets.getEolTarget()));
-                viewModel.setTodayOtherMovingTarget(Math.round(otherTarget));
+            viewModel.setTodayOtherMovingTarget(Math.round(todayRbmTargets.getOtherTarget()));
                 viewModel.setTodayAchievedHidTarget(Math.round(todayAchievedMovementModel.getHidBilled()));
                 viewModel.setTodayAchievedFastMovingTarget(Math.round(todayAchievedMovementModel.getFastMovingBilled()));
                 viewModel.setTodayAchievedSlowMovingTarget(Math.round(todayAchievedMovementModel.getSlowMovingBilled()));
                 viewModel.setTodayAchievedEolTarget(Math.round(todayAchievedMovementModel.getEolBilled()));
                 viewModel.setTodayAchievedOtherMovingTarget(Math.round(todayAchievedMovementModel.getOtherBilled()));
                 viewModel.setTotalAchievedTarget(Math.round(todayAchievedMovementModel.getHidBilled() + todayAchievedMovementModel.getFastMovingBilled() + todayAchievedMovementModel.getSlowMovingBilled() + todayAchievedMovementModel.getEolBilled() + todayAchievedMovementModel.getOtherBilled()));
                 rbmArrViewModels.add(viewModel);
-            }
+        }
         LOGGER.info("rbmArrViewModels {}", rbmArrViewModels);
         return rbmArrViewModels;
+    }
+    @Override
+    public void setMovementWiseRbmTargets() {
+        LocalDate todayDate = LocalDate.now();
+        LocalDate startDateOfMonthDay1 = LocalDate.now().withDayOfMonth(1);
+        List<WarehouseRbmTargetModel> warehouseRbmTargetModels = this.getWarehouseWiseRbmMonthlyTarget();
+        List<MTDAchievedTargetModel> mtdAchievedTargetModels = getDateWiseAchievedTargetOfRbm(startDateOfMonthDay1, todayDate);
+        int remainingWorkingDaysCount = getWorkingDaysCount(todayDate);
+        List<WarehouseMobileStockByMovementModel> warehouseMobileStockByMovementModels = getWarehouseMobileStockByMovement();
+        for (WarehouseRbmTargetModel rbmTarget : warehouseRbmTargetModels) {
+            float monthlyTarget = rbmTarget.getMonthlyTarget();
+            float achievedSoFar = (float) mtdAchievedTargetModels.stream()
+                    .filter(x -> x.getAuthId() == rbmTarget.getAuthId() && x.getWarehouseId() == rbmTarget.getWarehouseId())
+                    .mapToDouble(MTDAchievedTargetModel::getAcheivedMonthlyTarget)
+                    .sum();
+            float remainingTarget = monthlyTarget - achievedSoFar;
+            float todayTarget = remainingWorkingDaysCount > 0 ? remainingTarget / remainingWorkingDaysCount : 0;
+            // Get the warehouse stock data
+            WarehouseMobileStockByMovementModel warehouseMobileStockByMovementModel = warehouseMobileStockByMovementModels.stream()
+                    .filter(x -> x.getWarehouseId() == rbmTarget.getWarehouseId()).findFirst().orElse(null);
+            if (warehouseMobileStockByMovementModel != null) {
+                // Total stock value for this warehouse
+                float totalStockValue = warehouseMobileStockByMovementModel.getTotalAvailabilityPrice();
+                // Calculate target allocation based on stock value proportion
+                float hidTarget = (warehouseMobileStockByMovementModel.getTotalHidCatalogPrice() / totalStockValue) * todayTarget;
+                float fastMovingTarget = (warehouseMobileStockByMovementModel.getTotalFastMovingCatalogPrice() / totalStockValue) * todayTarget;
+                float slowMovingTarget = (warehouseMobileStockByMovementModel.getTotalSlowMovingCatalogPrice() / totalStockValue) * todayTarget;
+                float eolTarget = (warehouseMobileStockByMovementModel.getTotalEolCatalogPrice() / totalStockValue) * todayTarget;
+                float otherTarget = (warehouseMobileStockByMovementModel.getTotalOtherCategoryCatalogPrice() / totalStockValue) * todayTarget;
+                RbmTargets rbmTargets = new RbmTargets();
+                rbmTargets.setWarehouseId(rbmTarget.getWarehouseId());
+                rbmTargets.setRbmAuthId(rbmTarget.getAuthId());
+                rbmTargets.setRbmName(rbmTarget.getRbmName());
+                rbmTargets.setEolTarget(eolTarget);
+                rbmTargets.setHidTarget(hidTarget);
+                rbmTargets.setFastMovingTarget(fastMovingTarget);
+                rbmTargets.setSlowMovingTarget(slowMovingTarget);
+                rbmTargets.setOtherTarget(otherTarget);
+                rbmTargets.setCreateTimestamp(LocalDateTime.now());
+                rbmTargetsRepository.persist(rbmTargets);
+            }
+        }
+    }
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/RbmTargetServiceImpl.java – Rev 33917 → 33926