Subversion Repositories SmartDukaan

package com.spice.profitmandi.service.inventory;

import com.spice.profitmandi.dao.entity.inventory.PartnerAgeingModel;
import com.spice.profitmandi.dao.repository.fofo.ActivatedImeiRepository;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.persistence.TypedQuery;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;


@Component
public class AgeingServiceImpl implements AgeingService {

    @Autowired
    ActivatedImeiRepository activatedImeiRepository;
    @Autowired
    private SessionFactory sessionFactory;

    @Override
    public Map<String, AgeingModel> getAllAgeingForSecondary() {
        Session session = sessionFactory.getCurrentSession();
        final TypedQuery<AgeingModel> typedQuerySimilar = session.createNamedQuery("BrandAgeingLimit.imeisToSecondaryAlert", AgeingModel.class);
        List<AgeingModel> ageingModels = typedQuerySimilar.getResultList();
        return ageingModels.stream().collect(Collectors.toMap(x -> x.getSerialNumber(), x -> x, (u, v) -> u.getInvoiceDate().isBefore(v.getInvoiceDate()) ? u : v));
    }

    @Override
    public List<PartnerAgeingModel> getAllAgeingForTertiary() {
        Session session = sessionFactory.getCurrentSession();
        final TypedQuery<PartnerAgeingModel> imeisToTertiaryQuery = session.createNamedQuery("BrandAgeingLimit.imeisToTertiaryAlert", PartnerAgeingModel.class);
        return imeisToTertiaryQuery.getResultList();
    }

    @Override
    public List<PartnerAgeingModel> filterAgedInventory(Set<Integer> inventoryItemIds) {
        Session session = sessionFactory.getCurrentSession();
        final TypedQuery<PartnerAgeingModel> imeisToTertiaryQuery = session.createNamedQuery("BrandAgeingLimit.getByInventoryItemIds", PartnerAgeingModel.class);
        imeisToTertiaryQuery.setParameter("inventoryItemIds", inventoryItemIds);
        return imeisToTertiaryQuery.getResultList();

    }
}