| Line 205... |
Line 205... |
| 205 |
throw new ProfitMandiBusinessException("", "", "Could not connect to host");
|
205 |
throw new ProfitMandiBusinessException("", "", "Could not connect to host");
|
| 206 |
}
|
206 |
}
|
| 207 |
JSONObject solrResponseJSONObj = new JSONObject(response).getJSONObject("response");
|
207 |
JSONObject solrResponseJSONObj = new JSONObject(response).getJSONObject("response");
|
| 208 |
JSONArray docs = solrResponseJSONObj.getJSONArray("docs");
|
208 |
JSONArray docs = solrResponseJSONObj.getJSONArray("docs");
|
| 209 |
List<FofoCatalogResponse> dealResponse = getCatalogSingleSkuResponse(docs, false);
|
209 |
List<FofoCatalogResponse> dealResponse = getCatalogSingleSkuResponse(docs, false);
|
| - |
|
210 |
dealResponse = dealResponse.stream()
|
| 210 |
dealResponse = dealResponse.stream().filter(x->itemIdsQtyMap.keySet().contains((int)x.getItems().get(0).getItem_id()))
|
211 |
//.filter(x->itemIdsQtyMap.keySet().contains((int)(x.getItems().get(0).getItem_id())))
|
| 211 |
.map(x->{
|
212 |
.map(x->{
|
| 212 |
FofoAvailabilityInfo fai = x.getItems().get(0);
|
213 |
FofoAvailabilityInfo fai = x.getItems().get(0);
|
| 213 |
fai.setAvailability(itemIdsQtyMap.get((int)fai.getItem_id()));
|
214 |
fai.setAvailability(itemIdsQtyMap.get((int)fai.getItem_id()));
|
| 214 |
return x;
|
215 |
return x;
|
| 215 |
}).collect(Collectors.toList());
|
216 |
}).collect(Collectors.toList());
|