| Line 1458... |
Line 1458... |
| 1458 |
@Autowired
|
1458 |
@Autowired
|
| 1459 |
PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
|
1459 |
PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
|
| 1460 |
|
1460 |
|
| 1461 |
public void addInvestment() {
|
1461 |
public void addInvestment() {
|
| 1462 |
List<LocalDate> dates = Arrays.asList(LocalDate.of(2021, 7, 13), LocalDate.of(2021, 7, 31));
|
1462 |
List<LocalDate> dates = Arrays.asList(LocalDate.of(2021, 7, 13), LocalDate.of(2021, 7, 31));
|
| 1463 |
List<Integer> fofoIds = Arrays.asList(175136207, 175138910, 175138967, 175138990, 175138999);
|
1463 |
//List<Integer> fofoIds = Arrays.asList(175136207, 175138910, 175138967, 175138990, 175138999);
|
| 1464 |
for (LocalDate date : dates) {
|
1464 |
for (LocalDate date : dates) {
|
| 1465 |
LOGGER.info("Date - {}", date);
|
1465 |
LOGGER.info("Date - {}", date);
|
| 1466 |
Map<Integer, Boolean> investmentMap = partnerDailyInvestmentRepository.selectAll(date.plusDays(1)).stream()
|
1466 |
Map<Integer, PartnerDailyInvestment> investmentMap = partnerDailyInvestmentRepository.selectAll(date.plusDays(1)).stream()
|
| 1467 |
.collect(Collectors.toMap(x -> x.getFofoId(), x -> x.getShortPercentage() <= 10));
|
1467 |
.collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
|
| 1468 |
List<PartnerDailyInvestment> investments = partnerDailyInvestmentRepository.selectAll(date.minusDays(1));
|
1468 |
List<PartnerDailyInvestment> investments = partnerDailyInvestmentRepository.selectAll(date.minusDays(1));
|
| 1469 |
for (PartnerDailyInvestment investment : investments) {
|
1469 |
for (PartnerDailyInvestment investment : investments) {
|
| 1470 |
if (investmentMap.get(investment.getFofoId()) == null
|
1470 |
if (investmentMap.get(investment.getFofoId()) == null
|
| 1471 |
|| (investmentMap.get(investment.getFofoId()) == investment.getShortPercentage() <= 10)) {
|
1471 |
|| (investmentMap.get(investment.getFofoId()).getShortPercentage() <= 10) == (investment.getShortPercentage() <= 10)) {
|
| 1472 |
// Do nothing
|
1472 |
//Do nothing add investment as is
|
| 1473 |
} else if(fofoIds.contains(investment.getFofoId())){
|
1473 |
} else {
|
| 1474 |
LOGGER.info("Problem with fofo id => {}", investment.getFofoId());
|
1474 |
LOGGER.info("Problem with fofo id => {}", investment.getFofoId());
|
| - |
|
1475 |
//Lets give benefit of doubt
|
| - |
|
1476 |
if(investment.getShortPercentage() > 10) {
|
| - |
|
1477 |
investment = investmentMap.get(investment.getFofoId());
|
| - |
|
1478 |
}
|
| 1475 |
}
|
1479 |
}
|
| - |
|
1480 |
PartnerDailyInvestment partnerDailyInvestment = new PartnerDailyInvestment();
|
| - |
|
1481 |
partnerDailyInvestment.setActivatedStockAmount(investment.getActivatedStockAmount());
|
| - |
|
1482 |
partnerDailyInvestment.setDate(date);
|
| - |
|
1483 |
partnerDailyInvestment.setFofoId(investment.getFofoId());
|
| - |
|
1484 |
partnerDailyInvestment.setMinInvestment(investment.getMinInvestment());
|
| - |
|
1485 |
partnerDailyInvestment.setGrnPendingAmount(investment.getGrnPendingAmount());
|
| - |
|
1486 |
partnerDailyInvestment.setActivatedStockAmount(investment.getActivatedStockAmount());
|
| - |
|
1487 |
partnerDailyInvestment.setUnbilledAmount(investment.getUnbilledAmount());
|
| - |
|
1488 |
partnerDailyInvestment.setReturnInTransitAmount(investment.getReturnInTransitAmount());
|
| - |
|
1489 |
partnerDailyInvestment.setSalesAmount(investment.getSalesAmount());
|
| - |
|
1490 |
partnerDailyInvestment.setInStockAmount(investment.getInStockAmount());
|
| - |
|
1491 |
partnerDailyInvestmentRepository.persist(partnerDailyInvestment);
|
| 1476 |
}
|
1492 |
}
|
| 1477 |
}
|
1493 |
}
|
| 1478 |
}
|
1494 |
}
|
| 1479 |
|
1495 |
|
| 1480 |
}
|
1496 |
}
|