| Line 203... |
Line 203... |
| 203 |
}
|
203 |
}
|
| 204 |
}
|
204 |
}
|
| 205 |
} catch (Exception e) {
|
205 |
} catch (Exception e) {
|
| 206 |
LOGGER.info("Chose item that doesn't exist");
|
206 |
LOGGER.info("Chose item that doesn't exist");
|
| 207 |
}
|
207 |
}
|
| 208 |
model.addAttribute("response", mvcResponseSender.createResponseString(pm));
|
208 |
model.addAttribute("response1", mvcResponseSender.createResponseString(pm));
|
| 209 |
return "response";
|
209 |
return "response";
|
| 210 |
}
|
210 |
}
|
| 211 |
|
211 |
|
| 212 |
@RequestMapping(value = "/item", method = RequestMethod.GET)
|
212 |
@RequestMapping(value = "/item", method = RequestMethod.GET)
|
| 213 |
public String getItemPricing(HttpServletRequest request, Model model, @RequestParam String query,
|
213 |
public String getItemPricing(HttpServletRequest request, Model model, @RequestParam String query,
|
| Line 218... |
Line 218... |
| 218 |
.getAllPartnerItemStringDescription(anyColor).parallelStream()
|
218 |
.getAllPartnerItemStringDescription(anyColor).parallelStream()
|
| 219 |
.filter(x -> x.getItemDescription().toLowerCase().matches(".*?" + query1 + ".*?"))
|
219 |
.filter(x -> x.getItemDescription().toLowerCase().matches(".*?" + query1 + ".*?"))
|
| 220 |
.collect(Collectors.toList());
|
220 |
.collect(Collectors.toList());
|
| 221 |
LOGGER.info("partnersItemDescription" + partnersItemDescription);
|
221 |
LOGGER.info("partnersItemDescription" + partnersItemDescription);
|
| 222 |
|
222 |
|
| 223 |
model.addAttribute("response", mvcResponseSender.createResponseString(partnersItemDescription));
|
223 |
model.addAttribute("response1", mvcResponseSender.createResponseString(partnersItemDescription));
|
| 224 |
return "response";
|
224 |
return "response";
|
| 225 |
}
|
225 |
}
|
| 226 |
|
226 |
|
| 227 |
@RequestMapping(value = "/price-drop/imes/download")
|
227 |
@RequestMapping(value = "/price-drop/imes/download")
|
| 228 |
public ResponseEntity<ByteArrayResource> downloadPriceDropImeis(HttpServletRequest request,
|
228 |
public ResponseEntity<ByteArrayResource> downloadPriceDropImeis(HttpServletRequest request,
|
| Line 247... |
Line 247... |
| 247 |
priceDrop.setPriceDropIn(priceDropProcessModel.getPriceDropIn());
|
247 |
priceDrop.setPriceDropIn(priceDropProcessModel.getPriceDropIn());
|
| 248 |
// priceDrop.setProcessTimestamp(LocalDateTime.now());
|
248 |
// priceDrop.setProcessTimestamp(LocalDateTime.now());
|
| 249 |
priceDropRepository.persist(priceDrop);
|
249 |
priceDropRepository.persist(priceDrop);
|
| 250 |
response = true;
|
250 |
response = true;
|
| 251 |
}
|
251 |
}
|
| 252 |
model.addAttribute("response", mvcResponseSender.createResponseString(response));
|
252 |
model.addAttribute("response1", mvcResponseSender.createResponseString(response));
|
| 253 |
return "response";
|
253 |
return "response";
|
| 254 |
}
|
254 |
}
|
| 255 |
|
255 |
|
| 256 |
@RequestMapping(value = "/priceDropImeis/{priceDropId}", method = RequestMethod.GET)
|
256 |
@RequestMapping(value = "/priceDropImeis/{priceDropId}", method = RequestMethod.GET)
|
| 257 |
public String priceDropStatus(HttpServletRequest request, @PathVariable int priceDropId, Model model)
|
257 |
public String priceDropStatus(HttpServletRequest request, @PathVariable int priceDropId, Model model)
|
| Line 289... |
Line 289... |
| 289 |
priceDropImeisModel.setPendingImeis(pendingImeis);
|
289 |
priceDropImeisModel.setPendingImeis(pendingImeis);
|
| 290 |
priceDropImeisModel.setPriceDropId(priceDropId);
|
290 |
priceDropImeisModel.setPriceDropId(priceDropId);
|
| 291 |
priceDropImeisModel.setApprovedImeis(approvedImeis);
|
291 |
priceDropImeisModel.setApprovedImeis(approvedImeis);
|
| 292 |
priceDropImeisModel.setHoldImeis(holdImeis);
|
292 |
priceDropImeisModel.setHoldImeis(holdImeis);
|
| 293 |
priceDropImeisModel.setRejectedImeis(rejectedImeis);
|
293 |
priceDropImeisModel.setRejectedImeis(rejectedImeis);
|
| 294 |
model.addAttribute("response", mvcResponseSender.createResponseString(priceDropImeisModel));
|
294 |
model.addAttribute("response1", mvcResponseSender.createResponseString(priceDropImeisModel));
|
| 295 |
return "response";
|
295 |
return "response";
|
| 296 |
}
|
296 |
}
|
| 297 |
|
297 |
|
| 298 |
@RequestMapping(value = "/processPriceDrop", method = RequestMethod.POST)
|
298 |
@RequestMapping(value = "/processPriceDrop", method = RequestMethod.POST)
|
| 299 |
public String processPriceDrop(HttpServletRequest request, @RequestBody PriceDropProcessModel priceDropProcessModel,
|
299 |
public String processPriceDrop(HttpServletRequest request, @RequestBody PriceDropProcessModel priceDropProcessModel,
|
| Line 305... |
Line 305... |
| 305 |
}
|
305 |
}
|
| 306 |
priceDrop.setProcessTimestamp(LocalDateTime.now());
|
306 |
priceDrop.setProcessTimestamp(LocalDateTime.now());
|
| 307 |
priceDropRepository.persist(priceDrop);
|
307 |
priceDropRepository.persist(priceDrop);
|
| 308 |
priceDropService.processPriceDrop(priceDrop.getId(), priceDropProcessModel.isActivatedOnly());
|
308 |
priceDropService.processPriceDrop(priceDrop.getId(), priceDropProcessModel.isActivatedOnly());
|
| 309 |
response = true;
|
309 |
response = true;
|
| 310 |
model.addAttribute("response", mvcResponseSender.createResponseString(response));
|
310 |
model.addAttribute("response1", mvcResponseSender.createResponseString(response));
|
| 311 |
return "response";
|
311 |
return "response";
|
| 312 |
}
|
312 |
}
|
| 313 |
|
313 |
|
| 314 |
@RequestMapping(value = "/priceDrop", method = RequestMethod.POST)
|
314 |
@RequestMapping(value = "/priceDrop", method = RequestMethod.POST)
|
| 315 |
public String addPriceDrop(HttpServletRequest request, Model model, @RequestBody PriceDropModel priceDropModel)
|
315 |
public String addPriceDrop(HttpServletRequest request, Model model, @RequestBody PriceDropModel priceDropModel)
|
| Line 379... |
Line 379... |
| 379 |
} else {
|
379 |
} else {
|
| 380 |
throw new ProfitMandiBusinessException("Price Drop", priceDropModel.getPd(),
|
380 |
throw new ProfitMandiBusinessException("Price Drop", priceDropModel.getPd(),
|
| 381 |
"Price Drop Should be greater than 0");
|
381 |
"Price Drop Should be greater than 0");
|
| 382 |
}
|
382 |
}
|
| 383 |
}
|
383 |
}
|
| 384 |
model.addAttribute("response", mvcResponseSender.createResponseString(response));
|
384 |
model.addAttribute("response1", mvcResponseSender.createResponseString(response));
|
| 385 |
return "response";
|
385 |
return "response";
|
| 386 |
}
|
386 |
}
|
| 387 |
|
387 |
|
| 388 |
private void sendPriceChangeNotification(PriceDrop priceDrop) throws ProfitMandiBusinessException {
|
388 |
private void sendPriceChangeNotification(PriceDrop priceDrop) throws ProfitMandiBusinessException {
|
| 389 |
List<Item> items = itemRepository.selectAllByCatalogItemId(priceDrop.getCatalogItemId());
|
389 |
List<Item> items = itemRepository.selectAllByCatalogItemId(priceDrop.getCatalogItemId());
|
| Line 482... |
Line 482... |
| 482 |
} else {
|
482 |
} else {
|
| 483 |
throw new ProfitMandiBusinessException("INVALID STATUS", "PENDING",
|
483 |
throw new ProfitMandiBusinessException("INVALID STATUS", "PENDING",
|
| 484 |
"Pending Status is allowed only for Hold IMIEs");
|
484 |
"Pending Status is allowed only for Hold IMIEs");
|
| 485 |
}
|
485 |
}
|
| 486 |
}
|
486 |
}
|
| 487 |
model.addAttribute("response", mvcResponseSender.createResponseString(true));
|
487 |
model.addAttribute("response1", mvcResponseSender.createResponseString(true));
|
| 488 |
return "response";
|
488 |
return "response";
|
| 489 |
}
|
489 |
}
|
| 490 |
|
490 |
|
| 491 |
// TODO:PD
|
491 |
// TODO:PD
|
| 492 |
List<PriceDropIMEI> priceDropIMEIs = priceDropIMEIRepository
|
492 |
List<PriceDropIMEI> priceDropIMEIs = priceDropIMEIRepository
|
| Line 519... |
Line 519... |
| 519 |
|
519 |
|
| 520 |
}
|
520 |
}
|
| 521 |
|
521 |
|
| 522 |
}
|
522 |
}
|
| 523 |
|
523 |
|
| 524 |
model.addAttribute("response", mvcResponseSender.createResponseString(true));
|
524 |
model.addAttribute("response1", mvcResponseSender.createResponseString(true));
|
| 525 |
return "response";
|
525 |
return "response";
|
| 526 |
|
526 |
|
| 527 |
}
|
527 |
}
|
| 528 |
|
528 |
|
| 529 |
private ByteArrayOutputStream getByteArrayOutputStream(LocalDateTime affectedOn, Integer catalogItemId,
|
529 |
private ByteArrayOutputStream getByteArrayOutputStream(LocalDateTime affectedOn, Integer catalogItemId,
|