| Line 117... |
Line 117... |
| 117 |
Map<Integer, PartnerDetailModel> allPartnerStats = new HashMap<>();
|
117 |
Map<Integer, PartnerDetailModel> allPartnerStats = new HashMap<>();
|
| 118 |
|
118 |
|
| 119 |
List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository
|
119 |
List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository
|
| 120 |
.selectAll(curDate.withDayOfMonth(1).toLocalDate(), curDate.toLocalDate());
|
120 |
.selectAll(curDate.withDayOfMonth(1).toLocalDate(), curDate.toLocalDate());
|
| 121 |
Map<Integer, Long> investmentMaintainedDaysMap = partnerDailyInvestments.stream()
|
121 |
Map<Integer, Long> investmentMaintainedDaysMap = partnerDailyInvestments.stream()
|
| 122 |
.filter(x -> x.getShortPercentage() <= 10)
|
122 |
.filter(x -> x.getShortPercentage() <= ProfitMandiConstants.OK_INVESTMENT_SHORT_PERCENTAGE)
|
| 123 |
.collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.counting()));
|
123 |
.collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.counting()));
|
| 124 |
|
124 |
|
| 125 |
LOGGER.info("investmentMaintainedDaysMap" + investmentMaintainedDaysMap);
|
125 |
LOGGER.info("investmentMaintainedDaysMap" + investmentMaintainedDaysMap);
|
| 126 |
|
126 |
|
| 127 |
// Batch fetch investments for all fofoStores at once (performance optimization)
|
127 |
// Batch fetch investments for all fofoStores at once (performance optimization)
|