| Line 1461... |
Line 1461... |
| 1461 |
@Autowired
|
1461 |
@Autowired
|
| 1462 |
PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
|
1462 |
PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
|
| 1463 |
|
1463 |
|
| 1464 |
public void addInvestment() {
|
1464 |
public void addInvestment() {
|
| 1465 |
List<LocalDate> dates = Arrays.asList(LocalDate.of(2021, 7, 13), LocalDate.of(2021, 7, 31));
|
1465 |
List<LocalDate> dates = Arrays.asList(LocalDate.of(2021, 7, 13), LocalDate.of(2021, 7, 31));
|
| 1466 |
//List<Integer> fofoIds = Arrays.asList(175136207, 175138910, 175138967, 175138990, 175138999);
|
1466 |
// List<Integer> fofoIds = Arrays.asList(175136207, 175138910, 175138967,
|
| - |
|
1467 |
// 175138990, 175138999);
|
| 1467 |
for (LocalDate date : dates) {
|
1468 |
for (LocalDate date : dates) {
|
| 1468 |
LOGGER.info("Date - {}", date);
|
1469 |
LOGGER.info("Date - {}", date);
|
| 1469 |
Map<Integer, PartnerDailyInvestment> investmentMap = partnerDailyInvestmentRepository.selectAll(date.plusDays(1)).stream()
|
1470 |
Map<Integer, PartnerDailyInvestment> investmentMap = partnerDailyInvestmentRepository
|
| 1470 |
.collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
|
1471 |
.selectAll(date.plusDays(1)).stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
|
| 1471 |
List<PartnerDailyInvestment> investments = partnerDailyInvestmentRepository.selectAll(date.minusDays(1));
|
1472 |
List<PartnerDailyInvestment> investments = partnerDailyInvestmentRepository.selectAll(date.minusDays(1));
|
| 1472 |
for (PartnerDailyInvestment investment : investments) {
|
1473 |
for (PartnerDailyInvestment investment : investments) {
|
| 1473 |
if (investmentMap.get(investment.getFofoId()) == null
|
1474 |
if (investmentMap.get(investment.getFofoId()) == null || (investmentMap.get(investment.getFofoId())
|
| 1474 |
|| (investmentMap.get(investment.getFofoId()).getShortPercentage() <= 10) == (investment.getShortPercentage() <= 10)) {
|
1475 |
.getShortPercentage() <= 10) == (investment.getShortPercentage() <= 10)) {
|
| 1475 |
//Do nothing add investment as is
|
1476 |
// Do nothing add investment as is
|
| 1476 |
} else {
|
1477 |
} else {
|
| 1477 |
LOGGER.info("Problem with fofo id => {}", investment.getFofoId());
|
1478 |
LOGGER.info("Problem with fofo id => {}", investment.getFofoId());
|
| 1478 |
//Lets give benefit of doubt
|
1479 |
// Lets give benefit of doubt
|
| 1479 |
if(investment.getShortPercentage() > 10) {
|
1480 |
if (investment.getShortPercentage() > 10) {
|
| 1480 |
investment = investmentMap.get(investment.getFofoId());
|
1481 |
investment = investmentMap.get(investment.getFofoId());
|
| 1481 |
}
|
1482 |
}
|
| 1482 |
}
|
1483 |
}
|
| 1483 |
PartnerDailyInvestment partnerDailyInvestment = new PartnerDailyInvestment();
|
1484 |
PartnerDailyInvestment partnerDailyInvestment = new PartnerDailyInvestment();
|
| 1484 |
partnerDailyInvestment.setActivatedStockAmount(investment.getActivatedStockAmount());
|
1485 |
partnerDailyInvestment.setActivatedStockAmount(investment.getActivatedStockAmount());
|
| Line 1497... |
Line 1498... |
| 1497 |
}
|
1498 |
}
|
| 1498 |
}
|
1499 |
}
|
| 1499 |
|
1500 |
|
| 1500 |
@Autowired
|
1501 |
@Autowired
|
| 1501 |
BrandRegionMappingRepository brandRegionMappingRepository;
|
1502 |
BrandRegionMappingRepository brandRegionMappingRepository;
|
| - |
|
1503 |
|
| 1502 |
public void brandRegion() {
|
1504 |
public void brandRegion() {
|
| 1503 |
Set<Integer> warehouseIds = ProfitMandiConstants.WAREHOUSE_MAP.keySet();
|
1505 |
Set<Integer> warehouseIds = ProfitMandiConstants.WAREHOUSE_MAP.keySet();
|
| 1504 |
Map<String, Map<Boolean, List<BrandRegionMapping>>> mapping = brandRegionMappingRepository.selectAll().stream().collect(
|
1506 |
Map<String, Map<Boolean, List<BrandRegionMapping>>> mapping = brandRegionMappingRepository.selectAll().stream()
|
| - |
|
1507 |
.collect(Collectors.groupingBy(BrandRegionMapping::getBrand,
|
| - |
|
1508 |
Collectors.collectingAndThen(Collectors.toList(),
|
| 1505 |
Collectors.groupingBy(BrandRegionMapping::getBrand, Collectors.collectingAndThen(Collectors.toList(), x->x.stream().collect(Collectors.groupingBy(BrandRegionMapping::isAccessory)))));
|
1509 |
x -> x.stream().collect(Collectors.groupingBy(BrandRegionMapping::isAccessory)))));
|
| 1506 |
for(Map.Entry<String, Map<Boolean,List<BrandRegionMapping>>> entry : mapping.entrySet()) {
|
1510 |
for (Map.Entry<String, Map<Boolean, List<BrandRegionMapping>>> entry : mapping.entrySet()) {
|
| 1507 |
String brand = entry.getKey();
|
1511 |
String brand = entry.getKey();
|
| 1508 |
for(Map.Entry<Boolean, List<BrandRegionMapping>> isAccessoryEntry: entry.getValue().entrySet()) {
|
1512 |
for (Map.Entry<Boolean, List<BrandRegionMapping>> isAccessoryEntry : entry.getValue().entrySet()) {
|
| 1509 |
boolean isAccessory = isAccessoryEntry.getKey();
|
1513 |
boolean isAccessory = isAccessoryEntry.getKey();
|
| 1510 |
Map<Integer, List<Integer>> warehouseToIdsMap = isAccessoryEntry.getValue().stream().collect(Collectors.groupingBy(
|
1514 |
Map<Integer, List<Integer>> warehouseToIdsMap = isAccessoryEntry.getValue().stream()
|
| - |
|
1515 |
.collect(Collectors.groupingBy(BrandRegionMapping::getToWarehouseId,
|
| 1511 |
BrandRegionMapping::getToWarehouseId, Collectors.mapping(BrandRegionMapping::getFromWarehouseId, Collectors.toList())));
|
1516 |
Collectors.mapping(BrandRegionMapping::getFromWarehouseId, Collectors.toList())));
|
| 1512 |
for(int warehouseIdTo : warehouseIds) {
|
1517 |
for (int warehouseIdTo : warehouseIds) {
|
| 1513 |
List<Integer> warehouseIdsFrom = warehouseToIdsMap.get(warehouseIdTo);
|
1518 |
List<Integer> warehouseIdsFrom = warehouseToIdsMap.get(warehouseIdTo);
|
| 1514 |
if(warehouseIdsFrom==null || !warehouseIdsFrom.contains(warehouseIdTo)) {
|
1519 |
if (warehouseIdsFrom == null || !warehouseIdsFrom.contains(warehouseIdTo)) {
|
| 1515 |
LOGGER.info("Missing entries for brand region mapping = {}, {}, {}", brand, isAccessory, warehouseIdTo);
|
1520 |
LOGGER.info("Missing entries for brand region mapping = {}, {}, {}", brand, isAccessory,
|
| 1516 |
/*
|
1521 |
warehouseIdTo);
|
| - |
|
1522 |
|
| 1517 |
* BrandRegionMapping brandRegionMapping = new BrandRegionMapping();
|
1523 |
BrandRegionMapping brandRegionMapping = new BrandRegionMapping();
|
| 1518 |
* brandRegionMapping.setAccessory(isAccessory);
|
1524 |
brandRegionMapping.setAccessory(isAccessory);
|
| 1519 |
* brandRegionMapping.setBrand(brand);
|
1525 |
brandRegionMapping.setBrand(brand);
|
| 1520 |
* brandRegionMapping.setFromWarehouseId(warehouseIdTo);
|
1526 |
brandRegionMapping.setFromWarehouseId(warehouseIdTo);
|
| 1521 |
* brandRegionMapping.setToWarehouseId(warehouseIdTo);
|
1527 |
brandRegionMapping.setToWarehouseId(warehouseIdTo);
|
| 1522 |
* brandRegionMappingRepository.persist(brandRegionMapping);
|
1528 |
brandRegionMappingRepository.persist(brandRegionMapping);
|
| 1523 |
*/
|
1529 |
|
| 1524 |
}
|
1530 |
}
|
| 1525 |
}
|
1531 |
}
|
| 1526 |
}
|
1532 |
}
|
| 1527 |
}
|
1533 |
}
|
| 1528 |
}
|
1534 |
}
|