Subversion Repositories SmartDukaan

Rev

Rev 27570 | Rev 27572 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 27570 Rev 27571
Line 4... Line 4...
4 
import java.time.LocalDateTime;
 4 
import java.time.LocalDateTime;
5 
import java.util.List;
 5 
import java.util.List;
6 
import java.util.Map;
 6 
import java.util.Map;
7 
import java.util.stream.Collectors;
 7 
import java.util.stream.Collectors;
8 
 
 8 
 
- 
 
 9 
import org.apache.logging.log4j.LogManager;
- 
 
 10 
import org.apache.logging.log4j.Logger;
9 
import org.springframework.beans.factory.annotation.Autowired;
 11 
import org.springframework.beans.factory.annotation.Autowired;
10 
import org.springframework.stereotype.Component;
 12 
import org.springframework.stereotype.Component;
11 
import org.springframework.transaction.annotation.Transactional;
 13 
import org.springframework.transaction.annotation.Transactional;
12 
 
 14 
 
13 
import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
 15 
import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
Line 24... Line 26...
24 
public class InvestmentRelatedTasks {
 26 
public class InvestmentRelatedTasks {
25 
	@Autowired
 27 
	@Autowired
26 
	RetailerService retailerService;
 28 
	RetailerService retailerService;
27 
	@Autowired
 29 
	@Autowired
28 
	SchemeInOutRepository schemeInOutRepository;
 30 
	SchemeInOutRepository schemeInOutRepository;
- 
 
 31
- 
 
 32 
	private static final Logger LOGGER = LogManager.getLogger(InvestmentRelatedTasks.class);
29 
 
 33 
 
30 
	@Autowired
 34 
	@Autowired
31 
	InventoryItemRepository inventoryItemRepository;
 35 
	InventoryItemRepository inventoryItemRepository;
32
36
33 
	@Autowired
 37 
	@Autowired
Line 37... Line 41...
37 
		LocalDate firstDateOfCurrentMonth = LocalDateTime.now().withDayOfMonth(1).toLocalDate();
 41 
		LocalDate firstDateOfCurrentMonth = LocalDateTime.now().withDayOfMonth(1).toLocalDate();
38 
		LocalDate startOfPreviousMonth = firstDateOfCurrentMonth.minusMonths(1);
 42 
		LocalDate startOfPreviousMonth = firstDateOfCurrentMonth.minusMonths(1);
39 
		LocalDate lastOfPreviousMonth = firstDateOfCurrentMonth.minusDays(1);
 43 
		LocalDate lastOfPreviousMonth = firstDateOfCurrentMonth.minusDays(1);
40 
		List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository.selectAll(startOfPreviousMonth, lastOfPreviousMonth);
 44 
		List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository.selectAll(startOfPreviousMonth, lastOfPreviousMonth);
41 
		Map<Integer, Long> investmentMaintainedDaysMap = partnerDailyInvestments.stream().filter(x->x.getShortPercentage() <= 10).collect(Collectors.groupingBy(x->x.getFofoId(), Collectors.counting()));
 45 
		Map<Integer, Long> investmentMaintainedDaysMap = partnerDailyInvestments.stream().filter(x->x.getShortPercentage() <= 10).collect(Collectors.groupingBy(x->x.getFofoId(), Collectors.counting()));
- 
 
 46 
		LOGGER.info("investmentMaintainedDaysMap {}", investmentMaintainedDaysMap);
42 
		List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectAllPending(SchemeType.INVESTMENT, startOfPreviousMonth.atStartOfDay(), firstDateOfCurrentMonth.atStartOfDay());
 47 
		List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectAllPending(SchemeType.INVESTMENT, startOfPreviousMonth.atStartOfDay(), firstDateOfCurrentMonth.atStartOfDay());
43 
		Map<Integer, List<SchemeInOut>> inventoryItemIdSchemeMap = schemeInOuts.stream().collect(Collectors.groupingBy(x->x.getInventoryItemId()));
 48 
		Map<Integer, List<SchemeInOut>> inventoryItemIdSchemeMap = schemeInOuts.stream().collect(Collectors.groupingBy(x->x.getInventoryItemId()));
44 
		List<InventoryItem> inventoryItems = inventoryItemRepository.selectByIds(inventoryItemIdSchemeMap.keySet());
 49 
		List<InventoryItem> inventoryItems = inventoryItemRepository.selectByIds(inventoryItemIdSchemeMap.keySet());
45 
		Map<Integer, List<Integer>> retailerInventoryItemIdMap = inventoryItems.stream()
 50 
		Map<Integer, List<Integer>> retailerInventoryItemIdMap = inventoryItems.stream()
46 
				.collect(Collectors.groupingBy(x->x.getFofoId(), Collectors.mapping(x->x.getId(), Collectors.toList())));
 51 
				.collect(Collectors.groupingBy(x->x.getFofoId(), Collectors.mapping(x->x.getId(), Collectors.toList())));