| Line 187... |
Line 187... |
| 187 |
|
187 |
|
| 188 |
Map<Integer, String> providerMap = providerRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getName()));
|
188 |
Map<Integer, String> providerMap = providerRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getName()));
|
| 189 |
Map<Integer, List<Order>> existingProviderOrderMap = ordersByWaybill.stream().collect(Collectors.groupingBy(x -> x.getLogisticsProviderId()));
|
189 |
Map<Integer, List<Order>> existingProviderOrderMap = ordersByWaybill.stream().collect(Collectors.groupingBy(x -> x.getLogisticsProviderId()));
|
| 190 |
for (Entry<Integer, List<Order>> existingProviderEntrySet : existingProviderOrderMap.entrySet()) {
|
190 |
for (Entry<Integer, List<Order>> existingProviderEntrySet : existingProviderOrderMap.entrySet()) {
|
| 191 |
String providerName = providerMap.get(existingProviderEntrySet.getKey());
|
191 |
String providerName = providerMap.get(existingProviderEntrySet.getKey());
|
| - |
|
192 |
LOGGER.info("Provider Name - {}", providerName);
|
| 192 |
Set<String> wayBillNumbers = providerWayBillNumberMap.get(providerName);
|
193 |
Set<String> wayBillNumbers = providerWayBillNumberMap.get(providerName);
|
| - |
|
194 |
if(wayBillNumbers==null) continue;
|
| 193 |
for (Order order : ordersByWaybill) {
|
195 |
for (Order order : ordersByWaybill) {
|
| 194 |
if (wayBillNumbers.contains(order.getAirwayBillNumber())) {
|
196 |
if (wayBillNumbers.contains(order.getAirwayBillNumber())) {
|
| 195 |
String errorMessage = "Provider " + providerName + ", wayBillNumber " + order.getAirwayBillNumber();
|
197 |
String errorMessage = "Provider " + providerName + ", wayBillNumber " + order.getAirwayBillNumber() + " already exists";
|
| 196 |
throw new ProfitMandiBusinessException(errorMessage, errorMessage, errorMessage);
|
198 |
throw new ProfitMandiBusinessException(errorMessage, errorMessage, errorMessage);
|
| 197 |
}
|
199 |
}
|
| 198 |
}
|
200 |
}
|
| 199 |
}
|
201 |
}
|
| 200 |
|
202 |
|