Subversion Repositories SmartDukaan

import com.spice.profitmandi.dao.enumuration.inventory.CatalogMovingEnum;

import com.spice.profitmandi.dao.event.TagListingEventPublisher;

import com.spice.profitmandi.model.WarehouseItemQtyModel;

    @Autowired

    CategorisedCatalogRepository categorisedCatalogRepository;

    @RequestMapping(value = "/indent/getOurStockDetails", method = RequestMethod.GET)

    public ResponseEntity<?> getOurStockDetails(HttpServletRequest request, @RequestParam int catalogId, @RequestParam int warehouseId, Model model)

            throws Exception {

        try {

            // Get all items by catalogId

            List<Item> items = itemRepository.selectAllByCatalogItemId(catalogId);

            List<Integer> itemIds = items.stream().map(Item::getId).collect(Collectors.toList());

            if (itemIds.isEmpty()) {

                return responseSender.ok(Collections.emptyList());

            }

            // Get saholic stock for these items

            Map<Integer, List<WarehouseItemQtyModel>> stockMap = saholicInventoryService.getSaholicStock(warehouseId, itemIds);

            // Build result with item description and qty where netAvailability > 0

            List<Map<String, Object>> result = new ArrayList<>();

            for (Item item : items) {

                List<WarehouseItemQtyModel> stockList = stockMap.get(item.getId());

                if (stockList != null && !stockList.isEmpty()) {

                    int totalNetAvailability = stockList.stream()

                            .mapToInt(WarehouseItemQtyModel::getNetAvailability)

                            .sum();

                    if (totalNetAvailability > 0) {

                        Map<String, Object> itemDetail = new HashMap<>();

                        itemDetail.put("itemId", item.getId());

                        itemDetail.put("color", item.getColor());

                        itemDetail.put("itemDescription", item.getItemDescription());

                        itemDetail.put("qty", totalNetAvailability);

                        result.add(itemDetail);

                    }

                }

            }

            return responseSender.ok(result);

        } catch (Exception e) {

            LOGGER.error("Error getting our stock details for catalogId: {} warehouseId: {}", catalogId, warehouseId, e);

            return responseSender.ok(Collections.emptyList());

        }

    }

    @RequestMapping(value = "/indent/getOutOfStockDetails", method = RequestMethod.GET)

    public ResponseEntity<?> getOutOfStockDetails(HttpServletRequest request, @RequestParam String brand, @RequestParam int warehouseId, Model model) throws Exception {

        try {

            // Get all catalogs for the brand with their movement status

            List<CategorisedCatalogListModel> catalogMovements = categorisedCatalogRepository.getBrandWiseCatalogMovement(brand);

            // Filter only HID, FASTMOVING, RUNNING status

            Set<CatalogMovingEnum> validStatuses = new HashSet<>(Arrays.asList(

                    CatalogMovingEnum.HID, CatalogMovingEnum.FASTMOVING, CatalogMovingEnum.RUNNING));

            List<CategorisedCatalogListModel> filteredCatalogs = catalogMovements.stream()

                    .filter(c -> validStatuses.contains(c.getCurrentStatus()))

                    .collect(Collectors.toList());

            if (filteredCatalogs.isEmpty()) {

                return responseSender.ok(Collections.emptyList());

            }

            List<Map<String, Object>> result = new ArrayList<>();

            for (CategorisedCatalogListModel catalogModel : filteredCatalogs) {

                int catalogId = catalogModel.getModelId();

                // Get all items for this catalog

                List<Item> items = itemRepository.selectAllByCatalogItemId(catalogId);

                List<Integer> itemIds = items.stream().map(Item::getId).collect(Collectors.toList());

                if (itemIds.isEmpty()) {

                    // No items means out of stock for this model

                    Map<String, Object> itemDetail = new HashMap<>();

                    itemDetail.put("catalogId", catalogId);

                    itemDetail.put("modelNumber", catalogModel.getModelNumber());

                    itemDetail.put("status", catalogModel.getCurrentStatus().getValue());

                    itemDetail.put("qty", 0);

                    result.add(itemDetail);

                    continue;

                }

                // Get saholic stock for these items

                Map<Integer, List<WarehouseItemQtyModel>> stockMap = saholicInventoryService.getSaholicStock(warehouseId, itemIds);

                // Calculate total net availability for this catalog

                int totalNetAvailability = 0;

                for (Item item : items) {

                    List<WarehouseItemQtyModel> stockList = stockMap.get(item.getId());

                    if (stockList != null && !stockList.isEmpty()) {

                        totalNetAvailability += stockList.stream()

                                .mapToInt(WarehouseItemQtyModel::getNetAvailability)

                                .sum();

                    }

                }

                // Only include if out of stock (netAvailability <= 0)

                if (totalNetAvailability <= 0) {

                    Map<String, Object> itemDetail = new HashMap<>();

                    itemDetail.put("catalogId", catalogId);

                    itemDetail.put("modelNumber", catalogModel.getModelNumber());

                    itemDetail.put("status", catalogModel.getCurrentStatus().getValue());

                    itemDetail.put("qty", totalNetAvailability);

                    result.add(itemDetail);

                }

            }

            return responseSender.ok(result);

        } catch (Exception e) {

            LOGGER.error("Error getting out of stock details for brand: {} warehouseId: {}", brand, warehouseId, e);

            return responseSender.ok(Collections.emptyList());

        }

    }