| Line 1383... |
Line 1383... |
| 1383 |
offer.setItemCriteria(gson.toJson(itemCriteria));
|
1383 |
offer.setItemCriteria(gson.toJson(itemCriteria));
|
| 1384 |
}
|
1384 |
}
|
| 1385 |
|
1385 |
|
| 1386 |
}
|
1386 |
}
|
| 1387 |
}
|
1387 |
}
|
| 1388 |
|
1388 |
|
| 1389 |
@Autowired
|
1389 |
@Autowired
|
| 1390 |
SaholicReservationSnapshotRepository saholicReservationSnapshotRepository;
|
1390 |
SaholicReservationSnapshotRepository saholicReservationSnapshotRepository;
|
| 1391 |
|
- |
|
| 1392 |
|
1391 |
|
| 1393 |
@Autowired
|
1392 |
@Autowired
|
| 1394 |
SaholicInventoryService saholicInventoryService;
|
1393 |
SaholicInventoryService saholicInventoryService;
|
| 1395 |
|
1394 |
|
| 1396 |
|
- |
|
| 1397 |
public void fixReservations() throws Exception {
|
1395 |
public void fixReservations() throws Exception {
|
| 1398 |
//Clear all Reservations
|
1396 |
// Clear all Reservations
|
| 1399 |
saholicInventorySnapshotRepository.selectAll().stream().forEach(x->x.setReserved(0));
|
1397 |
saholicInventorySnapshotRepository.selectAll().stream().forEach(x -> x.setReserved(0));
|
| 1400 |
saholicReservationSnapshotRepository.selectAll().forEach(x->saholicReservationSnapshotRepository.delete(x));
|
1398 |
saholicReservationSnapshotRepository.selectAll().forEach(x -> saholicReservationSnapshotRepository.delete(x));
|
| 1401 |
List<Order> orders = orderRepository.selectAllOrderDatesBetweenByStatus(
|
1399 |
List<Order> orders = orderRepository.selectAllOrderDatesBetweenByStatus(
|
| 1402 |
LocalDate.now().minusDays(40).atStartOfDay(), LocalDateTime.now(),
|
1400 |
LocalDate.now().minusDays(40).atStartOfDay(), LocalDateTime.now(),
|
| 1403 |
OrderStatus.SUBMITTED_FOR_PROCESSING);
|
1401 |
OrderStatus.SUBMITTED_FOR_PROCESSING);
|
| 1404 |
for(Order order : orders) {
|
1402 |
for (Order order : orders) {
|
| 1405 |
SaholicReservationSnapshot saholicReservationSnapshot = saholicReservationSnapshotRepository.selectByOrderId(order.getId());
|
1403 |
SaholicReservationSnapshot saholicReservationSnapshot = saholicReservationSnapshotRepository
|
| - |
|
1404 |
.selectByOrderId(order.getId());
|
| 1406 |
if(saholicReservationSnapshot==null) {
|
1405 |
if (saholicReservationSnapshot == null) {
|
| - |
|
1406 |
saholicInventoryService.addReservationCount(order.getLineItem().getItemId(),
|
| 1407 |
saholicInventoryService.addReservationCount(order.getLineItem().getItemId(), order.getFulfilmentWarehouseId(), order.getLineItem().getQuantity(), order.getId());
|
1407 |
order.getFulfilmentWarehouseId(), order.getLineItem().getQuantity(), order.getId());
|
| 1408 |
}
|
- |
|
| 1409 |
}
|
1408 |
}
|
| - |
|
1409 |
}
|
| 1410 |
}
|
1410 |
}
|
| 1411 |
|
1411 |
|
| 1412 |
public void fixOrders() throws Exception {
|
1412 |
public void fixOrders() throws Exception {
|
| 1413 |
List<Order> orders = orderRepository.selectAllOrderDatesBetweenByStatus(
|
1413 |
List<Order> orders = orderRepository.selectAllOrderDatesBetweenByStatus(
|
| 1414 |
LocalDate.now().minusDays(10).atStartOfDay(), LocalDateTime.now(),
|
1414 |
LocalDate.now().minusDays(10).atStartOfDay(), LocalDateTime.now(),
|
| Line 1452... |
Line 1452... |
| 1452 |
order.setFulfilmentWarehouseId(warehouse.getId());
|
1452 |
order.setFulfilmentWarehouseId(warehouse.getId());
|
| 1453 |
|
1453 |
|
| 1454 |
}
|
1454 |
}
|
| 1455 |
|
1455 |
|
| 1456 |
}
|
1456 |
}
|
| 1457 |
|
1457 |
|
| 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 |
for(LocalDate date : dates) {
|
1464 |
for (LocalDate date : dates) {
|
| 1464 |
LOGGER.info("Date - {}", date);
|
1465 |
LOGGER.info("Date - {}", date);
|
| 1465 |
Map<Integer, Boolean> investmentMap = partnerDailyInvestmentRepository.selectAll(date.plusDays(1)).stream().collect(Collectors.toMap(x->x.getFofoId(), x->x.getShortPercentage() <= 10));
|
1466 |
Map<Integer, Boolean> investmentMap = partnerDailyInvestmentRepository.selectAll(date.plusDays(1)).stream()
|
| - |
|
1467 |
.collect(Collectors.toMap(x -> x.getFofoId(), x -> x.getShortPercentage() <= 10));
|
| 1466 |
List<PartnerDailyInvestment> investments = partnerDailyInvestmentRepository.selectAll(date.minusDays(1));
|
1468 |
List<PartnerDailyInvestment> investments = partnerDailyInvestmentRepository.selectAll(date.minusDays(1));
|
| 1467 |
for(PartnerDailyInvestment investment : investments) {
|
1469 |
for (PartnerDailyInvestment investment : investments) {
|
| - |
|
1470 |
if (investmentMap.get(investment.getFofoId()) == null
|
| 1468 |
if (investmentMap.get(investment.getFofoId()) == null || (investmentMap.get(investment.getFofoId()) == investment.getShortPercentage() <= 10)) {
|
1471 |
|| (investmentMap.get(investment.getFofoId()) == investment.getShortPercentage() <= 10)) {
|
| 1469 |
//Do nothing
|
1472 |
// Do nothing
|
| 1470 |
} else {
|
1473 |
} else if(fofoIds.contains(investment.getFofoId())){
|
| 1471 |
LOGGER.info("Problem with fofo id => {}", investment.getFofoId());
|
1474 |
LOGGER.info("Problem with fofo id => {}", investment.getFofoId());
|
| 1472 |
}
|
1475 |
}
|
| 1473 |
}
|
1476 |
}
|
| 1474 |
}
|
1477 |
}
|
| 1475 |
}
|
1478 |
}
|