Subversion Repositories SmartDukaan

package com.spice.profitmandi.dao.service;

import com.spice.profitmandi.common.model.BulkOrderModel;

import com.spice.profitmandi.common.model.ProfitMandiConstants;

import com.spice.profitmandi.dao.entity.catalog.Bid;

import com.spice.profitmandi.dao.entity.catalog.Item;

import com.spice.profitmandi.dao.entity.catalog.Liquidation;

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

import com.spice.profitmandi.dao.repository.catalog.BidRepository;

import com.spice.profitmandi.dao.repository.catalog.ItemRepository;

import com.spice.profitmandi.dao.repository.catalog.LiquidationRepository;

import com.spice.profitmandi.dao.repository.inventory.SaholicCISTableRepository;

import com.spice.profitmandi.service.order.BulkOrderService;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import java.time.LocalDateTime;

import java.time.format.DateTimeFormatter;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.List;

@Component

public class LiquidationService {

    private static final Logger LOGGER = LogManager.getLogger(LiquidationService.class);

    @Autowired

    BidRepository bidRepository;

    @Autowired

    LiquidationRepository liquidationRepository;

    @Autowired

    private ItemRepository itemRepository;

    @Autowired

    private BidService bidService;

    @Autowired

    SaholicCISTableRepository saholicCISTableRepository;

    @Autowired

    private BulkOrderService bulkOrderService;

    public void processBids(ProfitMandiConstants.BID_CRON_ENUM type) throws Exception {

        List<Liquidation> liquidations;

        if (type.equals(ProfitMandiConstants.BID_CRON_ENUM.YESTERDAY)){

            liquidations = liquidationRepository.selectAllByEndDate(LocalDateTime.now().minusDays(1));

        } else {

            liquidations = liquidationRepository.selectAllByEndDate(LocalDateTime.now());

        }

        LOGGER.info("liquidations: {}",liquidations);

        if (liquidations.size() > 0) {

            for (Liquidation liquidation : liquidations) {

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

                if (items.size() > 0) {

                    long remainingQty = 0;

                    for (Item item : items) {

                        List<SaholicCISTable> saholicCISTable = saholicCISTableRepository.selectAllByItemId(item.getId());

                        remainingQty += saholicCISTable.stream().mapToInt(SaholicCISTable::getAvailability).sum();

                    }

                    List<Bid> bids = bidRepository.selectAllBidByLiquidationIdAndStatus(liquidation.getId(), Arrays.asList(ProfitMandiConstants.BID_ENUM.PENDING, ProfitMandiConstants.BID_ENUM.PROCESSING));

                    for (Bid bid : bids) {

                        if (remainingQty >= bid.getQuantity()) {

                            List<BulkOrderModel> bulkOrderModels = new ArrayList<>();

                            BulkOrderModel bulkOrderModel = new BulkOrderModel();

                            bulkOrderModel.setRowIndex(bid.getId());

                            bulkOrderModel.setFofoId(bid.getFofoId());

                            bulkOrderModel.setItemId(items.get(0).getId());

                            bulkOrderModel.setQuantity(bid.getQuantity());

                            bulkOrderModel.setDescription(items.get(0).getItemDescription());

                            bulkOrderModel.setItemPrice(bid.getBiddingAmount());

                            bulkOrderModels.add(bulkOrderModel);

                            bulkOrderService.generatePurchaseOrder(bulkOrderModels, bid.getFofoId(), ProfitMandiConstants.PO_TYPE.AUTO, type);

                            remainingQty -= bid.getQuantity();

                        } else {

                            bidService.cancelYesterdayProcessBid(bid);

                        }

                    }

                    if (remainingQty <= 0) bidService.sendSummaryMailToUserAndManagers(liquidation.getCreatedBy(), bids, liquidation);

                    liquidation.setQuantity((int) remainingQty);

                    liquidation.setStatus(ProfitMandiConstants.LIQUIDATION_ENUM.CLOSED);

                }

            }

        }

    }

}