| Line 11... |
Line 11... |
| 11 |
import com.spice.profitmandi.dao.entity.dtr.*;
|
11 |
import com.spice.profitmandi.dao.entity.dtr.*;
|
| 12 |
import com.spice.profitmandi.dao.entity.fofo.*;
|
12 |
import com.spice.profitmandi.dao.entity.fofo.*;
|
| 13 |
import com.spice.profitmandi.dao.entity.user.Location;
|
13 |
import com.spice.profitmandi.dao.entity.user.Location;
|
| 14 |
import com.spice.profitmandi.dao.entity.user.Promoter;
|
14 |
import com.spice.profitmandi.dao.entity.user.Promoter;
|
| 15 |
import com.spice.profitmandi.dao.entity.user.User;
|
15 |
import com.spice.profitmandi.dao.entity.user.User;
|
| - |
|
16 |
import com.spice.profitmandi.dao.entity.warehouse.Supplier;
|
| 16 |
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
|
17 |
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
|
| 17 |
import com.spice.profitmandi.dao.repository.cs.CsService;
|
18 |
import com.spice.profitmandi.dao.repository.cs.CsService;
|
| 18 |
import com.spice.profitmandi.dao.repository.cs.RetailerBrandsLimitService;
|
19 |
import com.spice.profitmandi.dao.repository.cs.RetailerBrandsLimitService;
|
| 19 |
import com.spice.profitmandi.dao.repository.dtr.*;
|
20 |
import com.spice.profitmandi.dao.repository.dtr.*;
|
| 20 |
import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeRepository;
|
21 |
import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeRepository;
|
| Line 557... |
Line 558... |
| 557 |
return "response";
|
558 |
return "response";
|
| 558 |
|
559 |
|
| 559 |
}
|
560 |
}
|
| 560 |
|
561 |
|
| 561 |
@RequestMapping(value = "/getPromoterInfo", method = RequestMethod.GET)
|
562 |
@RequestMapping(value = "/getPromoterInfo", method = RequestMethod.GET)
|
| - |
|
563 |
|
| 562 |
public String getPromoterInfo(HttpServletRequest request,
|
564 |
public String getShowPromoterInfo(HttpServletRequest request,
|
| 563 |
@RequestParam(name = "offset", defaultValue = "0") int offset,
|
565 |
@RequestParam(name = "offset", defaultValue = "0") int offset,
|
| 564 |
@RequestParam(name = "limit", defaultValue = "10") int limit,
|
566 |
@RequestParam(name = "limit", defaultValue = "10") int limit,
|
| 565 |
@RequestParam(name = "fofoId", required = false, defaultValue = "0") int fofoId, Model model)
|
567 |
@RequestParam(name = "fofoId", required = false, defaultValue = "0") int fofoId, Model model)
|
| 566 |
throws Exception {
|
568 |
throws Exception {
|
| 567 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
569 |
//LOGGER.info("requested url : " + request.getRequestURL().toString());
|
| 568 |
List<Promoter> promoterInfo = null;
|
570 |
List<Promoter> promoterInfo = null;
|
| - |
|
571 |
long size = 0;
|
| - |
|
572 |
|
| - |
|
573 |
List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().map(x -> x.getId())
|
| - |
|
574 |
.collect(Collectors.toList());
|
| - |
|
575 |
|
| - |
|
576 |
Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
|
| - |
|
577 |
|
| - |
|
578 |
Map<Integer, CustomRetailer> customRetailersMap = fofoIds.stream().map(x -> customRetailerMap.get(x))
|
| - |
|
579 |
.filter(x -> x != null).collect(Collectors.toList()).stream()
|
| - |
|
580 |
.collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
|
| - |
|
581 |
String customRetailers = JSONObject.valueToString(customRetailersMap.values());
|
| - |
|
582 |
Set<String> brands = inventoryService.getAllTagListingBrands(ProfitMandiConstants.MOBILE_CATEGORY_ID);
|
| - |
|
583 |
brands.add("Airtel");
|
| - |
|
584 |
brands.add("Vodafone");
|
| - |
|
585 |
brands.add("Idea");
|
| - |
|
586 |
LOGGER.info("brands" + brands);
|
| - |
|
587 |
model.addAttribute("customRetailers", customRetailers);
|
| - |
|
588 |
model.addAttribute("brands", brands);
|
| - |
|
589 |
|
| - |
|
590 |
if (fofoId != 0) {
|
| - |
|
591 |
promoterInfo = promoterRepository.selectAllPromoterByFofoIdStatus(fofoId, offset, limit,true);
|
| - |
|
592 |
|
| - |
|
593 |
//size = promoterRepository.selectPromoterCount(fofoId);
|
| - |
|
594 |
size = promoterInfo.size();
|
| - |
|
595 |
} else {
|
| - |
|
596 |
//rkb
|
| - |
|
597 |
promoterInfo = promoterRepository.selectAllPromoterStatus(offset, limit,true);
|
| - |
|
598 |
|
| - |
|
599 |
//size = promoterRepository.selectAllCount();
|
| - |
|
600 |
size = promoterInfo.size();
|
| - |
|
601 |
}
|
| - |
|
602 |
if (!promoterInfo.isEmpty()) {
|
| - |
|
603 |
Set<Integer> partnerIds = new HashSet<>();
|
| - |
|
604 |
|
| - |
|
605 |
for (Promoter promoterdetail : promoterInfo) {
|
| - |
|
606 |
partnerIds.add(promoterdetail.getRetailerId());
|
| - |
|
607 |
}
|
| - |
|
608 |
Map<Integer, CustomRetailer> partnersMap = null;
|
| - |
|
609 |
if (!partnerIds.equals(null)) {
|
| - |
|
610 |
LOGGER.info("partnerIds" + partnerIds);
|
| - |
|
611 |
|
| - |
|
612 |
partnersMap = partnerIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null)
|
| - |
|
613 |
.collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
|
| - |
|
614 |
|
| - |
|
615 |
}
|
| - |
|
616 |
|
| - |
|
617 |
LOGGER.info("partnerIds" + partnersMap);
|
| - |
|
618 |
model.addAttribute("promoterInfo", promoterInfo);
|
| - |
|
619 |
model.addAttribute("partnersMap", partnersMap);
|
| - |
|
620 |
model.addAttribute("start", offset + 1);
|
| - |
|
621 |
model.addAttribute("size", size);
|
| - |
|
622 |
model.addAttribute("url", "/getPaginatedPromoterInfo");
|
| - |
|
623 |
|
| - |
|
624 |
if (promoterInfo.size() < limit) {
|
| - |
|
625 |
model.addAttribute("end", offset + promoterInfo.size());
|
| - |
|
626 |
} else {
|
| - |
|
627 |
model.addAttribute("end", offset + limit);
|
| - |
|
628 |
}
|
| - |
|
629 |
} else {
|
| - |
|
630 |
model.addAttribute("promoterInfo", promoterInfo);
|
| - |
|
631 |
model.addAttribute("size", size);
|
| - |
|
632 |
}
|
| - |
|
633 |
return "promoter-info";
|
| 569 |
|
634 |
|
| - |
|
635 |
}
|
| - |
|
636 |
|
| - |
|
637 |
|
| - |
|
638 |
|
| - |
|
639 |
@RequestMapping(value = "/getPromoterInactive", method = RequestMethod.GET)
|
| - |
|
640 |
|
| - |
|
641 |
public String getShowPromoterInactiveInfo(HttpServletRequest request,
|
| - |
|
642 |
@RequestParam(name = "offset", defaultValue = "0") int offset,
|
| - |
|
643 |
@RequestParam(name = "limit", defaultValue = "10") int limit,
|
| - |
|
644 |
@RequestParam(name = "fofoId", required = false, defaultValue = "0") int fofoId, Model model)
|
| - |
|
645 |
throws Exception {
|
| - |
|
646 |
//LOGGER.info("requested url : " + request.getRequestURL().toString());
|
| - |
|
647 |
List<Promoter> promoterInfo = null;
|
| 570 |
long size = 0;
|
648 |
long size = 0;
|
| 571 |
|
649 |
|
| 572 |
List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().map(x -> x.getId())
|
650 |
List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().map(x -> x.getId())
|
| 573 |
.collect(Collectors.toList());
|
651 |
.collect(Collectors.toList());
|
| 574 |
|
652 |
|
| Line 585... |
Line 663... |
| 585 |
LOGGER.info("brands" + brands);
|
663 |
LOGGER.info("brands" + brands);
|
| 586 |
model.addAttribute("customRetailers", customRetailers);
|
664 |
model.addAttribute("customRetailers", customRetailers);
|
| 587 |
model.addAttribute("brands", brands);
|
665 |
model.addAttribute("brands", brands);
|
| 588 |
|
666 |
|
| 589 |
if (fofoId != 0) {
|
667 |
if (fofoId != 0) {
|
| 590 |
promoterInfo = promoterRepository.selectAllPromoterByFofoId(fofoId, offset, limit);
|
668 |
promoterInfo = promoterRepository.selectAllPromoterByFofoIdStatus(fofoId, offset, limit,false);
|
| 591 |
|
669 |
|
| 592 |
size = promoterRepository.selectPromoterCount(fofoId);
|
670 |
//size = promoterRepository.selectPromoterCount(fofoId);
|
| - |
|
671 |
size = promoterInfo.size();
|
| 593 |
|
672 |
|
| 594 |
} else {
|
673 |
} else {
|
| 595 |
//rkb
|
674 |
//rkb
|
| 596 |
promoterInfo = promoterRepository.selectAllPromoter(offset, limit);
|
675 |
promoterInfo = promoterRepository.selectAllPromoterStatus(offset, limit,false);
|
| 597 |
|
676 |
|
| 598 |
size = promoterRepository.selectAllCount();
|
677 |
//size = promoterRepository.selectAllCount();
|
| - |
|
678 |
size = promoterInfo.size();
|
| 599 |
|
679 |
|
| 600 |
}
|
680 |
}
|
| 601 |
if (!promoterInfo.isEmpty()) {
|
681 |
if (!promoterInfo.isEmpty()) {
|
| 602 |
Set<Integer> partnerIds = new HashSet<>();
|
682 |
Set<Integer> partnerIds = new HashSet<>();
|
| 603 |
|
683 |
|
| Line 616... |
Line 696... |
| 616 |
LOGGER.info("partnerIds" + partnersMap);
|
696 |
LOGGER.info("partnerIds" + partnersMap);
|
| 617 |
model.addAttribute("promoterInfo", promoterInfo);
|
697 |
model.addAttribute("promoterInfo", promoterInfo);
|
| 618 |
model.addAttribute("partnersMap", partnersMap);
|
698 |
model.addAttribute("partnersMap", partnersMap);
|
| 619 |
model.addAttribute("start", offset + 1);
|
699 |
model.addAttribute("start", offset + 1);
|
| 620 |
model.addAttribute("size", size);
|
700 |
model.addAttribute("size", size);
|
| 621 |
model.addAttribute("url", "/getPaginatedPromoterInfo");
|
701 |
model.addAttribute("url", "/getPaginatedPromoterInactiveInfo");
|
| 622 |
|
702 |
|
| 623 |
if (promoterInfo.size() < limit) {
|
703 |
if (promoterInfo.size() < limit) {
|
| 624 |
model.addAttribute("end", offset + promoterInfo.size());
|
704 |
model.addAttribute("end", offset + promoterInfo.size());
|
| 625 |
} else {
|
705 |
} else {
|
| 626 |
model.addAttribute("end", offset + limit);
|
706 |
model.addAttribute("end", offset + limit);
|
| 627 |
}
|
707 |
}
|
| 628 |
} else {
|
708 |
} else {
|
| 629 |
model.addAttribute("promoterInfo", promoterInfo);
|
709 |
model.addAttribute("promoterInfo", promoterInfo);
|
| 630 |
model.addAttribute("size", size);
|
710 |
model.addAttribute("size", size);
|
| 631 |
}
|
711 |
}
|
| 632 |
return "promoter-info";
|
712 |
return "promoter-inactive";
|
| 633 |
|
713 |
|
| 634 |
}
|
714 |
}
|
| 635 |
|
715 |
|
| - |
|
716 |
|
| 636 |
@RequestMapping(value = "/getPaginatedPromoterInfo", method = RequestMethod.GET)
|
717 |
@RequestMapping(value = "/getPaginatedPromoterInfo", method = RequestMethod.GET)
|
| 637 |
public String getPaginatedPromoterInfo(HttpServletRequest request,
|
718 |
public String getPaginatedPromoterInfo(HttpServletRequest request,
|
| 638 |
@RequestParam(name = "offset", defaultValue = "0") int offset,
|
719 |
@RequestParam(name = "offset", defaultValue = "0") int offset,
|
| 639 |
@RequestParam(name = "limit", defaultValue = "10") int limit,
|
720 |
@RequestParam(name = "limit", defaultValue = "10") int limit,
|
| 640 |
@RequestParam(name = "fofoId", required = false, defaultValue = "0") int fofoId, Model model)
|
721 |
@RequestParam(name = "fofoId", required = false, defaultValue = "0") int fofoId, Model model)
|
| 641 |
throws ProfitMandiBusinessException {
|
722 |
throws ProfitMandiBusinessException {
|
| 642 |
LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
|
723 |
LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
|
| 643 |
List<Promoter> promoterInfo = null;
|
724 |
List<Promoter> promoterInfo = null;
|
| 644 |
if (fofoId != 0) {
|
725 |
if (fofoId != 0) {
|
| 645 |
promoterInfo = promoterRepository.selectAllPromoterByFofoId(fofoId, offset, limit);
|
726 |
promoterInfo = promoterRepository.selectAllPromoterByFofoIdStatus(fofoId, offset, limit,true);
|
| 646 |
} else {
|
727 |
} else {
|
| 647 |
promoterInfo = promoterRepository.selectAllPromoter(offset, limit);
|
728 |
promoterInfo = promoterRepository.selectAllPromoterStatus(offset, limit,true);
|
| 648 |
}
|
729 |
}
|
| 649 |
LOGGER.info("promoterInfo" + promoterInfo);
|
730 |
LOGGER.info("promoterInfo" + promoterInfo);
|
| 650 |
if (!promoterInfo.isEmpty()) {
|
731 |
if (!promoterInfo.isEmpty()) {
|
| 651 |
Set<Integer> partnerIds = new HashSet<>();
|
732 |
Set<Integer> partnerIds = new HashSet<>();
|
| 652 |
|
733 |
|
| Line 673... |
Line 754... |
| 673 |
|
754 |
|
| 674 |
}
|
755 |
}
|
| 675 |
|
756 |
|
| 676 |
return "promoter-info-paginated";
|
757 |
return "promoter-info-paginated";
|
| 677 |
}
|
758 |
}
|
| - |
|
759 |
@RequestMapping(value = "/getPaginatedPromoterInactiveInfo", method = RequestMethod.GET)
|
| - |
|
760 |
public String getPaginatedPromoterInactiveInfo(HttpServletRequest request,
|
| - |
|
761 |
@RequestParam(name = "offset", defaultValue = "0") int offset,
|
| - |
|
762 |
@RequestParam(name = "limit", defaultValue = "10") int limit,
|
| - |
|
763 |
@RequestParam(name = "fofoId", required = false, defaultValue = "0") int fofoId, Model model)
|
| - |
|
764 |
throws ProfitMandiBusinessException {
|
| - |
|
765 |
LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
|
| - |
|
766 |
List<Promoter> promoterInfo = null;
|
| - |
|
767 |
if (fofoId != 0) {
|
| - |
|
768 |
promoterInfo = promoterRepository.selectAllPromoterByFofoIdStatus(fofoId, offset, limit,false);
|
| - |
|
769 |
} else {
|
| - |
|
770 |
promoterInfo = promoterRepository.selectAllPromoterStatus(offset, limit,false);
|
| - |
|
771 |
}
|
| - |
|
772 |
LOGGER.info("promoterInfo" + promoterInfo);
|
| - |
|
773 |
if (!promoterInfo.isEmpty()) {
|
| - |
|
774 |
Set<Integer> partnerIds = new HashSet<>();
|
| - |
|
775 |
|
| - |
|
776 |
for (Promoter promoterdetail : promoterInfo) {
|
| - |
|
777 |
partnerIds.add(promoterdetail.getRetailerId());
|
| - |
|
778 |
}
|
| - |
|
779 |
Map<Integer, CustomRetailer> partnersMap = null;
|
| - |
|
780 |
if (!partnerIds.equals(null)) {
|
| - |
|
781 |
LOGGER.info("partnerIds" + partnerIds);
|
| - |
|
782 |
|
| - |
|
783 |
Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
|
| - |
|
784 |
|
| - |
|
785 |
partnersMap = partnerIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null)
|
| - |
|
786 |
.collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
|
| - |
|
787 |
|
| - |
|
788 |
}
|
| - |
|
789 |
|
| - |
|
790 |
LOGGER.info("partnerIds" + partnersMap);
|
| - |
|
791 |
model.addAttribute("promoterInfo", promoterInfo);
|
| - |
|
792 |
model.addAttribute("partnersMap", partnersMap);
|
| - |
|
793 |
model.addAttribute("url", "/getPaginatedPromoterInactiveInfo");
|
| - |
|
794 |
} else {
|
| - |
|
795 |
model.addAttribute("promoterInfo", promoterInfo);
|
| - |
|
796 |
|
| - |
|
797 |
}
|
| - |
|
798 |
|
| - |
|
799 |
return "promoter-inactive-info-paginated";
|
| - |
|
800 |
}
|
| 678 |
|
801 |
|
| 679 |
@RequestMapping(value = "/createPromoter", method = RequestMethod.POST)
|
802 |
@RequestMapping(value = "/createPromoter", method = RequestMethod.POST)
|
| 680 |
public String createPromoter(HttpServletRequest request, @RequestBody PromoterDetailModel promoterdetailModel,
|
803 |
public String createPromoter(HttpServletRequest request, @RequestBody PromoterDetailModel promoterdetailModel,
|
| 681 |
Model model) throws Exception {
|
804 |
Model model) throws Exception {
|
| 682 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
805 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
| Line 715... |
Line 838... |
| 715 |
model.addAttribute("response1", mvcResponseSender.createResponseString(true));
|
838 |
model.addAttribute("response1", mvcResponseSender.createResponseString(true));
|
| 716 |
|
839 |
|
| 717 |
return "response";
|
840 |
return "response";
|
| 718 |
|
841 |
|
| 719 |
}
|
842 |
}
|
| - |
|
843 |
@RequestMapping(value = "/setPromoterInActive", method = RequestMethod.POST)
|
| - |
|
844 |
public String PromoterInActive(HttpServletRequest request, @RequestParam(name = "id", required = true, defaultValue = "0") int id, Model model) throws Exception {
|
| - |
|
845 |
|
| - |
|
846 |
Promoter promoter = promoterRepository.selectById(id);
|
| - |
|
847 |
|
| - |
|
848 |
promoter.setStatus(false);
|
| - |
|
849 |
|
| - |
|
850 |
model.addAttribute("response1", mvcResponseSender.createResponseString(true));
|
| - |
|
851 |
|
| - |
|
852 |
return "response";
|
| - |
|
853 |
}
|
| - |
|
854 |
|
| 720 |
|
855 |
|
| 721 |
@RequestMapping(value = "/removePromoterfromPartnerStore", method = RequestMethod.POST)
|
856 |
@RequestMapping(value = "/removePromoterfromPartnerStore", method = RequestMethod.POST)
|
| 722 |
public String removePromoterfromPartnerStore(HttpServletRequest request,
|
857 |
public String removePromoterfromPartnerStore(HttpServletRequest request,
|
| 723 |
@RequestParam(name = "id", defaultValue = "0") int id, Model model) throws Exception {
|
858 |
@RequestParam(name = "id", defaultValue = "0") int id, Model model) throws Exception {
|
| 724 |
|
859 |
|
| 725 |
Promoter promoter = promoterRepository.selectById(id);
|
860 |
Promoter promoter = promoterRepository.selectById(id);
|
| 726 |
|
- |
|
| 727 |
promoter.setStatus(false);
|
861 |
promoter.setStatus(false);
|
| 728 |
promoterRepository.persist(promoter);
|
862 |
model.addAttribute("response1", mvcResponseSender.createResponseString(true));
|
| 729 |
|
863 |
|
| - |
|
864 |
return "response";
|
| - |
|
865 |
}
|
| - |
|
866 |
@RequestMapping(value = "/activePromoterfromPartnerStore", method = RequestMethod.POST)
|
| - |
|
867 |
public String activePromoterfromPartnerStore(HttpServletRequest request,
|
| - |
|
868 |
@RequestParam(name = "id", defaultValue = "0") int id, Model model) throws Exception {
|
| - |
|
869 |
|
| - |
|
870 |
Promoter promoter = promoterRepository.selectById(id);
|
| - |
|
871 |
promoter.setStatus(true);
|
| 730 |
model.addAttribute("response1", mvcResponseSender.createResponseString(true));
|
872 |
model.addAttribute("response1", mvcResponseSender.createResponseString(true));
|
| 731 |
|
873 |
|
| 732 |
return "response";
|
874 |
return "response";
|
| 733 |
}
|
875 |
}
|
| 734 |
|
876 |
|