| Line 890... |
Line 890... |
| 890 |
.collect(Collectors.toMap(Scheme::getId, Scheme::getType));
|
890 |
.collect(Collectors.toMap(Scheme::getId, Scheme::getType));
|
| 891 |
// LocalDateTime startDate = LocalDate.of(2018, 9, 1).atStartOfDay();
|
891 |
// LocalDateTime startDate = LocalDate.of(2018, 9, 1).atStartOfDay();
|
| 892 |
// LocalDateTime endDate = startDate.plusMonths(1);
|
892 |
// LocalDateTime endDate = startDate.plusMonths(1);
|
| 893 |
// List<FofoOrder> allOrders =
|
893 |
// List<FofoOrder> allOrders =
|
| 894 |
// fofoOrderRepository.selectBetweenSaleDate(startDate, endDate);
|
894 |
// fofoOrderRepository.selectBetweenSaleDate(startDate, endDate);
|
| 895 |
List<FofoOrder> allOrders = Arrays.asList(fofoOrderRepository.selectByInvoiceNumber("HRKN039/27"));
|
895 |
List<FofoOrder> allOrders = Arrays.asList(fofoOrderRepository.selectByInvoiceNumber("HRKN039/27", "UPGZ019/25"));
|
| 896 |
//
|
- |
|
| - |
|
896 |
Set<String> serialNumbersConsidered = new HashSet<>();
|
| 897 |
allOrders.stream().forEach(fofoOrder -> {
|
897 |
allOrders.stream().forEach(fofoOrder -> {
|
| 898 |
String description = "Adjustment of Duplicate Scheme for Sale Invoice " + fofoOrder.getInvoiceNumber();
|
898 |
String description = "Adjustment of Duplicate Scheme for Sale Invoice " + fofoOrder.getInvoiceNumber();
|
| 899 |
Map<Integer, String> inventorySerialNumberMap = new HashMap<>();
|
899 |
Map<Integer, String> inventorySerialNumberMap = new HashMap<>();
|
| 900 |
float amountToRollback = 0;
|
900 |
float amountToRollback = 0;
|
| 901 |
List<FofoOrderItem> orderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
|
901 |
List<FofoOrderItem> orderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
|
| Line 903... |
Line 903... |
| 903 |
inventorySerialNumberMap.putAll(x.getFofoLineItems().stream().filter(li -> li.getSerialNumber() != null)
|
903 |
inventorySerialNumberMap.putAll(x.getFofoLineItems().stream().filter(li -> li.getSerialNumber() != null)
|
| 904 |
.collect(Collectors.toMap(FofoLineItem::getInventoryItemId, FofoLineItem::getSerialNumber)));
|
904 |
.collect(Collectors.toMap(FofoLineItem::getInventoryItemId, FofoLineItem::getSerialNumber)));
|
| 905 |
});
|
905 |
});
|
| 906 |
if (inventorySerialNumberMap.size() > 0) {
|
906 |
if (inventorySerialNumberMap.size() > 0) {
|
| 907 |
for (String serialNumber : inventorySerialNumberMap.values()) {
|
907 |
for (String serialNumber : inventorySerialNumberMap.values()) {
|
| - |
|
908 |
if(serialNumbersConsidered.contains(serialNumber)) {
|
| - |
|
909 |
continue;
|
| - |
|
910 |
}
|
| - |
|
911 |
serialNumbersConsidered.add(serialNumber);
|
| 908 |
List<SchemeInOut> sios = schemeInOutRepository
|
912 |
List<SchemeInOut> sios = schemeInOutRepository
|
| 909 |
.selectAllDuplicate(fofoOrder.getFofoId(), Arrays.asList(serialNumber)).stream()
|
913 |
.selectAllDuplicate(fofoOrder.getFofoId(), Arrays.asList(serialNumber)).stream()
|
| 910 |
.filter(x -> schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.OUT))
|
914 |
.filter(x -> schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.OUT))
|
| 911 |
.collect(Collectors.toList());
|
915 |
.collect(Collectors.toList());
|
| 912 |
UserWalletHistory uwh = new UserWalletHistory();
|
916 |
UserWalletHistory uwh = new UserWalletHistory();
|