| Line 127... |
Line 127... |
| 127 |
import com.spice.profitmandi.service.pricing.PriceDropService;
|
127 |
import com.spice.profitmandi.service.pricing.PriceDropService;
|
| 128 |
import com.spice.profitmandi.service.scheme.SchemeService;
|
128 |
import com.spice.profitmandi.service.scheme.SchemeService;
|
| 129 |
import com.spice.profitmandi.service.transaction.TransactionService;
|
129 |
import com.spice.profitmandi.service.transaction.TransactionService;
|
| 130 |
import com.spice.profitmandi.service.user.RetailerService;
|
130 |
import com.spice.profitmandi.service.user.RetailerService;
|
| 131 |
import com.spice.profitmandi.service.wallet.WalletService;
|
131 |
import com.spice.profitmandi.service.wallet.WalletService;
|
| - |
|
132 |
import com.spice.profitmandi.service.warehouse.WarehouseInventoryService;
|
| 132 |
|
133 |
|
| 133 |
import in.shop2020.model.v1.order.OrderStatus;
|
134 |
import in.shop2020.model.v1.order.OrderStatus;
|
| 134 |
import in.shop2020.model.v1.order.WalletReferenceType;
|
135 |
import in.shop2020.model.v1.order.WalletReferenceType;
|
| 135 |
import okhttp3.OkHttpClient;
|
136 |
import okhttp3.OkHttpClient;
|
| 136 |
import okhttp3.Request;
|
137 |
import okhttp3.Request;
|
| Line 1224... |
Line 1225... |
| 1224 |
}
|
1225 |
}
|
| 1225 |
|
1226 |
|
| 1226 |
|
1227 |
|
| 1227 |
@Autowired
|
1228 |
@Autowired
|
| 1228 |
private WarehouseScanRepository warehouseScanRepository;
|
1229 |
private WarehouseScanRepository warehouseScanRepository;
|
| - |
|
1230 |
|
| - |
|
1231 |
@Autowired
|
| - |
|
1232 |
private WarehouseInventoryService warehouseInventoryService;
|
| - |
|
1233 |
|
| 1229 |
public void fixScans() {
|
1234 |
public void fixScans() {
|
| 1230 |
Map<Integer, Integer> inventoryOrderMap = new HashMap<>();
|
1235 |
Map<Integer, Integer> inventoryOrderMap = new HashMap<>();
|
| 1231 |
inventoryOrderMap.put(348795,1628598);
|
1236 |
inventoryOrderMap.put(348795,1628598);
|
| 1232 |
inventoryOrderMap.put(348796,1628599);
|
1237 |
inventoryOrderMap.put(348796,1628599);
|
| 1233 |
inventoryOrderMap.put(329854,1628600);
|
1238 |
inventoryOrderMap.put(329854,1628600);
|
| Line 1258... |
Line 1263... |
| 1258 |
Map<Integer, List<WarehouseScan>> inventoryScansMap = scans.stream().collect(Collectors.groupingBy(WarehouseScan::getInventoryItemId));
|
1263 |
Map<Integer, List<WarehouseScan>> inventoryScansMap = scans.stream().collect(Collectors.groupingBy(WarehouseScan::getInventoryItemId));
|
| 1259 |
|
1264 |
|
| 1260 |
for(Map.Entry<Integer, List<WarehouseScan>> mapEntry : inventoryScansMap.entrySet()) {
|
1265 |
for(Map.Entry<Integer, List<WarehouseScan>> mapEntry : inventoryScansMap.entrySet()) {
|
| 1261 |
int inventoryItemId = mapEntry.getKey();
|
1266 |
int inventoryItemId = mapEntry.getKey();
|
| 1262 |
List<WarehouseScan> duplicateScans = mapEntry.getValue().stream().filter(x->x.getOrderId() != null && x.getOrderId().equals(inventoryOrderMap.get(inventoryItemId))).collect(Collectors.toList());
|
1267 |
List<WarehouseScan> duplicateScans = mapEntry.getValue().stream().filter(x->x.getOrderId() != null && x.getOrderId().equals(inventoryOrderMap.get(inventoryItemId))).collect(Collectors.toList());
|
| 1263 |
LOGGER.info("Duplicate Scans {}", duplicateScans);
|
- |
|
| 1264 |
/*WarehouseScan duplicateScan = duplicateScans.stream().findFirst().get();
|
1268 |
WarehouseScan duplicateScan = duplicateScans.stream().findFirst().get();
|
| 1265 |
LOGGER.info("Duplicate Scan {}", duplicateScan);*/
|
1269 |
warehouseScanRepository.delete(duplicateScan);
|
| - |
|
1270 |
warehouseInventoryService.addQuantity(duplicateScan.getInventoryItemId(), duplicateScan.getQuantity());
|
| - |
|
1271 |
|
| 1266 |
}
|
1272 |
}
|
| 1267 |
|
1273 |
|
| 1268 |
}
|
1274 |
}
|
| 1269 |
|
1275 |
|
| 1270 |
}
|
1276 |
}
|